Versions in this module Expand all Collapse all v1 v1.10.3 Dec 16, 2024 v1.10.2 Dec 15, 2024 Changes in this version + const IncomingReceiptsLimit + const MsgChanBuffer + const NumTryBroadCast + const SleepPeriod + const SyncFrequency + const SyncIDLength + func BroadcastCXReceipts(newBlock *types.Block, consensus *consensus.Consensus) + func BroadcastCXReceiptsWithShardID(block *block.Header, commitSig []byte, commitBitmap []byte, toShardID uint32, ...) + func BroadcastMissingCXReceipts(c *consensus.Consensus) + func GenerateRandomString(n int) string + func GenerateSyncID() [SyncIDLength]byte + type DNSSyncingPeerProvider struct + func NewDNSSyncingPeerProvider(zone, port string, addrs []multiaddr.Multiaddr) *DNSSyncingPeerProvider + func (p *DNSSyncingPeerProvider) SyncingPeers(shardID uint32) (peers []p2p.Peer, err error) + type Downloaders interface + Close func() + DownloadAsync func(shardID uint32) + IsActive func() bool + NumPeers func() map[uint32]int + Start func() + SyncStatus func(shardID uint32) (bool, uint64, uint64) + type ISync interface + AddLastMileBlock func(block *types.Block) + AddNewBlock func(peerHash []byte, block *types.Block) + CreateSyncConfig func(peers []p2p.Peer, shardID uint32, selfPeerID libp2p_peer.ID, ...) error + GetActivePeerNumber func() int + GetParsedSyncStatus func() (IsSynchronized bool, OtherHeight uint64, HeightDiff uint64) + GetParsedSyncStatusDoubleChecked func() (IsSynchronized bool, OtherHeight uint64, HeightDiff uint64) + IsSameBlockchainHeight func(bc core.BlockChain) (uint64, bool) + IsSynchronized func() bool + RegisterNodeInfo func() int + SyncLoop func(bc core.BlockChain, isBeacon bool, consensus *consensus.Consensus, ...) + UpdateBlockAndStatus func(block *types.Block, bc core.BlockChain) error + type LocalSyncingPeerProvider struct + func NewLocalSyncingPeerProvider(basePort, selfPort uint16, numShards, shardSize uint32) *LocalSyncingPeerProvider + func (p *LocalSyncingPeerProvider) SyncingPeers(shardID uint32) (peers []p2p.Peer, err error) + type Node struct + BeaconBlockChannel chan *types.Block + BroadcastInvalidTx bool + Consensus *consensus.Consensus + ContractAddresses []common.Address + ContractDeployerCurrentNonce uint64 + CxPool *core.CxPool + IntelchainConfig *intelchainconfig.IntelchainConfig + IsSynchronized *abool.AtomicBool + Metrics metrics.Registry + NodeConfig *nodeconfig.ConfigType + SelfPeer p2p.Peer + SyncingPeerProvider SyncingPeerProvider + TransactionErrorSink *types.TransactionErrorSink + TxPool *core.TxPool + Worker *worker.Worker + func New(host p2p.Host, consensusObj *consensus.Consensus, ...) *Node + func (node *Node) APIs(intelchain *itc.Intelchain) []rpc.API + func (node *Node) AddNewBlockForExplorer(block *types.Block) + func (node *Node) AddPendingReceipts(receipts *types.CXReceiptsProof) + func (node *Node) AddPendingStakingTransaction(newStakingTx *staking.StakingTransaction) error + func (node *Node) AddPendingTransaction(newTx *types.Transaction) error + func (node *Node) BeaconSyncHook() + func (node *Node) Beaconchain() core.BlockChain + func (node *Node) Blockchain() core.BlockChain + func (node *Node) BootstrapConsensus() error + func (node *Node) BroadcastCrossLinkFromShardsToBeacon() + func (node *Node) BroadcastCrosslinkHeartbeatSignalFromBeaconToShards() + func (node *Node) BroadcastNewBlock(newBlock *types.Block, nodeConfig *nodeconfig.ConfigType) + func (node *Node) BroadcastSlash(witness *slash.Record) + func (node *Node) CalculateResponse(request *downloader_pb.DownloaderRequest, incomingPeer string) (*downloader_pb.DownloaderResponse, error) + func (node *Node) DoSyncing(bc core.BlockChain, willJoinConsensus bool) + func (node *Node) EpochChain() core.BlockChain + func (node *Node) GetAddressForBLSKey(blskey *bls_core.PublicKey, epoch *big.Int) common.Address + func (node *Node) GetAddresses(epoch *big.Int) map[string]common.Address + func (node *Node) GetConfig() rpc_common.Config + func (node *Node) GetConsensusBlockNum() uint64 + func (node *Node) GetConsensusCurViewID() uint64 + func (node *Node) GetConsensusInternal() rpc_common.ConsensusInternal + func (node *Node) GetConsensusMode() string + func (node *Node) GetConsensusPhase() string + func (node *Node) GetConsensusViewChangingID() uint64 + func (node *Node) GetLastSigningPower() (float64, error) + func (node *Node) GetLastSigningPower2() (float64, error) + func (node *Node) GetNodeBootTime() int64 + func (node *Node) GetOrCreateSyncInstance(initiate bool) ISync + func (node *Node) GetStakingTransactionsCount(address, txType string) (uint64, error) + func (node *Node) GetStakingTransactionsHistory(address, txType, order string) ([]common.Hash, error) + func (node *Node) GetSyncID() [SyncIDLength]byte + func (node *Node) GetTraceResultByHash(hash common.Hash) (json.RawMessage, error) + func (node *Node) GetTransactionsCount(address, txType string) (uint64, error) + func (node *Node) GetTransactionsHistory(address, txType, order string) ([]common.Hash, error) + func (node *Node) HandleNodeMessage(ctx context.Context, msgPayload []byte, actionType proto_node.MessageType) error + func (node *Node) InitSyncingServer(port int) + func (node *Node) IsBackup() bool + func (node *Node) IsCurrentlyLeader() bool + func (node *Node) IsOutOfSync(shardID uint32) bool + func (node *Node) IsRunningBeaconChain() bool + func (node *Node) ListBlockedPeer() []peer.ID + func (node *Node) ListPeer(topic string) []peer.ID + func (node *Node) ListTopic() []string + func (node *Node) NodeSyncing() + func (node *Node) PeerConnectivity() (int, int, int) + func (node *Node) PendingCXReceipts() []*types.CXReceiptsProof + func (node *Node) PostConsensusProcessing(newBlock *types.Block) error + func (node *Node) ProcessCrossLinkHeartbeatMessage(msgPayload []byte) + func (node *Node) ProcessCrossLinkMessage(msgPayload []byte) + func (node *Node) ProcessReceiptMessage(msgPayload []byte) + func (node *Node) ProposeNewBlock(commitSigs chan []byte) (*types.Block, error) + func (node *Node) RegisterExplorerServices() + func (node *Node) RegisterService(st service.Type, s service.Service) + func (node *Node) RegisterValidatorServices() + func (node *Node) ReportPlainErrorSink() types.TransactionErrorReports + func (node *Node) ReportStakingErrorSink() types.TransactionErrorReports + func (node *Node) SendNewBlockToUnsync() + func (node *Node) ServiceManager() *service.Manager + func (node *Node) SetNodeBackupMode(isBackup bool) bool + func (node *Node) ShutDown() + func (node *Node) StartGRPCSyncClient() + func (node *Node) StartPubSub() error + func (node *Node) StartRPC() error + func (node *Node) StartRosetta() error + func (node *Node) StartServices() error + func (node *Node) StartSyncingServer(port int) + func (node *Node) StopPubSub() + func (node *Node) StopRPC() error + func (node *Node) StopRosetta() error + func (node *Node) StopServices() error + func (node *Node) SupportGRPCSyncServer(port int) + func (node *Node) SyncInstance() ISync + func (node *Node) SyncPeers() map[string]int + func (node *Node) SyncStatus(shardID uint32) (bool, uint64, uint64) + func (node *Node) TraceLoopForExplorer() + func (node *Node) VerifyCrossLink(cl types.CrossLink) error + func (node *Node) WaitForConsensusReadyV2(cs *consensus.Consensus, stopChan chan struct{}, stoppedChan chan struct{}) + type SyncingPeerProvider interface + SyncingPeers func(shardID uint32) (peers []p2p.Peer, err error)
Go to main page