Versions in this module Expand all Collapse all v1 v1.23.4 Feb 1, 2026 Changes in this version + var ErrInvalidMessage = errors.New("invalid wire message") + var ErrUnknownTag = errors.New("unknown message tag") + func Marshal(m *Message) ([]byte, error) + type Accepted struct + ChainId []byte + ContainerIds [][]byte + RequestId uint32 + func (m *Accepted) GetChainId() []byte + func (m *Accepted) GetRequestId() uint32 + type AcceptedFrontier struct + ChainId []byte + ContainerId []byte + RequestId uint32 + func (m *AcceptedFrontier) GetChainId() []byte + func (m *AcceptedFrontier) GetRequestId() uint32 + type AcceptedStateSummary struct + ChainId []byte + RequestId uint32 + SummaryIds [][]byte + func (m *AcceptedStateSummary) GetChainId() []byte + func (m *AcceptedStateSummary) GetRequestId() uint32 + type Ancestors struct + ChainId []byte + Containers [][]byte + RequestId uint32 + func (m *Ancestors) GetChainId() []byte + func (m *Ancestors) GetRequestId() uint32 + type BFT struct + ChainId []byte + Message []byte + func (m *BFT) GetChainId() []byte + type BloomFilter struct + Filter []byte + Salt []byte + type Buffer struct + func NewBuffer(size int) *Buffer + func (b *Buffer) Bytes() []byte + func (b *Buffer) Reset() + func (b *Buffer) WriteBytes(data []byte) + func (b *Buffer) WriteBytesSlice(slices [][]byte) + func (b *Buffer) WriteString(s string) + func (b *Buffer) WriteUint16(v uint16) + func (b *Buffer) WriteUint32(v uint32) + func (b *Buffer) WriteUint32Slice(vals []uint32) + func (b *Buffer) WriteUint64(v uint64) + func (b *Buffer) WriteUint64Slice(vals []uint64) + func (b *Buffer) WriteUint8(v uint8) + type ChainSubnetPair struct + ChainId []byte + SubnetId []byte + type Chits struct + AcceptedId []byte + ChainId []byte + PreferredId []byte + PreferredIdAtHeight []byte + RequestId uint32 + func (m *Chits) GetChainId() []byte + func (m *Chits) GetRequestId() uint32 + type ClaimedIpPort struct + IpAddr []byte + IpPort uint32 + Signature []byte + Timestamp uint64 + TxId []byte + X509Certificate []byte + type Client struct + Major uint32 + Minor uint32 + Name string + Patch uint32 + type EngineType int32 + const EngineType_CHAIN + const EngineType_DAG + const EngineType_UNSPECIFIED + type Get struct + ChainId []byte + ContainerId []byte + Deadline uint64 + EngineType EngineType + RequestId uint32 + func (m *Get) GetChainId() []byte + func (m *Get) GetDeadline() uint64 + func (m *Get) GetRequestId() uint32 + type GetAccepted struct + ChainId []byte + ContainerIds [][]byte + Deadline uint64 + EngineType EngineType + RequestId uint32 + func (m *GetAccepted) GetChainId() []byte + func (m *GetAccepted) GetDeadline() uint64 + func (m *GetAccepted) GetRequestId() uint32 + type GetAcceptedFrontier struct + ChainId []byte + Deadline uint64 + EngineType EngineType + RequestId uint32 + func (m *GetAcceptedFrontier) GetChainId() []byte + func (m *GetAcceptedFrontier) GetDeadline() uint64 + func (m *GetAcceptedFrontier) GetRequestId() uint32 + type GetAcceptedStateSummary struct + ChainId []byte + Deadline uint64 + Heights []uint64 + RequestId uint32 + func (m *GetAcceptedStateSummary) GetChainId() []byte + func (m *GetAcceptedStateSummary) GetDeadline() uint64 + func (m *GetAcceptedStateSummary) GetRequestId() uint32 + type GetAncestors struct + ChainId []byte + ContainerId []byte + Deadline uint64 + EngineType EngineType + RequestId uint32 + func (m *GetAncestors) GetChainId() []byte + func (m *GetAncestors) GetDeadline() uint64 + func (m *GetAncestors) GetEngineType() EngineType + func (m *GetAncestors) GetRequestId() uint32 + type GetPeerList struct + KnownPeers *BloomFilter + type GetStateSummaryFrontier struct + ChainId []byte + Deadline uint64 + RequestId uint32 + func (m *GetStateSummaryFrontier) GetChainId() []byte + func (m *GetStateSummaryFrontier) GetDeadline() uint64 + func (m *GetStateSummaryFrontier) GetRequestId() uint32 + type Gossip struct + ChainId []byte + Gossip []byte + func (m *Gossip) GetChainId() []byte + type Handshake struct + Client *Client + IpAddr []byte + IpBlsSig []byte + IpNodeIdSig []byte + IpPort uint32 + IpSigningTime uint64 + KnownPeers *BloomFilter + MyTime uint64 + NetworkId uint32 + ObjectedAcps []uint32 + SupportedAcps []uint32 + TrackedSubnets [][]byte + type Message struct + Accepted *Accepted + AcceptedFrontier *AcceptedFrontier + AcceptedStateSummary *AcceptedStateSummary + Ancestors *Ancestors + BFT *BFT + Chits *Chits + CompressedZstd []byte + Get *Get + GetAccepted *GetAccepted + GetAcceptedFrontier *GetAcceptedFrontier + GetAcceptedStateSummary *GetAcceptedStateSummary + GetAncestors *GetAncestors + GetPeerList *GetPeerList + GetStateSummaryFrontier *GetStateSummaryFrontier + Gossip *Gossip + Handshake *Handshake + PeerList *PeerList + Ping *Ping + Pong *Pong + PullQuery *PullQuery + PushQuery *PushQuery + Put *Put + Request *Request + Response *Response + StateSummaryFrontier *StateSummaryFrontier + func Unmarshal(data []byte) (*Message, error) + type PeerList struct + ClaimedIpPorts []*ClaimedIpPort + type Ping struct + ChainSubnetPairs []*ChainSubnetPair + Uptime uint32 + type Pong struct + ChainSubnetPairs []*ChainSubnetPair + Uptime uint32 + type PullQuery struct + ChainId []byte + ContainerId []byte + Deadline uint64 + EngineType EngineType + RequestId uint32 + RequestedHeight uint64 + func (m *PullQuery) GetChainId() []byte + func (m *PullQuery) GetDeadline() uint64 + func (m *PullQuery) GetRequestId() uint32 + type PushQuery struct + ChainId []byte + Container []byte + Deadline uint64 + EngineType EngineType + RequestId uint32 + RequestedHeight uint64 + func (m *PushQuery) GetChainId() []byte + func (m *PushQuery) GetDeadline() uint64 + func (m *PushQuery) GetRequestId() uint32 + type Put struct + ChainId []byte + Container []byte + EngineType EngineType + RequestId uint32 + func (m *Put) GetChainId() []byte + func (m *Put) GetRequestId() uint32 + type Reader struct + func NewReader(data []byte) *Reader + func (r *Reader) ReadBytes() ([]byte, error) + func (r *Reader) ReadBytesSlice() ([][]byte, error) + func (r *Reader) ReadString() (string, error) + func (r *Reader) ReadUint16() (uint16, error) + func (r *Reader) ReadUint32() (uint32, error) + func (r *Reader) ReadUint32Slice() ([]uint32, error) + func (r *Reader) ReadUint64() (uint64, error) + func (r *Reader) ReadUint64Slice() ([]uint64, error) + func (r *Reader) ReadUint8() (uint8, error) + type Request struct + ChainId []byte + Deadline uint64 + Request []byte + RequestId uint32 + func (m *Request) GetChainId() []byte + func (m *Request) GetDeadline() uint64 + func (m *Request) GetRequestId() uint32 + type Response struct + ChainId []byte + RequestId uint32 + Response []byte + func (m *Response) GetChainId() []byte + func (m *Response) GetRequestId() uint32 + type StateSummaryFrontier struct + ChainId []byte + RequestId uint32 + Summary []byte + func (m *StateSummaryFrontier) GetChainId() []byte + func (m *StateSummaryFrontier) GetRequestId() uint32
Go to main page