Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pb

package

Go to main page

Versions in this module

v0

v0.19.1

Jul 5, 2022

v0.19.0

Jun 30, 2022

v0.18.0

Jun 30, 2022

v0.17.0

Jun 17, 2022

v0.16.1

May 25, 2022

v0.16.0

May 24, 2022

v0.15.1

Apr 18, 2022

v0.15.0

Apr 11, 2022

v0.14.0

Jan 17, 2022

v0.13.0

Dec 12, 2021

v0.12.0

Dec 2, 2021

v0.11.0

Oct 18, 2021

v0.10.0

Sep 8, 2021

v0.9.0

Jul 23, 2021

v0.8.6

Jul 16, 2021

v0.8.5

Feb 19, 2021

v0.8.4

Feb 18, 2021

v0.8.3

Feb 17, 2021

v0.8.2

Feb 17, 2021

v0.8.1

Feb 16, 2021

v0.8.0

Dec 19, 2020

v0.7.1

Feb 16, 2021

v0.7.0

Sep 2, 2020

v0.6.1

Jul 30, 2020

v0.6.0

Jun 5, 2020

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