app

Documentation

Index

• Variables
• func GetControllerInitializers() map[string]ControllerStarter
• func RegisterControllerInitializer(name string, starter ControllerStarter)
• func Run(opt *options.Options, genericOptions ...katalystbase.GenericOptions) error
• type ControllerStarter
• type StartFunc

Variables

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.