v1

package
v0.2.0-alpha01 Latest Latest
Warning

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

 Go to latest Published: Mar 30, 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 FromRKEControlPlanHandlerToHandler 

func FromRKEControlPlanHandlerToHandler(sync RKEControlPlanHandler) 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 RegisterRKEControlPlanGeneratingHandler 

func RegisterRKEControlPlanGeneratingHandler(ctx context.Context, controller RKEControlPlanController, apply apply.Apply,
	condition condition.Cond, name string, handler RKEControlPlanGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterRKEControlPlanStatusHandler 

func RegisterRKEControlPlanStatusHandler(ctx context.Context, controller RKEControlPlanController, condition condition.Cond, name string, handler RKEControlPlanStatusHandler)

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 UpdateRKEControlPlanDeepCopyOnChange 

func UpdateRKEControlPlanDeepCopyOnChange(client RKEControlPlanClient, obj *v1.RKEControlPlan, handler func(obj *v1.RKEControlPlan) (*v1.RKEControlPlan, error)) (*v1.RKEControlPlan, 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
	RKEControlPlan() RKEControlPlanController
	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 RKEControlPlanCache 

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

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

type RKEControlPlanClient 

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

type RKEControlPlanController 

type RKEControlPlanController interface {
	generic.ControllerMeta
	RKEControlPlanClient

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

	Cache() RKEControlPlanCache
}

func NewRKEControlPlanController 

func NewRKEControlPlanController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) RKEControlPlanController

type RKEControlPlanGeneratingHandler 

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

type RKEControlPlanHandler 

type RKEControlPlanHandler func(string, *v1.RKEControlPlan) (*v1.RKEControlPlan, error)

type RKEControlPlanIndexer 

type RKEControlPlanIndexer func(obj *v1.RKEControlPlan) ([]string, error)

type RKEControlPlanStatusHandler 

type RKEControlPlanStatusHandler func(obj *v1.RKEControlPlan, status v1.RKEBootstrapStatus) (v1.RKEBootstrapStatus, 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.