monovertexrollout

Documentation

Index

• Constants
• type MonoVertexRolloutReconciler
  • func NewMonoVertexRolloutReconciler(c client.Client, s *runtime.Scheme, customMetrics *metrics.CustomMetrics, ...) *MonoVertexRolloutReconciler
  • func (r *MonoVertexRolloutReconciler) ChildIsDrained(ctx context.Context, monoVertexDef *unstructured.Unstructured) (bool, error)
  • func (r *MonoVertexRolloutReconciler) ChildNeedsUpdating(ctx context.Context, from, to *unstructured.Unstructured) (bool, error)
  • func (r *MonoVertexRolloutReconciler) CreateBaseChildDefinition(rolloutObject ctlrcommon.RolloutObject, name string) (*unstructured.Unstructured, error)
  • func (r *MonoVertexRolloutReconciler) Drain(ctx context.Context, monoVertexDef *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) ListChildren(ctx context.Context, rolloutObject ctlrcommon.RolloutObject, ...) (*unstructured.UnstructuredList, error)
  • func (r *MonoVertexRolloutReconciler) Merge(existingMonoVertex, newMonoVertex *unstructured.Unstructured) (*unstructured.Unstructured, error)
  • func (r *MonoVertexRolloutReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, 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) ChildIsDrained

func (r *MonoVertexRolloutReconciler) ChildIsDrained(ctx context.Context, monoVertexDef *unstructured.Unstructured) (bool, error)

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) CreateBaseChildDefinition

func (r *MonoVertexRolloutReconciler) CreateBaseChildDefinition(rolloutObject ctlrcommon.RolloutObject, name string) (*unstructured.Unstructured, error)

func (*MonoVertexRolloutReconciler) Drain

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

func (r *MonoVertexRolloutReconciler) ListChildren(ctx context.Context, rolloutObject ctlrcommon.RolloutObject, labelSelector string, fieldSelector string) (*unstructured.UnstructuredList, error)

the following functions enable MonoVertexRolloutReconciler to implement progressiveController interface

func (*MonoVertexRolloutReconciler) Merge

func (r *MonoVertexRolloutReconciler) Merge(existingMonoVertex, newMonoVertex *unstructured.Unstructured) (*unstructured.Unstructured, error)

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) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.