v1beta1

package
v0.2.6 Latest Latest
Warning

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

Go to latest
Published: Mar 28, 2024 License: Apache-2.0 Imports: 20 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 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)

Jump to

Keyboard shortcuts

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