cloudprovider

Documentation

Index

• func ValidateObjectStoreConfigKeys(config map[string]string, validKeys ...string) error
• func ValidateVolumeSnapshotterConfigKeys(config map[string]string, validKeys ...string) error
• type BucketData
• type InMemoryObjectStore
  • func NewInMemoryObjectStore(buckets ...string) *InMemoryObjectStore
  • func (o *InMemoryObjectStore) ClearBucket(bucket string)
  • func (o *InMemoryObjectStore) CreateSignedURL(bucket, key string, ttl time.Duration) (string, error)
  • func (o *InMemoryObjectStore) DeleteObject(bucket, key string) error
  • func (o *InMemoryObjectStore) GetObject(bucket, key string) (io.ReadCloser, error)
  • func (o *InMemoryObjectStore) Init(config map[string]string) error
  • func (o *InMemoryObjectStore) ListCommonPrefixes(bucket, prefix, delimiter string) ([]string, error)
  • func (o *InMemoryObjectStore) ListObjects(bucket, prefix string) ([]string, error)
  • func (o *InMemoryObjectStore) ObjectExists(bucket, key string) (bool, error)
  • func (o *InMemoryObjectStore) PutObject(bucket, key string, body io.Reader) error

Functions

func ValidateObjectStoreConfigKeys

func ValidateObjectStoreConfigKeys(config map[string]string, validKeys ...string) error

ValidateObjectStoreConfigKeys ensures that an object store's config is valid by making sure each `config` key is in the `validKeys` list. The special key "bucket" is always considered valid.

func ValidateVolumeSnapshotterConfigKeys

func ValidateVolumeSnapshotterConfigKeys(config map[string]string, validKeys ...string) error

ValidateVolumeSnapshotterConfigKeys ensures that a volume snapshotter's config is valid by making sure each `config` key is in the `validKeys` list.

Types

type BucketData

type BucketData map[string][]byte

type InMemoryObjectStore

type InMemoryObjectStore struct {
	Data map[string]BucketData
}

InMemoryObjectStore is a simple implementation of the ObjectStore interface that stores its data in-memory/in-proc. This is mainly intended to be used as a test fake.

func NewInMemoryObjectStore

func NewInMemoryObjectStore(buckets ...string) *InMemoryObjectStore

func (*InMemoryObjectStore) ClearBucket

func (o *InMemoryObjectStore) ClearBucket(bucket string)

func (*InMemoryObjectStore) CreateSignedURL

func (o *InMemoryObjectStore) CreateSignedURL(bucket, key string, ttl time.Duration) (string, error)

func (*InMemoryObjectStore) DeleteObject

func (o *InMemoryObjectStore) DeleteObject(bucket, key string) error

func (*InMemoryObjectStore) GetObject

func (o *InMemoryObjectStore) GetObject(bucket, key string) (io.ReadCloser, error)

func (*InMemoryObjectStore) Init

func (o *InMemoryObjectStore) Init(config map[string]string) error

func (*InMemoryObjectStore) ListCommonPrefixes

func (o *InMemoryObjectStore) ListCommonPrefixes(bucket, prefix, delimiter string) ([]string, error)

func (*InMemoryObjectStore) ListObjects

func (o *InMemoryObjectStore) ListObjects(bucket, prefix string) ([]string, error)

func (*InMemoryObjectStore) ObjectExists

func (o *InMemoryObjectStore) ObjectExists(bucket, key string) (bool, error)

func (*InMemoryObjectStore) PutObject

func (o *InMemoryObjectStore) PutObject(bucket, key string, body io.Reader) error