libp2p

package
v1.8.13 Latest Latest
Warning

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

 Go to latest Published: May 7, 2026 License: GPL-3.0 Imports: 11 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",
		25: "SYNTHETIC_HEARTBEAT",
		26: "CUSTODY_PROBE",
		27: "IDENTIFY",
	}
	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,
		"SYNTHETIC_HEARTBEAT":        25,
		"CUSTODY_PROBE":              26,
		"IDENTIFY":                   27,
	}
)

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 AddPeerFromVTPool added in v1.8.12 

func AddPeerFromVTPool() *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) MarshalToSizedBufferVT added in v1.8.12 

func (m *AddPeer) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AddPeer) MarshalToVT added in v1.8.12 

func (m *AddPeer) MarshalToVT(dAtA []byte) (int, error)

func (*AddPeer) MarshalVT added in v1.8.12 

func (m *AddPeer) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *AddPeer) ResetVT()

func (*AddPeer) ReturnToVTPool added in v1.8.12 

func (m *AddPeer) ReturnToVTPool()

func (*AddPeer) SizeVT added in v1.8.12 

func (m *AddPeer) SizeVT() (n int)

func (*AddPeer) String added in v0.0.160 

func (x *AddPeer) String() string

func (*AddPeer) UnmarshalVT added in v1.8.12 

func (m *AddPeer) UnmarshalVT(dAtA []byte) error

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 ConnectedFromVTPool added in v1.8.12 

func ConnectedFromVTPool() *Connected

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *Connected) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Connected) MarshalToVT added in v1.8.12 

func (m *Connected) MarshalToVT(dAtA []byte) (int, error)

func (*Connected) MarshalVT added in v1.8.12 

func (m *Connected) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *Connected) ResetVT()

func (*Connected) ReturnToVTPool added in v1.8.12 

func (m *Connected) ReturnToVTPool()

func (*Connected) SizeVT added in v1.8.12 

func (m *Connected) SizeVT() (n int)

func (*Connected) String added in v0.0.160 

func (x *Connected) String() string

func (*Connected) UnmarshalVT added in v1.8.12 

func (m *Connected) UnmarshalVT(dAtA []byte) error

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 ControlGraftMetaFromVTPool added in v1.8.12 

func ControlGraftMetaFromVTPool() *ControlGraftMeta

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *ControlGraftMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControlGraftMeta) MarshalToVT added in v1.8.12 

func (m *ControlGraftMeta) MarshalToVT(dAtA []byte) (int, error)

func (*ControlGraftMeta) MarshalVT added in v1.8.12 

func (m *ControlGraftMeta) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *ControlGraftMeta) ResetVT()

func (*ControlGraftMeta) ReturnToVTPool added in v1.8.12 

func (m *ControlGraftMeta) ReturnToVTPool()

func (*ControlGraftMeta) SizeVT added in v1.8.12 

func (m *ControlGraftMeta) SizeVT() (n int)

func (*ControlGraftMeta) String added in v0.0.160 

func (x *ControlGraftMeta) String() string

func (*ControlGraftMeta) UnmarshalVT added in v1.8.12 

func (m *ControlGraftMeta) UnmarshalVT(dAtA []byte) error

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 ControlGraftMetaItemFromVTPool added in v1.8.12 

func ControlGraftMetaItemFromVTPool() *ControlGraftMetaItem

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *ControlGraftMetaItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControlGraftMetaItem) MarshalToVT added in v1.8.12 

func (m *ControlGraftMetaItem) MarshalToVT(dAtA []byte) (int, error)

func (*ControlGraftMetaItem) MarshalVT added in v1.8.12 

func (m *ControlGraftMetaItem) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *ControlGraftMetaItem) ResetVT()

func (*ControlGraftMetaItem) ReturnToVTPool added in v1.8.12 

func (m *ControlGraftMetaItem) ReturnToVTPool()

func (*ControlGraftMetaItem) SizeVT added in v1.8.12 

func (m *ControlGraftMetaItem) SizeVT() (n int)

func (*ControlGraftMetaItem) String added in v1.1.9 

func (x *ControlGraftMetaItem) String() string

func (*ControlGraftMetaItem) UnmarshalVT added in v1.8.12 

func (m *ControlGraftMetaItem) UnmarshalVT(dAtA []byte) error

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 ControlIDontWantMetaFromVTPool added in v1.8.12 

func ControlIDontWantMetaFromVTPool() *ControlIDontWantMeta

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *ControlIDontWantMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControlIDontWantMeta) MarshalToVT added in v1.8.12 

func (m *ControlIDontWantMeta) MarshalToVT(dAtA []byte) (int, error)

func (*ControlIDontWantMeta) MarshalVT added in v1.8.12 

func (m *ControlIDontWantMeta) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *ControlIDontWantMeta) ResetVT()

func (*ControlIDontWantMeta) ReturnToVTPool added in v1.8.12 

func (m *ControlIDontWantMeta) ReturnToVTPool()

func (*ControlIDontWantMeta) SizeVT added in v1.8.12 

func (m *ControlIDontWantMeta) SizeVT() (n int)

func (*ControlIDontWantMeta) String added in v1.1.5 

func (x *ControlIDontWantMeta) String() string

func (*ControlIDontWantMeta) UnmarshalVT added in v1.8.12 

func (m *ControlIDontWantMeta) UnmarshalVT(dAtA []byte) error

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 ControlIDontWantMetaItemFromVTPool added in v1.8.12 

func ControlIDontWantMetaItemFromVTPool() *ControlIDontWantMetaItem

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *ControlIDontWantMetaItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControlIDontWantMetaItem) MarshalToVT added in v1.8.12 

func (m *ControlIDontWantMetaItem) MarshalToVT(dAtA []byte) (int, error)

func (*ControlIDontWantMetaItem) MarshalVT added in v1.8.12 

func (m *ControlIDontWantMetaItem) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *ControlIDontWantMetaItem) ResetVT()

func (*ControlIDontWantMetaItem) ReturnToVTPool added in v1.8.12 

func (m *ControlIDontWantMetaItem) ReturnToVTPool()

func (*ControlIDontWantMetaItem) SizeVT added in v1.8.12 

func (m *ControlIDontWantMetaItem) SizeVT() (n int)

func (*ControlIDontWantMetaItem) String added in v1.1.9 

func (x *ControlIDontWantMetaItem) String() string

func (*ControlIDontWantMetaItem) UnmarshalVT added in v1.8.12 

func (m *ControlIDontWantMetaItem) UnmarshalVT(dAtA []byte) error

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 ControlIHaveMetaFromVTPool added in v1.8.12 

func ControlIHaveMetaFromVTPool() *ControlIHaveMeta

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *ControlIHaveMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControlIHaveMeta) MarshalToVT added in v1.8.12 

func (m *ControlIHaveMeta) MarshalToVT(dAtA []byte) (int, error)

func (*ControlIHaveMeta) MarshalVT added in v1.8.12 

func (m *ControlIHaveMeta) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *ControlIHaveMeta) ResetVT()

func (*ControlIHaveMeta) ReturnToVTPool added in v1.8.12 

func (m *ControlIHaveMeta) ReturnToVTPool()

func (*ControlIHaveMeta) SizeVT added in v1.8.12 

func (m *ControlIHaveMeta) SizeVT() (n int)

func (*ControlIHaveMeta) String added in v0.0.160 

func (x *ControlIHaveMeta) String() string

func (*ControlIHaveMeta) UnmarshalVT added in v1.8.12 

func (m *ControlIHaveMeta) UnmarshalVT(dAtA []byte) error

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 ControlIHaveMetaItemFromVTPool added in v1.8.12 

func ControlIHaveMetaItemFromVTPool() *ControlIHaveMetaItem

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *ControlIHaveMetaItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControlIHaveMetaItem) MarshalToVT added in v1.8.12 

func (m *ControlIHaveMetaItem) MarshalToVT(dAtA []byte) (int, error)

func (*ControlIHaveMetaItem) MarshalVT added in v1.8.12 

func (m *ControlIHaveMetaItem) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *ControlIHaveMetaItem) ResetVT()

func (*ControlIHaveMetaItem) ReturnToVTPool added in v1.8.12 

func (m *ControlIHaveMetaItem) ReturnToVTPool()

func (*ControlIHaveMetaItem) SizeVT added in v1.8.12 

func (m *ControlIHaveMetaItem) SizeVT() (n int)

func (*ControlIHaveMetaItem) String added in v1.1.9 

func (x *ControlIHaveMetaItem) String() string

func (*ControlIHaveMetaItem) UnmarshalVT added in v1.8.12 

func (m *ControlIHaveMetaItem) UnmarshalVT(dAtA []byte) error

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 ControlIWantMetaFromVTPool added in v1.8.12 

func ControlIWantMetaFromVTPool() *ControlIWantMeta

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *ControlIWantMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControlIWantMeta) MarshalToVT added in v1.8.12 

func (m *ControlIWantMeta) MarshalToVT(dAtA []byte) (int, error)

func (*ControlIWantMeta) MarshalVT added in v1.8.12 

func (m *ControlIWantMeta) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *ControlIWantMeta) ResetVT()

func (*ControlIWantMeta) ReturnToVTPool added in v1.8.12 

func (m *ControlIWantMeta) ReturnToVTPool()

func (*ControlIWantMeta) SizeVT added in v1.8.12 

func (m *ControlIWantMeta) SizeVT() (n int)

func (*ControlIWantMeta) String added in v0.0.160 

func (x *ControlIWantMeta) String() string

func (*ControlIWantMeta) UnmarshalVT added in v1.8.12 

func (m *ControlIWantMeta) UnmarshalVT(dAtA []byte) error

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 ControlIWantMetaItemFromVTPool added in v1.8.12 

func ControlIWantMetaItemFromVTPool() *ControlIWantMetaItem

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *ControlIWantMetaItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControlIWantMetaItem) MarshalToVT added in v1.8.12 

func (m *ControlIWantMetaItem) MarshalToVT(dAtA []byte) (int, error)

func (*ControlIWantMetaItem) MarshalVT added in v1.8.12 

func (m *ControlIWantMetaItem) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *ControlIWantMetaItem) ResetVT()

func (*ControlIWantMetaItem) ReturnToVTPool added in v1.8.12 

func (m *ControlIWantMetaItem) ReturnToVTPool()

func (*ControlIWantMetaItem) SizeVT added in v1.8.12 

func (m *ControlIWantMetaItem) SizeVT() (n int)

func (*ControlIWantMetaItem) String added in v1.1.9 

func (x *ControlIWantMetaItem) String() string

func (*ControlIWantMetaItem) UnmarshalVT added in v1.8.12 

func (m *ControlIWantMetaItem) UnmarshalVT(dAtA []byte) error

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 ControlMetaFromVTPool added in v1.8.12 

func ControlMetaFromVTPool() *ControlMeta

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *ControlMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControlMeta) MarshalToVT added in v1.8.12 

func (m *ControlMeta) MarshalToVT(dAtA []byte) (int, error)

func (*ControlMeta) MarshalVT added in v1.8.12 

func (m *ControlMeta) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *ControlMeta) ResetVT()

func (*ControlMeta) ReturnToVTPool added in v1.8.12 

func (m *ControlMeta) ReturnToVTPool()

func (*ControlMeta) SizeVT added in v1.8.12 

func (m *ControlMeta) SizeVT() (n int)

func (*ControlMeta) String added in v0.0.160 

func (x *ControlMeta) String() string

func (*ControlMeta) UnmarshalVT added in v1.8.12 

func (m *ControlMeta) UnmarshalVT(dAtA []byte) error

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 ControlPruneMetaFromVTPool added in v1.8.12 

func ControlPruneMetaFromVTPool() *ControlPruneMeta

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *ControlPruneMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControlPruneMeta) MarshalToVT added in v1.8.12 

func (m *ControlPruneMeta) MarshalToVT(dAtA []byte) (int, error)

func (*ControlPruneMeta) MarshalVT added in v1.8.12 

func (m *ControlPruneMeta) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *ControlPruneMeta) ResetVT()

func (*ControlPruneMeta) ReturnToVTPool added in v1.8.12 

func (m *ControlPruneMeta) ReturnToVTPool()

func (*ControlPruneMeta) SizeVT added in v1.8.12 

func (m *ControlPruneMeta) SizeVT() (n int)

func (*ControlPruneMeta) String added in v0.0.160 

func (x *ControlPruneMeta) String() string

func (*ControlPruneMeta) UnmarshalVT added in v1.8.12 

func (m *ControlPruneMeta) UnmarshalVT(dAtA []byte) error

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 ControlPruneMetaItemFromVTPool added in v1.8.12 

func ControlPruneMetaItemFromVTPool() *ControlPruneMetaItem

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *ControlPruneMetaItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControlPruneMetaItem) MarshalToVT added in v1.8.12 

func (m *ControlPruneMetaItem) MarshalToVT(dAtA []byte) (int, error)

func (*ControlPruneMetaItem) MarshalVT added in v1.8.12 

func (m *ControlPruneMetaItem) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *ControlPruneMetaItem) ResetVT()

func (*ControlPruneMetaItem) ReturnToVTPool added in v1.8.12 

func (m *ControlPruneMetaItem) ReturnToVTPool()

func (*ControlPruneMetaItem) SizeVT added in v1.8.12 

func (m *ControlPruneMetaItem) SizeVT() (n int)

func (*ControlPruneMetaItem) String added in v1.1.9 

func (x *ControlPruneMetaItem) String() string

func (*ControlPruneMetaItem) UnmarshalVT added in v1.8.12 

func (m *ControlPruneMetaItem) UnmarshalVT(dAtA []byte) error

type DataColumnCustodyProbe added in v1.5.0 

type DataColumnCustodyProbe struct {

	// Probe metadata
	JobStartTimestamp *timestamppb.Timestamp  `protobuf:"bytes,1,opt,name=job_start_timestamp,proto3" json:"job_start_timestamp,omitempty"`
	PeerId            *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=peer_id,proto3" json:"peer_id,omitempty"`
	// Slot and column
	Slot                               *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=slot,proto3" json:"slot,omitempty"`
	SlotStartDateTime                  *wrapperspb.UInt64Value `protobuf:"bytes,4,opt,name=slot_start_date_time,proto3" json:"slot_start_date_time,omitempty"`
	Epoch                              *wrapperspb.UInt32Value `protobuf:"bytes,5,opt,name=epoch,proto3" json:"epoch,omitempty"`
	EpochStartDateTime                 *wrapperspb.UInt64Value `protobuf:"bytes,6,opt,name=epoch_start_date_time,proto3" json:"epoch_start_date_time,omitempty"`
	WallclockRequestSlot               *wrapperspb.UInt32Value `protobuf:"bytes,7,opt,name=wallclock_request_slot,proto3" json:"wallclock_request_slot,omitempty"`
	WallclockRequestSlotStartDateTime  *wrapperspb.UInt64Value `` /* 129-byte string literal not displayed */
	WallclockRequestEpoch              *wrapperspb.UInt32Value `protobuf:"bytes,9,opt,name=wallclock_request_epoch,proto3" json:"wallclock_request_epoch,omitempty"`
	WallclockRequestEpochStartDateTime *wrapperspb.UInt64Value `` /* 132-byte string literal not displayed */
	// Column information
	ColumnIndex     *wrapperspb.UInt32Value `protobuf:"bytes,11,opt,name=column_index,proto3" json:"column_index,omitempty"`
	ColumnRowsCount *wrapperspb.UInt32Value `protobuf:"bytes,12,opt,name=column_rows_count,proto3" json:"column_rows_count,omitempty"`
	BeaconBlockRoot *wrapperspb.StringValue `protobuf:"bytes,13,opt,name=beacon_block_root,proto3" json:"beacon_block_root,omitempty"`
	// Probe results
	Result         *wrapperspb.StringValue `protobuf:"bytes,14,opt,name=result,proto3" json:"result,omitempty"`
	ResponseTimeMs *wrapperspb.Int64Value  `protobuf:"bytes,15,opt,name=response_time_ms,proto3" json:"response_time_ms,omitempty"`
	Error          *wrapperspb.StringValue `protobuf:"bytes,16,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

DataColumnCustodyProbe represents a peer custody probe event

func DataColumnCustodyProbeFromVTPool added in v1.8.12 

func DataColumnCustodyProbeFromVTPool() *DataColumnCustodyProbe

func (*DataColumnCustodyProbe) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use DataColumnCustodyProbe.ProtoReflect.Descriptor instead.

func (*DataColumnCustodyProbe) GetBeaconBlockRoot added in v1.5.0 

func (x *DataColumnCustodyProbe) GetBeaconBlockRoot() *wrapperspb.StringValue

func (*DataColumnCustodyProbe) GetColumnIndex added in v1.5.0 

func (x *DataColumnCustodyProbe) GetColumnIndex() *wrapperspb.UInt32Value

func (*DataColumnCustodyProbe) GetColumnRowsCount added in v1.5.0 

func (x *DataColumnCustodyProbe) GetColumnRowsCount() *wrapperspb.UInt32Value

func (*DataColumnCustodyProbe) GetEpoch added in v1.5.0 

func (x *DataColumnCustodyProbe) GetEpoch() *wrapperspb.UInt32Value

func (*DataColumnCustodyProbe) GetEpochStartDateTime added in v1.5.0 

func (x *DataColumnCustodyProbe) GetEpochStartDateTime() *wrapperspb.UInt64Value

func (*DataColumnCustodyProbe) GetError added in v1.5.0 

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

func (*DataColumnCustodyProbe) GetJobStartTimestamp added in v1.5.0 

func (x *DataColumnCustodyProbe) GetJobStartTimestamp() *timestamppb.Timestamp

func (*DataColumnCustodyProbe) GetPeerId added in v1.5.0 

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

func (*DataColumnCustodyProbe) GetResponseTimeMs added in v1.5.0 

func (x *DataColumnCustodyProbe) GetResponseTimeMs() *wrapperspb.Int64Value

func (*DataColumnCustodyProbe) GetResult added in v1.5.0 

func (x *DataColumnCustodyProbe) GetResult() *wrapperspb.StringValue

func (*DataColumnCustodyProbe) GetSlot added in v1.5.0 

func (x *DataColumnCustodyProbe) GetSlot() *wrapperspb.UInt32Value

func (*DataColumnCustodyProbe) GetSlotStartDateTime added in v1.5.0 

func (x *DataColumnCustodyProbe) GetSlotStartDateTime() *wrapperspb.UInt64Value

func (*DataColumnCustodyProbe) GetWallclockRequestEpoch added in v1.5.0 

func (x *DataColumnCustodyProbe) GetWallclockRequestEpoch() *wrapperspb.UInt32Value

func (*DataColumnCustodyProbe) GetWallclockRequestEpochStartDateTime added in v1.5.0 

func (x *DataColumnCustodyProbe) GetWallclockRequestEpochStartDateTime() *wrapperspb.UInt64Value

func (*DataColumnCustodyProbe) GetWallclockRequestSlot added in v1.5.0 

func (x *DataColumnCustodyProbe) GetWallclockRequestSlot() *wrapperspb.UInt32Value

func (*DataColumnCustodyProbe) GetWallclockRequestSlotStartDateTime added in v1.5.0 

func (x *DataColumnCustodyProbe) GetWallclockRequestSlotStartDateTime() *wrapperspb.UInt64Value

func (*DataColumnCustodyProbe) MarshalToSizedBufferVT added in v1.8.12 

func (m *DataColumnCustodyProbe) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DataColumnCustodyProbe) MarshalToVT added in v1.8.12 

func (m *DataColumnCustodyProbe) MarshalToVT(dAtA []byte) (int, error)

func (*DataColumnCustodyProbe) MarshalVT added in v1.8.12 

func (m *DataColumnCustodyProbe) MarshalVT() (dAtA []byte, err error)

func (*DataColumnCustodyProbe) ProtoMessage added in v1.5.0 

func (*DataColumnCustodyProbe) ProtoMessage()

func (*DataColumnCustodyProbe) ProtoReflect added in v1.5.0 

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

func (*DataColumnCustodyProbe) Reset added in v1.5.0 

func (x *DataColumnCustodyProbe) Reset()

func (*DataColumnCustodyProbe) ResetVT added in v1.8.12 

func (m *DataColumnCustodyProbe) ResetVT()

func (*DataColumnCustodyProbe) ReturnToVTPool added in v1.8.12 

func (m *DataColumnCustodyProbe) ReturnToVTPool()

func (*DataColumnCustodyProbe) SizeVT added in v1.8.12 

func (m *DataColumnCustodyProbe) SizeVT() (n int)

func (*DataColumnCustodyProbe) String added in v1.5.0 

func (x *DataColumnCustodyProbe) String() string

func (*DataColumnCustodyProbe) UnmarshalVT added in v1.8.12 

func (m *DataColumnCustodyProbe) UnmarshalVT(dAtA []byte) error

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 DeliverMessageFromVTPool added in v1.8.12 

func DeliverMessageFromVTPool() *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) MarshalToSizedBufferVT added in v1.8.12 

func (m *DeliverMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeliverMessage) MarshalToVT added in v1.8.12 

func (m *DeliverMessage) MarshalToVT(dAtA []byte) (int, error)

func (*DeliverMessage) MarshalVT added in v1.8.12 

func (m *DeliverMessage) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *DeliverMessage) ResetVT()

func (*DeliverMessage) ReturnToVTPool added in v1.8.12 

func (m *DeliverMessage) ReturnToVTPool()

func (*DeliverMessage) SizeVT added in v1.8.12 

func (m *DeliverMessage) SizeVT() (n int)

func (*DeliverMessage) String added in v1.1.7 

func (x *DeliverMessage) String() string

func (*DeliverMessage) UnmarshalVT added in v1.8.12 

func (m *DeliverMessage) UnmarshalVT(dAtA []byte) error

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 DisconnectedFromVTPool added in v1.8.12 

func DisconnectedFromVTPool() *Disconnected

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *Disconnected) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Disconnected) MarshalToVT added in v1.8.12 

func (m *Disconnected) MarshalToVT(dAtA []byte) (int, error)

func (*Disconnected) MarshalVT added in v1.8.12 

func (m *Disconnected) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *Disconnected) ResetVT()

func (*Disconnected) ReturnToVTPool added in v1.8.12 

func (m *Disconnected) ReturnToVTPool()

func (*Disconnected) SizeVT added in v1.8.12 

func (m *Disconnected) SizeVT() (n int)

func (*Disconnected) String added in v0.0.160 

func (x *Disconnected) String() string

func (*Disconnected) UnmarshalVT added in v1.8.12 

func (m *Disconnected) UnmarshalVT(dAtA []byte) error

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 DropRPCFromVTPool added in v1.8.12 

func DropRPCFromVTPool() *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) MarshalToSizedBufferVT added in v1.8.12 

func (m *DropRPC) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DropRPC) MarshalToVT added in v1.8.12 

func (m *DropRPC) MarshalToVT(dAtA []byte) (int, error)

func (*DropRPC) MarshalVT added in v1.8.12 

func (m *DropRPC) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *DropRPC) ResetVT()

func (*DropRPC) ReturnToVTPool added in v1.8.12 

func (m *DropRPC) ReturnToVTPool()

func (*DropRPC) SizeVT added in v1.8.12 

func (m *DropRPC) SizeVT() (n int)

func (*DropRPC) String added in v1.1.5 

func (x *DropRPC) String() string

func (*DropRPC) UnmarshalVT added in v1.8.12 

func (m *DropRPC) UnmarshalVT(dAtA []byte) error

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 DuplicateMessageFromVTPool added in v1.8.12 

func DuplicateMessageFromVTPool() *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) MarshalToSizedBufferVT added in v1.8.12 

func (m *DuplicateMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DuplicateMessage) MarshalToVT added in v1.8.12 

func (m *DuplicateMessage) MarshalToVT(dAtA []byte) (int, error)

func (*DuplicateMessage) MarshalVT added in v1.8.12 

func (m *DuplicateMessage) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *DuplicateMessage) ResetVT()

func (*DuplicateMessage) ReturnToVTPool added in v1.8.12 

func (m *DuplicateMessage) ReturnToVTPool()

func (*DuplicateMessage) SizeVT added in v1.8.12 

func (m *DuplicateMessage) SizeVT() (n int)

func (*DuplicateMessage) String added in v1.1.7 

func (x *DuplicateMessage) String() string

func (*DuplicateMessage) UnmarshalVT added in v1.8.12 

func (m *DuplicateMessage) UnmarshalVT(dAtA []byte) error

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
	EventType_SYNTHETIC_HEARTBEAT        EventType = 25
	EventType_CUSTODY_PROBE              EventType = 26
	EventType_IDENTIFY                   EventType = 27
)

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 GraftFromVTPool added in v1.8.12 

func GraftFromVTPool() *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) MarshalToSizedBufferVT added in v1.8.12 

func (m *Graft) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Graft) MarshalToVT added in v1.8.12 

func (m *Graft) MarshalToVT(dAtA []byte) (int, error)

func (*Graft) MarshalVT added in v1.8.12 

func (m *Graft) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *Graft) ResetVT()

func (*Graft) ReturnToVTPool added in v1.8.12 

func (m *Graft) ReturnToVTPool()

func (*Graft) SizeVT added in v1.8.12 

func (m *Graft) SizeVT() (n int)

func (*Graft) String added in v1.1.5 

func (x *Graft) String() string

func (*Graft) UnmarshalVT added in v1.8.12 

func (m *Graft) UnmarshalVT(dAtA []byte) error

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

func HandleMetadataFromVTPool added in v1.8.12 

func HandleMetadataFromVTPool() *HandleMetadata

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

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

Deprecated: Use HandleMetadata.ProtoReflect.Descriptor instead.

func (*HandleMetadata) GetDirection added in v1.4.15 

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

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *HandleMetadata) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*HandleMetadata) MarshalToVT added in v1.8.12 

func (m *HandleMetadata) MarshalToVT(dAtA []byte) (int, error)

func (*HandleMetadata) MarshalVT added in v1.8.12 

func (m *HandleMetadata) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *HandleMetadata) ResetVT()

func (*HandleMetadata) ReturnToVTPool added in v1.8.12 

func (m *HandleMetadata) ReturnToVTPool()

func (*HandleMetadata) SizeVT added in v1.8.12 

func (m *HandleMetadata) SizeVT() (n int)

func (*HandleMetadata) String added in v0.0.166 

func (x *HandleMetadata) String() string

func (*HandleMetadata) UnmarshalVT added in v1.8.12 

func (m *HandleMetadata) UnmarshalVT(dAtA []byte) error

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

func HandleStatusFromVTPool added in v1.8.12 

func HandleStatusFromVTPool() *HandleStatus

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

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

Deprecated: Use HandleStatus.ProtoReflect.Descriptor instead.

func (*HandleStatus) GetDirection added in v1.4.15 

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

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *HandleStatus) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*HandleStatus) MarshalToVT added in v1.8.12 

func (m *HandleStatus) MarshalToVT(dAtA []byte) (int, error)

func (*HandleStatus) MarshalVT added in v1.8.12 

func (m *HandleStatus) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *HandleStatus) ResetVT()

func (*HandleStatus) ReturnToVTPool added in v1.8.12 

func (m *HandleStatus) ReturnToVTPool()

func (*HandleStatus) SizeVT added in v1.8.12 

func (m *HandleStatus) SizeVT() (n int)

func (*HandleStatus) String added in v0.0.166 

func (x *HandleStatus) String() string

func (*HandleStatus) UnmarshalVT added in v1.8.12 

func (m *HandleStatus) UnmarshalVT(dAtA []byte) error

type Identify added in v1.8.11 

type Identify struct {
	RemotePeer      *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=remote_peer,proto3" json:"remote_peer,omitempty"`
	Success         *wrapperspb.BoolValue   `protobuf:"bytes,2,opt,name=success,proto3" json:"success,omitempty"`
	Error           *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	AgentVersion    *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=agent_version,proto3" json:"agent_version,omitempty"`
	ProtocolVersion *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=protocol_version,proto3" json:"protocol_version,omitempty"`
	Protocols       []string                `protobuf:"bytes,6,rep,name=protocols,proto3" json:"protocols,omitempty"`
	ListenAddrs     []string                `protobuf:"bytes,7,rep,name=listen_addrs,proto3" json:"listen_addrs,omitempty"`
	ObservedAddr    *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=observed_addr,proto3" json:"observed_addr,omitempty"`
	Transport       *wrapperspb.StringValue `protobuf:"bytes,9,opt,name=transport,proto3" json:"transport,omitempty"`
	Security        *wrapperspb.StringValue `protobuf:"bytes,10,opt,name=security,proto3" json:"security,omitempty"`
	Muxer           *wrapperspb.StringValue `protobuf:"bytes,11,opt,name=muxer,proto3" json:"muxer,omitempty"`
	Direction       *wrapperspb.StringValue `protobuf:"bytes,12,opt,name=direction,proto3" json:"direction,omitempty"`
	RemoteMultiaddr *wrapperspb.StringValue `protobuf:"bytes,13,opt,name=remote_multiaddr,proto3" json:"remote_multiaddr,omitempty"`
	// contains filtered or unexported fields
}

func IdentifyFromVTPool added in v1.8.12 

func IdentifyFromVTPool() *Identify

func (*Identify) Descriptor deprecated added in v1.8.11 

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

Deprecated: Use Identify.ProtoReflect.Descriptor instead.

func (*Identify) GetAgentVersion added in v1.8.11 

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

func (*Identify) GetDirection added in v1.8.11 

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

func (*Identify) GetError added in v1.8.11 

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

func (*Identify) GetListenAddrs added in v1.8.11 

func (x *Identify) GetListenAddrs() []string

func (*Identify) GetMuxer added in v1.8.11 

func (x *Identify) GetMuxer() *wrapperspb.StringValue

func (*Identify) GetObservedAddr added in v1.8.11 

func (x *Identify) GetObservedAddr() *wrapperspb.StringValue

func (*Identify) GetProtocolVersion added in v1.8.11 

func (x *Identify) GetProtocolVersion() *wrapperspb.StringValue

func (*Identify) GetProtocols added in v1.8.11 

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

func (*Identify) GetRemoteMultiaddr added in v1.8.11 

func (x *Identify) GetRemoteMultiaddr() *wrapperspb.StringValue

func (*Identify) GetRemotePeer added in v1.8.11 

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

func (*Identify) GetSecurity added in v1.8.11 

func (x *Identify) GetSecurity() *wrapperspb.StringValue

func (*Identify) GetSuccess added in v1.8.11 

func (x *Identify) GetSuccess() *wrapperspb.BoolValue

func (*Identify) GetTransport added in v1.8.11 

func (x *Identify) GetTransport() *wrapperspb.StringValue

func (*Identify) MarshalToSizedBufferVT added in v1.8.12 

func (m *Identify) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Identify) MarshalToVT added in v1.8.12 

func (m *Identify) MarshalToVT(dAtA []byte) (int, error)

func (*Identify) MarshalVT added in v1.8.12 

func (m *Identify) MarshalVT() (dAtA []byte, err error)

func (*Identify) ProtoMessage added in v1.8.11 

func (*Identify) ProtoMessage()

func (*Identify) ProtoReflect added in v1.8.11 

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

func (*Identify) Reset added in v1.8.11 

func (x *Identify) Reset()

func (*Identify) ResetVT added in v1.8.12 

func (m *Identify) ResetVT()

func (*Identify) ReturnToVTPool added in v1.8.12 

func (m *Identify) ReturnToVTPool()

func (*Identify) SizeVT added in v1.8.12 

func (m *Identify) SizeVT() (n int)

func (*Identify) String added in v1.8.11 

func (x *Identify) String() string

func (*Identify) UnmarshalVT added in v1.8.12 

func (m *Identify) UnmarshalVT(dAtA []byte) error

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 JoinFromVTPool added in v1.8.12 

func JoinFromVTPool() *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) MarshalToSizedBufferVT added in v1.8.12 

func (m *Join) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Join) MarshalToVT added in v1.8.12 

func (m *Join) MarshalToVT(dAtA []byte) (int, error)

func (*Join) MarshalVT added in v1.8.12 

func (m *Join) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *Join) ResetVT()

func (*Join) ReturnToVTPool added in v1.8.12 

func (m *Join) ReturnToVTPool()

func (*Join) SizeVT added in v1.8.12 

func (m *Join) SizeVT() (n int)

func (*Join) String added in v0.0.160 

func (x *Join) String() string

func (*Join) UnmarshalVT added in v1.8.12 

func (m *Join) UnmarshalVT(dAtA []byte) error

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 LeaveFromVTPool added in v1.8.12 

func LeaveFromVTPool() *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) MarshalToSizedBufferVT added in v1.8.12 

func (m *Leave) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Leave) MarshalToVT added in v1.8.12 

func (m *Leave) MarshalToVT(dAtA []byte) (int, error)

func (*Leave) MarshalVT added in v1.8.12 

func (m *Leave) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *Leave) ResetVT()

func (*Leave) ReturnToVTPool added in v1.8.12 

func (m *Leave) ReturnToVTPool()

func (*Leave) SizeVT added in v1.8.12 

func (m *Leave) SizeVT() (n int)

func (*Leave) String added in v0.0.160 

func (x *Leave) String() string

func (*Leave) UnmarshalVT added in v1.8.12 

func (m *Leave) UnmarshalVT(dAtA []byte) error

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 MessageMetaFromVTPool added in v1.8.12 

func MessageMetaFromVTPool() *MessageMeta

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *MessageMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MessageMeta) MarshalToVT added in v1.8.12 

func (m *MessageMeta) MarshalToVT(dAtA []byte) (int, error)

func (*MessageMeta) MarshalVT added in v1.8.12 

func (m *MessageMeta) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *MessageMeta) ResetVT()

func (*MessageMeta) ReturnToVTPool added in v1.8.12 

func (m *MessageMeta) ReturnToVTPool()

func (*MessageMeta) SizeVT added in v1.8.12 

func (m *MessageMeta) SizeVT() (n int)

func (*MessageMeta) String added in v0.0.160 

func (x *MessageMeta) String() string

func (*MessageMeta) UnmarshalVT added in v1.8.12 

func (m *MessageMeta) UnmarshalVT(dAtA []byte) error

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 MessageMetaItemFromVTPool added in v1.8.12 

func MessageMetaItemFromVTPool() *MessageMetaItem

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *MessageMetaItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MessageMetaItem) MarshalToVT added in v1.8.12 

func (m *MessageMetaItem) MarshalToVT(dAtA []byte) (int, error)

func (*MessageMetaItem) MarshalVT added in v1.8.12 

func (m *MessageMetaItem) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *MessageMetaItem) ResetVT()

func (*MessageMetaItem) ReturnToVTPool added in v1.8.12 

func (m *MessageMetaItem) ReturnToVTPool()

func (*MessageMetaItem) SizeVT added in v1.8.12 

func (m *MessageMetaItem) SizeVT() (n int)

func (*MessageMetaItem) String added in v1.1.12 

func (x *MessageMetaItem) String() string

func (*MessageMetaItem) UnmarshalVT added in v1.8.12 

func (m *MessageMetaItem) UnmarshalVT(dAtA []byte) error

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"`
	CustodyGroupCount *wrapperspb.UInt64Value `protobuf:"bytes,4,opt,name=custody_group_count,proto3" json:"custody_group_count,omitempty"`
	// contains filtered or unexported fields
}

func MetadataFromVTPool added in v1.8.12 

func MetadataFromVTPool() *Metadata

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) GetCustodyGroupCount added in v1.4.15 

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

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *Metadata) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Metadata) MarshalToVT added in v1.8.12 

func (m *Metadata) MarshalToVT(dAtA []byte) (int, error)

func (*Metadata) MarshalVT added in v1.8.12 

func (m *Metadata) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *Metadata) ResetVT()

func (*Metadata) ReturnToVTPool added in v1.8.12 

func (m *Metadata) ReturnToVTPool()

func (*Metadata) SizeVT added in v1.8.12 

func (m *Metadata) SizeVT() (n int)

func (*Metadata) String added in v0.0.166 

func (x *Metadata) String() string

func (*Metadata) UnmarshalVT added in v1.8.12 

func (m *Metadata) UnmarshalVT(dAtA []byte) error

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 PeerFromVTPool added in v1.8.12 

func PeerFromVTPool() *Peer

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *Peer) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Peer) MarshalToVT added in v1.8.12 

func (m *Peer) MarshalToVT(dAtA []byte) (int, error)

func (*Peer) MarshalVT added in v1.8.12 

func (m *Peer) MarshalVT() (dAtA []byte, err error)

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) ProtoReflect 

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

func (*Peer) Reset 

func (x *Peer) Reset()

func (*Peer) ResetVT added in v1.8.12 

func (m *Peer) ResetVT()

func (*Peer) ReturnToVTPool added in v1.8.12 

func (m *Peer) ReturnToVTPool()

func (*Peer) SizeVT added in v1.8.12 

func (m *Peer) SizeVT() (n int)

func (*Peer) String 

func (x *Peer) String() string

func (*Peer) UnmarshalVT added in v1.8.12 

func (m *Peer) UnmarshalVT(dAtA []byte) error

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 PruneFromVTPool added in v1.8.12 

func PruneFromVTPool() *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) MarshalToSizedBufferVT added in v1.8.12 

func (m *Prune) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Prune) MarshalToVT added in v1.8.12 

func (m *Prune) MarshalToVT(dAtA []byte) (int, error)

func (*Prune) MarshalVT added in v1.8.12 

func (m *Prune) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *Prune) ResetVT()

func (*Prune) ReturnToVTPool added in v1.8.12 

func (m *Prune) ReturnToVTPool()

func (*Prune) SizeVT added in v1.8.12 

func (m *Prune) SizeVT() (n int)

func (*Prune) String added in v1.1.5 

func (x *Prune) String() string

func (*Prune) UnmarshalVT added in v1.8.12 

func (m *Prune) UnmarshalVT(dAtA []byte) error

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 PublishMessageFromVTPool added in v1.8.12 

func PublishMessageFromVTPool() *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) MarshalToSizedBufferVT added in v1.8.12 

func (m *PublishMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PublishMessage) MarshalToVT added in v1.8.12 

func (m *PublishMessage) MarshalToVT(dAtA []byte) (int, error)

func (*PublishMessage) MarshalVT added in v1.8.12 

func (m *PublishMessage) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *PublishMessage) ResetVT()

func (*PublishMessage) ReturnToVTPool added in v1.8.12 

func (m *PublishMessage) ReturnToVTPool()

func (*PublishMessage) SizeVT added in v1.8.12 

func (m *PublishMessage) SizeVT() (n int)

func (*PublishMessage) String added in v1.1.7 

func (x *PublishMessage) String() string

func (*PublishMessage) UnmarshalVT added in v1.8.12 

func (m *PublishMessage) UnmarshalVT(dAtA []byte) error

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 RPCMetaFromVTPool added in v1.8.12 

func RPCMetaFromVTPool() *RPCMeta

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *RPCMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RPCMeta) MarshalToVT added in v1.8.12 

func (m *RPCMeta) MarshalToVT(dAtA []byte) (int, error)

func (*RPCMeta) MarshalVT added in v1.8.12 

func (m *RPCMeta) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *RPCMeta) ResetVT()

func (*RPCMeta) ReturnToVTPool added in v1.8.12 

func (m *RPCMeta) ReturnToVTPool()

func (*RPCMeta) SizeVT added in v1.8.12 

func (m *RPCMeta) SizeVT() (n int)

func (*RPCMeta) String added in v0.0.160 

func (x *RPCMeta) String() string

func (*RPCMeta) UnmarshalVT added in v1.8.12 

func (m *RPCMeta) UnmarshalVT(dAtA []byte) error

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 RecvRPCFromVTPool added in v1.8.12 

func RecvRPCFromVTPool() *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) MarshalToSizedBufferVT added in v1.8.12 

func (m *RecvRPC) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RecvRPC) MarshalToVT added in v1.8.12 

func (m *RecvRPC) MarshalToVT(dAtA []byte) (int, error)

func (*RecvRPC) MarshalVT added in v1.8.12 

func (m *RecvRPC) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *RecvRPC) ResetVT()

func (*RecvRPC) ReturnToVTPool added in v1.8.12 

func (m *RecvRPC) ReturnToVTPool()

func (*RecvRPC) SizeVT added in v1.8.12 

func (m *RecvRPC) SizeVT() (n int)

func (*RecvRPC) String added in v0.0.160 

func (x *RecvRPC) String() string

func (*RecvRPC) UnmarshalVT added in v1.8.12 

func (m *RecvRPC) UnmarshalVT(dAtA []byte) error

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 RejectMessageFromVTPool added in v1.8.12 

func RejectMessageFromVTPool() *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) MarshalToSizedBufferVT added in v1.8.12 

func (m *RejectMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RejectMessage) MarshalToVT added in v1.8.12 

func (m *RejectMessage) MarshalToVT(dAtA []byte) (int, error)

func (*RejectMessage) MarshalVT added in v1.8.12 

func (m *RejectMessage) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *RejectMessage) ResetVT()

func (*RejectMessage) ReturnToVTPool added in v1.8.12 

func (m *RejectMessage) ReturnToVTPool()

func (*RejectMessage) SizeVT added in v1.8.12 

func (m *RejectMessage) SizeVT() (n int)

func (*RejectMessage) String added in v1.1.7 

func (x *RejectMessage) String() string

func (*RejectMessage) UnmarshalVT added in v1.8.12 

func (m *RejectMessage) UnmarshalVT(dAtA []byte) error

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 RemovePeerFromVTPool added in v1.8.12 

func RemovePeerFromVTPool() *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) MarshalToSizedBufferVT added in v1.8.12 

func (m *RemovePeer) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RemovePeer) MarshalToVT added in v1.8.12 

func (m *RemovePeer) MarshalToVT(dAtA []byte) (int, error)

func (*RemovePeer) MarshalVT added in v1.8.12 

func (m *RemovePeer) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *RemovePeer) ResetVT()

func (*RemovePeer) ReturnToVTPool added in v1.8.12 

func (m *RemovePeer) ReturnToVTPool()

func (*RemovePeer) SizeVT added in v1.8.12 

func (m *RemovePeer) SizeVT() (n int)

func (*RemovePeer) String added in v0.0.160 

func (x *RemovePeer) String() string

func (*RemovePeer) UnmarshalVT added in v1.8.12 

func (m *RemovePeer) UnmarshalVT(dAtA []byte) error

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 SendRPCFromVTPool added in v1.8.12 

func SendRPCFromVTPool() *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) MarshalToSizedBufferVT added in v1.8.12 

func (m *SendRPC) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SendRPC) MarshalToVT added in v1.8.12 

func (m *SendRPC) MarshalToVT(dAtA []byte) (int, error)

func (*SendRPC) MarshalVT added in v1.8.12 

func (m *SendRPC) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *SendRPC) ResetVT()

func (*SendRPC) ReturnToVTPool added in v1.8.12 

func (m *SendRPC) ReturnToVTPool()

func (*SendRPC) SizeVT added in v1.8.12 

func (m *SendRPC) SizeVT() (n int)

func (*SendRPC) String added in v0.0.160 

func (x *SendRPC) String() string

func (*SendRPC) UnmarshalVT added in v1.8.12 

func (m *SendRPC) UnmarshalVT(dAtA []byte) error

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"`
	EarliestAvailableSlot *wrapperspb.UInt64Value `protobuf:"bytes,6,opt,name=earliest_available_slot,proto3" json:"earliest_available_slot,omitempty"`
	// contains filtered or unexported fields
}

func StatusFromVTPool added in v1.8.12 

func StatusFromVTPool() *Status

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

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetEarliestAvailableSlot added in v1.4.15 

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

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *Status) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Status) MarshalToVT added in v1.8.12 

func (m *Status) MarshalToVT(dAtA []byte) (int, error)

func (*Status) MarshalVT added in v1.8.12 

func (m *Status) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *Status) ResetVT()

func (*Status) ReturnToVTPool added in v1.8.12 

func (m *Status) ReturnToVTPool()

func (*Status) SizeVT added in v1.8.12 

func (m *Status) SizeVT() (n int)

func (*Status) String added in v0.0.166 

func (x *Status) String() string

func (*Status) UnmarshalVT added in v1.8.12 

func (m *Status) UnmarshalVT(dAtA []byte) error

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 SubMetaFromVTPool added in v1.8.12 

func SubMetaFromVTPool() *SubMeta

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *SubMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SubMeta) MarshalToVT added in v1.8.12 

func (m *SubMeta) MarshalToVT(dAtA []byte) (int, error)

func (*SubMeta) MarshalVT added in v1.8.12 

func (m *SubMeta) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *SubMeta) ResetVT()

func (*SubMeta) ReturnToVTPool added in v1.8.12 

func (m *SubMeta) ReturnToVTPool()

func (*SubMeta) SizeVT added in v1.8.12 

func (m *SubMeta) SizeVT() (n int)

func (*SubMeta) String added in v0.0.160 

func (x *SubMeta) String() string

func (*SubMeta) UnmarshalVT added in v1.8.12 

func (m *SubMeta) UnmarshalVT(dAtA []byte) error

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 SubMetaItemFromVTPool added in v1.8.12 

func SubMetaItemFromVTPool() *SubMetaItem

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *SubMetaItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SubMetaItem) MarshalToVT added in v1.8.12 

func (m *SubMetaItem) MarshalToVT(dAtA []byte) (int, error)

func (*SubMetaItem) MarshalVT added in v1.8.12 

func (m *SubMetaItem) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *SubMetaItem) ResetVT()

func (*SubMetaItem) ReturnToVTPool added in v1.8.12 

func (m *SubMetaItem) ReturnToVTPool()

func (*SubMetaItem) SizeVT added in v1.8.12 

func (m *SubMetaItem) SizeVT() (n int)

func (*SubMetaItem) String added in v1.1.12 

func (x *SubMetaItem) String() string

func (*SubMetaItem) UnmarshalVT added in v1.8.12 

func (m *SubMetaItem) UnmarshalVT(dAtA []byte) error

type SyntheticHeartbeat added in v1.4.0 

type SyntheticHeartbeat struct {
	Timestamp       *timestamppb.Timestamp  `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	RemotePeer      *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=remote_peer,proto3" json:"remote_peer,omitempty"`
	RemoteMaddrs    *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=remote_maddrs,proto3" json:"remote_maddrs,omitempty"`
	LatencyMs       *wrapperspb.Int64Value  `protobuf:"bytes,4,opt,name=latency_ms,proto3" json:"latency_ms,omitempty"`
	AgentVersion    *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=agent_version,proto3" json:"agent_version,omitempty"`
	Direction       *wrapperspb.UInt32Value `protobuf:"bytes,6,opt,name=direction,proto3" json:"direction,omitempty"`
	Protocols       []string                `protobuf:"bytes,7,rep,name=protocols,proto3" json:"protocols,omitempty"`
	ConnectionAgeNs *wrapperspb.Int64Value  `protobuf:"bytes,8,opt,name=connection_age_ns,proto3" json:"connection_age_ns,omitempty"`
	// contains filtered or unexported fields
}

func SyntheticHeartbeatFromVTPool added in v1.8.12 

func SyntheticHeartbeatFromVTPool() *SyntheticHeartbeat

func (*SyntheticHeartbeat) Descriptor deprecated added in v1.4.0 

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

Deprecated: Use SyntheticHeartbeat.ProtoReflect.Descriptor instead.

func (*SyntheticHeartbeat) GetAgentVersion added in v1.4.0 

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

func (*SyntheticHeartbeat) GetConnectionAgeNs added in v1.4.0 

func (x *SyntheticHeartbeat) GetConnectionAgeNs() *wrapperspb.Int64Value

func (*SyntheticHeartbeat) GetDirection added in v1.4.0 

func (x *SyntheticHeartbeat) GetDirection() *wrapperspb.UInt32Value

func (*SyntheticHeartbeat) GetLatencyMs added in v1.4.0 

func (x *SyntheticHeartbeat) GetLatencyMs() *wrapperspb.Int64Value

func (*SyntheticHeartbeat) GetProtocols added in v1.4.0 

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

func (*SyntheticHeartbeat) GetRemoteMaddrs added in v1.4.0 

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

func (*SyntheticHeartbeat) GetRemotePeer added in v1.4.0 

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

func (*SyntheticHeartbeat) GetTimestamp added in v1.4.0 

func (x *SyntheticHeartbeat) GetTimestamp() *timestamppb.Timestamp

func (*SyntheticHeartbeat) MarshalToSizedBufferVT added in v1.8.12 

func (m *SyntheticHeartbeat) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SyntheticHeartbeat) MarshalToVT added in v1.8.12 

func (m *SyntheticHeartbeat) MarshalToVT(dAtA []byte) (int, error)

func (*SyntheticHeartbeat) MarshalVT added in v1.8.12 

func (m *SyntheticHeartbeat) MarshalVT() (dAtA []byte, err error)

func (*SyntheticHeartbeat) ProtoMessage added in v1.4.0 

func (*SyntheticHeartbeat) ProtoMessage()

func (*SyntheticHeartbeat) ProtoReflect added in v1.4.0 

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

func (*SyntheticHeartbeat) Reset added in v1.4.0 

func (x *SyntheticHeartbeat) Reset()

func (*SyntheticHeartbeat) ResetVT added in v1.8.12 

func (m *SyntheticHeartbeat) ResetVT()

func (*SyntheticHeartbeat) ReturnToVTPool added in v1.8.12 

func (m *SyntheticHeartbeat) ReturnToVTPool()

func (*SyntheticHeartbeat) SizeVT added in v1.8.12 

func (m *SyntheticHeartbeat) SizeVT() (n int)

func (*SyntheticHeartbeat) String added in v1.4.0 

func (x *SyntheticHeartbeat) String() string

func (*SyntheticHeartbeat) UnmarshalVT added in v1.8.12 

func (m *SyntheticHeartbeat) UnmarshalVT(dAtA []byte) error

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 TraceEventMetadataFromVTPool added in v1.8.12 

func TraceEventMetadataFromVTPool() *TraceEventMetadata

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) MarshalToSizedBufferVT added in v1.8.12 

func (m *TraceEventMetadata) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TraceEventMetadata) MarshalToVT added in v1.8.12 

func (m *TraceEventMetadata) MarshalToVT(dAtA []byte) (int, error)

func (*TraceEventMetadata) MarshalVT added in v1.8.12 

func (m *TraceEventMetadata) MarshalVT() (dAtA []byte, err error)

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) ResetVT added in v1.8.12 

func (m *TraceEventMetadata) ResetVT()

func (*TraceEventMetadata) ReturnToVTPool added in v1.8.12 

func (m *TraceEventMetadata) ReturnToVTPool()

func (*TraceEventMetadata) SizeVT added in v1.8.12 

func (m *TraceEventMetadata) SizeVT() (n int)

func (*TraceEventMetadata) String added in v0.0.160 

func (x *TraceEventMetadata) String() string

func (*TraceEventMetadata) UnmarshalVT added in v1.8.12 

func (m *TraceEventMetadata) UnmarshalVT(dAtA []byte) error

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.