stages

Documentation

Index

• func SetupReconcilerWithManager(ctx context.Context, kargoMgr manager.Manager, argoMgr manager.Manager, ...) error
• type EnqueueDownstreamStagesHandler
  • func (e *EnqueueDownstreamStagesHandler) Create(_ event.CreateEvent, _ workqueue.RateLimitingInterface)
  • func (e *EnqueueDownstreamStagesHandler) Delete(_ event.DeleteEvent, _ workqueue.RateLimitingInterface)
  • func (e *EnqueueDownstreamStagesHandler) Generic(_ event.GenericEvent, _ workqueue.RateLimitingInterface)
  • func (e *EnqueueDownstreamStagesHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
• type PromoWentTerminal
  • func (p PromoWentTerminal) Create(_ event.CreateEvent) bool
  • func (p PromoWentTerminal) Delete(e event.DeleteEvent) bool
  • func (p PromoWentTerminal) Generic(_ event.GenericEvent) bool
  • func (p PromoWentTerminal) Update(e event.UpdateEvent) bool

Functions

func SetupReconcilerWithManager

func SetupReconcilerWithManager(
	ctx context.Context,
	kargoMgr manager.Manager,
	argoMgr manager.Manager,
	credentialsDB credentials.Database,
	shardName string,
) error

SetupReconcilerWithManager initializes a reconciler for Stage resources and registers it with the provided Manager.

Types

type EnqueueDownstreamStagesHandler

type EnqueueDownstreamStagesHandler struct {
	// contains filtered or unexported fields
}

EnqueueDownstreamStagesHandler is an event handler that enqueues downstream Stages if a Stage's history has been modified, so that those stages can update their availableFreight.

func (*EnqueueDownstreamStagesHandler) Create

func (e *EnqueueDownstreamStagesHandler) Create(_ event.CreateEvent, _ workqueue.RateLimitingInterface)

Create implements EventHandler.

func (*EnqueueDownstreamStagesHandler) Delete

func (e *EnqueueDownstreamStagesHandler) Delete(_ event.DeleteEvent, _ workqueue.RateLimitingInterface)

Delete implements EventHandler.

func (*EnqueueDownstreamStagesHandler) Generic

func (e *EnqueueDownstreamStagesHandler) Generic(_ event.GenericEvent, _ workqueue.RateLimitingInterface)

Generic implements EventHandler.

func (*EnqueueDownstreamStagesHandler) Update

func (e *EnqueueDownstreamStagesHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

Update implements EventHandler.

type PromoWentTerminal

type PromoWentTerminal struct {
	predicate.Funcs
	// contains filtered or unexported fields
}

PromoWentTerminal is a predicate that returns true if a promotion went terminal

func (PromoWentTerminal) Create

func (p PromoWentTerminal) Create(_ event.CreateEvent) bool

func (PromoWentTerminal) Delete

func (p PromoWentTerminal) Delete(e event.DeleteEvent) bool

func (PromoWentTerminal) Generic

func (p PromoWentTerminal) Generic(_ event.GenericEvent) bool

func (PromoWentTerminal) Update

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

Update implements default UpdateEvent filter for checking if a promotion went terminal