kvstore

type FileKV ¶ added in v1.9.2

type FileKV struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

FileKV is a disk-backed key-value store, every key-value pair is a hex-encoded .txt file, with the value as content. FileKV is safe for concurrent use with a single FileKV instance. FileKV is safe for concurrent use between different FileKV instances of the same disk directory as long as the file system supports atomic renames.

func NewFileKV(path string) *FileKV

func (d *FileKV) Close() error

func (d *FileKV) Get(k common.Hash) ([]byte, error)

func (d *FileKV) Put(k common.Hash, v []byte) error

type KV ¶

type KV interface {
	// Put puts the pre-image value v in the key-value store with key k.
	// KV store implementations may return additional errors specific to the KV storage.
	Put(k common.Hash, v []byte) error

	// Get retrieves the pre-image with key k from the key-value store.
	// It returns ErrNotFound when the pre-image cannot be found.
	// KV store implementations may return additional errors specific to the KV storage.
	Get(k common.Hash) ([]byte, error)

	// Closes the KV store.
	Close() error
}

KV is a Key-Value store interface for pre-image data.

type LocalPreimageSource ¶ added in v1.0.5

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

func NewLocalPreimageSource(config *config.Config) *LocalPreimageSource

func (s *LocalPreimageSource) Get(key common.Hash) ([]byte, error)

type MemKV ¶

type MemKV struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

MemKV implements the KV store interface in memory, backed by a regular Go map. This should only be used in testing, as large programs may require more pre-image data than available memory. MemKV is safe for concurrent use.

func NewMemKV() *MemKV

func (m *MemKV) Close() error

func (m *MemKV) Get(k common.Hash) ([]byte, error)

func (m *MemKV) Put(k common.Hash, v []byte) error

type PebbleKV ¶ added in v1.9.2

type PebbleKV struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

PebbleKV is a disk-backed key-value store, with PebbleDB as the underlying DBMS. PebbleKV is safe for concurrent use with a single PebbleKV instance.

func NewPebbleKV(path string) *PebbleKV

func (d *PebbleKV) Close() error

func (d *PebbleKV) Get(k common.Hash) ([]byte, error)

func (d *PebbleKV) Put(k common.Hash, v []byte) error

type PreimageSource ¶ added in v1.0.5

type PreimageSource func(key common.Hash) ([]byte, error)

type PreimageSourceSplitter ¶ added in v1.0.5

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

func NewPreimageSourceSplitter(local PreimageSource, global PreimageSource) *PreimageSourceSplitter

func (s *PreimageSourceSplitter) Get(key [32]byte) ([]byte, error)