Documentation ¶
Index ¶
- Variables
- type AddPeer
- func (*AddPeer) Descriptor() ([]byte, []int)deprecated
- func (x *AddPeer) GetPeerId() *wrapperspb.StringValue
- func (x *AddPeer) GetProtocol() *wrapperspb.StringValue
- func (*AddPeer) ProtoMessage()
- func (x *AddPeer) ProtoReflect() protoreflect.Message
- func (x *AddPeer) Reset()
- func (x *AddPeer) String() string
- type Connected
- func (*Connected) Descriptor() ([]byte, []int)deprecated
- func (x *Connected) GetAgentVersion() *wrapperspb.StringValue
- func (x *Connected) GetDirection() *wrapperspb.StringValue
- func (x *Connected) GetLimited() *wrapperspb.BoolValue
- func (x *Connected) GetOpened() *timestamppb.Timestamp
- func (x *Connected) GetRemoteMaddrs() *wrapperspb.StringValue
- func (x *Connected) GetRemotePeer() *wrapperspb.StringValue
- func (x *Connected) GetTransient() *wrapperspb.BoolValuedeprecated
- func (*Connected) ProtoMessage()
- func (x *Connected) ProtoReflect() protoreflect.Message
- func (x *Connected) Reset()
- func (x *Connected) String() string
- type ControlGraftMeta
- func (*ControlGraftMeta) Descriptor() ([]byte, []int)deprecated
- func (x *ControlGraftMeta) GetTopicId() *wrapperspb.StringValue
- func (*ControlGraftMeta) ProtoMessage()
- func (x *ControlGraftMeta) ProtoReflect() protoreflect.Message
- func (x *ControlGraftMeta) Reset()
- func (x *ControlGraftMeta) String() string
- type ControlIHaveMeta
- func (*ControlIHaveMeta) Descriptor() ([]byte, []int)deprecated
- func (x *ControlIHaveMeta) GetMessageIds() []*wrapperspb.StringValue
- func (x *ControlIHaveMeta) GetTopicId() *wrapperspb.StringValue
- func (*ControlIHaveMeta) ProtoMessage()
- func (x *ControlIHaveMeta) ProtoReflect() protoreflect.Message
- func (x *ControlIHaveMeta) Reset()
- func (x *ControlIHaveMeta) String() string
- type ControlIWantMeta
- func (*ControlIWantMeta) Descriptor() ([]byte, []int)deprecated
- func (x *ControlIWantMeta) GetMessageIds() []*wrapperspb.StringValue
- func (*ControlIWantMeta) ProtoMessage()
- func (x *ControlIWantMeta) ProtoReflect() protoreflect.Message
- func (x *ControlIWantMeta) Reset()
- func (x *ControlIWantMeta) String() string
- type ControlMeta
- func (*ControlMeta) Descriptor() ([]byte, []int)deprecated
- func (x *ControlMeta) GetGraft() []*ControlGraftMeta
- func (x *ControlMeta) GetIhave() []*ControlIHaveMeta
- func (x *ControlMeta) GetIwant() []*ControlIWantMeta
- func (x *ControlMeta) GetPrune() []*ControlPruneMeta
- func (*ControlMeta) ProtoMessage()
- func (x *ControlMeta) ProtoReflect() protoreflect.Message
- func (x *ControlMeta) Reset()
- func (x *ControlMeta) String() string
- type ControlPruneMeta
- func (*ControlPruneMeta) Descriptor() ([]byte, []int)deprecated
- func (x *ControlPruneMeta) GetPeerIds() []*wrapperspb.StringValue
- func (x *ControlPruneMeta) GetTopicId() *wrapperspb.StringValue
- func (*ControlPruneMeta) ProtoMessage()
- func (x *ControlPruneMeta) ProtoReflect() protoreflect.Message
- func (x *ControlPruneMeta) Reset()
- func (x *ControlPruneMeta) String() string
- type Disconnected
- func (*Disconnected) Descriptor() ([]byte, []int)deprecated
- func (x *Disconnected) GetAgentVersion() *wrapperspb.StringValue
- func (x *Disconnected) GetDirection() *wrapperspb.StringValue
- func (x *Disconnected) GetLimited() *wrapperspb.BoolValue
- func (x *Disconnected) GetOpened() *timestamppb.Timestamp
- func (x *Disconnected) GetRemoteMaddrs() *wrapperspb.StringValue
- func (x *Disconnected) GetRemotePeer() *wrapperspb.StringValue
- func (x *Disconnected) GetTransient() *wrapperspb.BoolValuedeprecated
- func (*Disconnected) ProtoMessage()
- func (x *Disconnected) ProtoReflect() protoreflect.Message
- func (x *Disconnected) Reset()
- func (x *Disconnected) String() string
- type EventType
- type HandleMetadata
- func (*HandleMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *HandleMetadata) GetError() *wrapperspb.StringValue
- func (x *HandleMetadata) GetLatency() *wrapperspb.FloatValue
- func (x *HandleMetadata) GetMetadata() *Metadata
- func (x *HandleMetadata) GetPeerId() *wrapperspb.StringValue
- func (x *HandleMetadata) GetProtocolId() *wrapperspb.StringValue
- func (*HandleMetadata) ProtoMessage()
- func (x *HandleMetadata) ProtoReflect() protoreflect.Message
- func (x *HandleMetadata) Reset()
- func (x *HandleMetadata) String() string
- type HandleStatus
- func (*HandleStatus) Descriptor() ([]byte, []int)deprecated
- func (x *HandleStatus) GetError() *wrapperspb.StringValue
- func (x *HandleStatus) GetLatency() *wrapperspb.FloatValue
- func (x *HandleStatus) GetPeerId() *wrapperspb.StringValue
- func (x *HandleStatus) GetProtocolId() *wrapperspb.StringValue
- func (x *HandleStatus) GetRequest() *Status
- func (x *HandleStatus) GetResponse() *Status
- func (*HandleStatus) ProtoMessage()
- func (x *HandleStatus) ProtoReflect() protoreflect.Message
- func (x *HandleStatus) Reset()
- func (x *HandleStatus) String() string
- type Join
- type Leave
- type MessageMeta
- func (*MessageMeta) Descriptor() ([]byte, []int)deprecated
- func (x *MessageMeta) GetMessageId() *wrapperspb.StringValue
- func (x *MessageMeta) GetTopic() *wrapperspb.StringValue
- func (*MessageMeta) ProtoMessage()
- func (x *MessageMeta) ProtoReflect() protoreflect.Message
- func (x *MessageMeta) Reset()
- func (x *MessageMeta) String() string
- type Metadata
- func (*Metadata) Descriptor() ([]byte, []int)deprecated
- func (x *Metadata) GetAttnets() *wrapperspb.StringValue
- func (x *Metadata) GetSeqNumber() *wrapperspb.UInt64Value
- func (x *Metadata) GetSyncnets() *wrapperspb.StringValue
- func (*Metadata) ProtoMessage()
- func (x *Metadata) ProtoReflect() protoreflect.Message
- func (x *Metadata) Reset()
- func (x *Metadata) String() string
- type Peer
- func (*Peer) Descriptor() ([]byte, []int)deprecated
- func (x *Peer) GetId() string
- func (x *Peer) GetIp() string
- func (x *Peer) GetLatency() *wrapperspb.UInt64Value
- func (x *Peer) GetPort() *wrapperspb.UInt32Value
- func (x *Peer) GetProtocolVersion() string
- func (x *Peer) GetProtocols() []string
- func (x *Peer) GetUserAgent() string
- func (*Peer) ProtoMessage()
- func (x *Peer) ProtoReflect() protoreflect.Message
- func (x *Peer) Reset()
- func (x *Peer) String() string
- type RPCMeta
- func (*RPCMeta) Descriptor() ([]byte, []int)deprecated
- func (x *RPCMeta) GetControl() *ControlMeta
- func (x *RPCMeta) GetMessages() []*MessageMeta
- func (x *RPCMeta) GetPeerId() *wrapperspb.StringValue
- func (x *RPCMeta) GetSubscriptions() []*SubMeta
- func (*RPCMeta) ProtoMessage()
- func (x *RPCMeta) ProtoReflect() protoreflect.Message
- func (x *RPCMeta) Reset()
- func (x *RPCMeta) String() string
- type RecvRPC
- type RemovePeer
- type SendRPC
- type Status
- func (*Status) Descriptor() ([]byte, []int)deprecated
- func (x *Status) GetFinalizedEpoch() *wrapperspb.UInt64Value
- func (x *Status) GetFinalizedRoot() *wrapperspb.StringValue
- func (x *Status) GetForkDigest() *wrapperspb.StringValue
- func (x *Status) GetHeadRoot() *wrapperspb.StringValue
- func (x *Status) GetHeadSlot() *wrapperspb.UInt64Value
- func (*Status) ProtoMessage()
- func (x *Status) ProtoReflect() protoreflect.Message
- func (x *Status) Reset()
- func (x *Status) String() string
- type SubMeta
- func (*SubMeta) Descriptor() ([]byte, []int)deprecated
- func (x *SubMeta) GetSubscribe() *wrapperspb.BoolValue
- func (x *SubMeta) GetTopicId() *wrapperspb.StringValue
- func (*SubMeta) ProtoMessage()
- func (x *SubMeta) ProtoReflect() protoreflect.Message
- func (x *SubMeta) Reset()
- func (x *SubMeta) String() string
- type TraceEventMetadata
- func (*TraceEventMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *TraceEventMetadata) GetPeerId() *wrapperspb.StringValue
- func (*TraceEventMetadata) ProtoMessage()
- func (x *TraceEventMetadata) ProtoReflect() protoreflect.Message
- func (x *TraceEventMetadata) Reset()
- func (x *TraceEventMetadata) String() string
Constants ¶
This section is empty.
Variables ¶
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.
var File_pkg_proto_libp2p_eth_proto protoreflect.FileDescriptor
var File_pkg_proto_libp2p_peer_proto protoreflect.FileDescriptor
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) 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
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) 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
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) EnumDescriptor
deprecated
added in
v0.0.160
func (EventType) Number ¶ added in v0.0.160
func (x EventType) Number() protoreflect.EnumNumber
func (EventType) Type ¶ added in v0.0.160
func (EventType) Type() protoreflect.EnumType
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) 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
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) 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
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) 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
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) GetLatency ¶
func (x *Peer) GetLatency() *wrapperspb.UInt64Value
func (*Peer) GetPort ¶
func (x *Peer) GetPort() *wrapperspb.UInt32Value
func (*Peer) GetProtocolVersion ¶
func (*Peer) GetProtocols ¶
func (*Peer) GetUserAgent ¶
func (*Peer) ProtoMessage ¶
func (*Peer) ProtoMessage()
func (*Peer) ProtoReflect ¶
func (x *Peer) ProtoReflect() protoreflect.Message
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) 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 (*RPCMeta) ProtoMessage ¶ added in v0.0.160
func (*RPCMeta) ProtoMessage()
func (*RPCMeta) ProtoReflect ¶ added in v0.0.160
func (x *RPCMeta) ProtoReflect() protoreflect.Message
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) 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
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) 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
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) 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
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) 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
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