Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetInClusterOrKubeConfig ¶
try list authprovider kubeconfig serviceAccount
func GetKubeConfigFromEnv ¶
func GetKubeConfigFromEnv() string
Types ¶
type Config ¶
type Config struct { KubeConfigFile string KubeRestConfig *rest.Config KubeFactoryClient kubernetes.Interface VanusFactoryClient clientset.Interface }
Config is the controller conf
type ConnectorEventHandler ¶
type ConnectorEventHandlerFuncs ¶
type ConnectorEventHandlerFuncs struct { AddFunc func(connectorID, config string) error UpdateFunc func(connectorID, config string) error DeleteFunc func(connectorID string) error }
func (ConnectorEventHandlerFuncs) OnAdd ¶
func (r ConnectorEventHandlerFuncs) OnAdd(connectorID, config string) error
OnAdd calls AddFunc if it's not nil.
func (ConnectorEventHandlerFuncs) OnDelete ¶
func (r ConnectorEventHandlerFuncs) OnDelete(connectorID string) error
OnDelete calls DeleteFunc if it's not nil.
func (ConnectorEventHandlerFuncs) OnUpdate ¶
func (r ConnectorEventHandlerFuncs) OnUpdate(connectorID, config string) error
OnUpdate calls UpdateFunc if it's not nil.
type ConnectorOption ¶
type ConnectorOption func(opt *connectorOptions)
func WithEventHandler ¶
func WithEventHandler(handler ConnectorEventHandler) ConnectorOption
func WithFilter ¶
func WithFilter(filter string) ConnectorOption
type FilterConnector ¶
type Runtime ¶
type Runtime interface { Run(ctx context.Context) Lister() vanuslister.ConnectorLister }
Click to show internal directories.
Click to hide internal directories.