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 EnqueueHighestPriorityPromotionHandler
- func (e *EnqueueHighestPriorityPromotionHandler[T]) Create(context.Context, event.TypedCreateEvent[T], ...)
- func (e *EnqueueHighestPriorityPromotionHandler[T]) Delete(_ context.Context, evt event.TypedDeleteEvent[T], ...)
- func (e *EnqueueHighestPriorityPromotionHandler[T]) Generic(context.Context, event.TypedGenericEvent[T], ...)
- func (e *EnqueueHighestPriorityPromotionHandler[T]) Update(_ context.Context, evt 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, directivesEngine directives.Engine, promotionMechanisms promotion.Mechanism, cfg ReconcilerConfig, ) error
SetupReconcilerWithManager initializes a reconciler for Promotion resources and registers it with the provided Manager.
Types ¶
type ArgoCDAppOperationCompleted ¶ added in v0.6.0
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 ¶ added in v0.6.0
func (p ArgoCDAppOperationCompleted[T]) Create(event.TypedCreateEvent[T]) bool
func (ArgoCDAppOperationCompleted[T]) Delete ¶ added in v0.6.0
func (p ArgoCDAppOperationCompleted[T]) Delete(event.TypedDeleteEvent[T]) bool
func (ArgoCDAppOperationCompleted[T]) Generic ¶ added in v0.6.0
func (p ArgoCDAppOperationCompleted[T]) Generic(event.TypedGenericEvent[T]) bool
func (ArgoCDAppOperationCompleted[T]) Update ¶ added in v0.6.0
func (p ArgoCDAppOperationCompleted[T]) Update(e event.TypedUpdateEvent[T]) bool
type EnqueueHighestPriorityPromotionHandler ¶ added in v0.2.0
type EnqueueHighestPriorityPromotionHandler[T any] struct { // contains filtered or unexported fields }
EnqueueHighestPriorityPromotionHandler is an event handler that enqueues the next highest priority Promotion for reconciliation when an active Promotion becomes terminal
func (*EnqueueHighestPriorityPromotionHandler[T]) Create ¶ added in v0.2.0
func (e *EnqueueHighestPriorityPromotionHandler[T]) Create( context.Context, event.TypedCreateEvent[T], workqueue.TypedRateLimitingInterface[reconcile.Request], )
Create implements TypedEventHandler.
func (*EnqueueHighestPriorityPromotionHandler[T]) Delete ¶ added in v0.2.0
func (e *EnqueueHighestPriorityPromotionHandler[T]) Delete( _ context.Context, evt event.TypedDeleteEvent[T], wq workqueue.TypedRateLimitingInterface[reconcile.Request], )
Delete implements TypedEventHandler. In case a Running promotion becomes deleted, we should enqueue the next one
func (*EnqueueHighestPriorityPromotionHandler[T]) Generic ¶ added in v0.2.0
func (e *EnqueueHighestPriorityPromotionHandler[T]) Generic( context.Context, event.TypedGenericEvent[T], workqueue.TypedRateLimitingInterface[reconcile.Request], )
Generic implements TypedEventHandler.
func (*EnqueueHighestPriorityPromotionHandler[T]) Update ¶ added in v0.2.0
func (e *EnqueueHighestPriorityPromotionHandler[T]) Update( _ context.Context, evt event.TypedUpdateEvent[T], wq workqueue.TypedRateLimitingInterface[reconcile.Request], )
Update implements TypedEventHandler. This should only be called with a promo that transitioned from non-terminal to terminal.
type ReconcilerConfig ¶ added in v0.6.0
type ReconcilerConfig struct {
ShardName string `envconfig:"SHARD_NAME"`
}
ReconcilerConfig represents configuration for the promotion reconciler.
func ReconcilerConfigFromEnv ¶ added in v0.6.0
func ReconcilerConfigFromEnv() ReconcilerConfig
func (ReconcilerConfig) Name ¶ added in v0.6.0
func (c ReconcilerConfig) Name() string
type UpdatedArgoCDAppHandler ¶ added in v0.6.0
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 ¶ added in v0.6.0
func (u *UpdatedArgoCDAppHandler[T]) Create( context.Context, event.TypedCreateEvent[T], workqueue.TypedRateLimitingInterface[reconcile.Request], )
Create implements TypedEventHandler.
func (*UpdatedArgoCDAppHandler[T]) Delete ¶ added in v0.6.0
func (u *UpdatedArgoCDAppHandler[T]) Delete( context.Context, event.TypedDeleteEvent[T], workqueue.TypedRateLimitingInterface[reconcile.Request], )
Delete implements TypedEventHandler.
func (*UpdatedArgoCDAppHandler[T]) Generic ¶ added in v0.6.0
func (u *UpdatedArgoCDAppHandler[T]) Generic( context.Context, event.TypedGenericEvent[T], workqueue.TypedRateLimitingInterface[reconcile.Request], )
Generic implements TypedEventHandler.
func (*UpdatedArgoCDAppHandler[T]) Update ¶ added in v0.6.0
func (u *UpdatedArgoCDAppHandler[T]) Update( ctx context.Context, e event.TypedUpdateEvent[T], wq workqueue.TypedRateLimitingInterface[reconcile.Request], )
Update implements TypedEventHandler.