badger

package

v0.15.2 Latest Latest Go to latest Published: Nov 15, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Package badger implements the blobserver interface by storing each blob in a dgraph-io/badger database.

This section is empty.

This section is empty.

func BlobRefBytes(prefix string, br blob.Ref) []byte

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

func New(root, prefix string) (Storage, error)

func NewManaged(db *badgerdb.DB, prefix string) Storage

NewManaged uses the given badgerdb.DB.

func (sto Storage) Close() error

func (sto Storage) EnumerateBlobs(ctx context.Context, dest chan<- blob.SizedRef, after string, limit int) error

func (sto Storage) Fetch(ctx context.Context, br blob.Ref) (io.ReadCloser, uint32, error)

func (sto Storage) ReceiveBlob(ctx context.Context, br blob.Ref, source io.Reader) (blob.SizedRef, error)

func (sto Storage) RemoveBlobs(ctx context.Context, blobs []blob.Ref) error

func (sto Storage) ResetStorageGeneration() error

func (sto Storage) StatBlobs(ctx context.Context, blobs []blob.Ref, fn func(blob.SizedRef) error) error

func (sto Storage) StorageGeneration() (initTime time.Time, random string, err error)