promotions

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)

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

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

func (e *EnqueueHighestPriorityPromotionHandler) Create(
	context.Context,
	event.CreateEvent,
	workqueue.RateLimitingInterface,
)

Create implements EventHandler.

func (*EnqueueHighestPriorityPromotionHandler) Delete

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

func (e *EnqueueHighestPriorityPromotionHandler) Generic(
	context.Context,
	event.GenericEvent,
	workqueue.RateLimitingInterface,
)

Generic implements EventHandler.

func (*EnqueueHighestPriorityPromotionHandler) Update

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.