Documentation ¶
Index ¶
- func SetupReconcilerWithManager(ctx context.Context, kargoMgr manager.Manager, argocdMgr manager.Manager, ...) error
- type ArgoCDAppOperationCompleted
- type EnqueueHighestPriorityPromotionHandler
- func (e *EnqueueHighestPriorityPromotionHandler) Create(context.Context, event.CreateEvent, workqueue.RateLimitingInterface)
- func (e *EnqueueHighestPriorityPromotionHandler) Delete(_ context.Context, evt event.DeleteEvent, wq workqueue.RateLimitingInterface)
- func (e *EnqueueHighestPriorityPromotionHandler) Generic(context.Context, event.GenericEvent, workqueue.RateLimitingInterface)
- func (e *EnqueueHighestPriorityPromotionHandler) Update(_ context.Context, evt event.UpdateEvent, wq workqueue.RateLimitingInterface)
- type ReconcilerConfig
- type UpdatedArgoCDAppHandler
- func (u *UpdatedArgoCDAppHandler) Create(context.Context, event.CreateEvent, workqueue.RateLimitingInterface)
- func (u *UpdatedArgoCDAppHandler) Delete(context.Context, event.DeleteEvent, workqueue.RateLimitingInterface)
- func (u *UpdatedArgoCDAppHandler) Generic(context.Context, event.GenericEvent, workqueue.RateLimitingInterface)
- func (u *UpdatedArgoCDAppHandler) Update(ctx context.Context, e event.UpdateEvent, wq workqueue.RateLimitingInterface)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetupReconcilerWithManager ¶
func SetupReconcilerWithManager( ctx context.Context, kargoMgr manager.Manager, argocdMgr manager.Manager, credentialsDB credentials.Database, 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 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) Create ¶ added in v0.6.0
func (p ArgoCDAppOperationCompleted) Create(event.CreateEvent) bool
func (ArgoCDAppOperationCompleted) Delete ¶ added in v0.6.0
func (p ArgoCDAppOperationCompleted) Delete(event.DeleteEvent) bool
func (ArgoCDAppOperationCompleted) Generic ¶ added in v0.6.0
func (p ArgoCDAppOperationCompleted) Generic(event.GenericEvent) bool
func (ArgoCDAppOperationCompleted) Update ¶ added in v0.6.0
func (p ArgoCDAppOperationCompleted) Update(e event.UpdateEvent) bool
type EnqueueHighestPriorityPromotionHandler ¶ added in v0.2.0
type EnqueueHighestPriorityPromotionHandler 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) Create ¶ added in v0.2.0
func (e *EnqueueHighestPriorityPromotionHandler) Create( context.Context, event.CreateEvent, workqueue.RateLimitingInterface, )
Create implements EventHandler.
func (*EnqueueHighestPriorityPromotionHandler) Delete ¶ added in v0.2.0
func (e *EnqueueHighestPriorityPromotionHandler) Delete( _ context.Context, evt event.DeleteEvent, wq workqueue.RateLimitingInterface, )
Delete implements EventHandler. In case a Running promotion becomes deleted, we should enqueue the next one
func (*EnqueueHighestPriorityPromotionHandler) Generic ¶ added in v0.2.0
func (e *EnqueueHighestPriorityPromotionHandler) Generic( context.Context, event.GenericEvent, workqueue.RateLimitingInterface, )
Generic implements EventHandler.
func (*EnqueueHighestPriorityPromotionHandler) Update ¶ added in v0.2.0
func (e *EnqueueHighestPriorityPromotionHandler) Update( _ context.Context, evt event.UpdateEvent, wq workqueue.RateLimitingInterface, )
Update implements EventHandler. 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 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) Create ¶ added in v0.6.0
func (u *UpdatedArgoCDAppHandler) Create( context.Context, event.CreateEvent, workqueue.RateLimitingInterface, )
Create implements EventHandler.
func (*UpdatedArgoCDAppHandler) Delete ¶ added in v0.6.0
func (u *UpdatedArgoCDAppHandler) Delete( context.Context, event.DeleteEvent, workqueue.RateLimitingInterface, )
Delete implements EventHandler.
func (*UpdatedArgoCDAppHandler) Generic ¶ added in v0.6.0
func (u *UpdatedArgoCDAppHandler) Generic( context.Context, event.GenericEvent, workqueue.RateLimitingInterface, )
Generic implements EventHandler.
func (*UpdatedArgoCDAppHandler) Update ¶ added in v0.6.0
func (u *UpdatedArgoCDAppHandler) Update( ctx context.Context, e event.UpdateEvent, wq workqueue.RateLimitingInterface, )
Update implements EventHandler.