argo

Jan 22, 2024

Changes in this version

+ func CreateArgoApplication(overview *api.GetOverviewResponse, app *api.Environment_Application, ...) *v1alpha1.Application

+ type ArgoAppProcessor struct

+ ApplicationClient application.ApplicationServiceClient

+ ManageArgoAppsEnabled bool

+ ManageArgoAppsFilter []string

+ func New(appClient application.ApplicationServiceClient, ...) ArgoAppProcessor

+ func (a *ArgoAppProcessor) Consume(ctx context.Context) error

+ func (a *ArgoAppProcessor) ConsumeArgo(ctx context.Context, hlth *setup.HealthReporter) error

+ func (a *ArgoAppProcessor) Push(ctx context.Context, last *api.GetOverviewResponse)

+ func (a ArgoAppProcessor) CreateOrUpdateApp(ctx context.Context, overview *api.GetOverviewResponse, ...)

+ func (a ArgoAppProcessor) DeleteArgoApps(ctx context.Context, argoApps map[string]*v1alpha1.Application, ...) error

+ type Key struct

+ AppName string

+ Application *api.Environment_Application

+ EnvName string

+ Environment *api.Environment

+ type SimplifiedApplicationServiceClient interface

+ Watch func(ctx context.Context, qry *application.ApplicationQuery, ...) (application.ApplicationService_WatchClient, error)