converge

Documentation

Index

• Constants
• func IsConvergeTask(t sh_task.Task) bool
• func IsFirstConvergeTask(t sh_task.Task) bool
• func NewApplyKubeConfigValuesTask(description string, logLabels map[string]string, globalValuesChanged bool) sh_task.Task
• func NewConvergeModulesTask(description string, convergeEvent ConvergeEvent, logLabels map[string]string) sh_task.Task
• type ConvergeEvent
• type ConvergePhase
• type ConvergeState
  • func NewConvergeState() *ConvergeState
  • func (cs *ConvergeState) SetFirstRunPhase(ph firstConvergePhase)

Constants

const (
	FirstNotStarted firstConvergePhase = iota
	FirstStarted
	FirstDone
)

const ConvergeEventProp = "converge.event"

Functions

func IsConvergeTask

func IsConvergeTask(t sh_task.Task) bool

func IsFirstConvergeTask

func IsFirstConvergeTask(t sh_task.Task) bool

func NewApplyKubeConfigValuesTask

func NewApplyKubeConfigValuesTask(description string, logLabels map[string]string, globalValuesChanged bool) sh_task.Task

func NewConvergeModulesTask

func NewConvergeModulesTask(description string, convergeEvent ConvergeEvent, logLabels map[string]string) sh_task.Task

Types

type ConvergeEvent

type ConvergeEvent string

const (
	// OperatorStartup is a first converge during startup.
	OperatorStartup ConvergeEvent = "OperatorStartup"
	// GlobalValuesChanged is a converge initiated by changing values in the global hook.
	GlobalValuesChanged ConvergeEvent = "GlobalValuesChanged"
	// ReloadAllModules is a converge queued to the main queue after the graph's state change
	ReloadAllModules ConvergeEvent = "ReloadAllModules"
)

type ConvergePhase

type ConvergePhase string

const (
	StandBy                 ConvergePhase = "StandBy"
	RunBeforeAll            ConvergePhase = "RunBeforeAll"
	WaitBeforeAll           ConvergePhase = "WaitBeforeAll"
	WaitDeleteAndRunModules ConvergePhase = "WaitDeleteAndRunModules"
	WaitAfterAll            ConvergePhase = "WaitAfterAll"
)

type ConvergeState

type ConvergeState struct {
	PhaseLock sync.RWMutex
	Phase     ConvergePhase

	FirstRunPhase firstConvergePhase
	FirstRunDoneC chan struct{}
	StartedAt     int64
	Activation    string
	CRDsEnsured   bool
}

func NewConvergeState

func NewConvergeState() *ConvergeState

func (*ConvergeState) SetFirstRunPhase

func (cs *ConvergeState) SetFirstRunPhase(ph firstConvergePhase)