sync

Documentation

Index

• Constants
• func IsPodAvailable(coreControl clonesetcore.Control, pod *v1.Pod, minReadySeconds int32) bool
• func SortUpdateIndexes(coreControl clonesetcore.Control, strategy appsv1alpha1.CloneSetUpdateStrategy, ...) []int
• type Interface
  • func New(c client.Client, recorder record.EventRecorder) Interface
• type IsPodUpdateFunc

Constants

const (
	// LengthOfInstanceID is the length of instance-id
	LengthOfInstanceID = 5
)

Functions

func IsPodAvailable

func IsPodAvailable(coreControl clonesetcore.Control, pod *v1.Pod, minReadySeconds int32) bool

func SortUpdateIndexes

func SortUpdateIndexes(coreControl clonesetcore.Control, strategy appsv1alpha1.CloneSetUpdateStrategy, pods []*v1.Pod, waitUpdateIndexes []int) []int

SortUpdateIndexes sorts the given oldRevisionIndexes of Pods to update according to the CloneSet strategy.

Types

type Interface

type Interface interface {
	Scale(
		currentCS, updateCS *appsv1alpha1.CloneSet,
		currentRevision, updateRevision string,
		pods []*v1.Pod, pvcs []*v1.PersistentVolumeClaim,
	) (bool, error)

	Update(cs *appsv1alpha1.CloneSet,
		currentRevision, updateRevision *apps.ControllerRevision, revisions []*apps.ControllerRevision,
		pods []*v1.Pod, pvcs []*v1.PersistentVolumeClaim,
	) error
}

Interface for managing pods scaling and updating.

func New

func New(c client.Client, recorder record.EventRecorder) Interface

type IsPodUpdateFunc

type IsPodUpdateFunc func(pod *v1.Pod, updateRevision string) bool