promotions

Documentation

Index

• func SetupReconcilerWithManager(ctx context.Context, kargoMgr manager.Manager, argocdMgr manager.Manager, ...) error
• type ArgoCDAppOperationCompleted
  • func (p ArgoCDAppOperationCompleted) Create(event.CreateEvent) bool
  • func (p ArgoCDAppOperationCompleted) Delete(event.DeleteEvent) bool
  • func (p ArgoCDAppOperationCompleted) Generic(event.GenericEvent) bool
  • func (p ArgoCDAppOperationCompleted) Update(e event.UpdateEvent) bool
• 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
  • func ReconcilerConfigFromEnv() ReconcilerConfig
  • func (c ReconcilerConfig) Name() string
• 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)

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

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

func (p ArgoCDAppOperationCompleted) Create(event.CreateEvent) bool

func (ArgoCDAppOperationCompleted) Delete

func (p ArgoCDAppOperationCompleted) Delete(event.DeleteEvent) bool

func (ArgoCDAppOperationCompleted) Generic

func (p ArgoCDAppOperationCompleted) Generic(event.GenericEvent) bool

func (ArgoCDAppOperationCompleted) Update

func (p ArgoCDAppOperationCompleted) Update(e event.UpdateEvent) bool

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.

type ReconcilerConfig

type ReconcilerConfig struct {
	ShardName string `envconfig:"SHARD_NAME"`
}

ReconcilerConfig represents configuration for the promotion reconciler.

func ReconcilerConfigFromEnv

func ReconcilerConfigFromEnv() ReconcilerConfig

func (ReconcilerConfig) Name

func (c ReconcilerConfig) Name() string

type UpdatedArgoCDAppHandler

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

func (u *UpdatedArgoCDAppHandler) Create(
	context.Context,
	event.CreateEvent,
	workqueue.RateLimitingInterface,
)

Create implements EventHandler.

func (*UpdatedArgoCDAppHandler) Delete

func (u *UpdatedArgoCDAppHandler) Delete(
	context.Context,
	event.DeleteEvent,
	workqueue.RateLimitingInterface,
)

Delete implements EventHandler.

func (*UpdatedArgoCDAppHandler) Generic

func (u *UpdatedArgoCDAppHandler) Generic(
	context.Context,
	event.GenericEvent,
	workqueue.RateLimitingInterface,
)

Generic implements EventHandler.

func (*UpdatedArgoCDAppHandler) Update

func (u *UpdatedArgoCDAppHandler) Update(
	ctx context.Context,
	e event.UpdateEvent,
	wq workqueue.RateLimitingInterface,
)

Update implements EventHandler.