Versions in this module Expand all Collapse all v1 v1.8.25 Apr 9, 2019 v1.8.24 Apr 8, 2019 Changes in this version + var ErrAddressLockTimeout = errors.New("address lock timeout") + var ErrInvalidMode = errors.New("invalid mode") + type ChunkDescriptor struct + Address storage.Address + StoreTimestamp int64 + func (c *ChunkDescriptor) String() string + type DB struct + func New(path string, baseKey []byte, o *Options) (db *DB, err error) + func (db *DB) Close() (err error) + func (db *DB) NewGetter(mode ModeGet) *Getter + func (db *DB) NewPutter(mode ModePut) *Putter + func (db *DB) NewSetter(mode ModeSet) *Setter + func (db *DB) SubscribePull(ctx context.Context, bin uint8, since, until *ChunkDescriptor) (c <-chan ChunkDescriptor, stop func()) + func (db *DB) SubscribePush(ctx context.Context) (c <-chan storage.Chunk, stop func()) + type Getter struct + func (g *Getter) Get(addr storage.Address) (chunk storage.Chunk, err error) + type ModeGet int + const ModeGetRequest + const ModeGetSync + type ModePut int + const ModePutRequest + const ModePutSync + const ModePutUpload + type ModeSet int + const ModeSetAccess + const ModeSetSync + type Options struct + Capacity int64 + MetricsPrefix string + MockStore *mock.NodeStore + type Putter struct + func (p *Putter) Put(ch storage.Chunk) (err error) + type Setter struct + func (s *Setter) Set(addr storage.Address) (err error) Incompatible versions in this module v2.3.0+incompatible May 22, 2019
Go to main page