v1

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Oct 8, 2020 License: Apache-2.0 Imports: 19 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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

func RegisterExternalServiceGeneratingHandler added in v0.6.0 

func RegisterExternalServiceGeneratingHandler(ctx context.Context, controller ExternalServiceController, apply apply.Apply,
	condition condition.Cond, name string, handler ExternalServiceGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterExternalServiceStatusHandler added in v0.6.0 

func RegisterExternalServiceStatusHandler(ctx context.Context, controller ExternalServiceController, condition condition.Cond, name string, handler ExternalServiceStatusHandler)

func RegisterRouterGeneratingHandler added in v0.6.0 

func RegisterRouterGeneratingHandler(ctx context.Context, controller RouterController, apply apply.Apply,
	condition condition.Cond, name string, handler RouterGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterRouterStatusHandler added in v0.6.0 

func RegisterRouterStatusHandler(ctx context.Context, controller RouterController, condition condition.Cond, name string, handler RouterStatusHandler)

func RegisterServiceGeneratingHandler added in v0.6.0 

func RegisterServiceGeneratingHandler(ctx context.Context, controller ServiceController, apply apply.Apply,
	condition condition.Cond, name string, handler ServiceGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterServiceStatusHandler added in v0.6.0 

func RegisterServiceStatusHandler(ctx context.Context, controller ServiceController, condition condition.Cond, name string, handler ServiceStatusHandler)

func RegisterStackGeneratingHandler added in v0.6.0 

func RegisterStackGeneratingHandler(ctx context.Context, controller StackController, apply apply.Apply,
	condition condition.Cond, name string, handler StackGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterStackStatusHandler added in v0.6.0 

func RegisterStackStatusHandler(ctx context.Context, controller StackController, condition condition.Cond, name string, handler StackStatusHandler)

func UpdateExternalServiceDeepCopyOnChange added in v0.6.0 

func UpdateExternalServiceDeepCopyOnChange(client ExternalServiceClient, obj *v1.ExternalService, handler func(obj *v1.ExternalService) (*v1.ExternalService, error)) (*v1.ExternalService, error)

func UpdateRouterDeepCopyOnChange added in v0.6.0 

func UpdateRouterDeepCopyOnChange(client RouterClient, obj *v1.Router, handler func(obj *v1.Router) (*v1.Router, error)) (*v1.Router, error)

func UpdateServiceDeepCopyOnChange added in v0.6.0 

func UpdateServiceDeepCopyOnChange(client ServiceClient, obj *v1.Service, handler func(obj *v1.Service) (*v1.Service, error)) (*v1.Service, error)

func UpdateStackDeepCopyOnChange added in v0.6.0 

func UpdateStackDeepCopyOnChange(client StackClient, obj *v1.Stack, handler func(obj *v1.Stack) (*v1.Stack, error)) (*v1.Stack, error)

Types

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 {
	generic.ControllerMeta
	ExternalServiceClient

	OnChange(ctx context.Context, name string, sync ExternalServiceHandler)
	OnRemove(ctx context.Context, name string, sync ExternalServiceHandler)
	Enqueue(namespace, name string)
	EnqueueAfter(namespace, name string, duration time.Duration)

	Cache() ExternalServiceCache
}

func NewExternalServiceController 

func NewExternalServiceController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.ExternalServicesGetter, informer informers.ExternalServiceInformer) ExternalServiceController

type ExternalServiceGeneratingHandler added in v0.6.0 

type ExternalServiceGeneratingHandler func(obj *v1.ExternalService, status v1.ExternalServiceStatus) ([]runtime.Object, v1.ExternalServiceStatus, error)

type ExternalServiceHandler 

type ExternalServiceHandler func(string, *v1.ExternalService) (*v1.ExternalService, error)

type ExternalServiceIndexer 

type ExternalServiceIndexer func(obj *v1.ExternalService) ([]string, error)

type ExternalServiceStatusHandler added in v0.6.0 

type ExternalServiceStatusHandler func(obj *v1.ExternalService, status v1.ExternalServiceStatus) (v1.ExternalServiceStatus, error)

type Interface 

type Interface interface {
	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 {
	generic.ControllerMeta
	RouterClient

	OnChange(ctx context.Context, name string, sync RouterHandler)
	OnRemove(ctx context.Context, name string, sync RouterHandler)
	Enqueue(namespace, name string)
	EnqueueAfter(namespace, name string, duration time.Duration)

	Cache() RouterCache
}

func NewRouterController 

func NewRouterController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.RoutersGetter, informer informers.RouterInformer) RouterController

type RouterGeneratingHandler added in v0.6.0 

type RouterGeneratingHandler func(obj *v1.Router, status v1.RouterStatus) ([]runtime.Object, v1.RouterStatus, error)

type RouterHandler 

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

type RouterIndexer 

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

type RouterStatusHandler added in v0.6.0 

type RouterStatusHandler func(obj *v1.Router, status v1.RouterStatus) (v1.RouterStatus, 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 {
	generic.ControllerMeta
	ServiceClient

	OnChange(ctx context.Context, name string, sync ServiceHandler)
	OnRemove(ctx context.Context, name string, sync ServiceHandler)
	Enqueue(namespace, name string)
	EnqueueAfter(namespace, name string, duration time.Duration)

	Cache() ServiceCache
}

func NewServiceController 

func NewServiceController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.ServicesGetter, informer informers.ServiceInformer) ServiceController

type ServiceGeneratingHandler added in v0.6.0 

type ServiceGeneratingHandler func(obj *v1.Service, status v1.ServiceStatus) ([]runtime.Object, v1.ServiceStatus, error)

type ServiceHandler 

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

type ServiceIndexer 

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

type ServiceStatusHandler added in v0.6.0 

type ServiceStatusHandler func(obj *v1.Service, status v1.ServiceStatus) (v1.ServiceStatus, 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 {
	generic.ControllerMeta
	StackClient

	OnChange(ctx context.Context, name string, sync StackHandler)
	OnRemove(ctx context.Context, name string, sync StackHandler)
	Enqueue(namespace, name string)
	EnqueueAfter(namespace, name string, duration time.Duration)

	Cache() StackCache
}

func NewStackController added in v0.3.0 

func NewStackController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.StacksGetter, informer informers.StackInformer) StackController

type StackGeneratingHandler added in v0.6.0 

type StackGeneratingHandler func(obj *v1.Stack, status v1.StackStatus) ([]runtime.Object, v1.StackStatus, error)

type StackHandler added in v0.3.0 

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

type StackIndexer added in v0.3.0 

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

type StackStatusHandler added in v0.6.0 

type StackStatusHandler func(obj *v1.Stack, status v1.StackStatus) (v1.StackStatus, error)

Source Files

View all Source files

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.
JackTT - Gopher 🇻🇳