pipelinerollout

func (*PipelineRolloutReconciler) AssessUpgradingChild ¶ added in v0.13.0

func (r *PipelineRolloutReconciler) AssessUpgradingChild(ctx context.Context, existingUpgradingChildDef *unstructured.Unstructured) (apiv1.AssessmentResult, error)

AssessUpgradingChild makes an assessment of the upgrading child to determine if it was successful, failed, or still not known Assessment: Success: phase must be "Running" and all conditions must be True Failure: phase is "Failed" or any condition is False Unknown: neither of the above if met This implements a function of the progressiveController interface

func (*PipelineRolloutReconciler) ChildNeedsUpdating ¶

func (r *PipelineRolloutReconciler) ChildNeedsUpdating(ctx context.Context, from, to *unstructured.Unstructured) (bool, error)

ChildNeedsUpdating() tests for essential equality, with any irrelevant fields eliminated from the comparison This implements a function of the progressiveController interface

func (*PipelineRolloutReconciler) CreateUpgradingChildDefinition ¶ added in v0.11.0

func (r *PipelineRolloutReconciler) CreateUpgradingChildDefinition(ctx context.Context, rolloutObject ctlrcommon.RolloutObject, name string) (*unstructured.Unstructured, error)

CreateUpgradingChildDefinition creates a definition for an "upgrading" pipeline This implements a function of the progressiveController interface

func (*PipelineRolloutReconciler) EnqueuePipeline ¶

func (r *PipelineRolloutReconciler) EnqueuePipeline(namespacedName k8stypes.NamespacedName)

func (*PipelineRolloutReconciler) ErrorHandler ¶

func (r *PipelineRolloutReconciler) ErrorHandler(pipelineRollout *apiv1.PipelineRollout, err error, reason, msg string)

func (*PipelineRolloutReconciler) IncrementChildCount ¶

func (r *PipelineRolloutReconciler) IncrementChildCount(ctx context.Context, rolloutObject ctlrcommon.RolloutObject) (int32, error)

IncrementChildCount increments the child count for the Rollout and returns the count to use This implements a function of the RolloutController interface

func (*PipelineRolloutReconciler) ProcessPromotedChildPostUpgrade ¶ added in v0.13.0

func (r *PipelineRolloutReconciler) ProcessPromotedChildPostUpgrade(
	ctx context.Context,
	rolloutPromotedChildStatus *apiv1.PromotedChildStatus,
	promotedChildDef *unstructured.Unstructured,
	c client.Client,
) (bool, error)

ProcessPromotedChildPostUpgrade handles the post-upgrade processing of a promoted pipeline. It performs the following post-upgrade operations: - it restores the promoted pipeline source vertices scale values to the desired values retrieved from the rollout status.

Parameters:

• ctx: the context for managing request-scoped values.
• rolloutPromotedChildStatus: the status of the promoted child, which may be updated during processing.
• promotedChildDef: the definition of the promoted child as an unstructured object.
• c: the client used for interacting with the Kubernetes API.

Returns:

• A boolean indicating whether we should requeue.
• An error if any issues occur during processing.

func (*PipelineRolloutReconciler) ProcessPromotedChildPreUpgrade ¶ added in v0.13.0

func (r *PipelineRolloutReconciler) ProcessPromotedChildPreUpgrade(
	ctx context.Context,
	rolloutPromotedChildStatus *apiv1.PromotedChildStatus,
	promotedChildDef *unstructured.Unstructured,
	c client.Client,
) (bool, error)

ProcessPromotedChildPreUpgrade handles the pre-upgrade processing of a promoted pipeline. It performs the following pre-upgrade operations: - it ensures that the promoted pipeline source vertices are scaled down before proceeding with a progressive upgrade.

Parameters:

• ctx: the context for managing request-scoped values.
• rolloutPromotedChildStatus: the status of the promoted child, which may be updated during processing.
• promotedChildDef: the definition of the promoted child as an unstructured object.
• c: the client used for interacting with the Kubernetes API.

Returns:

• A boolean indicating whether we should requeue.
• An error if any issues occur during processing.

func (*PipelineRolloutReconciler) Reconcile ¶

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.17.3/pkg/reconcile

func (*PipelineRolloutReconciler) Recycle ¶ added in v0.10.0

func (r *PipelineRolloutReconciler) Recycle(ctx context.Context,
	pipeline *unstructured.Unstructured,
	c client.Client,
) (bool, error)

Recycle deletes child; returns true if it was in fact deleted This implements a function of the RolloutController interface

func (*PipelineRolloutReconciler) SetupWithManager ¶

func (r *PipelineRolloutReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*PipelineRolloutReconciler) Shutdown ¶

func (r *PipelineRolloutReconciler) Shutdown(ctx context.Context)