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 PromotionAcknowledgedByStageHandler
  • func (u *PromotionAcknowledgedByStageHandler[T]) Create(context.Context, event.TypedCreateEvent[T], ...)
  • func (u *PromotionAcknowledgedByStageHandler[T]) Delete(context.Context, event.TypedDeleteEvent[T], ...)
  • func (u *PromotionAcknowledgedByStageHandler[T]) Generic(context.Context, event.TypedGenericEvent[T], ...)
  • func (u *PromotionAcknowledgedByStageHandler[T]) Update(ctx context.Context, e 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], ...)
  • func (u *UpdatedArgoCDAppHandler[T]) Delete(context.Context, event.TypedDeleteEvent[T], ...)
  • func (u *UpdatedArgoCDAppHandler[T]) Generic(context.Context, event.TypedGenericEvent[T], ...)
  • 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,
	directivesEngine directives.Engine,
	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 PromotionAcknowledgedByStageHandler

type PromotionAcknowledgedByStageHandler[T any] struct{}

PromotionAcknowledgedByStageHandler is an event handler that enqueues a Promotion for reconciliation when it has been acknowledged by the Stage\ it is for.

func (*PromotionAcknowledgedByStageHandler[T]) Create

func (u *PromotionAcknowledgedByStageHandler[T]) Create(
	context.Context,
	event.TypedCreateEvent[T],
	workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Create implements TypedEventHandler.

func (*PromotionAcknowledgedByStageHandler[T]) Delete

func (u *PromotionAcknowledgedByStageHandler[T]) Delete(
	context.Context,
	event.TypedDeleteEvent[T],
	workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Delete implements TypedEventHandler.

func (*PromotionAcknowledgedByStageHandler[T]) Generic

func (u *PromotionAcknowledgedByStageHandler[T]) Generic(
	context.Context,
	event.TypedGenericEvent[T],
	workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Generic implements TypedEventHandler.

func (*PromotionAcknowledgedByStageHandler[T]) Update

func (u *PromotionAcknowledgedByStageHandler[T]) Update(
	ctx context.Context,
	e event.TypedUpdateEvent[T],
	wq workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Update implements TypedEventHandler.

type ReconcilerConfig

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

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.TypedRateLimitingInterface[reconcile.Request],
)

Create implements TypedEventHandler.

func (*UpdatedArgoCDAppHandler[T]) Delete

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

Delete implements TypedEventHandler.

func (*UpdatedArgoCDAppHandler[T]) Generic

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

Generic implements TypedEventHandler.

func (*UpdatedArgoCDAppHandler[T]) Update

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

Update implements TypedEventHandler.