kvstore

type DiskKV ¶

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

DiskKV is a disk-backed key-value store, every key-value pair is a hex-encoded .txt file, with the value as content. DiskKV is safe for concurrent use with a single DiskKV instance. DiskKV is not safe for concurrent use between different DiskKV instances of the same disk directory: a Put needs to be completed before another DiskKV Get retrieves the values.

func NewDiskKV(path string) *DiskKV

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

func (d *DiskKV) 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.
	// It returns ErrAlreadyExists when the key already exists.
	// 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)
}

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) Get(k common.Hash) ([]byte, error)

func (m *MemKV) 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)