p2p

package
v1.10.5-rc.0 Latest Latest
Warning

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

Go to latest
Published: Aug 25, 2023 License: BSD-3-Clause Imports: 4 Imported by: 11

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 {
	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"`
	ContainerId []byte `protobuf:"bytes,3,opt,name=container_id,json=containerId,proto3" json:"container_id,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) 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 {
	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"`
	// Represents the current preferred block.
	PreferredId []byte `protobuf:"bytes,3,opt,name=preferred_id,json=preferredId,proto3" json:"preferred_id,omitempty"`
	// Represents the last accepted block.
	AcceptedId []byte `protobuf:"bytes,4,opt,name=accepted_id,json=acceptedId,proto3" json:"accepted_id,omitempty"`
	// contains filtered or unexported fields
}

Message that contains the votes/preferences of the node. It is sent in response to a "push_query" or "pull_query" request.

Upon receiving "chits", the engine will attempt to issue the preferred block into consensus. If the referenced block is not locally available, the engine will respond with a "get" message to fetch the missing block from the remote peer.

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) 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"`
	TxId            []byte `protobuf:"bytes,6,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	// contains filtered or unexported fields
}

ref. https://pkg.go.dev/github.com/MetalBlockchain/metalgo/utils/ips#ClaimedIPPort

func (*ClaimedIpPort) Descriptor deprecated

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

Deprecated: Use ClaimedIpPort.ProtoReflect.Descriptor instead.

func (*ClaimedIpPort) GetIpAddr

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

func (*ClaimedIpPort) GetIpPort

func (x *ClaimedIpPort) GetIpPort() uint32

func (*ClaimedIpPort) GetSignature

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

func (*ClaimedIpPort) GetTimestamp

func (x *ClaimedIpPort) GetTimestamp() uint64

func (*ClaimedIpPort) GetTxId added in v1.9.4

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

func (*ClaimedIpPort) GetX509Certificate

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

func (*ClaimedIpPort) ProtoMessage

func (*ClaimedIpPort) ProtoMessage()

func (*ClaimedIpPort) ProtoReflect

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

func (*ClaimedIpPort) Reset

func (x *ClaimedIpPort) Reset()

func (*ClaimedIpPort) String

func (x *ClaimedIpPort) String() string

type EngineType added in v1.9.6

type EngineType int32
const (
	EngineType_ENGINE_TYPE_UNSPECIFIED EngineType = 0
	EngineType_ENGINE_TYPE_AVALANCHE   EngineType = 1
	EngineType_ENGINE_TYPE_SNOWMAN     EngineType = 2
)

func (EngineType) Descriptor added in v1.9.6

func (EngineType) Descriptor() protoreflect.EnumDescriptor

func (EngineType) Enum added in v1.9.6

func (x EngineType) Enum() *EngineType

func (EngineType) EnumDescriptor deprecated added in v1.9.6

func (EngineType) EnumDescriptor() ([]byte, []int)

Deprecated: Use EngineType.Descriptor instead.

func (EngineType) Number added in v1.9.6

func (x EngineType) Number() protoreflect.EnumNumber

func (EngineType) String added in v1.9.6

func (x EngineType) String() string

func (EngineType) Type added in v1.9.6

type Get

type Get struct {
	ChainId     []byte     `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	RequestId   uint32     `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Deadline    uint64     `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	ContainerId []byte     `protobuf:"bytes,4,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	EngineType  EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"`
	// contains filtered or unexported fields
}

Message that requests for the container data.

On receiving "get", the engine looks up the container from the storage. If the container is found, it sends out the container data in "put" message.

func (*Get) Descriptor deprecated

func (*Get) 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 {
	ChainId      []byte     `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	RequestId    uint32     `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Deadline     uint64     `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	ContainerIds [][]byte   `protobuf:"bytes,4,rep,name=container_ids,json=containerIds,proto3" json:"container_ids,omitempty"`
	EngineType   EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"`
	// contains filtered or unexported fields
}

Message to request for the accepted blocks/vertices of the "remote" peer. The local node sends out this message during bootstrap, following "get_accepted_frontier". Basically, sending the list of the accepted frontier and expects the response of the accepted IDs from the remote peer.

See "metalgo/snow/engine/common/bootstrapper.Startup" and "sendGetAccepted". See "snow/engine/common/bootstrapper.go#AcceptedFrontier".

func (*GetAccepted) Descriptor deprecated

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

Deprecated: Use GetAccepted.ProtoReflect.Descriptor instead.

func (*GetAccepted) GetChainId

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

func (*GetAccepted) GetContainerIds

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

func (*GetAccepted) GetDeadline

func (x *GetAccepted) GetDeadline() uint64

func (*GetAccepted) GetEngineType added in v1.9.6

func (x *GetAccepted) GetEngineType() EngineType

func (*GetAccepted) GetRequestId

func (x *GetAccepted) GetRequestId() uint32

func (*GetAccepted) ProtoMessage

func (*GetAccepted) ProtoMessage()

func (*GetAccepted) ProtoReflect

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

func (*GetAccepted) Reset

func (x *GetAccepted) Reset()

func (*GetAccepted) String

func (x *GetAccepted) String() string

type GetAcceptedFrontier

type GetAcceptedFrontier struct {
	ChainId    []byte     `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	RequestId  uint32     `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Deadline   uint64     `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	EngineType EngineType `protobuf:"varint,4,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"`
	// contains filtered or unexported fields
}

Message to request for the accepted frontier of the "remote" peer. For instance, the accepted frontier of X-chain DAG is the set of accepted vertices that do not have any accepted descendants (i.e., frontier).

During bootstrap, the local node sends out "get_accepted_frontier" to validators (see "metalgo/snow/engine/common/bootstrapper.Startup"). And the expected response is "accepted_frontier".

See "snow/engine/common/bootstrapper.go#AcceptedFrontier".

func (*GetAcceptedFrontier) Descriptor deprecated

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

Deprecated: Use GetAcceptedFrontier.ProtoReflect.Descriptor instead.

func (*GetAcceptedFrontier) GetChainId

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

func (*GetAcceptedFrontier) GetDeadline

func (x *GetAcceptedFrontier) GetDeadline() uint64

func (*GetAcceptedFrontier) GetEngineType added in v1.9.6

func (x *GetAcceptedFrontier) GetEngineType() EngineType

func (*GetAcceptedFrontier) GetRequestId

func (x *GetAcceptedFrontier) GetRequestId() uint32

func (*GetAcceptedFrontier) ProtoMessage

func (*GetAcceptedFrontier) ProtoMessage()

func (*GetAcceptedFrontier) ProtoReflect

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

func (*GetAcceptedFrontier) Reset

func (x *GetAcceptedFrontier) Reset()

func (*GetAcceptedFrontier) String

func (x *GetAcceptedFrontier) String() string

type GetAcceptedStateSummary

type GetAcceptedStateSummary struct {
	ChainId   []byte   `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	RequestId uint32   `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Deadline  uint64   `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	Heights   []uint64 `protobuf:"varint,4,rep,packed,name=heights,proto3" json:"heights,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAcceptedStateSummary) Descriptor deprecated

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

Deprecated: Use GetAcceptedStateSummary.ProtoReflect.Descriptor instead.

func (*GetAcceptedStateSummary) GetChainId

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

func (*GetAcceptedStateSummary) GetDeadline

func (x *GetAcceptedStateSummary) GetDeadline() uint64

func (*GetAcceptedStateSummary) GetHeights

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

func (*GetAcceptedStateSummary) GetRequestId

func (x *GetAcceptedStateSummary) GetRequestId() uint32

func (*GetAcceptedStateSummary) ProtoMessage

func (*GetAcceptedStateSummary) ProtoMessage()

func (*GetAcceptedStateSummary) ProtoReflect

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

func (*GetAcceptedStateSummary) Reset

func (x *GetAcceptedStateSummary) Reset()

func (*GetAcceptedStateSummary) String

func (x *GetAcceptedStateSummary) String() string

type GetAncestors

type GetAncestors struct {
	ChainId     []byte     `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	RequestId   uint32     `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Deadline    uint64     `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	ContainerId []byte     `protobuf:"bytes,4,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	EngineType  EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"`
	// contains filtered or unexported fields
}

Message that requests for the ancestors (parents) of the specified container ID. The engine bootstrapper sends this message to fetch all accepted containers in its transitive path.

On receiving "get_ancestors", it responds with the ancestors' container bytes in "ancestors" message.

func (*GetAncestors) Descriptor deprecated

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

Deprecated: Use GetAncestors.ProtoReflect.Descriptor instead.

func (*GetAncestors) GetChainId

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

func (*GetAncestors) GetContainerId

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

func (*GetAncestors) GetDeadline

func (x *GetAncestors) GetDeadline() uint64

func (*GetAncestors) GetEngineType added in v1.9.6

func (x *GetAncestors) GetEngineType() EngineType

func (*GetAncestors) GetRequestId

func (x *GetAncestors) GetRequestId() uint32

func (*GetAncestors) ProtoMessage

func (*GetAncestors) ProtoMessage()

func (*GetAncestors) ProtoReflect

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

func (*GetAncestors) Reset

func (x *GetAncestors) Reset()

func (*GetAncestors) String

func (x *GetAncestors) String() string

type GetStateSummaryFrontier

type GetStateSummaryFrontier struct {
	ChainId   []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Deadline  uint64 `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStateSummaryFrontier) Descriptor deprecated

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

Deprecated: Use GetStateSummaryFrontier.ProtoReflect.Descriptor instead.

func (*GetStateSummaryFrontier) GetChainId

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

func (*GetStateSummaryFrontier) GetDeadline

func (x *GetStateSummaryFrontier) GetDeadline() uint64

func (*GetStateSummaryFrontier) GetRequestId

func (x *GetStateSummaryFrontier) GetRequestId() uint32

func (*GetStateSummaryFrontier) ProtoMessage

func (*GetStateSummaryFrontier) ProtoMessage()

func (*GetStateSummaryFrontier) ProtoReflect

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

func (*GetStateSummaryFrontier) Reset

func (x *GetStateSummaryFrontier) Reset()

func (*GetStateSummaryFrontier) String

func (x *GetStateSummaryFrontier) String() string

type Message

type Message struct {

	// NOTES
	// Use "oneof" for each message type and set rest to null if not used.
	// That is because when the compression is enabled, we don't want to include uncompressed fields.
	//
	// Types that are assignable to Message:
	//
	//	*Message_CompressedGzip
	//	*Message_CompressedZstd
	//	*Message_Ping
	//	*Message_Pong
	//	*Message_Version
	//	*Message_PeerList
	//	*Message_GetStateSummaryFrontier
	//	*Message_StateSummaryFrontier_
	//	*Message_GetAcceptedStateSummary
	//	*Message_AcceptedStateSummary_
	//	*Message_GetAcceptedFrontier
	//	*Message_AcceptedFrontier_
	//	*Message_GetAccepted
	//	*Message_Accepted_
	//	*Message_GetAncestors
	//	*Message_Ancestors_
	//	*Message_Get
	//	*Message_Put
	//	*Message_PushQuery
	//	*Message_PullQuery
	//	*Message_Chits
	//	*Message_AppRequest
	//	*Message_AppResponse
	//	*Message_AppGossip
	//	*Message_PeerListAck
	Message isMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Represents peer-to-peer messages. Only one type can be non-null.

func (*Message) Descriptor deprecated

func (*Message) 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) 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) 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) GetPeerListAck added in v1.9.4

func (x *Message) GetPeerListAck() *PeerListAck

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_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_GetStateSummaryFrontier

type Message_GetStateSummaryFrontier struct {
	// State-sync messages:
	GetStateSummaryFrontier *GetStateSummaryFrontier `protobuf:"bytes,15,opt,name=get_state_summary_frontier,json=getStateSummaryFrontier,proto3,oneof"`
}

type Message_PeerList

type Message_PeerList struct {
	PeerList *PeerList `protobuf:"bytes,14,opt,name=peer_list,json=peerList,proto3,oneof"`
}

type Message_PeerListAck added in v1.9.4

type Message_PeerListAck struct {
	PeerListAck *PeerListAck `protobuf:"bytes,33,opt,name=peer_list_ack,json=peerListAck,proto3,oneof"`
}

type Message_Ping

type Message_Ping struct {
	// Network messages:
	Ping *Ping `protobuf:"bytes,11,opt,name=ping,proto3,oneof"`
}

type Message_Pong

type Message_Pong struct {
	Pong *Pong `protobuf:"bytes,12,opt,name=pong,proto3,oneof"`
}

type Message_PullQuery

type Message_PullQuery struct {
	PullQuery *PullQuery `protobuf:"bytes,28,opt,name=pull_query,json=pullQuery,proto3,oneof"`
}

type Message_PushQuery

type Message_PushQuery struct {
	PushQuery *PushQuery `protobuf:"bytes,27,opt,name=push_query,json=pushQuery,proto3,oneof"`
}

type Message_Put

type Message_Put struct {
	Put *Put `protobuf:"bytes,26,opt,name=put,proto3,oneof"`
}

type Message_StateSummaryFrontier_

type Message_StateSummaryFrontier_ struct {
	StateSummaryFrontier_ *StateSummaryFrontier `protobuf:"bytes,16,opt,name=state_summary_frontier,json=stateSummaryFrontier,proto3,oneof"`
}

type Message_Version

type Message_Version struct {
	Version *Version `protobuf:"bytes,13,opt,name=version,proto3,oneof"`
}

type PeerAck added in v1.9.5

type PeerAck struct {
	TxId      []byte `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

"peer_ack" is sent in response to a "peer_list" message. The "tx_id" should correspond to a "tx_id" in the "peer_list" message. The sender should set "timestamp" to be the latest known timestamp of a signed IP corresponding to the nodeID of "tx_id".

Upon receipt, the "tx_id" and "timestamp" will determine if the receiptent can forgo future gossip of the node's IP to the sender of this message.

func (*PeerAck) Descriptor deprecated added in v1.9.5

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

Deprecated: Use PeerAck.ProtoReflect.Descriptor instead.

func (*PeerAck) GetTimestamp added in v1.9.5

func (x *PeerAck) GetTimestamp() uint64

func (*PeerAck) GetTxId added in v1.9.5

func (x *PeerAck) GetTxId() []byte

func (*PeerAck) ProtoMessage added in v1.9.5

func (*PeerAck) ProtoMessage()

func (*PeerAck) ProtoReflect added in v1.9.5

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

func (*PeerAck) Reset added in v1.9.5

func (x *PeerAck) Reset()

func (*PeerAck) String added in v1.9.5

func (x *PeerAck) String() string

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. "metalgo/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 PeerListAck added in v1.9.4

type PeerListAck struct {
	PeerAcks []*PeerAck `protobuf:"bytes,2,rep,name=peer_acks,json=peerAcks,proto3" json:"peer_acks,omitempty"`
	// contains filtered or unexported fields
}

Message that responds to a peer_list message containing the AddValidatorTxIDs from the peer_list message that we currently have in our validator set.

func (*PeerListAck) Descriptor deprecated added in v1.9.4

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

Deprecated: Use PeerListAck.ProtoReflect.Descriptor instead.

func (*PeerListAck) GetPeerAcks added in v1.9.5

func (x *PeerListAck) GetPeerAcks() []*PeerAck

func (*PeerListAck) ProtoMessage added in v1.9.4

func (*PeerListAck) ProtoMessage()

func (*PeerListAck) ProtoReflect added in v1.9.4

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

func (*PeerListAck) Reset added in v1.9.4

func (x *PeerListAck) Reset()

func (*PeerListAck) String added in v1.9.4

func (x *PeerListAck) String() string

type Ping

type Ping struct {

	// uptime is the primary network uptime percentage.
	Uptime uint32 `protobuf:"varint,1,opt,name=uptime,proto3" json:"uptime,omitempty"`
	// subnet_uptimes contains subnet uptime percentages.
	SubnetUptimes []*SubnetUptime `protobuf:"bytes,2,rep,name=subnet_uptimes,json=subnetUptimes,proto3" json:"subnet_uptimes,omitempty"`
	// contains filtered or unexported fields
}

Message that a node sends to its peers in order to periodically check responsivness and report the local node's uptime measurements of the peer.

On receiving a "ping", the peer should respond 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: remove all these fields in the future, but keep the message.
	// uptime is the primary network uptime percentage.
	Uptime uint32 `protobuf:"varint,1,opt,name=uptime,proto3" json:"uptime,omitempty"`
	// subnet_uptimes contains subnet uptime percentages.
	SubnetUptimes []*SubnetUptime `protobuf:"bytes,2,rep,name=subnet_uptimes,json=subnetUptimes,proto3" json:"subnet_uptimes,omitempty"`
	// contains filtered or unexported fields
}

Contains the uptime percentage of the message receiver (remote peer) from the sender's point of view, in response to "ping" message. Uptimes are expected to be provided as integers ranging in [0, 100].

func (*Pong) Descriptor deprecated

func (*Pong) 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 {
	ChainId     []byte     `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	RequestId   uint32     `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Deadline    uint64     `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	ContainerId []byte     `protobuf:"bytes,4,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	EngineType  EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"`
	// contains filtered or unexported fields
}

Message that contains a preferred container ID to query other peers for their preferences of the container. For example, when a new container is issued, the engine sends out "push_query" and "pull_query" queries to ask other peers their preferences. See "metalgo/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) GetEngineType added in v1.9.6

func (x *PullQuery) GetEngineType() EngineType

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"`
	EngineType EngineType `protobuf:"varint,5,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"`
	// contains filtered or unexported fields
}

Message that contains a preferred container ID and its container bytes in order to query other peers for their preferences of the container. For example, when a new container is issued, the engine sends out "push_query" and "pull_query" queries to ask other peers their preferences. See "metalgo/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) GetEngineType added in v1.9.6

func (x *PushQuery) GetEngineType() EngineType

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"`
	EngineType EngineType `protobuf:"varint,4,opt,name=engine_type,json=engineType,proto3,enum=p2p.EngineType" json:"engine_type,omitempty"`
	// contains filtered or unexported fields
}

Message that contains the container ID and its bytes in response to "get".

On receiving "put", the engine parses the container and tries to issue it to consensus.

func (*Put) Descriptor deprecated

func (*Put) 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 {
	ChainId   []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Summary   []byte `protobuf:"bytes,3,opt,name=summary,proto3" json:"summary,omitempty"`
	// contains filtered or unexported fields
}

func (*StateSummaryFrontier) Descriptor deprecated

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

Deprecated: Use StateSummaryFrontier.ProtoReflect.Descriptor instead.

func (*StateSummaryFrontier) GetChainId

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

func (*StateSummaryFrontier) GetRequestId

func (x *StateSummaryFrontier) GetRequestId() uint32

func (*StateSummaryFrontier) GetSummary

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

func (*StateSummaryFrontier) ProtoMessage

func (*StateSummaryFrontier) ProtoMessage()

func (*StateSummaryFrontier) ProtoReflect

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

func (*StateSummaryFrontier) Reset

func (x *StateSummaryFrontier) Reset()

func (*StateSummaryFrontier) String

func (x *StateSummaryFrontier) String() string

type SubnetUptime added in v1.9.4

type SubnetUptime struct {
	SubnetId []byte `protobuf:"bytes,1,opt,name=subnet_id,json=subnetId,proto3" json:"subnet_id,omitempty"`
	Uptime   uint32 `protobuf:"varint,2,opt,name=uptime,proto3" json:"uptime,omitempty"`
	// contains filtered or unexported fields
}

Contains subnet id and the related observed subnet uptime of the message receiver (remote peer).

func (*SubnetUptime) Descriptor deprecated added in v1.9.4

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

Deprecated: Use SubnetUptime.ProtoReflect.Descriptor instead.

func (*SubnetUptime) GetSubnetId added in v1.9.4

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

func (*SubnetUptime) GetUptime added in v1.9.4

func (x *SubnetUptime) GetUptime() uint32

func (*SubnetUptime) ProtoMessage added in v1.9.4

func (*SubnetUptime) ProtoMessage()

func (*SubnetUptime) ProtoReflect added in v1.9.4

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

func (*SubnetUptime) Reset added in v1.9.4

func (x *SubnetUptime) Reset()

func (*SubnetUptime) String added in v1.9.4

func (x *SubnetUptime) String() string

type Version

type Version struct {
	NetworkId      uint32   `protobuf:"varint,1,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
	MyTime         uint64   `protobuf:"varint,2,opt,name=my_time,json=myTime,proto3" json:"my_time,omitempty"`
	IpAddr         []byte   `protobuf:"bytes,3,opt,name=ip_addr,json=ipAddr,proto3" json:"ip_addr,omitempty"`
	IpPort         uint32   `protobuf:"varint,4,opt,name=ip_port,json=ipPort,proto3" json:"ip_port,omitempty"`
	MyVersion      string   `protobuf:"bytes,5,opt,name=my_version,json=myVersion,proto3" json:"my_version,omitempty"`
	MyVersionTime  uint64   `protobuf:"varint,6,opt,name=my_version_time,json=myVersionTime,proto3" json:"my_version_time,omitempty"`
	Sig            []byte   `protobuf:"bytes,7,opt,name=sig,proto3" json:"sig,omitempty"`
	TrackedSubnets [][]byte `protobuf:"bytes,8,rep,name=tracked_subnets,json=trackedSubnets,proto3" json:"tracked_subnets,omitempty"`
	// contains filtered or unexported fields
}

The first outbound message that the local node sends to its remote peer when the connection is established. In order for the local node to be tracked as a valid peer by the remote peer, the fields must be valid. For instance, the network ID must be matched and timestamp should be in-sync. Otherwise, the remote peer closes the connection. ref. "metalgo/network/peer#handleVersion" ref. https://pkg.go.dev/github.com/MetalBlockchain/metalgo/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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL