storage

May 8, 2018

Changes in this version

+ func RecordMetrics(storage *RocksStorage)

Mar 29, 2018

Changes in this version

type DiskStorage

+ func (storage *DiskStorage) DisableBatch()

+ func (storage *DiskStorage) EnableBatch()

+ func (storage *DiskStorage) Flush() error

+ type MemoryBatch struct

type MemoryStorage

+ func (db *MemoryStorage) DisableBatch()

+ func (db *MemoryStorage) EnableBatch()

+ func (db *MemoryStorage) Flush() error

+ type RocksStorage struct

+ func NewRocksStorage(path string) (*RocksStorage, error)

+ func (storage *RocksStorage) Close() error

+ func (storage *RocksStorage) Del(key []byte) error

+ func (storage *RocksStorage) DisableBatch()

+ func (storage *RocksStorage) EnableBatch()

+ func (storage *RocksStorage) Flush() error

+ func (storage *RocksStorage) Get(key []byte) ([]byte, error)

+ func (storage *RocksStorage) Put(key []byte, value []byte) error

type Storage

+ DisableBatch func()

+ EnableBatch func()

+ Flush func() error

Nov 7, 2017

Changes in this version

+ var ErrKeyNotFound = errors.New("not found")

+ type DiskStorage struct

+ func NewDiskStorage(path string) (*DiskStorage, error)

+ func (storage *DiskStorage) Close() error

+ func (storage *DiskStorage) Del(key []byte) error

+ func (storage *DiskStorage) Get(key []byte) ([]byte, error)

+ func (storage *DiskStorage) Put(key []byte, value []byte) error

+ type MemoryStorage struct

+ func NewMemoryStorage() (*MemoryStorage, error)

+ func (db *MemoryStorage) Del(key []byte) error

+ func (db *MemoryStorage) Get(key []byte) ([]byte, error)

+ func (db *MemoryStorage) Put(key []byte, value []byte) error

Oct 17, 2017

Changes in this version

+ type Storage interface

+ Del func(key []byte) error

+ Get func(key []byte) ([]byte, error)

+ Put func(key []byte, value []byte) error