transitioner

Documentation

Index

• type CycleNodeStatusTransitioner
  • func NewCycleNodeStatusTransitioner(cycleNodeStatus *v1.CycleNodeStatus, rm *controller.ResourceManager, ...) *CycleNodeStatusTransitioner
  • func (t *CycleNodeStatusTransitioner) Run() (reconcile.Result, error)
• type Options

Types

type CycleNodeStatusTransitioner

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

CycleNodeStatusTransitioner takes a cycleNodeStatus and attempts to transition it to the next phase

func NewCycleNodeStatusTransitioner

func NewCycleNodeStatusTransitioner(
	cycleNodeStatus *v1.CycleNodeStatus,
	rm *controller.ResourceManager,
	options Options,
) *CycleNodeStatusTransitioner

NewCycleNodeStatusTransitioner returns a new cycleNodeStatus transitioner

func (*CycleNodeStatusTransitioner) Run

func (t *CycleNodeStatusTransitioner) Run() (reconcile.Result, error)

Run runs the CycleNodeStatusTransitioner and returns a reconcile result and an error

type Options

type Options struct {
	// DefaultCNScyclingExpiry controls how long until the CycleNodeStatus will timeout
	DefaultCNScyclingExpiry time.Duration
	// UnhealthyPodTerminationThreshold controls how long we tolerate a pod being unhealthy and holding up the
	// CycleNodeStatus before forcibly removing it
	UnhealthyPodTerminationThreshold time.Duration
}

Options stores configurable options for the NewCycleNodeStatusTransitioner