Versions in this module Expand all Collapse all v0 v0.6.5 Jun 10, 2025 Changes in this version + type Node struct + AvailabilityStore *store.Shards + BlockService *chain.BlockService + Cancel context.CancelFunc + Context context.Context + PeersSet *peer.PeerSet + ProtocolManager *protocol.Manager + SegmentRootLookup work.SegmentRootLookup + SegmentRootToErasureRoot map[crypto.Hash]crypto.Hash + State state.State + StateTrieStore *store.Trie + TicketStore *store.Ticket + ValidatorManager *validator.ValidatorManager + ValidatorService validator.ValidatorService + WorkPackageSharingHandler *handlers.WorkPackageSharingHandler + WorkReportGuarantor handlers.WorkReportProcessAndGuarantee + func NewNode(nodeCtx context.Context, listenAddr *net.UDPAddr, keys validator.ValidatorKeys, ...) (*Node, error) + func (n *Node) AnnounceBlock(ctx context.Context, header *block.Header, peer *peer.Peer) error + func (n *Node) AuditShardRequestSend(ctx context.Context, peerKey ed25519.PublicKey, erasureRoot crypto.Hash, ...) (bundleShard []byte, justification [][]byte, err error) + func (n *Node) ConnectToNeighbours() error + func (n *Node) ConnectToPeer(addr *net.UDPAddr) error + func (n *Node) DistributeTicketToAll(ctx context.Context, ticket block.TicketProof) error + func (n *Node) DistributeTicketToPeer(ctx context.Context, ticket block.TicketProof, peerKey ed25519.PublicKey) error + func (n *Node) GetAllPeers() []*peer.Peer + func (n *Node) GetByAddress(addr string) *peer.Peer + func (n *Node) GetGuaranteedShardsAndStore(ctx context.Context, guarantee block.Guarantee) error + func (n *Node) GetProtocols() []string + func (n *Node) OnConnection(conn *transport.Conn) + func (n *Node) RequestBlocks(ctx context.Context, hash crypto.Hash, ascending bool, maxBlocks uint32, ...) ([]block.Block, error) + func (n *Node) RequestState(ctx context.Context, headerHash crypto.Hash, keyStart [31]byte, ...) (store.TrieRangeResult, error) + func (n *Node) RequestWorkReport(ctx context.Context, hash crypto.Hash, peerKey ed25519.PublicKey) (*block.WorkReport, error) + func (n *Node) SegmentShardRequestJustificationSend(ctx context.Context, peerKey ed25519.PublicKey, erasureRoot crypto.Hash, ...) (segmentShards [][]byte, justification [][][]byte, err error) + func (n *Node) SegmentShardRequestSend(ctx context.Context, peerKey ed25519.PublicKey, erasureRoot crypto.Hash, ...) (segmentShards [][]byte, err error) + func (n *Node) ShardDistributionSend(ctx context.Context, peerKey ed25519.PublicKey, coreIndex uint16, ...) (bundleShard []byte, segmentShard [][]byte, justification [][]byte, err error) + func (n *Node) Start() error + func (n *Node) Stop() error + func (n *Node) SubmitTicket(ctx context.Context, ticket block.TicketProof, peerKey ed25519.PublicKey) error + func (n *Node) SubmitWorkPackage(ctx context.Context, coreIndex uint16, pkg work.Package, extrinsics []byte, ...) error + func (n *Node) UpdateCoreAssignments() error + func (n *Node) ValidateConnection(tlsState tls.ConnectionState) error
Go to main page