p2p

package
v1.9.0-rc.9 Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2022 License: BSD-3-Clause Imports: 4 Imported by: 19

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Accepted.ProtoReflect.Descriptor instead.

func (*Accepted) GetChainId 

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

func (*Accepted) GetContainerIds 

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

func (*Accepted) GetRequestId 

func (x *Accepted) GetRequestId() uint32

func (*Accepted) ProtoMessage 

func (*Accepted) ProtoMessage()

func (*Accepted) ProtoReflect 

func (x *Accepted) ProtoReflect() protoreflect.Message

func (*Accepted) Reset 

func (x *Accepted) Reset()

func (*Accepted) String 

func (x *Accepted) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Ancestors.ProtoReflect.Descriptor instead.

func (*Ancestors) GetChainId 

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

func (*Ancestors) GetContainers 

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

func (*Ancestors) GetRequestId 

func (x *Ancestors) GetRequestId() uint32

func (*Ancestors) ProtoMessage 

func (*Ancestors) ProtoMessage()

func (*Ancestors) ProtoReflect 

func (x *Ancestors) ProtoReflect() protoreflect.Message

func (*Ancestors) Reset 

func (x *Ancestors) Reset()

func (*Ancestors) String 

func (x *Ancestors) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use AppGossip.ProtoReflect.Descriptor instead.

func (*AppGossip) GetAppBytes 

func (x *AppGossip) GetAppBytes() []byte

func (*AppGossip) GetChainId 

func (x *AppGossip) GetChainId() []byte

func (*AppGossip) ProtoMessage 

func (*AppGossip) ProtoMessage()

func (*AppGossip) ProtoReflect 

func (x *AppGossip) ProtoReflect() protoreflect.Message

func (*AppGossip) Reset 

func (x *AppGossip) Reset()

func (*AppGossip) String 

func (x *AppGossip) String() string

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"`
	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 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) Descriptor() ([]byte, []int)

Deprecated: Use Chits.ProtoReflect.Descriptor instead.

func (*Chits) GetChainId 

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

func (*Chits) GetContainerIds 

func (x *Chits) GetContainerIds() [][]byte

func (*Chits) GetRequestId 

func (x *Chits) GetRequestId() uint32

func (*Chits) ProtoMessage 

func (*Chits) ProtoMessage()

func (*Chits) ProtoReflect 

func (x *Chits) ProtoReflect() protoreflect.Message

func (*Chits) Reset 

func (x *Chits) Reset()

func (*Chits) String 

func (x *Chits) String() string

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"`
	// contains filtered or unexported fields
}

ref. https://pkg.go.dev/github.com/ava-labs/avalanchego/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) 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 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"`
	// 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) Descriptor() ([]byte, []int)

Deprecated: Use Get.ProtoReflect.Descriptor instead.

func (*Get) GetChainId 

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

func (*Get) GetContainerId 

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

func (*Get) GetDeadline 

func (x *Get) GetDeadline() uint64

func (*Get) GetRequestId 

func (x *Get) GetRequestId() uint32

func (*Get) ProtoMessage 

func (*Get) ProtoMessage()

func (*Get) ProtoReflect 

func (x *Get) ProtoReflect() protoreflect.Message

func (*Get) Reset 

func (x *Get) Reset()

func (*Get) String 

func (x *Get) String() string

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"`
	// 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) 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"`
	// 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) 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"`
	// 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) 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 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) Descriptor() ([]byte, []int)

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetAcceptedFrontier_ 

func (x *Message) GetAcceptedFrontier_() *AcceptedFrontier

func (*Message) GetAcceptedStateSummary_ 

func (x *Message) GetAcceptedStateSummary_() *AcceptedStateSummary

func (*Message) GetAccepted_ 

func (x *Message) GetAccepted_() *Accepted

func (*Message) GetAncestors_ 

func (x *Message) GetAncestors_() *Ancestors

func (*Message) GetAppGossip 

func (x *Message) GetAppGossip() *AppGossip

func (*Message) GetAppRequest 

func (x *Message) GetAppRequest() *AppRequest

func (*Message) GetAppResponse 

func (x *Message) GetAppResponse() *AppResponse

func (*Message) GetChits 

func (x *Message) GetChits() *Chits

func (*Message) GetCompressedGzip 

func (x *Message) GetCompressedGzip() []byte

func (*Message) GetGet 

func (x *Message) GetGet() *Get

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 (x *Message) GetPeerList() *PeerList

func (*Message) GetPing 

func (x *Message) GetPing() *Ping

func (*Message) GetPong 

func (x *Message) GetPong() *Pong

func (*Message) GetPullQuery 

func (x *Message) GetPullQuery() *PullQuery

func (*Message) GetPushQuery 

func (x *Message) GetPushQuery() *PushQuery

func (*Message) GetPut 

func (x *Message) GetPut() *Put

func (*Message) GetStateSummaryFrontier_ 

func (x *Message) GetStateSummaryFrontier_() *StateSummaryFrontier

func (*Message) GetVersion 

func (x *Message) GetVersion() *Version

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

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_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 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) Descriptor() ([]byte, []int)

Deprecated: Use PeerList.ProtoReflect.Descriptor instead.

func (*PeerList) GetClaimedIpPorts 

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

func (*PeerList) ProtoMessage 

func (*PeerList) ProtoMessage()

func (*PeerList) ProtoReflect 

func (x *PeerList) ProtoReflect() protoreflect.Message

func (*PeerList) Reset 

func (x *PeerList) Reset()

func (*PeerList) String 

func (x *PeerList) 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) Descriptor() ([]byte, []int)

Deprecated: Use Ping.ProtoReflect.Descriptor instead.

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) ProtoReflect 

func (x *Ping) ProtoReflect() protoreflect.Message

func (*Ping) Reset 

func (x *Ping) Reset()

func (*Ping) String 

func (x *Ping) String() string

type Pong 

type Pong struct {
	UptimePct uint32 `protobuf:"varint,1,opt,name=uptime_pct,json=uptimePct,proto3" json:"uptime_pct,omitempty"`
	// contains filtered or unexported fields
}

Contains the uptime of the message receiver (remote peer) from the sender's point of view, in response to "ping" message.

func (*Pong) Descriptor deprecated 

func (*Pong) Descriptor() ([]byte, []int)

Deprecated: Use Pong.ProtoReflect.Descriptor instead.

func (*Pong) GetUptimePct 

func (x *Pong) GetUptimePct() uint32

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) ProtoReflect 

func (x *Pong) ProtoReflect() protoreflect.Message

func (*Pong) Reset 

func (x *Pong) Reset()

func (*Pong) String 

func (x *Pong) String() string

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"`
	// 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) Descriptor() ([]byte, []int)

Deprecated: Use PullQuery.ProtoReflect.Descriptor instead.

func (*PullQuery) GetChainId 

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

func (*PullQuery) GetContainerId 

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

func (*PullQuery) GetDeadline 

func (x *PullQuery) GetDeadline() uint64

func (*PullQuery) GetRequestId 

func (x *PullQuery) GetRequestId() uint32

func (*PullQuery) ProtoMessage 

func (*PullQuery) ProtoMessage()

func (*PullQuery) ProtoReflect 

func (x *PullQuery) ProtoReflect() protoreflect.Message

func (*PullQuery) Reset 

func (x *PullQuery) Reset()

func (*PullQuery) String 

func (x *PullQuery) String() string

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"`
	// 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) Descriptor() ([]byte, []int)

Deprecated: Use PushQuery.ProtoReflect.Descriptor instead.

func (*PushQuery) GetChainId 

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

func (*PushQuery) GetContainer 

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

func (*PushQuery) GetDeadline 

func (x *PushQuery) GetDeadline() uint64

func (*PushQuery) GetRequestId 

func (x *PushQuery) GetRequestId() uint32

func (*PushQuery) ProtoMessage 

func (*PushQuery) ProtoMessage()

func (*PushQuery) ProtoReflect 

func (x *PushQuery) ProtoReflect() protoreflect.Message

func (*PushQuery) Reset 

func (x *PushQuery) Reset()

func (*PushQuery) String 

func (x *PushQuery) String() string

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"`
	// 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) Descriptor() ([]byte, []int)

Deprecated: Use Put.ProtoReflect.Descriptor instead.

func (*Put) GetChainId 

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

func (*Put) GetContainer 

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

func (*Put) GetRequestId 

func (x *Put) GetRequestId() uint32

func (*Put) ProtoMessage 

func (*Put) ProtoMessage()

func (*Put) ProtoReflect 

func (x *Put) ProtoReflect() protoreflect.Message

func (*Put) Reset 

func (x *Put) Reset()

func (*Put) String 

func (x *Put) String() string

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 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/ava-labs/avalanchego/network#Network "Dispatch"

func (*Version) Descriptor deprecated 

func (*Version) Descriptor() ([]byte, []int)

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetIpAddr 

func (x *Version) GetIpAddr() []byte

func (*Version) GetIpPort 

func (x *Version) GetIpPort() uint32

func (*Version) GetMyTime 

func (x *Version) GetMyTime() uint64

func (*Version) GetMyVersion 

func (x *Version) GetMyVersion() string

func (*Version) GetMyVersionTime 

func (x *Version) GetMyVersionTime() uint64

func (*Version) GetNetworkId 

func (x *Version) GetNetworkId() uint32

func (*Version) GetSig 

func (x *Version) GetSig() []byte

func (*Version) GetTrackedSubnets 

func (x *Version) GetTrackedSubnets() [][]byte

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) ProtoReflect 

func (x *Version) ProtoReflect() protoreflect.Message

func (*Version) Reset 

func (x *Version) Reset()

func (*Version) String 

func (x *Version) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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