storagetest

Documentation

Index

• func NewMockStorageExtension(getClientError error) storage.Extension
• func NewMockStorageExtensionWithDelay(getClientError error, executionDelay time.Duration) storage.Extension
• type MockStorageClient
  • func (m *MockStorageClient) Batch(_ context.Context, ops ...*storage.Operation) error
  • func (m *MockStorageClient) Close(context.Context) error
  • func (m *MockStorageClient) Delete(ctx context.Context, s string) error
  • func (m *MockStorageClient) Get(ctx context.Context, s string) ([]byte, error)
  • func (m *MockStorageClient) IsClosed() bool
  • func (m *MockStorageClient) Set(ctx context.Context, s string, bytes []byte) error

Functions

func NewMockStorageExtension

func NewMockStorageExtension(getClientError error) storage.Extension

func NewMockStorageExtensionWithDelay

func NewMockStorageExtensionWithDelay(getClientError error, executionDelay time.Duration) storage.Extension

Types

type MockStorageClient

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

func (*MockStorageClient) Batch

func (m *MockStorageClient) Batch(_ context.Context, ops ...*storage.Operation) error

func (*MockStorageClient) Close

func (m *MockStorageClient) Close(context.Context) error

func (*MockStorageClient) Delete

func (m *MockStorageClient) Delete(ctx context.Context, s string) error

func (*MockStorageClient) Get

func (m *MockStorageClient) Get(ctx context.Context, s string) ([]byte, error)

func (*MockStorageClient) IsClosed

func (m *MockStorageClient) IsClosed() bool

func (*MockStorageClient) Set

func (m *MockStorageClient) Set(ctx context.Context, s string, bytes []byte) error