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 (cs *ConvergeState) GetFirstRunPhase() FirstConvergePhase
- func (cs *ConvergeState) GetPhase() ConvergePhase
- func (cs *ConvergeState) SetFirstRunPhase(ph FirstConvergePhase)
- func (cs *ConvergeState) SetOnConvergeFinish(callback func())
- func (cs *ConvergeState) SetOnConvergeStart(callback func())
- func (cs *ConvergeState) SetPhase(ph ConvergePhase)
- type FirstConvergePhase
Constants ¶
View Source
const ConvergeEventProp = "converge.event"
Variables ¶
This section is empty.
Functions ¶
func IsConvergeTask ¶
func IsFirstConvergeTask ¶
func NewApplyKubeConfigValuesTask ¶ added in v1.4.0
func NewConvergeModulesTask ¶
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" )
func (ConvergeEvent) String ¶ added in v1.7.0
func (e ConvergeEvent) String() string
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 {
FirstRunDoneC chan struct{}
StartedAt int64
Activation string
CRDsEnsured bool
// contains filtered or unexported fields
}
func NewConvergeState ¶
func NewConvergeState() *ConvergeState
func (*ConvergeState) GetFirstRunPhase ¶ added in v1.7.0
func (cs *ConvergeState) GetFirstRunPhase() FirstConvergePhase
func (*ConvergeState) GetPhase ¶ added in v1.7.0
func (cs *ConvergeState) GetPhase() ConvergePhase
func (*ConvergeState) SetFirstRunPhase ¶
func (cs *ConvergeState) SetFirstRunPhase(ph FirstConvergePhase)
func (*ConvergeState) SetOnConvergeFinish ¶ added in v1.15.10
func (cs *ConvergeState) SetOnConvergeFinish(callback func())
func (*ConvergeState) SetOnConvergeStart ¶ added in v1.15.10
func (cs *ConvergeState) SetOnConvergeStart(callback func())
func (*ConvergeState) SetPhase ¶ added in v1.7.0
func (cs *ConvergeState) SetPhase(ph ConvergePhase)
type FirstConvergePhase ¶ added in v1.7.0
type FirstConvergePhase int
const ( FirstNotStarted FirstConvergePhase = iota FirstStarted FirstDone )
Click to show internal directories.
Click to hide internal directories.