storage

Documentation

Index

• func IsRecoverableException(err error) bool
• 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 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

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

type ResourceStorageConfig

type ResourceStorageConfig struct {
	GroupResource        schema.GroupResource
	StorageGroupResource schema.GroupResource

	Codec          runtime.Codec
	StorageVersion schema.GroupVersion
	MemoryVersion  schema.GroupVersion
}

type StorageFactory

type StorageFactory interface {
	GetResourceVersions(ctx context.Context, cluster string) (map[schema.GroupVersionResource]map[string]interface{}, error)
	CleanCluster(ctx context.Context, cluster string) error
	CleanClusterResource(ctx context.Context, cluster string, gvr schema.GroupVersionResource) error

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

	GetCollectionResources(ctx context.Context) ([]*internal.CollectionResource, error)
}

func NewStorageFactory

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