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) GetContainerIds() [][]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 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 Chits
- func (*Chits) Descriptor() ([]byte, []int)deprecated
- func (x *Chits) GetAcceptedContainerIds() [][]byte
- func (x *Chits) GetChainId() []byte
- func (x *Chits) GetPreferredContainerIds() [][]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 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 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 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) 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) 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) GetGetStateSummaryFrontier() *GetStateSummaryFrontier
- func (m *Message) GetMessage() isMessage_Message
- func (x *Message) GetPeerList() *PeerList
- func (x *Message) GetPeerListAck() *PeerListAck
- 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 (x *Message) GetVersion() *Version
- 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_AppGossip
- type Message_AppRequest
- type Message_AppResponse
- type Message_Chits
- type Message_CompressedGzip
- type Message_Get
- type Message_GetAccepted
- type Message_GetAcceptedFrontier
- type Message_GetAcceptedStateSummary
- type Message_GetAncestors
- type Message_GetStateSummaryFrontier
- type Message_PeerList
- type Message_PeerListAck
- type Message_Ping
- type Message_Pong
- type Message_PullQuery
- type Message_PushQuery
- type Message_Put
- type Message_StateSummaryFrontier_
- type Message_Version
- type PeerAck
- type PeerList
- type PeerListAck
- 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 (*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 (*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
- type Version
- func (*Version) Descriptor() ([]byte, []int)deprecated
- func (x *Version) GetIpAddr() []byte
- func (x *Version) GetIpPort() uint32
- func (x *Version) GetMyTime() uint64
- func (x *Version) GetMyVersion() string
- func (x *Version) GetMyVersionTime() uint64
- func (x *Version) GetNetworkId() uint32
- func (x *Version) GetSig() []byte
- func (x *Version) GetTrackedSubnets() [][]byte
- func (*Version) ProtoMessage()
- func (x *Version) ProtoReflect() protoreflect.Message
- func (x *Version) Reset()
- func (x *Version) 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 { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` ContainerIds [][]byte `protobuf:"bytes,3,rep,name=container_ids,json=containerIds,proto3" json:"container_ids,omitempty"` // contains filtered or unexported fields }
Message that contains the list of accepted block/vertex IDs in response to "get_accepted". For instance, on receiving "get_accepted" that contains the sender's accepted frontier IDs, the X-chain engine responds only with the accepted vertex IDs of the X-chain DAG.
See "snow/engine/avalanche#GetAccepted" and "SendAccepted". See "snow/engine/common/bootstrapper.go#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 { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` ContainerIds [][]byte `protobuf:"bytes,3,rep,name=container_ids,json=containerIds,proto3" json:"container_ids,omitempty"` // contains filtered or unexported fields }
Message that contains the list of accepted frontier in response to "get_accepted_frontier". For instance, on receiving "get_accepted_frontier", the X-chain engine responds with the accepted frontier of X-chain DAG.
See "snow/engine/common/bootstrapper.go#AcceptedFrontier".
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) GetContainerIds ¶
func (x *AcceptedFrontier) GetContainerIds() [][]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 { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` SummaryIds [][]byte `protobuf:"bytes,3,rep,name=summary_ids,json=summaryIds,proto3" json:"summary_ids,omitempty"` // contains filtered or unexported fields }
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 { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` Containers [][]byte `protobuf:"bytes,3,rep,name=containers,proto3" json:"containers,omitempty"` // contains filtered or unexported fields }
Message that contains the container bytes of the ancestors in response to "get_ancestors".
On receiving "ancestors", the engine parses the containers and queues them to be accepted once we've received the entire chain history.
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 AppGossip ¶
type AppGossip struct { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` AppBytes []byte `protobuf:"bytes,2,opt,name=app_bytes,json=appBytes,proto3" json:"app_bytes,omitempty"` // contains filtered or unexported fields }
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 { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` AppBytes []byte `protobuf:"bytes,4,opt,name=app_bytes,json=appBytes,proto3" json:"app_bytes,omitempty"` // contains filtered or unexported fields }
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 { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` AppBytes []byte `protobuf:"bytes,3,opt,name=app_bytes,json=appBytes,proto3" json:"app_bytes,omitempty"` // contains filtered or unexported fields }
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 Chits ¶
type Chits struct { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Represents the current preferred frontier. // TODO: Remove `repeated` once all chains are running Snowman. PreferredContainerIds [][]byte `` /* 126-byte string literal not displayed */ // Represents the current accepted frontier. // TODO: Remove `repeated` once all chains are running Snowman. AcceptedContainerIds [][]byte `protobuf:"bytes,4,rep,name=accepted_container_ids,json=acceptedContainerIds,proto3" json:"accepted_container_ids,omitempty"` // contains filtered or unexported fields }
Message that contains the votes/preferences of the local node, in response to "push_query" or "pull_query" (e.g., preferred frontier).
On receiving "chits", the engine issues those preferred containers of vertices/blocks to the consensus. If the received container is not found, it responds back with "get" message to fetch the missing container from the remote peer.
func (*Chits) Descriptor
deprecated
func (*Chits) GetAcceptedContainerIds ¶ added in v1.9.6
func (*Chits) GetChainId ¶
func (*Chits) GetPreferredContainerIds ¶ added in v1.9.6
func (*Chits) GetRequestId ¶
func (*Chits) ProtoMessage ¶
func (*Chits) ProtoMessage()
func (*Chits) ProtoReflect ¶
func (x *Chits) ProtoReflect() protoreflect.Message
type ClaimedIpPort ¶
type ClaimedIpPort struct { X509Certificate []byte `protobuf:"bytes,1,opt,name=x509_certificate,json=x509Certificate,proto3" json:"x509_certificate,omitempty"` IpAddr []byte `protobuf:"bytes,2,opt,name=ip_addr,json=ipAddr,proto3" json:"ip_addr,omitempty"` IpPort uint32 `protobuf:"varint,3,opt,name=ip_port,json=ipPort,proto3" json:"ip_port,omitempty"` Timestamp uint64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Signature []byte `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"` TxId []byte `protobuf:"bytes,6,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` // contains filtered or unexported fields }
ref. https://pkg.go.dev/github.com/MetalBlockchain/metalgo/utils/ips#ClaimedIPPort
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 EngineType ¶ added in v1.9.6
type EngineType int32
const ( EngineType_ENGINE_TYPE_UNSPECIFIED EngineType = 0 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 { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` ContainerId []byte `protobuf:"bytes,4,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` EngineType EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"` // contains filtered or unexported fields }
Message that requests for the container data.
On receiving "get", the engine looks up the container from the storage. If the container is found, it sends out the container data in "put" message.
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 { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` ContainerIds [][]byte `protobuf:"bytes,4,rep,name=container_ids,json=containerIds,proto3" json:"container_ids,omitempty"` EngineType EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"` // contains filtered or unexported fields }
Message to request for the accepted blocks/vertices of the "remote" peer. The local node sends out this message during bootstrap, following "get_accepted_frontier". Basically, sending the list of the accepted frontier and expects the response of the accepted IDs from the remote peer.
See "avalanchego/snow/engine/common/bootstrapper.Startup" and "sendGetAccepted". See "snow/engine/common/bootstrapper.go#AcceptedFrontier".
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 { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` EngineType EngineType `protobuf:"varint,4,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"` // contains filtered or unexported fields }
Message to request for the accepted frontier of the "remote" peer. For instance, the accepted frontier of X-chain DAG is the set of accepted vertices that do not have any accepted descendants (i.e., frontier).
During bootstrap, the local node sends out "get_accepted_frontier" to validators (see "avalanchego/snow/engine/common/bootstrapper.Startup"). And the expected response is "accepted_frontier".
See "snow/engine/common/bootstrapper.go#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 { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` Heights []uint64 `protobuf:"varint,4,rep,packed,name=heights,proto3" json:"heights,omitempty"` // contains filtered or unexported fields }
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 { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` ContainerId []byte `protobuf:"bytes,4,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` EngineType EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"` // contains filtered or unexported fields }
Message that requests for the ancestors (parents) of the specified container ID. The engine bootstrapper sends this message to fetch all accepted containers in its transitive path.
On receiving "get_ancestors", it responds with the ancestors' container bytes in "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 GetStateSummaryFrontier ¶
type GetStateSummaryFrontier struct { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` // contains filtered or unexported fields }
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 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_Ping // *Message_Pong // *Message_Version // *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_PeerListAck 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) GetAppGossip ¶
func (*Message) GetAppRequest ¶
func (x *Message) GetAppRequest() *AppRequest
func (*Message) GetAppResponse ¶
func (x *Message) GetAppResponse() *AppResponse
func (*Message) GetCompressedGzip ¶
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) GetGetStateSummaryFrontier ¶
func (x *Message) GetGetStateSummaryFrontier() *GetStateSummaryFrontier
func (*Message) GetMessage ¶
func (m *Message) GetMessage() isMessage_Message
func (*Message) GetPeerList ¶
func (*Message) GetPeerListAck ¶ added in v1.9.4
func (x *Message) GetPeerListAck() *PeerListAck
func (*Message) GetPullQuery ¶
func (*Message) GetPushQuery ¶
func (*Message) GetStateSummaryFrontier_ ¶
func (x *Message) GetStateSummaryFrontier_() *StateSummaryFrontier
func (*Message) GetVersion ¶
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_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_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_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_PeerList ¶
type Message_PeerList struct {
PeerList *PeerList `protobuf:"bytes,14,opt,name=peer_list,json=peerList,proto3,oneof"`
}
type Message_PeerListAck ¶ added in v1.9.4
type Message_PeerListAck struct {
PeerListAck *PeerListAck `protobuf:"bytes,33,opt,name=peer_list_ack,json=peerListAck,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 Message_Version ¶
type Message_Version struct {
Version *Version `protobuf:"bytes,13,opt,name=version,proto3,oneof"`
}
type PeerAck ¶ added in v1.9.5
type PeerAck struct { TxId []byte `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
"peer_ack" is sent in response to a "peer_list" message. The "tx_id" should correspond to a "tx_id" in the "peer_list" message. The sender should set "timestamp" to be the latest known timestamp of a signed IP corresponding to the nodeID of "tx_id".
Upon receipt, the "tx_id" and "timestamp" will determine if the receiptent can forgo future gossip of the node's IP to the sender of this message.
func (*PeerAck) Descriptor
deprecated
added in
v1.9.5
func (*PeerAck) GetTimestamp ¶ added in v1.9.5
func (*PeerAck) ProtoMessage ¶ added in v1.9.5
func (*PeerAck) ProtoMessage()
func (*PeerAck) ProtoReflect ¶ added in v1.9.5
func (x *PeerAck) ProtoReflect() protoreflect.Message
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 }
Message that contains a list of peer information (IP, certs, etc.) in response to "version" message, and sent periodically to a set of validators. ref. "avalanchego/network/network#Dispatch.runtTimers"
On receiving "peer_list", the engine starts/updates the tracking information of the remote peer.
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 PeerListAck ¶ added in v1.9.4
type PeerListAck struct { PeerAcks []*PeerAck `protobuf:"bytes,2,rep,name=peer_acks,json=peerAcks,proto3" json:"peer_acks,omitempty"` // contains filtered or unexported fields }
Message that responds to a peer_list message containing the AddValidatorTxIDs from the peer_list message that we currently have in our validator set.
func (*PeerListAck) Descriptor
deprecated
added in
v1.9.4
func (*PeerListAck) Descriptor() ([]byte, []int)
Deprecated: Use PeerListAck.ProtoReflect.Descriptor instead.
func (*PeerListAck) GetPeerAcks ¶ added in v1.9.5
func (x *PeerListAck) GetPeerAcks() []*PeerAck
func (*PeerListAck) ProtoMessage ¶ added in v1.9.4
func (*PeerListAck) ProtoMessage()
func (*PeerListAck) ProtoReflect ¶ added in v1.9.4
func (x *PeerListAck) ProtoReflect() protoreflect.Message
func (*PeerListAck) Reset ¶ added in v1.9.4
func (x *PeerListAck) Reset()
func (*PeerListAck) String ¶ added in v1.9.4
func (x *PeerListAck) String() string
type Ping ¶
type Ping struct {
// contains filtered or unexported fields
}
Message that the local node sends to its remote peers, in order to periodically check its uptime.
On receiving "ping", the remote peer responds with the observed uptime value of the message sender in "pong" message.
func (*Ping) Descriptor
deprecated
func (*Ping) ProtoMessage ¶
func (*Ping) ProtoMessage()
func (*Ping) ProtoReflect ¶
func (x *Ping) ProtoReflect() protoreflect.Message
type Pong ¶
type Pong struct { // uptime is the primary network uptime percentage. Uptime uint32 `protobuf:"varint,1,opt,name=uptime,proto3" json:"uptime,omitempty"` // subnet_uptimes contains subnet uptime percentages. SubnetUptimes []*SubnetUptime `protobuf:"bytes,2,rep,name=subnet_uptimes,json=subnetUptimes,proto3" json:"subnet_uptimes,omitempty"` // contains filtered or unexported fields }
Contains the uptime percentage of the message receiver (remote peer) from the sender's point of view, in response to "ping" message. Uptimes are expected to be provided as integers ranging in [0, 100].
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 { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` ContainerId []byte `protobuf:"bytes,4,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` EngineType EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"` // contains filtered or unexported fields }
Message that contains a preferred container ID to query other peers for their preferences of the container. For example, when a new container is issued, the engine sends out "push_query" and "pull_query" queries to ask other peers their preferences. See "avalanchego/snow/engine/common#SendMixedQuery".
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) ProtoMessage ¶
func (*PullQuery) ProtoMessage()
func (*PullQuery) ProtoReflect ¶
func (x *PullQuery) ProtoReflect() protoreflect.Message
type PushQuery ¶
type PushQuery struct { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` Deadline uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"` Container []byte `protobuf:"bytes,4,opt,name=container,proto3" json:"container,omitempty"` EngineType EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"` // contains filtered or unexported fields }
Message that contains a preferred container ID and its container bytes in order to query other peers for their preferences of the container. For example, when a new container is issued, the engine sends out "push_query" and "pull_query" queries to ask other peers their preferences. See "avalanchego/snow/engine/common#SendMixedQuery".
On receiving the "push_query", the engine parses the incoming container and tries to issue the container and all of its parents to the consensus, and calls "pull_query" handler to send "chits" for voting.
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) ProtoMessage ¶
func (*PushQuery) ProtoMessage()
func (*PushQuery) ProtoReflect ¶
func (x *PushQuery) ProtoReflect() protoreflect.Message
type Put ¶
type Put struct { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` Container []byte `protobuf:"bytes,3,opt,name=container,proto3" json:"container,omitempty"` EngineType EngineType `protobuf:"varint,4,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"` // contains filtered or unexported fields }
Message that contains the container ID and its bytes in response to "get".
On receiving "put", the engine parses the container and tries to issue it to consensus.
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 { ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` Summary []byte `protobuf:"bytes,3,opt,name=summary,proto3" json:"summary,omitempty"` // contains filtered or unexported fields }
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 { SubnetId []byte `protobuf:"bytes,1,opt,name=subnet_id,json=subnetId,proto3" json:"subnet_id,omitempty"` Uptime uint32 `protobuf:"varint,2,opt,name=uptime,proto3" json:"uptime,omitempty"` // contains filtered or unexported fields }
Contains subnet id and the related observed subnet uptime of the message receiver (remote peer).
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
type Version ¶
type Version struct { NetworkId uint32 `protobuf:"varint,1,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"` MyTime uint64 `protobuf:"varint,2,opt,name=my_time,json=myTime,proto3" json:"my_time,omitempty"` IpAddr []byte `protobuf:"bytes,3,opt,name=ip_addr,json=ipAddr,proto3" json:"ip_addr,omitempty"` IpPort uint32 `protobuf:"varint,4,opt,name=ip_port,json=ipPort,proto3" json:"ip_port,omitempty"` MyVersion string `protobuf:"bytes,5,opt,name=my_version,json=myVersion,proto3" json:"my_version,omitempty"` MyVersionTime uint64 `protobuf:"varint,6,opt,name=my_version_time,json=myVersionTime,proto3" json:"my_version_time,omitempty"` Sig []byte `protobuf:"bytes,7,opt,name=sig,proto3" json:"sig,omitempty"` TrackedSubnets [][]byte `protobuf:"bytes,8,rep,name=tracked_subnets,json=trackedSubnets,proto3" json:"tracked_subnets,omitempty"` // contains filtered or unexported fields }
The first outbound message that the local node sends to its remote peer when the connection is established. In order for the local node to be tracked as a valid peer by the remote peer, the fields must be valid. For instance, the network ID must be matched and timestamp should be in-sync. Otherwise, the remote peer closes the connection. ref. "avalanchego/network/peer#handleVersion" ref. https://pkg.go.dev/github.com/MetalBlockchain/metalgo/network#Network "Dispatch"
func (*Version) Descriptor
deprecated
func (*Version) GetMyVersion ¶
func (*Version) GetMyVersionTime ¶
func (*Version) GetNetworkId ¶
func (*Version) GetTrackedSubnets ¶
func (*Version) ProtoMessage ¶
func (*Version) ProtoMessage()
func (*Version) ProtoReflect ¶
func (x *Version) ProtoReflect() protoreflect.Message