Documentation ¶
Index ¶
- Variables
- type CompressMode
- type DbInfo
- type HhdbConPool
- func (hhdb *HhdbConPool) ClearTable(dbName string, TableId int32, TableName string) (int32, error)
- func (hhdb *HhdbConPool) DelPoints(dbName string, pointList *[]PointInfo) (int32, error)
- func (hhdb *HhdbConPool) DeleteTable(dbName string, TableId int32, TableName string) (int32, error)
- func (hhdb *HhdbConPool) InsertHisValueListByIdList(dbName string, pointIdList *[]int32, valueList *[][]PointValue) (*[]int32, error)
- func (hhdb *HhdbConPool) InsertHisValueListByNameList(dbName string, pointNameList *[]string, valueList *[][]PointValue) (*[]int32, error)
- func (hhdb *HhdbConPool) InsertPoints(dbName string, pointList *[]PointInfo) (int32, []int32, error)
- func (hhdb *HhdbConPool) InsertTable(dbName string, tableInfo TableInfo) (int32, error)
- func (hhdb *HhdbConPool) QueryHisRangeValueListReqByIdList(dbName string, pointIdList *[]int32, startMs uint64, endMs uint64, ...) (*[][]PointValue, *[]int32, error)
- func (hhdb *HhdbConPool) QueryHisRangeValueListReqByNameList(dbName string, pointNameList *[]string, startMs uint64, endMs uint64, ...) (*[][]PointValue, *[]int32, error)
- func (hhdb *HhdbConPool) QueryHisResampleValueListByIdList(dbName string, pointIdList *[]int32, startMs uint64, endMs uint64, ...) (*[][]PointValue, *[]int32, error)
- func (hhdb *HhdbConPool) QueryHisResampleValueListByNameList(dbName string, pointNameList *[]string, startMs uint64, endMs uint64, ...) (*[][]PointValue, *[]int32, error)
- func (hhdb *HhdbConPool) QueryHisTimePointValueListByIdList(dbName string, pointIdList *[]int32, msTimePoint uint64, mode ResampleMode) (*[]PointValue, *[]int32, error)
- func (hhdb *HhdbConPool) QueryHisTimePointValueListByNameList(dbName string, pointNameList *[]string, msTimePoint uint64, mode ResampleMode) (*[]PointValue, *[]int32, error)
- func (hhdb *HhdbConPool) QueryPointInfoListByID(dbName string, pointIdList *[]int32) (*[]PointInfo, error)
- func (hhdb *HhdbConPool) QueryPointInfoListByName(dbName string, pointNameList *[]string) (*[]PointInfo, error)
- func (hhdb *HhdbConPool) QueryPoints(dbName string, tableName string, tableId int32, pointId int32, ...) (*[]PointInfo, error)
- func (hhdb *HhdbConPool) QueryRealtimeValueListByIdList(dbName string, pointIdList *[]int32) (*[]PointValue, error)
- func (hhdb *HhdbConPool) QueryTableList(dbName string, TableId int32, TableName string, enablePage bool, page uint32, ...) (*[]TableInfo, error)
- func (hhdb *HhdbConPool) SetDbInfo(info *DbInfo)
- func (hhdb *HhdbConPool) SetOuttime(outtimeSec time.Duration)
- func (hhdb *HhdbConPool) UpdatePoints(dbName string, pointList *[]PointInfo) (int32, []int32, error)
- func (hhdb *HhdbConPool) UpdateRealtimeValueListByIdList(dbName string, pointIdList *[]int32, valueList *[]PointValue, useSysTime bool) (int32, error)
- func (hhdb *HhdbConPool) UpdateRealtimeValueListByNameList(dbName string, pointNameList *[]string, valueList *[]PointValue, ...) (int32, error)
- func (hhdb *HhdbConPool) UpdateTable(dbName string, tableInfo *TableInfo) (int32, error)
- type OperatorInfo
- type PointInfo
- type PointStatus
- type PointType
- type PointValue
- type RangeQueryMode
- type ResampleMode
- type TableInfo
- type ValueType
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ResampleMode_name = map[int32]string{ 0: "kRmSuggest", 1: "kRmBefore", 2: "kRmAfter", 3: "kRmInter", 4: "kRmNone", } ResampleMode_value = map[string]int32{ "kRmSuggest": 0, "kRmBefore": 1, "kRmAfter": 2, "kRmInter": 3, "kRmNone": 4, } )
Enum value maps for ResampleMode.
View Source
var ( RangeQueryMode_name = map[int32]string{ 0: "kRqmAll", 1: "kRqmMax", 2: "kRqmMin", 3: "kRqmSum", 4: "kRqmAvg", 5: "kRqmWeightSum", 6: "kRqmWeightAvg", 7: "kRqmFirst", 8: "kRqmLast", 9: "kRqmTimeDiff", 10: "kRqmLastDiff", 11: "kRqmMaxDiff", 12: "kRqmMse", 13: "kRqmMode", 14: "kRqmRate", } RangeQueryMode_value = map[string]int32{ "kRqmAll": 0, "kRqmMax": 1, "kRqmMin": 2, "kRqmSum": 3, "kRqmAvg": 4, "kRqmWeightSum": 5, "kRqmWeightAvg": 6, "kRqmFirst": 7, "kRqmLast": 8, "kRqmTimeDiff": 9, "kRqmLastDiff": 10, "kRqmMaxDiff": 11, "kRqmMse": 12, "kRqmMode": 13, "kRqmRate": 14, } )
Enum value maps for RangeQueryMode.
View Source
var ( PointType_name = map[int32]string{ 0: "kPtSwitch", 1: "kPtAnalog", 2: "kPtPackage", } PointType_value = map[string]int32{ "kPtSwitch": 0, "kPtAnalog": 1, "kPtPackage": 2, } )
Enum value maps for PointType.
View Source
var ( CompressMode_name = map[int32]string{ 0: "kCmThreshold", 1: "kCmLeap", 2: "kCmTime", 3: "kCmLoss", 4: "kCmNone", } CompressMode_value = map[string]int32{ "kCmThreshold": 0, "kCmLeap": 1, "kCmTime": 2, "kCmLoss": 3, "kCmNone": 4, } )
Enum value maps for CompressMode.
View Source
var ( ValueType_name = map[int32]string{ 0: "kVtBool", 1: "kVtFloat", 2: "kVtDouble", 3: "kVtChar", 4: "kVtByte", 5: "kVtShort", 6: "kVtWord", 7: "kVtInt", 8: "kVtDword", 9: "kVtLong", 10: "kVtQword", 11: "kVtString", 12: "kVtBoolArr", 13: "kVtFloatArr", 14: "kVtDoubleArr", 15: "kVtCharArr", 16: "kVtByteArr", 17: "kVtShortArr", 18: "kVtWordArr", 19: "kVtIntArr", 20: "kVtDwordArr", 21: "kVtLongArr", 22: "kVtQwordArr", 23: "kVtStringArr", } ValueType_value = map[string]int32{ "kVtBool": 0, "kVtFloat": 1, "kVtDouble": 2, "kVtChar": 3, "kVtByte": 4, "kVtShort": 5, "kVtWord": 6, "kVtInt": 7, "kVtDword": 8, "kVtLong": 9, "kVtQword": 10, "kVtString": 11, "kVtBoolArr": 12, "kVtFloatArr": 13, "kVtDoubleArr": 14, "kVtCharArr": 15, "kVtByteArr": 16, "kVtShortArr": 17, "kVtWordArr": 18, "kVtIntArr": 19, "kVtDwordArr": 20, "kVtLongArr": 21, "kVtQwordArr": 22, "kVtStringArr": 23, } )
Enum value maps for ValueType.
View Source
var ( PointStatus_name = map[int32]string{ 0: "kPsInit", 1: "kPsGood", 10: "kPsShowWarnning", 11: "kPsUncertain", 12: "kPsInavtive", 13: "kPsQualityIssue", 14: "kPsDataTypeMisMatch", 15: "kPsOutService", 16: "kPsOverRange", 17: "kPsUnderRange", 100: "kPsShowError", 101: "kPsNotFound", 102: "kPsBad", 106: "kPsDeviceFailure", 107: "kPsSensorFailure", 108: "kPsCommunFailure", } PointStatus_value = map[string]int32{ "kPsInit": 0, "kPsGood": 1, "kPsShowWarnning": 10, "kPsUncertain": 11, "kPsInavtive": 12, "kPsQualityIssue": 13, "kPsDataTypeMisMatch": 14, "kPsOutService": 15, "kPsOverRange": 16, "kPsUnderRange": 17, "kPsShowError": 100, "kPsNotFound": 101, "kPsBad": 102, "kPsDeviceFailure": 106, "kPsSensorFailure": 107, "kPsCommunFailure": 108, } )
Enum value maps for PointStatus.
View Source
var HHDB_GET_CON_ERROR int32 = -1
View Source
var HHDB_RPC_REQ_ERROR int32 = -2
Functions ¶
This section is empty.
Types ¶
type CompressMode ¶
type CompressMode int32
压缩模式
const ( CompressMode_kCmThreshold CompressMode = 0 //阈值压缩 CompressMode_kCmLeap CompressMode = 1 //跳变压缩 CompressMode_kCmTime CompressMode = 2 //定时压缩 CompressMode_kCmLoss CompressMode = 3 //有损压缩 CompressMode_kCmNone CompressMode = 4 //无损压缩 )
func (CompressMode) Enum ¶
func (x CompressMode) Enum() *CompressMode
func (CompressMode) String ¶
func (x CompressMode) String() string
type HhdbConPool ¶
type HhdbConPool struct {
// contains filtered or unexported fields
}
func (*HhdbConPool) ClearTable ¶
func (*HhdbConPool) DelPoints ¶
func (hhdb *HhdbConPool) DelPoints(dbName string, pointList *[]PointInfo) (int32, error)
func (*HhdbConPool) DeleteTable ¶
func (*HhdbConPool) InsertHisValueListByIdList ¶
func (hhdb *HhdbConPool) InsertHisValueListByIdList(dbName string, pointIdList *[]int32, valueList *[][]PointValue) (*[]int32, error)
func (*HhdbConPool) InsertHisValueListByNameList ¶
func (hhdb *HhdbConPool) InsertHisValueListByNameList(dbName string, pointNameList *[]string, valueList *[][]PointValue) (*[]int32, error)
func (*HhdbConPool) InsertPoints ¶
func (*HhdbConPool) InsertTable ¶
func (hhdb *HhdbConPool) InsertTable(dbName string, tableInfo TableInfo) (int32, error)
func (*HhdbConPool) QueryHisRangeValueListReqByIdList ¶
func (hhdb *HhdbConPool) QueryHisRangeValueListReqByIdList(dbName string, pointIdList *[]int32, startMs uint64, endMs uint64, mode RangeQueryMode) (*[][]PointValue, *[]int32, error)
func (*HhdbConPool) QueryHisRangeValueListReqByNameList ¶
func (hhdb *HhdbConPool) QueryHisRangeValueListReqByNameList(dbName string, pointNameList *[]string, startMs uint64, endMs uint64, mode RangeQueryMode) (*[][]PointValue, *[]int32, error)
func (*HhdbConPool) QueryHisResampleValueListByIdList ¶
func (hhdb *HhdbConPool) QueryHisResampleValueListByIdList(dbName string, pointIdList *[]int32, startMs uint64, endMs uint64, priodMs uint64, mode ResampleMode) (*[][]PointValue, *[]int32, error)
func (*HhdbConPool) QueryHisResampleValueListByNameList ¶
func (hhdb *HhdbConPool) QueryHisResampleValueListByNameList(dbName string, pointNameList *[]string, startMs uint64, endMs uint64, priodMs uint64, mode ResampleMode) (*[][]PointValue, *[]int32, error)
func (*HhdbConPool) QueryHisTimePointValueListByIdList ¶
func (hhdb *HhdbConPool) QueryHisTimePointValueListByIdList(dbName string, pointIdList *[]int32, msTimePoint uint64, mode ResampleMode) (*[]PointValue, *[]int32, error)
func (*HhdbConPool) QueryHisTimePointValueListByNameList ¶
func (hhdb *HhdbConPool) QueryHisTimePointValueListByNameList(dbName string, pointNameList *[]string, msTimePoint uint64, mode ResampleMode) (*[]PointValue, *[]int32, error)
func (*HhdbConPool) QueryPointInfoListByID ¶
func (hhdb *HhdbConPool) QueryPointInfoListByID(dbName string, pointIdList *[]int32) (*[]PointInfo, error)
func (*HhdbConPool) QueryPointInfoListByName ¶
func (hhdb *HhdbConPool) QueryPointInfoListByName(dbName string, pointNameList *[]string) (*[]PointInfo, error)
func (*HhdbConPool) QueryPoints ¶
func (*HhdbConPool) QueryRealtimeValueListByIdList ¶
func (hhdb *HhdbConPool) QueryRealtimeValueListByIdList(dbName string, pointIdList *[]int32) (*[]PointValue, error)
func (*HhdbConPool) QueryTableList ¶
func (*HhdbConPool) SetDbInfo ¶
func (hhdb *HhdbConPool) SetDbInfo(info *DbInfo)
func (*HhdbConPool) SetOuttime ¶
func (hhdb *HhdbConPool) SetOuttime(outtimeSec time.Duration)
func (*HhdbConPool) UpdatePoints ¶
func (*HhdbConPool) UpdateRealtimeValueListByIdList ¶
func (hhdb *HhdbConPool) UpdateRealtimeValueListByIdList(dbName string, pointIdList *[]int32, valueList *[]PointValue, useSysTime bool) (int32, error)
func (*HhdbConPool) UpdateRealtimeValueListByNameList ¶
func (hhdb *HhdbConPool) UpdateRealtimeValueListByNameList(dbName string, pointNameList *[]string, valueList *[]PointValue, useSysTime bool) (int32, error)
func (*HhdbConPool) UpdateTable ¶
func (hhdb *HhdbConPool) UpdateTable(dbName string, tableInfo *TableInfo) (int32, error)
type OperatorInfo ¶
type OperatorInfo struct {
// contains filtered or unexported fields
}
type PointInfo ¶
type PointInfo struct { PointId int32 `json:"pointId"` //测点ID,为>=0的整数 PointName string `json:"pointName"` //测点名 PointUnit string `json:"pointUnit"` //测点单位 PointDesc string `json:"pointDesc"` //测点描述 PointType PointType `json:"pointType"` //测点类型 WriteEnable bool `json:"writeEnable"` //是否可写 CheckEnable bool `json:"checkEnable"` //是否进行值校验 LowerThreshold float64 `json:"lowerThreshold"` //低限阈值 UpperThreshold float64 `json:"upperThreshold"` //高限阈值 ValueOffset float64 `json:"valueOffset"` //数据偏移量 ValueRate float64 `json:"valueRate"` //数据倍率 CompressMode CompressMode `json:"compressMode"` //压缩模式 CompressParam1 float64 `json:"compressParam1"` //压缩备用参数1 CompressParam2 float64 `json:"compressParam2"` //压缩备用参数2 OuttimeDay int32 `json:"outtimeDay"` //超时时间(单位:天)=0则不启用,>0为对应的超时时间,<0代表仅缓存实时数据不存储历史数据 ValueType ValueType `json:"valueType"` //测点值类型 TableId int32 `json:"tableId"` //点组ID CreateTime uint64 `json:"createTime"` //测点创建时间 ExtraField map[string]string `json:"extraField"` //自定义的拓展字段 }
测点全量信息
type PointStatus ¶
type PointStatus int32
const ( PointStatus_kPsInit PointStatus = 0 //初始化0-9为好的状态 PointStatus_kPsGood PointStatus = 1 //正常,表示测点的值是有效的且在正常范围内。这是最常见的状态 PointStatus_kPsShowWarnning PointStatus = 10 //>=10为警告状态 PointStatus_kPsUncertain PointStatus = 11 //不确定,表示测点的值可能有效,但存在某种不确定性或不可靠性。这通常用于表示数据质量差、未知状态或临时问题。 PointStatus_kPsQualityIssue PointStatus = 13 //数据质量问题,表示测点的数据存在质量问题,可能是由于噪声、干扰或其他原因导致的不准确性。 PointStatus_kPsDataTypeMisMatch PointStatus = 14 //数据类型不匹配 PointStatus_kPsOutService PointStatus = 15 //停用,表示测点当前处于停用状态,通常是因为设备维护或其他原因。 PointStatus_kPsOverRange PointStatus = 16 //超出范围,表示测点的值超出了其正常范围,通常用于指示测点的测量值超出了可接受的上限。 PointStatus_kPsUnderRange PointStatus = 17 //低于范围,表示测点的值低于其正常范围,通常用于指示测点的测量值低于可接受的下限。 PointStatus_kPsShowError PointStatus = 100 //>=100为错误状态 PointStatus_kPsNotFound PointStatus = 101 //错误,表示测点的值无效或处于错误状态。 PointStatus_kPsBad PointStatus = 102 //错误,表示测点的值无效或处于错误状态。 PointStatus_kPsDeviceFailure PointStatus = 106 //设备故障,表示测点所关联的设备发生故障,无法提供有效的数据。 PointStatus_kPsSensorFailure PointStatus = 107 //传感器故障,表示与测点关联的传感器发生故障,导致无法获得有效的测量数据。 PointStatus_kPsCommunFailure PointStatus = 108 //通信故障,表示测点与数据源之间的通信故障,导致无法获取或更新数据。 )
func (PointStatus) Enum ¶
func (x PointStatus) Enum() *PointStatus
func (PointStatus) String ¶
func (x PointStatus) String() string
type PointValue ¶
type PointValue struct { Value interface{} `json:"v"` //测点值 Mstime uint64 `json:"t"` //测点值时间 Status PointStatus `json:"s"` //测点值状态 }
type RangeQueryMode ¶
type RangeQueryMode int32
时间段查询模式
const ( RangeQueryMode_kRqmAll RangeQueryMode = 0 //时间段内所有数据 RangeQueryMode_kRqmMax RangeQueryMode = 1 //时间段内最大值 RangeQueryMode_kRqmMin RangeQueryMode = 2 //时间段内最小值 RangeQueryMode_kRqmSum RangeQueryMode = 3 //时间段内和值 RangeQueryMode_kRqmAvg RangeQueryMode = 4 //时间段内平均值 RangeQueryMode_kRqmWeightSum RangeQueryMode = 5 //时间段内加权和值 RangeQueryMode_kRqmWeightAvg RangeQueryMode = 6 //时间段内加权平均值 RangeQueryMode_kRqmFirst RangeQueryMode = 7 //取第一个值 RangeQueryMode_kRqmLast RangeQueryMode = 8 //取最后一个值 RangeQueryMode_kRqmTimeDiff RangeQueryMode = 9 //取时间段内开始时间点数据-结束时间点数据,若时间点数据不存在则kResSuggest模式进行查询 RangeQueryMode_kRqmLastDiff RangeQueryMode = 10 //取时间段内第一条数据-最后一条数据差值 RangeQueryMode_kRqmMaxDiff RangeQueryMode = 11 //取时间段内最大值减最小值的差值 RangeQueryMode_kRqmMse RangeQueryMode = 12 //均方差 RangeQueryMode_kRqmMode RangeQueryMode = 13 //众数 RangeQueryMode_kRqmRate RangeQueryMode = 14 //增长率 )
func (RangeQueryMode) Enum ¶
func (x RangeQueryMode) Enum() *RangeQueryMode
func (RangeQueryMode) String ¶
func (x RangeQueryMode) String() string
type ResampleMode ¶
type ResampleMode int32
降采样取值方式
const ( ResampleMode_kRmSuggest ResampleMode = 0 //根据压缩方式自动推荐准确的取值模式 ResampleMode_kRmBefore ResampleMode = 1 //当前时间点有值,则取该值,无值则取时间点前的第一个值 ResampleMode_kRmAfter ResampleMode = 2 //当前时间点有值,则取该值,无值则取时间点后的第一个值 ResampleMode_kRmInter ResampleMode = 3 //当前时间点有值,则取该值,无值则取时间点前、后的第一个值后,线性运算得到时间点值 ResampleMode_kRmNone ResampleMode = 4 //当前时间点有值,则取该值,无值则返回默认值 )
func (ResampleMode) Enum ¶
func (x ResampleMode) Enum() *ResampleMode
func (ResampleMode) String ¶
func (x ResampleMode) String() string
type ValueType ¶
type ValueType int32
数据值类型
const ( ValueType_kVtBool ValueType = 0 // true 或 false 的二进制值 ValueType_kVtFloat ValueType = 1 //32 位实数值浮点型 IEEE-754 标准定义 ValueType_kVtDouble ValueType = 2 //64 位实数值双精度 IEEE-754 标准定义 ValueType_kVtChar ValueType = 3 // 有符号的 8 位整数数据 ValueType_kVtByte ValueType = 4 //无符号的 8 位整数数据 ValueType_kVtShort ValueType = 5 //有符号的 16 位整数数据 ValueType_kVtWord ValueType = 6 //无符号的 16 位整数数据 ValueType_kVtInt ValueType = 7 //有符号的 32 位整数数据 ValueType_kVtDword ValueType = 8 // 无符号的 32 位整数数据 ValueType_kVtLong ValueType = 9 //有符号的 64 位整数数据 ValueType_kVtQword ValueType = 10 //无符号的 64 位整数数据 ValueType_kVtString ValueType = 11 //字符串 ValueType_kVtBoolArr ValueType = 12 //bool数组 ValueType_kVtFloatArr ValueType = 13 //32 位实数值浮点型数组 ValueType_kVtDoubleArr ValueType = 14 //64 位实数值浮点型数组 ValueType_kVtCharArr ValueType = 15 //char数组 ValueType_kVtByteArr ValueType = 16 //byte数组 ValueType_kVtShortArr ValueType = 17 //short数组 ValueType_kVtWordArr ValueType = 18 //word数组 ValueType_kVtIntArr ValueType = 19 //有符号的 32 位整数数据数组 ValueType_kVtDwordArr ValueType = 20 //无符号的 32 位整数数据数组 ValueType_kVtLongArr ValueType = 21 //有符号的 64 位整数数据数组 ValueType_kVtQwordArr ValueType = 22 //无符号的 64 位整数数据数组 ValueType_kVtStringArr ValueType = 23 //字符串数组 )
Source Files ¶
Click to show internal directories.
Click to hide internal directories.