utils

Jul 21, 2021

Changes in this version

+ func GetAppsByHealthStatusCode(apps []argov1alpha1.Application, code health.HealthStatusCode) []argov1alpha1.Application

+ func GetAppsBySyncStatusCode(apps []argov1alpha1.Application, code argov1alpha1.SyncStatusCode) []argov1alpha1.Application

+ func GetAppsName(apps []argov1alpha1.Application) string

+ func GetClustersName(clusters []corev1.Secret) string

+ func GetSyncedAppsByStage(apps []argov1alpha1.Application, stage syncv1alpha1.ProgressiveSyncStage, ...) []argov1alpha1.Application

+ func IsArgoCDCluster(labels map[string]string) bool

+ func SortAppsByName(apps []argov1alpha1.Application)

+ func SortSecretsByName(secrets *corev1.SecretList)

+ type ArgoCDAppClient interface

+ Sync func(ctx context.Context, in *applicationpkg.ApplicationSyncRequest, ...) (*v1alpha1.Application, error)

+ func GetArgoCDAppClient(c Configuration) ArgoCDAppClient

+ type Configuration struct

+ ArgoCDAuthToken string

+ ArgoCDInsecure bool

+ ArgoCDServerAddr string

+ func ReadConfiguration() (Configuration, error)

+ type InMemorySyncState struct

+ MaxParallelPerStage map[string]int

+ MaxTargetsPerStage map[string]int

+ Mutex *sync.Mutex

+ Name string

+ SyncedAppsPerStage map[string]int

+ SyncedAtStage map[string]string

+ func (s *InMemorySyncState) GetMaxParallel(stage syncv1alpha1.ProgressiveSyncStage) int

+ func (s *InMemorySyncState) GetMaxTargets(stage syncv1alpha1.ProgressiveSyncStage) int

+ func (s *InMemorySyncState) IsAppMarkedInStage(app argov1alpha1.Application, stage syncv1alpha1.ProgressiveSyncStage) bool

+ func (s *InMemorySyncState) MarkAppAsSynced(app argov1alpha1.Application, stage syncv1alpha1.ProgressiveSyncStage)

+ func (s *InMemorySyncState) RefreshState(apps []argov1alpha1.Application, stage syncv1alpha1.ProgressiveSyncStage)

+ type ProgressiveSyncState interface

+ GetMaxParallel func(stage syncv1alpha1.ProgressiveSyncStage) int

+ GetMaxTargets func(stage syncv1alpha1.ProgressiveSyncStage) int

+ IsAppMarkedInStage func(app argov1alpha1.Application, stage syncv1alpha1.ProgressiveSyncStage) bool

+ MarkAppAsSynced func(app argov1alpha1.Application, stage syncv1alpha1.ProgressiveSyncStage)

+ RefreshState func(apps []argov1alpha1.Application, stage syncv1alpha1.ProgressiveSyncStage)

+ type ProgressiveSyncStateManager interface

+ Get func(name string) (ProgressiveSyncState, error)

+ func NewProgressiveSyncManager() ProgressiveSyncStateManager

+ type ProgressiveSyncStateManagerImpl struct

+ Mutex *sync.Mutex

+ func (p *ProgressiveSyncStateManagerImpl) Get(name string) (ProgressiveSyncState, error)