Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶ added in v0.4.0
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 ¶ added in v0.4.0
func ReconcilerConfigFromEnv() ReconcilerConfig
ReconcilerConfigFromEnv returns a new ReconcilerConfig populated from the environment variables.
func (ReconcilerConfig) Name ¶ added in v0.6.0
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) 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.
Source Files