v1

Documentation

Index

• func FromBackupHandlerToHandler(sync BackupHandler) generic.Handler
• func FromResourceSetHandlerToHandler(sync ResourceSetHandler) generic.Handler
• func FromRestoreHandlerToHandler(sync RestoreHandler) generic.Handler
• func RegisterBackupGeneratingHandler(ctx context.Context, controller BackupController, apply apply.Apply, ...)
• func RegisterBackupStatusHandler(ctx context.Context, controller BackupController, condition condition.Cond, ...)
• func RegisterRestoreGeneratingHandler(ctx context.Context, controller RestoreController, apply apply.Apply, ...)
• func RegisterRestoreStatusHandler(ctx context.Context, controller RestoreController, condition condition.Cond, ...)
• func UpdateBackupDeepCopyOnChange(client BackupClient, obj *v1.Backup, ...) (*v1.Backup, error)
• func UpdateResourceSetDeepCopyOnChange(client ResourceSetClient, obj *v1.ResourceSet, ...) (*v1.ResourceSet, error)
• func UpdateRestoreDeepCopyOnChange(client RestoreClient, obj *v1.Restore, ...) (*v1.Restore, error)
• type BackupCache
• type BackupClient
• type BackupController
  • func NewBackupController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) BackupController
• type BackupGeneratingHandler
• type BackupHandler
• type BackupIndexer
• type BackupStatusHandler
• type Interface
  • func New(controllerFactory controller.SharedControllerFactory) Interface
• type ResourceSetCache
• type ResourceSetClient
• type ResourceSetController
  • func NewResourceSetController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) ResourceSetController
• type ResourceSetHandler
• type ResourceSetIndexer
• type RestoreCache
• type RestoreClient
• type RestoreController
  • func NewRestoreController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) RestoreController
• type RestoreGeneratingHandler
• type RestoreHandler
• type RestoreIndexer
• type RestoreStatusHandler

Functions

func FromBackupHandlerToHandler

func FromBackupHandlerToHandler(sync BackupHandler) generic.Handler

func FromResourceSetHandlerToHandler

func FromResourceSetHandlerToHandler(sync ResourceSetHandler) generic.Handler

func FromRestoreHandlerToHandler

func FromRestoreHandlerToHandler(sync RestoreHandler) generic.Handler

func RegisterBackupGeneratingHandler

func RegisterBackupGeneratingHandler(ctx context.Context, controller BackupController, apply apply.Apply,
	condition condition.Cond, name string, handler BackupGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterBackupStatusHandler

func RegisterBackupStatusHandler(ctx context.Context, controller BackupController, condition condition.Cond, name string, handler BackupStatusHandler)

func RegisterRestoreGeneratingHandler

func RegisterRestoreGeneratingHandler(ctx context.Context, controller RestoreController, apply apply.Apply,
	condition condition.Cond, name string, handler RestoreGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterRestoreStatusHandler

func RegisterRestoreStatusHandler(ctx context.Context, controller RestoreController, condition condition.Cond, name string, handler RestoreStatusHandler)

func UpdateBackupDeepCopyOnChange

func UpdateBackupDeepCopyOnChange(client BackupClient, obj *v1.Backup, handler func(obj *v1.Backup) (*v1.Backup, error)) (*v1.Backup, error)

func UpdateResourceSetDeepCopyOnChange

func UpdateResourceSetDeepCopyOnChange(client ResourceSetClient, obj *v1.ResourceSet, handler func(obj *v1.ResourceSet) (*v1.ResourceSet, error)) (*v1.ResourceSet, error)

func UpdateRestoreDeepCopyOnChange

func UpdateRestoreDeepCopyOnChange(client RestoreClient, obj *v1.Restore, handler func(obj *v1.Restore) (*v1.Restore, error)) (*v1.Restore, error)

Types

type BackupCache

type BackupCache interface {
	Get(name string) (*v1.Backup, error)
	List(selector labels.Selector) ([]*v1.Backup, error)

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

type BackupClient

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

type BackupController

type BackupController interface {
	generic.ControllerMeta
	BackupClient

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

	Cache() BackupCache
}

func NewBackupController

func NewBackupController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) BackupController

type BackupGeneratingHandler

type BackupGeneratingHandler func(obj *v1.Backup, status v1.BackupStatus) ([]runtime.Object, v1.BackupStatus, error)

type BackupHandler

type BackupHandler func(string, *v1.Backup) (*v1.Backup, error)

type BackupIndexer

type BackupIndexer func(obj *v1.Backup) ([]string, error)

type BackupStatusHandler

type BackupStatusHandler func(obj *v1.Backup, status v1.BackupStatus) (v1.BackupStatus, error)

type Interface

type Interface interface {
	Backup() BackupController
	ResourceSet() ResourceSetController
	Restore() RestoreController
}

func New

func New(controllerFactory controller.SharedControllerFactory) Interface

type ResourceSetCache

type ResourceSetCache interface {
	Get(name string) (*v1.ResourceSet, error)
	List(selector labels.Selector) ([]*v1.ResourceSet, error)

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

type ResourceSetClient

type ResourceSetClient interface {
	Create(*v1.ResourceSet) (*v1.ResourceSet, error)
	Update(*v1.ResourceSet) (*v1.ResourceSet, error)

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

type ResourceSetController

type ResourceSetController interface {
	generic.ControllerMeta
	ResourceSetClient

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

	Cache() ResourceSetCache
}

func NewResourceSetController

func NewResourceSetController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ResourceSetController

type ResourceSetHandler

type ResourceSetHandler func(string, *v1.ResourceSet) (*v1.ResourceSet, error)

type ResourceSetIndexer

type ResourceSetIndexer func(obj *v1.ResourceSet) ([]string, error)

type RestoreCache

type RestoreCache interface {
	Get(name string) (*v1.Restore, error)
	List(selector labels.Selector) ([]*v1.Restore, error)

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

type RestoreClient

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

type RestoreController

type RestoreController interface {
	generic.ControllerMeta
	RestoreClient

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

	Cache() RestoreCache
}

func NewRestoreController

func NewRestoreController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) RestoreController

type RestoreGeneratingHandler

type RestoreGeneratingHandler func(obj *v1.Restore, status v1.RestoreStatus) ([]runtime.Object, v1.RestoreStatus, error)

type RestoreHandler

type RestoreHandler func(string, *v1.Restore) (*v1.Restore, error)

type RestoreIndexer

type RestoreIndexer func(obj *v1.Restore) ([]string, error)

type RestoreStatusHandler

type RestoreStatusHandler func(obj *v1.Restore, status v1.RestoreStatus) (v1.RestoreStatus, error)