libp2p

package
v1.0.18 Latest Latest
Warning

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

Go to latest
Published: Dec 2, 2024 License: GPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	EventType_name = map[int32]string{
		0: "UNKNOWN",
		1: "CONNECTED",
		2: "DISCONNECTED",
		3: "ADD_PEER",
		4: "REMOVE_PEER",
		5: "RECV_RPC",
		6: "SEND_RPC",
		7: "JOIN",
		8: "HANDLE_STATUS",
		9: "HANDLE_METADATA",
	}
	EventType_value = map[string]int32{
		"UNKNOWN":         0,
		"CONNECTED":       1,
		"DISCONNECTED":    2,
		"ADD_PEER":        3,
		"REMOVE_PEER":     4,
		"RECV_RPC":        5,
		"SEND_RPC":        6,
		"JOIN":            7,
		"HANDLE_STATUS":   8,
		"HANDLE_METADATA": 9,
	}
)

Enum value maps for EventType.

View Source
var File_pkg_proto_libp2p_eth_proto protoreflect.FileDescriptor
View Source
var File_pkg_proto_libp2p_peer_proto protoreflect.FileDescriptor
View Source
var File_pkg_proto_libp2p_trace_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AddPeer added in v0.0.160

type AddPeer struct {
	PeerId   *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	Protocol *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// contains filtered or unexported fields
}

func TraceEventToAddPeer added in v0.0.160

func TraceEventToAddPeer(event *host.TraceEvent) (*AddPeer, error)

Helper function to convert a Hermes TraceEvent to a libp2p AddPeer

func (*AddPeer) Descriptor deprecated added in v0.0.160

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

Deprecated: Use AddPeer.ProtoReflect.Descriptor instead.

func (*AddPeer) GetPeerId added in v0.0.160

func (x *AddPeer) GetPeerId() *wrapperspb.StringValue

func (*AddPeer) GetProtocol added in v0.0.160

func (x *AddPeer) GetProtocol() *wrapperspb.StringValue

func (*AddPeer) ProtoMessage added in v0.0.160

func (*AddPeer) ProtoMessage()

func (*AddPeer) ProtoReflect added in v0.0.160

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

func (*AddPeer) Reset added in v0.0.160

func (x *AddPeer) Reset()

func (*AddPeer) String added in v0.0.160

func (x *AddPeer) String() string

type Connected added in v0.0.160

type Connected struct {
	RemotePeer   *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=remote_peer,proto3" json:"remote_peer,omitempty"`
	RemoteMaddrs *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=remote_maddrs,proto3" json:"remote_maddrs,omitempty"`
	AgentVersion *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=agent_version,proto3" json:"agent_version,omitempty"`
	Direction    *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=direction,proto3" json:"direction,omitempty"`
	Opened       *timestamppb.Timestamp  `protobuf:"bytes,5,opt,name=opened,proto3" json:"opened,omitempty"`
	// See: https://github.com/probe-lab/hermes/commit/614e34ed0db780ee08c3bc333925a62409096166
	//
	// Deprecated: Marked as deprecated in pkg/proto/libp2p/trace.proto.
	Transient *wrapperspb.BoolValue `protobuf:"bytes,6,opt,name=transient,proto3" json:"transient,omitempty"`
	Limited   *wrapperspb.BoolValue `protobuf:"bytes,7,opt,name=limited,proto3" json:"limited,omitempty"`
	// contains filtered or unexported fields
}

func TraceEventToConnected added in v0.0.160

func TraceEventToConnected(event *host.TraceEvent) (*Connected, error)

func (*Connected) Descriptor deprecated added in v0.0.160

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

Deprecated: Use Connected.ProtoReflect.Descriptor instead.

func (*Connected) GetAgentVersion added in v0.0.160

func (x *Connected) GetAgentVersion() *wrapperspb.StringValue

func (*Connected) GetDirection added in v0.0.160

func (x *Connected) GetDirection() *wrapperspb.StringValue

func (*Connected) GetLimited added in v1.0.16

func (x *Connected) GetLimited() *wrapperspb.BoolValue

func (*Connected) GetOpened added in v0.0.160

func (x *Connected) GetOpened() *timestamppb.Timestamp

func (*Connected) GetRemoteMaddrs added in v0.0.160

func (x *Connected) GetRemoteMaddrs() *wrapperspb.StringValue

func (*Connected) GetRemotePeer added in v0.0.160

func (x *Connected) GetRemotePeer() *wrapperspb.StringValue

func (*Connected) GetTransient deprecated added in v0.0.160

func (x *Connected) GetTransient() *wrapperspb.BoolValue

Deprecated: Marked as deprecated in pkg/proto/libp2p/trace.proto.

func (*Connected) ProtoMessage added in v0.0.160

func (*Connected) ProtoMessage()

func (*Connected) ProtoReflect added in v0.0.160

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

func (*Connected) Reset added in v0.0.160

func (x *Connected) Reset()

func (*Connected) String added in v0.0.160

func (x *Connected) String() string

type ControlGraftMeta added in v0.0.160

type ControlGraftMeta struct {
	TopicId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=topic_id,proto3" json:"topic_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlGraftMeta) Descriptor deprecated added in v0.0.160

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

Deprecated: Use ControlGraftMeta.ProtoReflect.Descriptor instead.

func (*ControlGraftMeta) GetTopicId added in v0.0.160

func (x *ControlGraftMeta) GetTopicId() *wrapperspb.StringValue

func (*ControlGraftMeta) ProtoMessage added in v0.0.160

func (*ControlGraftMeta) ProtoMessage()

func (*ControlGraftMeta) ProtoReflect added in v0.0.160

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

func (*ControlGraftMeta) Reset added in v0.0.160

func (x *ControlGraftMeta) Reset()

func (*ControlGraftMeta) String added in v0.0.160

func (x *ControlGraftMeta) String() string

type ControlIHaveMeta added in v0.0.160

type ControlIHaveMeta struct {
	TopicId    *wrapperspb.StringValue   `protobuf:"bytes,1,opt,name=topic_id,proto3" json:"topic_id,omitempty"`
	MessageIds []*wrapperspb.StringValue `protobuf:"bytes,2,rep,name=message_ids,proto3" json:"message_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlIHaveMeta) Descriptor deprecated added in v0.0.160

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

Deprecated: Use ControlIHaveMeta.ProtoReflect.Descriptor instead.

func (*ControlIHaveMeta) GetMessageIds added in v0.0.160

func (x *ControlIHaveMeta) GetMessageIds() []*wrapperspb.StringValue

func (*ControlIHaveMeta) GetTopicId added in v0.0.160

func (x *ControlIHaveMeta) GetTopicId() *wrapperspb.StringValue

func (*ControlIHaveMeta) ProtoMessage added in v0.0.160

func (*ControlIHaveMeta) ProtoMessage()

func (*ControlIHaveMeta) ProtoReflect added in v0.0.160

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

func (*ControlIHaveMeta) Reset added in v0.0.160

func (x *ControlIHaveMeta) Reset()

func (*ControlIHaveMeta) String added in v0.0.160

func (x *ControlIHaveMeta) String() string

type ControlIWantMeta added in v0.0.160

type ControlIWantMeta struct {
	MessageIds []*wrapperspb.StringValue `protobuf:"bytes,1,rep,name=message_ids,proto3" json:"message_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlIWantMeta) Descriptor deprecated added in v0.0.160

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

Deprecated: Use ControlIWantMeta.ProtoReflect.Descriptor instead.

func (*ControlIWantMeta) GetMessageIds added in v0.0.160

func (x *ControlIWantMeta) GetMessageIds() []*wrapperspb.StringValue

func (*ControlIWantMeta) ProtoMessage added in v0.0.160

func (*ControlIWantMeta) ProtoMessage()

func (*ControlIWantMeta) ProtoReflect added in v0.0.160

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

func (*ControlIWantMeta) Reset added in v0.0.160

func (x *ControlIWantMeta) Reset()

func (*ControlIWantMeta) String added in v0.0.160

func (x *ControlIWantMeta) String() string

type ControlMeta added in v0.0.160

type ControlMeta struct {
	Ihave []*ControlIHaveMeta `protobuf:"bytes,1,rep,name=ihave,proto3" json:"ihave,omitempty"`
	Iwant []*ControlIWantMeta `protobuf:"bytes,2,rep,name=iwant,proto3" json:"iwant,omitempty"`
	Graft []*ControlGraftMeta `protobuf:"bytes,3,rep,name=graft,proto3" json:"graft,omitempty"`
	Prune []*ControlPruneMeta `protobuf:"bytes,4,rep,name=prune,proto3" json:"prune,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlMeta) Descriptor deprecated added in v0.0.160

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

Deprecated: Use ControlMeta.ProtoReflect.Descriptor instead.

func (*ControlMeta) GetGraft added in v0.0.160

func (x *ControlMeta) GetGraft() []*ControlGraftMeta

func (*ControlMeta) GetIhave added in v0.0.160

func (x *ControlMeta) GetIhave() []*ControlIHaveMeta

func (*ControlMeta) GetIwant added in v0.0.160

func (x *ControlMeta) GetIwant() []*ControlIWantMeta

func (*ControlMeta) GetPrune added in v0.0.160

func (x *ControlMeta) GetPrune() []*ControlPruneMeta

func (*ControlMeta) ProtoMessage added in v0.0.160

func (*ControlMeta) ProtoMessage()

func (*ControlMeta) ProtoReflect added in v0.0.160

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

func (*ControlMeta) Reset added in v0.0.160

func (x *ControlMeta) Reset()

func (*ControlMeta) String added in v0.0.160

func (x *ControlMeta) String() string

type ControlPruneMeta added in v0.0.160

type ControlPruneMeta struct {
	TopicId *wrapperspb.StringValue   `protobuf:"bytes,1,opt,name=topic_id,proto3" json:"topic_id,omitempty"`
	PeerIds []*wrapperspb.StringValue `protobuf:"bytes,2,rep,name=peer_ids,proto3" json:"peer_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlPruneMeta) Descriptor deprecated added in v0.0.160

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

Deprecated: Use ControlPruneMeta.ProtoReflect.Descriptor instead.

func (*ControlPruneMeta) GetPeerIds added in v0.0.160

func (x *ControlPruneMeta) GetPeerIds() []*wrapperspb.StringValue

func (*ControlPruneMeta) GetTopicId added in v0.0.160

func (x *ControlPruneMeta) GetTopicId() *wrapperspb.StringValue

func (*ControlPruneMeta) ProtoMessage added in v0.0.160

func (*ControlPruneMeta) ProtoMessage()

func (*ControlPruneMeta) ProtoReflect added in v0.0.160

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

func (*ControlPruneMeta) Reset added in v0.0.160

func (x *ControlPruneMeta) Reset()

func (*ControlPruneMeta) String added in v0.0.160

func (x *ControlPruneMeta) String() string

type Disconnected added in v0.0.160

type Disconnected struct {
	RemotePeer   *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=remote_peer,proto3" json:"remote_peer,omitempty"`
	RemoteMaddrs *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=remote_maddrs,proto3" json:"remote_maddrs,omitempty"`
	AgentVersion *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=agent_version,proto3" json:"agent_version,omitempty"`
	Direction    *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=direction,proto3" json:"direction,omitempty"`
	Opened       *timestamppb.Timestamp  `protobuf:"bytes,5,opt,name=opened,proto3" json:"opened,omitempty"`
	// See: https://github.com/probe-lab/hermes/commit/614e34ed0db780ee08c3bc333925a62409096166
	//
	// Deprecated: Marked as deprecated in pkg/proto/libp2p/trace.proto.
	Transient *wrapperspb.BoolValue `protobuf:"bytes,6,opt,name=transient,proto3" json:"transient,omitempty"`
	Limited   *wrapperspb.BoolValue `protobuf:"bytes,7,opt,name=limited,proto3" json:"limited,omitempty"`
	// contains filtered or unexported fields
}

func TraceEventToDisconnected added in v0.0.160

func TraceEventToDisconnected(event *host.TraceEvent) (*Disconnected, error)

func (*Disconnected) Descriptor deprecated added in v0.0.160

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

Deprecated: Use Disconnected.ProtoReflect.Descriptor instead.

func (*Disconnected) GetAgentVersion added in v0.0.160

func (x *Disconnected) GetAgentVersion() *wrapperspb.StringValue

func (*Disconnected) GetDirection added in v0.0.160

func (x *Disconnected) GetDirection() *wrapperspb.StringValue

func (*Disconnected) GetLimited added in v1.0.16

func (x *Disconnected) GetLimited() *wrapperspb.BoolValue

func (*Disconnected) GetOpened added in v0.0.160

func (x *Disconnected) GetOpened() *timestamppb.Timestamp

func (*Disconnected) GetRemoteMaddrs added in v0.0.160

func (x *Disconnected) GetRemoteMaddrs() *wrapperspb.StringValue

func (*Disconnected) GetRemotePeer added in v0.0.160

func (x *Disconnected) GetRemotePeer() *wrapperspb.StringValue

func (*Disconnected) GetTransient deprecated added in v0.0.160

func (x *Disconnected) GetTransient() *wrapperspb.BoolValue

Deprecated: Marked as deprecated in pkg/proto/libp2p/trace.proto.

func (*Disconnected) ProtoMessage added in v0.0.160

func (*Disconnected) ProtoMessage()

func (*Disconnected) ProtoReflect added in v0.0.160

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

func (*Disconnected) Reset added in v0.0.160

func (x *Disconnected) Reset()

func (*Disconnected) String added in v0.0.160

func (x *Disconnected) String() string

type EventType added in v0.0.160

type EventType int32
const (
	EventType_UNKNOWN         EventType = 0
	EventType_CONNECTED       EventType = 1
	EventType_DISCONNECTED    EventType = 2
	EventType_ADD_PEER        EventType = 3
	EventType_REMOVE_PEER     EventType = 4
	EventType_RECV_RPC        EventType = 5
	EventType_SEND_RPC        EventType = 6
	EventType_JOIN            EventType = 7
	EventType_HANDLE_STATUS   EventType = 8
	EventType_HANDLE_METADATA EventType = 9
)

func (EventType) Descriptor added in v0.0.160

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum added in v0.0.160

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated added in v0.0.160

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

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number added in v0.0.160

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String added in v0.0.160

func (x EventType) String() string

func (EventType) Type added in v0.0.160

type HandleMetadata added in v0.0.166

type HandleMetadata struct {
	PeerId     *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	ProtocolId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=protocol_id,proto3" json:"protocol_id,omitempty"`
	Error      *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Latency    *wrapperspb.FloatValue  `protobuf:"bytes,4,opt,name=latency,proto3" json:"latency,omitempty"`
	Metadata   *Metadata               `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func TraceEventToHandleMetadata added in v0.0.166

func TraceEventToHandleMetadata(event *host.TraceEvent) (*HandleMetadata, error)

func (*HandleMetadata) Descriptor deprecated added in v0.0.166

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

Deprecated: Use HandleMetadata.ProtoReflect.Descriptor instead.

func (*HandleMetadata) GetError added in v0.0.166

func (x *HandleMetadata) GetError() *wrapperspb.StringValue

func (*HandleMetadata) GetLatency added in v0.0.166

func (x *HandleMetadata) GetLatency() *wrapperspb.FloatValue

func (*HandleMetadata) GetMetadata added in v0.0.166

func (x *HandleMetadata) GetMetadata() *Metadata

func (*HandleMetadata) GetPeerId added in v0.0.166

func (x *HandleMetadata) GetPeerId() *wrapperspb.StringValue

func (*HandleMetadata) GetProtocolId added in v0.0.166

func (x *HandleMetadata) GetProtocolId() *wrapperspb.StringValue

func (*HandleMetadata) ProtoMessage added in v0.0.166

func (*HandleMetadata) ProtoMessage()

func (*HandleMetadata) ProtoReflect added in v0.0.166

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

func (*HandleMetadata) Reset added in v0.0.166

func (x *HandleMetadata) Reset()

func (*HandleMetadata) String added in v0.0.166

func (x *HandleMetadata) String() string

type HandleStatus added in v0.0.166

type HandleStatus struct {
	PeerId     *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	ProtocolId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=protocol_id,proto3" json:"protocol_id,omitempty"`
	Error      *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Latency    *wrapperspb.FloatValue  `protobuf:"bytes,4,opt,name=latency,proto3" json:"latency,omitempty"`
	Request    *Status                 `protobuf:"bytes,5,opt,name=request,proto3" json:"request,omitempty"`
	Response   *Status                 `protobuf:"bytes,6,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func TraceEventToHandleStatus added in v0.0.166

func TraceEventToHandleStatus(event *host.TraceEvent) (*HandleStatus, error)

func (*HandleStatus) Descriptor deprecated added in v0.0.166

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

Deprecated: Use HandleStatus.ProtoReflect.Descriptor instead.

func (*HandleStatus) GetError added in v0.0.166

func (x *HandleStatus) GetError() *wrapperspb.StringValue

func (*HandleStatus) GetLatency added in v0.0.166

func (x *HandleStatus) GetLatency() *wrapperspb.FloatValue

func (*HandleStatus) GetPeerId added in v0.0.166

func (x *HandleStatus) GetPeerId() *wrapperspb.StringValue

func (*HandleStatus) GetProtocolId added in v0.0.166

func (x *HandleStatus) GetProtocolId() *wrapperspb.StringValue

func (*HandleStatus) GetRequest added in v0.0.166

func (x *HandleStatus) GetRequest() *Status

func (*HandleStatus) GetResponse added in v0.0.166

func (x *HandleStatus) GetResponse() *Status

func (*HandleStatus) ProtoMessage added in v0.0.166

func (*HandleStatus) ProtoMessage()

func (*HandleStatus) ProtoReflect added in v0.0.166

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

func (*HandleStatus) Reset added in v0.0.166

func (x *HandleStatus) Reset()

func (*HandleStatus) String added in v0.0.166

func (x *HandleStatus) String() string

type Join added in v0.0.160

type Join struct {
	Topic *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func TraceEventToJoin added in v0.0.160

func TraceEventToJoin(event *host.TraceEvent) (*Join, error)

Helper function to convert a Hermes TraceEvent to a libp2p Join

func (*Join) Descriptor deprecated added in v0.0.160

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

Deprecated: Use Join.ProtoReflect.Descriptor instead.

func (*Join) GetTopic added in v0.0.160

func (x *Join) GetTopic() *wrapperspb.StringValue

func (*Join) ProtoMessage added in v0.0.160

func (*Join) ProtoMessage()

func (*Join) ProtoReflect added in v0.0.160

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

func (*Join) Reset added in v0.0.160

func (x *Join) Reset()

func (*Join) String added in v0.0.160

func (x *Join) String() string

type Leave added in v0.0.160

type Leave struct {
	Topic *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func TraceEventToLeave added in v0.0.160

func TraceEventToLeave(event *host.TraceEvent) (*Leave, error)

Helper function to convert a Hermes TraceEvent to a libp2p Leave

func (*Leave) Descriptor deprecated added in v0.0.160

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

Deprecated: Use Leave.ProtoReflect.Descriptor instead.

func (*Leave) GetTopic added in v0.0.160

func (x *Leave) GetTopic() *wrapperspb.StringValue

func (*Leave) ProtoMessage added in v0.0.160

func (*Leave) ProtoMessage()

func (*Leave) ProtoReflect added in v0.0.160

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

func (*Leave) Reset added in v0.0.160

func (x *Leave) Reset()

func (*Leave) String added in v0.0.160

func (x *Leave) String() string

type MessageMeta added in v0.0.160

type MessageMeta struct {
	MessageId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=message_id,proto3" json:"message_id,omitempty"`
	Topic     *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageMeta) Descriptor deprecated added in v0.0.160

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

Deprecated: Use MessageMeta.ProtoReflect.Descriptor instead.

func (*MessageMeta) GetMessageId added in v0.0.160

func (x *MessageMeta) GetMessageId() *wrapperspb.StringValue

func (*MessageMeta) GetTopic added in v0.0.160

func (x *MessageMeta) GetTopic() *wrapperspb.StringValue

func (*MessageMeta) ProtoMessage added in v0.0.160

func (*MessageMeta) ProtoMessage()

func (*MessageMeta) ProtoReflect added in v0.0.160

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

func (*MessageMeta) Reset added in v0.0.160

func (x *MessageMeta) Reset()

func (*MessageMeta) String added in v0.0.160

func (x *MessageMeta) String() string

type Metadata added in v0.0.166

type Metadata struct {
	SeqNumber *wrapperspb.UInt64Value `protobuf:"bytes,1,opt,name=seq_number,proto3" json:"seq_number,omitempty"`
	Attnets   *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=attnets,proto3" json:"attnets,omitempty"`
	Syncnets  *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=syncnets,proto3" json:"syncnets,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated added in v0.0.166

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetAttnets added in v0.0.166

func (x *Metadata) GetAttnets() *wrapperspb.StringValue

func (*Metadata) GetSeqNumber added in v0.0.166

func (x *Metadata) GetSeqNumber() *wrapperspb.UInt64Value

func (*Metadata) GetSyncnets added in v0.0.166

func (x *Metadata) GetSyncnets() *wrapperspb.StringValue

func (*Metadata) ProtoMessage added in v0.0.166

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect added in v0.0.166

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

func (*Metadata) Reset added in v0.0.166

func (x *Metadata) Reset()

func (*Metadata) String added in v0.0.166

func (x *Metadata) String() string

type Peer

type Peer struct {

	// ID is the ID of the peer.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Port is the port of the peer.
	Port *wrapperspb.UInt32Value `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	// IP is the IP of the peer.
	Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	// UserAgent is the user agent of the peer.
	UserAgent string `protobuf:"bytes,4,opt,name=user_agent,proto3" json:"user_agent,omitempty"`
	// ProtocolVersion is the protocol version of the peer.
	ProtocolVersion string `protobuf:"bytes,5,opt,name=protocol_version,proto3" json:"protocol_version,omitempty"`
	// Protocols is the protocols of the peer.
	Protocols []string `protobuf:"bytes,6,rep,name=protocols,proto3" json:"protocols,omitempty"`
	// Latency is the latency of the peer (in milliseconds).
	Latency *wrapperspb.UInt64Value `protobuf:"bytes,7,opt,name=latency,proto3" json:"latency,omitempty"`
	// contains filtered or unexported fields
}

func (*Peer) Descriptor deprecated

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

Deprecated: Use Peer.ProtoReflect.Descriptor instead.

func (*Peer) GetId

func (x *Peer) GetId() string

func (*Peer) GetIp

func (x *Peer) GetIp() string

func (*Peer) GetLatency

func (x *Peer) GetLatency() *wrapperspb.UInt64Value

func (*Peer) GetPort

func (x *Peer) GetPort() *wrapperspb.UInt32Value

func (*Peer) GetProtocolVersion

func (x *Peer) GetProtocolVersion() string

func (*Peer) GetProtocols

func (x *Peer) GetProtocols() []string

func (*Peer) GetUserAgent

func (x *Peer) GetUserAgent() string

func (*Peer) ProtoMessage

func (*Peer) ProtoMessage()

func (*Peer) ProtoReflect

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

func (*Peer) Reset

func (x *Peer) Reset()

func (*Peer) String

func (x *Peer) String() string

type RPCMeta added in v0.0.160

type RPCMeta struct {
	Messages      []*MessageMeta          `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	Subscriptions []*SubMeta              `protobuf:"bytes,2,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	Control       *ControlMeta            `protobuf:"bytes,3,opt,name=control,proto3" json:"control,omitempty"`
	PeerId        *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCMeta) Descriptor deprecated added in v0.0.160

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

Deprecated: Use RPCMeta.ProtoReflect.Descriptor instead.

func (*RPCMeta) GetControl added in v0.0.160

func (x *RPCMeta) GetControl() *ControlMeta

func (*RPCMeta) GetMessages added in v0.0.160

func (x *RPCMeta) GetMessages() []*MessageMeta

func (*RPCMeta) GetPeerId added in v0.0.160

func (x *RPCMeta) GetPeerId() *wrapperspb.StringValue

func (*RPCMeta) GetSubscriptions added in v0.0.160

func (x *RPCMeta) GetSubscriptions() []*SubMeta

func (*RPCMeta) ProtoMessage added in v0.0.160

func (*RPCMeta) ProtoMessage()

func (*RPCMeta) ProtoReflect added in v0.0.160

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

func (*RPCMeta) Reset added in v0.0.160

func (x *RPCMeta) Reset()

func (*RPCMeta) String added in v0.0.160

func (x *RPCMeta) String() string

type RecvRPC added in v0.0.160

type RecvRPC struct {
	PeerId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	Meta   *RPCMeta                `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func TraceEventToRecvRPC added in v0.0.160

func TraceEventToRecvRPC(event *host.TraceEvent) (*RecvRPC, error)

Helper function to convert a Hermes TraceEvent to a libp2p RecvRPC

func (*RecvRPC) Descriptor deprecated added in v0.0.160

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

Deprecated: Use RecvRPC.ProtoReflect.Descriptor instead.

func (*RecvRPC) GetMeta added in v0.0.160

func (x *RecvRPC) GetMeta() *RPCMeta

func (*RecvRPC) GetPeerId added in v0.0.160

func (x *RecvRPC) GetPeerId() *wrapperspb.StringValue

func (*RecvRPC) ProtoMessage added in v0.0.160

func (*RecvRPC) ProtoMessage()

func (*RecvRPC) ProtoReflect added in v0.0.160

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

func (*RecvRPC) Reset added in v0.0.160

func (x *RecvRPC) Reset()

func (*RecvRPC) String added in v0.0.160

func (x *RecvRPC) String() string

type RemovePeer added in v0.0.160

type RemovePeer struct {
	PeerId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	// contains filtered or unexported fields
}

func TraceEventToRemovePeer added in v0.0.160

func TraceEventToRemovePeer(event *host.TraceEvent) (*RemovePeer, error)

Helper function to convert a Hermes TraceEvent to a libp2p RemovePeer

func (*RemovePeer) Descriptor deprecated added in v0.0.160

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

Deprecated: Use RemovePeer.ProtoReflect.Descriptor instead.

func (*RemovePeer) GetPeerId added in v0.0.160

func (x *RemovePeer) GetPeerId() *wrapperspb.StringValue

func (*RemovePeer) ProtoMessage added in v0.0.160

func (*RemovePeer) ProtoMessage()

func (*RemovePeer) ProtoReflect added in v0.0.160

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

func (*RemovePeer) Reset added in v0.0.160

func (x *RemovePeer) Reset()

func (*RemovePeer) String added in v0.0.160

func (x *RemovePeer) String() string

type SendRPC added in v0.0.160

type SendRPC struct {
	PeerId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	Meta   *RPCMeta                `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func TraceEventToSendRPC added in v0.0.160

func TraceEventToSendRPC(event *host.TraceEvent) (*SendRPC, error)

Helper function to convert a Hermes TraceEvent to a libp2p SendRPC

func (*SendRPC) Descriptor deprecated added in v0.0.160

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

Deprecated: Use SendRPC.ProtoReflect.Descriptor instead.

func (*SendRPC) GetMeta added in v0.0.160

func (x *SendRPC) GetMeta() *RPCMeta

func (*SendRPC) GetPeerId added in v0.0.160

func (x *SendRPC) GetPeerId() *wrapperspb.StringValue

func (*SendRPC) ProtoMessage added in v0.0.160

func (*SendRPC) ProtoMessage()

func (*SendRPC) ProtoReflect added in v0.0.160

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

func (*SendRPC) Reset added in v0.0.160

func (x *SendRPC) Reset()

func (*SendRPC) String added in v0.0.160

func (x *SendRPC) String() string

type Status added in v0.0.166

type Status struct {
	ForkDigest     *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=fork_digest,proto3" json:"fork_digest,omitempty"`
	FinalizedRoot  *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=finalized_root,proto3" json:"finalized_root,omitempty"`
	FinalizedEpoch *wrapperspb.UInt64Value `protobuf:"bytes,3,opt,name=finalized_epoch,proto3" json:"finalized_epoch,omitempty"`
	HeadRoot       *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=head_root,proto3" json:"head_root,omitempty"`
	HeadSlot       *wrapperspb.UInt64Value `protobuf:"bytes,5,opt,name=head_slot,proto3" json:"head_slot,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated added in v0.0.166

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetFinalizedEpoch added in v0.0.166

func (x *Status) GetFinalizedEpoch() *wrapperspb.UInt64Value

func (*Status) GetFinalizedRoot added in v0.0.166

func (x *Status) GetFinalizedRoot() *wrapperspb.StringValue

func (*Status) GetForkDigest added in v0.0.166

func (x *Status) GetForkDigest() *wrapperspb.StringValue

func (*Status) GetHeadRoot added in v0.0.166

func (x *Status) GetHeadRoot() *wrapperspb.StringValue

func (*Status) GetHeadSlot added in v0.0.166

func (x *Status) GetHeadSlot() *wrapperspb.UInt64Value

func (*Status) ProtoMessage added in v0.0.166

func (*Status) ProtoMessage()

func (*Status) ProtoReflect added in v0.0.166

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

func (*Status) Reset added in v0.0.166

func (x *Status) Reset()

func (*Status) String added in v0.0.166

func (x *Status) String() string

type SubMeta added in v0.0.160

type SubMeta struct {
	Subscribe *wrapperspb.BoolValue   `protobuf:"bytes,1,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
	TopicId   *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=topic_id,proto3" json:"topic_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SubMeta) Descriptor deprecated added in v0.0.160

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

Deprecated: Use SubMeta.ProtoReflect.Descriptor instead.

func (*SubMeta) GetSubscribe added in v0.0.160

func (x *SubMeta) GetSubscribe() *wrapperspb.BoolValue

func (*SubMeta) GetTopicId added in v0.0.160

func (x *SubMeta) GetTopicId() *wrapperspb.StringValue

func (*SubMeta) ProtoMessage added in v0.0.160

func (*SubMeta) ProtoMessage()

func (*SubMeta) ProtoReflect added in v0.0.160

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

func (*SubMeta) Reset added in v0.0.160

func (x *SubMeta) Reset()

func (*SubMeta) String added in v0.0.160

func (x *SubMeta) String() string

type TraceEventMetadata added in v0.0.160

type TraceEventMetadata struct {
	PeerId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceEventMetadata) Descriptor deprecated added in v0.0.160

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

Deprecated: Use TraceEventMetadata.ProtoReflect.Descriptor instead.

func (*TraceEventMetadata) GetPeerId added in v0.0.160

func (x *TraceEventMetadata) GetPeerId() *wrapperspb.StringValue

func (*TraceEventMetadata) ProtoMessage added in v0.0.160

func (*TraceEventMetadata) ProtoMessage()

func (*TraceEventMetadata) ProtoReflect added in v0.0.160

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

func (*TraceEventMetadata) Reset added in v0.0.160

func (x *TraceEventMetadata) Reset()

func (*TraceEventMetadata) String added in v0.0.160

func (x *TraceEventMetadata) String() string

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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