Documentation ¶
Index ¶
- func FromAppHandlerToHandler(sync AppHandler) generic.Handler
- func FromExternalServiceHandlerToHandler(sync ExternalServiceHandler) generic.Handler
- func FromRouterHandlerToHandler(sync RouterHandler) generic.Handler
- func FromServiceHandlerToHandler(sync ServiceHandler) generic.Handler
- func FromStackHandlerToHandler(sync StackHandler) generic.Handler
- type AppCache
- type AppClient
- type AppController
- type AppHandler
- type AppIndexer
- type ExternalServiceCache
- type ExternalServiceClient
- type ExternalServiceController
- type ExternalServiceHandler
- type ExternalServiceIndexer
- type Interface
- type RouterCache
- type RouterClient
- type RouterController
- type RouterHandler
- type RouterIndexer
- type ServiceCache
- type ServiceClient
- type ServiceController
- type ServiceHandler
- type ServiceIndexer
- type StackCache
- type StackClient
- type StackController
- type StackHandler
- type StackIndexer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FromAppHandlerToHandler ¶
func FromAppHandlerToHandler(sync AppHandler) generic.Handler
func FromExternalServiceHandlerToHandler ¶
func FromExternalServiceHandlerToHandler(sync ExternalServiceHandler) generic.Handler
func FromRouterHandlerToHandler ¶
func FromRouterHandlerToHandler(sync RouterHandler) generic.Handler
func FromServiceHandlerToHandler ¶
func FromServiceHandlerToHandler(sync ServiceHandler) generic.Handler
func FromStackHandlerToHandler ¶ added in v0.3.0
func FromStackHandlerToHandler(sync StackHandler) generic.Handler
Types ¶
type AppClient ¶
type AppClient interface { Create(*v1.App) (*v1.App, error) Update(*v1.App) (*v1.App, error) UpdateStatus(*v1.App) (*v1.App, error) Delete(namespace, name string, options *metav1.DeleteOptions) error Get(namespace, name string, options metav1.GetOptions) (*v1.App, error) List(namespace string, opts metav1.ListOptions) (*v1.AppList, error) Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error) Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.App, err error) }
type AppController ¶
type AppController interface { AppClient OnChange(ctx context.Context, name string, sync AppHandler) OnRemove(ctx context.Context, name string, sync AppHandler) Enqueue(namespace, name string) Cache() AppCache Informer() cache.SharedIndexInformer GroupVersionKind() schema.GroupVersionKind AddGenericHandler(ctx context.Context, name string, handler generic.Handler) AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler) Updater() generic.Updater }
func NewAppController ¶
func NewAppController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.AppsGetter, informer informers.AppInformer) AppController
type AppHandler ¶
func UpdateAppOnChange ¶
func UpdateAppOnChange(updater generic.Updater, handler AppHandler) AppHandler
type ExternalServiceCache ¶
type ExternalServiceCache interface { Get(namespace, name string) (*v1.ExternalService, error) List(namespace string, selector labels.Selector) ([]*v1.ExternalService, error) AddIndexer(indexName string, indexer ExternalServiceIndexer) GetByIndex(indexName, key string) ([]*v1.ExternalService, error) }
type ExternalServiceClient ¶
type ExternalServiceClient interface { Create(*v1.ExternalService) (*v1.ExternalService, error) Update(*v1.ExternalService) (*v1.ExternalService, error) UpdateStatus(*v1.ExternalService) (*v1.ExternalService, error) Delete(namespace, name string, options *metav1.DeleteOptions) error Get(namespace, name string, options metav1.GetOptions) (*v1.ExternalService, error) List(namespace string, opts metav1.ListOptions) (*v1.ExternalServiceList, error) Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error) Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.ExternalService, err error) }
type ExternalServiceController ¶
type ExternalServiceController interface { ExternalServiceClient OnChange(ctx context.Context, name string, sync ExternalServiceHandler) OnRemove(ctx context.Context, name string, sync ExternalServiceHandler) Enqueue(namespace, name string) Cache() ExternalServiceCache Informer() cache.SharedIndexInformer GroupVersionKind() schema.GroupVersionKind AddGenericHandler(ctx context.Context, name string, handler generic.Handler) AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler) Updater() generic.Updater }
func NewExternalServiceController ¶
func NewExternalServiceController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.ExternalServicesGetter, informer informers.ExternalServiceInformer) ExternalServiceController
type ExternalServiceHandler ¶
type ExternalServiceHandler func(string, *v1.ExternalService) (*v1.ExternalService, error)
func UpdateExternalServiceOnChange ¶
func UpdateExternalServiceOnChange(updater generic.Updater, handler ExternalServiceHandler) ExternalServiceHandler
type ExternalServiceIndexer ¶
type ExternalServiceIndexer func(obj *v1.ExternalService) ([]string, error)
type Interface ¶
type Interface interface { App() AppController ExternalService() ExternalServiceController Router() RouterController Service() ServiceController Stack() StackController }
func New ¶
func New(controllerManager *generic.ControllerManager, client clientset.RioV1Interface, informers informers.Interface) Interface
type RouterCache ¶
type RouterClient ¶
type RouterClient interface { Create(*v1.Router) (*v1.Router, error) Update(*v1.Router) (*v1.Router, error) UpdateStatus(*v1.Router) (*v1.Router, error) Delete(namespace, name string, options *metav1.DeleteOptions) error Get(namespace, name string, options metav1.GetOptions) (*v1.Router, error) List(namespace string, opts metav1.ListOptions) (*v1.RouterList, error) Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error) Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Router, err error) }
type RouterController ¶
type RouterController interface { RouterClient OnChange(ctx context.Context, name string, sync RouterHandler) OnRemove(ctx context.Context, name string, sync RouterHandler) Enqueue(namespace, name string) Cache() RouterCache Informer() cache.SharedIndexInformer GroupVersionKind() schema.GroupVersionKind AddGenericHandler(ctx context.Context, name string, handler generic.Handler) AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler) Updater() generic.Updater }
func NewRouterController ¶
func NewRouterController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.RoutersGetter, informer informers.RouterInformer) RouterController
type RouterHandler ¶
func UpdateRouterOnChange ¶
func UpdateRouterOnChange(updater generic.Updater, handler RouterHandler) RouterHandler
type ServiceCache ¶
type ServiceClient ¶
type ServiceClient interface { Create(*v1.Service) (*v1.Service, error) Update(*v1.Service) (*v1.Service, error) UpdateStatus(*v1.Service) (*v1.Service, error) Delete(namespace, name string, options *metav1.DeleteOptions) error Get(namespace, name string, options metav1.GetOptions) (*v1.Service, error) List(namespace string, opts metav1.ListOptions) (*v1.ServiceList, error) Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error) Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Service, err error) }
type ServiceController ¶
type ServiceController interface { ServiceClient OnChange(ctx context.Context, name string, sync ServiceHandler) OnRemove(ctx context.Context, name string, sync ServiceHandler) Enqueue(namespace, name string) Cache() ServiceCache Informer() cache.SharedIndexInformer GroupVersionKind() schema.GroupVersionKind AddGenericHandler(ctx context.Context, name string, handler generic.Handler) AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler) Updater() generic.Updater }
func NewServiceController ¶
func NewServiceController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.ServicesGetter, informer informers.ServiceInformer) ServiceController
type ServiceHandler ¶
func UpdateServiceOnChange ¶
func UpdateServiceOnChange(updater generic.Updater, handler ServiceHandler) ServiceHandler
type StackCache ¶ added in v0.3.0
type StackClient ¶ added in v0.3.0
type StackClient interface { Create(*v1.Stack) (*v1.Stack, error) Update(*v1.Stack) (*v1.Stack, error) UpdateStatus(*v1.Stack) (*v1.Stack, error) Delete(namespace, name string, options *metav1.DeleteOptions) error Get(namespace, name string, options metav1.GetOptions) (*v1.Stack, error) List(namespace string, opts metav1.ListOptions) (*v1.StackList, error) Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error) Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Stack, err error) }
type StackController ¶ added in v0.3.0
type StackController interface { StackClient OnChange(ctx context.Context, name string, sync StackHandler) OnRemove(ctx context.Context, name string, sync StackHandler) Enqueue(namespace, name string) Cache() StackCache Informer() cache.SharedIndexInformer GroupVersionKind() schema.GroupVersionKind AddGenericHandler(ctx context.Context, name string, handler generic.Handler) AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler) Updater() generic.Updater }
func NewStackController ¶ added in v0.3.0
func NewStackController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.StacksGetter, informer informers.StackInformer) StackController
type StackHandler ¶ added in v0.3.0
func UpdateStackOnChange ¶ added in v0.3.0
func UpdateStackOnChange(updater generic.Updater, handler StackHandler) StackHandler
Click to show internal directories.
Click to hide internal directories.