Documentation ¶
Index ¶
- Variables
- type Accepted
- func (*Accepted) Descriptor() ([]byte, []int)deprecated
- func (x *Accepted) GetChainId() []byte
- func (x *Accepted) GetContainerIds() [][]byte
- func (x *Accepted) GetRequestId() uint32
- func (*Accepted) ProtoMessage()
- func (x *Accepted) ProtoReflect() protoreflect.Message
- func (x *Accepted) Reset()
- func (x *Accepted) String() string
- type AcceptedFrontier
- func (*AcceptedFrontier) Descriptor() ([]byte, []int)deprecated
- func (x *AcceptedFrontier) GetChainId() []byte
- func (x *AcceptedFrontier) GetContainerId() []byte
- func (x *AcceptedFrontier) GetRequestId() uint32
- func (*AcceptedFrontier) ProtoMessage()
- func (x *AcceptedFrontier) ProtoReflect() protoreflect.Message
- func (x *AcceptedFrontier) Reset()
- func (x *AcceptedFrontier) String() string
- type AcceptedStateSummary
- func (*AcceptedStateSummary) Descriptor() ([]byte, []int)deprecated
- func (x *AcceptedStateSummary) GetChainId() []byte
- func (x *AcceptedStateSummary) GetRequestId() uint32
- func (x *AcceptedStateSummary) GetSummaryIds() [][]byte
- func (*AcceptedStateSummary) ProtoMessage()
- func (x *AcceptedStateSummary) ProtoReflect() protoreflect.Message
- func (x *AcceptedStateSummary) Reset()
- func (x *AcceptedStateSummary) String() string
- type Ancestors
- func (*Ancestors) Descriptor() ([]byte, []int)deprecated
- func (x *Ancestors) GetChainId() []byte
- func (x *Ancestors) GetContainers() [][]byte
- func (x *Ancestors) GetRequestId() uint32
- func (*Ancestors) ProtoMessage()
- func (x *Ancestors) ProtoReflect() protoreflect.Message
- func (x *Ancestors) Reset()
- func (x *Ancestors) String() string
- type AppError
- func (*AppError) Descriptor() ([]byte, []int)deprecated
- func (x *AppError) GetChainId() []byte
- func (x *AppError) GetErrorCode() int32
- func (x *AppError) GetErrorMessage() string
- func (x *AppError) GetRequestId() uint32
- func (*AppError) ProtoMessage()
- func (x *AppError) ProtoReflect() protoreflect.Message
- func (x *AppError) Reset()
- func (x *AppError) String() string
- type AppGossip
- type AppRequest
- func (*AppRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AppRequest) GetAppBytes() []byte
- func (x *AppRequest) GetChainId() []byte
- func (x *AppRequest) GetDeadline() uint64
- func (x *AppRequest) GetRequestId() uint32
- func (*AppRequest) ProtoMessage()
- func (x *AppRequest) ProtoReflect() protoreflect.Message
- func (x *AppRequest) Reset()
- func (x *AppRequest) String() string
- type AppResponse
- func (*AppResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AppResponse) GetAppBytes() []byte
- func (x *AppResponse) GetChainId() []byte
- func (x *AppResponse) GetRequestId() uint32
- func (*AppResponse) ProtoMessage()
- func (x *AppResponse) ProtoReflect() protoreflect.Message
- func (x *AppResponse) Reset()
- func (x *AppResponse) String() string
- type BloomFilter
- type Chits
- func (*Chits) Descriptor() ([]byte, []int)deprecated
- func (x *Chits) GetAcceptedId() []byte
- func (x *Chits) GetChainId() []byte
- func (x *Chits) GetPreferredId() []byte
- func (x *Chits) GetPreferredIdAtHeight() []byte
- func (x *Chits) GetRequestId() uint32
- func (*Chits) ProtoMessage()
- func (x *Chits) ProtoReflect() protoreflect.Message
- func (x *Chits) Reset()
- func (x *Chits) String() string
- type ClaimedIpPort
- func (*ClaimedIpPort) Descriptor() ([]byte, []int)deprecated
- func (x *ClaimedIpPort) GetIpAddr() []byte
- func (x *ClaimedIpPort) GetIpPort() uint32
- func (x *ClaimedIpPort) GetSignature() []byte
- func (x *ClaimedIpPort) GetTimestamp() uint64
- func (x *ClaimedIpPort) GetTxId() []byte
- func (x *ClaimedIpPort) GetX509Certificate() []byte
- func (*ClaimedIpPort) ProtoMessage()
- func (x *ClaimedIpPort) ProtoReflect() protoreflect.Message
- func (x *ClaimedIpPort) Reset()
- func (x *ClaimedIpPort) String() string
- type Client
- func (*Client) Descriptor() ([]byte, []int)deprecated
- func (x *Client) GetMajor() uint32
- func (x *Client) GetMinor() uint32
- func (x *Client) GetName() string
- func (x *Client) GetPatch() uint32
- func (*Client) ProtoMessage()
- func (x *Client) ProtoReflect() protoreflect.Message
- func (x *Client) Reset()
- func (x *Client) String() string
- type EngineType
- type Get
- func (*Get) Descriptor() ([]byte, []int)deprecated
- func (x *Get) GetChainId() []byte
- func (x *Get) GetContainerId() []byte
- func (x *Get) GetDeadline() uint64
- func (x *Get) GetEngineType() EngineType
- func (x *Get) GetRequestId() uint32
- func (*Get) ProtoMessage()
- func (x *Get) ProtoReflect() protoreflect.Message
- func (x *Get) Reset()
- func (x *Get) String() string
- type GetAccepted
- func (*GetAccepted) Descriptor() ([]byte, []int)deprecated
- func (x *GetAccepted) GetChainId() []byte
- func (x *GetAccepted) GetContainerIds() [][]byte
- func (x *GetAccepted) GetDeadline() uint64
- func (x *GetAccepted) GetEngineType() EngineType
- func (x *GetAccepted) GetRequestId() uint32
- func (*GetAccepted) ProtoMessage()
- func (x *GetAccepted) ProtoReflect() protoreflect.Message
- func (x *GetAccepted) Reset()
- func (x *GetAccepted) String() string
- type GetAcceptedFrontier
- func (*GetAcceptedFrontier) Descriptor() ([]byte, []int)deprecated
- func (x *GetAcceptedFrontier) GetChainId() []byte
- func (x *GetAcceptedFrontier) GetDeadline() uint64
- func (x *GetAcceptedFrontier) GetEngineType() EngineType
- func (x *GetAcceptedFrontier) GetRequestId() uint32
- func (*GetAcceptedFrontier) ProtoMessage()
- func (x *GetAcceptedFrontier) ProtoReflect() protoreflect.Message
- func (x *GetAcceptedFrontier) Reset()
- func (x *GetAcceptedFrontier) String() string
- type GetAcceptedStateSummary
- func (*GetAcceptedStateSummary) Descriptor() ([]byte, []int)deprecated
- func (x *GetAcceptedStateSummary) GetChainId() []byte
- func (x *GetAcceptedStateSummary) GetDeadline() uint64
- func (x *GetAcceptedStateSummary) GetHeights() []uint64
- func (x *GetAcceptedStateSummary) GetRequestId() uint32
- func (*GetAcceptedStateSummary) ProtoMessage()
- func (x *GetAcceptedStateSummary) ProtoReflect() protoreflect.Message
- func (x *GetAcceptedStateSummary) Reset()
- func (x *GetAcceptedStateSummary) String() string
- type GetAncestors
- func (*GetAncestors) Descriptor() ([]byte, []int)deprecated
- func (x *GetAncestors) GetChainId() []byte
- func (x *GetAncestors) GetContainerId() []byte
- func (x *GetAncestors) GetDeadline() uint64
- func (x *GetAncestors) GetEngineType() EngineType
- func (x *GetAncestors) GetRequestId() uint32
- func (*GetAncestors) ProtoMessage()
- func (x *GetAncestors) ProtoReflect() protoreflect.Message
- func (x *GetAncestors) Reset()
- func (x *GetAncestors) String() string
- type GetPeerList
- type GetStateSummaryFrontier
- func (*GetStateSummaryFrontier) Descriptor() ([]byte, []int)deprecated
- func (x *GetStateSummaryFrontier) GetChainId() []byte
- func (x *GetStateSummaryFrontier) GetDeadline() uint64
- func (x *GetStateSummaryFrontier) GetRequestId() uint32
- func (*GetStateSummaryFrontier) ProtoMessage()
- func (x *GetStateSummaryFrontier) ProtoReflect() protoreflect.Message
- func (x *GetStateSummaryFrontier) Reset()
- func (x *GetStateSummaryFrontier) String() string
- type Handshake
- func (*Handshake) Descriptor() ([]byte, []int)deprecated
- func (x *Handshake) GetClient() *Client
- func (x *Handshake) GetIpAddr() []byte
- func (x *Handshake) GetIpPort() uint32
- func (x *Handshake) GetIpSigningTime() uint64
- func (x *Handshake) GetKnownPeers() *BloomFilter
- func (x *Handshake) GetMyTime() uint64
- func (x *Handshake) GetMyVersion() string
- func (x *Handshake) GetNetworkId() uint32
- func (x *Handshake) GetObjectedAcps() []uint32
- func (x *Handshake) GetSig() []byte
- func (x *Handshake) GetSupportedAcps() []uint32
- func (x *Handshake) GetTrackedSubnets() [][]byte
- func (*Handshake) ProtoMessage()
- func (x *Handshake) ProtoReflect() protoreflect.Message
- func (x *Handshake) Reset()
- func (x *Handshake) String() string
- type Message
- func (*Message) Descriptor() ([]byte, []int)deprecated
- func (x *Message) GetAcceptedFrontier_() *AcceptedFrontier
- func (x *Message) GetAcceptedStateSummary_() *AcceptedStateSummary
- func (x *Message) GetAccepted_() *Accepted
- func (x *Message) GetAncestors_() *Ancestors
- func (x *Message) GetAppError() *AppError
- func (x *Message) GetAppGossip() *AppGossip
- func (x *Message) GetAppRequest() *AppRequest
- func (x *Message) GetAppResponse() *AppResponse
- func (x *Message) GetChits() *Chits
- func (x *Message) GetCompressedGzip() []byte
- func (x *Message) GetCompressedZstd() []byte
- func (x *Message) GetGet() *Get
- func (x *Message) GetGetAccepted() *GetAccepted
- func (x *Message) GetGetAcceptedFrontier() *GetAcceptedFrontier
- func (x *Message) GetGetAcceptedStateSummary() *GetAcceptedStateSummary
- func (x *Message) GetGetAncestors() *GetAncestors
- func (x *Message) GetGetPeerList() *GetPeerList
- func (x *Message) GetGetStateSummaryFrontier() *GetStateSummaryFrontier
- func (x *Message) GetHandshake() *Handshake
- func (m *Message) GetMessage() isMessage_Message
- func (x *Message) GetPeerList_() *PeerList
- func (x *Message) GetPing() *Ping
- func (x *Message) GetPong() *Pong
- func (x *Message) GetPullQuery() *PullQuery
- func (x *Message) GetPushQuery() *PushQuery
- func (x *Message) GetPut() *Put
- func (x *Message) GetStateSummaryFrontier_() *StateSummaryFrontier
- func (*Message) ProtoMessage()
- func (x *Message) ProtoReflect() protoreflect.Message
- func (x *Message) Reset()
- func (x *Message) String() string
- type Message_AcceptedFrontier_
- type Message_AcceptedStateSummary_
- type Message_Accepted_
- type Message_Ancestors_
- type Message_AppError
- type Message_AppGossip
- type Message_AppRequest
- type Message_AppResponse
- type Message_Chits
- type Message_CompressedGzip
- type Message_CompressedZstd
- type Message_Get
- type Message_GetAccepted
- type Message_GetAcceptedFrontier
- type Message_GetAcceptedStateSummary
- type Message_GetAncestors
- type Message_GetPeerList
- type Message_GetStateSummaryFrontier
- type Message_Handshake
- type Message_PeerList_
- type Message_Ping
- type Message_Pong
- type Message_PullQuery
- type Message_PushQuery
- type Message_Put
- type Message_StateSummaryFrontier_
- type PeerList
- type Ping
- type Pong
- type PullQuery
- func (*PullQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PullQuery) GetChainId() []byte
- func (x *PullQuery) GetContainerId() []byte
- func (x *PullQuery) GetDeadline() uint64
- func (x *PullQuery) GetEngineType() EngineType
- func (x *PullQuery) GetRequestId() uint32
- func (x *PullQuery) GetRequestedHeight() uint64
- func (*PullQuery) ProtoMessage()
- func (x *PullQuery) ProtoReflect() protoreflect.Message
- func (x *PullQuery) Reset()
- func (x *PullQuery) String() string
- type PushQuery
- func (*PushQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PushQuery) GetChainId() []byte
- func (x *PushQuery) GetContainer() []byte
- func (x *PushQuery) GetDeadline() uint64
- func (x *PushQuery) GetEngineType() EngineType
- func (x *PushQuery) GetRequestId() uint32
- func (x *PushQuery) GetRequestedHeight() uint64
- func (*PushQuery) ProtoMessage()
- func (x *PushQuery) ProtoReflect() protoreflect.Message
- func (x *PushQuery) Reset()
- func (x *PushQuery) String() string
- type Put
- func (*Put) Descriptor() ([]byte, []int)deprecated
- func (x *Put) GetChainId() []byte
- func (x *Put) GetContainer() []byte
- func (x *Put) GetEngineType() EngineType
- func (x *Put) GetRequestId() uint32
- func (*Put) ProtoMessage()
- func (x *Put) ProtoReflect() protoreflect.Message
- func (x *Put) Reset()
- func (x *Put) String() string
- type StateSummaryFrontier
- func (*StateSummaryFrontier) Descriptor() ([]byte, []int)deprecated
- func (x *StateSummaryFrontier) GetChainId() []byte
- func (x *StateSummaryFrontier) GetRequestId() uint32
- func (x *StateSummaryFrontier) GetSummary() []byte
- func (*StateSummaryFrontier) ProtoMessage()
- func (x *StateSummaryFrontier) ProtoReflect() protoreflect.Message
- func (x *StateSummaryFrontier) Reset()
- func (x *StateSummaryFrontier) String() string
- type SubnetUptime
- func (*SubnetUptime) Descriptor() ([]byte, []int)deprecated
- func (x *SubnetUptime) GetSubnetId() []byte
- func (x *SubnetUptime) GetUptime() uint32
- func (*SubnetUptime) ProtoMessage()
- func (x *SubnetUptime) ProtoReflect() protoreflect.Message
- func (x *SubnetUptime) Reset()
- func (x *SubnetUptime) String() string
Constants ¶
This section is empty.
Variables ¶
var ( EngineType_name = map[int32]string{ 0: "ENGINE_TYPE_UNSPECIFIED", 1: "ENGINE_TYPE_AVALANCHE", 2: "ENGINE_TYPE_SNOWMAN", } EngineType_value = map[string]int32{ "ENGINE_TYPE_UNSPECIFIED": 0, "ENGINE_TYPE_AVALANCHE": 1, "ENGINE_TYPE_SNOWMAN": 2, } )
Enum value maps for EngineType.
var File_p2p_p2p_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Accepted ¶
type Accepted struct { // Chain being responded from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Request id of the original GetAccepted request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Subset of container ids from the GetAccepted request that the sender has // accepted ContainerIds [][]byte `protobuf:"bytes,3,rep,name=container_ids,json=containerIds,proto3" json:"container_ids,omitempty"` // contains filtered or unexported fields }
Accepted is sent in response to GetAccepted. The sending peer responds with a subset of container ids from the GetAccepted request that the sending peer has accepted.
func (*Accepted) Descriptor
deprecated
func (*Accepted) GetChainId ¶
func (*Accepted) GetContainerIds ¶
func (*Accepted) GetRequestId ¶
func (*Accepted) ProtoMessage ¶
func (*Accepted) ProtoMessage()
func (*Accepted) ProtoReflect ¶
func (x *Accepted) ProtoReflect() protoreflect.Message
type AcceptedFrontier ¶
type AcceptedFrontier struct { // Chain being responded from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Request id of the original GetAcceptedFrontier request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // The id of the last accepted frontier ContainerId []byte `protobuf:"bytes,3,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` // contains filtered or unexported fields }
AcceptedFrontier contains the remote peer's last accepted frontier.
AcceptedFrontier is sent in response to GetAcceptedFrontier.
func (*AcceptedFrontier) Descriptor
deprecated
func (*AcceptedFrontier) Descriptor() ([]byte, []int)
Deprecated: Use AcceptedFrontier.ProtoReflect.Descriptor instead.
func (*AcceptedFrontier) GetChainId ¶
func (x *AcceptedFrontier) GetChainId() []byte
func (*AcceptedFrontier) GetContainerId ¶ added in v1.10.3
func (x *AcceptedFrontier) GetContainerId() []byte
func (*AcceptedFrontier) GetRequestId ¶
func (x *AcceptedFrontier) GetRequestId() uint32
func (*AcceptedFrontier) ProtoMessage ¶
func (*AcceptedFrontier) ProtoMessage()
func (*AcceptedFrontier) ProtoReflect ¶
func (x *AcceptedFrontier) ProtoReflect() protoreflect.Message
func (*AcceptedFrontier) Reset ¶
func (x *AcceptedFrontier) Reset()
func (*AcceptedFrontier) String ¶
func (x *AcceptedFrontier) String() string
type AcceptedStateSummary ¶
type AcceptedStateSummary struct { // Chain being responded from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Request id of the original GetAcceptedStateSummary request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // State summary ids SummaryIds [][]byte `protobuf:"bytes,3,rep,name=summary_ids,json=summaryIds,proto3" json:"summary_ids,omitempty"` // contains filtered or unexported fields }
AcceptedStateSummary is sent in response to GetAcceptedStateSummary
func (*AcceptedStateSummary) Descriptor
deprecated
func (*AcceptedStateSummary) Descriptor() ([]byte, []int)
Deprecated: Use AcceptedStateSummary.ProtoReflect.Descriptor instead.
func (*AcceptedStateSummary) GetChainId ¶
func (x *AcceptedStateSummary) GetChainId() []byte
func (*AcceptedStateSummary) GetRequestId ¶
func (x *AcceptedStateSummary) GetRequestId() uint32
func (*AcceptedStateSummary) GetSummaryIds ¶
func (x *AcceptedStateSummary) GetSummaryIds() [][]byte
func (*AcceptedStateSummary) ProtoMessage ¶
func (*AcceptedStateSummary) ProtoMessage()
func (*AcceptedStateSummary) ProtoReflect ¶
func (x *AcceptedStateSummary) ProtoReflect() protoreflect.Message
func (*AcceptedStateSummary) Reset ¶
func (x *AcceptedStateSummary) Reset()
func (*AcceptedStateSummary) String ¶
func (x *AcceptedStateSummary) String() string
type Ancestors ¶
type Ancestors struct { // Chain being responded from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Request id of the original GetAncestors request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Ancestry for the requested container Containers [][]byte `protobuf:"bytes,3,rep,name=containers,proto3" json:"containers,omitempty"` // contains filtered or unexported fields }
Ancestors is sent in response to GetAncestors.
Ancestors contains a contiguous ancestry of containers for the requested container in order of increasing block height.
func (*Ancestors) Descriptor
deprecated
func (*Ancestors) GetChainId ¶
func (*Ancestors) GetContainers ¶
func (*Ancestors) GetRequestId ¶
func (*Ancestors) ProtoMessage ¶
func (*Ancestors) ProtoMessage()
func (*Ancestors) ProtoReflect ¶
func (x *Ancestors) ProtoReflect() protoreflect.Message
type AppError ¶ added in v1.10.16
type AppError struct { // Chain the message is for ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Request id of the original AppRequest RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // VM defined error code. VMs may define error codes > 0. ErrorCode int32 `protobuf:"zigzag32,3,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"` // VM defined error message ErrorMessage string `protobuf:"bytes,4,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` // contains filtered or unexported fields }
AppError is a VM-defined error sent in response to AppRequest
func (*AppError) Descriptor
deprecated
added in
v1.10.16
func (*AppError) GetChainId ¶ added in v1.10.16
func (*AppError) GetErrorCode ¶ added in v1.10.16
func (*AppError) GetErrorMessage ¶ added in v1.10.16
func (*AppError) GetRequestId ¶ added in v1.10.16
func (*AppError) ProtoMessage ¶ added in v1.10.16
func (*AppError) ProtoMessage()
func (*AppError) ProtoReflect ¶ added in v1.10.16
func (x *AppError) ProtoReflect() protoreflect.Message
type AppGossip ¶
type AppGossip struct { // Chain the message is for ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Message body AppBytes []byte `protobuf:"bytes,2,opt,name=app_bytes,json=appBytes,proto3" json:"app_bytes,omitempty"` // contains filtered or unexported fields }
AppGossip is a VM-defined message
func (*AppGossip) Descriptor
deprecated
func (*AppGossip) GetAppBytes ¶
func (*AppGossip) GetChainId ¶
func (*AppGossip) ProtoMessage ¶
func (*AppGossip) ProtoMessage()
func (*AppGossip) ProtoReflect ¶
func (x *AppGossip) ProtoReflect() protoreflect.Message
type AppRequest ¶
type AppRequest struct { // Chain being requested from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Unique identifier for this request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Timeout (ns) for this request Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` // Request body AppBytes []byte `protobuf:"bytes,4,opt,name=app_bytes,json=appBytes,proto3" json:"app_bytes,omitempty"` // contains filtered or unexported fields }
AppRequest is a VM-defined request.
Remote peers must respond to AppRequest with a corresponding AppResponse or AppError
func (*AppRequest) Descriptor
deprecated
func (*AppRequest) Descriptor() ([]byte, []int)
Deprecated: Use AppRequest.ProtoReflect.Descriptor instead.
func (*AppRequest) GetAppBytes ¶
func (x *AppRequest) GetAppBytes() []byte
func (*AppRequest) GetChainId ¶
func (x *AppRequest) GetChainId() []byte
func (*AppRequest) GetDeadline ¶
func (x *AppRequest) GetDeadline() uint64
func (*AppRequest) GetRequestId ¶
func (x *AppRequest) GetRequestId() uint32
func (*AppRequest) ProtoMessage ¶
func (*AppRequest) ProtoMessage()
func (*AppRequest) ProtoReflect ¶
func (x *AppRequest) ProtoReflect() protoreflect.Message
func (*AppRequest) Reset ¶
func (x *AppRequest) Reset()
func (*AppRequest) String ¶
func (x *AppRequest) String() string
type AppResponse ¶
type AppResponse struct { // Chain being responded from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Request id of the original AppRequest RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Response body AppBytes []byte `protobuf:"bytes,3,opt,name=app_bytes,json=appBytes,proto3" json:"app_bytes,omitempty"` // contains filtered or unexported fields }
AppResponse is a VM-defined response sent in response to AppRequest
func (*AppResponse) Descriptor
deprecated
func (*AppResponse) Descriptor() ([]byte, []int)
Deprecated: Use AppResponse.ProtoReflect.Descriptor instead.
func (*AppResponse) GetAppBytes ¶
func (x *AppResponse) GetAppBytes() []byte
func (*AppResponse) GetChainId ¶
func (x *AppResponse) GetChainId() []byte
func (*AppResponse) GetRequestId ¶
func (x *AppResponse) GetRequestId() uint32
func (*AppResponse) ProtoMessage ¶
func (*AppResponse) ProtoMessage()
func (*AppResponse) ProtoReflect ¶
func (x *AppResponse) ProtoReflect() protoreflect.Message
func (*AppResponse) Reset ¶
func (x *AppResponse) Reset()
func (*AppResponse) String ¶
func (x *AppResponse) String() string
type BloomFilter ¶ added in v1.10.18
type BloomFilter struct { Filter []byte `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` Salt []byte `protobuf:"bytes,2,opt,name=salt,proto3" json:"salt,omitempty"` // contains filtered or unexported fields }
BloomFilter with a random salt to prevent consistent hash collisions
func (*BloomFilter) Descriptor
deprecated
added in
v1.10.18
func (*BloomFilter) Descriptor() ([]byte, []int)
Deprecated: Use BloomFilter.ProtoReflect.Descriptor instead.
func (*BloomFilter) GetFilter ¶ added in v1.10.18
func (x *BloomFilter) GetFilter() []byte
func (*BloomFilter) GetSalt ¶ added in v1.10.18
func (x *BloomFilter) GetSalt() []byte
func (*BloomFilter) ProtoMessage ¶ added in v1.10.18
func (*BloomFilter) ProtoMessage()
func (*BloomFilter) ProtoReflect ¶ added in v1.10.18
func (x *BloomFilter) ProtoReflect() protoreflect.Message
func (*BloomFilter) Reset ¶ added in v1.10.18
func (x *BloomFilter) Reset()
func (*BloomFilter) String ¶ added in v1.10.18
func (x *BloomFilter) String() string
type Chits ¶
type Chits struct { // Chain being responded from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Request id of the original PushQuery/PullQuery request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Currently preferred block PreferredId []byte `protobuf:"bytes,3,opt,name=preferred_id,json=preferredId,proto3" json:"preferred_id,omitempty"` // Last accepted block AcceptedId []byte `protobuf:"bytes,4,opt,name=accepted_id,json=acceptedId,proto3" json:"accepted_id,omitempty"` // Currently preferred block at the requested height PreferredIdAtHeight []byte `protobuf:"bytes,5,opt,name=preferred_id_at_height,json=preferredIdAtHeight,proto3" json:"preferred_id_at_height,omitempty"` // contains filtered or unexported fields }
Chits contains the preferences of a peer in response to a PushQuery or PullQuery message.
func (*Chits) Descriptor
deprecated
func (*Chits) GetAcceptedId ¶ added in v1.10.3
func (*Chits) GetChainId ¶
func (*Chits) GetPreferredId ¶ added in v1.10.3
func (*Chits) GetPreferredIdAtHeight ¶ added in v1.10.12
func (*Chits) GetRequestId ¶
func (*Chits) ProtoMessage ¶
func (*Chits) ProtoMessage()
func (*Chits) ProtoReflect ¶
func (x *Chits) ProtoReflect() protoreflect.Message
type ClaimedIpPort ¶
type ClaimedIpPort struct { // X509 certificate of the peer X509Certificate []byte `protobuf:"bytes,1,opt,name=x509_certificate,json=x509Certificate,proto3" json:"x509_certificate,omitempty"` // IP address of the peer IpAddr []byte `protobuf:"bytes,2,opt,name=ip_addr,json=ipAddr,proto3" json:"ip_addr,omitempty"` // IP port of the peer IpPort uint32 `protobuf:"varint,3,opt,name=ip_port,json=ipPort,proto3" json:"ip_port,omitempty"` // Timestamp of the IP address + port pair Timestamp uint64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Signature of the IP port pair at a provided timestamp Signature []byte `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"` // P-Chain transaction that added this peer to the validator set TxId []byte `protobuf:"bytes,6,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` // contains filtered or unexported fields }
ClaimedIpPort contains metadata needed to connect to a peer
func (*ClaimedIpPort) Descriptor
deprecated
func (*ClaimedIpPort) Descriptor() ([]byte, []int)
Deprecated: Use ClaimedIpPort.ProtoReflect.Descriptor instead.
func (*ClaimedIpPort) GetIpAddr ¶
func (x *ClaimedIpPort) GetIpAddr() []byte
func (*ClaimedIpPort) GetIpPort ¶
func (x *ClaimedIpPort) GetIpPort() uint32
func (*ClaimedIpPort) GetSignature ¶
func (x *ClaimedIpPort) GetSignature() []byte
func (*ClaimedIpPort) GetTimestamp ¶
func (x *ClaimedIpPort) GetTimestamp() uint64
func (*ClaimedIpPort) GetTxId ¶ added in v1.9.4
func (x *ClaimedIpPort) GetTxId() []byte
func (*ClaimedIpPort) GetX509Certificate ¶
func (x *ClaimedIpPort) GetX509Certificate() []byte
func (*ClaimedIpPort) ProtoMessage ¶
func (*ClaimedIpPort) ProtoMessage()
func (*ClaimedIpPort) ProtoReflect ¶
func (x *ClaimedIpPort) ProtoReflect() protoreflect.Message
func (*ClaimedIpPort) Reset ¶
func (x *ClaimedIpPort) Reset()
func (*ClaimedIpPort) String ¶
func (x *ClaimedIpPort) String() string
type Client ¶ added in v1.10.18
type Client struct { // Client name (e.g avalanchego) Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Client semantic version Major uint32 `protobuf:"varint,2,opt,name=major,proto3" json:"major,omitempty"` Minor uint32 `protobuf:"varint,3,opt,name=minor,proto3" json:"minor,omitempty"` Patch uint32 `protobuf:"varint,4,opt,name=patch,proto3" json:"patch,omitempty"` // contains filtered or unexported fields }
Metadata about a peer's P2P client used to determine compatibility
func (*Client) Descriptor
deprecated
added in
v1.10.18
func (*Client) ProtoMessage ¶ added in v1.10.18
func (*Client) ProtoMessage()
func (*Client) ProtoReflect ¶ added in v1.10.18
func (x *Client) ProtoReflect() protoreflect.Message
type EngineType ¶ added in v1.9.6
type EngineType int32
The consensus engine that should be used when handling a consensus request.
const ( EngineType_ENGINE_TYPE_UNSPECIFIED EngineType = 0 // Only the X-Chain uses avalanche consensus EngineType_ENGINE_TYPE_AVALANCHE EngineType = 1 EngineType_ENGINE_TYPE_SNOWMAN EngineType = 2 )
func (EngineType) Descriptor ¶ added in v1.9.6
func (EngineType) Descriptor() protoreflect.EnumDescriptor
func (EngineType) Enum ¶ added in v1.9.6
func (x EngineType) Enum() *EngineType
func (EngineType) EnumDescriptor
deprecated
added in
v1.9.6
func (EngineType) EnumDescriptor() ([]byte, []int)
Deprecated: Use EngineType.Descriptor instead.
func (EngineType) Number ¶ added in v1.9.6
func (x EngineType) Number() protoreflect.EnumNumber
func (EngineType) String ¶ added in v1.9.6
func (x EngineType) String() string
func (EngineType) Type ¶ added in v1.9.6
func (EngineType) Type() protoreflect.EnumType
type Get ¶
type Get struct { // Chain being requested from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Unique identifier for this request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Timeout (ns) for this request Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` // Container being requested ContainerId []byte `protobuf:"bytes,4,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` // Consensus type to handle this message EngineType EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"` // contains filtered or unexported fields }
Get requests a container from a remote peer.
Remote peers should respond with a Put message if they have the container.
func (*Get) Descriptor
deprecated
func (*Get) GetChainId ¶
func (*Get) GetContainerId ¶
func (*Get) GetDeadline ¶
func (*Get) GetEngineType ¶ added in v1.9.6
func (x *Get) GetEngineType() EngineType
func (*Get) GetRequestId ¶
func (*Get) ProtoMessage ¶
func (*Get) ProtoMessage()
func (*Get) ProtoReflect ¶
func (x *Get) ProtoReflect() protoreflect.Message
type GetAccepted ¶
type GetAccepted struct { // Chain being requested from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Unique identifier for this message RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Timeout (ns) for this request Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` // The sender's accepted frontier ContainerIds [][]byte `protobuf:"bytes,4,rep,name=container_ids,json=containerIds,proto3" json:"container_ids,omitempty"` // Consensus type to handle this message EngineType EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"` // contains filtered or unexported fields }
GetAccepted sends a request with the sender's accepted frontier to a remote peer.
Peers should respond to GetAccepted with an Accepted message.
func (*GetAccepted) Descriptor
deprecated
func (*GetAccepted) Descriptor() ([]byte, []int)
Deprecated: Use GetAccepted.ProtoReflect.Descriptor instead.
func (*GetAccepted) GetChainId ¶
func (x *GetAccepted) GetChainId() []byte
func (*GetAccepted) GetContainerIds ¶
func (x *GetAccepted) GetContainerIds() [][]byte
func (*GetAccepted) GetDeadline ¶
func (x *GetAccepted) GetDeadline() uint64
func (*GetAccepted) GetEngineType ¶ added in v1.9.6
func (x *GetAccepted) GetEngineType() EngineType
func (*GetAccepted) GetRequestId ¶
func (x *GetAccepted) GetRequestId() uint32
func (*GetAccepted) ProtoMessage ¶
func (*GetAccepted) ProtoMessage()
func (*GetAccepted) ProtoReflect ¶
func (x *GetAccepted) ProtoReflect() protoreflect.Message
func (*GetAccepted) Reset ¶
func (x *GetAccepted) Reset()
func (*GetAccepted) String ¶
func (x *GetAccepted) String() string
type GetAcceptedFrontier ¶
type GetAcceptedFrontier struct { // Chain being requested from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Unique identifier for this request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Timeout (ns) for this request Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` // Consensus type the remote peer should use to handle this message EngineType EngineType `protobuf:"varint,4,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"` // contains filtered or unexported fields }
GetAcceptedFrontier requests the accepted frontier from a peer.
Peers should respond to GetAcceptedFrontier with AcceptedFrontier.
func (*GetAcceptedFrontier) Descriptor
deprecated
func (*GetAcceptedFrontier) Descriptor() ([]byte, []int)
Deprecated: Use GetAcceptedFrontier.ProtoReflect.Descriptor instead.
func (*GetAcceptedFrontier) GetChainId ¶
func (x *GetAcceptedFrontier) GetChainId() []byte
func (*GetAcceptedFrontier) GetDeadline ¶
func (x *GetAcceptedFrontier) GetDeadline() uint64
func (*GetAcceptedFrontier) GetEngineType ¶ added in v1.9.6
func (x *GetAcceptedFrontier) GetEngineType() EngineType
func (*GetAcceptedFrontier) GetRequestId ¶
func (x *GetAcceptedFrontier) GetRequestId() uint32
func (*GetAcceptedFrontier) ProtoMessage ¶
func (*GetAcceptedFrontier) ProtoMessage()
func (*GetAcceptedFrontier) ProtoReflect ¶
func (x *GetAcceptedFrontier) ProtoReflect() protoreflect.Message
func (*GetAcceptedFrontier) Reset ¶
func (x *GetAcceptedFrontier) Reset()
func (*GetAcceptedFrontier) String ¶
func (x *GetAcceptedFrontier) String() string
type GetAcceptedStateSummary ¶
type GetAcceptedStateSummary struct { // Chain bein requested from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Unique identifier for this request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Timeout (ns) for this request Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` // Heights being requested Heights []uint64 `protobuf:"varint,4,rep,packed,name=heights,proto3" json:"heights,omitempty"` // contains filtered or unexported fields }
GetAcceptedStateSummary requests a set of state summaries at a set of block heights
func (*GetAcceptedStateSummary) Descriptor
deprecated
func (*GetAcceptedStateSummary) Descriptor() ([]byte, []int)
Deprecated: Use GetAcceptedStateSummary.ProtoReflect.Descriptor instead.
func (*GetAcceptedStateSummary) GetChainId ¶
func (x *GetAcceptedStateSummary) GetChainId() []byte
func (*GetAcceptedStateSummary) GetDeadline ¶
func (x *GetAcceptedStateSummary) GetDeadline() uint64
func (*GetAcceptedStateSummary) GetHeights ¶
func (x *GetAcceptedStateSummary) GetHeights() []uint64
func (*GetAcceptedStateSummary) GetRequestId ¶
func (x *GetAcceptedStateSummary) GetRequestId() uint32
func (*GetAcceptedStateSummary) ProtoMessage ¶
func (*GetAcceptedStateSummary) ProtoMessage()
func (*GetAcceptedStateSummary) ProtoReflect ¶
func (x *GetAcceptedStateSummary) ProtoReflect() protoreflect.Message
func (*GetAcceptedStateSummary) Reset ¶
func (x *GetAcceptedStateSummary) Reset()
func (*GetAcceptedStateSummary) String ¶
func (x *GetAcceptedStateSummary) String() string
type GetAncestors ¶
type GetAncestors struct { // Chain being requested from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Unique identifier for this request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Timeout (ns) for this request Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` // Container for which ancestors are being requested ContainerId []byte `protobuf:"bytes,4,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` // Consensus type to handle this message EngineType EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"` // contains filtered or unexported fields }
GetAncestors requests the ancestors for a given container.
The remote peer should respond with an Ancestors message.
func (*GetAncestors) Descriptor
deprecated
func (*GetAncestors) Descriptor() ([]byte, []int)
Deprecated: Use GetAncestors.ProtoReflect.Descriptor instead.
func (*GetAncestors) GetChainId ¶
func (x *GetAncestors) GetChainId() []byte
func (*GetAncestors) GetContainerId ¶
func (x *GetAncestors) GetContainerId() []byte
func (*GetAncestors) GetDeadline ¶
func (x *GetAncestors) GetDeadline() uint64
func (*GetAncestors) GetEngineType ¶ added in v1.9.6
func (x *GetAncestors) GetEngineType() EngineType
func (*GetAncestors) GetRequestId ¶
func (x *GetAncestors) GetRequestId() uint32
func (*GetAncestors) ProtoMessage ¶
func (*GetAncestors) ProtoMessage()
func (*GetAncestors) ProtoReflect ¶
func (x *GetAncestors) ProtoReflect() protoreflect.Message
func (*GetAncestors) Reset ¶
func (x *GetAncestors) Reset()
func (*GetAncestors) String ¶
func (x *GetAncestors) String() string
type GetPeerList ¶ added in v1.10.18
type GetPeerList struct { KnownPeers *BloomFilter `protobuf:"bytes,1,opt,name=known_peers,json=knownPeers,proto3" json:"known_peers,omitempty"` // contains filtered or unexported fields }
GetPeerList contains a bloom filter of the currently known validator IPs.
GetPeerList must not be responded to until finishing the handshake. After the handshake is completed, GetPeerlist messages should be responded to with a Peerlist message containing validators that are not present in the bloom filter.
func (*GetPeerList) Descriptor
deprecated
added in
v1.10.18
func (*GetPeerList) Descriptor() ([]byte, []int)
Deprecated: Use GetPeerList.ProtoReflect.Descriptor instead.
func (*GetPeerList) GetKnownPeers ¶ added in v1.10.18
func (x *GetPeerList) GetKnownPeers() *BloomFilter
func (*GetPeerList) ProtoMessage ¶ added in v1.10.18
func (*GetPeerList) ProtoMessage()
func (*GetPeerList) ProtoReflect ¶ added in v1.10.18
func (x *GetPeerList) ProtoReflect() protoreflect.Message
func (*GetPeerList) Reset ¶ added in v1.10.18
func (x *GetPeerList) Reset()
func (*GetPeerList) String ¶ added in v1.10.18
func (x *GetPeerList) String() string
type GetStateSummaryFrontier ¶
type GetStateSummaryFrontier struct { // Chain being requested from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Unique identifier for this request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Timeout (ns) for this request Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` // contains filtered or unexported fields }
GetStateSummaryFrontier requests a peer's most recently accepted state summary
func (*GetStateSummaryFrontier) Descriptor
deprecated
func (*GetStateSummaryFrontier) Descriptor() ([]byte, []int)
Deprecated: Use GetStateSummaryFrontier.ProtoReflect.Descriptor instead.
func (*GetStateSummaryFrontier) GetChainId ¶
func (x *GetStateSummaryFrontier) GetChainId() []byte
func (*GetStateSummaryFrontier) GetDeadline ¶
func (x *GetStateSummaryFrontier) GetDeadline() uint64
func (*GetStateSummaryFrontier) GetRequestId ¶
func (x *GetStateSummaryFrontier) GetRequestId() uint32
func (*GetStateSummaryFrontier) ProtoMessage ¶
func (*GetStateSummaryFrontier) ProtoMessage()
func (*GetStateSummaryFrontier) ProtoReflect ¶
func (x *GetStateSummaryFrontier) ProtoReflect() protoreflect.Message
func (*GetStateSummaryFrontier) Reset ¶
func (x *GetStateSummaryFrontier) Reset()
func (*GetStateSummaryFrontier) String ¶
func (x *GetStateSummaryFrontier) String() string
type Handshake ¶ added in v1.10.18
type Handshake struct { // Network the peer is running on (e.g local, testnet, mainnet) NetworkId uint32 `protobuf:"varint,1,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"` // Unix timestamp when this Handshake message was created MyTime uint64 `protobuf:"varint,2,opt,name=my_time,json=myTime,proto3" json:"my_time,omitempty"` // IP address of the peer IpAddr []byte `protobuf:"bytes,3,opt,name=ip_addr,json=ipAddr,proto3" json:"ip_addr,omitempty"` // IP port of the peer IpPort uint32 `protobuf:"varint,4,opt,name=ip_port,json=ipPort,proto3" json:"ip_port,omitempty"` // Avalanche client version MyVersion string `protobuf:"bytes,5,opt,name=my_version,json=myVersion,proto3" json:"my_version,omitempty"` // Timestamp of the IP IpSigningTime uint64 `protobuf:"varint,6,opt,name=ip_signing_time,json=ipSigningTime,proto3" json:"ip_signing_time,omitempty"` // Signature of the peer IP port pair at a provided timestamp Sig []byte `protobuf:"bytes,7,opt,name=sig,proto3" json:"sig,omitempty"` // Subnets the peer is tracking TrackedSubnets [][]byte `protobuf:"bytes,8,rep,name=tracked_subnets,json=trackedSubnets,proto3" json:"tracked_subnets,omitempty"` Client *Client `protobuf:"bytes,9,opt,name=client,proto3" json:"client,omitempty"` SupportedAcps []uint32 `protobuf:"varint,10,rep,packed,name=supported_acps,json=supportedAcps,proto3" json:"supported_acps,omitempty"` ObjectedAcps []uint32 `protobuf:"varint,11,rep,packed,name=objected_acps,json=objectedAcps,proto3" json:"objected_acps,omitempty"` KnownPeers *BloomFilter `protobuf:"bytes,12,opt,name=known_peers,json=knownPeers,proto3" json:"known_peers,omitempty"` // contains filtered or unexported fields }
Handshake is the first outbound message sent to a peer when a connection is established to start the p2p handshake.
Peers must respond to a Handshake message with a PeerList message to allow the peer to connect to other peers in the network.
Peers should drop connections to peers with incompatible versions.
func (*Handshake) Descriptor
deprecated
added in
v1.10.18
func (*Handshake) GetIpSigningTime ¶ added in v1.10.18
func (*Handshake) GetKnownPeers ¶ added in v1.10.18
func (x *Handshake) GetKnownPeers() *BloomFilter
func (*Handshake) GetMyVersion ¶ added in v1.10.18
func (*Handshake) GetNetworkId ¶ added in v1.10.18
func (*Handshake) GetObjectedAcps ¶ added in v1.10.18
func (*Handshake) GetSupportedAcps ¶ added in v1.10.18
func (*Handshake) GetTrackedSubnets ¶ added in v1.10.18
func (*Handshake) ProtoMessage ¶ added in v1.10.18
func (*Handshake) ProtoMessage()
func (*Handshake) ProtoReflect ¶ added in v1.10.18
func (x *Handshake) ProtoReflect() protoreflect.Message
type Message ¶
type Message struct { // NOTES // Use "oneof" for each message type and set rest to null if not used. // That is because when the compression is enabled, we don't want to include uncompressed fields. // // Types that are assignable to Message: // // *Message_CompressedGzip // *Message_CompressedZstd // *Message_Ping // *Message_Pong // *Message_Handshake // *Message_GetPeerList // *Message_PeerList_ // *Message_GetStateSummaryFrontier // *Message_StateSummaryFrontier_ // *Message_GetAcceptedStateSummary // *Message_AcceptedStateSummary_ // *Message_GetAcceptedFrontier // *Message_AcceptedFrontier_ // *Message_GetAccepted // *Message_Accepted_ // *Message_GetAncestors // *Message_Ancestors_ // *Message_Get // *Message_Put // *Message_PushQuery // *Message_PullQuery // *Message_Chits // *Message_AppRequest // *Message_AppResponse // *Message_AppGossip // *Message_AppError Message isMessage_Message `protobuf_oneof:"message"` // contains filtered or unexported fields }
Represents peer-to-peer messages. Only one type can be non-null.
func (*Message) Descriptor
deprecated
func (*Message) GetAcceptedFrontier_ ¶
func (x *Message) GetAcceptedFrontier_() *AcceptedFrontier
func (*Message) GetAcceptedStateSummary_ ¶
func (x *Message) GetAcceptedStateSummary_() *AcceptedStateSummary
func (*Message) GetAccepted_ ¶
func (*Message) GetAncestors_ ¶
func (*Message) GetAppError ¶ added in v1.10.16
func (*Message) GetAppGossip ¶
func (*Message) GetAppRequest ¶
func (x *Message) GetAppRequest() *AppRequest
func (*Message) GetAppResponse ¶
func (x *Message) GetAppResponse() *AppResponse
func (*Message) GetCompressedGzip ¶
func (*Message) GetCompressedZstd ¶ added in v1.10.0
func (*Message) GetGetAccepted ¶
func (x *Message) GetGetAccepted() *GetAccepted
func (*Message) GetGetAcceptedFrontier ¶
func (x *Message) GetGetAcceptedFrontier() *GetAcceptedFrontier
func (*Message) GetGetAcceptedStateSummary ¶
func (x *Message) GetGetAcceptedStateSummary() *GetAcceptedStateSummary
func (*Message) GetGetAncestors ¶
func (x *Message) GetGetAncestors() *GetAncestors
func (*Message) GetGetPeerList ¶ added in v1.10.18
func (x *Message) GetGetPeerList() *GetPeerList
func (*Message) GetGetStateSummaryFrontier ¶
func (x *Message) GetGetStateSummaryFrontier() *GetStateSummaryFrontier
func (*Message) GetHandshake ¶ added in v1.10.18
func (*Message) GetMessage ¶
func (m *Message) GetMessage() isMessage_Message
func (*Message) GetPeerList_ ¶ added in v1.10.18
func (*Message) GetPullQuery ¶
func (*Message) GetPushQuery ¶
func (*Message) GetStateSummaryFrontier_ ¶
func (x *Message) GetStateSummaryFrontier_() *StateSummaryFrontier
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) ProtoReflect ¶
func (x *Message) ProtoReflect() protoreflect.Message
type Message_AcceptedFrontier_ ¶
type Message_AcceptedFrontier_ struct {
AcceptedFrontier_ *AcceptedFrontier `protobuf:"bytes,20,opt,name=accepted_frontier,json=acceptedFrontier,proto3,oneof"`
}
type Message_AcceptedStateSummary_ ¶
type Message_AcceptedStateSummary_ struct {
AcceptedStateSummary_ *AcceptedStateSummary `protobuf:"bytes,18,opt,name=accepted_state_summary,json=acceptedStateSummary,proto3,oneof"`
}
type Message_Accepted_ ¶
type Message_Accepted_ struct {
Accepted_ *Accepted `protobuf:"bytes,22,opt,name=accepted,proto3,oneof"`
}
type Message_Ancestors_ ¶
type Message_Ancestors_ struct {
Ancestors_ *Ancestors `protobuf:"bytes,24,opt,name=ancestors,proto3,oneof"`
}
type Message_AppError ¶ added in v1.10.16
type Message_AppError struct {
AppError *AppError `protobuf:"bytes,34,opt,name=app_error,json=appError,proto3,oneof"`
}
type Message_AppGossip ¶
type Message_AppGossip struct {
AppGossip *AppGossip `protobuf:"bytes,32,opt,name=app_gossip,json=appGossip,proto3,oneof"`
}
type Message_AppRequest ¶
type Message_AppRequest struct { // App messages: AppRequest *AppRequest `protobuf:"bytes,30,opt,name=app_request,json=appRequest,proto3,oneof"` }
type Message_AppResponse ¶
type Message_AppResponse struct {
AppResponse *AppResponse `protobuf:"bytes,31,opt,name=app_response,json=appResponse,proto3,oneof"`
}
type Message_Chits ¶
type Message_Chits struct {
Chits *Chits `protobuf:"bytes,29,opt,name=chits,proto3,oneof"`
}
type Message_CompressedGzip ¶
type Message_CompressedGzip struct { // Gzip-compressed bytes of a "p2p.Message" whose "oneof" "message" field is // NOT compressed_* BUT one of the message types (e.g. ping, pong, etc.). // This field is only set if the message type supports compression. CompressedGzip []byte `protobuf:"bytes,1,opt,name=compressed_gzip,json=compressedGzip,proto3,oneof"` }
type Message_CompressedZstd ¶ added in v1.10.0
type Message_CompressedZstd struct { // zstd-compressed bytes of a "p2p.Message" whose "oneof" "message" field is // NOT compressed_* BUT one of the message types (e.g. ping, pong, etc.). // This field is only set if the message type supports compression. CompressedZstd []byte `protobuf:"bytes,2,opt,name=compressed_zstd,json=compressedZstd,proto3,oneof"` }
type Message_Get ¶
type Message_Get struct { // Consensus messages: Get *Get `protobuf:"bytes,25,opt,name=get,proto3,oneof"` }
type Message_GetAccepted ¶
type Message_GetAccepted struct {
GetAccepted *GetAccepted `protobuf:"bytes,21,opt,name=get_accepted,json=getAccepted,proto3,oneof"`
}
type Message_GetAcceptedFrontier ¶
type Message_GetAcceptedFrontier struct { // Bootstrapping messages: GetAcceptedFrontier *GetAcceptedFrontier `protobuf:"bytes,19,opt,name=get_accepted_frontier,json=getAcceptedFrontier,proto3,oneof"` }
type Message_GetAcceptedStateSummary ¶
type Message_GetAcceptedStateSummary struct {
GetAcceptedStateSummary *GetAcceptedStateSummary `protobuf:"bytes,17,opt,name=get_accepted_state_summary,json=getAcceptedStateSummary,proto3,oneof"`
}
type Message_GetAncestors ¶
type Message_GetAncestors struct {
GetAncestors *GetAncestors `protobuf:"bytes,23,opt,name=get_ancestors,json=getAncestors,proto3,oneof"`
}
type Message_GetPeerList ¶ added in v1.10.18
type Message_GetPeerList struct {
GetPeerList *GetPeerList `protobuf:"bytes,35,opt,name=get_peer_list,json=getPeerList,proto3,oneof"`
}
type Message_GetStateSummaryFrontier ¶
type Message_GetStateSummaryFrontier struct { // State-sync messages: GetStateSummaryFrontier *GetStateSummaryFrontier `protobuf:"bytes,15,opt,name=get_state_summary_frontier,json=getStateSummaryFrontier,proto3,oneof"` }
type Message_Handshake ¶ added in v1.10.18
type Message_Handshake struct {
Handshake *Handshake `protobuf:"bytes,13,opt,name=handshake,proto3,oneof"`
}
type Message_PeerList_ ¶ added in v1.10.18
type Message_PeerList_ struct {
PeerList_ *PeerList `protobuf:"bytes,14,opt,name=peer_list,json=peerList,proto3,oneof"`
}
type Message_Ping ¶
type Message_Ping struct { // Network messages: Ping *Ping `protobuf:"bytes,11,opt,name=ping,proto3,oneof"` }
type Message_Pong ¶
type Message_Pong struct {
Pong *Pong `protobuf:"bytes,12,opt,name=pong,proto3,oneof"`
}
type Message_PullQuery ¶
type Message_PullQuery struct {
PullQuery *PullQuery `protobuf:"bytes,28,opt,name=pull_query,json=pullQuery,proto3,oneof"`
}
type Message_PushQuery ¶
type Message_PushQuery struct {
PushQuery *PushQuery `protobuf:"bytes,27,opt,name=push_query,json=pushQuery,proto3,oneof"`
}
type Message_Put ¶
type Message_Put struct {
Put *Put `protobuf:"bytes,26,opt,name=put,proto3,oneof"`
}
type Message_StateSummaryFrontier_ ¶
type Message_StateSummaryFrontier_ struct {
StateSummaryFrontier_ *StateSummaryFrontier `protobuf:"bytes,16,opt,name=state_summary_frontier,json=stateSummaryFrontier,proto3,oneof"`
}
type PeerList ¶
type PeerList struct { ClaimedIpPorts []*ClaimedIpPort `protobuf:"bytes,1,rep,name=claimed_ip_ports,json=claimedIpPorts,proto3" json:"claimed_ip_ports,omitempty"` // contains filtered or unexported fields }
PeerList contains network-level metadata for a set of validators.
PeerList must be sent in response to an inbound Handshake message from a remote peer a peer wants to connect to. Once a PeerList is received after a Handshake message, the p2p handshake is complete and the connection is established.
PeerList should be sent in response to a GetPeerlist message if the handshake has been completed.
func (*PeerList) Descriptor
deprecated
func (*PeerList) GetClaimedIpPorts ¶
func (x *PeerList) GetClaimedIpPorts() []*ClaimedIpPort
func (*PeerList) ProtoMessage ¶
func (*PeerList) ProtoMessage()
func (*PeerList) ProtoReflect ¶
func (x *PeerList) ProtoReflect() protoreflect.Message
type Ping ¶
type Ping struct { // Uptime percentage on the primary network [0, 100] Uptime uint32 `protobuf:"varint,1,opt,name=uptime,proto3" json:"uptime,omitempty"` // Uptime percentage on subnets SubnetUptimes []*SubnetUptime `protobuf:"bytes,2,rep,name=subnet_uptimes,json=subnetUptimes,proto3" json:"subnet_uptimes,omitempty"` // contains filtered or unexported fields }
Ping reports a peer's perceived uptime percentage.
Peers should respond to Ping with a Pong.
func (*Ping) Descriptor
deprecated
func (*Ping) GetSubnetUptimes ¶ added in v1.10.2
func (x *Ping) GetSubnetUptimes() []*SubnetUptime
func (*Ping) ProtoMessage ¶
func (*Ping) ProtoMessage()
func (*Ping) ProtoReflect ¶
func (x *Ping) ProtoReflect() protoreflect.Message
type Pong ¶
type Pong struct { // Deprecated: uptime is now sent in Ping // Uptime percentage on the primary network [0, 100] Uptime uint32 `protobuf:"varint,1,opt,name=uptime,proto3" json:"uptime,omitempty"` // Deprecated: uptime is now sent in Ping // Uptime percentage on subnets SubnetUptimes []*SubnetUptime `protobuf:"bytes,2,rep,name=subnet_uptimes,json=subnetUptimes,proto3" json:"subnet_uptimes,omitempty"` // contains filtered or unexported fields }
Pong is sent in response to a Ping with the perceived uptime of the peer.
func (*Pong) Descriptor
deprecated
func (*Pong) GetSubnetUptimes ¶ added in v1.9.4
func (x *Pong) GetSubnetUptimes() []*SubnetUptime
func (*Pong) ProtoMessage ¶
func (*Pong) ProtoMessage()
func (*Pong) ProtoReflect ¶
func (x *Pong) ProtoReflect() protoreflect.Message
type PullQuery ¶
type PullQuery struct { // Chain being requested from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Unique identifier for this request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Timeout (ns) for this request Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` // Container id being gossiped ContainerId []byte `protobuf:"bytes,4,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` // Consensus type to handle this message EngineType EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"` // Requesting peer's last accepted height RequestedHeight uint64 `protobuf:"varint,6,opt,name=requested_height,json=requestedHeight,proto3" json:"requested_height,omitempty"` // contains filtered or unexported fields }
PullQuery requests the preferences of a remote peer given a container id.
Remote peers should respond to a PullQuery with a Chits message
func (*PullQuery) Descriptor
deprecated
func (*PullQuery) GetChainId ¶
func (*PullQuery) GetContainerId ¶
func (*PullQuery) GetDeadline ¶
func (*PullQuery) GetEngineType ¶ added in v1.9.6
func (x *PullQuery) GetEngineType() EngineType
func (*PullQuery) GetRequestId ¶
func (*PullQuery) GetRequestedHeight ¶ added in v1.10.12
func (*PullQuery) ProtoMessage ¶
func (*PullQuery) ProtoMessage()
func (*PullQuery) ProtoReflect ¶
func (x *PullQuery) ProtoReflect() protoreflect.Message
type PushQuery ¶
type PushQuery struct { // Chain being requested from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Unique identifier for this request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Timeout (ns) for this request Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` // Container being gossiped Container []byte `protobuf:"bytes,4,opt,name=container,proto3" json:"container,omitempty"` // Consensus type to handle this message EngineType EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"` // Requesting peer's last accepted height RequestedHeight uint64 `protobuf:"varint,6,opt,name=requested_height,json=requestedHeight,proto3" json:"requested_height,omitempty"` // contains filtered or unexported fields }
PushQuery requests the preferences of a remote peer given a container.
Remote peers should respond to a PushQuery with a Chits message
func (*PushQuery) Descriptor
deprecated
func (*PushQuery) GetChainId ¶
func (*PushQuery) GetContainer ¶
func (*PushQuery) GetDeadline ¶
func (*PushQuery) GetEngineType ¶ added in v1.9.6
func (x *PushQuery) GetEngineType() EngineType
func (*PushQuery) GetRequestId ¶
func (*PushQuery) GetRequestedHeight ¶ added in v1.10.12
func (*PushQuery) ProtoMessage ¶
func (*PushQuery) ProtoMessage()
func (*PushQuery) ProtoReflect ¶
func (x *PushQuery) ProtoReflect() protoreflect.Message
type Put ¶
type Put struct { // Chain being responded from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Request id of the original Get request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Requested container Container []byte `protobuf:"bytes,3,opt,name=container,proto3" json:"container,omitempty"` // Consensus type to handle this message EngineType EngineType `protobuf:"varint,4,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"` // contains filtered or unexported fields }
Put is sent in response to Get with the requested block.
func (*Put) Descriptor
deprecated
func (*Put) GetChainId ¶
func (*Put) GetContainer ¶
func (*Put) GetEngineType ¶ added in v1.9.6
func (x *Put) GetEngineType() EngineType
func (*Put) GetRequestId ¶
func (*Put) ProtoMessage ¶
func (*Put) ProtoMessage()
func (*Put) ProtoReflect ¶
func (x *Put) ProtoReflect() protoreflect.Message
type StateSummaryFrontier ¶
type StateSummaryFrontier struct { // Chain being responded from ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // Request id of the original GetStateSummaryFrontier request RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // The requested state summary Summary []byte `protobuf:"bytes,3,opt,name=summary,proto3" json:"summary,omitempty"` // contains filtered or unexported fields }
StateSummaryFrontier is sent in response to a GetStateSummaryFrontier request
func (*StateSummaryFrontier) Descriptor
deprecated
func (*StateSummaryFrontier) Descriptor() ([]byte, []int)
Deprecated: Use StateSummaryFrontier.ProtoReflect.Descriptor instead.
func (*StateSummaryFrontier) GetChainId ¶
func (x *StateSummaryFrontier) GetChainId() []byte
func (*StateSummaryFrontier) GetRequestId ¶
func (x *StateSummaryFrontier) GetRequestId() uint32
func (*StateSummaryFrontier) GetSummary ¶
func (x *StateSummaryFrontier) GetSummary() []byte
func (*StateSummaryFrontier) ProtoMessage ¶
func (*StateSummaryFrontier) ProtoMessage()
func (*StateSummaryFrontier) ProtoReflect ¶
func (x *StateSummaryFrontier) ProtoReflect() protoreflect.Message
func (*StateSummaryFrontier) Reset ¶
func (x *StateSummaryFrontier) Reset()
func (*StateSummaryFrontier) String ¶
func (x *StateSummaryFrontier) String() string
type SubnetUptime ¶ added in v1.9.4
type SubnetUptime struct { // Subnet the peer is validating SubnetId []byte `protobuf:"bytes,1,opt,name=subnet_id,json=subnetId,proto3" json:"subnet_id,omitempty"` // Uptime percentage on the subnet [0, 100] Uptime uint32 `protobuf:"varint,2,opt,name=uptime,proto3" json:"uptime,omitempty"` // contains filtered or unexported fields }
SubnetUptime is a descriptor for a peer's perceived uptime on a subnet.
func (*SubnetUptime) Descriptor
deprecated
added in
v1.9.4
func (*SubnetUptime) Descriptor() ([]byte, []int)
Deprecated: Use SubnetUptime.ProtoReflect.Descriptor instead.
func (*SubnetUptime) GetSubnetId ¶ added in v1.9.4
func (x *SubnetUptime) GetSubnetId() []byte
func (*SubnetUptime) GetUptime ¶ added in v1.9.4
func (x *SubnetUptime) GetUptime() uint32
func (*SubnetUptime) ProtoMessage ¶ added in v1.9.4
func (*SubnetUptime) ProtoMessage()
func (*SubnetUptime) ProtoReflect ¶ added in v1.9.4
func (x *SubnetUptime) ProtoReflect() protoreflect.Message
func (*SubnetUptime) Reset ¶ added in v1.9.4
func (x *SubnetUptime) Reset()
func (*SubnetUptime) String ¶ added in v1.9.4
func (x *SubnetUptime) String() string