Versions in this module Expand all Collapse all v2 v2.2.1 May 14, 2024 v2.2.0 Mar 3, 2023 Changes in this version + const NumNbrToSyncRandAddr + const NumNbrToSyncTxnPool + func MakeSigChainTransaction(wallet *vault.Wallet, sigChain []byte) (*transaction.Transaction, error) + func NewBacktrackSigChainMessage(sigChainElems []*pb.SigChainElem, hash []byte) (*pb.UnsignedMessage, error) + func NewGetBlockHeadersMessage(startHeight, endHeight uint32) (*pb.UnsignedMessage, error) + func NewGetBlockHeadersReply(headers []*block.Header) (*pb.UnsignedMessage, error) + func NewGetBlocksMessage(startHeight, endHeight uint32) (*pb.UnsignedMessage, error) + func NewGetBlocksReply(blocks []*block.Block) (*pb.UnsignedMessage, error) + func NewGetStateMessage(hashes []common.Uint256) (*pb.UnsignedMessage, error) + func NewGetStatesReply(nodes [][]byte) (*pb.UnsignedMessage, error) + func NewIHaveSignatureChainTransactionMessage(height uint32, sigHash []byte) (*pb.UnsignedMessage, error) + func NewPinSigChainMessage(hash []byte) (*pb.UnsignedMessage, error) + func NewRelayMessage(srcIdentifier string, srcPubkey, destID, payload, blockHash, lastHash []byte, ...) (*pb.UnsignedMessage, error) + func NewReqAddrNonceMessage() (*pb.UnsignedMessage, error) + func NewReqSyncAddrTxnMessage(addr []byte, nonce uint64) (*pb.UnsignedMessage, error) + func NewReqSyncTxnPoolMessage(tp *pool.TxnPool) (*pb.UnsignedMessage, error) + func NewReqTxnPoolHashMessage() (*pb.UnsignedMessage, error) + func NewRequestSignatureChainTransactionMessage(sigHash []byte) (*pb.UnsignedMessage, error) + func NewRequestSignatureChainTransactionReply(transaction *transaction.Transaction) (*pb.UnsignedMessage, error) + func NewRplAddrNonceMessage(tp *pool.TxnPool) (*pb.UnsignedMessage, error) + func NewRplSyncAddrTxnMessage(reqMsg *pb.AddrNonce, tp *pool.TxnPool) (*pb.UnsignedMessage, error) + func NewRplSyncTxnPoolMessage(reqMsg *pb.RequestSyncTxnPool, tp *pool.TxnPool) (*pb.UnsignedMessage, error) + func NewRplTxnPoolHashMessage(tp *pool.TxnPool) (*pb.UnsignedMessage, error) + func NewTransactionsMessage(transactions []*transaction.Transaction) (*pb.UnsignedMessage, error) + func ShouldRejectAddr(localAddr, remoteAddr string) bool + type ChordInfo struct + FingerTable map[int][]*ChordRemoteNodeInfo + LocalNode *LocalNode + Predecessors []*ChordRemoteNodeInfo + Successors []*ChordRemoteNodeInfo + type ChordRemoteNodeInfo struct + func (crn *ChordRemoteNodeInfo) MarshalJSON() ([]byte, error) + type LocalNode struct + func NewLocalNode(wallet *vault.Wallet, nn *nnet.NNet, ledgerMode pb.LedgerMode) (*LocalNode, error) + func (hc LocalNode) ExistHash(hash common.Uint256) bool + func (localNode *LocalNode) BroadcastTransaction(txn *transaction.Transaction) error + func (localNode *LocalNode) CheckIDChange(v interface{}) + func (localNode *LocalNode) ComputeSharedKey(remotePublicKey []byte) (*[node.SharedKeySize]byte, error) + func (localNode *LocalNode) FindSuccessorAddrs(key []byte, numSucc int) ([]string, error) + func (localNode *LocalNode) FindWsAddr(key []byte) (string, string, []byte, []byte, error) + func (localNode *LocalNode) FindWssAddr(key []byte) (string, string, []byte, []byte, error) + func (localNode *LocalNode) GetChordInfo() node.IChordInfo + func (localNode *LocalNode) GetGossipNeighbors(filter func(*node.RemoteNode) bool) []*node.RemoteNode + func (localNode *LocalNode) GetHeight() uint32 + func (localNode *LocalNode) GetNeighborBlockHeaders(remoteNode *node.RemoteNode, startHeight, endHeight uint32) ([]*block.Header, error) + func (localNode *LocalNode) GetNeighborBlocks(remoteNode *node.RemoteNode, startHeight, endHeight uint32) ([]*block.Block, error) + func (localNode *LocalNode) GetNeighborByNNetNode(nnetRemoteNode *nnetnode.RemoteNode) *node.RemoteNode + func (localNode *LocalNode) GetNeighborInfo() []*node.RemoteNode + func (localNode *LocalNode) GetNeighborStates(remoteNode *node.RemoteNode, hashes []common.Uint256) ([][]byte, error) + func (localNode *LocalNode) GetNeighborsMajorityStateRootByHeight(height uint32, neighbors []*node.RemoteNode) common.Uint256 + func (localNode *LocalNode) GetNnet() *nnet.NNet + func (localNode *LocalNode) GetProposalSubmitted() uint32 + func (localNode *LocalNode) GetRelayMessageCount() uint64 + func (localNode *LocalNode) GetSyncState() pb.SyncState + func (localNode *LocalNode) GetTxnPool() *pool.TxnPool + func (localNode *LocalNode) GetVotingNeighbors(filter func(*node.RemoteNode) bool) []*node.RemoteNode + func (localNode *LocalNode) GetWsAddr() string + func (localNode *LocalNode) GetWssAddr() string + func (localNode *LocalNode) IncrementProposalSubmitted() + func (localNode *LocalNode) IncrementRelayMessageCount() + func (localNode *LocalNode) MarshalJSON() ([]byte, error) + func (localNode *LocalNode) NewSignatureChainObjectionMessage(height uint32, sigHash []byte) (*pb.UnsignedMessage, error) + func (localNode *LocalNode) ResetSyncing() + func (localNode *LocalNode) SendRelayMessage(srcAddr, destAddr string, payload, signature, blockHash []byte, ...) error + func (localNode *LocalNode) SerializeMessage(unsignedMsg *pb.UnsignedMessage, sign bool) ([]byte, error) + func (localNode *LocalNode) SetMinVerifiableHeight(height uint32) + func (localNode *LocalNode) SetSyncState(s pb.SyncState) bool + func (localNode *LocalNode) Start() error + func (localNode *LocalNode) StartFastSyncing(syncRootHash common.Uint256, peers []*node.RemoteNode) error + func (localNode *LocalNode) StartSyncRandAddrTxn() + func (localNode *LocalNode) StartSyncTxnPool() + func (localNode *LocalNode) StartSyncing(syncStopHash common.Uint256, syncStopHeight uint32, ...) (bool, error) + func (localNode *LocalNode) SyncRandAddrTxn() + func (localNode *LocalNode) SyncTxnPool() + func (localNode *LocalNode) VerifySigChain(sc *pb.SigChain, height uint32) error + func (localNode *LocalNode) VerifySigChainObjection(sc *pb.SigChain, reporterID []byte, height uint32) (int, error) + func (nm LocalNode) GetConnectionCnt() uint + func (nm LocalNode) GetNeighborHeights() ([]uint32, uint) + func (nm LocalNode) GetNeighborNode(id string) *node.RemoteNode + func (nm LocalNode) GetNeighbors(filter func(*node.RemoteNode) bool) []*node.RemoteNode + func (nm LocalNode) RemoveNeighborNode(id string) + type RelayService struct + func NewRelayService(wallet *vault.Wallet, localNode *LocalNode) *RelayService + func (rs *RelayService) Start() error
Go to main page