v1

package
v0.4.0-rc3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 22, 2019 License: Apache-2.0 Imports: 15 Imported by: 2

Documentation

Index

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 AppCache

type AppCache interface {
	Get(namespace, name string) (*v1.App, error)
	List(namespace string, selector labels.Selector) ([]*v1.App, error)

	AddIndexer(indexName string, indexer AppIndexer)
	GetByIndex(indexName, key string) ([]*v1.App, error)
}

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

type AppHandler func(string, *v1.App) (*v1.App, error)

func UpdateAppOnChange

func UpdateAppOnChange(updater generic.Updater, handler AppHandler) AppHandler

type AppIndexer

type AppIndexer func(obj *v1.App) ([]string, error)

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
}

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 RouterCache interface {
	Get(namespace, name string) (*v1.Router, error)
	List(namespace string, selector labels.Selector) ([]*v1.Router, error)

	AddIndexer(indexName string, indexer RouterIndexer)
	GetByIndex(indexName, key string) ([]*v1.Router, error)
}

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

type RouterHandler func(string, *v1.Router) (*v1.Router, error)

func UpdateRouterOnChange

func UpdateRouterOnChange(updater generic.Updater, handler RouterHandler) RouterHandler

type RouterIndexer

type RouterIndexer func(obj *v1.Router) ([]string, error)

type ServiceCache

type ServiceCache interface {
	Get(namespace, name string) (*v1.Service, error)
	List(namespace string, selector labels.Selector) ([]*v1.Service, error)

	AddIndexer(indexName string, indexer ServiceIndexer)
	GetByIndex(indexName, key string) ([]*v1.Service, error)
}

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

type ServiceHandler func(string, *v1.Service) (*v1.Service, error)

func UpdateServiceOnChange

func UpdateServiceOnChange(updater generic.Updater, handler ServiceHandler) ServiceHandler

type ServiceIndexer

type ServiceIndexer func(obj *v1.Service) ([]string, error)

type StackCache added in v0.3.0

type StackCache interface {
	Get(namespace, name string) (*v1.Stack, error)
	List(namespace string, selector labels.Selector) ([]*v1.Stack, error)

	AddIndexer(indexName string, indexer StackIndexer)
	GetByIndex(indexName, key string) ([]*v1.Stack, error)
}

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

type StackHandler func(string, *v1.Stack) (*v1.Stack, error)

func UpdateStackOnChange added in v0.3.0

func UpdateStackOnChange(updater generic.Updater, handler StackHandler) StackHandler

type StackIndexer added in v0.3.0

type StackIndexer func(obj *v1.Stack) ([]string, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL