INNER CODE UNIT · Go

triggerClientInitiatedProcessing

istio-ecosystem/admiral · admiral/pkg/clusters/admiralDatabaseClient.go:243

func triggerClientInitiatedProcessing(ctx context.Context, c ProcessClientDependencyRecord, remoteRegistry *RemoteRegistry, processingForMap map[string]string) error {
	if !common.ClientInitiatedProcessingEnabledForDynamicConfig() {
		return nil
	}

	txId := uuid.NewString()
	ctxLogger := log.WithField("task", common.ClientInitiatedProcessing)
	ctx = context.WithValue(ctx, "txId", txId)
	bypassPrefix := "bypass:"

	var processedGlobalIdentifiers []string
	for _, globalIdentifier := range processingForMap {
		var err error
		var bypass bool
		if strings.HasPrefix(globalIdentifier, bypassPrefix) {
			globalIdentifier = strings.TrimPrefix(globalIdentifier, bypassPrefix)
			bypass = true
		}

View source record →