inmem

package

v0.6.1 Latest Latest Go to latest Published: Aug 14, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Bucket implements the store.Bucket and shipper.Bucket interfaces against local memory.

func NewBucket() *Bucket

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

func (b *Bucket) Close() error

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

Delete removes all data prefixed with the dir.

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

Exists checks if the given directory exists in memory.

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

Get returns a reader for the given object name.

func (b *Bucket) 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 (b *Bucket) IsObjNotFoundErr(err error) bool

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

func (b *Bucket) Iter(_ context.Context, dir string, f func(string) error) 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 (b *Bucket) Name() string

Name returns the bucket name.

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

Objects returns internally stored objects. NOTE: For assert purposes.

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

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