libp2p

package
v1.0.11 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 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"`
	Transient    *wrapperspb.BoolValue   `protobuf:"bytes,6,opt,name=transient,proto3" json:"transient,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) 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 added in v0.0.160 

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

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"`
	Transient    *wrapperspb.BoolValue   `protobuf:"bytes,6,opt,name=transient,proto3" json:"transient,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) 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 added in v0.0.160 

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

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 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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