kvmetainfo

package
v0.9.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 15, 2019 License: AGPL-3.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var DefaultES = storj.EncryptionScheme{
	Cipher:    storj.AESGCM,
	BlockSize: 1 * memory.KiB.Int32(),
}

DefaultES default values for EncryptionScheme

View Source
var DefaultRS = storj.RedundancyScheme{
	Algorithm:      storj.ReedSolomon,
	RequiredShares: 20,
	RepairShares:   30,
	OptimalShares:  40,
	TotalShares:    50,
	ShareSize:      1 * memory.KiB.Int32(),
}

DefaultRS default values for RedundancyScheme

Functions

This section is empty.

Types

type DB

type DB struct {
	*Project
	// contains filtered or unexported fields
}

DB implements metainfo database

func New

func New(metainfo metainfo.Client, buckets buckets.Store, streams streams.Store, segments segments.Store, rootKey *storj.Key) *DB

New creates a new metainfo database

func (*DB) CreateObject

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

CreateObject creates an uploading object and returns an interface for uploading Object information

func (*DB) DeleteObject

func (db *DB) DeleteObject(ctx context.Context, bucket string, path storj.Path) (err error)

DeleteObject deletes an object from database

func (*DB) GetObject

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

GetObject returns information about an object

func (*DB) GetObjectStream

func (db *DB) GetObjectStream(ctx context.Context, bucket string, path storj.Path) (stream storj.ReadOnlyStream, err error)

GetObjectStream returns interface for reading the object stream

func (*DB) Limits

func (db *DB) Limits() (storj.MetainfoLimits, error)

Limits returns limits for this metainfo database

func (*DB) ListObjects

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

ListObjects lists objects in bucket based on the ListOptions

func (*DB) ListPendingObjects

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

ListPendingObjects lists pending objects in bucket based on the ListOptions

func (*DB) ModifyObject

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

ModifyObject modifies a committed object

func (*DB) ModifyPendingObject

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

ModifyPendingObject creates an interface for updating a partially uploaded object

type Project

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

Project implements project management operations

func NewProject

func NewProject(buckets buckets.Store) *Project

NewProject constructs a *Project

func (*Project) CreateBucket

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

CreateBucket creates a new bucket with the specified information

func (*Project) DeleteBucket

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

DeleteBucket deletes bucket

func (*Project) GetBucket

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

GetBucket gets bucket information

func (*Project) ListBuckets

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

ListBuckets lists buckets

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL