monovertexrollout

Documentation

Index

• Constants
• type MonoVertexRolloutReconciler
  • func NewMonoVertexRolloutReconciler(c client.Client, s *runtime.Scheme, customMetrics *metrics.CustomMetrics, ...) *MonoVertexRolloutReconciler
  • func (r *MonoVertexRolloutReconciler) ChildNeedsUpdating(ctx context.Context, from, to *unstructured.Unstructured) (bool, error)
  • func (r *MonoVertexRolloutReconciler) CreateUpgradingChildDefinition(ctx context.Context, rolloutObject ctlrcommon.RolloutObject, name string) (*unstructured.Unstructured, error)
  • func (r *MonoVertexRolloutReconciler) ErrorHandler(monoVertexRollout *apiv1.MonoVertexRollout, err error, reason, msg string)
  • func (r *MonoVertexRolloutReconciler) IncrementChildCount(ctx context.Context, rolloutObject ctlrcommon.RolloutObject) (int32, error)
  • func (r *MonoVertexRolloutReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MonoVertexRolloutReconciler) Recycle(ctx context.Context, monoVertexDef *unstructured.Unstructured, c client.Client) error
  • func (r *MonoVertexRolloutReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	ControllerMonoVertexRollout = "monovertex-rollout-controller"
)

Types

type MonoVertexRolloutReconciler

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

MonoVertexRolloutReconciler reconciles a MonoVertexRollout object

func NewMonoVertexRolloutReconciler

func NewMonoVertexRolloutReconciler(
	c client.Client,
	s *runtime.Scheme,
	customMetrics *metrics.CustomMetrics,
	recorder record.EventRecorder,
) *MonoVertexRolloutReconciler

func (*MonoVertexRolloutReconciler) ChildNeedsUpdating

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

ChildNeedsUpdating() tests for essential equality, with any irrelevant fields eliminated from the comparison

func (*MonoVertexRolloutReconciler) CreateUpgradingChildDefinition

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

func (*MonoVertexRolloutReconciler) ErrorHandler

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

func (*MonoVertexRolloutReconciler) IncrementChildCount

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

increment the child count for the Rollout and return the count to use

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

func (r *MonoVertexRolloutReconciler) Recycle(ctx context.Context,
	monoVertexDef *unstructured.Unstructured,
	c client.Client,
) error

func (*MonoVertexRolloutReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.