Documentation
¶
Index ¶
- func SetupReconcilerWithManager(ctx context.Context, kargoMgr manager.Manager, argocdMgr manager.Manager, ...) error
- 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)
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, shardName string, ) error
SetupReconcilerWithManager initializes a reconciler for Promotion resources and registers it with the provided Manager.
Types ¶
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.
Source Files
Click to show internal directories.
Click to hide internal directories.