v1

Documentation

Index

• func FromDaemonSetHandlerToHandler(sync DaemonSetHandler) generic.Handler
• func FromDeploymentHandlerToHandler(sync DeploymentHandler) generic.Handler
• type DaemonSetCache
• type DaemonSetClient
• type DaemonSetController
  • func NewDaemonSetController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) DaemonSetController
• type DaemonSetHandler
  • func UpdateDaemonSetOnChange(updater generic.Updater, handler DaemonSetHandler) DaemonSetHandler
• type DaemonSetIndexer
• type DeploymentCache
• type DeploymentClient
• type DeploymentController
  • func NewDeploymentController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) DeploymentController
• type DeploymentHandler
  • func UpdateDeploymentOnChange(updater generic.Updater, handler DeploymentHandler) DeploymentHandler
• type DeploymentIndexer
• type Interface
  • func New(controllerManager *generic.ControllerManager, client clientset.AppsV1Interface, ...) Interface

Functions

func FromDaemonSetHandlerToHandler

func FromDaemonSetHandlerToHandler(sync DaemonSetHandler) generic.Handler

func FromDeploymentHandlerToHandler

func FromDeploymentHandlerToHandler(sync DeploymentHandler) generic.Handler

Types

type DaemonSetCache

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

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

type DaemonSetClient

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

type DaemonSetController

type DaemonSetController interface {
	DaemonSetClient

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

	Cache() DaemonSetCache

	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 NewDaemonSetController

func NewDaemonSetController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.DaemonSetsGetter, informer informers.DaemonSetInformer) DaemonSetController

type DaemonSetHandler

type DaemonSetHandler func(string, *v1.DaemonSet) (*v1.DaemonSet, error)

func UpdateDaemonSetOnChange

func UpdateDaemonSetOnChange(updater generic.Updater, handler DaemonSetHandler) DaemonSetHandler

type DaemonSetIndexer

type DaemonSetIndexer func(obj *v1.DaemonSet) ([]string, error)

type DeploymentCache

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

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

type DeploymentClient

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

type DeploymentController

type DeploymentController interface {
	DeploymentClient

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

	Cache() DeploymentCache

	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 NewDeploymentController

func NewDeploymentController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.DeploymentsGetter, informer informers.DeploymentInformer) DeploymentController

type DeploymentHandler

type DeploymentHandler func(string, *v1.Deployment) (*v1.Deployment, error)

func UpdateDeploymentOnChange

func UpdateDeploymentOnChange(updater generic.Updater, handler DeploymentHandler) DeploymentHandler

type DeploymentIndexer

type DeploymentIndexer func(obj *v1.Deployment) ([]string, error)

type Interface

type Interface interface {
	DaemonSet() DaemonSetController
	Deployment() DeploymentController
}

func New

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