storage

Documentation

Index

• Variables
• func RecordMetrics(storage *RocksStorage)
• type DiskStorage
  • func NewDiskStorage(path string) (*DiskStorage, error)
  • func (storage *DiskStorage) Close() error
  • func (storage *DiskStorage) Del(key []byte) error
  • func (storage *DiskStorage) DisableBatch()
  • func (storage *DiskStorage) EnableBatch()
  • func (storage *DiskStorage) Flush() error
  • func (storage *DiskStorage) Get(key []byte) ([]byte, error)
  • func (storage *DiskStorage) Put(key []byte, value []byte) error
• type MemoryBatch
• type MemoryStorage
  • func NewMemoryStorage() (*MemoryStorage, error)
  • func (db *MemoryStorage) Del(key []byte) error
  • func (db *MemoryStorage) DisableBatch()
  • func (db *MemoryStorage) EnableBatch()
  • func (db *MemoryStorage) Flush() error
  • func (db *MemoryStorage) Get(key []byte) ([]byte, error)
  • func (db *MemoryStorage) Put(key []byte, value []byte) error
• type RocksStorage
  • 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

Variables

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

const

Functions

func RecordMetrics

func RecordMetrics(storage *RocksStorage)

RecordMetrics record rocksdb metrics

Types

type DiskStorage

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

DiskStorage the nodes in trie.

func NewDiskStorage

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

NewDiskStorage init a storage

func (*DiskStorage) Close

func (storage *DiskStorage) Close() error

Close levelDB

func (*DiskStorage) Del

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

Del delete the key in Storage.

func (*DiskStorage) DisableBatch

func (storage *DiskStorage) DisableBatch()

DisableBatch disable batch write.

func (*DiskStorage) EnableBatch

func (storage *DiskStorage) EnableBatch()

EnableBatch enable batch write.

func (*DiskStorage) Flush

func (storage *DiskStorage) Flush() error

Flush write and flush pending batch write.

func (*DiskStorage) Get

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

Get return value to the key in Storage

func (*DiskStorage) Put

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

Put put the key-value entry to Storage

type MemoryBatch

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

MemoryBatch do batch task in memory storage

type MemoryStorage

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

MemoryStorage the nodes in trie.

func NewMemoryStorage

func NewMemoryStorage() (*MemoryStorage, error)

NewMemoryStorage init a storage

func (*MemoryStorage) Del

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

Del delete the key in Storage.

func (*MemoryStorage) DisableBatch

func (db *MemoryStorage) DisableBatch()

DisableBatch disable batch write.

func (*MemoryStorage) EnableBatch

func (db *MemoryStorage) EnableBatch()

EnableBatch enable batch write.

func (*MemoryStorage) Flush

func (db *MemoryStorage) Flush() error

Flush write and flush pending batch write.

func (*MemoryStorage) Get

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

Get return value to the key in Storage

func (*MemoryStorage) Put

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

Put put the key-value entry to Storage

type RocksStorage

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

RocksStorage the nodes in trie.

func NewRocksStorage

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

NewRocksStorage init a storage

func (*RocksStorage) Close

func (storage *RocksStorage) Close() error

Close levelDB

func (*RocksStorage) Del

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

Del delete the key in Storage.

func (*RocksStorage) DisableBatch

func (storage *RocksStorage) DisableBatch()

DisableBatch disable batch write.

func (*RocksStorage) EnableBatch

func (storage *RocksStorage) EnableBatch()

EnableBatch enable batch write.

func (*RocksStorage) Flush

func (storage *RocksStorage) Flush() error

Flush write and flush pending batch write.

func (*RocksStorage) Get

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

Get return value to the key in Storage

func (*RocksStorage) Put

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

Put put the key-value entry to Storage

type Storage

type Storage interface {
	// Get return the value to the key in Storage.
	Get(key []byte) ([]byte, error)

	// Put put the key-value entry to Storage.
	Put(key []byte, value []byte) error

	// Del delete the key entry in Storage.
	Del(key []byte) error

	// EnableBatch enable batch write.
	EnableBatch()

	// DisableBatch disable batch write.
	DisableBatch()

	// Flush write and flush pending batch write.
	Flush() error
}

Storage interface of Storage.