pb

package
Version: v0.9.0 Latest Latest
Warning

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

Go to latest
Published: Jul 23, 2021 License: Apache-2.0, MIT, Apache-2.0, MIT Imports: 5 Imported by: 2

Documentation

Overview

Package introspection/pb contains the protobuf definitions and objects for that form the libp2p introspection protocol.

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthIntrospection        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIntrospection          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupIntrospection = fmt.Errorf("proto: unexpected end of group")
)
View Source
var ClientCommand_Command_name = map[int32]string{
	0: "HELLO",
	1: "REQUEST",
	2: "PUSH_ENABLE",
	3: "PUSH_DISABLE",
	4: "PUSH_PAUSE",
	5: "PUSH_RESUME",
	7: "UPDATE_CONFIG",
}
View Source
var ClientCommand_Command_value = map[string]int32{
	"HELLO":         0,
	"REQUEST":       1,
	"PUSH_ENABLE":   2,
	"PUSH_DISABLE":  3,
	"PUSH_PAUSE":    4,
	"PUSH_RESUME":   5,
	"UPDATE_CONFIG": 7,
}
View Source
var ClientCommand_Source_name = map[int32]string{
	0: "STATE",
	1: "RUNTIME",
	2: "EVENTS",
}
View Source
var ClientCommand_Source_value = map[string]int32{
	"STATE":   0,
	"RUNTIME": 1,
	"EVENTS":  2,
}
View Source
var CommandResponse_Result_name = map[int32]string{
	0: "OK",
	1: "ERR",
}
View Source
var CommandResponse_Result_value = map[string]int32{
	"OK":  0,
	"ERR": 1,
}
View Source
var DHT_PeerInDHT_Status_name = map[int32]string{
	0: "ACTIVE",
	1: "MISSING",
	2: "REJECTED",
	3: "CANDIDATE",
}
View Source
var DHT_PeerInDHT_Status_value = map[string]int32{
	"ACTIVE":    0,
	"MISSING":   1,
	"REJECTED":  2,
	"CANDIDATE": 3,
}
View Source
var EventType_EventProperty_PropertyType_name = map[int32]string{
	0:  "STRING",
	1:  "NUMBER",
	10: "TIME",
	11: "PEERID",
	12: "MULTIADDR",
	90: "JSON",
}
View Source
var EventType_EventProperty_PropertyType_value = map[string]int32{
	"STRING":    0,
	"NUMBER":    1,
	"TIME":      10,
	"PEERID":    11,
	"MULTIADDR": 12,
	"JSON":      90,
}
View Source
var Role_name = map[int32]string{
	0: "INITIATOR",
	1: "RESPONDER",
}
View Source
var Role_value = map[string]int32{
	"INITIATOR": 0,
	"RESPONDER": 1,
}
View Source
var ServerNotice_Kind_name = map[int32]string{
	0: "DISCARDING_EVENTS",
}
View Source
var ServerNotice_Kind_value = map[string]int32{
	"DISCARDING_EVENTS": 0,
}
View Source
var Status_name = map[int32]string{
	0: "ACTIVE",
	1: "CLOSED",
	2: "OPENING",
	3: "CLOSING",
	4: "ERROR",
}
View Source
var Status_value = map[string]int32{
	"ACTIVE":  0,
	"CLOSED":  1,
	"OPENING": 2,
	"CLOSING": 3,
	"ERROR":   4,
}

Functions

This section is empty.

Types

type ClientCommand

type ClientCommand struct {
	Version *Version              `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Id      uint64                `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Command ClientCommand_Command `protobuf:"varint,3,opt,name=command,proto3,enum=pb.ClientCommand_Command" json:"command,omitempty"`
	Source  ClientCommand_Source  `protobuf:"varint,4,opt,name=source,proto3,enum=pb.ClientCommand_Source" json:"source,omitempty"`
	Config  *Configuration        `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"`
}

ClientCommand is a command sent from the client to the server.

func (*ClientCommand) Descriptor

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

func (*ClientCommand) GetCommand

func (m *ClientCommand) GetCommand() ClientCommand_Command

func (*ClientCommand) GetConfig

func (m *ClientCommand) GetConfig() *Configuration

func (*ClientCommand) GetId

func (m *ClientCommand) GetId() uint64

func (*ClientCommand) GetSource

func (m *ClientCommand) GetSource() ClientCommand_Source

func (*ClientCommand) GetVersion

func (m *ClientCommand) GetVersion() *Version

func (*ClientCommand) Marshal

func (m *ClientCommand) Marshal() (dAtA []byte, err error)

func (*ClientCommand) MarshalTo

func (m *ClientCommand) MarshalTo(dAtA []byte) (int, error)

func (*ClientCommand) MarshalToSizedBuffer

func (m *ClientCommand) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientCommand) ProtoMessage

func (*ClientCommand) ProtoMessage()

func (*ClientCommand) Reset

func (m *ClientCommand) Reset()

func (*ClientCommand) Size

func (m *ClientCommand) Size() (n int)

func (*ClientCommand) String

func (m *ClientCommand) String() string

func (*ClientCommand) Unmarshal

func (m *ClientCommand) Unmarshal(dAtA []byte) error

func (*ClientCommand) XXX_DiscardUnknown

func (m *ClientCommand) XXX_DiscardUnknown()

func (*ClientCommand) XXX_Marshal

func (m *ClientCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientCommand) XXX_Merge

func (m *ClientCommand) XXX_Merge(src proto.Message)

func (*ClientCommand) XXX_Size

func (m *ClientCommand) XXX_Size() int

func (*ClientCommand) XXX_Unmarshal

func (m *ClientCommand) XXX_Unmarshal(b []byte) error

type ClientCommand_Command

type ClientCommand_Command int32
const (
	// HELLO is the first command that a client must send to greet the server.
	// Connections that do not respect this invariant will be terminated.
	ClientCommand_HELLO ClientCommand_Command = 0
	// REQUEST is applicable to STATE and RUNTIME sources.
	ClientCommand_REQUEST ClientCommand_Command = 1
	// PUSH streams can only be started for STATE and EVENTS sources.
	ClientCommand_PUSH_ENABLE  ClientCommand_Command = 2
	ClientCommand_PUSH_DISABLE ClientCommand_Command = 3
	ClientCommand_PUSH_PAUSE   ClientCommand_Command = 4
	ClientCommand_PUSH_RESUME  ClientCommand_Command = 5
	// UPDATE_CONFIG requests a configuration update. The config field is
	// compulsory.
	//
	// The server reserves the right to override the requested values, and
	// will return the effective configuration in the response.
	ClientCommand_UPDATE_CONFIG ClientCommand_Command = 7
)

func (ClientCommand_Command) EnumDescriptor

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

func (ClientCommand_Command) String

func (x ClientCommand_Command) String() string

type ClientCommand_Source

type ClientCommand_Source int32
const (
	ClientCommand_STATE   ClientCommand_Source = 0
	ClientCommand_RUNTIME ClientCommand_Source = 1
	ClientCommand_EVENTS  ClientCommand_Source = 2
)

func (ClientCommand_Source) EnumDescriptor

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

func (ClientCommand_Source) String

func (x ClientCommand_Source) String() string

type CommandResponse

type CommandResponse struct {
	Id     uint64                 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Result CommandResponse_Result `protobuf:"varint,2,opt,name=result,proto3,enum=pb.CommandResponse_Result" json:"result,omitempty"`
	Error  string                 `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// effective_config is the effective configuration the server holds for
	// this connection. It is returned in response to HELLO and UPDATE_CONFIG
	// commands.
	EffectiveConfig *Configuration `protobuf:"bytes,4,opt,name=effective_config,json=effectiveConfig,proto3" json:"effective_config,omitempty"`
}

CommandResponse is a response to a command sent by the client.

func (*CommandResponse) Descriptor

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

func (*CommandResponse) GetEffectiveConfig

func (m *CommandResponse) GetEffectiveConfig() *Configuration

func (*CommandResponse) GetError

func (m *CommandResponse) GetError() string

func (*CommandResponse) GetId

func (m *CommandResponse) GetId() uint64

func (*CommandResponse) GetResult

func (m *CommandResponse) GetResult() CommandResponse_Result

func (*CommandResponse) Marshal

func (m *CommandResponse) Marshal() (dAtA []byte, err error)

func (*CommandResponse) MarshalTo

func (m *CommandResponse) MarshalTo(dAtA []byte) (int, error)

func (*CommandResponse) MarshalToSizedBuffer

func (m *CommandResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommandResponse) ProtoMessage

func (*CommandResponse) ProtoMessage()

func (*CommandResponse) Reset

func (m *CommandResponse) Reset()

func (*CommandResponse) Size

func (m *CommandResponse) Size() (n int)

func (*CommandResponse) String

func (m *CommandResponse) String() string

func (*CommandResponse) Unmarshal

func (m *CommandResponse) Unmarshal(dAtA []byte) error

func (*CommandResponse) XXX_DiscardUnknown

func (m *CommandResponse) XXX_DiscardUnknown()

func (*CommandResponse) XXX_Marshal

func (m *CommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandResponse) XXX_Merge

func (m *CommandResponse) XXX_Merge(src proto.Message)

func (*CommandResponse) XXX_Size

func (m *CommandResponse) XXX_Size() int

func (*CommandResponse) XXX_Unmarshal

func (m *CommandResponse) XXX_Unmarshal(b []byte) error

type CommandResponse_Result

type CommandResponse_Result int32
const (
	CommandResponse_OK  CommandResponse_Result = 0
	CommandResponse_ERR CommandResponse_Result = 1
)

func (CommandResponse_Result) EnumDescriptor

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

func (CommandResponse_Result) String

func (x CommandResponse_Result) String() string

type Configuration

type Configuration struct {
	RetentionPeriodMs       uint64 `protobuf:"varint,1,opt,name=retention_period_ms,json=retentionPeriodMs,proto3" json:"retention_period_ms,omitempty"`
	StateSnapshotIntervalMs uint64 `` /* 135-byte string literal not displayed */
}

Configuration encapsulates configuration fields for the protocol and commands.

func (*Configuration) Descriptor

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

func (*Configuration) GetRetentionPeriodMs

func (m *Configuration) GetRetentionPeriodMs() uint64

func (*Configuration) GetStateSnapshotIntervalMs

func (m *Configuration) GetStateSnapshotIntervalMs() uint64

func (*Configuration) Marshal

func (m *Configuration) Marshal() (dAtA []byte, err error)

func (*Configuration) MarshalTo

func (m *Configuration) MarshalTo(dAtA []byte) (int, error)

func (*Configuration) MarshalToSizedBuffer

func (m *Configuration) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Configuration) ProtoMessage

func (*Configuration) ProtoMessage()

func (*Configuration) Reset

func (m *Configuration) Reset()

func (*Configuration) Size

func (m *Configuration) Size() (n int)

func (*Configuration) String

func (m *Configuration) String() string

func (*Configuration) Unmarshal

func (m *Configuration) Unmarshal(dAtA []byte) error

func (*Configuration) XXX_DiscardUnknown

func (m *Configuration) XXX_DiscardUnknown()

func (*Configuration) XXX_Marshal

func (m *Configuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Configuration) XXX_Merge

func (m *Configuration) XXX_Merge(src proto.Message)

func (*Configuration) XXX_Size

func (m *Configuration) XXX_Size() int

func (*Configuration) XXX_Unmarshal

func (m *Configuration) XXX_Unmarshal(b []byte) error

type Connection

type Connection struct {
	// the id of this connection, not to be shown in user tooling,
	// used for (cross)referencing connections (e.g. relay).
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// the peer id of the other party.
	PeerId string `protobuf:"bytes,2,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// the status of this connection.
	Status Status `protobuf:"varint,3,opt,name=status,proto3,enum=pb.Status" json:"status,omitempty"`
	// a reference to the transport managing this connection.
	TransportId []byte `protobuf:"bytes,4,opt,name=transport_id,json=transportId,proto3" json:"transport_id,omitempty"`
	// the endpoints participating in this connection.
	Endpoints *EndpointPair `protobuf:"bytes,5,opt,name=endpoints,proto3" json:"endpoints,omitempty"`
	// the timeline of the connection, see Connection.Timeline.
	Timeline *Connection_Timeline `protobuf:"bytes,6,opt,name=timeline,proto3" json:"timeline,omitempty"`
	// our role in this connection.
	Role Role `protobuf:"varint,7,opt,name=role,proto3,enum=pb.Role" json:"role,omitempty"`
	// traffic statistics.
	Traffic *Traffic `protobuf:"bytes,8,opt,name=traffic,proto3" json:"traffic,omitempty"`
	// properties of this connection.
	Attribs *Connection_Attributes `protobuf:"bytes,9,opt,name=attribs,proto3" json:"attribs,omitempty"`
	// the instantaneous latency of this connection in nanoseconds.
	LatencyNs uint64 `protobuf:"varint,10,opt,name=latency_ns,json=latencyNs,proto3" json:"latency_ns,omitempty"`
	// streams within this connection.
	Streams *StreamList `protobuf:"bytes,11,opt,name=streams,proto3" json:"streams,omitempty"`
	// if this is a relayed connection, this points to the relaying connection.
	// a default value here (empty bytes) indicates this is not a relayed connection.
	//
	// Types that are valid to be assigned to RelayedOver:
	//	*Connection_ConnId
	//	*Connection_Conn
	RelayedOver isConnection_RelayedOver `protobuf_oneof:"relayed_over"`
	// user provided tags.
	UserProvidedTags []string `protobuf:"bytes,99,rep,name=user_provided_tags,json=userProvidedTags,proto3" json:"user_provided_tags,omitempty"`
}

Connection reports metrics and state of a libp2p connection.

func (*Connection) Descriptor

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

func (*Connection) GetAttribs

func (m *Connection) GetAttribs() *Connection_Attributes

func (*Connection) GetConn

func (m *Connection) GetConn() *Connection

func (*Connection) GetConnId

func (m *Connection) GetConnId() []byte

func (*Connection) GetEndpoints

func (m *Connection) GetEndpoints() *EndpointPair

func (*Connection) GetId

func (m *Connection) GetId() []byte

func (*Connection) GetLatencyNs

func (m *Connection) GetLatencyNs() uint64

func (*Connection) GetPeerId

func (m *Connection) GetPeerId() string

func (*Connection) GetRelayedOver

func (m *Connection) GetRelayedOver() isConnection_RelayedOver

func (*Connection) GetRole

func (m *Connection) GetRole() Role

func (*Connection) GetStatus

func (m *Connection) GetStatus() Status

func (*Connection) GetStreams

func (m *Connection) GetStreams() *StreamList

func (*Connection) GetTimeline

func (m *Connection) GetTimeline() *Connection_Timeline

func (*Connection) GetTraffic

func (m *Connection) GetTraffic() *Traffic

func (*Connection) GetTransportId

func (m *Connection) GetTransportId() []byte

func (*Connection) GetUserProvidedTags

func (m *Connection) GetUserProvidedTags() []string

func (*Connection) Marshal

func (m *Connection) Marshal() (dAtA []byte, err error)

func (*Connection) MarshalTo

func (m *Connection) MarshalTo(dAtA []byte) (int, error)

func (*Connection) MarshalToSizedBuffer

func (m *Connection) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Connection) ProtoMessage

func (*Connection) ProtoMessage()

func (*Connection) Reset

func (m *Connection) Reset()

func (*Connection) Size

func (m *Connection) Size() (n int)

func (*Connection) String

func (m *Connection) String() string

func (*Connection) Unmarshal

func (m *Connection) Unmarshal(dAtA []byte) error

func (*Connection) XXX_DiscardUnknown

func (m *Connection) XXX_DiscardUnknown()

func (*Connection) XXX_Marshal

func (m *Connection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Connection) XXX_Merge

func (m *Connection) XXX_Merge(src proto.Message)

func (*Connection) XXX_OneofWrappers

func (*Connection) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Connection) XXX_Size

func (m *Connection) XXX_Size() int

func (*Connection) XXX_Unmarshal

func (m *Connection) XXX_Unmarshal(b []byte) error

type Connection_Attributes

type Connection_Attributes struct {
	// the multiplexer being used.
	Multiplexer string `protobuf:"bytes,1,opt,name=multiplexer,proto3" json:"multiplexer,omitempty"`
	// the encryption method being used.
	Encryption string `protobuf:"bytes,2,opt,name=encryption,proto3" json:"encryption,omitempty"`
}

Attributes encapsulates the attributes of this connection.

func (*Connection_Attributes) Descriptor

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

func (*Connection_Attributes) GetEncryption

func (m *Connection_Attributes) GetEncryption() string

func (*Connection_Attributes) GetMultiplexer

func (m *Connection_Attributes) GetMultiplexer() string

func (*Connection_Attributes) Marshal

func (m *Connection_Attributes) Marshal() (dAtA []byte, err error)

func (*Connection_Attributes) MarshalTo

func (m *Connection_Attributes) MarshalTo(dAtA []byte) (int, error)

func (*Connection_Attributes) MarshalToSizedBuffer

func (m *Connection_Attributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Connection_Attributes) ProtoMessage

func (*Connection_Attributes) ProtoMessage()

func (*Connection_Attributes) Reset

func (m *Connection_Attributes) Reset()

func (*Connection_Attributes) Size

func (m *Connection_Attributes) Size() (n int)

func (*Connection_Attributes) String

func (m *Connection_Attributes) String() string

func (*Connection_Attributes) Unmarshal

func (m *Connection_Attributes) Unmarshal(dAtA []byte) error

func (*Connection_Attributes) XXX_DiscardUnknown

func (m *Connection_Attributes) XXX_DiscardUnknown()

func (*Connection_Attributes) XXX_Marshal

func (m *Connection_Attributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Connection_Attributes) XXX_Merge

func (m *Connection_Attributes) XXX_Merge(src proto.Message)

func (*Connection_Attributes) XXX_Size

func (m *Connection_Attributes) XXX_Size() int

func (*Connection_Attributes) XXX_Unmarshal

func (m *Connection_Attributes) XXX_Unmarshal(b []byte) error

type Connection_Conn

type Connection_Conn struct {
	Conn *Connection `protobuf:"bytes,17,opt,name=conn,proto3,oneof" json:"conn,omitempty"`
}

func (*Connection_Conn) MarshalTo

func (m *Connection_Conn) MarshalTo(dAtA []byte) (int, error)

func (*Connection_Conn) MarshalToSizedBuffer

func (m *Connection_Conn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Connection_Conn) Size

func (m *Connection_Conn) Size() (n int)

type Connection_ConnId

type Connection_ConnId struct {
	ConnId []byte `protobuf:"bytes,16,opt,name=conn_id,json=connId,proto3,oneof" json:"conn_id,omitempty"`
}

func (*Connection_ConnId) MarshalTo

func (m *Connection_ConnId) MarshalTo(dAtA []byte) (int, error)

func (*Connection_ConnId) MarshalToSizedBuffer

func (m *Connection_ConnId) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Connection_ConnId) Size

func (m *Connection_ConnId) Size() (n int)

type Connection_Timeline

type Connection_Timeline struct {
	// the instant when a connection was opened on the wire.
	OpenTs uint64 `protobuf:"varint,1,opt,name=open_ts,json=openTs,proto3" json:"open_ts,omitempty"`
	// the instant when the upgrade process (handshake, security, multiplexing) finished.
	UpgradedTs uint64 `protobuf:"varint,2,opt,name=upgraded_ts,json=upgradedTs,proto3" json:"upgraded_ts,omitempty"`
	// the instant when this connection was terminated.
	CloseTs uint64 `protobuf:"varint,3,opt,name=close_ts,json=closeTs,proto3" json:"close_ts,omitempty"`
}

Timeline contains the timestamps (ms since epoch) of the well-known milestones of a connection.

func (*Connection_Timeline) Descriptor

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

func (*Connection_Timeline) GetCloseTs

func (m *Connection_Timeline) GetCloseTs() uint64

func (*Connection_Timeline) GetOpenTs

func (m *Connection_Timeline) GetOpenTs() uint64

func (*Connection_Timeline) GetUpgradedTs

func (m *Connection_Timeline) GetUpgradedTs() uint64

func (*Connection_Timeline) Marshal

func (m *Connection_Timeline) Marshal() (dAtA []byte, err error)

func (*Connection_Timeline) MarshalTo

func (m *Connection_Timeline) MarshalTo(dAtA []byte) (int, error)

func (*Connection_Timeline) MarshalToSizedBuffer

func (m *Connection_Timeline) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Connection_Timeline) ProtoMessage

func (*Connection_Timeline) ProtoMessage()

func (*Connection_Timeline) Reset

func (m *Connection_Timeline) Reset()

func (*Connection_Timeline) Size

func (m *Connection_Timeline) Size() (n int)

func (*Connection_Timeline) String

func (m *Connection_Timeline) String() string

func (*Connection_Timeline) Unmarshal

func (m *Connection_Timeline) Unmarshal(dAtA []byte) error

func (*Connection_Timeline) XXX_DiscardUnknown

func (m *Connection_Timeline) XXX_DiscardUnknown()

func (*Connection_Timeline) XXX_Marshal

func (m *Connection_Timeline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Connection_Timeline) XXX_Merge

func (m *Connection_Timeline) XXX_Merge(src proto.Message)

func (*Connection_Timeline) XXX_Size

func (m *Connection_Timeline) XXX_Size() int

func (*Connection_Timeline) XXX_Unmarshal

func (m *Connection_Timeline) XXX_Unmarshal(b []byte) error

type DHT

type DHT struct {
	// DHT protocol name
	Protocol string `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// protocol enabled.
	Enabled bool `protobuf:"varint,2,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// timestamp (ms since epoch) of start up.
	StartTs uint64 `protobuf:"varint,3,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	// params of the dht.
	Params *DHT_Params `protobuf:"bytes,4,opt,name=params,proto3" json:"params,omitempty"`
	// existing, intantiated buckets and their contents
	Buckets []*DHT_Bucket `protobuf:"bytes,5,rep,name=buckets,proto3" json:"buckets,omitempty"`
	// counts inbound queries received from other peers
	IncomingQueries *DHT_QueryGauge `protobuf:"bytes,6,opt,name=incoming_queries,json=incomingQueries,proto3" json:"incoming_queries,omitempty"`
	// counts outbound queries dispatched by this peer
	OutgoingQueries *DHT_QueryGauge `protobuf:"bytes,7,opt,name=outgoing_queries,json=outgoingQueries,proto3" json:"outgoing_queries,omitempty"`
}

DHT metrics and state.

func (*DHT) Descriptor

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

func (*DHT) GetBuckets

func (m *DHT) GetBuckets() []*DHT_Bucket

func (*DHT) GetEnabled

func (m *DHT) GetEnabled() bool

func (*DHT) GetIncomingQueries

func (m *DHT) GetIncomingQueries() *DHT_QueryGauge

func (*DHT) GetOutgoingQueries

func (m *DHT) GetOutgoingQueries() *DHT_QueryGauge

func (*DHT) GetParams

func (m *DHT) GetParams() *DHT_Params

func (*DHT) GetProtocol

func (m *DHT) GetProtocol() string

func (*DHT) GetStartTs

func (m *DHT) GetStartTs() uint64

func (*DHT) Marshal

func (m *DHT) Marshal() (dAtA []byte, err error)

func (*DHT) MarshalTo

func (m *DHT) MarshalTo(dAtA []byte) (int, error)

func (*DHT) MarshalToSizedBuffer

func (m *DHT) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DHT) ProtoMessage

func (*DHT) ProtoMessage()

func (*DHT) Reset

func (m *DHT) Reset()

func (*DHT) Size

func (m *DHT) Size() (n int)

func (*DHT) String

func (m *DHT) String() string

func (*DHT) Unmarshal

func (m *DHT) Unmarshal(dAtA []byte) error

func (*DHT) XXX_DiscardUnknown

func (m *DHT) XXX_DiscardUnknown()

func (*DHT) XXX_Marshal

func (m *DHT) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DHT) XXX_Merge

func (m *DHT) XXX_Merge(src proto.Message)

func (*DHT) XXX_Size

func (m *DHT) XXX_Size() int

func (*DHT) XXX_Unmarshal

func (m *DHT) XXX_Unmarshal(b []byte) error

type DHT_Bucket

type DHT_Bucket struct {
	// CPL (Common Prefix Length) is the length of the common prefix
	// between the ids of every peer in this bucket and the DHT peer id
	Cpl uint32 `protobuf:"varint,1,opt,name=cpl,proto3" json:"cpl,omitempty"`
	// Peers associated with this bucket
	Peers []*DHT_PeerInDHT `protobuf:"bytes,2,rep,name=peers,proto3" json:"peers,omitempty"`
}

A "k-bucket" containing peers of a certain kadamelia distance

func (*DHT_Bucket) Descriptor

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

func (*DHT_Bucket) GetCpl

func (m *DHT_Bucket) GetCpl() uint32

func (*DHT_Bucket) GetPeers

func (m *DHT_Bucket) GetPeers() []*DHT_PeerInDHT

func (*DHT_Bucket) Marshal

func (m *DHT_Bucket) Marshal() (dAtA []byte, err error)

func (*DHT_Bucket) MarshalTo

func (m *DHT_Bucket) MarshalTo(dAtA []byte) (int, error)

func (*DHT_Bucket) MarshalToSizedBuffer

func (m *DHT_Bucket) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DHT_Bucket) ProtoMessage

func (*DHT_Bucket) ProtoMessage()

func (*DHT_Bucket) Reset

func (m *DHT_Bucket) Reset()

func (*DHT_Bucket) Size

func (m *DHT_Bucket) Size() (n int)

func (*DHT_Bucket) String

func (m *DHT_Bucket) String() string

func (*DHT_Bucket) Unmarshal

func (m *DHT_Bucket) Unmarshal(dAtA []byte) error

func (*DHT_Bucket) XXX_DiscardUnknown

func (m *DHT_Bucket) XXX_DiscardUnknown()

func (*DHT_Bucket) XXX_Marshal

func (m *DHT_Bucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DHT_Bucket) XXX_Merge

func (m *DHT_Bucket) XXX_Merge(src proto.Message)

func (*DHT_Bucket) XXX_Size

func (m *DHT_Bucket) XXX_Size() int

func (*DHT_Bucket) XXX_Unmarshal

func (m *DHT_Bucket) XXX_Unmarshal(b []byte) error

type DHT_Params

type DHT_Params struct {
	// routing table bucket size.
	K uint64 `protobuf:"varint,1,opt,name=k,proto3" json:"k,omitempty"`
	// concurrency of asynchronous requests.
	Alpha uint64 `protobuf:"varint,2,opt,name=alpha,proto3" json:"alpha,omitempty"`
	// number of disjoint paths to use.
	DisjointPaths uint64 `protobuf:"varint,3,opt,name=disjoint_paths,json=disjointPaths,proto3" json:"disjoint_paths,omitempty"`
	// number of peers closest to a target that must have responded
	// in order for a given query path to complete
	Beta uint64 `protobuf:"varint,4,opt,name=beta,proto3" json:"beta,omitempty"`
}

func (*DHT_Params) Descriptor

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

func (*DHT_Params) GetAlpha

func (m *DHT_Params) GetAlpha() uint64

func (*DHT_Params) GetBeta

func (m *DHT_Params) GetBeta() uint64

func (*DHT_Params) GetDisjointPaths

func (m *DHT_Params) GetDisjointPaths() uint64

func (*DHT_Params) GetK

func (m *DHT_Params) GetK() uint64

func (*DHT_Params) Marshal

func (m *DHT_Params) Marshal() (dAtA []byte, err error)

func (*DHT_Params) MarshalTo

func (m *DHT_Params) MarshalTo(dAtA []byte) (int, error)

func (*DHT_Params) MarshalToSizedBuffer

func (m *DHT_Params) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DHT_Params) ProtoMessage

func (*DHT_Params) ProtoMessage()

func (*DHT_Params) Reset

func (m *DHT_Params) Reset()

func (*DHT_Params) Size

func (m *DHT_Params) Size() (n int)

func (*DHT_Params) String

func (m *DHT_Params) String() string

func (*DHT_Params) Unmarshal

func (m *DHT_Params) Unmarshal(dAtA []byte) error

func (*DHT_Params) XXX_DiscardUnknown

func (m *DHT_Params) XXX_DiscardUnknown()

func (*DHT_Params) XXX_Marshal

func (m *DHT_Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DHT_Params) XXX_Merge

func (m *DHT_Params) XXX_Merge(src proto.Message)

func (*DHT_Params) XXX_Size

func (m *DHT_Params) XXX_Size() int

func (*DHT_Params) XXX_Unmarshal

func (m *DHT_Params) XXX_Unmarshal(b []byte) error

type DHT_PeerInDHT

type DHT_PeerInDHT struct {
	// the peer id of the host system
	PeerId string `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// the peer's status when data snapshot is taken
	Status DHT_PeerInDHT_Status `protobuf:"varint,2,opt,name=status,proto3,enum=pb.DHT_PeerInDHT_Status" json:"status,omitempty"`
	// age in bucket (ms)
	AgeInBucket uint32 `protobuf:"varint,3,opt,name=age_in_bucket,json=ageInBucket,proto3" json:"age_in_bucket,omitempty"`
}

Peer in DHT

func (*DHT_PeerInDHT) Descriptor

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

func (*DHT_PeerInDHT) GetAgeInBucket

func (m *DHT_PeerInDHT) GetAgeInBucket() uint32

func (*DHT_PeerInDHT) GetPeerId

func (m *DHT_PeerInDHT) GetPeerId() string

func (*DHT_PeerInDHT) GetStatus

func (m *DHT_PeerInDHT) GetStatus() DHT_PeerInDHT_Status

func (*DHT_PeerInDHT) Marshal

func (m *DHT_PeerInDHT) Marshal() (dAtA []byte, err error)

func (*DHT_PeerInDHT) MarshalTo

func (m *DHT_PeerInDHT) MarshalTo(dAtA []byte) (int, error)

func (*DHT_PeerInDHT) MarshalToSizedBuffer

func (m *DHT_PeerInDHT) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DHT_PeerInDHT) ProtoMessage

func (*DHT_PeerInDHT) ProtoMessage()

func (*DHT_PeerInDHT) Reset

func (m *DHT_PeerInDHT) Reset()

func (*DHT_PeerInDHT) Size

func (m *DHT_PeerInDHT) Size() (n int)

func (*DHT_PeerInDHT) String

func (m *DHT_PeerInDHT) String() string

func (*DHT_PeerInDHT) Unmarshal

func (m *DHT_PeerInDHT) Unmarshal(dAtA []byte) error

func (*DHT_PeerInDHT) XXX_DiscardUnknown

func (m *DHT_PeerInDHT) XXX_DiscardUnknown()

func (*DHT_PeerInDHT) XXX_Marshal

func (m *DHT_PeerInDHT) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DHT_PeerInDHT) XXX_Merge

func (m *DHT_PeerInDHT) XXX_Merge(src proto.Message)

func (*DHT_PeerInDHT) XXX_Size

func (m *DHT_PeerInDHT) XXX_Size() int

func (*DHT_PeerInDHT) XXX_Unmarshal

func (m *DHT_PeerInDHT) XXX_Unmarshal(b []byte) error

type DHT_PeerInDHT_Status

type DHT_PeerInDHT_Status int32

The DHT's relationship with this peer

const (
	// Connected, in a bucket, ready to send/receive queries
	DHT_PeerInDHT_ACTIVE DHT_PeerInDHT_Status = 0
	// Not currently connected, still "in" a bucket (e.g. temporarily disconnected)
	DHT_PeerInDHT_MISSING DHT_PeerInDHT_Status = 1
	// Removed from a bucket or candidate list (e.g. connection lost or too slow)
	DHT_PeerInDHT_REJECTED DHT_PeerInDHT_Status = 2
	// Was reachable when last checked, waiting to join a currently-full bucket
	DHT_PeerInDHT_CANDIDATE DHT_PeerInDHT_Status = 3
)

func (DHT_PeerInDHT_Status) EnumDescriptor

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

func (DHT_PeerInDHT_Status) String

func (x DHT_PeerInDHT_Status) String() string

type DHT_QueryGauge

type DHT_QueryGauge struct {
	// Cumulative counter of queries with "SUCCESS" status
	Success uint64 `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Cumulative counter of queries with "ERROR" status
	Error uint64 `protobuf:"varint,2,opt,name=error,proto3" json:"error,omitempty"`
	// Cumulative counter of queries with "TIMEOUT" status
	Timeout uint64 `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
}

Counters of query events, by status

func (*DHT_QueryGauge) Descriptor

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

func (*DHT_QueryGauge) GetError

func (m *DHT_QueryGauge) GetError() uint64

func (*DHT_QueryGauge) GetSuccess

func (m *DHT_QueryGauge) GetSuccess() uint64

func (*DHT_QueryGauge) GetTimeout

func (m *DHT_QueryGauge) GetTimeout() uint64

func (*DHT_QueryGauge) Marshal

func (m *DHT_QueryGauge) Marshal() (dAtA []byte, err error)

func (*DHT_QueryGauge) MarshalTo

func (m *DHT_QueryGauge) MarshalTo(dAtA []byte) (int, error)

func (*DHT_QueryGauge) MarshalToSizedBuffer

func (m *DHT_QueryGauge) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DHT_QueryGauge) ProtoMessage

func (*DHT_QueryGauge) ProtoMessage()

func (*DHT_QueryGauge) Reset

func (m *DHT_QueryGauge) Reset()

func (*DHT_QueryGauge) Size

func (m *DHT_QueryGauge) Size() (n int)

func (*DHT_QueryGauge) String

func (m *DHT_QueryGauge) String() string

func (*DHT_QueryGauge) Unmarshal

func (m *DHT_QueryGauge) Unmarshal(dAtA []byte) error

func (*DHT_QueryGauge) XXX_DiscardUnknown

func (m *DHT_QueryGauge) XXX_DiscardUnknown()

func (*DHT_QueryGauge) XXX_Marshal

func (m *DHT_QueryGauge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DHT_QueryGauge) XXX_Merge

func (m *DHT_QueryGauge) XXX_Merge(src proto.Message)

func (*DHT_QueryGauge) XXX_Size

func (m *DHT_QueryGauge) XXX_Size() int

func (*DHT_QueryGauge) XXX_Unmarshal

func (m *DHT_QueryGauge) XXX_Unmarshal(b []byte) error

type DataGauge

type DataGauge struct {
	// Cumulative bytes.
	CumBytes uint64 `protobuf:"varint,1,opt,name=cum_bytes,json=cumBytes,proto3" json:"cum_bytes,omitempty"`
	// Cumulative packets.
	CumPackets uint64 `protobuf:"varint,2,opt,name=cum_packets,json=cumPackets,proto3" json:"cum_packets,omitempty"`
	// Instantaneous bandwidth measurement (bytes/second).
	InstBw uint64 `protobuf:"varint,3,opt,name=inst_bw,json=instBw,proto3" json:"inst_bw,omitempty"`
}

DataGauge reports stats for data traffic in a given direction.

func (*DataGauge) Descriptor

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

func (*DataGauge) GetCumBytes

func (m *DataGauge) GetCumBytes() uint64

func (*DataGauge) GetCumPackets

func (m *DataGauge) GetCumPackets() uint64

func (*DataGauge) GetInstBw

func (m *DataGauge) GetInstBw() uint64

func (*DataGauge) Marshal

func (m *DataGauge) Marshal() (dAtA []byte, err error)

func (*DataGauge) MarshalTo

func (m *DataGauge) MarshalTo(dAtA []byte) (int, error)

func (*DataGauge) MarshalToSizedBuffer

func (m *DataGauge) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataGauge) ProtoMessage

func (*DataGauge) ProtoMessage()

func (*DataGauge) Reset

func (m *DataGauge) Reset()

func (*DataGauge) Size

func (m *DataGauge) Size() (n int)

func (*DataGauge) String

func (m *DataGauge) String() string

func (*DataGauge) Unmarshal

func (m *DataGauge) Unmarshal(dAtA []byte) error

func (*DataGauge) XXX_DiscardUnknown

func (m *DataGauge) XXX_DiscardUnknown()

func (*DataGauge) XXX_Marshal

func (m *DataGauge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataGauge) XXX_Merge

func (m *DataGauge) XXX_Merge(src proto.Message)

func (*DataGauge) XXX_Size

func (m *DataGauge) XXX_Size() int

func (*DataGauge) XXX_Unmarshal

func (m *DataGauge) XXX_Unmarshal(b []byte) error

type EndpointPair

type EndpointPair struct {
	// the source multiaddr.
	SrcMultiaddr string `protobuf:"bytes,1,opt,name=src_multiaddr,json=srcMultiaddr,proto3" json:"src_multiaddr,omitempty"`
	// the destination multiaddr.
	DstMultiaddr string `protobuf:"bytes,2,opt,name=dst_multiaddr,json=dstMultiaddr,proto3" json:"dst_multiaddr,omitempty"`
}

EndpointPair is a pair of multiaddrs.

func (*EndpointPair) Descriptor

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

func (*EndpointPair) GetDstMultiaddr

func (m *EndpointPair) GetDstMultiaddr() string

func (*EndpointPair) GetSrcMultiaddr

func (m *EndpointPair) GetSrcMultiaddr() string

func (*EndpointPair) Marshal

func (m *EndpointPair) Marshal() (dAtA []byte, err error)

func (*EndpointPair) MarshalTo

func (m *EndpointPair) MarshalTo(dAtA []byte) (int, error)

func (*EndpointPair) MarshalToSizedBuffer

func (m *EndpointPair) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EndpointPair) ProtoMessage

func (*EndpointPair) ProtoMessage()

func (*EndpointPair) Reset

func (m *EndpointPair) Reset()

func (*EndpointPair) Size

func (m *EndpointPair) Size() (n int)

func (*EndpointPair) String

func (m *EndpointPair) String() string

func (*EndpointPair) Unmarshal

func (m *EndpointPair) Unmarshal(dAtA []byte) error

func (*EndpointPair) XXX_DiscardUnknown

func (m *EndpointPair) XXX_DiscardUnknown()

func (*EndpointPair) XXX_Marshal

func (m *EndpointPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndpointPair) XXX_Merge

func (m *EndpointPair) XXX_Merge(src proto.Message)

func (*EndpointPair) XXX_Size

func (m *EndpointPair) XXX_Size() int

func (*EndpointPair) XXX_Unmarshal

func (m *EndpointPair) XXX_Unmarshal(b []byte) error

type Event

type Event struct {
	// definition of event type, containing only `name` unless this is first encounter of novel event
	Type *EventType `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// time this event occurred (ms since epoch)
	Ts uint64 `protobuf:"varint,2,opt,name=ts,proto3" json:"ts,omitempty"`
	// stringified json; top-level keys and value types match EventProperty definitions
	Content string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
}

Event

func (*Event) Descriptor

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

func (*Event) GetContent

func (m *Event) GetContent() string

func (*Event) GetTs

func (m *Event) GetTs() uint64

func (*Event) GetType

func (m *Event) GetType() *EventType

func (*Event) Marshal

func (m *Event) Marshal() (dAtA []byte, err error)

func (*Event) MarshalTo

func (m *Event) MarshalTo(dAtA []byte) (int, error)

func (*Event) MarshalToSizedBuffer

func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) Reset

func (m *Event) Reset()

func (*Event) Size

func (m *Event) Size() (n int)

func (*Event) String

func (m *Event) String() string

func (*Event) Unmarshal

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) XXX_DiscardUnknown

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal

func (m *Event) XXX_Unmarshal(b []byte) error

type EventType

type EventType struct {
	// name of event type, e.g. PeerConnecting
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// for runtime, send property_types for all events already seen in events list
	// for events, only send property_types in the first event of a type not in runtime
	PropertyTypes []*EventType_EventProperty `protobuf:"bytes,2,rep,name=property_types,json=propertyTypes,proto3" json:"property_types,omitempty"`
}

describes a type of event

func (*EventType) Descriptor

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

func (*EventType) GetName

func (m *EventType) GetName() string

func (*EventType) GetPropertyTypes

func (m *EventType) GetPropertyTypes() []*EventType_EventProperty

func (*EventType) Marshal

func (m *EventType) Marshal() (dAtA []byte, err error)

func (*EventType) MarshalTo

func (m *EventType) MarshalTo(dAtA []byte) (int, error)

func (*EventType) MarshalToSizedBuffer

func (m *EventType) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventType) ProtoMessage

func (*EventType) ProtoMessage()

func (*EventType) Reset

func (m *EventType) Reset()

func (*EventType) Size

func (m *EventType) Size() (n int)

func (*EventType) String

func (m *EventType) String() string

func (*EventType) Unmarshal

func (m *EventType) Unmarshal(dAtA []byte) error

func (*EventType) XXX_DiscardUnknown

func (m *EventType) XXX_DiscardUnknown()

func (*EventType) XXX_Marshal

func (m *EventType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventType) XXX_Merge

func (m *EventType) XXX_Merge(src proto.Message)

func (*EventType) XXX_Size

func (m *EventType) XXX_Size() int

func (*EventType) XXX_Unmarshal

func (m *EventType) XXX_Unmarshal(b []byte) error

type EventType_EventProperty

type EventType_EventProperty struct {
	// property name of content e.g. openTs
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// type to interpret content value as
	Type EventType_EventProperty_PropertyType `protobuf:"varint,2,opt,name=type,proto3,enum=pb.EventType_EventProperty_PropertyType" json:"type,omitempty"`
	// if true, expect an array of values of `type`; else, singular
	HasMultiple bool `protobuf:"varint,3,opt,name=has_multiple,json=hasMultiple,proto3" json:"has_multiple,omitempty"`
}

metadata about content types in event's top-level content JSON

func (*EventType_EventProperty) Descriptor

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

func (*EventType_EventProperty) GetHasMultiple

func (m *EventType_EventProperty) GetHasMultiple() bool

func (*EventType_EventProperty) GetName

func (m *EventType_EventProperty) GetName() string

func (*EventType_EventProperty) GetType

func (*EventType_EventProperty) Marshal

func (m *EventType_EventProperty) Marshal() (dAtA []byte, err error)

func (*EventType_EventProperty) MarshalTo

func (m *EventType_EventProperty) MarshalTo(dAtA []byte) (int, error)

func (*EventType_EventProperty) MarshalToSizedBuffer

func (m *EventType_EventProperty) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventType_EventProperty) ProtoMessage

func (*EventType_EventProperty) ProtoMessage()

func (*EventType_EventProperty) Reset

func (m *EventType_EventProperty) Reset()

func (*EventType_EventProperty) Size

func (m *EventType_EventProperty) Size() (n int)

func (*EventType_EventProperty) String

func (m *EventType_EventProperty) String() string

func (*EventType_EventProperty) Unmarshal

func (m *EventType_EventProperty) Unmarshal(dAtA []byte) error

func (*EventType_EventProperty) XXX_DiscardUnknown

func (m *EventType_EventProperty) XXX_DiscardUnknown()

func (*EventType_EventProperty) XXX_Marshal

func (m *EventType_EventProperty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventType_EventProperty) XXX_Merge

func (m *EventType_EventProperty) XXX_Merge(src proto.Message)

func (*EventType_EventProperty) XXX_Size

func (m *EventType_EventProperty) XXX_Size() int

func (*EventType_EventProperty) XXX_Unmarshal

func (m *EventType_EventProperty) XXX_Unmarshal(b []byte) error

type EventType_EventProperty_PropertyType

type EventType_EventProperty_PropertyType int32

tells client how to sort, filter or display known content properties

const (
	// for properties to treat as a simple primitive
	EventType_EventProperty_STRING EventType_EventProperty_PropertyType = 0
	EventType_EventProperty_NUMBER EventType_EventProperty_PropertyType = 1
	// for properties with special human-readable formatting
	EventType_EventProperty_TIME      EventType_EventProperty_PropertyType = 10
	EventType_EventProperty_PEERID    EventType_EventProperty_PropertyType = 11
	EventType_EventProperty_MULTIADDR EventType_EventProperty_PropertyType = 12
	// for complex structures like nested arrays, object trees etc
	EventType_EventProperty_JSON EventType_EventProperty_PropertyType = 90
)

func (EventType_EventProperty_PropertyType) EnumDescriptor

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

func (EventType_EventProperty_PropertyType) String

type ResultCounter

type ResultCounter struct {
	Total uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Ok    uint32 `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	Err   uint32 `protobuf:"varint,3,opt,name=err,proto3" json:"err,omitempty"`
}

ResultCounter is a monotonically increasing counter that reports an ok/err breakdown of the total.

func (*ResultCounter) Descriptor

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

func (*ResultCounter) GetErr

func (m *ResultCounter) GetErr() uint32

func (*ResultCounter) GetOk

func (m *ResultCounter) GetOk() uint32

func (*ResultCounter) GetTotal

func (m *ResultCounter) GetTotal() uint32

func (*ResultCounter) Marshal

func (m *ResultCounter) Marshal() (dAtA []byte, err error)

func (*ResultCounter) MarshalTo

func (m *ResultCounter) MarshalTo(dAtA []byte) (int, error)

func (*ResultCounter) MarshalToSizedBuffer

func (m *ResultCounter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResultCounter) ProtoMessage

func (*ResultCounter) ProtoMessage()

func (*ResultCounter) Reset

func (m *ResultCounter) Reset()

func (*ResultCounter) Size

func (m *ResultCounter) Size() (n int)

func (*ResultCounter) String

func (m *ResultCounter) String() string

func (*ResultCounter) Unmarshal

func (m *ResultCounter) Unmarshal(dAtA []byte) error

func (*ResultCounter) XXX_DiscardUnknown

func (m *ResultCounter) XXX_DiscardUnknown()

func (*ResultCounter) XXX_Marshal

func (m *ResultCounter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResultCounter) XXX_Merge

func (m *ResultCounter) XXX_Merge(src proto.Message)

func (*ResultCounter) XXX_Size

func (m *ResultCounter) XXX_Size() int

func (*ResultCounter) XXX_Unmarshal

func (m *ResultCounter) XXX_Unmarshal(b []byte) error

type Role

type Role int32

Our role in a connection or stream.

const (
	Role_INITIATOR Role = 0
	Role_RESPONDER Role = 1
)

func (Role) EnumDescriptor

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

func (Role) String

func (x Role) String() string

type Runtime

type Runtime struct {
	// e.g. go-libp2p, js-libp2p, rust-libp2p, etc.
	Implementation string `protobuf:"bytes,1,opt,name=implementation,proto3" json:"implementation,omitempty"`
	// e.g. 1.2.3.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// e.g. Windows, Unix, macOS, Chrome, Mozilla, etc.
	Platform string `protobuf:"bytes,3,opt,name=platform,proto3" json:"platform,omitempty"`
	// our peer id - the peer id of the host system
	PeerId string `protobuf:"bytes,4,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	// metadata describing configured event types
	EventTypes []*EventType `protobuf:"bytes,7,rep,name=event_types,json=eventTypes,proto3" json:"event_types,omitempty"`
}

Runtime encapsulates runtime info about a node.

func (*Runtime) Descriptor

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

func (*Runtime) GetEventTypes

func (m *Runtime) GetEventTypes() []*EventType

func (*Runtime) GetImplementation

func (m *Runtime) GetImplementation() string

func (*Runtime) GetPeerId

func (m *Runtime) GetPeerId() string

func (*Runtime) GetPlatform

func (m *Runtime) GetPlatform() string

func (*Runtime) GetVersion

func (m *Runtime) GetVersion() string

func (*Runtime) Marshal

func (m *Runtime) Marshal() (dAtA []byte, err error)

func (*Runtime) MarshalTo

func (m *Runtime) MarshalTo(dAtA []byte) (int, error)

func (*Runtime) MarshalToSizedBuffer

func (m *Runtime) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Runtime) ProtoMessage

func (*Runtime) ProtoMessage()

func (*Runtime) Reset

func (m *Runtime) Reset()

func (*Runtime) Size

func (m *Runtime) Size() (n int)

func (*Runtime) String

func (m *Runtime) String() string

func (*Runtime) Unmarshal

func (m *Runtime) Unmarshal(dAtA []byte) error

func (*Runtime) XXX_DiscardUnknown

func (m *Runtime) XXX_DiscardUnknown()

func (*Runtime) XXX_Marshal

func (m *Runtime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Runtime) XXX_Merge

func (m *Runtime) XXX_Merge(src proto.Message)

func (*Runtime) XXX_Size

func (m *Runtime) XXX_Size() int

func (*Runtime) XXX_Unmarshal

func (m *Runtime) XXX_Unmarshal(b []byte) error

type ServerMessage

type ServerMessage struct {
	// Version of this protobuf.
	Version *Version `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// The payload this message contains.
	//
	// Types that are valid to be assigned to Payload:
	//	*ServerMessage_State
	//	*ServerMessage_Runtime
	//	*ServerMessage_Event
	//	*ServerMessage_Response
	//	*ServerMessage_Notice
	Payload isServerMessage_Payload `protobuf_oneof:"payload"`
}

ServerMessage wraps messages to be sent to clients to allow extension based on new types of data sources

func (*ServerMessage) Descriptor

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

func (*ServerMessage) GetEvent

func (m *ServerMessage) GetEvent() *Event

func (*ServerMessage) GetNotice

func (m *ServerMessage) GetNotice() *ServerNotice

func (*ServerMessage) GetPayload

func (m *ServerMessage) GetPayload() isServerMessage_Payload

func (*ServerMessage) GetResponse

func (m *ServerMessage) GetResponse() *CommandResponse

func (*ServerMessage) GetRuntime

func (m *ServerMessage) GetRuntime() *Runtime

func (*ServerMessage) GetState

func (m *ServerMessage) GetState() *State

func (*ServerMessage) GetVersion

func (m *ServerMessage) GetVersion() *Version

func (*ServerMessage) Marshal

func (m *ServerMessage) Marshal() (dAtA []byte, err error)

func (*ServerMessage) MarshalTo

func (m *ServerMessage) MarshalTo(dAtA []byte) (int, error)

func (*ServerMessage) MarshalToSizedBuffer

func (m *ServerMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServerMessage) ProtoMessage

func (*ServerMessage) ProtoMessage()

func (*ServerMessage) Reset

func (m *ServerMessage) Reset()

func (*ServerMessage) Size

func (m *ServerMessage) Size() (n int)

func (*ServerMessage) String

func (m *ServerMessage) String() string

func (*ServerMessage) Unmarshal

func (m *ServerMessage) Unmarshal(dAtA []byte) error

func (*ServerMessage) XXX_DiscardUnknown

func (m *ServerMessage) XXX_DiscardUnknown()

func (*ServerMessage) XXX_Marshal

func (m *ServerMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerMessage) XXX_Merge

func (m *ServerMessage) XXX_Merge(src proto.Message)

func (*ServerMessage) XXX_OneofWrappers

func (*ServerMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServerMessage) XXX_Size

func (m *ServerMessage) XXX_Size() int

func (*ServerMessage) XXX_Unmarshal

func (m *ServerMessage) XXX_Unmarshal(b []byte) error

type ServerMessage_Event

type ServerMessage_Event struct {
	Event *Event `protobuf:"bytes,4,opt,name=event,proto3,oneof" json:"event,omitempty"`
}

func (*ServerMessage_Event) MarshalTo

func (m *ServerMessage_Event) MarshalTo(dAtA []byte) (int, error)

func (*ServerMessage_Event) MarshalToSizedBuffer

func (m *ServerMessage_Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServerMessage_Event) Size

func (m *ServerMessage_Event) Size() (n int)

type ServerMessage_Notice

type ServerMessage_Notice struct {
	Notice *ServerNotice `protobuf:"bytes,6,opt,name=notice,proto3,oneof" json:"notice,omitempty"`
}

func (*ServerMessage_Notice) MarshalTo

func (m *ServerMessage_Notice) MarshalTo(dAtA []byte) (int, error)

func (*ServerMessage_Notice) MarshalToSizedBuffer

func (m *ServerMessage_Notice) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServerMessage_Notice) Size

func (m *ServerMessage_Notice) Size() (n int)

type ServerMessage_Response

type ServerMessage_Response struct {
	Response *CommandResponse `protobuf:"bytes,5,opt,name=response,proto3,oneof" json:"response,omitempty"`
}

func (*ServerMessage_Response) MarshalTo

func (m *ServerMessage_Response) MarshalTo(dAtA []byte) (int, error)

func (*ServerMessage_Response) MarshalToSizedBuffer

func (m *ServerMessage_Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServerMessage_Response) Size

func (m *ServerMessage_Response) Size() (n int)

type ServerMessage_Runtime

type ServerMessage_Runtime struct {
	Runtime *Runtime `protobuf:"bytes,3,opt,name=runtime,proto3,oneof" json:"runtime,omitempty"`
}

func (*ServerMessage_Runtime) MarshalTo

func (m *ServerMessage_Runtime) MarshalTo(dAtA []byte) (int, error)

func (*ServerMessage_Runtime) MarshalToSizedBuffer

func (m *ServerMessage_Runtime) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServerMessage_Runtime) Size

func (m *ServerMessage_Runtime) Size() (n int)

type ServerMessage_State

type ServerMessage_State struct {
	State *State `protobuf:"bytes,2,opt,name=state,proto3,oneof" json:"state,omitempty"`
}

func (*ServerMessage_State) MarshalTo

func (m *ServerMessage_State) MarshalTo(dAtA []byte) (int, error)

func (*ServerMessage_State) MarshalToSizedBuffer

func (m *ServerMessage_State) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServerMessage_State) Size

func (m *ServerMessage_State) Size() (n int)

type ServerNotice

type ServerNotice struct {
	Kind ServerNotice_Kind `protobuf:"varint,1,opt,name=kind,proto3,enum=pb.ServerNotice_Kind" json:"kind,omitempty"`
}

ServerNotice represents a NOTICE sent from the server to the client.

func (*ServerNotice) Descriptor

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

func (*ServerNotice) GetKind

func (m *ServerNotice) GetKind() ServerNotice_Kind

func (*ServerNotice) Marshal

func (m *ServerNotice) Marshal() (dAtA []byte, err error)

func (*ServerNotice) MarshalTo

func (m *ServerNotice) MarshalTo(dAtA []byte) (int, error)

func (*ServerNotice) MarshalToSizedBuffer

func (m *ServerNotice) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServerNotice) ProtoMessage

func (*ServerNotice) ProtoMessage()

func (*ServerNotice) Reset

func (m *ServerNotice) Reset()

func (*ServerNotice) Size

func (m *ServerNotice) Size() (n int)

func (*ServerNotice) String

func (m *ServerNotice) String() string

func (*ServerNotice) Unmarshal

func (m *ServerNotice) Unmarshal(dAtA []byte) error

func (*ServerNotice) XXX_DiscardUnknown

func (m *ServerNotice) XXX_DiscardUnknown()

func (*ServerNotice) XXX_Marshal

func (m *ServerNotice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerNotice) XXX_Merge

func (m *ServerNotice) XXX_Merge(src proto.Message)

func (*ServerNotice) XXX_Size

func (m *ServerNotice) XXX_Size() int

func (*ServerNotice) XXX_Unmarshal

func (m *ServerNotice) XXX_Unmarshal(b []byte) error

type ServerNotice_Kind

type ServerNotice_Kind int32
const (
	ServerNotice_DISCARDING_EVENTS ServerNotice_Kind = 0
)

func (ServerNotice_Kind) EnumDescriptor

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

func (ServerNotice_Kind) String

func (x ServerNotice_Kind) String() string

type SlidingCounter

type SlidingCounter struct {
	Over_1M   uint32 `protobuf:"varint,1,opt,name=over_1m,json=over1m,proto3" json:"over_1m,omitempty"`
	Over_5M   uint32 `protobuf:"varint,2,opt,name=over_5m,json=over5m,proto3" json:"over_5m,omitempty"`
	Over_15M  uint32 `protobuf:"varint,3,opt,name=over_15m,json=over15m,proto3" json:"over_15m,omitempty"`
	Over_30M  uint32 `protobuf:"varint,4,opt,name=over_30m,json=over30m,proto3" json:"over_30m,omitempty"`
	Over_1Hr  uint32 `protobuf:"varint,5,opt,name=over_1hr,json=over1hr,proto3" json:"over_1hr,omitempty"`
	Over_2Hr  uint32 `protobuf:"varint,6,opt,name=over_2hr,json=over2hr,proto3" json:"over_2hr,omitempty"`
	Over_4Hr  uint32 `protobuf:"varint,7,opt,name=over_4hr,json=over4hr,proto3" json:"over_4hr,omitempty"`
	Over_8Hr  uint32 `protobuf:"varint,8,opt,name=over_8hr,json=over8hr,proto3" json:"over_8hr,omitempty"`
	Over_12Hr uint32 `protobuf:"varint,9,opt,name=over_12hr,json=over12hr,proto3" json:"over_12hr,omitempty"`
	Over_24Hr uint32 `protobuf:"varint,10,opt,name=over_24hr,json=over24hr,proto3" json:"over_24hr,omitempty"`
}

Moving totals over sliding time windows. Models sensible time windows, we don't have to populate them all at once.

Graphical example:

time past -> present an event 16 min ago ======================================================X================>>

                                           |               | 1m
                                           |           |---| 5m
                                           | |-------------| 15m
                              |------------X---------------| 30m
|------------------------------------------X---------------| 60m

func (*SlidingCounter) Descriptor

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

func (*SlidingCounter) GetOver_12Hr

func (m *SlidingCounter) GetOver_12Hr() uint32

func (*SlidingCounter) GetOver_15M

func (m *SlidingCounter) GetOver_15M() uint32

func (*SlidingCounter) GetOver_1Hr

func (m *SlidingCounter) GetOver_1Hr() uint32

func (*SlidingCounter) GetOver_1M

func (m *SlidingCounter) GetOver_1M() uint32

func (*SlidingCounter) GetOver_24Hr

func (m *SlidingCounter) GetOver_24Hr() uint32

func (*SlidingCounter) GetOver_2Hr

func (m *SlidingCounter) GetOver_2Hr() uint32

func (*SlidingCounter) GetOver_30M

func (m *SlidingCounter) GetOver_30M() uint32

func (*SlidingCounter) GetOver_4Hr

func (m *SlidingCounter) GetOver_4Hr() uint32

func (*SlidingCounter) GetOver_5M

func (m *SlidingCounter) GetOver_5M() uint32

func (*SlidingCounter) GetOver_8Hr

func (m *SlidingCounter) GetOver_8Hr() uint32

func (*SlidingCounter) Marshal

func (m *SlidingCounter) Marshal() (dAtA []byte, err error)

func (*SlidingCounter) MarshalTo

func (m *SlidingCounter) MarshalTo(dAtA []byte) (int, error)

func (*SlidingCounter) MarshalToSizedBuffer

func (m *SlidingCounter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SlidingCounter) ProtoMessage

func (*SlidingCounter) ProtoMessage()

func (*SlidingCounter) Reset

func (m *SlidingCounter) Reset()

func (*SlidingCounter) Size

func (m *SlidingCounter) Size() (n int)

func (*SlidingCounter) String

func (m *SlidingCounter) String() string

func (*SlidingCounter) Unmarshal

func (m *SlidingCounter) Unmarshal(dAtA []byte) error

func (*SlidingCounter) XXX_DiscardUnknown

func (m *SlidingCounter) XXX_DiscardUnknown()

func (*SlidingCounter) XXX_Marshal

func (m *SlidingCounter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SlidingCounter) XXX_Merge

func (m *SlidingCounter) XXX_Merge(src proto.Message)

func (*SlidingCounter) XXX_Size

func (m *SlidingCounter) XXX_Size() int

func (*SlidingCounter) XXX_Unmarshal

func (m *SlidingCounter) XXX_Unmarshal(b []byte) error

type State

type State struct {
	// list of connections
	Subsystems *Subsystems `protobuf:"bytes,1,opt,name=subsystems,proto3" json:"subsystems,omitempty"`
	// overall traffic for this peer
	Traffic *Traffic `protobuf:"bytes,2,opt,name=traffic,proto3" json:"traffic,omitempty"`
	// moment this data snapshot and instantaneous values were taken
	InstantTs uint64 `protobuf:"varint,3,opt,name=instant_ts,json=instantTs,proto3" json:"instant_ts,omitempty"`
	// start of included data collection (cumulative values counted from here)
	StartTs uint64 `protobuf:"varint,4,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	// length of time up to instant_ts covered by this data snapshot
	SnapshotDurationMs uint32 `protobuf:"varint,5,opt,name=snapshot_duration_ms,json=snapshotDurationMs,proto3" json:"snapshot_duration_ms,omitempty"`
}

Connections and streams output for a time interval is one of these.

func (*State) Descriptor

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

func (*State) GetInstantTs

func (m *State) GetInstantTs() uint64

func (*State) GetSnapshotDurationMs

func (m *State) GetSnapshotDurationMs() uint32

func (*State) GetStartTs

func (m *State) GetStartTs() uint64

func (*State) GetSubsystems

func (m *State) GetSubsystems() *Subsystems

func (*State) GetTraffic

func (m *State) GetTraffic() *Traffic

func (*State) Marshal

func (m *State) Marshal() (dAtA []byte, err error)

func (*State) MarshalTo

func (m *State) MarshalTo(dAtA []byte) (int, error)

func (*State) MarshalToSizedBuffer

func (m *State) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*State) ProtoMessage

func (*State) ProtoMessage()

func (*State) Reset

func (m *State) Reset()

func (*State) Size

func (m *State) Size() (n int)

func (*State) String

func (m *State) String() string

func (*State) Unmarshal

func (m *State) Unmarshal(dAtA []byte) error

func (*State) XXX_DiscardUnknown

func (m *State) XXX_DiscardUnknown()

func (*State) XXX_Marshal

func (m *State) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*State) XXX_Merge

func (m *State) XXX_Merge(src proto.Message)

func (*State) XXX_Size

func (m *State) XXX_Size() int

func (*State) XXX_Unmarshal

func (m *State) XXX_Unmarshal(b []byte) error

type Status

type Status int32

The status of a connection or stream.

const (
	Status_ACTIVE  Status = 0
	Status_CLOSED  Status = 1
	Status_OPENING Status = 2
	Status_CLOSING Status = 3
	Status_ERROR   Status = 4
)

func (Status) EnumDescriptor

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

func (Status) String

func (x Status) String() string

type Stream

type Stream struct {
	// the id of this stream, not to be shown in user tooling,
	// used for (cross)referencing streams.
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// the protocol pinned to this stream.
	Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// our role in this stream.
	Role Role `protobuf:"varint,3,opt,name=role,proto3,enum=pb.Role" json:"role,omitempty"`
	// traffic statistics.
	Traffic *Traffic `protobuf:"bytes,4,opt,name=traffic,proto3" json:"traffic,omitempty"`
	// the connection this stream is hosted under.
	Conn *Stream_ConnectionRef `protobuf:"bytes,5,opt,name=conn,proto3" json:"conn,omitempty"`
	// the timeline of the stream, see Stream.Timeline.
	Timeline *Stream_Timeline `protobuf:"bytes,6,opt,name=timeline,proto3" json:"timeline,omitempty"`
	// the status of this stream.
	Status Status `protobuf:"varint,7,opt,name=status,proto3,enum=pb.Status" json:"status,omitempty"`
	// the instantaneous latency of this stream in nanoseconds.
	// TODO: this is hard to calculate.
	LatencyNs uint64 `protobuf:"varint,16,opt,name=latency_ns,json=latencyNs,proto3" json:"latency_ns,omitempty"`
	// user provided tags.
	UserProvidedTags []string `protobuf:"bytes,99,rep,name=user_provided_tags,json=userProvidedTags,proto3" json:"user_provided_tags,omitempty"`
}

Stream reports metrics and state of a libp2p stream.

func (*Stream) Descriptor

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

func (*Stream) GetConn

func (m *Stream) GetConn() *Stream_ConnectionRef

func (*Stream) GetId

func (m *Stream) GetId() []byte

func (*Stream) GetLatencyNs

func (m *Stream) GetLatencyNs() uint64

func (*Stream) GetProtocol

func (m *Stream) GetProtocol() string

func (*Stream) GetRole

func (m *Stream) GetRole() Role

func (*Stream) GetStatus

func (m *Stream) GetStatus() Status

func (*Stream) GetTimeline

func (m *Stream) GetTimeline() *Stream_Timeline

func (*Stream) GetTraffic

func (m *Stream) GetTraffic() *Traffic

func (*Stream) GetUserProvidedTags

func (m *Stream) GetUserProvidedTags() []string

func (*Stream) Marshal

func (m *Stream) Marshal() (dAtA []byte, err error)

func (*Stream) MarshalTo

func (m *Stream) MarshalTo(dAtA []byte) (int, error)

func (*Stream) MarshalToSizedBuffer

func (m *Stream) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Stream) ProtoMessage

func (*Stream) ProtoMessage()

func (*Stream) Reset

func (m *Stream) Reset()

func (*Stream) Size

func (m *Stream) Size() (n int)

func (*Stream) String

func (m *Stream) String() string

func (*Stream) Unmarshal

func (m *Stream) Unmarshal(dAtA []byte) error

func (*Stream) XXX_DiscardUnknown

func (m *Stream) XXX_DiscardUnknown()

func (*Stream) XXX_Marshal

func (m *Stream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Stream) XXX_Merge

func (m *Stream) XXX_Merge(src proto.Message)

func (*Stream) XXX_Size

func (m *Stream) XXX_Size() int

func (*Stream) XXX_Unmarshal

func (m *Stream) XXX_Unmarshal(b []byte) error

type StreamList

type StreamList struct {
	// NOTE: only one of the next 2 fields can appear, but proto3
	// doesn't support combining oneof and repeated.
	//
	// streams within this connection by reference.
	StreamIds [][]byte `protobuf:"bytes,1,rep,name=stream_ids,json=streamIds,proto3" json:"stream_ids,omitempty"`
	// streams within this connection by inlining.
	Streams []*Stream `protobuf:"bytes,2,rep,name=streams,proto3" json:"streams,omitempty"`
}

a list of streams, by reference or inlined.

func (*StreamList) Descriptor

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

func (*StreamList) GetStreamIds

func (m *StreamList) GetStreamIds() [][]byte

func (*StreamList) GetStreams

func (m *StreamList) GetStreams() []*Stream

func (*StreamList) Marshal

func (m *StreamList) Marshal() (dAtA []byte, err error)

func (*StreamList) MarshalTo

func (m *StreamList) MarshalTo(dAtA []byte) (int, error)

func (*StreamList) MarshalToSizedBuffer

func (m *StreamList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamList) ProtoMessage

func (*StreamList) ProtoMessage()

func (*StreamList) Reset

func (m *StreamList) Reset()

func (*StreamList) Size

func (m *StreamList) Size() (n int)

func (*StreamList) String

func (m *StreamList) String() string

func (*StreamList) Unmarshal

func (m *StreamList) Unmarshal(dAtA []byte) error

func (*StreamList) XXX_DiscardUnknown

func (m *StreamList) XXX_DiscardUnknown()

func (*StreamList) XXX_Marshal

func (m *StreamList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamList) XXX_Merge

func (m *StreamList) XXX_Merge(src proto.Message)

func (*StreamList) XXX_Size

func (m *StreamList) XXX_Size() int

func (*StreamList) XXX_Unmarshal

func (m *StreamList) XXX_Unmarshal(b []byte) error

type Stream_ConnectionRef

type Stream_ConnectionRef struct {
	// Types that are valid to be assigned to Connection:
	//	*Stream_ConnectionRef_Conn
	//	*Stream_ConnectionRef_ConnId
	Connection isStream_ConnectionRef_Connection `protobuf_oneof:"connection"`
}

func (*Stream_ConnectionRef) Descriptor

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

func (*Stream_ConnectionRef) GetConn

func (m *Stream_ConnectionRef) GetConn() *Connection

func (*Stream_ConnectionRef) GetConnId

func (m *Stream_ConnectionRef) GetConnId() []byte

func (*Stream_ConnectionRef) GetConnection

func (m *Stream_ConnectionRef) GetConnection() isStream_ConnectionRef_Connection

func (*Stream_ConnectionRef) Marshal

func (m *Stream_ConnectionRef) Marshal() (dAtA []byte, err error)

func (*Stream_ConnectionRef) MarshalTo

func (m *Stream_ConnectionRef) MarshalTo(dAtA []byte) (int, error)

func (*Stream_ConnectionRef) MarshalToSizedBuffer

func (m *Stream_ConnectionRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Stream_ConnectionRef) ProtoMessage

func (*Stream_ConnectionRef) ProtoMessage()

func (*Stream_ConnectionRef) Reset

func (m *Stream_ConnectionRef) Reset()

func (*Stream_ConnectionRef) Size

func (m *Stream_ConnectionRef) Size() (n int)

func (*Stream_ConnectionRef) String

func (m *Stream_ConnectionRef) String() string

func (*Stream_ConnectionRef) Unmarshal

func (m *Stream_ConnectionRef) Unmarshal(dAtA []byte) error

func (*Stream_ConnectionRef) XXX_DiscardUnknown

func (m *Stream_ConnectionRef) XXX_DiscardUnknown()

func (*Stream_ConnectionRef) XXX_Marshal

func (m *Stream_ConnectionRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Stream_ConnectionRef) XXX_Merge

func (m *Stream_ConnectionRef) XXX_Merge(src proto.Message)

func (*Stream_ConnectionRef) XXX_OneofWrappers

func (*Stream_ConnectionRef) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Stream_ConnectionRef) XXX_Size

func (m *Stream_ConnectionRef) XXX_Size() int

func (*Stream_ConnectionRef) XXX_Unmarshal

func (m *Stream_ConnectionRef) XXX_Unmarshal(b []byte) error

type Stream_ConnectionRef_Conn

type Stream_ConnectionRef_Conn struct {
	Conn *Connection `protobuf:"bytes,1,opt,name=conn,proto3,oneof" json:"conn,omitempty"`
}

func (*Stream_ConnectionRef_Conn) MarshalTo

func (m *Stream_ConnectionRef_Conn) MarshalTo(dAtA []byte) (int, error)

func (*Stream_ConnectionRef_Conn) MarshalToSizedBuffer

func (m *Stream_ConnectionRef_Conn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Stream_ConnectionRef_Conn) Size

func (m *Stream_ConnectionRef_Conn) Size() (n int)

type Stream_ConnectionRef_ConnId

type Stream_ConnectionRef_ConnId struct {
	ConnId []byte `protobuf:"bytes,2,opt,name=conn_id,json=connId,proto3,oneof" json:"conn_id,omitempty"`
}

func (*Stream_ConnectionRef_ConnId) MarshalTo

func (m *Stream_ConnectionRef_ConnId) MarshalTo(dAtA []byte) (int, error)

func (*Stream_ConnectionRef_ConnId) MarshalToSizedBuffer

func (m *Stream_ConnectionRef_ConnId) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Stream_ConnectionRef_ConnId) Size

func (m *Stream_ConnectionRef_ConnId) Size() (n int)

type Stream_Timeline

type Stream_Timeline struct {
	// the instant when the stream was opened.
	OpenTs uint64 `protobuf:"varint,1,opt,name=open_ts,json=openTs,proto3" json:"open_ts,omitempty"`
	// the instant when the stream was terminated.
	CloseTs uint64 `protobuf:"varint,2,opt,name=close_ts,json=closeTs,proto3" json:"close_ts,omitempty"`
}

Timeline contains the timestamps (ms since epoch) of the well-known milestones of a stream.

func (*Stream_Timeline) Descriptor

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

func (*Stream_Timeline) GetCloseTs

func (m *Stream_Timeline) GetCloseTs() uint64

func (*Stream_Timeline) GetOpenTs

func (m *Stream_Timeline) GetOpenTs() uint64

func (*Stream_Timeline) Marshal

func (m *Stream_Timeline) Marshal() (dAtA []byte, err error)

func (*Stream_Timeline) MarshalTo

func (m *Stream_Timeline) MarshalTo(dAtA []byte) (int, error)

func (*Stream_Timeline) MarshalToSizedBuffer

func (m *Stream_Timeline) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Stream_Timeline) ProtoMessage

func (*Stream_Timeline) ProtoMessage()

func (*Stream_Timeline) Reset

func (m *Stream_Timeline) Reset()

func (*Stream_Timeline) Size

func (m *Stream_Timeline) Size() (n int)

func (*Stream_Timeline) String

func (m *Stream_Timeline) String() string

func (*Stream_Timeline) Unmarshal

func (m *Stream_Timeline) Unmarshal(dAtA []byte) error

func (*Stream_Timeline) XXX_DiscardUnknown

func (m *Stream_Timeline) XXX_DiscardUnknown()

func (*Stream_Timeline) XXX_Marshal

func (m *Stream_Timeline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Stream_Timeline) XXX_Merge

func (m *Stream_Timeline) XXX_Merge(src proto.Message)

func (*Stream_Timeline) XXX_Size

func (m *Stream_Timeline) XXX_Size() int

func (*Stream_Timeline) XXX_Unmarshal

func (m *Stream_Timeline) XXX_Unmarshal(b []byte) error

type Subsystems

type Subsystems struct {
	// connections data, source agnostic but currently only supports the Swarm subsystem
	Connections []*Connection `protobuf:"bytes,1,rep,name=connections,proto3" json:"connections,omitempty"`
	// the DHT subsystem.
	Dht *DHT `protobuf:"bytes,2,opt,name=dht,proto3" json:"dht,omitempty"`
}

Subsystems encapsulates all instrumented subsystems for a libp2p host.

func (*Subsystems) Descriptor

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

func (*Subsystems) GetConnections

func (m *Subsystems) GetConnections() []*Connection

func (*Subsystems) GetDht

func (m *Subsystems) GetDht() *DHT

func (*Subsystems) Marshal

func (m *Subsystems) Marshal() (dAtA []byte, err error)

func (*Subsystems) MarshalTo

func (m *Subsystems) MarshalTo(dAtA []byte) (int, error)

func (*Subsystems) MarshalToSizedBuffer

func (m *Subsystems) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Subsystems) ProtoMessage

func (*Subsystems) ProtoMessage()

func (*Subsystems) Reset

func (m *Subsystems) Reset()

func (*Subsystems) Size

func (m *Subsystems) Size() (n int)

func (*Subsystems) String

func (m *Subsystems) String() string

func (*Subsystems) Unmarshal

func (m *Subsystems) Unmarshal(dAtA []byte) error

func (*Subsystems) XXX_DiscardUnknown

func (m *Subsystems) XXX_DiscardUnknown()

func (*Subsystems) XXX_Marshal

func (m *Subsystems) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Subsystems) XXX_Merge

func (m *Subsystems) XXX_Merge(src proto.Message)

func (*Subsystems) XXX_Size

func (m *Subsystems) XXX_Size() int

func (*Subsystems) XXX_Unmarshal

func (m *Subsystems) XXX_Unmarshal(b []byte) error

type Traffic

type Traffic struct {
	// snapshot of the data in metrics.
	TrafficIn *DataGauge `protobuf:"bytes,1,opt,name=traffic_in,json=trafficIn,proto3" json:"traffic_in,omitempty"`
	// snapshot of the data out metrics.
	TrafficOut *DataGauge `protobuf:"bytes,2,opt,name=traffic_out,json=trafficOut,proto3" json:"traffic_out,omitempty"`
}

Traffic encloses data transfer statistics.

func (*Traffic) Descriptor

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

func (*Traffic) GetTrafficIn

func (m *Traffic) GetTrafficIn() *DataGauge

func (*Traffic) GetTrafficOut

func (m *Traffic) GetTrafficOut() *DataGauge

func (*Traffic) Marshal

func (m *Traffic) Marshal() (dAtA []byte, err error)

func (*Traffic) MarshalTo

func (m *Traffic) MarshalTo(dAtA []byte) (int, error)

func (*Traffic) MarshalToSizedBuffer

func (m *Traffic) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Traffic) ProtoMessage

func (*Traffic) ProtoMessage()

func (*Traffic) Reset

func (m *Traffic) Reset()

func (*Traffic) Size

func (m *Traffic) Size() (n int)

func (*Traffic) String

func (m *Traffic) String() string

func (*Traffic) Unmarshal

func (m *Traffic) Unmarshal(dAtA []byte) error

func (*Traffic) XXX_DiscardUnknown

func (m *Traffic) XXX_DiscardUnknown()

func (*Traffic) XXX_Marshal

func (m *Traffic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Traffic) XXX_Merge

func (m *Traffic) XXX_Merge(src proto.Message)

func (*Traffic) XXX_Size

func (m *Traffic) XXX_Size() int

func (*Traffic) XXX_Unmarshal

func (m *Traffic) XXX_Unmarshal(b []byte) error

type Version

type Version struct {
	Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
}

Version of schema

func (*Version) Descriptor

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

func (*Version) GetVersion

func (m *Version) GetVersion() uint32

func (*Version) Marshal

func (m *Version) Marshal() (dAtA []byte, err error)

func (*Version) MarshalTo

func (m *Version) MarshalTo(dAtA []byte) (int, error)

func (*Version) MarshalToSizedBuffer

func (m *Version) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Version) ProtoMessage

func (*Version) ProtoMessage()

func (*Version) Reset

func (m *Version) Reset()

func (*Version) Size

func (m *Version) Size() (n int)

func (*Version) String

func (m *Version) String() string

func (*Version) Unmarshal

func (m *Version) Unmarshal(dAtA []byte) error

func (*Version) XXX_DiscardUnknown

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal

func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Version) XXX_Merge

func (m *Version) XXX_Merge(src proto.Message)

func (*Version) XXX_Size

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal

func (m *Version) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL