db

package
v1.3.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 13, 2021 License: Apache-2.0 Imports: 9 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// prefix+hash -> Account Trie Node and Value
	KPAccountNode  = []byte("aa")
	KPAccountValue = []byte("ab")
	// prefix+hash -> Code of Account
	KPCode = []byte("ac")
	// prefix+hash -> Account Storage Trie Node
	KPAccStorageNode = []byte("ad")
	// prefix+hash -> Account Long Storage Trie Node and Value (for system contract)
	KPAccLongNode  = []byte("am")
	KPAccLongValue = []byte("an")
	// shard chain
	// prefix + hash -> AccountDelta Trie Node and Value
	KPDeltaNodeNode  = []byte("ae")
	KPDeltaNodeValue = []byte("af")
	// prefix + header.BalanceDeltaRoot -> combined trie of AccountDelta Tries
	KPDeltaTrie = []byte("ag")
	// prefix + shard.ElectChainID.Formalize() + heightOfBlock.Bytes() -> hash root of Account
	KPDeltaFromTrie = []byte("ah")
	// prefix + DeltaFromKey{ShardID, Height} -> serialization of []*AccountDelta
	KPDeltaFroms          = []byte("ai")
	KPDeltaFromMaxHeight  = []byte("aj")
	KPDeltaFromWaterline  = []byte("ak")
	KPDeltaToBeSent       = []byte("ao")
	KPDFWaterlineSnapshot = []byte("ap")

	// prefix + HistoryTree.Node.Hash -> HistoryTree.Node.Children/Leafs
	KPHistoryNode = []byte("al")

	// prefix+hash -> Transaction Trie Node and Value
	KPTxNode  = []byte("tk")
	KPTxValue = []byte("tv")
	// prefix+hash -> Transaction in block  and index of the all transactions
	KPTxIndex = []byte("ti")

	// prefix + hash -> Verifiable Cash Check Trie Node and Value
	KPVccNode  = []byte("va")
	KPVccValue = []byte("vb")
	// prefix + hash -> Cashed Verifiable Cash Check Trie Node and Value
	KPCVccNode  = []byte("vc")
	KPCVccValue = []byte("vd")
	// prefix + Vcc.Hash -> cash the check Tx.Hash
	KPCVccTxIndex = []byte("ve")

	// prefix+hash(Header) -> block/Header height
	KPBlockNumByHash = []byte("bn")
	// prefix+height -> Header hash
	KPBlockHashByNum = []byte("bh")
	// // prefix+hash(header) -> Header encoded value
	// KPBlockHeader = []byte("bv")
	// prefix+hash(header) -> block encoded value
	KPBlock = []byte("bb")
	// prefix -> current Highest block height
	KPCurrentHeight = []byte("bc")
	// prefix+hash(Header) -> Receipts
	KPReceipts = []byte("br")
	// prefix+height -> received data block (not yet processed, just persisted in the database)
	KPBlockNotVerified = []byte("bv")
	// prefix+EpochNum -> election results of the EpochNum'th committee
	// key is the elected Epoch, not the Epoch at the time of the election, starting
	// from 0. If the election result fails, continue
	KPEpochComm = []byte("bec")

	// main chain
	// prefix + FormalizedChainID -> ChainInfos Trie Node and Value
	KPChainNode  = []byte("cn")
	KPChainValue = []byte("ci")
	// prefix + ChainId + EpochNum -> Committee
	KPChainEpochCommittee = []byte("ce")
	// prefix + ChainId + Height -> Header
	KPChainHeightHeader = []byte("ch")
	// prefix + ChainId + Height -> BlockProof
	KPChainHeightProof = []byte("cp")
	// the earliest Cursor on the main chain received by the current node and has not yet
	// issued a reward, the reward can be issue from this height to process the Request
	KPRewardHeightCursor = []byte("cf")

	// prefix+ChainID -> the latest (block height + block Hash) has been reported
	KPChainReportCursor = []byte("cc")

	KPRewardBase = []byte("rb")

	KPRRNode          = []byte("ra") // Required Reserve Trie Node Prefix
	KPRRValue         = []byte("rc") // Required Reserve Trie Value Prefix
	KPRRCNode         = []byte("rd") // Required Reserve Changing Trie Node Prefix
	KPRRCValue        = []byte("re") // Required Reserve Changing Trie Value Prefix
	KPRRRoot          = []byte("rf") // Required Reserve Trie Root Hash: prefix+EraNum -> RootOfRRTrie
	KPSettleInfoNode  = []byte("rg") // Settle info for one node trie node prefix
	KPSettleInfoValue = []byte("ri") // settle info for one node trie value preifx
	KPRRActReceipts   = []byte("rh") // RRAct Receipts in one block, prefix+RRActReceipts.RootHash -> (stream of RRActReceipts)
	KPRRActRptIndex   = []byte("rj") // prefix+TxHash -> (RRActReceipts.RootHash, Index in RRActReceipts)

	KPStorageEntry = []byte("se")

	ErrNotFound = errors.New("data not found")
	ErrReadOnly = errors.New("read only database")
)

Functions

func BatchWrite 

func BatchWrite(dbase Database, threshold, length int,
	write func(j int, w Writer) (ok bool, err error)) (count int, err error)

func CopySlice 

func CopySlice(val []byte) []byte

func GetNilError 

func GetNilError(db Database, key []byte) ([]byte, error)

func NewCachedDB 

func NewCachedDB(db Database, cacheSize int) (*cachedDB, error)

func PrefixKey 

func PrefixKey(prefix []byte, key []byte) []byte

func PrefixKey2 

func PrefixKey2(prefix1 []byte, prefix2 []byte, key []byte) []byte

func ToBlockHashKey 

func ToBlockHashKey(height common.Height) []byte

func ToBlockKey 

func ToBlockKey(hashOfHeader []byte) []byte

func ToBlockNotVerified 

func ToBlockNotVerified(height common.Height) []byte

func ToBlockNumberKey 

func ToBlockNumberKey(hashOfHeader []byte) []byte

func ToBlockReceiptsKey 

func ToBlockReceiptsKey(hashOfHeader []byte) []byte

func ToBlockTXIndexKey 

func ToBlockTXIndexKey(hashOfTransacion []byte) []byte

func ToChainCommitteeKey 

func ToChainCommitteeKey(chainId common.ChainID, epochNum common.EpochNum) []byte

func ToChainHeightHeaderKey 

func ToChainHeightHeaderKey(chainId common.ChainID, height common.Height) []byte

func ToChainHeightProofKey 

func ToChainHeightProofKey(chainId common.ChainID, height common.Height) []byte

func ToChainReportCursorKey 

func ToChainReportCursorKey(chainId common.ChainID) []byte

func ToCurrentHeightKey 

func ToCurrentHeightKey() []byte

func ToDFWaterlineSnapshotKey 

func ToDFWaterlineSnapshotKey(hashOfWaterlines []byte) []byte

func ToDeltaFromKey 

func ToDeltaFromKey(fromID common.ChainID, height common.Height) []byte

func ToDeltaFromMaxHeightKey 

func ToDeltaFromMaxHeightKey(fromID common.ChainID) []byte

func ToDeltaFromWaterlineKey 

func ToDeltaFromWaterlineKey(fromID common.ChainID) []byte

func ToDeltaToBeSentKey 

func ToDeltaToBeSentKey() []byte

func ToEpochCommKey 

func ToEpochCommKey(chainId common.ChainID, epoch common.EpochNum) []byte

func ToFirstRewardCursorKey 

func ToFirstRewardCursorKey() []byte

func ToRRActReceiptsKey added in v1.3.6 

func ToRRActReceiptsKey(rootOfReceipts []byte) []byte

func ToRRActRptIndexKey added in v1.3.6 

func ToRRActRptIndexKey(hashOfTx []byte) []byte

func ToRRKey 

func ToRRKey(era common.EraNum) []byte

func ToRewardBaseKey 

func ToRewardBaseKey(chainId common.ChainID) []byte

func ToStorageEntryKey 

func ToStorageEntryKey(root []byte, num int) []byte

Types

type Batch 

type Batch interface {
	Put(key, value []byte) error
	Delete(key []byte) error
	Size() int
}

type DataAdapter 

type DataAdapter interface {
	Load(key []byte) (value []byte, err error)
	Save(key []byte, value []byte) error
}

func NewKeyPrefixedDataAdapter 

func NewKeyPrefixedDataAdapter(database Database, keyPrefix []byte) DataAdapter

func NewTransparentDataAdapter 

func NewTransparentDataAdapter() DataAdapter

type Database 

type Database interface {
	Put(key, value []byte) error
	Has(key []byte) (bool, error)
	Get(key []byte) ([]byte, error)
	Delete(key []byte) error
	NewBatch() Batch
	Batch(batch Batch) error
	Close() error
}

func NewCachedDBWithPath 

func NewCachedDBWithPath(path string, cacheSize int) (Database, error)

func NewMemDB 

func NewMemDB() Database

func ReadOnly added in v1.3.6 

func ReadOnly(dbase Database) Database

func Temporary added in v1.3.6 

func Temporary(dbase Database) Database

type DummyAdapter 

type DummyAdapter struct{}

func (DummyAdapter) Load 

func (d DummyAdapter) Load(key []byte) (value []byte, err error)

func (DummyAdapter) Save 

func (d DummyAdapter) Save(key []byte, value []byte) error

type KeyBatch 

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

func (*KeyBatch) Delete 

func (k *KeyBatch) Delete(key []byte) error

func (*KeyBatch) Put 

func (k *KeyBatch) Put(key, value []byte) error

func (*KeyBatch) Size 

func (k *KeyBatch) Size() int

type KeyDatabase 

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

func (*KeyDatabase) Batch 

func (d *KeyDatabase) Batch(batch Batch) error

func (*KeyDatabase) Close 

func (d *KeyDatabase) Close() error

func (*KeyDatabase) Delete 

func (d *KeyDatabase) Delete(key []byte) error

func (*KeyDatabase) Get 

func (d *KeyDatabase) Get(key []byte) ([]byte, error)

func (*KeyDatabase) Has 

func (d *KeyDatabase) Has(key []byte) (bool, error)

func (*KeyDatabase) NewBatch 

func (d *KeyDatabase) NewBatch() Batch

func (*KeyDatabase) Put 

func (d *KeyDatabase) Put(key, value []byte) error

type LDB 

type LDB struct {
	common.AbstractService
	// contains filtered or unexported fields
}

func NewLDB 

func NewLDB(path string) (*LDB, error)

func (*LDB) Batch 

func (db *LDB) Batch(batch Batch) error

func (*LDB) Delete 

func (db *LDB) Delete(key []byte) error

func (*LDB) Get 

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

func (*LDB) Has 

func (db *LDB) Has(key []byte) (bool, error)

func (*LDB) NewBatch 

func (db *LDB) NewBatch() Batch

func (*LDB) Path 

func (db *LDB) Path() string

func (*LDB) Put 

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

type MemDB 

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

func (*MemDB) Batch 

func (m *MemDB) Batch(batch Batch) error

func (*MemDB) Close 

func (m *MemDB) Close() error

func (*MemDB) Delete 

func (m *MemDB) Delete(key []byte) error

func (*MemDB) Get 

func (m *MemDB) Get(key []byte) ([]byte, error)

func (*MemDB) Has 

func (m *MemDB) Has(key []byte) (bool, error)

func (*MemDB) NewBatch 

func (m *MemDB) NewBatch() Batch

func (*MemDB) Put 

func (m *MemDB) Put(key, value []byte) error

type Writer 

type Writer interface {
	Put(key, value []byte) error
	Delete(key []byte) error
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.