Documentation
¶
Index ¶
- type 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) IterWithAttributes(ctx context.Context, dir string, ...) error
- func (b *InMemBucket) Name() string
- func (b *InMemBucket) Objects() map[string][]byte
- func (b *InMemBucket) Provider() objstore.ObjProvider
- func (b *InMemBucket) Set(name string, data []byte)
- func (i *InMemBucket) SupportedIterOptions() []objstore.IterOptionType
- func (b *InMemBucket) Upload(_ context.Context, name string, r io.Reader, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) 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) IterWithAttributes ¶ added in v1.13.0
func (b *InMemBucket) IterWithAttributes(ctx context.Context, dir string, f func(attrs objstore.IterObjectAttributes) error, options ...objstore.IterOption) error
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) Provider ¶ added in v1.13.0
func (b *InMemBucket) Provider() objstore.ObjProvider
func (*InMemBucket) Set ¶
func (b *InMemBucket) Set(name string, data []byte)
func (*InMemBucket) SupportedIterOptions ¶ added in v1.13.0
func (i *InMemBucket) SupportedIterOptions() []objstore.IterOptionType
Source Files