bolt

Documentation

Index

• type DB
  • func Open(path string) (*DB, error)
• type Storage
  • func NewStorage(db *DB, bucket string) *Storage
  • func (s Storage) Delete(_ context.Context, refs ...string) error
  • func (s Storage) Get(_ context.Context, ref string) blob.Blob
  • func (s *Storage) Iter(ctx context.Context, state rx.Lens[string]) rx.Iter[blob.RefBlob]
  • func (s Storage) Set(_ context.Context, ref string, r io.Reader) error

Types

type DB

type DB = bolt.DB

func Open

func Open(path string) (*DB, error)

type Storage

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

func NewStorage

func NewStorage(db *DB, bucket string) *Storage

func (Storage) Delete

func (s Storage) Delete(_ context.Context, refs ...string) error

func (Storage) Get

func (s Storage) Get(_ context.Context, ref string) blob.Blob

func (*Storage) Iter

func (s *Storage) Iter(ctx context.Context, state rx.Lens[string]) rx.Iter[blob.RefBlob]

func (Storage) Set

func (s Storage) Set(_ context.Context, ref string, r io.Reader) error