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

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.