memory

Documentation

Index

• Variables
• type Storage
  • func Open() *Storage
  • func (r *Storage) Exists(ctx context.Context, name string) (bool, error)
  • func (r *Storage) Get(ctx context.Context, name string, offs, size int64) (io.ReadCloser, error)
  • func (r *Storage) Kind() string
  • func (r *Storage) ListEntries(ctx context.Context, path string) ([]remotestorage.EntryInfo, []string, error)
  • func (r *Storage) Put(ctx context.Context, name string, fileName string) error
  • func (r *Storage) SetRandomPutDelays(minMs, maxMs int)
  • func (r *Storage) String() string

Variables

var (
	ErrInvalidArguments = errors.New("invalid arguments")
)

Types

type Storage

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

Storage implements a simple in-memory remote storage

func Open

func Open() *Storage

func (*Storage) Exists

func (r *Storage) Exists(ctx context.Context, name string) (bool, error)

Exists checks if a remove resource exists and can be read Note that due to an asynchronous nature of cluod storage, a resource stored with the Put method may not be immediately accessible

func (*Storage) Get

func (r *Storage) Get(ctx context.Context, name string, offs, size int64) (io.ReadCloser, error)

Get opens a stream of data for given object

func (*Storage) Kind

func (r *Storage) Kind() string

func (*Storage) ListEntries

func (r *Storage) ListEntries(ctx context.Context, path string) ([]remotestorage.EntryInfo, []string, error)

func (*Storage) Put

func (r *Storage) Put(ctx context.Context, name string, fileName string) error

Put writes a remote s3 resource

func (*Storage) SetRandomPutDelays

func (r *Storage) SetRandomPutDelays(minMs, maxMs int)

func (*Storage) String

func (r *Storage) String() string