INNER CODE UNIT · Go

removeProcessedIdentities

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

func removeProcessedIdentities(processedGlobalIdentifiers []string, processingForMap map[string]string) int {
	for _, globalIdentifier := range processedGlobalIdentifiers {
		delete(processingForMap, globalIdentifier)
	}
	var unprocessed []string
	for k := range processingForMap {
		unprocessed = append(unprocessed, k)
	}
	currentParams := common.GetAdmiralParams()
	currentParams.InitiateClientInitiatedProcessingFor = unprocessed
	common.UpdateAdmiralParams(currentParams)
	return len(unprocessed)
}

func processLBMigration(ctx context.Context, rr *RemoteRegistry, updatedLBs []string, existingCache *[]string, lbLabel string) {

	ctxLogger := log.WithField("task", common.LBUpdateProcessor)

View source record →