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
Source Files
Click to show internal directories.
Click to hide internal directories.