p2p

package
v1.23.17 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 21, 2026 License: BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Overview

Package p2p provides P2P message types for network communication. This is the ZAP-based implementation (zero protobuf).

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidMessage = errors.New("invalid wire message")
	ErrUnknownTag     = errors.New("unknown message tag")
)

Functions

func Marshal 

func Marshal(m *Message) ([]byte, error)

Marshal encodes a Message to ZAP wire format

func Size 

func Size(m *Message) int

Size returns the encoded size of a message

func Unmarshal 

func Unmarshal(data []byte, m *Message) error

Unmarshal decodes a Message from ZAP wire format

Types

type Accepted 

type Accepted struct {
	ChainId      []byte
	RequestId    uint32
	ContainerIds [][]byte
}

Accepted message

func (*Accepted) GetChainId 

func (m *Accepted) GetChainId() []byte

func (*Accepted) GetContainerIds 

func (m *Accepted) GetContainerIds() [][]byte

func (*Accepted) GetRequestId 

func (m *Accepted) GetRequestId() uint32

func (*Accepted) Reset 

func (m *Accepted) Reset()

func (*Accepted) String 

func (m *Accepted) String() string

type AcceptedFrontier 

type AcceptedFrontier struct {
	ChainId     []byte
	RequestId   uint32
	ContainerId []byte
}

AcceptedFrontier message

func (*AcceptedFrontier) GetChainId 

func (m *AcceptedFrontier) GetChainId() []byte

func (*AcceptedFrontier) GetContainerId 

func (m *AcceptedFrontier) GetContainerId() []byte

func (*AcceptedFrontier) GetRequestId 

func (m *AcceptedFrontier) GetRequestId() uint32

func (*AcceptedFrontier) Reset 

func (m *AcceptedFrontier) Reset()

func (*AcceptedFrontier) String 

func (m *AcceptedFrontier) String() string

type AcceptedStateSummary 

type AcceptedStateSummary struct {
	ChainId    []byte
	RequestId  uint32
	SummaryIds [][]byte
}

AcceptedStateSummary message

func (*AcceptedStateSummary) GetChainId 

func (m *AcceptedStateSummary) GetChainId() []byte

func (*AcceptedStateSummary) GetRequestId 

func (m *AcceptedStateSummary) GetRequestId() uint32

func (*AcceptedStateSummary) GetSummaryIds 

func (m *AcceptedStateSummary) GetSummaryIds() [][]byte

func (*AcceptedStateSummary) Reset 

func (m *AcceptedStateSummary) Reset()

func (*AcceptedStateSummary) String 

func (m *AcceptedStateSummary) String() string

type Ancestors 

type Ancestors struct {
	ChainId    []byte
	RequestId  uint32
	Containers [][]byte
}

Ancestors message

func (*Ancestors) GetChainId 

func (m *Ancestors) GetChainId() []byte

func (*Ancestors) GetContainers 

func (m *Ancestors) GetContainers() [][]byte

func (*Ancestors) GetRequestId 

func (m *Ancestors) GetRequestId() uint32

func (*Ancestors) Reset 

func (m *Ancestors) Reset()

func (*Ancestors) String 

func (m *Ancestors) String() string

type BFT 

type BFT struct {
	ChainId []byte
	Message isBFT_Message
}

BFT message

func (*BFT) GetBlockProposal 

func (m *BFT) GetBlockProposal() *BlockProposal

func (*BFT) GetChainId 

func (m *BFT) GetChainId() []byte

func (*BFT) GetMessage 

func (m *BFT) GetMessage() isBFT_Message

func (*BFT) GetReplicationRequest 

func (m *BFT) GetReplicationRequest() *ReplicationRequest

func (*BFT) GetReplicationResponse 

func (m *BFT) GetReplicationResponse() *ReplicationResponse

func (*BFT) GetVote 

func (m *BFT) GetVote() *Vote

func (*BFT) Reset 

func (m *BFT) Reset()

func (*BFT) String 

func (m *BFT) String() string

type BFT_BlockProposal 

type BFT_BlockProposal struct{ BlockProposal *BlockProposal }

type BFT_EmptyNotarization 

type BFT_EmptyNotarization struct{ EmptyNotarization *EmptyNotarization }

type BFT_EmptyVote 

type BFT_EmptyVote struct{ EmptyVote *EmptyVote }

type BFT_Finalization 

type BFT_Finalization struct{ Finalization *QuorumCertificate }

type BFT_FinalizeVote 

type BFT_FinalizeVote struct{ FinalizeVote *Vote }

type BFT_Notarization 

type BFT_Notarization struct{ Notarization *QuorumCertificate }

type BFT_ReplicationRequest 

type BFT_ReplicationRequest struct{ ReplicationRequest *ReplicationRequest }

type BFT_ReplicationResponse 

type BFT_ReplicationResponse struct{ ReplicationResponse *ReplicationResponse }

type BFT_Vote 

type BFT_Vote struct{ Vote *Vote }

type BlockProposal 

type BlockProposal struct {
	Block []byte
}

BlockProposal message

func (*BlockProposal) GetBlock 

func (m *BlockProposal) GetBlock() []byte

type BloomFilter 

type BloomFilter struct {
	Filter []byte
	Salt   []byte
}

BloomFilter for peer discovery

func (*BloomFilter) GetFilter 

func (m *BloomFilter) GetFilter() []byte

func (*BloomFilter) GetSalt 

func (m *BloomFilter) GetSalt() []byte

type Buffer 

type Buffer struct {
	// contains filtered or unexported fields
}

Buffer for zero-copy encoding

func NewBuffer 

func NewBuffer(size int) *Buffer

func (*Buffer) Bytes 

func (b *Buffer) Bytes() []byte

func (*Buffer) WriteBytes 

func (b *Buffer) WriteBytes(data []byte)

func (*Buffer) WriteBytesSlice 

func (b *Buffer) WriteBytesSlice(slices [][]byte)

func (*Buffer) WriteInt32 

func (b *Buffer) WriteInt32(v int32)

func (*Buffer) WriteString 

func (b *Buffer) WriteString(s string)

func (*Buffer) WriteUint8 

func (b *Buffer) WriteUint8(v uint8)

func (*Buffer) WriteUint32 

func (b *Buffer) WriteUint32(v uint32)

func (*Buffer) WriteUint32Slice 

func (b *Buffer) WriteUint32Slice(vals []uint32)

func (*Buffer) WriteUint64 

func (b *Buffer) WriteUint64(v uint64)

func (*Buffer) WriteUint64Slice 

func (b *Buffer) WriteUint64Slice(vals []uint64)

type Chits 

type Chits struct {
	ChainId             []byte
	RequestId           uint32
	PreferredId         []byte
	PreferredIdAtHeight []byte
	AcceptedId          []byte
	AcceptedHeight      uint64
}

Chits message

func (*Chits) GetAcceptedHeight 

func (m *Chits) GetAcceptedHeight() uint64

func (*Chits) GetAcceptedId 

func (m *Chits) GetAcceptedId() []byte

func (*Chits) GetChainId 

func (m *Chits) GetChainId() []byte

func (*Chits) GetPreferredId 

func (m *Chits) GetPreferredId() []byte

func (*Chits) GetPreferredIdAtHeight 

func (m *Chits) GetPreferredIdAtHeight() []byte

func (*Chits) GetRequestId 

func (m *Chits) GetRequestId() uint32

func (*Chits) Reset 

func (m *Chits) Reset()

func (*Chits) String 

func (m *Chits) String() string

type ClaimedIpPort 

type ClaimedIpPort struct {
	X509Certificate []byte
	IpAddr          []byte
	IpPort          uint32
	Timestamp       uint64
	Signature       []byte
	TxId            []byte
}

ClaimedIpPort in peer list

func (*ClaimedIpPort) GetIpAddr 

func (m *ClaimedIpPort) GetIpAddr() []byte

func (*ClaimedIpPort) GetIpPort 

func (m *ClaimedIpPort) GetIpPort() uint32

func (*ClaimedIpPort) GetSignature 

func (m *ClaimedIpPort) GetSignature() []byte

func (*ClaimedIpPort) GetTimestamp 

func (m *ClaimedIpPort) GetTimestamp() uint64

func (*ClaimedIpPort) GetTxId 

func (m *ClaimedIpPort) GetTxId() []byte

func (*ClaimedIpPort) GetX509Certificate 

func (m *ClaimedIpPort) GetX509Certificate() []byte

type Client 

type Client struct {
	Name  string
	Major uint32
	Minor uint32
	Patch uint32
}

Client info

func (*Client) GetMajor 

func (m *Client) GetMajor() uint32

func (*Client) GetMinor 

func (m *Client) GetMinor() uint32

func (*Client) GetName 

func (m *Client) GetName() string

func (*Client) GetPatch 

func (m *Client) GetPatch() uint32

type EmptyNotarization 

type EmptyNotarization struct {
	View                uint64
	Seq                 uint64
	AggregatedSignature []byte
	Signers             []byte
}

EmptyNotarization message

type EmptyVote 

type EmptyVote struct {
	View      uint64
	Seq       uint64
	Signature []byte
}

EmptyVote message

type EngineType 

type EngineType int32

EngineType represents the consensus engine type 

const (
	EngineType_ENGINE_TYPE_UNSPECIFIED EngineType = 0
	EngineType_ENGINE_TYPE_CHAIN       EngineType = 1
	EngineType_ENGINE_TYPE_DAG         EngineType = 2
)

func (EngineType) String 

func (e EngineType) String() string

type Error 

type Error struct {
	ChainId      []byte
	RequestId    uint32
	ErrorCode    int32
	ErrorMessage string
}

Error message (application-level error)

func (*Error) GetChainId 

func (m *Error) GetChainId() []byte

func (*Error) GetErrorCode 

func (m *Error) GetErrorCode() int32

func (*Error) GetErrorMessage 

func (m *Error) GetErrorMessage() string

func (*Error) GetRequestId 

func (m *Error) GetRequestId() uint32

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

type Get 

type Get struct {
	ChainId     []byte
	RequestId   uint32
	Deadline    uint64
	ContainerId []byte
	EngineType  EngineType
}

Get message

func (*Get) GetChainId 

func (m *Get) GetChainId() []byte

func (*Get) GetContainerId 

func (m *Get) GetContainerId() []byte

func (*Get) GetDeadline 

func (m *Get) GetDeadline() uint64

func (*Get) GetEngineType 

func (m *Get) GetEngineType() EngineType

func (*Get) GetRequestId 

func (m *Get) GetRequestId() uint32

func (*Get) Reset 

func (m *Get) Reset()

func (*Get) String 

func (m *Get) String() string

type GetAccepted 

type GetAccepted struct {
	ChainId      []byte
	RequestId    uint32
	Deadline     uint64
	ContainerIds [][]byte
	EngineType   EngineType
}

GetAccepted message

func (*GetAccepted) GetChainId 

func (m *GetAccepted) GetChainId() []byte

func (*GetAccepted) GetContainerIds 

func (m *GetAccepted) GetContainerIds() [][]byte

func (*GetAccepted) GetDeadline 

func (m *GetAccepted) GetDeadline() uint64

func (*GetAccepted) GetEngineType 

func (m *GetAccepted) GetEngineType() EngineType

func (*GetAccepted) GetRequestId 

func (m *GetAccepted) GetRequestId() uint32

func (*GetAccepted) Reset 

func (m *GetAccepted) Reset()

func (*GetAccepted) String 

func (m *GetAccepted) String() string

type GetAcceptedFrontier 

type GetAcceptedFrontier struct {
	ChainId    []byte
	RequestId  uint32
	Deadline   uint64
	EngineType EngineType
}

GetAcceptedFrontier message

func (*GetAcceptedFrontier) GetChainId 

func (m *GetAcceptedFrontier) GetChainId() []byte

func (*GetAcceptedFrontier) GetDeadline 

func (m *GetAcceptedFrontier) GetDeadline() uint64

func (*GetAcceptedFrontier) GetEngineType 

func (m *GetAcceptedFrontier) GetEngineType() EngineType

func (*GetAcceptedFrontier) GetRequestId 

func (m *GetAcceptedFrontier) GetRequestId() uint32

func (*GetAcceptedFrontier) Reset 

func (m *GetAcceptedFrontier) Reset()

func (*GetAcceptedFrontier) String 

func (m *GetAcceptedFrontier) String() string

type GetAcceptedStateSummary 

type GetAcceptedStateSummary struct {
	ChainId   []byte
	RequestId uint32
	Deadline  uint64
	Heights   []uint64
}

GetAcceptedStateSummary message

func (*GetAcceptedStateSummary) GetChainId 

func (m *GetAcceptedStateSummary) GetChainId() []byte

func (*GetAcceptedStateSummary) GetDeadline 

func (m *GetAcceptedStateSummary) GetDeadline() uint64

func (*GetAcceptedStateSummary) GetHeights 

func (m *GetAcceptedStateSummary) GetHeights() []uint64

func (*GetAcceptedStateSummary) GetRequestId 

func (m *GetAcceptedStateSummary) GetRequestId() uint32

func (*GetAcceptedStateSummary) Reset 

func (m *GetAcceptedStateSummary) Reset()

func (*GetAcceptedStateSummary) String 

func (m *GetAcceptedStateSummary) String() string

type GetAncestors 

type GetAncestors struct {
	ChainId     []byte
	RequestId   uint32
	Deadline    uint64
	ContainerId []byte
	EngineType  EngineType
}

GetAncestors message

func (*GetAncestors) GetChainId 

func (m *GetAncestors) GetChainId() []byte

func (*GetAncestors) GetContainerId 

func (m *GetAncestors) GetContainerId() []byte

func (*GetAncestors) GetDeadline 

func (m *GetAncestors) GetDeadline() uint64

func (*GetAncestors) GetEngineType 

func (m *GetAncestors) GetEngineType() EngineType

func (*GetAncestors) GetRequestId 

func (m *GetAncestors) GetRequestId() uint32

func (*GetAncestors) Reset 

func (m *GetAncestors) Reset()

func (*GetAncestors) String 

func (m *GetAncestors) String() string

type GetPeerList 

type GetPeerList struct {
	KnownPeers *BloomFilter
	AllChains  bool
}

GetPeerList message

func (*GetPeerList) GetAllChains 

func (m *GetPeerList) GetAllChains() bool

func (*GetPeerList) GetKnownPeers 

func (m *GetPeerList) GetKnownPeers() *BloomFilter

func (*GetPeerList) Reset 

func (m *GetPeerList) Reset()

func (*GetPeerList) String 

func (m *GetPeerList) String() string

type GetStateSummaryFrontier 

type GetStateSummaryFrontier struct {
	ChainId   []byte
	RequestId uint32
	Deadline  uint64
}

GetStateSummaryFrontier message

func (*GetStateSummaryFrontier) GetChainId 

func (m *GetStateSummaryFrontier) GetChainId() []byte

func (*GetStateSummaryFrontier) GetDeadline 

func (m *GetStateSummaryFrontier) GetDeadline() uint64

func (*GetStateSummaryFrontier) GetRequestId 

func (m *GetStateSummaryFrontier) GetRequestId() uint32

func (*GetStateSummaryFrontier) Reset 

func (m *GetStateSummaryFrontier) Reset()

func (*GetStateSummaryFrontier) String 

func (m *GetStateSummaryFrontier) String() string

type Gossip 

type Gossip struct {
	ChainId  []byte
	AppBytes []byte
}

Gossip message (application-level)

func (*Gossip) GetAppBytes 

func (m *Gossip) GetAppBytes() []byte

func (*Gossip) GetChainId 

func (m *Gossip) GetChainId() []byte

func (*Gossip) Reset 

func (m *Gossip) Reset()

func (*Gossip) String 

func (m *Gossip) String() string

type Handshake 

type Handshake struct {
	NetworkId     uint32
	MyTime        uint64
	IpAddr        []byte
	IpPort        uint32
	IpSigningTime uint64
	IpNodeIdSig   []byte
	TrackedNets   [][]byte
	Client        *Client
	SupportedLps  []uint32
	ObjectedLps   []uint32
	KnownPeers    *BloomFilter
	IpBlsSig      []byte
	AllChains     bool
}

Handshake message

func (*Handshake) GetAllChains 

func (m *Handshake) GetAllChains() bool

func (*Handshake) GetClient 

func (m *Handshake) GetClient() *Client

func (*Handshake) GetIpAddr 

func (m *Handshake) GetIpAddr() []byte

func (*Handshake) GetIpBlsSig 

func (m *Handshake) GetIpBlsSig() []byte

func (*Handshake) GetIpNodeIdSig 

func (m *Handshake) GetIpNodeIdSig() []byte

func (*Handshake) GetIpPort 

func (m *Handshake) GetIpPort() uint32

func (*Handshake) GetIpSigningTime 

func (m *Handshake) GetIpSigningTime() uint64

func (*Handshake) GetKnownPeers 

func (m *Handshake) GetKnownPeers() *BloomFilter

func (*Handshake) GetMyTime 

func (m *Handshake) GetMyTime() uint64

func (*Handshake) GetNetworkId 

func (m *Handshake) GetNetworkId() uint32

func (*Handshake) GetObjectedLps 

func (m *Handshake) GetObjectedLps() []uint32

func (*Handshake) GetSupportedLps 

func (m *Handshake) GetSupportedLps() []uint32

func (*Handshake) GetTrackedNets 

func (m *Handshake) GetTrackedNets() [][]byte

func (*Handshake) Reset 

func (m *Handshake) Reset()

func (*Handshake) String 

func (m *Handshake) String() string

type Message 

type Message struct {
	Message isMessage_Message
}

Message is the top-level P2P message container

func (*Message) GetAccepted 

func (m *Message) GetAccepted() *Accepted

func (*Message) GetAcceptedFrontier 

func (m *Message) GetAcceptedFrontier() *AcceptedFrontier

func (*Message) GetAcceptedStateSummary 

func (m *Message) GetAcceptedStateSummary() *AcceptedStateSummary

func (*Message) GetAncestors 

func (m *Message) GetAncestors() *Ancestors

func (*Message) GetBFT 

func (m *Message) GetBFT() *BFT

func (*Message) GetChits 

func (m *Message) GetChits() *Chits

func (*Message) GetCompressedZstd 

func (m *Message) GetCompressedZstd() []byte

func (*Message) GetError 

func (m *Message) GetError() *Error

func (*Message) GetGet 

func (m *Message) GetGet() *Get

func (*Message) GetGetAccepted 

func (m *Message) GetGetAccepted() *GetAccepted

func (*Message) GetGetAcceptedFrontier 

func (m *Message) GetGetAcceptedFrontier() *GetAcceptedFrontier

func (*Message) GetGetAcceptedStateSummary 

func (m *Message) GetGetAcceptedStateSummary() *GetAcceptedStateSummary

func (*Message) GetGetAncestors 

func (m *Message) GetGetAncestors() *GetAncestors

func (*Message) GetGetPeerList 

func (m *Message) GetGetPeerList() *GetPeerList

func (*Message) GetGetStateSummaryFrontier 

func (m *Message) GetGetStateSummaryFrontier() *GetStateSummaryFrontier

func (*Message) GetGossip 

func (m *Message) GetGossip() *Gossip

func (*Message) GetHandshake 

func (m *Message) GetHandshake() *Handshake

func (*Message) GetMessage 

func (m *Message) GetMessage() isMessage_Message

func (*Message) GetPeerList 

func (m *Message) GetPeerList() *PeerList

func (*Message) GetPing 

func (m *Message) GetPing() *Ping

func (*Message) GetPong 

func (m *Message) GetPong() *Pong

func (*Message) GetPullQuery 

func (m *Message) GetPullQuery() *PullQuery

func (*Message) GetPushQuery 

func (m *Message) GetPushQuery() *PushQuery

func (*Message) GetPut 

func (m *Message) GetPut() *Put

func (*Message) GetRequest 

func (m *Message) GetRequest() *Request

func (*Message) GetResponse 

func (m *Message) GetResponse() *Response

func (*Message) GetStateSummaryFrontier 

func (m *Message) GetStateSummaryFrontier() *StateSummaryFrontier

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

type Message_AcceptedFrontier_ 

type Message_AcceptedFrontier_ struct{ AcceptedFrontier_ *AcceptedFrontier }

type Message_AcceptedStateSummary_ 

type Message_AcceptedStateSummary_ struct{ AcceptedStateSummary_ *AcceptedStateSummary }

type Message_Accepted_ 

type Message_Accepted_ struct{ Accepted_ *Accepted }

type Message_Ancestors_ 

type Message_Ancestors_ struct{ Ancestors_ *Ancestors }

type Message_BFT 

type Message_BFT struct{ BFT *BFT }

type Message_Chits 

type Message_Chits struct{ Chits *Chits }

type Message_CompressedZstd 

type Message_CompressedZstd struct{ CompressedZstd []byte }

type Message_Error 

type Message_Error struct{ Error *Error }

type Message_Get 

type Message_Get struct{ Get *Get }

type Message_GetAccepted 

type Message_GetAccepted struct{ GetAccepted *GetAccepted }

type Message_GetAcceptedFrontier 

type Message_GetAcceptedFrontier struct{ GetAcceptedFrontier *GetAcceptedFrontier }

type Message_GetAcceptedStateSummary 

type Message_GetAcceptedStateSummary struct{ GetAcceptedStateSummary *GetAcceptedStateSummary }

type Message_GetAncestors 

type Message_GetAncestors struct{ GetAncestors *GetAncestors }

type Message_GetPeerList 

type Message_GetPeerList struct{ GetPeerList *GetPeerList }

type Message_GetStateSummaryFrontier 

type Message_GetStateSummaryFrontier struct{ GetStateSummaryFrontier *GetStateSummaryFrontier }

type Message_Gossip 

type Message_Gossip struct{ Gossip *Gossip }

type Message_Handshake 

type Message_Handshake struct{ Handshake *Handshake }

type Message_PeerList_ 

type Message_PeerList_ struct{ PeerList_ *PeerList }

type Message_Ping 

type Message_Ping struct{ Ping *Ping }

type Message_Pong 

type Message_Pong struct{ Pong *Pong }

type Message_PullQuery 

type Message_PullQuery struct{ PullQuery *PullQuery }

type Message_PushQuery 

type Message_PushQuery struct{ PushQuery *PushQuery }

type Message_Put 

type Message_Put struct{ Put *Put }

type Message_Request 

type Message_Request struct{ Request *Request }

type Message_Response 

type Message_Response struct{ Response *Response }

type Message_StateSummaryFrontier_ 

type Message_StateSummaryFrontier_ struct{ StateSummaryFrontier_ *StateSummaryFrontier }

type PeerList 

type PeerList struct {
	ClaimedIpPorts []*ClaimedIpPort
}

PeerList message

func (*PeerList) GetClaimedIpPorts 

func (m *PeerList) GetClaimedIpPorts() []*ClaimedIpPort

func (*PeerList) Reset 

func (m *PeerList) Reset()

func (*PeerList) String 

func (m *PeerList) String() string

type Ping 

type Ping struct {
	Uptime        uint32
	SubnetUptimes []*SubnetUptime
}

Ping message

func (*Ping) GetSubnetUptimes 

func (m *Ping) GetSubnetUptimes() []*SubnetUptime

func (*Ping) GetUptime 

func (m *Ping) GetUptime() uint32

func (*Ping) Reset 

func (m *Ping) Reset()

func (*Ping) String 

func (m *Ping) String() string

type Pong 

type Pong struct {
	Uptime        uint32
	SubnetUptimes []*SubnetUptime
}

Pong message

func (*Pong) GetSubnetUptimes 

func (m *Pong) GetSubnetUptimes() []*SubnetUptime

func (*Pong) GetUptime 

func (m *Pong) GetUptime() uint32

func (*Pong) Reset 

func (m *Pong) Reset()

func (*Pong) String 

func (m *Pong) String() string

type PullQuery 

type PullQuery struct {
	ChainId         []byte
	RequestId       uint32
	Deadline        uint64
	ContainerId     []byte
	EngineType      EngineType
	RequestedHeight uint64
}

PullQuery message

func (*PullQuery) GetChainId 

func (m *PullQuery) GetChainId() []byte

func (*PullQuery) GetContainerId 

func (m *PullQuery) GetContainerId() []byte

func (*PullQuery) GetDeadline 

func (m *PullQuery) GetDeadline() uint64

func (*PullQuery) GetEngineType 

func (m *PullQuery) GetEngineType() EngineType

func (*PullQuery) GetRequestId 

func (m *PullQuery) GetRequestId() uint32

func (*PullQuery) GetRequestedHeight 

func (m *PullQuery) GetRequestedHeight() uint64

func (*PullQuery) Reset 

func (m *PullQuery) Reset()

func (*PullQuery) String 

func (m *PullQuery) String() string

type PushQuery 

type PushQuery struct {
	ChainId         []byte
	RequestId       uint32
	Deadline        uint64
	Container       []byte
	EngineType      EngineType
	RequestedHeight uint64
}

PushQuery message

func (*PushQuery) GetChainId 

func (m *PushQuery) GetChainId() []byte

func (*PushQuery) GetContainer 

func (m *PushQuery) GetContainer() []byte

func (*PushQuery) GetDeadline 

func (m *PushQuery) GetDeadline() uint64

func (*PushQuery) GetEngineType 

func (m *PushQuery) GetEngineType() EngineType

func (*PushQuery) GetRequestId 

func (m *PushQuery) GetRequestId() uint32

func (*PushQuery) GetRequestedHeight 

func (m *PushQuery) GetRequestedHeight() uint64

func (*PushQuery) Reset 

func (m *PushQuery) Reset()

func (*PushQuery) String 

func (m *PushQuery) String() string

type Put 

type Put struct {
	ChainId    []byte
	RequestId  uint32
	Container  []byte
	EngineType EngineType
}

Put message

func (*Put) GetChainId 

func (m *Put) GetChainId() []byte

func (*Put) GetContainer 

func (m *Put) GetContainer() []byte

func (*Put) GetEngineType 

func (m *Put) GetEngineType() EngineType

func (*Put) GetRequestId 

func (m *Put) GetRequestId() uint32

func (*Put) Reset 

func (m *Put) Reset()

func (*Put) String 

func (m *Put) String() string

type QuorumCertificate 

type QuorumCertificate struct {
	BlockHash           []byte
	View                uint64
	Seq                 uint64
	AggregatedSignature []byte
	Signers             []byte
}

QuorumCertificate message

type Reader 

type Reader struct {
	// contains filtered or unexported fields
}

Reader for zero-copy decoding

func NewReader 

func NewReader(data []byte) *Reader

func (*Reader) ReadBytes 

func (r *Reader) ReadBytes() ([]byte, error)

func (*Reader) ReadBytesSlice 

func (r *Reader) ReadBytesSlice() ([][]byte, error)

func (*Reader) ReadInt32 

func (r *Reader) ReadInt32() (int32, error)

func (*Reader) ReadString 

func (r *Reader) ReadString() (string, error)

func (*Reader) ReadUint8 

func (r *Reader) ReadUint8() (uint8, error)

func (*Reader) ReadUint32 

func (r *Reader) ReadUint32() (uint32, error)

func (*Reader) ReadUint32Slice 

func (r *Reader) ReadUint32Slice() ([]uint32, error)

func (*Reader) ReadUint64 

func (r *Reader) ReadUint64() (uint64, error)

func (*Reader) ReadUint64Slice 

func (r *Reader) ReadUint64Slice() ([]uint64, error)

type ReplicationRequest 

type ReplicationRequest struct {
	Seqs        []uint64
	LatestRound uint64
}

ReplicationRequest message

func (*ReplicationRequest) GetLatestRound 

func (m *ReplicationRequest) GetLatestRound() uint64

func (*ReplicationRequest) GetSeqs 

func (m *ReplicationRequest) GetSeqs() []uint64

type ReplicationResponse 

type ReplicationResponse struct {
	Messages [][]byte
}

ReplicationResponse message

type Request 

type Request struct {
	ChainId   []byte
	RequestId uint32
	Deadline  uint64
	AppBytes  []byte
}

Request message (application-level)

func (*Request) GetAppBytes 

func (m *Request) GetAppBytes() []byte

func (*Request) GetChainId 

func (m *Request) GetChainId() []byte

func (*Request) GetDeadline 

func (m *Request) GetDeadline() uint64

func (*Request) GetRequestId 

func (m *Request) GetRequestId() uint32

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) String 

func (m *Request) String() string

type Response 

type Response struct {
	ChainId   []byte
	RequestId uint32
	AppBytes  []byte
}

Response message (application-level)

func (*Response) GetAppBytes 

func (m *Response) GetAppBytes() []byte

func (*Response) GetChainId 

func (m *Response) GetChainId() []byte

func (*Response) GetRequestId 

func (m *Response) GetRequestId() uint32

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

type StateSummaryFrontier 

type StateSummaryFrontier struct {
	ChainId   []byte
	RequestId uint32
	Summary   []byte
}

StateSummaryFrontier message

func (*StateSummaryFrontier) GetChainId 

func (m *StateSummaryFrontier) GetChainId() []byte

func (*StateSummaryFrontier) GetRequestId 

func (m *StateSummaryFrontier) GetRequestId() uint32

func (*StateSummaryFrontier) GetSummary 

func (m *StateSummaryFrontier) GetSummary() []byte

func (*StateSummaryFrontier) Reset 

func (m *StateSummaryFrontier) Reset()

func (*StateSummaryFrontier) String 

func (m *StateSummaryFrontier) String() string

type SubnetUptime 

type SubnetUptime struct {
	SubnetId []byte
	Uptime   uint32
}

SubnetUptime for ping/pong

func (*SubnetUptime) GetSubnetId 

func (m *SubnetUptime) GetSubnetId() []byte

func (*SubnetUptime) GetUptime 

func (m *SubnetUptime) GetUptime() uint32

type Vote 

type Vote struct {
	BlockHash []byte
	Signature []byte
}

Vote message

func (*Vote) GetBlockHash 

func (m *Vote) GetBlockHash() []byte

func (*Vote) GetSignature 

func (m *Vote) GetSignature() []byte

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.