memorystorage

Documentation

Index

• Constants
• func NewStorageFactory(_ string) (storage.StorageFactory, error)
• type ClusterWatchEvent
• type ResourceStorage
  • func (s *ResourceStorage) Create(ctx context.Context, cluster string, obj runtime.Object) error
  • func (s *ResourceStorage) Delete(ctx context.Context, cluster string, obj runtime.Object) error
  • func (s *ResourceStorage) Get(ctx context.Context, cluster, namespace, name string, into runtime.Object) error
  • func (s *ResourceStorage) GetStorageConfig() *storage.ResourceStorageConfig
  • func (s *ResourceStorage) List(ctx context.Context, listObject runtime.Object, opts *internal.ListOptions) error
  • func (s *ResourceStorage) Update(ctx context.Context, cluster string, obj runtime.Object) error
  • func (s *ResourceStorage) Watch(ctx context.Context, options *internal.ListOptions) (watch.Interface, error)
• type StorageFactory
  • func (s *StorageFactory) CleanCluster(ctx context.Context, cluster string) error
  • func (s *StorageFactory) CleanClusterResource(ctx context.Context, cluster string, gvr schema.GroupVersionResource) error
  • func (s *StorageFactory) GetCollectionResources(ctx context.Context) ([]*internal.CollectionResource, error)
  • func (s *StorageFactory) GetResourceVersions(ctx context.Context, cluster string) (map[schema.GroupVersionResource]map[string]interface{}, error)
  • func (s *StorageFactory) GetSupportedRequestVerbs() []string
  • func (s *StorageFactory) NewCollectionResourceStorage(cr *internal.CollectionResource) (storage.CollectionResourceStorage, error)
  • func (s *StorageFactory) NewResourceStorage(config *storage.ResourceStorageConfig) (storage.ResourceStorage, error)
  • func (s *StorageFactory) PrepareCluster(cluster string) error

Constants

const (
	StorageName = "memory"
)

Functions

func NewStorageFactory

func NewStorageFactory(_ string) (storage.StorageFactory, error)

Types

type ClusterWatchEvent

type ClusterWatchEvent struct {
	Event       watch.Event
	ClusterName string
}

type ResourceStorage

type ResourceStorage struct {
	sync.RWMutex

	Codec runtime.Codec

	CrvSynchro *cache.ClusterResourceVersionSynchro
	// contains filtered or unexported fields
}

func (*ResourceStorage) Create

func (s *ResourceStorage) Create(ctx context.Context, cluster string, obj runtime.Object) error

func (*ResourceStorage) Delete

func (s *ResourceStorage) Delete(ctx context.Context, cluster string, obj runtime.Object) error

func (*ResourceStorage) Get

func (s *ResourceStorage) Get(ctx context.Context, cluster, namespace, name string, into runtime.Object) error

func (*ResourceStorage) GetStorageConfig

func (s *ResourceStorage) GetStorageConfig() *storage.ResourceStorageConfig

func (*ResourceStorage) List

func (s *ResourceStorage) List(ctx context.Context, listObject runtime.Object, opts *internal.ListOptions) error

func (*ResourceStorage) Update

func (s *ResourceStorage) Update(ctx context.Context, cluster string, obj runtime.Object) error

func (*ResourceStorage) Watch

func (s *ResourceStorage) Watch(ctx context.Context, options *internal.ListOptions) (watch.Interface, error)

type StorageFactory

type StorageFactory struct {
	// contains filtered or unexported fields
}

func (*StorageFactory) CleanCluster

func (s *StorageFactory) CleanCluster(ctx context.Context, cluster string) error

func (*StorageFactory) CleanClusterResource

func (s *StorageFactory) CleanClusterResource(ctx context.Context, cluster string, gvr schema.GroupVersionResource) error

func (*StorageFactory) GetCollectionResources

func (s *StorageFactory) GetCollectionResources(ctx context.Context) ([]*internal.CollectionResource, error)

func (*StorageFactory) GetResourceVersions

func (s *StorageFactory) GetResourceVersions(ctx context.Context, cluster string) (map[schema.GroupVersionResource]map[string]interface{}, error)

func (*StorageFactory) GetSupportedRequestVerbs

func (s *StorageFactory) GetSupportedRequestVerbs() []string

func (*StorageFactory) NewCollectionResourceStorage

func (s *StorageFactory) NewCollectionResourceStorage(cr *internal.CollectionResource) (storage.CollectionResourceStorage, error)

func (*StorageFactory) NewResourceStorage

func (s *StorageFactory) NewResourceStorage(config *storage.ResourceStorageConfig) (storage.ResourceStorage, error)

func (*StorageFactory) PrepareCluster

func (s *StorageFactory) PrepareCluster(cluster string) error