kvmetainfo

Mar 19, 2020

Changes in this version

+ var DefaultES = storj.EncryptionParameters

+ var DefaultRS = storj.RedundancyScheme

+ var Error = errs.Class("SetupProject error")

+ type CreateObject struct

+ ContentType string

+ Expires time.Time

+ Metadata map[string]string

+ func (create CreateObject) Object(bucket storj.Bucket, path storj.Path) storj.Object

+ type DB struct

+ func New(project *Project, metainfo *metainfo.Client, streams streams.Store, ...) *DB

+ func (db *DB) CreateBucket(ctx context.Context, bucketName string, info *storj.Bucket) (bucketInfo storj.Bucket, err error)

+ func (db *DB) CreateObject(ctx context.Context, bucket storj.Bucket, path storj.Path, ...) (object MutableObject, err error)

+ func (db *DB) DeleteBucket(ctx context.Context, bucketName string) (_ storj.Bucket, err error)

+ func (db *DB) DeleteObject(ctx context.Context, bucket storj.Bucket, path storj.Path) (_ storj.Object, err error)

+ func (db *DB) GetBucket(ctx context.Context, bucketName string) (bucketInfo storj.Bucket, err error)

+ func (db *DB) GetObject(ctx context.Context, bucket storj.Bucket, path storj.Path) (info storj.Object, err error)

+ func (db *DB) GetObjectStream(ctx context.Context, bucket storj.Bucket, object storj.Object) (stream ReadOnlyStream, err error)

+ func (db *DB) Limits() (MetainfoLimits, error)

+ func (db *DB) ListBuckets(ctx context.Context, options storj.BucketListOptions) (list storj.BucketList, err error)

+ func (db *DB) ListObjects(ctx context.Context, bucket storj.Bucket, options storj.ListOptions) (list storj.ObjectList, err error)

+ func (db *DB) ListObjectsExtended(ctx context.Context, bucket storj.Bucket, options storj.ListOptions) (list storj.ObjectList, err error)

+ func (db *DB) ListPendingObjects(ctx context.Context, bucket storj.Bucket, options storj.ListOptions) (list storj.ObjectList, err error)

+ func (db *DB) ModifyObject(ctx context.Context, bucket storj.Bucket, path storj.Path) (object MutableObject, err error)

+ func (db *DB) ModifyPendingObject(ctx context.Context, bucket storj.Bucket, path storj.Path) (object MutableObject, err error)

+ type MetainfoLimits struct

+ ListLimit int64

+ MaximumInlineSegmentSize int64

+ MinimumRemoteSegmentSize int64

+ type MutableObject interface

+ Commit func(ctx context.Context) error

+ ContinueStream func(ctx context.Context) (MutableStream, error)

+ CreateStream func(ctx context.Context) (MutableStream, error)

+ DeleteStream func(ctx context.Context) error

+ Info func() storj.Object

+ type MutableStream interface

+ AddSegments func(ctx context.Context, segments ...storj.Segment) error

+ BucketName func() string

+ Expires func() time.Time

+ Metadata func() ([]byte, error)

+ Path func() string

+ UpdateSegments func(ctx context.Context, segments ...storj.Segment) error

+ type Project struct

+ func NewProject(streams streams.Store, encryptedBlockSize int32, segmentsSize int64, ...) *Project

+ func SetupProject(m *metainfo.Client) (*Project, error)

+ func (db *Project) CreateBucket(ctx context.Context, bucketName string, info *storj.Bucket) (_ storj.Bucket, err error)

+ func (db *Project) DeleteBucket(ctx context.Context, bucketName string) (_ storj.Bucket, err error)

+ func (db *Project) GetBucket(ctx context.Context, bucketName string) (_ storj.Bucket, err error)

+ func (db *Project) ListBuckets(ctx context.Context, listOpts storj.BucketListOptions) (_ storj.BucketList, err error)

+ type ReadOnlyStream interface

+ Info func() storj.Object

+ Segments func(ctx context.Context, index int64, limit int64) (infos []storj.Segment, more bool, err error)

+ SegmentsAt func(ctx context.Context, byteOffset int64, limit int64) (infos []storj.Segment, more bool, err error)