v1beta1

Documentation

Index

• func FromIngressHandlerToHandler(sync IngressHandler) generic.Handler
• func RegisterIngressGeneratingHandler(ctx context.Context, controller IngressController, apply apply.Apply, ...)
• func RegisterIngressStatusHandler(ctx context.Context, controller IngressController, condition condition.Cond, ...)
• func UpdateIngressDeepCopyOnChange(client IngressClient, obj *v1beta1.Ingress, ...) (*v1beta1.Ingress, error)
• type IngressCache
• type IngressClient
• type IngressController
  • func NewIngressController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) IngressController
• type IngressGeneratingHandler
• type IngressHandler
• type IngressIndexer
• type IngressStatusHandler
• type Interface
  • func New(controllerFactory controller.SharedControllerFactory) Interface

Functions

func FromIngressHandlerToHandler

func FromIngressHandlerToHandler(sync IngressHandler) generic.Handler

func RegisterIngressGeneratingHandler

func RegisterIngressGeneratingHandler(ctx context.Context, controller IngressController, apply apply.Apply,
	condition condition.Cond, name string, handler IngressGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterIngressStatusHandler

func RegisterIngressStatusHandler(ctx context.Context, controller IngressController, condition condition.Cond, name string, handler IngressStatusHandler)

func UpdateIngressDeepCopyOnChange

func UpdateIngressDeepCopyOnChange(client IngressClient, obj *v1beta1.Ingress, handler func(obj *v1beta1.Ingress) (*v1beta1.Ingress, error)) (*v1beta1.Ingress, error)

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

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

	Cache() IngressCache
}

func NewIngressController

func NewIngressController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) IngressController

type IngressGeneratingHandler

type IngressGeneratingHandler func(obj *v1beta1.Ingress, status v1beta1.IngressStatus) ([]runtime.Object, v1beta1.IngressStatus, error)

type IngressHandler

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

type IngressIndexer

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

type IngressStatusHandler

type IngressStatusHandler func(obj *v1beta1.Ingress, status v1beta1.IngressStatus) (v1beta1.IngressStatus, error)

type Interface

type Interface interface {
	Ingress() IngressController
}

func New

func New(controllerFactory controller.SharedControllerFactory) Interface