v1beta1

Documentation

Index

• func FromIngressHandlerToHandler(sync IngressHandler) generic.Handler
• type IngressCache
• type IngressClient
• type IngressController
  • func NewIngressController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) IngressController
• type IngressHandler
  • func UpdateIngressOnChange(updater generic.Updater, handler IngressHandler) IngressHandler
• type IngressIndexer
• type Interface
  • func New(controllerManager *generic.ControllerManager, ...) Interface

Functions

func FromIngressHandlerToHandler

func FromIngressHandlerToHandler(sync IngressHandler) generic.Handler

Types

type IngressCache

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

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

type IngressClient

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

type IngressController

type IngressController interface {
	IngressClient

	OnChange(ctx context.Context, name string, sync IngressHandler)
	OnRemove(ctx context.Context, name string, sync IngressHandler)
	Enqueue(namespace, name string)

	Cache() IngressCache

	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 NewIngressController

func NewIngressController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.IngressesGetter, informer informers.IngressInformer) IngressController

type IngressHandler

type IngressHandler func(string, *v1beta1.Ingress) (*v1beta1.Ingress, error)

func UpdateIngressOnChange

func UpdateIngressOnChange(updater generic.Updater, handler IngressHandler) IngressHandler

type IngressIndexer

type IngressIndexer func(obj *v1beta1.Ingress) ([]string, error)

type Interface

type Interface interface {
	Ingress() IngressController
}

func New

func New(controllerManager *generic.ControllerManager, client clientset.ExtensionsV1beta1Interface,
	informers informers.Interface) Interface