localstore

Mar 21, 2022

Changes in this version

type DB

+ func (db *DB) SetChunkInfo(chunkInfo chunkinfo.Interface)

Feb 17, 2022

Changes in this version

type Options

+ Driver string

Nov 23, 2021

Changes in this version

type DB

+ func (db *DB) WithChunkInfo(c chunkinfo.Interface)

Sep 29, 2021

Changes in this version

+ const DbSchemaCode

+ const DbSchemaNone

+ var DbSchemaCurrent = DbSchemaCode

+ var ErrInvalidMode = errors.New("invalid mode")

+ type DB struct

+ func New(path string, baseKey []byte, o *Options, logger logging.Logger) (db *DB, err error)

+ func (db *DB) Close() (err error)

+ func (db *DB) Config(c chunkinfo.Interface)

+ func (db *DB) DebugIndices() (indexInfo map[string]int, err error)

+ func (db *DB) Export(w io.Writer) (count int64, err error)

+ func (db *DB) Get(ctx context.Context, mode storage.ModeGet, addr boson.Address) (ch boson.Chunk, err error)

+ func (db *DB) GetMulti(ctx context.Context, mode storage.ModeGet, addrs ...boson.Address) (chunks []boson.Chunk, err error)

+ func (db *DB) Has(ctx context.Context, mode storage.ModeHas, addr boson.Address) (bool, error)

+ func (db *DB) HasMulti(ctx context.Context, hasMode storage.ModeHas, addrs ...boson.Address) ([]bool, error)

+ func (db *DB) Import(r io.Reader, legacy bool) (count int64, err error)

+ func (db *DB) Put(ctx context.Context, mode storage.ModePut, chs ...boson.Chunk) (exist []bool, err error)

+ func (db *DB) Set(ctx context.Context, mode storage.ModeSet, addrs ...boson.Address) (err error)

+ func (s *DB) Metrics() []prometheus.Collector

+ type Options struct

+ BlockCacheCapacity uint64

+ Capacity uint64

+ DisableSeeksCompaction bool

+ MetricsPrefix string

+ OpenFilesLimit uint64

+ WriteBufferSize uint64