libp2p

package
v1.3.3 Latest Latest
Warning

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

 Go to latest Published: Jul 31, 2025 License: GPL-3.0 Imports: 14 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",
		10: "DROP_RPC",
		11: "LEAVE",
		12: "GRAFT",
		13: "PRUNE",
		14: "PUBLISH_MESSAGE",
		15: "REJECT_MESSAGE",
		16: "DUPLICATE_MESSAGE",
		17: "DELIVER_MESSAGE",
		18: "RPC_META_CONTROL_IHAVE",
		19: "RPC_META_CONTROL_IWANT",
		20: "RPC_META_CONTROL_IDONTWANT",
		21: "RPC_META_CONTROL_GRAFT",
		22: "RPC_META_CONTROL_PRUNE",
		23: "RPC_META_SUBSCRIPTION",
		24: "RPC_META_MESSAGE",
	}
	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,
		"DROP_RPC":                   10,
		"LEAVE":                      11,
		"GRAFT":                      12,
		"PRUNE":                      13,
		"PUBLISH_MESSAGE":            14,
		"REJECT_MESSAGE":             15,
		"DUPLICATE_MESSAGE":          16,
		"DELIVER_MESSAGE":            17,
		"RPC_META_CONTROL_IHAVE":     18,
		"RPC_META_CONTROL_IWANT":     19,
		"RPC_META_CONTROL_IDONTWANT": 20,
		"RPC_META_CONTROL_GRAFT":     21,
		"RPC_META_CONTROL_PRUNE":     22,
		"RPC_META_SUBSCRIPTION":      23,
		"RPC_META_MESSAGE":           24,
	}
)

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
}

ControlGraftMeta represents a single topic. This is used to represent the highest level of the control message, and is what is used when parsing/preparing the control messages.

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 ControlGraftMetaItem added in v1.1.9 

type ControlGraftMetaItem struct {
	RootEventId  *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=root_event_id,proto3" json:"root_event_id,omitempty"`
	PeerId       *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	Topic        *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	ControlIndex *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=control_index,proto3" json:"control_index,omitempty"`
	// contains filtered or unexported fields
}

ControlGraftMetaItem represents a single topic. This is used to represent the lowest level of the control message, and is what is persisted to the store.

func (*ControlGraftMetaItem) Descriptor deprecated added in v1.1.9 

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

Deprecated: Use ControlGraftMetaItem.ProtoReflect.Descriptor instead.

func (*ControlGraftMetaItem) GetControlIndex added in v1.1.9 

func (x *ControlGraftMetaItem) GetControlIndex() *wrapperspb.UInt32Value

func (*ControlGraftMetaItem) GetPeerId added in v1.1.9 

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

func (*ControlGraftMetaItem) GetRootEventId added in v1.1.9 

func (x *ControlGraftMetaItem) GetRootEventId() *wrapperspb.StringValue

func (*ControlGraftMetaItem) GetTopic added in v1.1.9 

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

func (*ControlGraftMetaItem) ProtoMessage added in v1.1.9 

func (*ControlGraftMetaItem) ProtoMessage()

func (*ControlGraftMetaItem) ProtoReflect added in v1.1.9 

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

func (*ControlGraftMetaItem) Reset added in v1.1.9 

func (x *ControlGraftMetaItem) Reset()

func (*ControlGraftMetaItem) String added in v1.1.9 

func (x *ControlGraftMetaItem) String() string

type ControlIDontWantMeta added in v1.1.5 

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

ControlIDontWantMeta represents a single message ID. This is used to represent the highest level of the control message, and is what is used when parsing/preparing the control messages.

func (*ControlIDontWantMeta) Descriptor deprecated added in v1.1.5 

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

Deprecated: Use ControlIDontWantMeta.ProtoReflect.Descriptor instead.

func (*ControlIDontWantMeta) GetMessageIds added in v1.1.5 

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

func (*ControlIDontWantMeta) ProtoMessage added in v1.1.5 

func (*ControlIDontWantMeta) ProtoMessage()

func (*ControlIDontWantMeta) ProtoReflect added in v1.1.5 

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

func (*ControlIDontWantMeta) Reset added in v1.1.5 

func (x *ControlIDontWantMeta) Reset()

func (*ControlIDontWantMeta) String added in v1.1.5 

func (x *ControlIDontWantMeta) String() string

type ControlIDontWantMetaItem added in v1.1.9 

type ControlIDontWantMetaItem struct {
	RootEventId  *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=root_event_id,proto3" json:"root_event_id,omitempty"`
	PeerId       *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	MessageId    *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=message_id,proto3" json:"message_id,omitempty"`
	MessageIndex *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=message_index,proto3" json:"message_index,omitempty"`
	ControlIndex *wrapperspb.UInt32Value `protobuf:"bytes,5,opt,name=control_index,proto3" json:"control_index,omitempty"`
	// contains filtered or unexported fields
}

ControlIDontWantMetaItem represents a single message ID. This is used to represent the lowest level of the control message, and is what is persisted to the store.

func (*ControlIDontWantMetaItem) Descriptor deprecated added in v1.1.9 

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

Deprecated: Use ControlIDontWantMetaItem.ProtoReflect.Descriptor instead.

func (*ControlIDontWantMetaItem) GetControlIndex added in v1.1.9 

func (x *ControlIDontWantMetaItem) GetControlIndex() *wrapperspb.UInt32Value

func (*ControlIDontWantMetaItem) GetMessageId added in v1.1.9 

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

func (*ControlIDontWantMetaItem) GetMessageIndex added in v1.1.9 

func (x *ControlIDontWantMetaItem) GetMessageIndex() *wrapperspb.UInt32Value

func (*ControlIDontWantMetaItem) GetPeerId added in v1.1.9 

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

func (*ControlIDontWantMetaItem) GetRootEventId added in v1.1.9 

func (x *ControlIDontWantMetaItem) GetRootEventId() *wrapperspb.StringValue

func (*ControlIDontWantMetaItem) ProtoMessage added in v1.1.9 

func (*ControlIDontWantMetaItem) ProtoMessage()

func (*ControlIDontWantMetaItem) ProtoReflect added in v1.1.9 

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

func (*ControlIDontWantMetaItem) Reset added in v1.1.9 

func (x *ControlIDontWantMetaItem) Reset()

func (*ControlIDontWantMetaItem) String added in v1.1.9 

func (x *ControlIDontWantMetaItem) 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
}

ControlIHaveMeta represents a single topic and its message IDs. This is used to represent the highest level of the control message, and is what is used when parsing/preparing the control messages.

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 ControlIHaveMetaItem added in v1.1.9 

type ControlIHaveMetaItem struct {
	RootEventId  *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=root_event_id,proto3" json:"root_event_id,omitempty"`
	PeerId       *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	MessageId    *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=message_id,proto3" json:"message_id,omitempty"`
	Topic        *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=topic,proto3" json:"topic,omitempty"`
	MessageIndex *wrapperspb.UInt32Value `protobuf:"bytes,5,opt,name=message_index,proto3" json:"message_index,omitempty"`
	ControlIndex *wrapperspb.UInt32Value `protobuf:"bytes,6,opt,name=control_index,proto3" json:"control_index,omitempty"`
	// contains filtered or unexported fields
}

ControlIHaveMetaItem represents a single message ID for a topic. This is used to represent the lowest level of the control message, and is what is persisted to the store.

func (*ControlIHaveMetaItem) Descriptor deprecated added in v1.1.9 

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

Deprecated: Use ControlIHaveMetaItem.ProtoReflect.Descriptor instead.

func (*ControlIHaveMetaItem) GetControlIndex added in v1.1.9 

func (x *ControlIHaveMetaItem) GetControlIndex() *wrapperspb.UInt32Value

func (*ControlIHaveMetaItem) GetMessageId added in v1.1.9 

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

func (*ControlIHaveMetaItem) GetMessageIndex added in v1.1.9 

func (x *ControlIHaveMetaItem) GetMessageIndex() *wrapperspb.UInt32Value

func (*ControlIHaveMetaItem) GetPeerId added in v1.1.9 

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

func (*ControlIHaveMetaItem) GetRootEventId added in v1.1.9 

func (x *ControlIHaveMetaItem) GetRootEventId() *wrapperspb.StringValue

func (*ControlIHaveMetaItem) GetTopic added in v1.1.9 

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

func (*ControlIHaveMetaItem) ProtoMessage added in v1.1.9 

func (*ControlIHaveMetaItem) ProtoMessage()

func (*ControlIHaveMetaItem) ProtoReflect added in v1.1.9 

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

func (*ControlIHaveMetaItem) Reset added in v1.1.9 

func (x *ControlIHaveMetaItem) Reset()

func (*ControlIHaveMetaItem) String added in v1.1.9 

func (x *ControlIHaveMetaItem) String() string

type ControlIWantMeta added in v0.0.160 

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

ControlIWantMeta represents a single message ID. This is used to represent the highest level of the control message, and is what is used when parsing/preparing the control messages.

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 ControlIWantMetaItem added in v1.1.9 

type ControlIWantMetaItem struct {
	RootEventId  *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=root_event_id,proto3" json:"root_event_id,omitempty"`
	PeerId       *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	MessageId    *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=message_id,proto3" json:"message_id,omitempty"`
	MessageIndex *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=message_index,proto3" json:"message_index,omitempty"`
	ControlIndex *wrapperspb.UInt32Value `protobuf:"bytes,5,opt,name=control_index,proto3" json:"control_index,omitempty"`
	// contains filtered or unexported fields
}

ControlIWantMetaItem represents a single message ID. This is used to represent the lowest level of the control message, and is what is persisted to the store.

func (*ControlIWantMetaItem) Descriptor deprecated added in v1.1.9 

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

Deprecated: Use ControlIWantMetaItem.ProtoReflect.Descriptor instead.

func (*ControlIWantMetaItem) GetControlIndex added in v1.1.9 

func (x *ControlIWantMetaItem) GetControlIndex() *wrapperspb.UInt32Value

func (*ControlIWantMetaItem) GetMessageId added in v1.1.9 

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

func (*ControlIWantMetaItem) GetMessageIndex added in v1.1.9 

func (x *ControlIWantMetaItem) GetMessageIndex() *wrapperspb.UInt32Value

func (*ControlIWantMetaItem) GetPeerId added in v1.1.9 

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

func (*ControlIWantMetaItem) GetRootEventId added in v1.1.9 

func (x *ControlIWantMetaItem) GetRootEventId() *wrapperspb.StringValue

func (*ControlIWantMetaItem) ProtoMessage added in v1.1.9 

func (*ControlIWantMetaItem) ProtoMessage()

func (*ControlIWantMetaItem) ProtoReflect added in v1.1.9 

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

func (*ControlIWantMetaItem) Reset added in v1.1.9 

func (x *ControlIWantMetaItem) Reset()

func (*ControlIWantMetaItem) String added in v1.1.9 

func (x *ControlIWantMetaItem) 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"`
	Idontwant []*ControlIDontWantMeta `protobuf:"bytes,5,rep,name=idontwant,proto3" json:"idontwant,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) GetIdontwant added in v1.1.5 

func (x *ControlMeta) GetIdontwant() []*ControlIDontWantMeta

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
}

ControlPruneMeta represents a single topic and its peer IDs. This is used to represent the highest level of the control message, and is what is used when parsing/preparing the control messages.

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 ControlPruneMetaItem added in v1.1.9 

type ControlPruneMetaItem struct {
	RootEventId  *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=root_event_id,proto3" json:"root_event_id,omitempty"`
	PeerId       *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	GraftPeerId  *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=graft_peer_id,proto3" json:"graft_peer_id,omitempty"`
	Topic        *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=topic,proto3" json:"topic,omitempty"`
	ControlIndex *wrapperspb.UInt32Value `protobuf:"bytes,5,opt,name=control_index,proto3" json:"control_index,omitempty"`
	PeerIndex    *wrapperspb.UInt32Value `protobuf:"bytes,6,opt,name=peer_index,proto3" json:"peer_index,omitempty"`
	// contains filtered or unexported fields
}

ControlPruneMetaItem represents a single peer ID for a topic. This is used to represent the lowest level of the control message, and is what is persisted to the store.

func (*ControlPruneMetaItem) Descriptor deprecated added in v1.1.9 

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

Deprecated: Use ControlPruneMetaItem.ProtoReflect.Descriptor instead.

func (*ControlPruneMetaItem) GetControlIndex added in v1.1.9 

func (x *ControlPruneMetaItem) GetControlIndex() *wrapperspb.UInt32Value

func (*ControlPruneMetaItem) GetGraftPeerId added in v1.1.9 

func (x *ControlPruneMetaItem) GetGraftPeerId() *wrapperspb.StringValue

func (*ControlPruneMetaItem) GetPeerId added in v1.1.9 

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

func (*ControlPruneMetaItem) GetPeerIndex added in v1.1.9 

func (x *ControlPruneMetaItem) GetPeerIndex() *wrapperspb.UInt32Value

func (*ControlPruneMetaItem) GetRootEventId added in v1.1.9 

func (x *ControlPruneMetaItem) GetRootEventId() *wrapperspb.StringValue

func (*ControlPruneMetaItem) GetTopic added in v1.1.9 

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

func (*ControlPruneMetaItem) ProtoMessage added in v1.1.9 

func (*ControlPruneMetaItem) ProtoMessage()

func (*ControlPruneMetaItem) ProtoReflect added in v1.1.9 

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

func (*ControlPruneMetaItem) Reset added in v1.1.9 

func (x *ControlPruneMetaItem) Reset()

func (*ControlPruneMetaItem) String added in v1.1.9 

func (x *ControlPruneMetaItem) String() string

type DeliverMessage added in v1.1.7 

type DeliverMessage struct {
	MsgId     *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=msg_id,proto3" json:"msg_id,omitempty"`
	PeerId    *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	Topic     *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Local     *wrapperspb.BoolValue   `protobuf:"bytes,4,opt,name=local,proto3" json:"local,omitempty"`
	MsgSize   *wrapperspb.UInt32Value `protobuf:"bytes,5,opt,name=msg_size,proto3" json:"msg_size,omitempty"`
	SeqNumber *wrapperspb.UInt64Value `protobuf:"bytes,6,opt,name=seq_number,proto3" json:"seq_number,omitempty"`
	// contains filtered or unexported fields
}

func TraceEventToDeliverMessage added in v1.1.7 

func TraceEventToDeliverMessage(event *host.TraceEvent) (*DeliverMessage, error)

Helper function to convert a Hermes TraceEvent to a libp2p DeliverMessage.

func (*DeliverMessage) Descriptor deprecated added in v1.1.7 

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

Deprecated: Use DeliverMessage.ProtoReflect.Descriptor instead.

func (*DeliverMessage) GetLocal added in v1.1.7 

func (x *DeliverMessage) GetLocal() *wrapperspb.BoolValue

func (*DeliverMessage) GetMsgId added in v1.1.7 

func (x *DeliverMessage) GetMsgId() *wrapperspb.StringValue

func (*DeliverMessage) GetMsgSize added in v1.1.7 

func (x *DeliverMessage) GetMsgSize() *wrapperspb.UInt32Value

func (*DeliverMessage) GetPeerId added in v1.1.7 

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

func (*DeliverMessage) GetSeqNumber added in v1.1.7 

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

func (*DeliverMessage) GetTopic added in v1.1.7 

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

func (*DeliverMessage) ProtoMessage added in v1.1.7 

func (*DeliverMessage) ProtoMessage()

func (*DeliverMessage) ProtoReflect added in v1.1.7 

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

func (*DeliverMessage) Reset added in v1.1.7 

func (x *DeliverMessage) Reset()

func (*DeliverMessage) String added in v1.1.7 

func (x *DeliverMessage) 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 DropRPC added in v1.1.5 

type DropRPC 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 TraceEventToDropRPC added in v1.1.5 

func TraceEventToDropRPC(event *host.TraceEvent) (*DropRPC, error)

Helper function to convert a Hermes TraceEvent to a libp2p DropRPC.

func (*DropRPC) Descriptor deprecated added in v1.1.5 

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

Deprecated: Use DropRPC.ProtoReflect.Descriptor instead.

func (*DropRPC) GetMeta added in v1.1.5 

func (x *DropRPC) GetMeta() *RPCMeta

func (*DropRPC) GetPeerId added in v1.1.5 

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

func (*DropRPC) ProtoMessage added in v1.1.5 

func (*DropRPC) ProtoMessage()

func (*DropRPC) ProtoReflect added in v1.1.5 

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

func (*DropRPC) Reset added in v1.1.5 

func (x *DropRPC) Reset()

func (*DropRPC) String added in v1.1.5 

func (x *DropRPC) String() string

type DuplicateMessage added in v1.1.7 

type DuplicateMessage struct {
	MsgId     *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=msg_id,proto3" json:"msg_id,omitempty"`
	PeerId    *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	Topic     *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Local     *wrapperspb.BoolValue   `protobuf:"bytes,4,opt,name=local,proto3" json:"local,omitempty"`
	MsgSize   *wrapperspb.UInt32Value `protobuf:"bytes,5,opt,name=msg_size,proto3" json:"msg_size,omitempty"`
	SeqNumber *wrapperspb.UInt64Value `protobuf:"bytes,6,opt,name=seq_number,proto3" json:"seq_number,omitempty"`
	// contains filtered or unexported fields
}

func TraceEventToDuplicateMessage added in v1.1.7 

func TraceEventToDuplicateMessage(event *host.TraceEvent) (*DuplicateMessage, error)

Helper function to convert a Hermes TraceEvent to a libp2p DuplicateMessage.

func (*DuplicateMessage) Descriptor deprecated added in v1.1.7 

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

Deprecated: Use DuplicateMessage.ProtoReflect.Descriptor instead.

func (*DuplicateMessage) GetLocal added in v1.1.7 

func (x *DuplicateMessage) GetLocal() *wrapperspb.BoolValue

func (*DuplicateMessage) GetMsgId added in v1.1.7 

func (x *DuplicateMessage) GetMsgId() *wrapperspb.StringValue

func (*DuplicateMessage) GetMsgSize added in v1.1.7 

func (x *DuplicateMessage) GetMsgSize() *wrapperspb.UInt32Value

func (*DuplicateMessage) GetPeerId added in v1.1.7 

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

func (*DuplicateMessage) GetSeqNumber added in v1.1.7 

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

func (*DuplicateMessage) GetTopic added in v1.1.7 

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

func (*DuplicateMessage) ProtoMessage added in v1.1.7 

func (*DuplicateMessage) ProtoMessage()

func (*DuplicateMessage) ProtoReflect added in v1.1.7 

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

func (*DuplicateMessage) Reset added in v1.1.7 

func (x *DuplicateMessage) Reset()

func (*DuplicateMessage) String added in v1.1.7 

func (x *DuplicateMessage) 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
	EventType_DROP_RPC                   EventType = 10
	EventType_LEAVE                      EventType = 11
	EventType_GRAFT                      EventType = 12
	EventType_PRUNE                      EventType = 13
	EventType_PUBLISH_MESSAGE            EventType = 14
	EventType_REJECT_MESSAGE             EventType = 15
	EventType_DUPLICATE_MESSAGE          EventType = 16
	EventType_DELIVER_MESSAGE            EventType = 17
	EventType_RPC_META_CONTROL_IHAVE     EventType = 18
	EventType_RPC_META_CONTROL_IWANT     EventType = 19
	EventType_RPC_META_CONTROL_IDONTWANT EventType = 20
	EventType_RPC_META_CONTROL_GRAFT     EventType = 21
	EventType_RPC_META_CONTROL_PRUNE     EventType = 22
	EventType_RPC_META_SUBSCRIPTION      EventType = 23
	EventType_RPC_META_MESSAGE           EventType = 24
)

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 Graft added in v1.1.5 

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

func TraceEventToGraft added in v1.1.5 

func TraceEventToGraft(event *host.TraceEvent) (*Graft, error)

Helper function to convert a Hermes TraceEvent to a libp2p Graft.

func (*Graft) Descriptor deprecated added in v1.1.5 

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

Deprecated: Use Graft.ProtoReflect.Descriptor instead.

func (*Graft) GetPeerId added in v1.1.5 

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

func (*Graft) GetTopic added in v1.1.5 

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

func (*Graft) ProtoMessage added in v1.1.5 

func (*Graft) ProtoMessage()

func (*Graft) ProtoReflect added in v1.1.5 

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

func (*Graft) Reset added in v1.1.5 

func (x *Graft) Reset()

func (*Graft) String added in v1.1.5 

func (x *Graft) String() string

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"`
	TopicId   *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=topic_id,proto3" json:"topic_id,omitempty"`
	// contains filtered or unexported fields
}

MessageMeta represents a single message. This is used to represent the highest level of the RPC meta data, and is what is used when parsing/preparing the RPC meta data.

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) GetTopicId added in v1.1.12 

func (x *MessageMeta) GetTopicId() *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 MessageMetaItem added in v1.1.12 

type MessageMetaItem struct {
	RootEventId  *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=root_event_id,proto3" json:"root_event_id,omitempty"`
	PeerId       *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	MessageId    *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=message_id,proto3" json:"message_id,omitempty"`
	TopicId      *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=topic_id,proto3" json:"topic_id,omitempty"`
	ControlIndex *wrapperspb.UInt32Value `protobuf:"bytes,5,opt,name=control_index,proto3" json:"control_index,omitempty"`
	// contains filtered or unexported fields
}

MessageMetaItem represents a single message. This is used to represent the lowest level of the RPC meta data, and is what is persisted to the store.

func (*MessageMetaItem) Descriptor deprecated added in v1.1.12 

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

Deprecated: Use MessageMetaItem.ProtoReflect.Descriptor instead.

func (*MessageMetaItem) GetControlIndex added in v1.1.12 

func (x *MessageMetaItem) GetControlIndex() *wrapperspb.UInt32Value

func (*MessageMetaItem) GetMessageId added in v1.1.12 

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

func (*MessageMetaItem) GetPeerId added in v1.1.12 

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

func (*MessageMetaItem) GetRootEventId added in v1.1.12 

func (x *MessageMetaItem) GetRootEventId() *wrapperspb.StringValue

func (*MessageMetaItem) GetTopicId added in v1.1.12 

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

func (*MessageMetaItem) ProtoMessage added in v1.1.12 

func (*MessageMetaItem) ProtoMessage()

func (*MessageMetaItem) ProtoReflect added in v1.1.12 

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

func (*MessageMetaItem) Reset added in v1.1.12 

func (x *MessageMetaItem) Reset()

func (*MessageMetaItem) String added in v1.1.12 

func (x *MessageMetaItem) 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 Prune added in v1.1.5 

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

func TraceEventToPrune added in v1.1.5 

func TraceEventToPrune(event *host.TraceEvent) (*Prune, error)

Helper function to convert a Hermes TraceEvent to a libp2p Prune.

func (*Prune) Descriptor deprecated added in v1.1.5 

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

Deprecated: Use Prune.ProtoReflect.Descriptor instead.

func (*Prune) GetPeerId added in v1.1.5 

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

func (*Prune) GetTopic added in v1.1.5 

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

func (*Prune) ProtoMessage added in v1.1.5 

func (*Prune) ProtoMessage()

func (*Prune) ProtoReflect added in v1.1.5 

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

func (*Prune) Reset added in v1.1.5 

func (x *Prune) Reset()

func (*Prune) String added in v1.1.5 

func (x *Prune) String() string

type PublishMessage added in v1.1.7 

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

func TraceEventToPublishMessage added in v1.1.7 

func TraceEventToPublishMessage(event *host.TraceEvent) (*PublishMessage, error)

Helper function to convert a Hermes TraceEvent to a libp2p PublishMessage.

func (*PublishMessage) Descriptor deprecated added in v1.1.7 

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

Deprecated: Use PublishMessage.ProtoReflect.Descriptor instead.

func (*PublishMessage) GetMsgId added in v1.1.7 

func (x *PublishMessage) GetMsgId() *wrapperspb.StringValue

func (*PublishMessage) GetTopic added in v1.1.7 

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

func (*PublishMessage) ProtoMessage added in v1.1.7 

func (*PublishMessage) ProtoMessage()

func (*PublishMessage) ProtoReflect added in v1.1.7 

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

func (*PublishMessage) Reset added in v1.1.7 

func (x *PublishMessage) Reset()

func (*PublishMessage) String added in v1.1.7 

func (x *PublishMessage) 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
}

RPCMeta represents the RPC meta data for a peer. This is used to represent the highest level of the RPC meta data, and is what is used when parsing/preparing the RPC meta data.

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 RejectMessage added in v1.1.7 

type RejectMessage struct {
	MsgId     *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=msg_id,proto3" json:"msg_id,omitempty"`
	PeerId    *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	Topic     *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Reason    *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	Local     *wrapperspb.BoolValue   `protobuf:"bytes,5,opt,name=local,proto3" json:"local,omitempty"`
	MsgSize   *wrapperspb.UInt32Value `protobuf:"bytes,6,opt,name=msg_size,proto3" json:"msg_size,omitempty"`
	SeqNumber *wrapperspb.UInt64Value `protobuf:"bytes,7,opt,name=seq_number,proto3" json:"seq_number,omitempty"`
	// contains filtered or unexported fields
}

func TraceEventToRejectMessage added in v1.1.7 

func TraceEventToRejectMessage(event *host.TraceEvent) (*RejectMessage, error)

Helper function to convert a Hermes TraceEvent to a libp2p RejectMessage.

func (*RejectMessage) Descriptor deprecated added in v1.1.7 

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

Deprecated: Use RejectMessage.ProtoReflect.Descriptor instead.

func (*RejectMessage) GetLocal added in v1.1.7 

func (x *RejectMessage) GetLocal() *wrapperspb.BoolValue

func (*RejectMessage) GetMsgId added in v1.1.7 

func (x *RejectMessage) GetMsgId() *wrapperspb.StringValue

func (*RejectMessage) GetMsgSize added in v1.1.7 

func (x *RejectMessage) GetMsgSize() *wrapperspb.UInt32Value

func (*RejectMessage) GetPeerId added in v1.1.7 

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

func (*RejectMessage) GetReason added in v1.1.7 

func (x *RejectMessage) GetReason() *wrapperspb.StringValue

func (*RejectMessage) GetSeqNumber added in v1.1.7 

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

func (*RejectMessage) GetTopic added in v1.1.7 

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

func (*RejectMessage) ProtoMessage added in v1.1.7 

func (*RejectMessage) ProtoMessage()

func (*RejectMessage) ProtoReflect added in v1.1.7 

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

func (*RejectMessage) Reset added in v1.1.7 

func (x *RejectMessage) Reset()

func (*RejectMessage) String added in v1.1.7 

func (x *RejectMessage) 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
}

SubMeta represents the RPC meta data for a peer. This is used to represent the highest level of the RPC meta data, and is what is used when parsing/preparing the RPC meta data.

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 SubMetaItem added in v1.1.12 

type SubMetaItem struct {
	RootEventId  *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=root_event_id,proto3" json:"root_event_id,omitempty"`
	PeerId       *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	TopicId      *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=topic_id,proto3" json:"topic_id,omitempty"`
	Subscribe    *wrapperspb.BoolValue   `protobuf:"bytes,4,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
	ControlIndex *wrapperspb.UInt32Value `protobuf:"bytes,5,opt,name=control_index,proto3" json:"control_index,omitempty"`
	// contains filtered or unexported fields
}

SubMetaItem represents a single subscription. This is used to represent the lowest level of the RPC meta data, and is what is persisted to the store.

func (*SubMetaItem) Descriptor deprecated added in v1.1.12 

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

Deprecated: Use SubMetaItem.ProtoReflect.Descriptor instead.

func (*SubMetaItem) GetControlIndex added in v1.1.12 

func (x *SubMetaItem) GetControlIndex() *wrapperspb.UInt32Value

func (*SubMetaItem) GetPeerId added in v1.1.12 

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

func (*SubMetaItem) GetRootEventId added in v1.1.12 

func (x *SubMetaItem) GetRootEventId() *wrapperspb.StringValue

func (*SubMetaItem) GetSubscribe added in v1.1.12 

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

func (*SubMetaItem) GetTopicId added in v1.1.12 

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

func (*SubMetaItem) ProtoMessage added in v1.1.12 

func (*SubMetaItem) ProtoMessage()

func (*SubMetaItem) ProtoReflect added in v1.1.12 

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

func (*SubMetaItem) Reset added in v1.1.12 

func (x *SubMetaItem) Reset()

func (*SubMetaItem) String added in v1.1.12 

func (x *SubMetaItem) 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.