runtime

type Config struct {
	KubeConfigFile     string
	KubeRestConfig     *rest.Config
	KubeFactoryClient  kubernetes.Interface
	VanusFactoryClient clientset.Interface
}

type ConnectorEventHandler interface {
	OnAdd(connectorID, config string) error
	OnUpdate(connectorID, config string) error
	OnDelete(connectorID string) error
}

type ConnectorEventHandlerFuncs struct {
	AddFunc    func(connectorID, config string) error
	UpdateFunc func(connectorID, config string) error
	DeleteFunc func(connectorID string) error
}

type ConnectorOption func(opt *connectorOptions)

type FilterConnector struct {
	Kind string
	Type string
}

type Runtime interface {
	Run(ctx context.Context)
	Lister() vanuslister.ConnectorLister
}