Documentation
¶
Index ¶
- func SetupReconcilerWithManager(ctx context.Context, kargoMgr manager.Manager, argocdMgr manager.Manager, ...) error
- type ArgoCDAppOperationCompleted
- func (p ArgoCDAppOperationCompleted[T]) Create(event.TypedCreateEvent[T]) bool
- func (p ArgoCDAppOperationCompleted[T]) Delete(event.TypedDeleteEvent[T]) bool
- func (p ArgoCDAppOperationCompleted[T]) Generic(event.TypedGenericEvent[T]) bool
- func (p ArgoCDAppOperationCompleted[T]) Update(e event.TypedUpdateEvent[T]) bool
- type PromotionAcknowledgedByStageHandler
- func (p *PromotionAcknowledgedByStageHandler[T]) Create(context.Context, event.TypedCreateEvent[T], ...)
- func (p *PromotionAcknowledgedByStageHandler[T]) Delete(context.Context, event.TypedDeleteEvent[T], ...)
- func (p *PromotionAcknowledgedByStageHandler[T]) Generic(context.Context, event.TypedGenericEvent[T], ...)
- func (p *PromotionAcknowledgedByStageHandler[T]) Update(ctx context.Context, e event.TypedUpdateEvent[T], ...)
- type ReconcilerConfig
- type UpdatedArgoCDAppHandler
- func (u *UpdatedArgoCDAppHandler[T]) Create(context.Context, event.TypedCreateEvent[T], ...)
- func (u *UpdatedArgoCDAppHandler[T]) Delete(context.Context, event.TypedDeleteEvent[T], ...)
- func (u *UpdatedArgoCDAppHandler[T]) Generic(context.Context, event.TypedGenericEvent[T], ...)
- func (u *UpdatedArgoCDAppHandler[T]) Update(ctx context.Context, e event.TypedUpdateEvent[T], ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetupReconcilerWithManager ¶
func SetupReconcilerWithManager( ctx context.Context, kargoMgr manager.Manager, argocdMgr manager.Manager, promoEngine promotion.Engine, cfg ReconcilerConfig, ) error
SetupReconcilerWithManager initializes a reconciler for Promotion resources and registers it with the provided Manager.
Types ¶
type ArgoCDAppOperationCompleted ¶
type ArgoCDAppOperationCompleted[T any] struct { // contains filtered or unexported fields }
ArgoCDAppOperationCompleted is a predicate that filters out ArgoCD Application Update events where the operation has completed. This is useful for triggering a reconciliation of a Promotion only when an ArgoCD Application operation has finished.
func (ArgoCDAppOperationCompleted[T]) Create ¶
func (p ArgoCDAppOperationCompleted[T]) Create(event.TypedCreateEvent[T]) bool
func (ArgoCDAppOperationCompleted[T]) Delete ¶
func (p ArgoCDAppOperationCompleted[T]) Delete(event.TypedDeleteEvent[T]) bool
func (ArgoCDAppOperationCompleted[T]) Generic ¶
func (p ArgoCDAppOperationCompleted[T]) Generic(event.TypedGenericEvent[T]) bool
func (ArgoCDAppOperationCompleted[T]) Update ¶
func (p ArgoCDAppOperationCompleted[T]) Update(e event.TypedUpdateEvent[T]) bool
type PromotionAcknowledgedByStageHandler ¶
type PromotionAcknowledgedByStageHandler[T any] struct { // contains filtered or unexported fields }
PromotionAcknowledgedByStageHandler is an event handler that enqueues a Promotion for reconciliation when it has been acknowledged by the Stage\ it is for.
func (*PromotionAcknowledgedByStageHandler[T]) Create ¶
func (p *PromotionAcknowledgedByStageHandler[T]) Create( context.Context, event.TypedCreateEvent[T], workqueue.TypedRateLimitingInterface[reconcile.Request], )
Create implements TypedEventHandler.
func (*PromotionAcknowledgedByStageHandler[T]) Delete ¶
func (p *PromotionAcknowledgedByStageHandler[T]) Delete( context.Context, event.TypedDeleteEvent[T], workqueue.TypedRateLimitingInterface[reconcile.Request], )
Delete implements TypedEventHandler.
func (*PromotionAcknowledgedByStageHandler[T]) Generic ¶
func (p *PromotionAcknowledgedByStageHandler[T]) Generic( context.Context, event.TypedGenericEvent[T], workqueue.TypedRateLimitingInterface[reconcile.Request], )
Generic implements TypedEventHandler.
func (*PromotionAcknowledgedByStageHandler[T]) Update ¶
func (p *PromotionAcknowledgedByStageHandler[T]) Update( ctx context.Context, e event.TypedUpdateEvent[T], wq workqueue.TypedRateLimitingInterface[reconcile.Request], )
Update implements TypedEventHandler.
type ReconcilerConfig ¶
type ReconcilerConfig struct {
IsDefaultController bool `envconfig:"IS_DEFAULT_CONTROLLER"`
ShardName string `envconfig:"SHARD_NAME"`
APIServerBaseURL string `envconfig:"API_SERVER_BASE_URL"`
MaxConcurrentReconciles int `envconfig:"MAX_CONCURRENT_PROMOTION_RECONCILES" default:"4"`
}
ReconcilerConfig represents configuration for the promotion reconciler.
func ReconcilerConfigFromEnv ¶
func ReconcilerConfigFromEnv() ReconcilerConfig
func (ReconcilerConfig) Name ¶
func (c ReconcilerConfig) Name() string
type UpdatedArgoCDAppHandler ¶
type UpdatedArgoCDAppHandler[T any] struct { // contains filtered or unexported fields }
UpdatedArgoCDAppHandler is an event handler that enqueues Promotions for reconciliation when an associated ArgoCD Application is updated.
func (*UpdatedArgoCDAppHandler[T]) Create ¶
func (u *UpdatedArgoCDAppHandler[T]) Create( context.Context, event.TypedCreateEvent[T], workqueue.TypedRateLimitingInterface[reconcile.Request], )
Create implements TypedEventHandler.
func (*UpdatedArgoCDAppHandler[T]) Delete ¶
func (u *UpdatedArgoCDAppHandler[T]) Delete( context.Context, event.TypedDeleteEvent[T], workqueue.TypedRateLimitingInterface[reconcile.Request], )
Delete implements TypedEventHandler.
func (*UpdatedArgoCDAppHandler[T]) Generic ¶
func (u *UpdatedArgoCDAppHandler[T]) Generic( context.Context, event.TypedGenericEvent[T], workqueue.TypedRateLimitingInterface[reconcile.Request], )
Generic implements TypedEventHandler.
func (*UpdatedArgoCDAppHandler[T]) Update ¶
func (u *UpdatedArgoCDAppHandler[T]) Update( ctx context.Context, e event.TypedUpdateEvent[T], wq workqueue.TypedRateLimitingInterface[reconcile.Request], )
Update implements TypedEventHandler.
Source Files
Click to show internal directories.
Click to hide internal directories.