statedb_cache

Documentation

Index

• type StateDBCacheBatch
  • func (b *StateDBCacheBatch) Delete(key []byte) error
  • func (b *StateDBCacheBatch) Put(key []byte, value []byte) error
  • func (b *StateDBCacheBatch) Replay(w ethdb.KeyValueWriter) error
  • func (b *StateDBCacheBatch) Reset()
  • func (b *StateDBCacheBatch) ValueSize() int
  • func (b *StateDBCacheBatch) Write() (err error)
• type StateDBCacheConfig
• type StateDBCacheDatabase
  • func NewStateDBCacheDatabase(remoteDB common.TiKVStore, config StateDBCacheConfig, readOnly bool) (*StateDBCacheDatabase, error)
  • func (c *StateDBCacheDatabase) Close() error
  • func (c *StateDBCacheDatabase) Compact(start []byte, limit []byte) error
  • func (c *StateDBCacheDatabase) Delete(key []byte) (err error)
  • func (c *StateDBCacheDatabase) Get(key []byte) (ret []byte, err error)
  • func (c *StateDBCacheDatabase) Has(key []byte) (bool, error)
  • func (c *StateDBCacheDatabase) NewBatch() ethdb.Batch
  • func (c *StateDBCacheDatabase) NewIterator(start, end []byte) ethdb.Iterator
  • func (c *StateDBCacheDatabase) Put(key []byte, value []byte) (err error)
  • func (c *StateDBCacheDatabase) ReplayCache(batch ethdb.Batch) error
  • func (c *StateDBCacheDatabase) Stat(property string) (string, error)

Types

type StateDBCacheBatch

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

func (*StateDBCacheBatch) Delete

func (b *StateDBCacheBatch) Delete(key []byte) error

func (*StateDBCacheBatch) Put

func (b *StateDBCacheBatch) Put(key []byte, value []byte) error

func (*StateDBCacheBatch) Replay

func (b *StateDBCacheBatch) Replay(w ethdb.KeyValueWriter) error

func (*StateDBCacheBatch) Reset

func (b *StateDBCacheBatch) Reset()

func (*StateDBCacheBatch) ValueSize

func (b *StateDBCacheBatch) ValueSize() int

func (*StateDBCacheBatch) Write

func (b *StateDBCacheBatch) Write() (err error)

type StateDBCacheConfig

type StateDBCacheConfig struct {
	CacheSizeInMB        uint32
	CachePersistencePath string
	RedisServerAddr      []string
	RedisLRUTimeInDay    uint32
	DebugHitRate         bool
}

type StateDBCacheDatabase

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

func NewStateDBCacheDatabase

func NewStateDBCacheDatabase(remoteDB common.TiKVStore, config StateDBCacheConfig, readOnly bool) (*StateDBCacheDatabase, error)

func (*StateDBCacheDatabase) Close

func (c *StateDBCacheDatabase) Close() error

Close disconnect the redis and save memory cache to file

func (*StateDBCacheDatabase) Compact

func (c *StateDBCacheDatabase) Compact(start []byte, limit []byte) error

func (*StateDBCacheDatabase) Delete

func (c *StateDBCacheDatabase) Delete(key []byte) (err error)

Delete removes the key from the key-value data store.

func (*StateDBCacheDatabase) Get

func (c *StateDBCacheDatabase) Get(key []byte) (ret []byte, err error)

Get retrieves the given key if it's present in the key-value data store.

func (*StateDBCacheDatabase) Has

func (c *StateDBCacheDatabase) Has(key []byte) (bool, error)

Has retrieves if a key is present in the key-value data store.

func (*StateDBCacheDatabase) NewBatch

func (c *StateDBCacheDatabase) NewBatch() ethdb.Batch

NewBatch creates a write-only database that buffers changes to its host db until a final write is called.

func (*StateDBCacheDatabase) NewIterator

func (c *StateDBCacheDatabase) NewIterator(start, end []byte) ethdb.Iterator

func (*StateDBCacheDatabase) Put

func (c *StateDBCacheDatabase) Put(key []byte, value []byte) (err error)

Put inserts the given value into the key-value data store.

func (*StateDBCacheDatabase) ReplayCache

func (c *StateDBCacheDatabase) ReplayCache(batch ethdb.Batch) error

func (*StateDBCacheDatabase) Stat

func (c *StateDBCacheDatabase) Stat(property string) (string, error)

Stat returns a particular internal stat of the database.