chainsynker

Documentation

Index

• Constants
• Variables
• func InitChainSynker(cfg shared.Config)
• func OnNewShardBlock(bc *blockchain.BlockChain, h common.Hash, height uint64, chainID int)
• func ResetMongoAndReSync() error
• type ChainSyncState
• type IncPdexState

Constants

const (
	ShardData  = "coin-processed-"
	BeaconData = "beacon-processed"
)

Variables

var Localnode interface {
	OnReceive(msgType int, f func(msg interface{}))
	GetUserDatabase() *leveldb.DB
	GetBlockchain() *blockchain.BlockChain
	OnNewBlockFromParticularHeight(chainID int, blkHeight int64, isFinalized bool, f func(bc *blockchain.BlockChain, h common.Hash, height uint64, chainID int))
	GetShardState(shardID int) (uint64, *common.Hash)
	SyncSpecificShardBlockBytes(shardID int, height uint64, blockHash string) ([]byte, error)
}

var TransactionStateDB map[byte]*statedb.StateDB

var ShardProcessedState map[byte]uint64

Functions

func InitChainSynker

func InitChainSynker(cfg shared.Config)

func OnNewShardBlock

func OnNewShardBlock(bc *blockchain.BlockChain, h common.Hash, height uint64, chainID int)

func ResetMongoAndReSync

func ResetMongoAndReSync() error

Types

type ChainSyncState

type ChainSyncState struct {
	BlockProcessed map[int]uint64
	// contains filtered or unexported fields
}

type IncPdexState

type IncPdexState struct {
	StakingPools map[string]*pdex.StakingPoolState
	PoolPairs    map[string]*pdex.PoolPairState
	Param        *statedb.Pdexv3Params
}