pb

package
v0.0.0-...-6c532cc Latest Latest
Warning

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

 Go to latest Published: Aug 13, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

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 (m *EventType_EventProperty) GetType() EventType_EventProperty_PropertyType

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 

func (x EventType_EventProperty_PropertyType) String() 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

Source Files

View all Source files

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.