rolloutorchestrator

Documentation

Index

• func LastStageComplete(stageRevisionStatus, finalTargetRevs []v1.TargetRevision) bool
• func NewController(ctx context.Context, cmw configmap.Watcher) *controller.Impl
• func RemoveNonTrafficRev(ts []v1.TargetRevision) []v1.TargetRevision
• func RetrieveRevsUpDown(targetRevs []v1.TargetRevision) (map[string]*v1.TargetRevision, map[string]*v1.TargetRevision, error)
• type Reconciler
  • func (r *Reconciler) ReconcileKind(ctx context.Context, ro *v1.RolloutOrchestrator) pkgreconciler.Event

Functions

func LastStageComplete

func LastStageComplete(stageRevisionStatus, finalTargetRevs []v1.TargetRevision) bool

LastStageComplete decides whether the last stage of the progressive upgrade is complete or not.

func NewController

func NewController(
	ctx context.Context,
	cmw configmap.Watcher,
) *controller.Impl

NewController creates a new RolloutOrchestrator controller

func RemoveNonTrafficRev

func RemoveNonTrafficRev(ts []v1.TargetRevision) []v1.TargetRevision

RemoveNonTrafficRev removes the redundant TargetRevision from the list of TargetRevisions.

func RetrieveRevsUpDown

func RetrieveRevsUpDown(targetRevs []v1.TargetRevision) (map[string]*v1.TargetRevision, map[string]*v1.TargetRevision, error)

RetrieveRevsUpDown returns two list of revisions scaling up and down based on the input TargetRevisions.

Types

type Reconciler

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

Reconciler implements controller.Reconciler for RolloutOrchestrator resources.

func (*Reconciler) ReconcileKind

func (r *Reconciler) ReconcileKind(ctx context.Context, ro *v1.RolloutOrchestrator) pkgreconciler.Event

ReconcileKind implements Interface.ReconcileKind.