v1

Documentation

Index

• func FromNodeHandlerToHandler(sync NodeHandler) generic.Handler
• func FromPodHandlerToHandler(sync PodHandler) generic.Handler
• type Interface
  • func New(controllerManager *generic.ControllerManager, client clientset.CoreV1Interface, ...) Interface
• type NodeCache
• type NodeClient
• type NodeController
  • func NewNodeController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) NodeController
• type NodeHandler
  • func UpdateNodeOnChange(updater generic.Updater, handler NodeHandler) NodeHandler
• type NodeIndexer
• type PodCache
• type PodClient
• type PodController
  • func NewPodController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) PodController
• type PodHandler
  • func UpdatePodOnChange(updater generic.Updater, handler PodHandler) PodHandler
• type PodIndexer

Functions

func FromNodeHandlerToHandler

func FromNodeHandlerToHandler(sync NodeHandler) generic.Handler

func FromPodHandlerToHandler

func FromPodHandlerToHandler(sync PodHandler) generic.Handler

Types

type Interface

type Interface interface {
	Node() NodeController
	Pod() PodController
}

func New

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

type NodeCache

type NodeCache interface {
	Get(name string) (*v1.Node, error)
	List(selector labels.Selector) ([]*v1.Node, error)

	AddIndexer(indexName string, indexer NodeIndexer)
	GetByIndex(indexName, key string) ([]*v1.Node, error)
}

type NodeClient

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

type NodeController

type NodeController interface {
	NodeClient

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

	Cache() NodeCache

	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 NewNodeController

func NewNodeController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.NodesGetter, informer informers.NodeInformer) NodeController

type NodeHandler

type NodeHandler func(string, *v1.Node) (*v1.Node, error)

func UpdateNodeOnChange

func UpdateNodeOnChange(updater generic.Updater, handler NodeHandler) NodeHandler

type NodeIndexer

type NodeIndexer func(obj *v1.Node) ([]string, error)

type PodCache

type PodCache interface {
	Get(namespace, name string) (*v1.Pod, error)
	List(namespace string, selector labels.Selector) ([]*v1.Pod, error)

	AddIndexer(indexName string, indexer PodIndexer)
	GetByIndex(indexName, key string) ([]*v1.Pod, error)
}

type PodClient

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

type PodController

type PodController interface {
	PodClient

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

	Cache() PodCache

	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 NewPodController

func NewPodController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.PodsGetter, informer informers.PodInformer) PodController

type PodHandler

type PodHandler func(string, *v1.Pod) (*v1.Pod, error)

func UpdatePodOnChange

func UpdatePodOnChange(updater generic.Updater, handler PodHandler) PodHandler

type PodIndexer

type PodIndexer func(obj *v1.Pod) ([]string, error)