promotions

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], workqueue.RateLimitingInterface)
  • func (e *EnqueueHighestPriorityPromotionHandler[T]) Delete(_ context.Context, evt event.TypedDeleteEvent[T], ...)
  • func (e *EnqueueHighestPriorityPromotionHandler[T]) Generic(context.Context, event.TypedGenericEvent[T], workqueue.RateLimitingInterface)
  • func (e *EnqueueHighestPriorityPromotionHandler[T]) Update(_ context.Context, evt event.TypedUpdateEvent[T], ...)
• type ReconcilerConfig
  • func ReconcilerConfigFromEnv() ReconcilerConfig
  • func (c ReconcilerConfig) Name() string
• type UpdatedArgoCDAppHandler
  • func (u *UpdatedArgoCDAppHandler[T]) Create(context.Context, event.TypedCreateEvent[T], workqueue.RateLimitingInterface)
  • func (u *UpdatedArgoCDAppHandler[T]) Delete(context.Context, event.TypedDeleteEvent[T], workqueue.RateLimitingInterface)
  • func (u *UpdatedArgoCDAppHandler[T]) Generic(context.Context, event.TypedGenericEvent[T], workqueue.RateLimitingInterface)
  • func (u *UpdatedArgoCDAppHandler[T]) Update(ctx context.Context, e event.TypedUpdateEvent[T], ...)

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[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

func (p ArgoCDAppOperationCompleted[T]) Create(event.TypedCreateEvent[T]) bool

func (ArgoCDAppOperationCompleted[T]) Delete

func (p ArgoCDAppOperationCompleted[T]) Delete(event.TypedDeleteEvent[T]) bool

func (ArgoCDAppOperationCompleted[T]) Generic

func (p ArgoCDAppOperationCompleted[T]) Generic(event.TypedGenericEvent[T]) bool

func (ArgoCDAppOperationCompleted[T]) Update

func (p ArgoCDAppOperationCompleted[T]) Update(e event.TypedUpdateEvent[T]) bool

type EnqueueHighestPriorityPromotionHandler

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

func (e *EnqueueHighestPriorityPromotionHandler[T]) Create(
	context.Context,
	event.TypedCreateEvent[T],
	workqueue.RateLimitingInterface,
)

Create implements TypedEventHandler.

func (*EnqueueHighestPriorityPromotionHandler[T]) Delete

func (e *EnqueueHighestPriorityPromotionHandler[T]) Delete(
	_ context.Context,
	evt event.TypedDeleteEvent[T],
	wq workqueue.RateLimitingInterface,
)

Delete implements TypedEventHandler. In case a Running promotion becomes deleted, we should enqueue the next one

func (*EnqueueHighestPriorityPromotionHandler[T]) Generic

func (e *EnqueueHighestPriorityPromotionHandler[T]) Generic(
	context.Context,
	event.TypedGenericEvent[T],
	workqueue.RateLimitingInterface,
)

Generic implements TypedEventHandler.

func (*EnqueueHighestPriorityPromotionHandler[T]) Update

func (e *EnqueueHighestPriorityPromotionHandler[T]) Update(
	_ context.Context,
	evt event.TypedUpdateEvent[T],
	wq workqueue.RateLimitingInterface,
)

Update implements TypedEventHandler. 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[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

func (u *UpdatedArgoCDAppHandler[T]) Create(
	context.Context,
	event.TypedCreateEvent[T],
	workqueue.RateLimitingInterface,
)

Create implements TypedEventHandler.

func (*UpdatedArgoCDAppHandler[T]) Delete

func (u *UpdatedArgoCDAppHandler[T]) Delete(
	context.Context,
	event.TypedDeleteEvent[T],
	workqueue.RateLimitingInterface,
)

Delete implements TypedEventHandler.

func (*UpdatedArgoCDAppHandler[T]) Generic

func (u *UpdatedArgoCDAppHandler[T]) Generic(
	context.Context,
	event.TypedGenericEvent[T],
	workqueue.RateLimitingInterface,
)

Generic implements TypedEventHandler.

func (*UpdatedArgoCDAppHandler[T]) Update

func (u *UpdatedArgoCDAppHandler[T]) Update(
	ctx context.Context,
	e event.TypedUpdateEvent[T],
	wq workqueue.RateLimitingInterface,
)

Update implements TypedEventHandler.