v1

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Jun 12, 2019 License: Apache-2.0 Imports: 15 Imported by: 0

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

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
}

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
}

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)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.