Versions in this module Expand all Collapse all v1 v1.8.7 Sep 21, 2022 v1.2.6 Sep 21, 2022 v1.2.5 Sep 21, 2022 v1.2.1 Sep 21, 2022 v1.0.5 Sep 27, 2022 v1.0.4 Sep 23, 2022 v1.0.3 Sep 23, 2022 v1.0.2 Sep 23, 2022 Changes in this version + var ClientCommand_Command_name = map[int32]string + var ClientCommand_Command_value = map[string]int32 + var ClientCommand_Source_name = map[int32]string + var ClientCommand_Source_value = map[string]int32 + var CommandResponse_Result_name = map[int32]string + var CommandResponse_Result_value = map[string]int32 + var DHT_PeerInDHT_Status_name = map[int32]string + var DHT_PeerInDHT_Status_value = map[string]int32 + var ErrIntOverflowIntrospection = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthIntrospection = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupIntrospection = fmt.Errorf("proto: unexpected end of group") + var EventType_EventProperty_PropertyType_name = map[int32]string + var EventType_EventProperty_PropertyType_value = map[string]int32 + var Role_name = map[int32]string + var Role_value = map[string]int32 + var ServerNotice_Kind_name = map[int32]string + var ServerNotice_Kind_value = map[string]int32 + var Status_name = map[int32]string + var Status_value = map[string]int32 + type ClientCommand struct + Command ClientCommand_Command + Config *Configuration + Id uint64 + Source ClientCommand_Source + Version *Version + func (*ClientCommand) Descriptor() ([]byte, []int) + func (*ClientCommand) ProtoMessage() + func (m *ClientCommand) GetCommand() ClientCommand_Command + func (m *ClientCommand) GetConfig() *Configuration + func (m *ClientCommand) GetId() uint64 + func (m *ClientCommand) GetSource() ClientCommand_Source + func (m *ClientCommand) GetVersion() *Version + func (m *ClientCommand) Marshal() (dAtA []byte, err error) + func (m *ClientCommand) MarshalTo(dAtA []byte) (int, error) + func (m *ClientCommand) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ClientCommand) Reset() + func (m *ClientCommand) Size() (n int) + func (m *ClientCommand) String() string + func (m *ClientCommand) Unmarshal(dAtA []byte) error + func (m *ClientCommand) XXX_DiscardUnknown() + func (m *ClientCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClientCommand) XXX_Merge(src proto.Message) + func (m *ClientCommand) XXX_Size() int + func (m *ClientCommand) XXX_Unmarshal(b []byte) error + type ClientCommand_Command int32 + const ClientCommand_HELLO + const ClientCommand_PUSH_DISABLE + const ClientCommand_PUSH_ENABLE + const ClientCommand_PUSH_PAUSE + const ClientCommand_PUSH_RESUME + const ClientCommand_REQUEST + const ClientCommand_UPDATE_CONFIG + func (ClientCommand_Command) EnumDescriptor() ([]byte, []int) + func (x ClientCommand_Command) String() string + type ClientCommand_Source int32 + const ClientCommand_EVENTS + const ClientCommand_RUNTIME + const ClientCommand_STATE + func (ClientCommand_Source) EnumDescriptor() ([]byte, []int) + func (x ClientCommand_Source) String() string + type CommandResponse struct + EffectiveConfig *Configuration + Error string + Id uint64 + Result CommandResponse_Result + func (*CommandResponse) Descriptor() ([]byte, []int) + func (*CommandResponse) ProtoMessage() + func (m *CommandResponse) GetEffectiveConfig() *Configuration + func (m *CommandResponse) GetError() string + func (m *CommandResponse) GetId() uint64 + func (m *CommandResponse) GetResult() CommandResponse_Result + func (m *CommandResponse) Marshal() (dAtA []byte, err error) + func (m *CommandResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandResponse) Reset() + func (m *CommandResponse) Size() (n int) + func (m *CommandResponse) String() string + func (m *CommandResponse) Unmarshal(dAtA []byte) error + func (m *CommandResponse) XXX_DiscardUnknown() + func (m *CommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandResponse) XXX_Merge(src proto.Message) + func (m *CommandResponse) XXX_Size() int + func (m *CommandResponse) XXX_Unmarshal(b []byte) error + type CommandResponse_Result int32 + const CommandResponse_ERR + const CommandResponse_OK + func (CommandResponse_Result) EnumDescriptor() ([]byte, []int) + func (x CommandResponse_Result) String() string + type Configuration struct + RetentionPeriodMs uint64 + StateSnapshotIntervalMs uint64 + func (*Configuration) Descriptor() ([]byte, []int) + func (*Configuration) ProtoMessage() + func (m *Configuration) GetRetentionPeriodMs() uint64 + func (m *Configuration) GetStateSnapshotIntervalMs() uint64 + func (m *Configuration) Marshal() (dAtA []byte, err error) + func (m *Configuration) MarshalTo(dAtA []byte) (int, error) + func (m *Configuration) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Configuration) Reset() + func (m *Configuration) Size() (n int) + func (m *Configuration) String() string + func (m *Configuration) Unmarshal(dAtA []byte) error + func (m *Configuration) XXX_DiscardUnknown() + func (m *Configuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Configuration) XXX_Merge(src proto.Message) + func (m *Configuration) XXX_Size() int + func (m *Configuration) XXX_Unmarshal(b []byte) error + type Connection struct + Attribs *Connection_Attributes + Endpoints *EndpointPair + Id []byte + LatencyNs uint64 + PeerId string + RelayedOver isConnection_RelayedOver + Role Role + Status Status + Streams *StreamList + Timeline *Connection_Timeline + Traffic *Traffic + TransportId []byte + UserProvidedTags []string + func (*Connection) Descriptor() ([]byte, []int) + func (*Connection) ProtoMessage() + func (*Connection) XXX_OneofWrappers() []interface{} + func (m *Connection) GetAttribs() *Connection_Attributes + func (m *Connection) GetConn() *Connection + func (m *Connection) GetConnId() []byte + func (m *Connection) GetEndpoints() *EndpointPair + func (m *Connection) GetId() []byte + func (m *Connection) GetLatencyNs() uint64 + func (m *Connection) GetPeerId() string + func (m *Connection) GetRelayedOver() isConnection_RelayedOver + func (m *Connection) GetRole() Role + func (m *Connection) GetStatus() Status + func (m *Connection) GetStreams() *StreamList + func (m *Connection) GetTimeline() *Connection_Timeline + func (m *Connection) GetTraffic() *Traffic + func (m *Connection) GetTransportId() []byte + func (m *Connection) GetUserProvidedTags() []string + func (m *Connection) Marshal() (dAtA []byte, err error) + func (m *Connection) MarshalTo(dAtA []byte) (int, error) + func (m *Connection) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Connection) Reset() + func (m *Connection) Size() (n int) + func (m *Connection) String() string + func (m *Connection) Unmarshal(dAtA []byte) error + func (m *Connection) XXX_DiscardUnknown() + func (m *Connection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Connection) XXX_Merge(src proto.Message) + func (m *Connection) XXX_Size() int + func (m *Connection) XXX_Unmarshal(b []byte) error + type Connection_Attributes struct + Encryption string + Multiplexer string + func (*Connection_Attributes) Descriptor() ([]byte, []int) + func (*Connection_Attributes) ProtoMessage() + func (m *Connection_Attributes) GetEncryption() string + func (m *Connection_Attributes) GetMultiplexer() string + func (m *Connection_Attributes) Marshal() (dAtA []byte, err error) + func (m *Connection_Attributes) MarshalTo(dAtA []byte) (int, error) + func (m *Connection_Attributes) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Connection_Attributes) Reset() + func (m *Connection_Attributes) Size() (n int) + func (m *Connection_Attributes) String() string + func (m *Connection_Attributes) Unmarshal(dAtA []byte) error + func (m *Connection_Attributes) XXX_DiscardUnknown() + func (m *Connection_Attributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Connection_Attributes) XXX_Merge(src proto.Message) + func (m *Connection_Attributes) XXX_Size() int + func (m *Connection_Attributes) XXX_Unmarshal(b []byte) error + type Connection_Conn struct + Conn *Connection + func (m *Connection_Conn) MarshalTo(dAtA []byte) (int, error) + func (m *Connection_Conn) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Connection_Conn) Size() (n int) + type Connection_ConnId struct + ConnId []byte + func (m *Connection_ConnId) MarshalTo(dAtA []byte) (int, error) + func (m *Connection_ConnId) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Connection_ConnId) Size() (n int) + type Connection_Timeline struct + CloseTs uint64 + OpenTs uint64 + UpgradedTs uint64 + func (*Connection_Timeline) Descriptor() ([]byte, []int) + func (*Connection_Timeline) ProtoMessage() + func (m *Connection_Timeline) GetCloseTs() uint64 + func (m *Connection_Timeline) GetOpenTs() uint64 + func (m *Connection_Timeline) GetUpgradedTs() uint64 + func (m *Connection_Timeline) Marshal() (dAtA []byte, err error) + func (m *Connection_Timeline) MarshalTo(dAtA []byte) (int, error) + func (m *Connection_Timeline) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Connection_Timeline) Reset() + func (m *Connection_Timeline) Size() (n int) + func (m *Connection_Timeline) String() string + func (m *Connection_Timeline) Unmarshal(dAtA []byte) error + func (m *Connection_Timeline) XXX_DiscardUnknown() + func (m *Connection_Timeline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Connection_Timeline) XXX_Merge(src proto.Message) + func (m *Connection_Timeline) XXX_Size() int + func (m *Connection_Timeline) XXX_Unmarshal(b []byte) error + type DHT struct + Buckets []*DHT_Bucket + Enabled bool + IncomingQueries *DHT_QueryGauge + OutgoingQueries *DHT_QueryGauge + Params *DHT_Params + Protocol string + StartTs uint64 + func (*DHT) Descriptor() ([]byte, []int) + func (*DHT) ProtoMessage() + func (m *DHT) GetBuckets() []*DHT_Bucket + func (m *DHT) GetEnabled() bool + func (m *DHT) GetIncomingQueries() *DHT_QueryGauge + func (m *DHT) GetOutgoingQueries() *DHT_QueryGauge + func (m *DHT) GetParams() *DHT_Params + func (m *DHT) GetProtocol() string + func (m *DHT) GetStartTs() uint64 + func (m *DHT) Marshal() (dAtA []byte, err error) + func (m *DHT) MarshalTo(dAtA []byte) (int, error) + func (m *DHT) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DHT) Reset() + func (m *DHT) Size() (n int) + func (m *DHT) String() string + func (m *DHT) Unmarshal(dAtA []byte) error + func (m *DHT) XXX_DiscardUnknown() + func (m *DHT) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DHT) XXX_Merge(src proto.Message) + func (m *DHT) XXX_Size() int + func (m *DHT) XXX_Unmarshal(b []byte) error + type DHT_Bucket struct + Cpl uint32 + Peers []*DHT_PeerInDHT + func (*DHT_Bucket) Descriptor() ([]byte, []int) + func (*DHT_Bucket) ProtoMessage() + func (m *DHT_Bucket) GetCpl() uint32 + func (m *DHT_Bucket) GetPeers() []*DHT_PeerInDHT + func (m *DHT_Bucket) Marshal() (dAtA []byte, err error) + func (m *DHT_Bucket) MarshalTo(dAtA []byte) (int, error) + func (m *DHT_Bucket) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DHT_Bucket) Reset() + func (m *DHT_Bucket) Size() (n int) + func (m *DHT_Bucket) String() string + func (m *DHT_Bucket) Unmarshal(dAtA []byte) error + func (m *DHT_Bucket) XXX_DiscardUnknown() + func (m *DHT_Bucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DHT_Bucket) XXX_Merge(src proto.Message) + func (m *DHT_Bucket) XXX_Size() int + func (m *DHT_Bucket) XXX_Unmarshal(b []byte) error + type DHT_Params struct + Alpha uint64 + Beta uint64 + DisjointPaths uint64 + K uint64 + func (*DHT_Params) Descriptor() ([]byte, []int) + func (*DHT_Params) ProtoMessage() + func (m *DHT_Params) GetAlpha() uint64 + func (m *DHT_Params) GetBeta() uint64 + func (m *DHT_Params) GetDisjointPaths() uint64 + func (m *DHT_Params) GetK() uint64 + func (m *DHT_Params) Marshal() (dAtA []byte, err error) + func (m *DHT_Params) MarshalTo(dAtA []byte) (int, error) + func (m *DHT_Params) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DHT_Params) Reset() + func (m *DHT_Params) Size() (n int) + func (m *DHT_Params) String() string + func (m *DHT_Params) Unmarshal(dAtA []byte) error + func (m *DHT_Params) XXX_DiscardUnknown() + func (m *DHT_Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DHT_Params) XXX_Merge(src proto.Message) + func (m *DHT_Params) XXX_Size() int + func (m *DHT_Params) XXX_Unmarshal(b []byte) error + type DHT_PeerInDHT struct + AgeInBucket uint32 + PeerId string + Status DHT_PeerInDHT_Status + func (*DHT_PeerInDHT) Descriptor() ([]byte, []int) + func (*DHT_PeerInDHT) ProtoMessage() + func (m *DHT_PeerInDHT) GetAgeInBucket() uint32 + func (m *DHT_PeerInDHT) GetPeerId() string + func (m *DHT_PeerInDHT) GetStatus() DHT_PeerInDHT_Status + func (m *DHT_PeerInDHT) Marshal() (dAtA []byte, err error) + func (m *DHT_PeerInDHT) MarshalTo(dAtA []byte) (int, error) + func (m *DHT_PeerInDHT) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DHT_PeerInDHT) Reset() + func (m *DHT_PeerInDHT) Size() (n int) + func (m *DHT_PeerInDHT) String() string + func (m *DHT_PeerInDHT) Unmarshal(dAtA []byte) error + func (m *DHT_PeerInDHT) XXX_DiscardUnknown() + func (m *DHT_PeerInDHT) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DHT_PeerInDHT) XXX_Merge(src proto.Message) + func (m *DHT_PeerInDHT) XXX_Size() int + func (m *DHT_PeerInDHT) XXX_Unmarshal(b []byte) error + type DHT_PeerInDHT_Status int32 + const DHT_PeerInDHT_ACTIVE + const DHT_PeerInDHT_CANDIDATE + const DHT_PeerInDHT_MISSING + const DHT_PeerInDHT_REJECTED + func (DHT_PeerInDHT_Status) EnumDescriptor() ([]byte, []int) + func (x DHT_PeerInDHT_Status) String() string + type DHT_QueryGauge struct + Error uint64 + Success uint64 + Timeout uint64 + func (*DHT_QueryGauge) Descriptor() ([]byte, []int) + func (*DHT_QueryGauge) ProtoMessage() + func (m *DHT_QueryGauge) GetError() uint64 + func (m *DHT_QueryGauge) GetSuccess() uint64 + func (m *DHT_QueryGauge) GetTimeout() uint64 + func (m *DHT_QueryGauge) Marshal() (dAtA []byte, err error) + func (m *DHT_QueryGauge) MarshalTo(dAtA []byte) (int, error) + func (m *DHT_QueryGauge) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DHT_QueryGauge) Reset() + func (m *DHT_QueryGauge) Size() (n int) + func (m *DHT_QueryGauge) String() string + func (m *DHT_QueryGauge) Unmarshal(dAtA []byte) error + func (m *DHT_QueryGauge) XXX_DiscardUnknown() + func (m *DHT_QueryGauge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DHT_QueryGauge) XXX_Merge(src proto.Message) + func (m *DHT_QueryGauge) XXX_Size() int + func (m *DHT_QueryGauge) XXX_Unmarshal(b []byte) error + type DataGauge struct + CumBytes uint64 + CumPackets uint64 + InstBw uint64 + func (*DataGauge) Descriptor() ([]byte, []int) + func (*DataGauge) ProtoMessage() + func (m *DataGauge) GetCumBytes() uint64 + func (m *DataGauge) GetCumPackets() uint64 + func (m *DataGauge) GetInstBw() uint64 + func (m *DataGauge) Marshal() (dAtA []byte, err error) + func (m *DataGauge) MarshalTo(dAtA []byte) (int, error) + func (m *DataGauge) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DataGauge) Reset() + func (m *DataGauge) Size() (n int) + func (m *DataGauge) String() string + func (m *DataGauge) Unmarshal(dAtA []byte) error + func (m *DataGauge) XXX_DiscardUnknown() + func (m *DataGauge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DataGauge) XXX_Merge(src proto.Message) + func (m *DataGauge) XXX_Size() int + func (m *DataGauge) XXX_Unmarshal(b []byte) error + type EndpointPair struct + DstMultiaddr string + SrcMultiaddr string + func (*EndpointPair) Descriptor() ([]byte, []int) + func (*EndpointPair) ProtoMessage() + func (m *EndpointPair) GetDstMultiaddr() string + func (m *EndpointPair) GetSrcMultiaddr() string + func (m *EndpointPair) Marshal() (dAtA []byte, err error) + func (m *EndpointPair) MarshalTo(dAtA []byte) (int, error) + func (m *EndpointPair) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EndpointPair) Reset() + func (m *EndpointPair) Size() (n int) + func (m *EndpointPair) String() string + func (m *EndpointPair) Unmarshal(dAtA []byte) error + func (m *EndpointPair) XXX_DiscardUnknown() + func (m *EndpointPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EndpointPair) XXX_Merge(src proto.Message) + func (m *EndpointPair) XXX_Size() int + func (m *EndpointPair) XXX_Unmarshal(b []byte) error + type Event struct + Content string + Ts uint64 + Type *EventType + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (m *Event) GetContent() string + func (m *Event) GetTs() uint64 + func (m *Event) GetType() *EventType + func (m *Event) Marshal() (dAtA []byte, err error) + func (m *Event) MarshalTo(dAtA []byte) (int, error) + func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event) Reset() + func (m *Event) Size() (n int) + func (m *Event) String() string + func (m *Event) Unmarshal(dAtA []byte) error + func (m *Event) XXX_DiscardUnknown() + func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Event) XXX_Merge(src proto.Message) + func (m *Event) XXX_Size() int + func (m *Event) XXX_Unmarshal(b []byte) error + type EventType struct + Name string + PropertyTypes []*EventType_EventProperty + func (*EventType) Descriptor() ([]byte, []int) + func (*EventType) ProtoMessage() + func (m *EventType) GetName() string + func (m *EventType) GetPropertyTypes() []*EventType_EventProperty + func (m *EventType) Marshal() (dAtA []byte, err error) + func (m *EventType) MarshalTo(dAtA []byte) (int, error) + func (m *EventType) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventType) Reset() + func (m *EventType) Size() (n int) + func (m *EventType) String() string + func (m *EventType) Unmarshal(dAtA []byte) error + func (m *EventType) XXX_DiscardUnknown() + func (m *EventType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventType) XXX_Merge(src proto.Message) + func (m *EventType) XXX_Size() int + func (m *EventType) XXX_Unmarshal(b []byte) error + type EventType_EventProperty struct + HasMultiple bool + Name string + Type EventType_EventProperty_PropertyType + func (*EventType_EventProperty) Descriptor() ([]byte, []int) + func (*EventType_EventProperty) ProtoMessage() + func (m *EventType_EventProperty) GetHasMultiple() bool + func (m *EventType_EventProperty) GetName() string + func (m *EventType_EventProperty) GetType() EventType_EventProperty_PropertyType + func (m *EventType_EventProperty) Marshal() (dAtA []byte, err error) + func (m *EventType_EventProperty) MarshalTo(dAtA []byte) (int, error) + func (m *EventType_EventProperty) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventType_EventProperty) Reset() + func (m *EventType_EventProperty) Size() (n int) + func (m *EventType_EventProperty) String() string + func (m *EventType_EventProperty) Unmarshal(dAtA []byte) error + func (m *EventType_EventProperty) XXX_DiscardUnknown() + func (m *EventType_EventProperty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventType_EventProperty) XXX_Merge(src proto.Message) + func (m *EventType_EventProperty) XXX_Size() int + func (m *EventType_EventProperty) XXX_Unmarshal(b []byte) error + type EventType_EventProperty_PropertyType int32 + const EventType_EventProperty_JSON + const EventType_EventProperty_MULTIADDR + const EventType_EventProperty_NUMBER + const EventType_EventProperty_PEERID + const EventType_EventProperty_STRING + const EventType_EventProperty_TIME + func (EventType_EventProperty_PropertyType) EnumDescriptor() ([]byte, []int) + func (x EventType_EventProperty_PropertyType) String() string + type ResultCounter struct + Err uint32 + Ok uint32 + Total uint32 + func (*ResultCounter) Descriptor() ([]byte, []int) + func (*ResultCounter) ProtoMessage() + func (m *ResultCounter) GetErr() uint32 + func (m *ResultCounter) GetOk() uint32 + func (m *ResultCounter) GetTotal() uint32 + func (m *ResultCounter) Marshal() (dAtA []byte, err error) + func (m *ResultCounter) MarshalTo(dAtA []byte) (int, error) + func (m *ResultCounter) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResultCounter) Reset() + func (m *ResultCounter) Size() (n int) + func (m *ResultCounter) String() string + func (m *ResultCounter) Unmarshal(dAtA []byte) error + func (m *ResultCounter) XXX_DiscardUnknown() + func (m *ResultCounter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResultCounter) XXX_Merge(src proto.Message) + func (m *ResultCounter) XXX_Size() int + func (m *ResultCounter) XXX_Unmarshal(b []byte) error + type Role int32 + const Role_INITIATOR + const Role_RESPONDER + func (Role) EnumDescriptor() ([]byte, []int) + func (x Role) String() string + type Runtime struct + EventTypes []*EventType + Implementation string + PeerId string + Platform string + Version string + func (*Runtime) Descriptor() ([]byte, []int) + func (*Runtime) ProtoMessage() + func (m *Runtime) GetEventTypes() []*EventType + func (m *Runtime) GetImplementation() string + func (m *Runtime) GetPeerId() string + func (m *Runtime) GetPlatform() string + func (m *Runtime) GetVersion() string + func (m *Runtime) Marshal() (dAtA []byte, err error) + func (m *Runtime) MarshalTo(dAtA []byte) (int, error) + func (m *Runtime) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Runtime) Reset() + func (m *Runtime) Size() (n int) + func (m *Runtime) String() string + func (m *Runtime) Unmarshal(dAtA []byte) error + func (m *Runtime) XXX_DiscardUnknown() + func (m *Runtime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Runtime) XXX_Merge(src proto.Message) + func (m *Runtime) XXX_Size() int + func (m *Runtime) XXX_Unmarshal(b []byte) error + type ServerMessage struct + Payload isServerMessage_Payload + Version *Version + func (*ServerMessage) Descriptor() ([]byte, []int) + func (*ServerMessage) ProtoMessage() + func (*ServerMessage) XXX_OneofWrappers() []interface{} + func (m *ServerMessage) GetEvent() *Event + func (m *ServerMessage) GetNotice() *ServerNotice + func (m *ServerMessage) GetPayload() isServerMessage_Payload + func (m *ServerMessage) GetResponse() *CommandResponse + func (m *ServerMessage) GetRuntime() *Runtime + func (m *ServerMessage) GetState() *State + func (m *ServerMessage) GetVersion() *Version + func (m *ServerMessage) Marshal() (dAtA []byte, err error) + func (m *ServerMessage) MarshalTo(dAtA []byte) (int, error) + func (m *ServerMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ServerMessage) Reset() + func (m *ServerMessage) Size() (n int) + func (m *ServerMessage) String() string + func (m *ServerMessage) Unmarshal(dAtA []byte) error + func (m *ServerMessage) XXX_DiscardUnknown() + func (m *ServerMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServerMessage) XXX_Merge(src proto.Message) + func (m *ServerMessage) XXX_Size() int + func (m *ServerMessage) XXX_Unmarshal(b []byte) error + type ServerMessage_Event struct + Event *Event + func (m *ServerMessage_Event) MarshalTo(dAtA []byte) (int, error) + func (m *ServerMessage_Event) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ServerMessage_Event) Size() (n int) + type ServerMessage_Notice struct + Notice *ServerNotice + func (m *ServerMessage_Notice) MarshalTo(dAtA []byte) (int, error) + func (m *ServerMessage_Notice) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ServerMessage_Notice) Size() (n int) + type ServerMessage_Response struct + Response *CommandResponse + func (m *ServerMessage_Response) MarshalTo(dAtA []byte) (int, error) + func (m *ServerMessage_Response) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ServerMessage_Response) Size() (n int) + type ServerMessage_Runtime struct + Runtime *Runtime + func (m *ServerMessage_Runtime) MarshalTo(dAtA []byte) (int, error) + func (m *ServerMessage_Runtime) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ServerMessage_Runtime) Size() (n int) + type ServerMessage_State struct + State *State + func (m *ServerMessage_State) MarshalTo(dAtA []byte) (int, error) + func (m *ServerMessage_State) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ServerMessage_State) Size() (n int) + type ServerNotice struct + Kind ServerNotice_Kind + func (*ServerNotice) Descriptor() ([]byte, []int) + func (*ServerNotice) ProtoMessage() + func (m *ServerNotice) GetKind() ServerNotice_Kind + func (m *ServerNotice) Marshal() (dAtA []byte, err error) + func (m *ServerNotice) MarshalTo(dAtA []byte) (int, error) + func (m *ServerNotice) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ServerNotice) Reset() + func (m *ServerNotice) Size() (n int) + func (m *ServerNotice) String() string + func (m *ServerNotice) Unmarshal(dAtA []byte) error + func (m *ServerNotice) XXX_DiscardUnknown() + func (m *ServerNotice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServerNotice) XXX_Merge(src proto.Message) + func (m *ServerNotice) XXX_Size() int + func (m *ServerNotice) XXX_Unmarshal(b []byte) error + type ServerNotice_Kind int32 + const ServerNotice_DISCARDING_EVENTS + func (ServerNotice_Kind) EnumDescriptor() ([]byte, []int) + func (x ServerNotice_Kind) String() string + type SlidingCounter struct + Over_12Hr uint32 + Over_15M uint32 + Over_1Hr uint32 + Over_1M uint32 + Over_24Hr uint32 + Over_2Hr uint32 + Over_30M uint32 + Over_4Hr uint32 + Over_5M uint32 + Over_8Hr uint32 + func (*SlidingCounter) Descriptor() ([]byte, []int) + func (*SlidingCounter) ProtoMessage() + func (m *SlidingCounter) GetOver_12Hr() uint32 + func (m *SlidingCounter) GetOver_15M() uint32 + func (m *SlidingCounter) GetOver_1Hr() uint32 + func (m *SlidingCounter) GetOver_1M() uint32 + func (m *SlidingCounter) GetOver_24Hr() uint32 + func (m *SlidingCounter) GetOver_2Hr() uint32 + func (m *SlidingCounter) GetOver_30M() uint32 + func (m *SlidingCounter) GetOver_4Hr() uint32 + func (m *SlidingCounter) GetOver_5M() uint32 + func (m *SlidingCounter) GetOver_8Hr() uint32 + func (m *SlidingCounter) Marshal() (dAtA []byte, err error) + func (m *SlidingCounter) MarshalTo(dAtA []byte) (int, error) + func (m *SlidingCounter) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SlidingCounter) Reset() + func (m *SlidingCounter) Size() (n int) + func (m *SlidingCounter) String() string + func (m *SlidingCounter) Unmarshal(dAtA []byte) error + func (m *SlidingCounter) XXX_DiscardUnknown() + func (m *SlidingCounter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SlidingCounter) XXX_Merge(src proto.Message) + func (m *SlidingCounter) XXX_Size() int + func (m *SlidingCounter) XXX_Unmarshal(b []byte) error + type State struct + InstantTs uint64 + SnapshotDurationMs uint32 + StartTs uint64 + Subsystems *Subsystems + Traffic *Traffic + func (*State) Descriptor() ([]byte, []int) + func (*State) ProtoMessage() + func (m *State) GetInstantTs() uint64 + func (m *State) GetSnapshotDurationMs() uint32 + func (m *State) GetStartTs() uint64 + func (m *State) GetSubsystems() *Subsystems + func (m *State) GetTraffic() *Traffic + func (m *State) Marshal() (dAtA []byte, err error) + func (m *State) MarshalTo(dAtA []byte) (int, error) + func (m *State) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *State) Reset() + func (m *State) Size() (n int) + func (m *State) String() string + func (m *State) Unmarshal(dAtA []byte) error + func (m *State) XXX_DiscardUnknown() + func (m *State) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *State) XXX_Merge(src proto.Message) + func (m *State) XXX_Size() int + func (m *State) XXX_Unmarshal(b []byte) error + type Status int32 + const Status_ACTIVE + const Status_CLOSED + const Status_CLOSING + const Status_ERROR + const Status_OPENING + func (Status) EnumDescriptor() ([]byte, []int) + func (x Status) String() string + type Stream struct + Conn *Stream_ConnectionRef + Id []byte + LatencyNs uint64 + Protocol string + Role Role + Status Status + Timeline *Stream_Timeline + Traffic *Traffic + UserProvidedTags []string + func (*Stream) Descriptor() ([]byte, []int) + func (*Stream) ProtoMessage() + func (m *Stream) GetConn() *Stream_ConnectionRef + func (m *Stream) GetId() []byte + func (m *Stream) GetLatencyNs() uint64 + func (m *Stream) GetProtocol() string + func (m *Stream) GetRole() Role + func (m *Stream) GetStatus() Status + func (m *Stream) GetTimeline() *Stream_Timeline + func (m *Stream) GetTraffic() *Traffic + func (m *Stream) GetUserProvidedTags() []string + func (m *Stream) Marshal() (dAtA []byte, err error) + func (m *Stream) MarshalTo(dAtA []byte) (int, error) + func (m *Stream) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Stream) Reset() + func (m *Stream) Size() (n int) + func (m *Stream) String() string + func (m *Stream) Unmarshal(dAtA []byte) error + func (m *Stream) XXX_DiscardUnknown() + func (m *Stream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Stream) XXX_Merge(src proto.Message) + func (m *Stream) XXX_Size() int + func (m *Stream) XXX_Unmarshal(b []byte) error + type StreamList struct + StreamIds [][]byte + Streams []*Stream + func (*StreamList) Descriptor() ([]byte, []int) + func (*StreamList) ProtoMessage() + func (m *StreamList) GetStreamIds() [][]byte + func (m *StreamList) GetStreams() []*Stream + func (m *StreamList) Marshal() (dAtA []byte, err error) + func (m *StreamList) MarshalTo(dAtA []byte) (int, error) + func (m *StreamList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StreamList) Reset() + func (m *StreamList) Size() (n int) + func (m *StreamList) String() string + func (m *StreamList) Unmarshal(dAtA []byte) error + func (m *StreamList) XXX_DiscardUnknown() + func (m *StreamList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamList) XXX_Merge(src proto.Message) + func (m *StreamList) XXX_Size() int + func (m *StreamList) XXX_Unmarshal(b []byte) error + type Stream_ConnectionRef struct + Connection isStream_ConnectionRef_Connection + func (*Stream_ConnectionRef) Descriptor() ([]byte, []int) + func (*Stream_ConnectionRef) ProtoMessage() + func (*Stream_ConnectionRef) XXX_OneofWrappers() []interface{} + func (m *Stream_ConnectionRef) GetConn() *Connection + func (m *Stream_ConnectionRef) GetConnId() []byte + func (m *Stream_ConnectionRef) GetConnection() isStream_ConnectionRef_Connection + func (m *Stream_ConnectionRef) Marshal() (dAtA []byte, err error) + func (m *Stream_ConnectionRef) MarshalTo(dAtA []byte) (int, error) + func (m *Stream_ConnectionRef) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Stream_ConnectionRef) Reset() + func (m *Stream_ConnectionRef) Size() (n int) + func (m *Stream_ConnectionRef) String() string + func (m *Stream_ConnectionRef) Unmarshal(dAtA []byte) error + func (m *Stream_ConnectionRef) XXX_DiscardUnknown() + func (m *Stream_ConnectionRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Stream_ConnectionRef) XXX_Merge(src proto.Message) + func (m *Stream_ConnectionRef) XXX_Size() int + func (m *Stream_ConnectionRef) XXX_Unmarshal(b []byte) error + type Stream_ConnectionRef_Conn struct + Conn *Connection + func (m *Stream_ConnectionRef_Conn) MarshalTo(dAtA []byte) (int, error) + func (m *Stream_ConnectionRef_Conn) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Stream_ConnectionRef_Conn) Size() (n int) + type Stream_ConnectionRef_ConnId struct + ConnId []byte + func (m *Stream_ConnectionRef_ConnId) MarshalTo(dAtA []byte) (int, error) + func (m *Stream_ConnectionRef_ConnId) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Stream_ConnectionRef_ConnId) Size() (n int) + type Stream_Timeline struct + CloseTs uint64 + OpenTs uint64 + func (*Stream_Timeline) Descriptor() ([]byte, []int) + func (*Stream_Timeline) ProtoMessage() + func (m *Stream_Timeline) GetCloseTs() uint64 + func (m *Stream_Timeline) GetOpenTs() uint64 + func (m *Stream_Timeline) Marshal() (dAtA []byte, err error) + func (m *Stream_Timeline) MarshalTo(dAtA []byte) (int, error) + func (m *Stream_Timeline) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Stream_Timeline) Reset() + func (m *Stream_Timeline) Size() (n int) + func (m *Stream_Timeline) String() string + func (m *Stream_Timeline) Unmarshal(dAtA []byte) error + func (m *Stream_Timeline) XXX_DiscardUnknown() + func (m *Stream_Timeline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Stream_Timeline) XXX_Merge(src proto.Message) + func (m *Stream_Timeline) XXX_Size() int + func (m *Stream_Timeline) XXX_Unmarshal(b []byte) error + type Subsystems struct + Connections []*Connection + Dht *DHT + func (*Subsystems) Descriptor() ([]byte, []int) + func (*Subsystems) ProtoMessage() + func (m *Subsystems) GetConnections() []*Connection + func (m *Subsystems) GetDht() *DHT + func (m *Subsystems) Marshal() (dAtA []byte, err error) + func (m *Subsystems) MarshalTo(dAtA []byte) (int, error) + func (m *Subsystems) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Subsystems) Reset() + func (m *Subsystems) Size() (n int) + func (m *Subsystems) String() string + func (m *Subsystems) Unmarshal(dAtA []byte) error + func (m *Subsystems) XXX_DiscardUnknown() + func (m *Subsystems) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Subsystems) XXX_Merge(src proto.Message) + func (m *Subsystems) XXX_Size() int + func (m *Subsystems) XXX_Unmarshal(b []byte) error + type Traffic struct + TrafficIn *DataGauge + TrafficOut *DataGauge + func (*Traffic) Descriptor() ([]byte, []int) + func (*Traffic) ProtoMessage() + func (m *Traffic) GetTrafficIn() *DataGauge + func (m *Traffic) GetTrafficOut() *DataGauge + func (m *Traffic) Marshal() (dAtA []byte, err error) + func (m *Traffic) MarshalTo(dAtA []byte) (int, error) + func (m *Traffic) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Traffic) Reset() + func (m *Traffic) Size() (n int) + func (m *Traffic) String() string + func (m *Traffic) Unmarshal(dAtA []byte) error + func (m *Traffic) XXX_DiscardUnknown() + func (m *Traffic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Traffic) XXX_Merge(src proto.Message) + func (m *Traffic) XXX_Size() int + func (m *Traffic) XXX_Unmarshal(b []byte) error + type Version struct + Version uint32 + func (*Version) Descriptor() ([]byte, []int) + func (*Version) ProtoMessage() + func (m *Version) GetVersion() uint32 + func (m *Version) Marshal() (dAtA []byte, err error) + func (m *Version) MarshalTo(dAtA []byte) (int, error) + func (m *Version) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Version) Reset() + func (m *Version) Size() (n int) + func (m *Version) String() string + func (m *Version) Unmarshal(dAtA []byte) error + func (m *Version) XXX_DiscardUnknown() + func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Version) XXX_Merge(src proto.Message) + func (m *Version) XXX_Size() int + func (m *Version) XXX_Unmarshal(b []byte) error
Go to main page