v1

package
v0.2.0-alpha02 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 7, 2021 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromRKEBootstrapHandlerToHandler 

func FromRKEBootstrapHandlerToHandler(sync RKEBootstrapHandler) generic.Handler

func FromRKEBootstrapTemplateHandlerToHandler 

func FromRKEBootstrapTemplateHandlerToHandler(sync RKEBootstrapTemplateHandler) generic.Handler

func FromRKEClusterHandlerToHandler 

func FromRKEClusterHandlerToHandler(sync RKEClusterHandler) generic.Handler

func FromRKEControlPlaneHandlerToHandler 

func FromRKEControlPlaneHandlerToHandler(sync RKEControlPlaneHandler) generic.Handler

func FromUnmanagedMachineHandlerToHandler 

func FromUnmanagedMachineHandlerToHandler(sync UnmanagedMachineHandler) generic.Handler

func RegisterRKEBootstrapGeneratingHandler 

func RegisterRKEBootstrapGeneratingHandler(ctx context.Context, controller RKEBootstrapController, apply apply.Apply,
	condition condition.Cond, name string, handler RKEBootstrapGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterRKEBootstrapStatusHandler 

func RegisterRKEBootstrapStatusHandler(ctx context.Context, controller RKEBootstrapController, condition condition.Cond, name string, handler RKEBootstrapStatusHandler)

func RegisterRKEClusterGeneratingHandler 

func RegisterRKEClusterGeneratingHandler(ctx context.Context, controller RKEClusterController, apply apply.Apply,
	condition condition.Cond, name string, handler RKEClusterGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterRKEClusterStatusHandler 

func RegisterRKEClusterStatusHandler(ctx context.Context, controller RKEClusterController, condition condition.Cond, name string, handler RKEClusterStatusHandler)

func RegisterRKEControlPlaneGeneratingHandler 

func RegisterRKEControlPlaneGeneratingHandler(ctx context.Context, controller RKEControlPlaneController, apply apply.Apply,
	condition condition.Cond, name string, handler RKEControlPlaneGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterRKEControlPlaneStatusHandler 

func RegisterRKEControlPlaneStatusHandler(ctx context.Context, controller RKEControlPlaneController, condition condition.Cond, name string, handler RKEControlPlaneStatusHandler)

func RegisterUnmanagedMachineGeneratingHandler 

func RegisterUnmanagedMachineGeneratingHandler(ctx context.Context, controller UnmanagedMachineController, apply apply.Apply,
	condition condition.Cond, name string, handler UnmanagedMachineGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterUnmanagedMachineStatusHandler 

func RegisterUnmanagedMachineStatusHandler(ctx context.Context, controller UnmanagedMachineController, condition condition.Cond, name string, handler UnmanagedMachineStatusHandler)

func UpdateRKEBootstrapDeepCopyOnChange 

func UpdateRKEBootstrapDeepCopyOnChange(client RKEBootstrapClient, obj *v1.RKEBootstrap, handler func(obj *v1.RKEBootstrap) (*v1.RKEBootstrap, error)) (*v1.RKEBootstrap, error)

func UpdateRKEBootstrapTemplateDeepCopyOnChange 

func UpdateRKEBootstrapTemplateDeepCopyOnChange(client RKEBootstrapTemplateClient, obj *v1.RKEBootstrapTemplate, handler func(obj *v1.RKEBootstrapTemplate) (*v1.RKEBootstrapTemplate, error)) (*v1.RKEBootstrapTemplate, error)

func UpdateRKEClusterDeepCopyOnChange 

func UpdateRKEClusterDeepCopyOnChange(client RKEClusterClient, obj *v1.RKECluster, handler func(obj *v1.RKECluster) (*v1.RKECluster, error)) (*v1.RKECluster, error)

func UpdateRKEControlPlaneDeepCopyOnChange 

func UpdateRKEControlPlaneDeepCopyOnChange(client RKEControlPlaneClient, obj *v1.RKEControlPlane, handler func(obj *v1.RKEControlPlane) (*v1.RKEControlPlane, error)) (*v1.RKEControlPlane, error)

func UpdateUnmanagedMachineDeepCopyOnChange 

func UpdateUnmanagedMachineDeepCopyOnChange(client UnmanagedMachineClient, obj *v1.UnmanagedMachine, handler func(obj *v1.UnmanagedMachine) (*v1.UnmanagedMachine, error)) (*v1.UnmanagedMachine, error)

Types

type Interface 

type Interface interface {
	RKEBootstrap() RKEBootstrapController
	RKEBootstrapTemplate() RKEBootstrapTemplateController
	RKECluster() RKEClusterController
	RKEControlPlane() RKEControlPlaneController
	UnmanagedMachine() UnmanagedMachineController
}

func New 

func New(controllerFactory controller.SharedControllerFactory) Interface

type RKEBootstrapCache 

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

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

type RKEBootstrapClient 

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

type RKEBootstrapController 

type RKEBootstrapController interface {
	generic.ControllerMeta
	RKEBootstrapClient

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

	Cache() RKEBootstrapCache
}

func NewRKEBootstrapController 

func NewRKEBootstrapController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) RKEBootstrapController

type RKEBootstrapGeneratingHandler 

type RKEBootstrapGeneratingHandler func(obj *v1.RKEBootstrap, status v1.RKEBootstrapStatus) ([]runtime.Object, v1.RKEBootstrapStatus, error)

type RKEBootstrapHandler 

type RKEBootstrapHandler func(string, *v1.RKEBootstrap) (*v1.RKEBootstrap, error)

type RKEBootstrapIndexer 

type RKEBootstrapIndexer func(obj *v1.RKEBootstrap) ([]string, error)

type RKEBootstrapStatusHandler 

type RKEBootstrapStatusHandler func(obj *v1.RKEBootstrap, status v1.RKEBootstrapStatus) (v1.RKEBootstrapStatus, error)

type RKEBootstrapTemplateCache 

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

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

type RKEBootstrapTemplateClient 

type RKEBootstrapTemplateClient interface {
	Create(*v1.RKEBootstrapTemplate) (*v1.RKEBootstrapTemplate, error)
	Update(*v1.RKEBootstrapTemplate) (*v1.RKEBootstrapTemplate, error)

	Delete(namespace, name string, options *metav1.DeleteOptions) error
	Get(namespace, name string, options metav1.GetOptions) (*v1.RKEBootstrapTemplate, error)
	List(namespace string, opts metav1.ListOptions) (*v1.RKEBootstrapTemplateList, error)
	Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error)
	Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.RKEBootstrapTemplate, err error)
}

type RKEBootstrapTemplateController 

type RKEBootstrapTemplateController interface {
	generic.ControllerMeta
	RKEBootstrapTemplateClient

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

	Cache() RKEBootstrapTemplateCache
}

func NewRKEBootstrapTemplateController 

func NewRKEBootstrapTemplateController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) RKEBootstrapTemplateController

type RKEBootstrapTemplateHandler 

type RKEBootstrapTemplateHandler func(string, *v1.RKEBootstrapTemplate) (*v1.RKEBootstrapTemplate, error)

type RKEBootstrapTemplateIndexer 

type RKEBootstrapTemplateIndexer func(obj *v1.RKEBootstrapTemplate) ([]string, error)

type RKEClusterCache 

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

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

type RKEClusterClient 

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

type RKEClusterController 

type RKEClusterController interface {
	generic.ControllerMeta
	RKEClusterClient

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

	Cache() RKEClusterCache
}

func NewRKEClusterController 

func NewRKEClusterController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) RKEClusterController

type RKEClusterGeneratingHandler 

type RKEClusterGeneratingHandler func(obj *v1.RKECluster, status v1.RKEClusterStatus) ([]runtime.Object, v1.RKEClusterStatus, error)

type RKEClusterHandler 

type RKEClusterHandler func(string, *v1.RKECluster) (*v1.RKECluster, error)

type RKEClusterIndexer 

type RKEClusterIndexer func(obj *v1.RKECluster) ([]string, error)

type RKEClusterStatusHandler 

type RKEClusterStatusHandler func(obj *v1.RKECluster, status v1.RKEClusterStatus) (v1.RKEClusterStatus, error)

type RKEControlPlaneCache 

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

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

type RKEControlPlaneClient 

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

type RKEControlPlaneController 

type RKEControlPlaneController interface {
	generic.ControllerMeta
	RKEControlPlaneClient

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

	Cache() RKEControlPlaneCache
}

func NewRKEControlPlaneController 

func NewRKEControlPlaneController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) RKEControlPlaneController

type RKEControlPlaneGeneratingHandler 

type RKEControlPlaneGeneratingHandler func(obj *v1.RKEControlPlane, status v1.RKEControlPlaneStatus) ([]runtime.Object, v1.RKEControlPlaneStatus, error)

type RKEControlPlaneHandler 

type RKEControlPlaneHandler func(string, *v1.RKEControlPlane) (*v1.RKEControlPlane, error)

type RKEControlPlaneIndexer 

type RKEControlPlaneIndexer func(obj *v1.RKEControlPlane) ([]string, error)

type RKEControlPlaneStatusHandler 

type RKEControlPlaneStatusHandler func(obj *v1.RKEControlPlane, status v1.RKEControlPlaneStatus) (v1.RKEControlPlaneStatus, error)

type UnmanagedMachineCache 

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

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

type UnmanagedMachineClient 

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

type UnmanagedMachineController 

type UnmanagedMachineController interface {
	generic.ControllerMeta
	UnmanagedMachineClient

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

	Cache() UnmanagedMachineCache
}

func NewUnmanagedMachineController 

func NewUnmanagedMachineController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) UnmanagedMachineController

type UnmanagedMachineGeneratingHandler 

type UnmanagedMachineGeneratingHandler func(obj *v1.UnmanagedMachine, status v1.UnmanagedMachineStatus) ([]runtime.Object, v1.UnmanagedMachineStatus, error)

type UnmanagedMachineHandler 

type UnmanagedMachineHandler func(string, *v1.UnmanagedMachine) (*v1.UnmanagedMachine, error)

type UnmanagedMachineIndexer 

type UnmanagedMachineIndexer func(obj *v1.UnmanagedMachine) ([]string, error)

type UnmanagedMachineStatusHandler 

type UnmanagedMachineStatusHandler func(obj *v1.UnmanagedMachine, status v1.UnmanagedMachineStatus) (v1.UnmanagedMachineStatus, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.