utils

Documentation

Index

• Variables
• func DoItSlowly(count int, initialBatchSize int, fn func() error) (int, error)
• func GetActiveAndInactivePods(reader client.Reader, opts *client.ListOptions) ([]*v1.Pod, []*v1.Pod, error)
• func GetControllerKey(cs *fuxiv1alpha1.Fuxi) string
• func GetShortHash(hash string) string
• func NextRevision(revisions []*apps.ControllerRevision) int64
• func SplitPodsByRevision(pods []*v1.Pod, rev string) (matched, unmatched []*v1.Pod)

Variables

var (
	ControllerKind              = fuxiv1alpha1.SchemeGroupVersion.WithKind("Fuxi")
	ScaleExpectations           = expectations.NewScaleExpectations()
	ResourceVersionExpectations = expectations.NewResourceVersionExpectation()
	RevisionAdapterImpl         = &revisionAdapterImpl{}
	EqualToRevisionHash         = RevisionAdapterImpl.EqualToRevisionHash
	DurationStore               = requeueduration.DurationStore{}
)

Functions

func DoItSlowly

func DoItSlowly(count int, initialBatchSize int, fn func() error) (int, error)

func GetActiveAndInactivePods

func GetActiveAndInactivePods(reader client.Reader, opts *client.ListOptions) ([]*v1.Pod, []*v1.Pod, error)

func GetControllerKey

func GetControllerKey(cs *fuxiv1alpha1.Fuxi) string

func GetShortHash

func GetShortHash(hash string) string

func NextRevision

func NextRevision(revisions []*apps.ControllerRevision) int64

func SplitPodsByRevision

func SplitPodsByRevision(pods []*v1.Pod, rev string) (matched, unmatched []*v1.Pod)