monovertexrollout

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

func (r *MonoVertexRolloutReconciler) AssessUpgradingChild(ctx context.Context, rolloutObject progressive.ProgressiveRolloutObject, existingUpgradingChildDef *unstructured.Unstructured) (apiv1.AssessmentResult, string, error)

AssessUpgradingChild makes an assessment of the upgrading child to determine if it was successful, failed, or still not known This implements a function of the progressiveController interface

func (*MonoVertexRolloutReconciler) ChildNeedsUpdating ¶

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

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

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

func (r *MonoVertexRolloutReconciler) CreateUpgradingChildDefinition(ctx context.Context, rolloutObject progressive.ProgressiveRolloutObject, name string) (*unstructured.Unstructured, error)

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

func (*MonoVertexRolloutReconciler) ErrorHandler ¶

func (r *MonoVertexRolloutReconciler) ErrorHandler(ctx context.Context, monoVertexRollout *apiv1.MonoVertexRollout, err error, reason, msg string)

func (*MonoVertexRolloutReconciler) IncrementChildCount ¶

func (r *MonoVertexRolloutReconciler) 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 (*MonoVertexRolloutReconciler) ProcessPromotedChildPostFailure ¶ added in v0.14.0

func (r *MonoVertexRolloutReconciler) ProcessPromotedChildPostFailure(
	ctx context.Context,
	rolloutObject progressive.ProgressiveRolloutObject,
	promotedMonoVertexDef *unstructured.Unstructured,
	c client.Client,
) (bool, error)

ProcessPromotedChildPostFailure andles the post-upgrade processing of the promoted monovertex after the "upgrading" child has failed. It performs the following post-upgrade operations: - it restores the promoted monovertex scale values to the original values retrieved from the rollout status.

Parameters:

• ctx: the context for managing request-scoped values.
• rolloutObject: the MonoVertexRollout instance
• promotedMonoVertexDef: the definition of the promoted monovertex 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 (*MonoVertexRolloutReconciler) ProcessPromotedChildPreUpgrade ¶ added in v0.13.0

func (r *MonoVertexRolloutReconciler) ProcessPromotedChildPreUpgrade(
	ctx context.Context,
	rolloutObject progressive.ProgressiveRolloutObject,
	promotedMonoVertexDef *unstructured.Unstructured,
	c client.Client,
) (bool, error)

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

Parameters:

• ctx: the context for managing request-scoped values.
• rolloutObject: the MonoVertexRollout instance
• promotedMonoVertexDef: the definition of the promoted monovertex 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 (*MonoVertexRolloutReconciler) ProcessUpgradingChildPostFailure ¶ added in v0.16.0

func (r *MonoVertexRolloutReconciler) ProcessUpgradingChildPostFailure(
	ctx context.Context,
	rolloutObject progressive.ProgressiveRolloutObject,
	upgradingMonoVertexDef *unstructured.Unstructured,
	c client.Client,
) (bool, error)

ProcessUpgradingChildPostFailure handles the failure of an upgrading monovertex (anything specific to MonoVertex) It performs the following post-failure operations: - it scales down the upgrading monovertex to 0 pods if it's not already

Parameters:

• ctx: the context for managing request-scoped values.
• rolloutObject: the MonoVertexRollout instance
• upgradingMonoVertexDef: the definition of the existing upgrading monovertex from the beginning of reconciliation
• 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 (*MonoVertexRolloutReconciler) ProcessUpgradingChildPostSuccess ¶ added in v0.17.0

func (r *MonoVertexRolloutReconciler) ProcessUpgradingChildPostSuccess(
	ctx context.Context,
	rolloutObject progressive.ProgressiveRolloutObject,
	upgradingMonoVertexDef *unstructured.Unstructured,
	c client.Client,
) error

ProcessUpgradingChildPostSuccess handles an upgrading monovertex that has been deemed successful to be promoted. It performs the following post-success operations: - it scales up the monovertex back to the original scale.min and scale.max

Parameters:

• ctx: the context for managing request-scoped values.
• rolloutObject: the MonoVertexRollout instance
• upgradingMonoVertexDef: the definition of the existing upgrading monovertex from the beginning of reconciliation
• c: the client used for interacting with the Kubernetes API.

Returns:

• An error if any issues occur during processing.

func (*MonoVertexRolloutReconciler) ProcessUpgradingChildPostUpgrade ¶ added in v0.19.0

func (r *MonoVertexRolloutReconciler) ProcessUpgradingChildPostUpgrade(
	ctx context.Context,
	rolloutObject progressive.ProgressiveRolloutObject,
	upgradingMonoVertexDef *unstructured.Unstructured,
	c client.Client,
) (bool, error)

ProcessUpgradingChildPostUpgrade handles the processing of an upgrading monovertex definition after it's been created

Parameters:

• ctx: the context for managing request-scoped values.
• rolloutObject: the MonoVertexRollout instance
• upgradingMonoVertexDef: the definition of the upgrading monovertex 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 (*MonoVertexRolloutReconciler) ProcessUpgradingChildPreUpgrade ¶ added in v0.17.0

func (r *MonoVertexRolloutReconciler) ProcessUpgradingChildPreUpgrade(
	ctx context.Context,
	rolloutObject progressive.ProgressiveRolloutObject,
	upgradingMonoVertexDef *unstructured.Unstructured,
	c client.Client,
) (bool, error)

ProcessUpgradingChildPreUpgrade handles the processing of an upgrading monovertex definition before it's been created It performs the following pre-upgrade operations: - it uses the promoted rollout status scale values to calculate the upgrading monovertex scale min and max.

Parameters:

• ctx: the context for managing request-scoped values.
• rolloutObject: the MonoVertexRollout instance
• upgradingMonoVertexDef: the definition of the upgrading monovertex 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 (*MonoVertexRolloutReconciler) Reconcile ¶

func (r *MonoVertexRolloutReconciler) 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 (*MonoVertexRolloutReconciler) Recycle ¶ added in v0.10.0

func (r *MonoVertexRolloutReconciler) Recycle(ctx context.Context,
	monoVertexDef *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 (*MonoVertexRolloutReconciler) SetupWithManager ¶

func (r *MonoVertexRolloutReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.