Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ControllersDisabledByDefault = sets.NewString()
ControllersDisabledByDefault is the set of controllers which is disabled by default
Functions ¶
func GetControllerInitializers ¶
func GetControllerInitializers() map[string]ControllerStarter
GetControllerInitializers returns those controllers with initialized functions
func RegisterControllerInitializer ¶
func RegisterControllerInitializer(name string, starter ControllerStarter)
RegisterControllerInitializer is used to register user-defined controllers
func Run ¶
func Run(opt *options.Options, genericOptions ...katalystbase.GenericOptions) error
Types ¶
type ControllerStarter ¶
type ControllerStarter struct {
Starter StartFunc
ExtraConf interface{}
}
ControllerStarter is used to start katalyst controllers
type StartFunc ¶
type StartFunc func(ctx context.Context, controlCtx *katalystbase.GenericContext, conf *config.Configuration, extraControllerConf interface{}, controllerName string) (bool, error)
StartFunc is used to launch a particular controller. It may run additional "should I activate checks". Any error returned will cause the controller process to `Fatal` The bool indicates whether the controller was enabled.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.