p2p

package
v1.11.1-rc.3 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2024 License: BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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) 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 {

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

Deprecated: Use AppError.ProtoReflect.Descriptor instead.

func (*AppError) GetChainId added in v1.10.16 

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

func (*AppError) GetErrorCode added in v1.10.16 

func (x *AppError) GetErrorCode() int32

func (*AppError) GetErrorMessage added in v1.10.16 

func (x *AppError) GetErrorMessage() string

func (*AppError) GetRequestId added in v1.10.16 

func (x *AppError) GetRequestId() uint32

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

func (*AppError) Reset added in v1.10.16 

func (x *AppError) Reset()

func (*AppError) String added in v1.10.16 

func (x *AppError) String() string

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) 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 {

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

Deprecated: Use Chits.ProtoReflect.Descriptor instead.

func (*Chits) GetAcceptedId added in v1.10.3 

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

func (*Chits) GetChainId 

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

func (*Chits) GetPreferredId added in v1.10.3 

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

func (*Chits) GetPreferredIdAtHeight added in v1.10.13 

func (x *Chits) GetPreferredIdAtHeight() []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 {

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

Deprecated: Use Client.ProtoReflect.Descriptor instead.

func (*Client) GetMajor added in v1.10.18 

func (x *Client) GetMajor() uint32

func (*Client) GetMinor added in v1.10.18 

func (x *Client) GetMinor() uint32

func (*Client) GetName added in v1.10.18 

func (x *Client) GetName() string

func (*Client) GetPatch added in v1.10.18 

func (x *Client) GetPatch() uint32

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

func (*Client) Reset added in v1.10.18 

func (x *Client) Reset()

func (*Client) String added in v1.10.18 

func (x *Client) String() string

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) 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) GetEngineType added in v1.9.6 

func (x *Get) GetEngineType() EngineType

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 {

	// 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 with the TLS
	// key.
	IpNodeIdSig []byte `protobuf:"bytes,7,opt,name=ip_node_id_sig,json=ipNodeIdSig,proto3" json:"ip_node_id_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"`
	// Signature of the peer IP port pair at a provided timestamp with the BLS
	// key.
	IpBlsSig []byte `protobuf:"bytes,13,opt,name=ip_bls_sig,json=ipBlsSig,proto3" json:"ip_bls_sig,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) Descriptor() ([]byte, []int)

Deprecated: Use Handshake.ProtoReflect.Descriptor instead.

func (*Handshake) GetClient added in v1.10.18 

func (x *Handshake) GetClient() *Client

func (*Handshake) GetIpAddr added in v1.10.18 

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

func (*Handshake) GetIpBlsSig added in v1.11.1 

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

func (*Handshake) GetIpNodeIdSig added in v1.11.1 

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

func (*Handshake) GetIpPort added in v1.10.18 

func (x *Handshake) GetIpPort() uint32

func (*Handshake) GetIpSigningTime added in v1.10.18 

func (x *Handshake) GetIpSigningTime() uint64

func (*Handshake) GetKnownPeers added in v1.10.18 

func (x *Handshake) GetKnownPeers() *BloomFilter

func (*Handshake) GetMyTime added in v1.10.18 

func (x *Handshake) GetMyTime() uint64

func (*Handshake) GetMyVersion added in v1.10.18 

func (x *Handshake) GetMyVersion() string

func (*Handshake) GetNetworkId added in v1.10.18 

func (x *Handshake) GetNetworkId() uint32

func (*Handshake) GetObjectedAcps added in v1.10.18 

func (x *Handshake) GetObjectedAcps() []uint32

func (*Handshake) GetSupportedAcps added in v1.10.18 

func (x *Handshake) GetSupportedAcps() []uint32

func (*Handshake) GetTrackedSubnets added in v1.10.18 

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

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

func (*Handshake) Reset added in v1.10.18 

func (x *Handshake) Reset()

func (*Handshake) String added in v1.10.18 

func (x *Handshake) 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_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) 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) GetAppError added in v1.10.16 

func (x *Message) GetAppError() *AppError

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) GetCompressedZstd added in v1.10.0 

func (x *Message) GetCompressedZstd() []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) 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 (x *Message) GetHandshake() *Handshake

func (*Message) GetMessage 

func (m *Message) GetMessage() isMessage_Message

func (*Message) GetPeerList_ added in v1.10.18 

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) 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_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) 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 {

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

Deprecated: Use Ping.ProtoReflect.Descriptor instead.

func (*Ping) GetSubnetUptimes added in v1.10.2 

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

func (*Ping) GetUptime added in v1.10.2 

func (x *Ping) GetUptime() uint32

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 {

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

Deprecated: Use Pong.ProtoReflect.Descriptor instead.

func (*Pong) GetSubnetUptimes added in v1.9.4 

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

func (*Pong) GetUptime added in v1.9.4 

func (x *Pong) GetUptime() 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 {

	// 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) 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) GetEngineType added in v1.9.6 

func (x *PullQuery) GetEngineType() EngineType

func (*PullQuery) GetRequestId 

func (x *PullQuery) GetRequestId() uint32

func (*PullQuery) GetRequestedHeight added in v1.10.13 

func (x *PullQuery) GetRequestedHeight() uint64

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 {

	// 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) 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) GetEngineType added in v1.9.6 

func (x *PushQuery) GetEngineType() EngineType

func (*PushQuery) GetRequestId 

func (x *PushQuery) GetRequestId() uint32

func (*PushQuery) GetRequestedHeight added in v1.10.13 

func (x *PushQuery) GetRequestedHeight() uint64

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 {

	// 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) 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) GetEngineType added in v1.9.6 

func (x *Put) GetEngineType() EngineType

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 {

	// 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

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.