pb

package

Go to main page

Versions in this module

v0

v0.24.2

Dec 31, 2022 GO-2023-2000 +1 more

GO-2023-2000: Large RSA keys can cause high resource usage in github.com/libp2p/go-libp2p

GO-2023-2024: Out-of-memory vulnerability in github.com/libp2p/go-libp2p

v0.24.1

Dec 12, 2022 GO-2023-2000 +1 more

GO-2023-2000: Large RSA keys can cause high resource usage in github.com/libp2p/go-libp2p

GO-2023-2024: Out-of-memory vulnerability in github.com/libp2p/go-libp2p

v0.24.0

Dec 6, 2022 GO-2023-2000 +1 more

GO-2023-2000: Large RSA keys can cause high resource usage in github.com/libp2p/go-libp2p

GO-2023-2024: Out-of-memory vulnerability in github.com/libp2p/go-libp2p

v0.24.0-dev

Sep 23, 2022 GO-2023-2000 +1 more

GO-2023-2000: Large RSA keys can cause high resource usage in github.com/libp2p/go-libp2p

GO-2023-2024: Out-of-memory vulnerability in github.com/libp2p/go-libp2p

v0.23.4

Nov 9, 2022 GO-2023-2000 +1 more

GO-2023-2000: Large RSA keys can cause high resource usage in github.com/libp2p/go-libp2p

GO-2023-2024: Out-of-memory vulnerability in github.com/libp2p/go-libp2p

v0.23.3

Nov 2, 2022 GO-2023-2000 +1 more

GO-2023-2000: Large RSA keys can cause high resource usage in github.com/libp2p/go-libp2p

GO-2023-2024: Out-of-memory vulnerability in github.com/libp2p/go-libp2p

v0.23.2

Sep 23, 2022 GO-2023-2000 +1 more

GO-2023-2000: Large RSA keys can cause high resource usage in github.com/libp2p/go-libp2p

GO-2023-2024: Out-of-memory vulnerability in github.com/libp2p/go-libp2p

v0.23.1

Sep 21, 2022 GO-2023-2000 +1 more

GO-2023-2000: Large RSA keys can cause high resource usage in github.com/libp2p/go-libp2p

GO-2023-2024: Out-of-memory vulnerability in github.com/libp2p/go-libp2p

v0.23.0

Sep 20, 2022 GO-2023-2000 +1 more

GO-2023-2000: Large RSA keys can cause high resource usage in github.com/libp2p/go-libp2p

GO-2023-2024: Out-of-memory vulnerability in github.com/libp2p/go-libp2p

v0.22.0

Aug 19, 2022 GO-2023-2000 +1 more

GO-2023-2000: Large RSA keys can cause high resource usage in github.com/libp2p/go-libp2p

GO-2023-2024: Out-of-memory vulnerability in github.com/libp2p/go-libp2p

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL