Versions in this module Expand all Collapse all v1 v1.23.17 Feb 21, 2026 v1.23.16 Feb 21, 2026 v1.23.6 Feb 9, 2026 v1.23.5 Feb 8, 2026 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