v1alpha4

Documentation

Index

• func FromClusterHandlerToHandler(sync ClusterHandler) generic.Handler
• func FromMachineHandlerToHandler(sync MachineHandler) generic.Handler
• func RegisterClusterGeneratingHandler(ctx context.Context, controller ClusterController, apply apply.Apply, ...)
• func RegisterClusterStatusHandler(ctx context.Context, controller ClusterController, condition condition.Cond, ...)
• func RegisterMachineGeneratingHandler(ctx context.Context, controller MachineController, apply apply.Apply, ...)
• func RegisterMachineStatusHandler(ctx context.Context, controller MachineController, condition condition.Cond, ...)
• func UpdateClusterDeepCopyOnChange(client ClusterClient, obj *v1alpha4.Cluster, ...) (*v1alpha4.Cluster, error)
• func UpdateMachineDeepCopyOnChange(client MachineClient, obj *v1alpha4.Machine, ...) (*v1alpha4.Machine, error)
• type ClusterCache
• type ClusterClient
• type ClusterController
  • func NewClusterController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) ClusterController
• type ClusterGeneratingHandler
• type ClusterHandler
• type ClusterIndexer
• type ClusterStatusHandler
• type Interface
  • func New(controllerFactory controller.SharedControllerFactory) Interface
• type MachineCache
• type MachineClient
• type MachineController
  • func NewMachineController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) MachineController
• type MachineGeneratingHandler
• type MachineHandler
• type MachineIndexer
• type MachineStatusHandler

Functions

func FromClusterHandlerToHandler

func FromClusterHandlerToHandler(sync ClusterHandler) generic.Handler

func FromMachineHandlerToHandler

func FromMachineHandlerToHandler(sync MachineHandler) generic.Handler

func RegisterClusterGeneratingHandler

func RegisterClusterGeneratingHandler(ctx context.Context, controller ClusterController, apply apply.Apply,
	condition condition.Cond, name string, handler ClusterGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterClusterStatusHandler

func RegisterClusterStatusHandler(ctx context.Context, controller ClusterController, condition condition.Cond, name string, handler ClusterStatusHandler)

func RegisterMachineGeneratingHandler

func RegisterMachineGeneratingHandler(ctx context.Context, controller MachineController, apply apply.Apply,
	condition condition.Cond, name string, handler MachineGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterMachineStatusHandler

func RegisterMachineStatusHandler(ctx context.Context, controller MachineController, condition condition.Cond, name string, handler MachineStatusHandler)

func UpdateClusterDeepCopyOnChange

func UpdateClusterDeepCopyOnChange(client ClusterClient, obj *v1alpha4.Cluster, handler func(obj *v1alpha4.Cluster) (*v1alpha4.Cluster, error)) (*v1alpha4.Cluster, error)

func UpdateMachineDeepCopyOnChange

func UpdateMachineDeepCopyOnChange(client MachineClient, obj *v1alpha4.Machine, handler func(obj *v1alpha4.Machine) (*v1alpha4.Machine, error)) (*v1alpha4.Machine, error)

Types

type ClusterCache

type ClusterCache interface {
	Get(namespace, name string) (*v1alpha4.Cluster, error)
	List(namespace string, selector labels.Selector) ([]*v1alpha4.Cluster, error)

	AddIndexer(indexName string, indexer ClusterIndexer)
	GetByIndex(indexName, key string) ([]*v1alpha4.Cluster, error)
}

type ClusterClient

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

type ClusterController

type ClusterController interface {
	generic.ControllerMeta
	ClusterClient

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

	Cache() ClusterCache
}

func NewClusterController

func NewClusterController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ClusterController

type ClusterGeneratingHandler

type ClusterGeneratingHandler func(obj *v1alpha4.Cluster, status v1alpha4.ClusterStatus) ([]runtime.Object, v1alpha4.ClusterStatus, error)

type ClusterHandler

type ClusterHandler func(string, *v1alpha4.Cluster) (*v1alpha4.Cluster, error)

type ClusterIndexer

type ClusterIndexer func(obj *v1alpha4.Cluster) ([]string, error)

type ClusterStatusHandler

type ClusterStatusHandler func(obj *v1alpha4.Cluster, status v1alpha4.ClusterStatus) (v1alpha4.ClusterStatus, error)

type Interface

type Interface interface {
	Cluster() ClusterController
	Machine() MachineController
}

func New

func New(controllerFactory controller.SharedControllerFactory) Interface

type MachineCache

type MachineCache interface {
	Get(namespace, name string) (*v1alpha4.Machine, error)
	List(namespace string, selector labels.Selector) ([]*v1alpha4.Machine, error)

	AddIndexer(indexName string, indexer MachineIndexer)
	GetByIndex(indexName, key string) ([]*v1alpha4.Machine, error)
}

type MachineClient

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

type MachineController

type MachineController interface {
	generic.ControllerMeta
	MachineClient

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

	Cache() MachineCache
}

func NewMachineController

func NewMachineController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) MachineController

type MachineGeneratingHandler

type MachineGeneratingHandler func(obj *v1alpha4.Machine, status v1alpha4.MachineStatus) ([]runtime.Object, v1alpha4.MachineStatus, error)

type MachineHandler

type MachineHandler func(string, *v1alpha4.Machine) (*v1alpha4.Machine, error)

type MachineIndexer

type MachineIndexer func(obj *v1alpha4.Machine) ([]string, error)

type MachineStatusHandler

type MachineStatusHandler func(obj *v1alpha4.Machine, status v1alpha4.MachineStatus) (v1alpha4.MachineStatus, error)