mocks

Documentation

Index

• func GetMockStorageClient() *storage.DataStore
• type NopCloser
  • func (NopCloser) Close() error
• type TestDataStore
  • func (t *TestDataStore) ConstructReference(ctx context.Context, reference storage.DataReference, nestedKeys ...string) (storage.DataReference, error)
  • func (t *TestDataStore) CopyRaw(ctx context.Context, source, destination storage.DataReference, ...) error
  • func (t *TestDataStore) GetBaseContainerFQN(ctx context.Context) storage.DataReference
  • func (t *TestDataStore) Head(ctx context.Context, reference storage.DataReference) (storage.Metadata, error)
  • func (t *TestDataStore) ReadProtobuf(ctx context.Context, reference storage.DataReference, msg proto.Message) error
  • func (t *TestDataStore) ReadRaw(ctx context.Context, reference storage.DataReference) (io.ReadCloser, error)
  • func (t *TestDataStore) WriteProtobuf(ctx context.Context, reference storage.DataReference, opts storage.Options, ...) error
  • func (t *TestDataStore) WriteRaw(ctx context.Context, reference storage.DataReference, size int64, ...) error

Functions

func GetMockStorageClient

func GetMockStorageClient() *storage.DataStore

Types

type NopCloser

type NopCloser struct {
	io.Reader
}

func (NopCloser) Close

func (NopCloser) Close() error

type TestDataStore

type TestDataStore struct {
	HeadCb          func(ctx context.Context, reference storage.DataReference) (storage.Metadata, error)
	ReadProtobufCb  func(ctx context.Context, reference storage.DataReference, msg proto.Message) error
	WriteProtobufCb func(
		ctx context.Context, reference storage.DataReference, opts storage.Options, msg proto.Message) error
	ConstructReferenceCb func(
		ctx context.Context, reference storage.DataReference, nestedKeys ...string) (storage.DataReference, error)
	Store map[storage.DataReference][]byte
}

func (*TestDataStore) ConstructReference

func (t *TestDataStore) ConstructReference(
	ctx context.Context, reference storage.DataReference, nestedKeys ...string) (storage.DataReference, error)

func (*TestDataStore) CopyRaw

func (t *TestDataStore) CopyRaw(ctx context.Context, source, destination storage.DataReference, opts storage.Options) error

Copies from source to destination.

func (*TestDataStore) GetBaseContainerFQN

func (t *TestDataStore) GetBaseContainerFQN(ctx context.Context) storage.DataReference

func (*TestDataStore) Head

func (t *TestDataStore) Head(ctx context.Context, reference storage.DataReference) (storage.Metadata, error)

func (*TestDataStore) ReadProtobuf

func (t *TestDataStore) ReadProtobuf(ctx context.Context, reference storage.DataReference, msg proto.Message) error

func (*TestDataStore) ReadRaw

func (t *TestDataStore) ReadRaw(ctx context.Context, reference storage.DataReference) (io.ReadCloser, error)

Retrieves a byte array from the Blob store or an error

func (*TestDataStore) WriteProtobuf

func (t *TestDataStore) WriteProtobuf(
	ctx context.Context, reference storage.DataReference, opts storage.Options, msg proto.Message) error

func (*TestDataStore) WriteRaw

func (t *TestDataStore) WriteRaw(
	ctx context.Context, reference storage.DataReference, size int64, opts storage.Options, raw io.Reader) error

Stores a raw byte array.