chain

package
v0.0.3-powserver Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2018 License: GPL-3.0 Imports: 26 Imported by: 38

Documentation

Index

Constants

View Source 
const (
	InsertAccountBlocksEvent        = uint8(1)
	InsertAccountBlocksSuccessEvent = uint8(2)

	DeleteAccountBlocksEvent        = uint8(3)
	DeleteAccountBlocksSuccessEvent = uint8(4)

	InsertSnapshotBlocksSuccessEvent = uint8(6)

	DeleteSnapshotBlocksSuccessEvent = uint8(8)
)

Variables

View Source 
var GenesisConsensusGroupBlock ledger.AccountBlock
View Source 
var GenesisConsensusGroupBlockVC vmctxt_interface.VmDatabase
View Source 
var GenesisMintageBlock ledger.AccountBlock
View Source 
var GenesisMintageBlockVC vmctxt_interface.VmDatabase
View Source 
var GenesisMintageSendBlock ledger.AccountBlock
View Source 
var GenesisMintageSendBlockVC vmctxt_interface.VmDatabase
View Source 
var GenesisRegisterBlock ledger.AccountBlock
View Source 
var GenesisRegisterBlockVC vmctxt_interface.VmDatabase
View Source 
var GenesisSnapshotBlock ledger.SnapshotBlock
View Source 
var SecondSnapshotBlock ledger.SnapshotBlock

Functions

This section is empty.

Types

type BlockMapQueryParam 

type BlockMapQueryParam struct {
	OriginBlockHash *types.Hash
	Count           uint64
	Forward         bool
}

type Chain 

type Chain interface {
	InsertAccountBlocks(vmAccountBlocks []*vm_context.VmAccountBlock) error
	GetAccountBlocksByHash(addr types.Address, origin *types.Hash, count uint64, forward bool) ([]*ledger.AccountBlock, error)
	GetAccountBlocksByHeight(addr types.Address, start uint64, count uint64, forward bool) ([]*ledger.AccountBlock, error)
	GetAccountBlockMap(queryParams map[types.Address]*BlockMapQueryParam) map[types.Address][]*ledger.AccountBlock
	GetLatestAccountBlock(addr *types.Address) (*ledger.AccountBlock, error)
	GetAccountBalance(addr *types.Address) (map[types.TokenTypeId]*big.Int, error)
	GetAccountBalanceByTokenId(addr *types.Address, tokenId *types.TokenTypeId) (*big.Int, error)
	GetAccountBlockHashByHeight(addr *types.Address, height uint64) (*types.Hash, error)

	GetAccountBlockByHeight(addr *types.Address, height uint64) (*ledger.AccountBlock, error)
	GetAccountBlockByHash(blockHash *types.Hash) (*ledger.AccountBlock, error)
	GetAccountBlocksByAddress(addr *types.Address, index int, num int, count int) ([]*ledger.AccountBlock, error)
	GetFirstConfirmedAccountBlockBySbHeight(snapshotBlockHeight uint64, addr *types.Address) (*ledger.AccountBlock, error)
	GetUnConfirmAccountBlocks(addr *types.Address) []*ledger.AccountBlock
	DeleteAccountBlocks(addr *types.Address, toHeight uint64) (map[types.Address][]*ledger.AccountBlock, error)
	Init()
	Compressor() *compress.Compressor
	ChainDb() *chain_db.ChainDb
	Start()
	Destroy()
	Stop()
	GenStateTrie(prevStateHash types.Hash, snapshotContent ledger.SnapshotContent) (*trie.Trie, error)
	GetNeedSnapshotContent() ledger.SnapshotContent

	InsertSnapshotBlock(snapshotBlock *ledger.SnapshotBlock) error
	GetSnapshotBlocksByHash(originBlockHash *types.Hash, count uint64, forward bool, containSnapshotContent bool) ([]*ledger.SnapshotBlock, error)
	GetSnapshotBlocksByHeight(height uint64, count uint64, forward bool, containSnapshotContent bool) ([]*ledger.SnapshotBlock, error)
	GetSnapshotBlockByHeight(height uint64) (*ledger.SnapshotBlock, error)
	GetSnapshotBlockByHash(hash *types.Hash) (*ledger.SnapshotBlock, error)
	GetLatestSnapshotBlock() *ledger.SnapshotBlock
	GetGenesisSnapshotBlock() *ledger.SnapshotBlock
	GetConfirmBlock(accountBlockHash *types.Hash) (*ledger.SnapshotBlock, error)
	GetConfirmTimes(accountBlockHash *types.Hash) (uint64, error)
	GetSnapshotBlockBeforeTime(blockCreatedTime *time.Time) (*ledger.SnapshotBlock, error)
	GetConfirmAccountBlock(snapshotHeight uint64, address *types.Address) (*ledger.AccountBlock, error)
	DeleteSnapshotBlocksToHeight(toHeight uint64) ([]*ledger.SnapshotBlock, map[types.Address][]*ledger.AccountBlock, error)
	GetContractGidByAccountBlock(block *ledger.AccountBlock) (*types.Gid, error)
	GetContractGid(addr *types.Address) (*types.Gid, error)
	GetRegisterList(snapshotHash types.Hash, gid types.Gid) []*contracts.Registration
	GetVoteMap(snapshotHash types.Hash, gid types.Gid) []*contracts.VoteInfo
	KafkaSender() *sender.KafkaSender

	// Pledge amount
	GetPledgeAmount(snapshotHash types.Hash, beneficial types.Address) *big.Int

	// Pledge quota
	GetPledgeQuota(snapshotHash types.Hash, beneficial types.Address) uint64
	GetPledgeQuotas(snapshotHash types.Hash, beneficialList []types.Address) map[types.Address]uint64

	GetConsensusGroupList(snapshotHash types.Hash) []*contracts.ConsensusGroupInfo
	GetBalanceList(snapshotHash types.Hash, tokenTypeId types.TokenTypeId, addressList []types.Address) map[types.Address]*big.Int

	GetTokenInfoById(tokenId *types.TokenTypeId) *contracts.TokenInfo
	AccountType(address *types.Address) (uint64, error)
	GetAccount(address *types.Address) (*ledger.Account, error)
	GetSubLedgerByHeight(startHeight uint64, count uint64, forward bool) ([]*ledger.CompressedFileMeta, [][2]uint64)
	GetSubLedgerByHash(startBlockHash *types.Hash, count uint64, forward bool) ([]*ledger.CompressedFileMeta, [][2]uint64, error)
	GetConfirmSubLedger(fromHeight uint64, toHeight uint64) ([]*ledger.SnapshotBlock, map[types.Address][]*ledger.AccountBlock, error)
	GetVmLogList(logListHash *types.Hash) (ledger.VmLogList, error)
	UnRegister(listenerId uint64)
	RegisterInsertAccountBlocks(processor InsertProcessorFunc) uint64
	RegisterInsertAccountBlocksSuccess(processor InsertProcessorFuncSuccess) uint64
	RegisterDeleteAccountBlocks(processor DeleteProcessorFunc) uint64
	RegisterDeleteAccountBlocksSuccess(processor DeleteProcessorFuncSuccess) uint64
	RegisterInsertSnapshotBlocksSuccess(processor InsertSnapshotBlocksSuccess) uint64
	RegisterDeleteSnapshotBlocksSuccess(processor DeleteSnapshotBlocksSuccess) uint64

	GetStateTrie(stateHash *types.Hash) *trie.Trie
	NewStateTrie() *trie.Trie

	// Be
	GetLatestBlockEventId() (uint64, error)
	GetEvent(eventId uint64) (byte, []types.Hash, error)

	// onroad
	IsSuccessReceived(addr *types.Address, hash *types.Hash) bool
	// contains filtered or unexported methods
}

func NewChain 

func NewChain(cfg *config.Config) Chain

type DeleteProcessorFunc 

type DeleteProcessorFunc func(batch *leveldb.Batch, subLedger map[types.Address][]*ledger.AccountBlock) error

type DeleteProcessorFuncSuccess 

type DeleteProcessorFuncSuccess func(subLedger map[types.Address][]*ledger.AccountBlock)

type DeleteSnapshotBlocksSuccess 

type DeleteSnapshotBlocksSuccess func([]*ledger.SnapshotBlock)

type InsertProcessorFunc 

type InsertProcessorFunc func(batch *leveldb.Batch, blocks []*vm_context.VmAccountBlock) error

type InsertProcessorFuncSuccess 

type InsertProcessorFuncSuccess func(blocks []*vm_context.VmAccountBlock)

type InsertSnapshotBlocksSuccess 

type InsertSnapshotBlocksSuccess func([]*ledger.SnapshotBlock)

type NeedSnapshotCache 

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

func NewNeedSnapshotContent 

func NewNeedSnapshotContent(chain *chain, unconfirmedSubLedger map[types.Address][]*ledger.AccountBlock) *NeedSnapshotCache

func (*NeedSnapshotCache) BeSnapshot 

func (cache *NeedSnapshotCache) BeSnapshot(addr *types.Address, height uint64)

func (*NeedSnapshotCache) Get 

func (cache *NeedSnapshotCache) Get(addr *types.Address) *ledger.AccountBlock

func (*NeedSnapshotCache) GetBlockByHash 

func (cache *NeedSnapshotCache) GetBlockByHash(addr *types.Address, hash types.Hash) *ledger.AccountBlock

func (*NeedSnapshotCache) GetSnapshotContent 

func (cache *NeedSnapshotCache) GetSnapshotContent() ledger.SnapshotContent

func (*NeedSnapshotCache) Remove 

func (cache *NeedSnapshotCache) Remove(addr *types.Address)

func (*NeedSnapshotCache) Set 

func (cache *NeedSnapshotCache) Set(addr *types.Address, accountBlock *ledger.AccountBlock)

type StateTriePool 

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

func NewStateTriePool 

func NewStateTriePool(chain *chain) *StateTriePool

func (*StateTriePool) Get 

func (pool *StateTriePool) Get(address *types.Address) (*trie.Trie, error)

func (*StateTriePool) Set 

func (pool *StateTriePool) Set(address *types.Address, trie *trie.Trie)

Source Files

View all Source files

Directories

Path Synopsis

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.