stages

Documentation

Index

• type ControlFlowStageReconciler
  • func NewControlFlowStageReconciler(cfg ReconcilerConfig) *ControlFlowStageReconciler
  • func (r *ControlFlowStageReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ControlFlowStageReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, sharedIndexer client.FieldIndexer) error
• type IsControlFlowStage
  • func (s IsControlFlowStage) Create(e event.CreateEvent) bool
  • func (s IsControlFlowStage) Delete(event.DeleteEvent) bool
  • func (s IsControlFlowStage) Generic(event.GenericEvent) bool
  • func (s IsControlFlowStage) Update(e event.UpdateEvent) bool
• type ReconcilerConfig
  • func ReconcilerConfigFromEnv() ReconcilerConfig
  • func (c ReconcilerConfig) Name() string
• type RegularStageReconciler
  • func NewRegularStageReconciler(cfg ReconcilerConfig, engine directives.Engine) *RegularStageReconciler
  • func (r *RegularStageReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *RegularStageReconciler) SetupWithManager(ctx context.Context, kargoMgr, argocdMgr ctrl.Manager, ...) error

Types

type ControlFlowStageReconciler

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

func NewControlFlowStageReconciler

func NewControlFlowStageReconciler(
	cfg ReconcilerConfig,
) *ControlFlowStageReconciler

NewControlFlowStageReconciler returns a new control flow Stage reconciler. After creating the reconciler, call SetupWithManager to register it with a controller manager.

func (*ControlFlowStageReconciler) Reconcile

func (r *ControlFlowStageReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile reconciles the given control flow Stage.

func (*ControlFlowStageReconciler) SetupWithManager

func (r *ControlFlowStageReconciler) SetupWithManager(
	ctx context.Context,
	mgr ctrl.Manager,
	sharedIndexer client.FieldIndexer,
) error

SetupWithManager sets up the control flow Stage reconciler with the given controller manager. It registers the reconciler with the manager and sets up watches on the required objects.

type IsControlFlowStage

type IsControlFlowStage bool

IsControlFlowStage is a predicate that filters out Stages based on whether they are control flow Stages or not.

func (IsControlFlowStage) Create

func (s IsControlFlowStage) Create(e event.CreateEvent) bool

func (IsControlFlowStage) Delete

func (s IsControlFlowStage) Delete(event.DeleteEvent) bool

func (IsControlFlowStage) Generic

func (s IsControlFlowStage) Generic(event.GenericEvent) bool

func (IsControlFlowStage) Update

func (s IsControlFlowStage) Update(e event.UpdateEvent) bool

type ReconcilerConfig

type ReconcilerConfig struct {
	ShardName                          string `envconfig:"SHARD_NAME"`
	RolloutsIntegrationEnabled         bool   `envconfig:"ROLLOUTS_INTEGRATION_ENABLED"`
	RolloutsControllerInstanceID       string `envconfig:"ROLLOUTS_CONTROLLER_INSTANCE_ID"`
	MaxConcurrentControlFlowReconciles int    `envconfig:"MAX_CONCURRENT_CONTROL_FLOW_RECONCILES" default:"4"`
	MaxConcurrentReconciles            int    `envconfig:"MAX_CONCURRENT_STAGE_RECONCILES" default:"4"`
}

ReconcilerConfig represents configuration for the stage reconciler.

func ReconcilerConfigFromEnv

func ReconcilerConfigFromEnv() ReconcilerConfig

ReconcilerConfigFromEnv returns a new ReconcilerConfig populated from the environment variables.

func (ReconcilerConfig) Name

func (c ReconcilerConfig) Name() string

Name returns the name of the Stage controller.

type RegularStageReconciler

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

func NewRegularStageReconciler

func NewRegularStageReconciler(cfg ReconcilerConfig, engine directives.Engine) *RegularStageReconciler

NewRegularStageReconciler creates a new Stages reconciler.

func (*RegularStageReconciler) Reconcile

func (r *RegularStageReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*RegularStageReconciler) SetupWithManager

func (r *RegularStageReconciler) SetupWithManager(
	ctx context.Context,
	kargoMgr, argocdMgr ctrl.Manager,
	sharedIndexer client.FieldIndexer,
) error

SetupWithManager sets up the Stage reconciler with the given controller manager. It registers the reconciler with the manager and sets up watches on the required objects.