store

package
v1.1.3-beta Latest Latest
Warning

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

 Go to latest Published: Jan 8, 2020 License: Apache-2.0 Imports: 23 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	AccountPrefix        = []byte{0x00}
	NanoPayPrefix        = []byte{0x01}
	NanoPayCleanupPrefix = []byte{0x02}
	NamePrefix           = []byte{0x03}
	NameRegistrantPrefix = []byte{0x04}
	PubSubPrefix         = []byte{0x05}
	PubSubCleanupPrefix  = []byte{0x06}
	IssueAssetPrefix     = []byte{0x07}
)

Functions

func NewAccount 

func NewAccount(n uint64, b *balance, id []byte) *account

func NewTrieStore 

func NewTrieStore(db db.IStore) *cachingDB

Types

type Asset 

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

func (*Asset) Deserialize 

func (ia *Asset) Deserialize(r io.Reader) error

func (*Asset) Empty 

func (ia *Asset) Empty() bool

func (*Asset) Serialize 

func (ia *Asset) Serialize(w io.Writer) error

type ChainStore 

type ChainStore struct {
	States *StateDB
	// contains filtered or unexported fields
}

func NewLedgerStore 

func NewLedgerStore() (*ChainStore, error)

func (*ChainStore) AddHeader 

func (cs *ChainStore) AddHeader(header *block.Header) error

func (*ChainStore) CalcNextDonation 

func (cs *ChainStore) CalcNextDonation(height uint32) (*Donation, error)

func (*ChainStore) Close 

func (cs *ChainStore) Close()

func (*ChainStore) GenerateStateRoot 

func (cs *ChainStore) GenerateStateRoot(ctx context.Context, b *block.Block, genesisBlockInitialized, needBeCommitted bool) (Uint256, error)

func (*ChainStore) GetAsset 

func (cs *ChainStore) GetAsset(assetID common.Uint256) (name, symbol string, totalSupply common.Fixed64, precision uint32, err error)

func (*ChainStore) GetBalance 

func (cs *ChainStore) GetBalance(addr Uint160) Fixed64

func (*ChainStore) GetBalanceByAssetID 

func (cs *ChainStore) GetBalanceByAssetID(addr Uint160, assetID Uint256) Fixed64

func (*ChainStore) GetBlock 

func (cs *ChainStore) GetBlock(hash Uint256) (*block.Block, error)

func (*ChainStore) GetBlockByHeight 

func (cs *ChainStore) GetBlockByHeight(height uint32) (*block.Block, error)

func (*ChainStore) GetBlockHash 

func (cs *ChainStore) GetBlockHash(height uint32) (Uint256, error)

func (*ChainStore) GetCurrentBlockHash 

func (cs *ChainStore) GetCurrentBlockHash() Uint256

func (*ChainStore) GetCurrentBlockHashFromDB 

func (cs *ChainStore) GetCurrentBlockHashFromDB() (Uint256, uint32, error)

func (*ChainStore) GetCurrentBlockStateRoot 

func (cs *ChainStore) GetCurrentBlockStateRoot() (Uint256, error)

func (*ChainStore) GetCurrentHeaderHash 

func (cs *ChainStore) GetCurrentHeaderHash() Uint256

func (*ChainStore) GetDatabase 

func (cs *ChainStore) GetDatabase() db.IStore

func (*ChainStore) GetDonation 

func (cs *ChainStore) GetDonation() (Fixed64, error)

func (*ChainStore) GetHeader 

func (cs *ChainStore) GetHeader(hash Uint256) (*block.Header, error)

func (*ChainStore) GetHeaderByHeight 

func (cs *ChainStore) GetHeaderByHeight(height uint32) (*block.Header, error)

func (*ChainStore) GetHeaderHashByHeight 

func (cs *ChainStore) GetHeaderHashByHeight(height uint32) Uint256

func (*ChainStore) GetHeaderHeight 

func (cs *ChainStore) GetHeaderHeight() uint32

func (*ChainStore) GetHeaderWithCache 

func (cs *ChainStore) GetHeaderWithCache(hash Uint256) (*block.Header, error)

func (*ChainStore) GetHeight 

func (cs *ChainStore) GetHeight() uint32

func (*ChainStore) GetHeightByBlockHash 

func (cs *ChainStore) GetHeightByBlockHash(hash Uint256) (uint32, error)

func (*ChainStore) GetID 

func (cs *ChainStore) GetID(publicKey []byte) ([]byte, error)

func (*ChainStore) GetName 

func (cs *ChainStore) GetName(registrant []byte) (string, error)

func (*ChainStore) GetNanoPay 

func (cs *ChainStore) GetNanoPay(addr Uint160, recipient Uint160, nonce uint64) (Fixed64, uint32, error)

func (*ChainStore) GetNonce 

func (cs *ChainStore) GetNonce(addr Uint160) uint64

func (*ChainStore) GetPruningStartHeight 

func (cs *ChainStore) GetPruningStartHeight() (uint32, uint32)

func (*ChainStore) GetRegistrant 

func (cs *ChainStore) GetRegistrant(name string) ([]byte, error)

func (*ChainStore) GetStateRoots 

func (cs *ChainStore) GetStateRoots(fromHeight, toHeight uint32) ([]Uint256, error)

func (*ChainStore) GetSubscribers 

func (cs *ChainStore) GetSubscribers(topic string, bucket, offset, limit uint32) ([]string, error)

func (*ChainStore) GetSubscribersCount 

func (cs *ChainStore) GetSubscribersCount(topic string, bucket uint32) int

func (*ChainStore) GetSubscribersWithMeta 

func (cs *ChainStore) GetSubscribersWithMeta(topic string, bucket, offset, limit uint32) (map[string]string, error)

func (*ChainStore) GetSubscription 

func (cs *ChainStore) GetSubscription(topic string, bucket uint32, subscriber []byte, identifier string) (string, uint32, error)

func (*ChainStore) GetTransaction 

func (cs *ChainStore) GetTransaction(hash Uint256) (*transaction.Transaction, error)

func (*ChainStore) InitLedgerStoreWithGenesisBlock 

func (cs *ChainStore) InitLedgerStoreWithGenesisBlock(genesisBlock *block.Block) (uint32, error)

func (*ChainStore) IsBlockInStore 

func (cs *ChainStore) IsBlockInStore(hash Uint256) bool

func (*ChainStore) IsDoubleSpend 

func (cs *ChainStore) IsDoubleSpend(tx *transaction.Transaction) bool

func (*ChainStore) IsSubscribed 

func (cs *ChainStore) IsSubscribed(topic string, bucket uint32, subscriber []byte, identifier string) (bool, error)

func (*ChainStore) IsTxHashDuplicate 

func (cs *ChainStore) IsTxHashDuplicate(txhash Uint256) bool

func (*ChainStore) PruneStates 

func (cs *ChainStore) PruneStates() error

func (*ChainStore) PruneStatesLowMemory 

func (cs *ChainStore) PruneStatesLowMemory() error

func (*ChainStore) ResetDB 

func (cs *ChainStore) ResetDB() error

func (*ChainStore) Rollback 

func (cs *ChainStore) Rollback(b *block.Block) error

func (*ChainStore) SaveBlock 

func (cs *ChainStore) SaveBlock(b *block.Block, fastAdd bool) error

func (*ChainStore) SequentialPrune 

func (cs *ChainStore) SequentialPrune() error

func (*ChainStore) TrieTraverse 

func (cs *ChainStore) TrieTraverse() error

func (*ChainStore) VerifyState 

func (cs *ChainStore) VerifyState() error

type Donation 

type Donation struct {
	Height uint32
	Amount Fixed64
}

func NewDonation 

func NewDonation(height uint32, amount Fixed64) *Donation

func (*Donation) Deserialize 

func (d *Donation) Deserialize(r io.Reader) error

func (*Donation) Serialize 

func (d *Donation) Serialize(w io.Writer) error

type HeaderCache 

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

func NewHeaderCache 

func NewHeaderCache() *HeaderCache

func (*HeaderCache) AddHeaderToCache 

func (hc *HeaderCache) AddHeaderToCache(header *block.Header)

func (*HeaderCache) Dump 

func (hc *HeaderCache) Dump()

func (*HeaderCache) GetCachedHeader 

func (hc *HeaderCache) GetCachedHeader(hash common.Uint256) (*block.Header, error)

func (*HeaderCache) GetCachedHeaderHashByHeight 

func (hc *HeaderCache) GetCachedHeaderHashByHeight(height uint32) common.Uint256

func (*HeaderCache) GetCurrentCacheHeaderHash 

func (hc *HeaderCache) GetCurrentCacheHeaderHash() common.Uint256

func (*HeaderCache) GetCurrentCachedHeight 

func (hc *HeaderCache) GetCurrentCachedHeight() uint32

func (*HeaderCache) RemoveCachedHeader 

func (hc *HeaderCache) RemoveCachedHeader(stopHeight uint32)

func (*HeaderCache) RollbackHeader 

func (hc *HeaderCache) RollbackHeader(h *block.Header)

type ITrie 

type ITrie interface {
	TryGet(key []byte) ([]byte, error)
	TryUpdate(key, value []byte) error
	TryDelete(key []byte) error
	TryTraverse() error
	Hash() Uint256
	CommitTo() (Uint256, error)
	NodeIterator(start []byte) trie.NodeIterator
	NewRefCounts(refCountTargetHeight, pruningTargetHeight uint32) (*trie.RefCounts, error)
}

type Operation 

type Operation int
const (
	Addition Operation = iota
	Subtraction
)

type StateDB 

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

func NewStateDB 

func NewStateDB(root common.Uint256, cs *ChainStore) (*StateDB, error)

func (*StateDB) CleanupNanoPay 

func (sdb *StateDB) CleanupNanoPay(height uint32) error

func (*StateDB) CleanupPubSub 

func (sdb *StateDB) CleanupPubSub(height uint32) error

func (*StateDB) Finalize 

func (sdb *StateDB) Finalize(commit bool) (root common.Uint256, err error)

func (*StateDB) FinalizeAccounts 

func (sdb *StateDB) FinalizeAccounts(commit bool)

func (*StateDB) FinalizeIssueAsset 

func (sdb *StateDB) FinalizeIssueAsset(commit bool)

func (*StateDB) FinalizeNames 

func (sdb *StateDB) FinalizeNames(commit bool)

func (*StateDB) FinalizeNanoPay 

func (sdb *StateDB) FinalizeNanoPay(commit bool)

func (*StateDB) FinalizePubSub 

func (sdb *StateDB) FinalizePubSub(commit bool)

func (*StateDB) GetAsset 

func (sdb *StateDB) GetAsset(assetID common.Uint256) (*Asset, error)

func (*StateDB) GetBalance 

func (sdb *StateDB) GetBalance(assetID common.Uint256, addr common.Uint160) common.Fixed64

func (*StateDB) GetID 

func (sdb *StateDB) GetID(addr common.Uint160) []byte

func (*StateDB) GetNanoPay 

func (sdb *StateDB) GetNanoPay(sender, recipient common.Uint160, nonce uint64) (common.Fixed64, uint32, error)

func (*StateDB) GetNonce 

func (sdb *StateDB) GetNonce(addr common.Uint160) uint64

func (*StateDB) GetOrNewAccount 

func (sdb *StateDB) GetOrNewAccount(addr common.Uint160) *account

func (*StateDB) IncrNonce 

func (sdb *StateDB) IncrNonce(addr common.Uint160) error

func (*StateDB) IntermediateRoot 

func (sdb *StateDB) IntermediateRoot() common.Uint256

func (*StateDB) PruneStates 

func (sdb *StateDB) PruneStates() error

func (*StateDB) PruneStatesLowMemory 

func (sdb *StateDB) PruneStatesLowMemory() error

func (*StateDB) RollbackPruning 

func (sdb *StateDB) RollbackPruning(b *block.Block) error

func (*StateDB) SequentialPrune 

func (sdb *StateDB) SequentialPrune() error

func (*StateDB) SetAccount 

func (sdb *StateDB) SetAccount(addr common.Uint160, acc *account)

func (*StateDB) SetAsset 

func (sdb *StateDB) SetAsset(assetID common.Uint256, name string, symbol string, totalSupply common.Fixed64, precision uint32, owner common.Uint160) error

func (*StateDB) SetBalance 

func (sdb *StateDB) SetBalance(addr common.Uint160, assetID common.Uint256, value common.Fixed64) error

func (*StateDB) SetID 

func (sdb *StateDB) SetID(addr common.Uint160, id []byte) error

func (*StateDB) SetNanoPay 

func (sdb *StateDB) SetNanoPay(sender, recipient common.Uint160, nonce uint64, balance common.Fixed64, expiresAt uint32) error

func (*StateDB) SetNonce 

func (sdb *StateDB) SetNonce(addr common.Uint160, nonce uint64) error

func (*StateDB) TrieTraverse 

func (sdb *StateDB) TrieTraverse() error

func (*StateDB) UpdateBalance 

func (sdb *StateDB) UpdateBalance(addr common.Uint160, assetID common.Uint256, value common.Fixed64, op Operation) error

func (*StateDB) UpdateID 

func (sdb *StateDB) UpdateID(addr common.Uint160, id []byte) error

func (*StateDB) VerifyState 

func (sdb *StateDB) VerifyState() 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.