storage

Documentation

Index

• func IsRecoverableException(err error) bool
• func LoadPlugins(dir string) error
• func NewRecoverableException(err error) error
• func RegisterStorageFactoryFunc(name string, f NewStorageFactoryFunc)
• type CollectionResourceStorage
• type NewStorageFactoryFunc
• type ResourceStorage
• type ResourceStorageConfig
• type StorageFactory
  • func NewStorageFactory(name, configPath string) (StorageFactory, error)

Functions

func IsRecoverableException

func IsRecoverableException(err error) bool

func LoadPlugins

func LoadPlugins(dir string) error

func NewRecoverableException

func NewRecoverableException(err error) error

func RegisterStorageFactoryFunc

func RegisterStorageFactoryFunc(name string, f NewStorageFactoryFunc)

Types

type CollectionResourceStorage

type CollectionResourceStorage interface {
	Get(ctx context.Context, opts *internal.ListOptions) (*internal.CollectionResource, error)
}

type NewStorageFactoryFunc

type NewStorageFactoryFunc func(configPath string) (StorageFactory, error)

type ResourceStorage

type ResourceStorage interface {
	GetStorageConfig() *ResourceStorageConfig

	Get(ctx context.Context, cluster, namespace, name string, obj runtime.Object) error
	List(ctx context.Context, listObj runtime.Object, opts *internal.ListOptions) error
	Watch(ctx context.Context, options *internal.ListOptions) (watch.Interface, error)

	Create(ctx context.Context, cluster string, obj runtime.Object) error
	Update(ctx context.Context, cluster string, obj runtime.Object) error

	ConvertDeletedObject(obj interface{}) (runtime.Object, error)
	Delete(ctx context.Context, cluster string, obj runtime.Object) error
}

type ResourceStorageConfig

type ResourceStorageConfig struct {
	Namespaced bool

	GroupResource        schema.GroupResource
	StorageGroupResource schema.GroupResource

	MemoryVersion  schema.GroupVersion
	StorageVersion schema.GroupVersion

	Codec runtime.Codec
}

type StorageFactory

type StorageFactory interface {
	// Currently only supports returning a union of verbs for all resources,
	// in the future it may be necessary to return verbs depending on different resources.
	GetSupportedRequestVerbs() []string

	PrepareCluster(cluster string) error

	GetResourceVersions(ctx context.Context, cluster string) (map[schema.GroupVersionResource]map[string]interface{}, error)
	GetCollectionResources(ctx context.Context) ([]*internal.CollectionResource, error)

	NewResourceStorage(config *ResourceStorageConfig) (ResourceStorage, error)
	NewCollectionResourceStorage(cr *internal.CollectionResource) (CollectionResourceStorage, error)

	CleanCluster(ctx context.Context, cluster string) error
	CleanClusterResource(ctx context.Context, cluster string, gvr schema.GroupVersionResource) error
}

func NewStorageFactory

func NewStorageFactory(name, configPath string) (StorageFactory, error)