pipelinerollout

Documentation

Index

• Constants
• type PipelineRolloutReconciler
  • func NewPipelineRolloutReconciler(c client.Client, s *runtime.Scheme, customMetrics *metrics.CustomMetrics, ...) *PipelineRolloutReconciler
  • func (r *PipelineRolloutReconciler) ChildIsDrained(ctx context.Context, pipelineDef *unstructured.Unstructured) (bool, error)
  • func (r *PipelineRolloutReconciler) ChildNeedsUpdating(ctx context.Context, from, to *unstructured.Unstructured) (bool, error)
  • func (r *PipelineRolloutReconciler) CreateBaseChildDefinition(rolloutObject ctlrcommon.RolloutObject, name string) (*unstructured.Unstructured, error)
  • func (r *PipelineRolloutReconciler) Drain(ctx context.Context, pipeline *unstructured.Unstructured) error
  • func (r *PipelineRolloutReconciler) EnqueuePipeline(namespacedName k8stypes.NamespacedName)
  • func (r *PipelineRolloutReconciler) ErrorHandler(pipelineRollout *apiv1.PipelineRollout, err error, reason, msg string)
  • func (r *PipelineRolloutReconciler) IncrementChildCount(ctx context.Context, rolloutObject ctlrcommon.RolloutObject) (int32, error)
  • func (r *PipelineRolloutReconciler) ListChildren(ctx context.Context, rolloutObject ctlrcommon.RolloutObject, ...) (*unstructured.UnstructuredList, error)
  • func (r *PipelineRolloutReconciler) Merge(existingPipeline, newPipeline *unstructured.Unstructured) (*unstructured.Unstructured, error)
  • func (r *PipelineRolloutReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PipelineRolloutReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *PipelineRolloutReconciler) Shutdown(ctx context.Context)

Constants

const (
	ControllerPipelineRollout = "pipeline-rollout-controller"
)

Types

type PipelineRolloutReconciler

type PipelineRolloutReconciler struct {

	// Queue contains the list of PipelineRollouts that currently need to be reconciled
	// both PipelineRolloutReconciler.Reconcile() and other Rollout reconcilers can add PipelineRollouts to this Queue to be processed as needed
	// a set of Workers is used to process this Queue
	Queue workqueue.TypedRateLimitingInterface[interface{}]
	// contains filtered or unexported fields
}

PipelineRolloutReconciler reconciles a PipelineRollout object

var (
	PipelineROReconciler *PipelineRolloutReconciler
)

func NewPipelineRolloutReconciler

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

func (*PipelineRolloutReconciler) ChildIsDrained

func (r *PipelineRolloutReconciler) ChildIsDrained(ctx context.Context, pipelineDef *unstructured.Unstructured) (bool, error)

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

func (*PipelineRolloutReconciler) CreateBaseChildDefinition

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

func (*PipelineRolloutReconciler) Drain

func (r *PipelineRolloutReconciler) Drain(ctx context.Context, pipeline *unstructured.Unstructured) error

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)

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

func (*PipelineRolloutReconciler) ListChildren

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

the following functions enable PipelineRolloutReconciler to implement progressiveController interface

func (*PipelineRolloutReconciler) Merge

func (r *PipelineRolloutReconciler) Merge(existingPipeline, newPipeline *unstructured.Unstructured) (*unstructured.Unstructured, error)

take the existing pipeline and merge anything needed from the new pipeline definition

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