sidecarset

Documentation

Index

• func Add(mgr manager.Manager) error
• func SortUpdateIndexes(strategy appsv1alpha1.SidecarSetUpdateStrategy, pods []*corev1.Pod, ...) []int
• type Processor
  • func NewSidecarSetProcessor(cli client.Client, rec record.EventRecorder) *Processor
  • func (p *Processor) UpdateSidecarSet(sidecarSet *appsv1alpha1.SidecarSet) (reconcile.Result, error)
• type ReconcileSidecarSet
  • func (r *ReconcileSidecarSet) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)
• type Strategy
  • func NewStrategy() Strategy

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new SidecarSet Controller and adds it to the Manager with default RBAC. The Manager will set fields on the Controller and Start it when the Manager is Started.

func SortUpdateIndexes

func SortUpdateIndexes(strategy appsv1alpha1.SidecarSetUpdateStrategy, pods []*corev1.Pod, waitUpdateIndexes []int) []int

SortUpdateIndexes sorts the given waitUpdateIndexes of Pods to update according to the SidecarSet update strategy.

Types

type Processor

type Processor struct {
	Client client.Client
	// contains filtered or unexported fields
}

func NewSidecarSetProcessor

func NewSidecarSetProcessor(cli client.Client, rec record.EventRecorder) *Processor

func (*Processor) UpdateSidecarSet

func (p *Processor) UpdateSidecarSet(sidecarSet *appsv1alpha1.SidecarSet) (reconcile.Result, error)

type ReconcileSidecarSet

type ReconcileSidecarSet struct {
	client.Client
	// contains filtered or unexported fields
}

ReconcileSidecarSet reconciles a SidecarSet object

func (*ReconcileSidecarSet) Reconcile

func (r *ReconcileSidecarSet) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a SidecarSet object and makes changes based on the state read and what is in the SidecarSet.Spec

type Strategy

type Strategy interface {
	// according to sidecarset's upgrade strategy, select the pods to be upgraded, include the following:
	//1. select which pods can be upgrade, the following:
	//	* pod must be not updated for the latest sidecarSet
	//	* If selector is not nil, this upgrade will only update the selected pods.
	//2. Sort Pods with default sequence
	//3. sort waitUpdateIndexes based on the scatter rules
	//4. calculate max count of pods can update with maxUnavailable
	//5. also return the pods that are not upgradable
	GetNextUpgradePods(control sidecarcontrol.SidecarControl, pods []*corev1.Pod) (upgradePods []*corev1.Pod, notUpgradablePods []*corev1.Pod)
}

func NewStrategy

func NewStrategy() Strategy