Versions in this module Expand all Collapse all v0 v0.0.4 Jun 2, 2022 v0.0.1 Jul 14, 2021 Changes in this version + func FromNodeHandlerToHandler(sync NodeHandler) generic.Handler + func FromPodHandlerToHandler(sync PodHandler) generic.Handler + func FromSecretHandlerToHandler(sync SecretHandler) generic.Handler + func RegisterNodeGeneratingHandler(ctx context.Context, controller NodeController, apply apply.Apply, ...) + func RegisterNodeStatusHandler(ctx context.Context, controller NodeController, condition condition.Cond, ...) + func RegisterPodGeneratingHandler(ctx context.Context, controller PodController, apply apply.Apply, ...) + func RegisterPodStatusHandler(ctx context.Context, controller PodController, condition condition.Cond, ...) + func UpdateNodeDeepCopyOnChange(client NodeClient, obj *v1.Node, handler func(obj *v1.Node) (*v1.Node, error)) (*v1.Node, error) + func UpdatePodDeepCopyOnChange(client PodClient, obj *v1.Pod, handler func(obj *v1.Pod) (*v1.Pod, error)) (*v1.Pod, error) + func UpdateSecretDeepCopyOnChange(client SecretClient, obj *v1.Secret, ...) (*v1.Secret, error) + type Interface interface + Node func() NodeController + Pod func() PodController + Secret func() SecretController + func New(controllerFactory controller.SharedControllerFactory) Interface + type NodeCache interface + AddIndexer func(indexName string, indexer NodeIndexer) + Get func(name string) (*v1.Node, error) + GetByIndex func(indexName, key string) ([]*v1.Node, error) + List func(selector labels.Selector) ([]*v1.Node, error) + type NodeClient interface + Create func(*v1.Node) (*v1.Node, error) + Delete func(name string, options *metav1.DeleteOptions) error + Get func(name string, options metav1.GetOptions) (*v1.Node, error) + List func(opts metav1.ListOptions) (*v1.NodeList, error) + Patch func(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Node, err error) + Update func(*v1.Node) (*v1.Node, error) + UpdateStatus func(*v1.Node) (*v1.Node, error) + Watch func(opts metav1.ListOptions) (watch.Interface, error) + type NodeController interface + Cache func() NodeCache + Enqueue func(name string) + EnqueueAfter func(name string, duration time.Duration) + OnChange func(ctx context.Context, name string, sync NodeHandler) + OnRemove func(ctx context.Context, name string, sync NodeHandler) + func NewNodeController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) NodeController + type NodeGeneratingHandler func(obj *v1.Node, status v1.NodeStatus) ([]runtime.Object, v1.NodeStatus, error) + type NodeHandler func(string, *v1.Node) (*v1.Node, error) + type NodeIndexer func(obj *v1.Node) ([]string, error) + type NodeStatusHandler func(obj *v1.Node, status v1.NodeStatus) (v1.NodeStatus, error) + type PodCache interface + AddIndexer func(indexName string, indexer PodIndexer) + Get func(namespace, name string) (*v1.Pod, error) + GetByIndex func(indexName, key string) ([]*v1.Pod, error) + List func(namespace string, selector labels.Selector) ([]*v1.Pod, error) + type PodClient interface + Create func(*v1.Pod) (*v1.Pod, error) + Delete func(namespace, name string, options *metav1.DeleteOptions) error + Get func(namespace, name string, options metav1.GetOptions) (*v1.Pod, error) + List func(namespace string, opts metav1.ListOptions) (*v1.PodList, error) + Patch func(namespace, name string, pt types.PatchType, data []byte, ...) (result *v1.Pod, err error) + Update func(*v1.Pod) (*v1.Pod, error) + UpdateStatus func(*v1.Pod) (*v1.Pod, error) + Watch func(namespace string, opts metav1.ListOptions) (watch.Interface, error) + type PodController interface + Cache func() PodCache + Enqueue func(namespace, name string) + EnqueueAfter func(namespace, name string, duration time.Duration) + OnChange func(ctx context.Context, name string, sync PodHandler) + OnRemove func(ctx context.Context, name string, sync PodHandler) + func NewPodController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) PodController + type PodGeneratingHandler func(obj *v1.Pod, status v1.PodStatus) ([]runtime.Object, v1.PodStatus, error) + type PodHandler func(string, *v1.Pod) (*v1.Pod, error) + type PodIndexer func(obj *v1.Pod) ([]string, error) + type PodStatusHandler func(obj *v1.Pod, status v1.PodStatus) (v1.PodStatus, error) + type SecretCache interface + AddIndexer func(indexName string, indexer SecretIndexer) + Get func(namespace, name string) (*v1.Secret, error) + GetByIndex func(indexName, key string) ([]*v1.Secret, error) + List func(namespace string, selector labels.Selector) ([]*v1.Secret, error) + type SecretClient interface + Create func(*v1.Secret) (*v1.Secret, error) + Delete func(namespace, name string, options *metav1.DeleteOptions) error + Get func(namespace, name string, options metav1.GetOptions) (*v1.Secret, error) + List func(namespace string, opts metav1.ListOptions) (*v1.SecretList, error) + Patch func(namespace, name string, pt types.PatchType, data []byte, ...) (result *v1.Secret, err error) + Update func(*v1.Secret) (*v1.Secret, error) + Watch func(namespace string, opts metav1.ListOptions) (watch.Interface, error) + type SecretController interface + Cache func() SecretCache + Enqueue func(namespace, name string) + EnqueueAfter func(namespace, name string, duration time.Duration) + OnChange func(ctx context.Context, name string, sync SecretHandler) + OnRemove func(ctx context.Context, name string, sync SecretHandler) + func NewSecretController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) SecretController + type SecretHandler func(string, *v1.Secret) (*v1.Secret, error) + type SecretIndexer func(obj *v1.Secret) ([]string, error)