v1beta1

Documentation

Index

• func FromIPPoolHandlerToHandler(sync IPPoolHandler) generic.Handler
• func FromLoadBalancerHandlerToHandler(sync LoadBalancerHandler) generic.Handler
• func RegisterIPPoolGeneratingHandler(ctx context.Context, controller IPPoolController, apply apply.Apply, ...)
• func RegisterIPPoolStatusHandler(ctx context.Context, controller IPPoolController, condition condition.Cond, ...)
• func RegisterLoadBalancerGeneratingHandler(ctx context.Context, controller LoadBalancerController, apply apply.Apply, ...)
• func RegisterLoadBalancerStatusHandler(ctx context.Context, controller LoadBalancerController, ...)
• func UpdateIPPoolDeepCopyOnChange(client IPPoolClient, obj *v1beta1.IPPool, ...) (*v1beta1.IPPool, error)
• func UpdateLoadBalancerDeepCopyOnChange(client LoadBalancerClient, obj *v1beta1.LoadBalancer, ...) (*v1beta1.LoadBalancer, error)
• type IPPoolCache
• type IPPoolClient
• type IPPoolController
  • func NewIPPoolController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) IPPoolController
• type IPPoolGeneratingHandler
• type IPPoolHandler
• type IPPoolIndexer
• type IPPoolStatusHandler
• type Interface
  • func New(controllerFactory controller.SharedControllerFactory) Interface
• type LoadBalancerCache
• type LoadBalancerClient
• type LoadBalancerController
  • func NewLoadBalancerController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) LoadBalancerController
• type LoadBalancerGeneratingHandler
• type LoadBalancerHandler
• type LoadBalancerIndexer
• type LoadBalancerStatusHandler

Functions

func FromIPPoolHandlerToHandler

func FromIPPoolHandlerToHandler(sync IPPoolHandler) generic.Handler

func FromLoadBalancerHandlerToHandler

func FromLoadBalancerHandlerToHandler(sync LoadBalancerHandler) generic.Handler

func RegisterIPPoolGeneratingHandler

func RegisterIPPoolGeneratingHandler(ctx context.Context, controller IPPoolController, apply apply.Apply,
	condition condition.Cond, name string, handler IPPoolGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterIPPoolStatusHandler

func RegisterIPPoolStatusHandler(ctx context.Context, controller IPPoolController, condition condition.Cond, name string, handler IPPoolStatusHandler)

func RegisterLoadBalancerGeneratingHandler

func RegisterLoadBalancerGeneratingHandler(ctx context.Context, controller LoadBalancerController, apply apply.Apply,
	condition condition.Cond, name string, handler LoadBalancerGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterLoadBalancerStatusHandler

func RegisterLoadBalancerStatusHandler(ctx context.Context, controller LoadBalancerController, condition condition.Cond, name string, handler LoadBalancerStatusHandler)

func UpdateIPPoolDeepCopyOnChange

func UpdateIPPoolDeepCopyOnChange(client IPPoolClient, obj *v1beta1.IPPool, handler func(obj *v1beta1.IPPool) (*v1beta1.IPPool, error)) (*v1beta1.IPPool, error)

func UpdateLoadBalancerDeepCopyOnChange

func UpdateLoadBalancerDeepCopyOnChange(client LoadBalancerClient, obj *v1beta1.LoadBalancer, handler func(obj *v1beta1.LoadBalancer) (*v1beta1.LoadBalancer, error)) (*v1beta1.LoadBalancer, error)

Types

type IPPoolCache

type IPPoolCache interface {
	Get(name string) (*v1beta1.IPPool, error)
	List(selector labels.Selector) ([]*v1beta1.IPPool, error)

	AddIndexer(indexName string, indexer IPPoolIndexer)
	GetByIndex(indexName, key string) ([]*v1beta1.IPPool, error)
}

type IPPoolClient

type IPPoolClient interface {
	Create(*v1beta1.IPPool) (*v1beta1.IPPool, error)
	Update(*v1beta1.IPPool) (*v1beta1.IPPool, error)
	UpdateStatus(*v1beta1.IPPool) (*v1beta1.IPPool, error)
	Delete(name string, options *metav1.DeleteOptions) error
	Get(name string, options metav1.GetOptions) (*v1beta1.IPPool, error)
	List(opts metav1.ListOptions) (*v1beta1.IPPoolList, error)
	Watch(opts metav1.ListOptions) (watch.Interface, error)
	Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1beta1.IPPool, err error)
}

type IPPoolController

type IPPoolController interface {
	generic.ControllerMeta
	IPPoolClient

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

	Cache() IPPoolCache
}

func NewIPPoolController

func NewIPPoolController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) IPPoolController

type IPPoolGeneratingHandler

type IPPoolGeneratingHandler func(obj *v1beta1.IPPool, status v1beta1.IPPoolStatus) ([]runtime.Object, v1beta1.IPPoolStatus, error)

type IPPoolHandler

type IPPoolHandler func(string, *v1beta1.IPPool) (*v1beta1.IPPool, error)

type IPPoolIndexer

type IPPoolIndexer func(obj *v1beta1.IPPool) ([]string, error)

type IPPoolStatusHandler

type IPPoolStatusHandler func(obj *v1beta1.IPPool, status v1beta1.IPPoolStatus) (v1beta1.IPPoolStatus, error)

type Interface

type Interface interface {
	IPPool() IPPoolController
	LoadBalancer() LoadBalancerController
}

func New

func New(controllerFactory controller.SharedControllerFactory) Interface

type LoadBalancerCache

type LoadBalancerCache interface {
	Get(namespace, name string) (*v1beta1.LoadBalancer, error)
	List(namespace string, selector labels.Selector) ([]*v1beta1.LoadBalancer, error)

	AddIndexer(indexName string, indexer LoadBalancerIndexer)
	GetByIndex(indexName, key string) ([]*v1beta1.LoadBalancer, error)
}

type LoadBalancerClient

type LoadBalancerClient interface {
	Create(*v1beta1.LoadBalancer) (*v1beta1.LoadBalancer, error)
	Update(*v1beta1.LoadBalancer) (*v1beta1.LoadBalancer, error)
	UpdateStatus(*v1beta1.LoadBalancer) (*v1beta1.LoadBalancer, error)
	Delete(namespace, name string, options *metav1.DeleteOptions) error
	Get(namespace, name string, options metav1.GetOptions) (*v1beta1.LoadBalancer, error)
	List(namespace string, opts metav1.ListOptions) (*v1beta1.LoadBalancerList, error)
	Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error)
	Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1beta1.LoadBalancer, err error)
}

type LoadBalancerController

type LoadBalancerController interface {
	generic.ControllerMeta
	LoadBalancerClient

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

	Cache() LoadBalancerCache
}

func NewLoadBalancerController

func NewLoadBalancerController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) LoadBalancerController

type LoadBalancerGeneratingHandler

type LoadBalancerGeneratingHandler func(obj *v1beta1.LoadBalancer, status v1beta1.LoadBalancerStatus) ([]runtime.Object, v1beta1.LoadBalancerStatus, error)

type LoadBalancerHandler

type LoadBalancerHandler func(string, *v1beta1.LoadBalancer) (*v1beta1.LoadBalancer, error)

type LoadBalancerIndexer

type LoadBalancerIndexer func(obj *v1beta1.LoadBalancer) ([]string, error)

type LoadBalancerStatusHandler

type LoadBalancerStatusHandler func(obj *v1beta1.LoadBalancer, status v1beta1.LoadBalancerStatus) (v1beta1.LoadBalancerStatus, error)