storagemgr

Documentation

Index

• Constants
• func ExportCachedStorageMetrics()
• func Initialize(defaultKVType string, defaultKvCacheSize int, sync bool) error
• func NewCachedStorage(s storage.Storage, megabytesLimit int) (storage.Storage, error)
• func Open(p string) (storage.Storage, error)
• func OpenSpecifyType(typ string, p string) (storage.Storage, error)
• func ResetCachedStorageMetrics()
• type BatchWrapper
  • func (w *BatchWrapper) Commit()
  • func (w *BatchWrapper) Delete(key []byte)
  • func (w *BatchWrapper) Put(key, value []byte)
• type CachedStorage
  • func (c *CachedStorage) Close() error
  • func (c *CachedStorage) Delete(key []byte)
  • func (c *CachedStorage) Get(key []byte) []byte
  • func (c *CachedStorage) Has(key []byte) bool
  • func (c *CachedStorage) NewBatch() storage.Batch
  • func (c *CachedStorage) Put(key, value []byte)

Constants

const (
	BlockChain = "blockchain"
	Ledger     = "ledger"
	Blockfile  = "blockfile"
	Consensus  = "consensus"
	Epoch      = "epoch"
)

Functions

func ExportCachedStorageMetrics

func ExportCachedStorageMetrics()

func Initialize

func Initialize(defaultKVType string, defaultKvCacheSize int, sync bool) error

func NewCachedStorage

func NewCachedStorage(s storage.Storage, megabytesLimit int) (storage.Storage, error)

func Open

func Open(p string) (storage.Storage, error)

func OpenSpecifyType

func OpenSpecifyType(typ string, p string) (storage.Storage, error)

func ResetCachedStorageMetrics

func ResetCachedStorageMetrics()

Types

type BatchWrapper

type BatchWrapper struct {
	storage.Batch
	// contains filtered or unexported fields
}

func (*BatchWrapper) Commit

func (w *BatchWrapper) Commit()

func (*BatchWrapper) Delete

func (w *BatchWrapper) Delete(key []byte)

func (*BatchWrapper) Put

func (w *BatchWrapper) Put(key, value []byte)

type CachedStorage

type CachedStorage struct {
	storage.Storage
	// contains filtered or unexported fields
}

func (*CachedStorage) Close

func (c *CachedStorage) Close() error

func (*CachedStorage) Delete

func (c *CachedStorage) Delete(key []byte)

func (*CachedStorage) Get

func (c *CachedStorage) Get(key []byte) []byte

func (*CachedStorage) Has

func (c *CachedStorage) Has(key []byte) bool

func (*CachedStorage) NewBatch

func (c *CachedStorage) NewBatch() storage.Batch

func (*CachedStorage) Put

func (c *CachedStorage) Put(key, value []byte)