task

Documentation

Index

• Constants
• type HookMetadata
  • func HookMetadataAccessor(t task.Task) (meta HookMetadata)
  • func (m HookMetadata) GetBindingContext() []BindingContext
  • func (hm HookMetadata) GetDescription() string
  • func (m HookMetadata) GetHookName() string

Constants

const (
	ModuleDelete         task.TaskType = "ModuleDelete"
	ModuleRun            task.TaskType = "ModuleRun"
	ModuleHookRun        task.TaskType = "ModuleHookRun"
	GlobalHookRun        task.TaskType = "GlobalHookRun"
	ReloadAllModules     task.TaskType = "ReloadAllModules"
	DiscoverModulesState task.TaskType = "DiscoverModulesState"

	GlobalHookEnableKubernetesBindings      task.TaskType = "GlobalHookEnableKubernetesBindings"
	GlobalHookWaitKubernetesSynchronization task.TaskType = "GlobalHookWaitKubernetesSynchronization"
	GlobalHookEnableScheduleBindings        task.TaskType = "GlobalHookEnableScheduleBindings"

	// Delete unknown helm release when no module in ModulesDir
	ModulePurge task.TaskType = "ModulePurge"
	// Task to call ModuleManager.Retry
	ModuleManagerRetry task.TaskType = "ModuleManagerRetry"
)

Addon-operator specific task types

Types

type HookMetadata

type HookMetadata struct {
	EventDescription string // event name for informative queue dump
	HookName         string
	ModuleName       string
	Binding          string // binding name from configuration
	BindingType      BindingType
	BindingContext   []BindingContext
	AllowFailure     bool //Task considered as 'ok' if hook failed. False by default. Can be true for some schedule hooks.

	OnStartupHooks bool // Execute onStartup and kubernetes@Synchronization hooks for module

	ValuesChecksum           string // checksum of global values before first afterAll hook execution
	DynamicEnabledChecksum   string // checksum of dynamicEnabled before first afterAll hook execution
	LastAfterAllHook         bool   // true if task is a last afterAll hook in sequence
	ReloadAllOnValuesChanges bool   // whether or not run DiscoverModules process if hook change global values

	KubernetesBindingId    string // Unique id for kubernetes bindings
	WaitForSynchronization bool   // kubernetes.Synchronization task should be waited
}

HookMetadata is metadata for addon-operator tasks

func HookMetadataAccessor

func HookMetadataAccessor(t task.Task) (meta HookMetadata)

func (HookMetadata) GetBindingContext

func (m HookMetadata) GetBindingContext() []BindingContext

func (HookMetadata) GetDescription

func (hm HookMetadata) GetDescription() string

func (HookMetadata) GetHookName

func (m HookMetadata) GetHookName() string