controller

Documentation

Index

• func RecheckDeletionTimestamp(getObject func() (metav1.Object, error)) func() error
• func SplitNamespaceAndNameByDot(value string) (namespace, name string, err error)
• type CanaryReleaseController
  • func NewCanaryReleaseController(cfg config.Configuration) *CanaryReleaseController
  • func (crc *CanaryReleaseController) Run(workers int, stopCh <-chan struct{})
• type SortPodStatusByName
  • func (s SortPodStatusByName) Len() int
  • func (s SortPodStatusByName) Less(i, j int) bool
  • func (s SortPodStatusByName) Swap(i, j int)

Functions

func RecheckDeletionTimestamp

func RecheckDeletionTimestamp(getObject func() (metav1.Object, error)) func() error

RecheckDeletionTimestamp returns a canAdopt() function to recheck deletion.

The canAdopt() function calls getObject() to fetch the latest value, and denies adoption attempts if that object has a non-nil DeletionTimestamp.

func SplitNamespaceAndNameByDot

func SplitNamespaceAndNameByDot(value string) (namespace, name string, err error)

SplitNamespaceAndNameByDot returns the namespace and name that encoded into the label or value by dot

Types

type CanaryReleaseController

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

CanaryReleaseController ...

func NewCanaryReleaseController

func NewCanaryReleaseController(cfg config.Configuration) *CanaryReleaseController

NewCanaryReleaseController creates a new CanaryReleaseController

func (*CanaryReleaseController) Run

func (crc *CanaryReleaseController) Run(workers int, stopCh <-chan struct{})

Run ...

type SortPodStatusByName

type SortPodStatusByName []releaseapi.PodStatus

SortPodStatusByName ...

func (SortPodStatusByName) Len

func (s SortPodStatusByName) Len() int

func (SortPodStatusByName) Less

func (s SortPodStatusByName) Less(i, j int) bool

func (SortPodStatusByName) Swap

func (s SortPodStatusByName) Swap(i, j int)