Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

lnode

package

Go to main page

Versions in this module

v2

v2.2.5

Jan 9, 2026

v2.2.4

Jan 8, 2026

v2.2.3

Jan 2, 2026

v2.2.2

Jan 1, 2026

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