Versions in this module Expand all Collapse all v1 v1.1.0 Dec 19, 2019 Changes in this version + const PROTO_CONTENT_MSG + const PROTO_KEYS_MSG + const PROTO_LEGACY_COMBINED_KEYS_AND_CONTENT_MSG + type ProtoKey struct + EncodingPath string + Version string + func EncodingPathsSupported() []*ProtoKey + type ProtoMsgType int + type ProtoMsgs struct + func EncodingPathToMessageReflectionSet(p *ProtoKey) *ProtoMsgs + func (p *ProtoMsgs) MessageReflection(t ProtoMsgType) reflect.Type + type Telemetry struct + CollectionEndTime uint64 + CollectionId uint64 + CollectionStartTime uint64 + DataGpb *TelemetryGPBTable + DataGpbkv []*TelemetryField + EncodingPath string + ModelVersion string + MsgTimestamp uint64 + NodeId isTelemetry_NodeId + Subscription isTelemetry_Subscription + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Telemetry) Descriptor() ([]byte, []int) + func (*Telemetry) ProtoMessage() + func (*Telemetry) XXX_OneofWrappers() []interface{} + func (m *Telemetry) GetCollectionEndTime() uint64 + func (m *Telemetry) GetCollectionId() uint64 + func (m *Telemetry) GetCollectionStartTime() uint64 + func (m *Telemetry) GetDataGpb() *TelemetryGPBTable + func (m *Telemetry) GetDataGpbkv() []*TelemetryField + func (m *Telemetry) GetEncodingPath() string + func (m *Telemetry) GetModelVersion() string + func (m *Telemetry) GetMsgTimestamp() uint64 + func (m *Telemetry) GetNodeId() isTelemetry_NodeId + func (m *Telemetry) GetNodeIdStr() string + func (m *Telemetry) GetSubscription() isTelemetry_Subscription + func (m *Telemetry) GetSubscriptionIdStr() string + func (m *Telemetry) Reset() + func (m *Telemetry) String() string + func (m *Telemetry) XXX_DiscardUnknown() + func (m *Telemetry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Telemetry) XXX_Merge(src proto.Message) + func (m *Telemetry) XXX_Size() int + func (m *Telemetry) XXX_Unmarshal(b []byte) error + type TelemetryField struct + Delete bool + Fields []*TelemetryField + Name string + Timestamp uint64 + ValueByType isTelemetryField_ValueByType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TelemetryField) Descriptor() ([]byte, []int) + func (*TelemetryField) ProtoMessage() + func (*TelemetryField) XXX_OneofWrappers() []interface{} + func (m *TelemetryField) GetBoolValue() bool + func (m *TelemetryField) GetBytesValue() []byte + func (m *TelemetryField) GetDelete() bool + func (m *TelemetryField) GetDoubleValue() float64 + func (m *TelemetryField) GetFields() []*TelemetryField + func (m *TelemetryField) GetFloatValue() float32 + func (m *TelemetryField) GetName() string + func (m *TelemetryField) GetSint32Value() int32 + func (m *TelemetryField) GetSint64Value() int64 + func (m *TelemetryField) GetStringValue() string + func (m *TelemetryField) GetTimestamp() uint64 + func (m *TelemetryField) GetUint32Value() uint32 + func (m *TelemetryField) GetUint64Value() uint64 + func (m *TelemetryField) GetValueByType() isTelemetryField_ValueByType + func (m *TelemetryField) Reset() + func (m *TelemetryField) String() string + func (m *TelemetryField) XXX_DiscardUnknown() + func (m *TelemetryField) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TelemetryField) XXX_Merge(src proto.Message) + func (m *TelemetryField) XXX_Size() int + func (m *TelemetryField) XXX_Unmarshal(b []byte) error + type TelemetryField_BoolValue struct + BoolValue bool + type TelemetryField_BytesValue struct + BytesValue []byte + type TelemetryField_DoubleValue struct + DoubleValue float64 + type TelemetryField_FloatValue struct + FloatValue float32 + type TelemetryField_Sint32Value struct + Sint32Value int32 + type TelemetryField_Sint64Value struct + Sint64Value int64 + type TelemetryField_StringValue struct + StringValue string + type TelemetryField_Uint32Value struct + Uint32Value uint32 + type TelemetryField_Uint64Value struct + Uint64Value uint64 + type TelemetryGPBTable struct + Row []*TelemetryRowGPB + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TelemetryGPBTable) Descriptor() ([]byte, []int) + func (*TelemetryGPBTable) ProtoMessage() + func (m *TelemetryGPBTable) GetRow() []*TelemetryRowGPB + func (m *TelemetryGPBTable) Reset() + func (m *TelemetryGPBTable) String() string + func (m *TelemetryGPBTable) XXX_DiscardUnknown() + func (m *TelemetryGPBTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TelemetryGPBTable) XXX_Merge(src proto.Message) + func (m *TelemetryGPBTable) XXX_Size() int + func (m *TelemetryGPBTable) XXX_Unmarshal(b []byte) error + type TelemetryRowGPB struct + Content []byte + Keys []byte + Timestamp uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TelemetryRowGPB) Descriptor() ([]byte, []int) + func (*TelemetryRowGPB) ProtoMessage() + func (m *TelemetryRowGPB) GetContent() []byte + func (m *TelemetryRowGPB) GetKeys() []byte + func (m *TelemetryRowGPB) GetTimestamp() uint64 + func (m *TelemetryRowGPB) Reset() + func (m *TelemetryRowGPB) String() string + func (m *TelemetryRowGPB) XXX_DiscardUnknown() + func (m *TelemetryRowGPB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TelemetryRowGPB) XXX_Merge(src proto.Message) + func (m *TelemetryRowGPB) XXX_Size() int + func (m *TelemetryRowGPB) XXX_Unmarshal(b []byte) error + type Telemetry_NodeIdStr struct + NodeIdStr string + type Telemetry_SubscriptionIdStr struct + SubscriptionIdStr string