v1

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Sep 30, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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)

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.