Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterTaskHandler ¶
RegisterTaskHandler creates a factory function for ModuleEnsureCRDs tasks
Types ¶
type Task ¶
type Task struct {
// contains filtered or unexported fields
}
Task handles ensuring CRDs for modules
func NewTask ¶
func NewTask( shellTask sh_task.Task, kubeClient *klient.Client, moduleManager *module_manager.ModuleManager, convergeState *converge.ConvergeState, queueService *taskqueue.Service, crdExtraLabels map[string]string, discoveredGVKs *discovercrds.DiscoveredGVKs, logger *log.Logger, ) *Task
NewTask creates a new task handler for ensuring module CRDs
func (*Task) CheckCRDsEnsured ¶
CheckCRDsEnsured checks if there any other ModuleEnsureCRDs tasks in the queue and if there aren't, sets ConvergeState.CRDsEnsured to true and applies global values patch with the discovered GVKs
func (*Task) EnsureCRDs ¶
func (s *Task) EnsureCRDs(module *modules.BasicModule) ([]string, error)
type TaskDependencies ¶
type TaskDependencies interface {
GetKubeClient() *klient.Client
GetModuleManager() *module_manager.ModuleManager
GetConvergeState() *converge.ConvergeState
GetCRDExtraLabels() map[string]string
GetQueueService() *taskqueue.Service
GetDiscoveredGVKs() *discovercrds.DiscoveredGVKs
}
TaskDependencies defines the interface for accessing necessary components
Source Files
Click to show internal directories.
Click to hide internal directories.