Documentation ¶
Index ¶
- func ConvertOnKubernetesEventToKubeEventHook(hook module_manager.Hook, config kube_events_manager.OnKubernetesEventConfig, ...) *kube_event.KubeEventHook
- func MakeKubeEventHookDescriptors(hook module_manager.Hook, hookConfig *module_manager.HookConfig) []*kube_event.KubeEventHook
- type KubeEventsHooksController
- type MainKubeEventsHooksController
- func (obj *MainKubeEventsHooksController) DisableModuleHooks(moduleName string, moduleManager module_manager.ModuleManager, ...) error
- func (obj *MainKubeEventsHooksController) EnableGlobalHooks(moduleManager module_manager.ModuleManager, ...) error
- func (obj *MainKubeEventsHooksController) EnableModuleHooks(moduleName string, moduleManager module_manager.ModuleManager, ...) error
- func (obj *MainKubeEventsHooksController) HandleEvent(kubeEvent kube_events_manager.KubeEvent) (*struct{ Tasks []task.Task }, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertOnKubernetesEventToKubeEventHook ¶
func ConvertOnKubernetesEventToKubeEventHook(hook module_manager.Hook, config kube_events_manager.OnKubernetesEventConfig, namespace string) *kube_event.KubeEventHook
func MakeKubeEventHookDescriptors ¶
func MakeKubeEventHookDescriptors(hook module_manager.Hook, hookConfig *module_manager.HookConfig) []*kube_event.KubeEventHook
MakeKubeEventHookDescriptors converts hook config into KubeEventHook structures
Types ¶
type KubeEventsHooksController ¶
type KubeEventsHooksController interface { EnableGlobalHooks(moduleManager module_manager.ModuleManager, eventsManager kube_events_manager.KubeEventsManager) error EnableModuleHooks(moduleName string, moduleManager module_manager.ModuleManager, eventsManager kube_events_manager.KubeEventsManager) error DisableModuleHooks(moduleName string, moduleManager module_manager.ModuleManager, eventsManager kube_events_manager.KubeEventsManager) error HandleEvent(kubeEvent kube_events_manager.KubeEvent) (*struct{ Tasks []task.Task }, error) }
type MainKubeEventsHooksController ¶
type MainKubeEventsHooksController struct { GlobalHooks map[string]*kube_event.KubeEventHook ModuleHooks map[string]*kube_event.KubeEventHook EnabledModules []string }
func NewMainKubeEventsHooksController ¶
func NewMainKubeEventsHooksController() *MainKubeEventsHooksController
NewMainKubeEventsHooksController returns new instance of MainKubeEventsHooksController
func (*MainKubeEventsHooksController) DisableModuleHooks ¶
func (obj *MainKubeEventsHooksController) DisableModuleHooks(moduleName string, moduleManager module_manager.ModuleManager, eventsManager kube_events_manager.KubeEventsManager) error
DisableModuleHooks stops informers for module hooks
func (*MainKubeEventsHooksController) EnableGlobalHooks ¶
func (obj *MainKubeEventsHooksController) EnableGlobalHooks(moduleManager module_manager.ModuleManager, eventsManager kube_events_manager.KubeEventsManager) error
EnableGlobalHooks starts kube events informers for all global hooks
func (*MainKubeEventsHooksController) EnableModuleHooks ¶
func (obj *MainKubeEventsHooksController) EnableModuleHooks(moduleName string, moduleManager module_manager.ModuleManager, eventsManager kube_events_manager.KubeEventsManager) error
EnableModuleHooks starts kube events informers for all module hooks
func (*MainKubeEventsHooksController) HandleEvent ¶
func (obj *MainKubeEventsHooksController) HandleEvent(kubeEvent kube_events_manager.KubeEvent) (*struct{ Tasks []task.Task }, error)
HandleEvent creates a task from kube event
Click to show internal directories.
Click to hide internal directories.