localstore

Feb 20, 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)