memory

Documentation

Index

• type InMemBucket
  • func NewInMemBucket() *InMemBucket
  • func (b *InMemBucket) Attributes(_ context.Context, name string) (objstore.ObjectAttributes, error)
  • func (b *InMemBucket) Close() error
  • func (b *InMemBucket) Delete(_ context.Context, name string) error
  • func (b *InMemBucket) Exists(_ context.Context, name string) (bool, error)
  • func (b *InMemBucket) Get(_ context.Context, name string) (io.ReadCloser, error)
  • func (b *InMemBucket) GetRange(_ context.Context, name string, off, length int64) (io.ReadCloser, error)
  • func (b *InMemBucket) IsAccessDeniedErr(err error) bool
  • func (b *InMemBucket) IsObjNotFoundErr(err error) bool
  • func (b *InMemBucket) Iter(_ context.Context, dir string, f func(string) error, ...) error
  • func (b *InMemBucket) Name() string
  • func (b *InMemBucket) Objects() map[string][]byte
  • func (b *InMemBucket) Set(name string, data []byte)
  • func (b *InMemBucket) Upload(_ context.Context, name string, r io.Reader) error

Types

type InMemBucket

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

InMemBucket implements the objstore.Bucket interfaces against local memory. Methods from Bucket interface are thread-safe. Objects are assumed to be immutable.

func NewInMemBucket

func NewInMemBucket() *InMemBucket

NewInMemBucket returns a new in memory Bucket. NOTE: Returned bucket is just a naive in memory bucket implementation. For test use cases only.

func (*InMemBucket) Attributes

func (b *InMemBucket) Attributes(_ context.Context, name string) (objstore.ObjectAttributes, error)

Attributes returns information about the specified object.

func (*InMemBucket) Close

func (b *InMemBucket) Close() error

func (*InMemBucket) Delete

func (b *InMemBucket) Delete(_ context.Context, name string) error

Delete removes all data prefixed with the dir.

func (*InMemBucket) Exists

func (b *InMemBucket) Exists(_ context.Context, name string) (bool, error)

Exists checks if the given directory exists in memory.

func (*InMemBucket) Get

func (b *InMemBucket) Get(_ context.Context, name string) (io.ReadCloser, error)

Get returns a reader for the given object name.

func (*InMemBucket) GetRange

func (b *InMemBucket) GetRange(_ context.Context, name string, off, length int64) (io.ReadCloser, error)

GetRange returns a new range reader for the given object name and range.

func (*InMemBucket) IsAccessDeniedErr

func (b *InMemBucket) IsAccessDeniedErr(err error) bool

IsAccessDeniedErr returns true if access to object is denied.

func (*InMemBucket) IsObjNotFoundErr

func (b *InMemBucket) IsObjNotFoundErr(err error) bool

IsObjNotFoundErr returns true if error means that object is not found. Relevant to Get operations.

func (*InMemBucket) Iter

func (b *InMemBucket) Iter(_ context.Context, dir string, f func(string) error, options ...objstore.IterOption) error

Iter calls f for each entry in the given directory. The argument to f is the full object name including the prefix of the inspected directory.

func (*InMemBucket) Name

func (b *InMemBucket) Name() string

Name returns the bucket name.

func (*InMemBucket) Objects

func (b *InMemBucket) Objects() map[string][]byte

Objects returns a copy of the internally stored objects. NOTE: For assert purposes.

func (*InMemBucket) Set

func (b *InMemBucket) Set(name string, data []byte)

func (*InMemBucket) Upload

func (b *InMemBucket) Upload(_ context.Context, name string, r io.Reader) error

Upload writes the file specified in src to into the memory.