telemetry

package
v0.0.0-...-8759746 Latest Latest
Warning

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

Go to latest
Published: Jul 8, 2021 License: MIT Imports: 3 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var TelemetrySelfDefinedEvent_ThresholdRelation_name = map[int32]string{
	0: "ThresholdRelation_INVALID",
	1: "ThresholdRelation_AND",
	2: "ThresholdRelation_OR",
}
View Source
var TelemetrySelfDefinedEvent_ThresholdRelation_value = map[string]int32{
	"ThresholdRelation_INVALID": 0,
	"ThresholdRelation_AND":     1,
	"ThresholdRelation_OR":      2,
}
View Source
var TelemetryThreshold_ThresholdOpType_name = map[int32]string{
	0: "ThresholdOpType_EQ",
	1: "ThresholdOpType_GT",
	2: "ThresholdOpType_GE",
	3: "ThresholdOpType_LT",
	4: "ThresholdOpType_LE",
}
View Source
var TelemetryThreshold_ThresholdOpType_value = map[string]int32{
	"ThresholdOpType_EQ": 0,
	"ThresholdOpType_GT": 1,
	"ThresholdOpType_GE": 2,
	"ThresholdOpType_LT": 3,
	"ThresholdOpType_LE": 4,
}
View Source
var Telemetry_Encoding_name = map[int32]string{
	0: "Encoding_GPB",
	1: "Encoding_JSON",
}
View Source
var Telemetry_Encoding_value = map[string]int32{
	"Encoding_GPB":  0,
	"Encoding_JSON": 1,
}

Functions

This section is empty.

Types

type Telemetry

type Telemetry struct {
	NodeIdStr            string             `protobuf:"bytes,1,opt,name=node_id_str,json=nodeIdStr,proto3" json:"node_id_str,omitempty"`
	SubscriptionIdStr    string             `protobuf:"bytes,2,opt,name=subscription_id_str,json=subscriptionIdStr,proto3" json:"subscription_id_str,omitempty"`
	SensorPath           string             `protobuf:"bytes,3,opt,name=sensor_path,json=sensorPath,proto3" json:"sensor_path,omitempty"`
	CollectionId         uint64             `protobuf:"varint,4,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	CollectionStartTime  uint64             `protobuf:"varint,5,opt,name=collection_start_time,json=collectionStartTime,proto3" json:"collection_start_time,omitempty"`
	MsgTimestamp         uint64             `protobuf:"varint,6,opt,name=msg_timestamp,json=msgTimestamp,proto3" json:"msg_timestamp,omitempty"`
	DataGpb              *TelemetryGPBTable `protobuf:"bytes,7,opt,name=data_gpb,json=dataGpb,proto3" json:"data_gpb,omitempty"`
	CollectionEndTime    uint64             `protobuf:"varint,8,opt,name=collection_end_time,json=collectionEndTime,proto3" json:"collection_end_time,omitempty"`
	CurrentPeriod        uint32             `protobuf:"varint,9,opt,name=current_period,json=currentPeriod,proto3" json:"current_period,omitempty"`
	ExceptDesc           string             `protobuf:"bytes,10,opt,name=except_desc,json=exceptDesc,proto3" json:"except_desc,omitempty"`
	ProductName          string             `protobuf:"bytes,11,opt,name=product_name,json=productName,proto3" json:"product_name,omitempty"`
	Encoding             Telemetry_Encoding `protobuf:"varint,12,opt,name=encoding,proto3,enum=telemetry.Telemetry_Encoding" json:"encoding,omitempty"`
	DataStr              string             `protobuf:"bytes,14,opt,name=data_str,json=dataStr,proto3" json:"data_str,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Telemetry) Descriptor

func (*Telemetry) Descriptor() ([]byte, []int)

func (*Telemetry) GetCollectionEndTime

func (m *Telemetry) GetCollectionEndTime() uint64

func (*Telemetry) GetCollectionId

func (m *Telemetry) GetCollectionId() uint64

func (*Telemetry) GetCollectionStartTime

func (m *Telemetry) GetCollectionStartTime() uint64

func (*Telemetry) GetCurrentPeriod

func (m *Telemetry) GetCurrentPeriod() uint32

func (*Telemetry) GetDataGpb

func (m *Telemetry) GetDataGpb() *TelemetryGPBTable

func (*Telemetry) GetDataStr

func (m *Telemetry) GetDataStr() string

func (*Telemetry) GetEncoding

func (m *Telemetry) GetEncoding() Telemetry_Encoding

func (*Telemetry) GetExceptDesc

func (m *Telemetry) GetExceptDesc() string

func (*Telemetry) GetMsgTimestamp

func (m *Telemetry) GetMsgTimestamp() uint64

func (*Telemetry) GetNodeIdStr

func (m *Telemetry) GetNodeIdStr() string

func (*Telemetry) GetProductName

func (m *Telemetry) GetProductName() string

func (*Telemetry) GetSensorPath

func (m *Telemetry) GetSensorPath() string

func (*Telemetry) GetSubscriptionIdStr

func (m *Telemetry) GetSubscriptionIdStr() string

func (*Telemetry) ProtoMessage

func (*Telemetry) ProtoMessage()

func (*Telemetry) Reset

func (m *Telemetry) Reset()

func (*Telemetry) String

func (m *Telemetry) String() string

func (*Telemetry) XXX_DiscardUnknown

func (m *Telemetry) XXX_DiscardUnknown()

func (*Telemetry) XXX_Marshal

func (m *Telemetry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Telemetry) XXX_Merge

func (m *Telemetry) XXX_Merge(src proto.Message)

func (*Telemetry) XXX_Size

func (m *Telemetry) XXX_Size() int

func (*Telemetry) XXX_Unmarshal

func (m *Telemetry) XXX_Unmarshal(b []byte) error

type TelemetryGPBTable

type TelemetryGPBTable struct {
	Row                  []*TelemetryRowGPB `protobuf:"bytes,1,rep,name=row,proto3" json:"row,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*TelemetryGPBTable) Descriptor

func (*TelemetryGPBTable) Descriptor() ([]byte, []int)

func (*TelemetryGPBTable) GetRow

func (m *TelemetryGPBTable) GetRow() []*TelemetryRowGPB

func (*TelemetryGPBTable) ProtoMessage

func (*TelemetryGPBTable) ProtoMessage()

func (*TelemetryGPBTable) Reset

func (m *TelemetryGPBTable) Reset()

func (*TelemetryGPBTable) String

func (m *TelemetryGPBTable) String() string

func (*TelemetryGPBTable) XXX_DiscardUnknown

func (m *TelemetryGPBTable) XXX_DiscardUnknown()

func (*TelemetryGPBTable) XXX_Marshal

func (m *TelemetryGPBTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TelemetryGPBTable) XXX_Merge

func (m *TelemetryGPBTable) XXX_Merge(src proto.Message)

func (*TelemetryGPBTable) XXX_Size

func (m *TelemetryGPBTable) XXX_Size() int

func (*TelemetryGPBTable) XXX_Unmarshal

func (m *TelemetryGPBTable) XXX_Unmarshal(b []byte) error

type TelemetryRowGPB

type TelemetryRowGPB struct {
	Timestamp            uint64   `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Content              []byte   `protobuf:"bytes,11,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TelemetryRowGPB) Descriptor

func (*TelemetryRowGPB) Descriptor() ([]byte, []int)

func (*TelemetryRowGPB) GetContent

func (m *TelemetryRowGPB) GetContent() []byte

func (*TelemetryRowGPB) GetTimestamp

func (m *TelemetryRowGPB) GetTimestamp() uint64

func (*TelemetryRowGPB) ProtoMessage

func (*TelemetryRowGPB) ProtoMessage()

func (*TelemetryRowGPB) Reset

func (m *TelemetryRowGPB) Reset()

func (*TelemetryRowGPB) String

func (m *TelemetryRowGPB) String() string

func (*TelemetryRowGPB) XXX_DiscardUnknown

func (m *TelemetryRowGPB) XXX_DiscardUnknown()

func (*TelemetryRowGPB) XXX_Marshal

func (m *TelemetryRowGPB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TelemetryRowGPB) XXX_Merge

func (m *TelemetryRowGPB) XXX_Merge(src proto.Message)

func (*TelemetryRowGPB) XXX_Size

func (m *TelemetryRowGPB) XXX_Size() int

func (*TelemetryRowGPB) XXX_Unmarshal

func (m *TelemetryRowGPB) XXX_Unmarshal(b []byte) error

type TelemetrySelfDefineThresTable

type TelemetrySelfDefineThresTable struct {
	Row                  []*TelemetryThreshold `protobuf:"bytes,1,rep,name=row,proto3" json:"row,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*TelemetrySelfDefineThresTable) Descriptor

func (*TelemetrySelfDefineThresTable) Descriptor() ([]byte, []int)

func (*TelemetrySelfDefineThresTable) GetRow

func (*TelemetrySelfDefineThresTable) ProtoMessage

func (*TelemetrySelfDefineThresTable) ProtoMessage()

func (*TelemetrySelfDefineThresTable) Reset

func (m *TelemetrySelfDefineThresTable) Reset()

func (*TelemetrySelfDefineThresTable) String

func (*TelemetrySelfDefineThresTable) XXX_DiscardUnknown

func (m *TelemetrySelfDefineThresTable) XXX_DiscardUnknown()

func (*TelemetrySelfDefineThresTable) XXX_Marshal

func (m *TelemetrySelfDefineThresTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TelemetrySelfDefineThresTable) XXX_Merge

func (m *TelemetrySelfDefineThresTable) XXX_Merge(src proto.Message)

func (*TelemetrySelfDefineThresTable) XXX_Size

func (m *TelemetrySelfDefineThresTable) XXX_Size() int

func (*TelemetrySelfDefineThresTable) XXX_Unmarshal

func (m *TelemetrySelfDefineThresTable) XXX_Unmarshal(b []byte) error

type TelemetrySelfDefinedEvent

type TelemetrySelfDefinedEvent struct {
	Path                 string                                      `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Level                uint32                                      `protobuf:"varint,2,opt,name=level,proto3" json:"level,omitempty"`
	Description          string                                      `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	FieldName            string                                      `protobuf:"bytes,4,opt,name=fieldName,proto3" json:"fieldName,omitempty"`
	FieldValue           uint32                                      `protobuf:"varint,5,opt,name=fieldValue,proto3" json:"fieldValue,omitempty"`
	DataThreshold        *TelemetrySelfDefineThresTable              `protobuf:"bytes,6,opt,name=data_threshold,json=dataThreshold,proto3" json:"data_threshold,omitempty"`
	ThresholdRelation    TelemetrySelfDefinedEvent_ThresholdRelation `` /* 147-byte string literal not displayed */
	Content              []byte                                      `protobuf:"bytes,8,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

func (*TelemetrySelfDefinedEvent) Descriptor

func (*TelemetrySelfDefinedEvent) Descriptor() ([]byte, []int)

func (*TelemetrySelfDefinedEvent) GetContent

func (m *TelemetrySelfDefinedEvent) GetContent() []byte

func (*TelemetrySelfDefinedEvent) GetDataThreshold

func (*TelemetrySelfDefinedEvent) GetDescription

func (m *TelemetrySelfDefinedEvent) GetDescription() string

func (*TelemetrySelfDefinedEvent) GetFieldName

func (m *TelemetrySelfDefinedEvent) GetFieldName() string

func (*TelemetrySelfDefinedEvent) GetFieldValue

func (m *TelemetrySelfDefinedEvent) GetFieldValue() uint32

func (*TelemetrySelfDefinedEvent) GetLevel

func (m *TelemetrySelfDefinedEvent) GetLevel() uint32

func (*TelemetrySelfDefinedEvent) GetPath

func (m *TelemetrySelfDefinedEvent) GetPath() string

func (*TelemetrySelfDefinedEvent) GetThresholdRelation

func (*TelemetrySelfDefinedEvent) ProtoMessage

func (*TelemetrySelfDefinedEvent) ProtoMessage()

func (*TelemetrySelfDefinedEvent) Reset

func (m *TelemetrySelfDefinedEvent) Reset()

func (*TelemetrySelfDefinedEvent) String

func (m *TelemetrySelfDefinedEvent) String() string

func (*TelemetrySelfDefinedEvent) XXX_DiscardUnknown

func (m *TelemetrySelfDefinedEvent) XXX_DiscardUnknown()

func (*TelemetrySelfDefinedEvent) XXX_Marshal

func (m *TelemetrySelfDefinedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TelemetrySelfDefinedEvent) XXX_Merge

func (m *TelemetrySelfDefinedEvent) XXX_Merge(src proto.Message)

func (*TelemetrySelfDefinedEvent) XXX_Size

func (m *TelemetrySelfDefinedEvent) XXX_Size() int

func (*TelemetrySelfDefinedEvent) XXX_Unmarshal

func (m *TelemetrySelfDefinedEvent) XXX_Unmarshal(b []byte) error

type TelemetrySelfDefinedEvent_ThresholdRelation

type TelemetrySelfDefinedEvent_ThresholdRelation int32
const (
	TelemetrySelfDefinedEvent_ThresholdRelation_INVALID TelemetrySelfDefinedEvent_ThresholdRelation = 0
	TelemetrySelfDefinedEvent_ThresholdRelation_AND     TelemetrySelfDefinedEvent_ThresholdRelation = 1
	TelemetrySelfDefinedEvent_ThresholdRelation_OR      TelemetrySelfDefinedEvent_ThresholdRelation = 2
)

func (TelemetrySelfDefinedEvent_ThresholdRelation) EnumDescriptor

func (TelemetrySelfDefinedEvent_ThresholdRelation) EnumDescriptor() ([]byte, []int)

func (TelemetrySelfDefinedEvent_ThresholdRelation) String

type TelemetryThreshold

type TelemetryThreshold struct {
	ThresholdValue       uint32                             `protobuf:"varint,1,opt,name=thresholdValue,proto3" json:"thresholdValue,omitempty"`
	ThresholdOpType      TelemetryThreshold_ThresholdOpType `` /* 134-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*TelemetryThreshold) Descriptor

func (*TelemetryThreshold) Descriptor() ([]byte, []int)

func (*TelemetryThreshold) GetThresholdOpType

func (*TelemetryThreshold) GetThresholdValue

func (m *TelemetryThreshold) GetThresholdValue() uint32

func (*TelemetryThreshold) ProtoMessage

func (*TelemetryThreshold) ProtoMessage()

func (*TelemetryThreshold) Reset

func (m *TelemetryThreshold) Reset()

func (*TelemetryThreshold) String

func (m *TelemetryThreshold) String() string

func (*TelemetryThreshold) XXX_DiscardUnknown

func (m *TelemetryThreshold) XXX_DiscardUnknown()

func (*TelemetryThreshold) XXX_Marshal

func (m *TelemetryThreshold) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TelemetryThreshold) XXX_Merge

func (m *TelemetryThreshold) XXX_Merge(src proto.Message)

func (*TelemetryThreshold) XXX_Size

func (m *TelemetryThreshold) XXX_Size() int

func (*TelemetryThreshold) XXX_Unmarshal

func (m *TelemetryThreshold) XXX_Unmarshal(b []byte) error

type TelemetryThreshold_ThresholdOpType

type TelemetryThreshold_ThresholdOpType int32
const (
	TelemetryThreshold_ThresholdOpType_EQ TelemetryThreshold_ThresholdOpType = 0
	TelemetryThreshold_ThresholdOpType_GT TelemetryThreshold_ThresholdOpType = 1
	TelemetryThreshold_ThresholdOpType_GE TelemetryThreshold_ThresholdOpType = 2
	TelemetryThreshold_ThresholdOpType_LT TelemetryThreshold_ThresholdOpType = 3
	TelemetryThreshold_ThresholdOpType_LE TelemetryThreshold_ThresholdOpType = 4
)

func (TelemetryThreshold_ThresholdOpType) EnumDescriptor

func (TelemetryThreshold_ThresholdOpType) EnumDescriptor() ([]byte, []int)

func (TelemetryThreshold_ThresholdOpType) String

type Telemetry_Encoding

type Telemetry_Encoding int32
const (
	Telemetry_Encoding_GPB  Telemetry_Encoding = 0
	Telemetry_Encoding_JSON Telemetry_Encoding = 1
)

func (Telemetry_Encoding) EnumDescriptor

func (Telemetry_Encoding) EnumDescriptor() ([]byte, []int)

func (Telemetry_Encoding) String

func (x Telemetry_Encoding) String() string

Jump to

Keyboard shortcuts

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