CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore(deps): Bump github.com/apache/iotdb-client-go from 0.12.2-0.20220722111104-cd17da295b46 to 1.2.0-tsbs (#15086)

This commit is contained in:
dependabot[bot] 2024-04-02 12:24:12 -06:00 committed by GitHub
parent 7d185fa624
commit ba81bef3af
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
go.mod
View File

@ -35,7 +35,7 @@ require (
github.com/antchfx/xmlquery v1.3.18
github.com/antchfx/xpath v1.2.5
github.com/apache/arrow/go/v13 v13.0.0
github.com/apache/iotdb-client-go v0.12.2-0.20220722111104-cd17da295b46
github.com/apache/iotdb-client-go v1.2.0-tsbs
github.com/apache/thrift v0.18.1
github.com/aristanetworks/goarista v0.0.0-20190325233358-a123909ec740
github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5

4
go.sum
View File

@ -798,8 +798,8 @@ github.com/apache/arrow/go/v13 v13.0.0 h1:kELrvDQuKZo8csdWYqBQfyi431x6Zs/YJTEgUu
github.com/apache/arrow/go/v13 v13.0.0/go.mod h1:W69eByFNO0ZR30q1/7Sr9d83zcVZmF2MiP3fFYAWJOc=
github.com/apache/arrow/go/v14 v14.0.2 h1:N8OkaJEOfI3mEZt07BIkvo4sC6XDbL+48MBPWO5IONw=
github.com/apache/arrow/go/v14 v14.0.2/go.mod h1:u3fgh3EdgN/YQ8cVQRguVW3R+seMybFg8QBQ5LU+eBY=
github.com/apache/iotdb-client-go v0.12.2-0.20220722111104-cd17da295b46 h1:28HyUQcr8ZCyCAatR0gkf9PuLr52U2T+66tx5Th0nxI=
github.com/apache/iotdb-client-go v0.12.2-0.20220722111104-cd17da295b46/go.mod h1:1z89VPGCUGHGqxkPW8p2Haq6WJwrRBKZN+WOjDBiQQM=
github.com/apache/iotdb-client-go v1.2.0-tsbs h1:hezGUydAkDSceCvsetYorI87S2e8HZ4hTQHmGZgOGDY=
github.com/apache/iotdb-client-go v1.2.0-tsbs/go.mod h1:3D6QYkqRmASS/4HsjU+U/3fscyc5M9xKRfywZsKuoZY=
github.com/apache/thrift v0.15.0/go.mod h1:PHK3hniurgQaNMZYaCLEqXKsYK8upmhPbmdP2FXSqgU=
github.com/apache/thrift v0.16.0/go.mod h1:PHK3hniurgQaNMZYaCLEqXKsYK8upmhPbmdP2FXSqgU=
github.com/apache/thrift v0.18.1 h1:lNhK/1nqjbwbiOPDBPFJVKxgDEGSepKuTh6OLiXW8kg=

8
plugins/outputs/iotdb/iotdb.go
View File

@ -175,7 +175,7 @@ func (s *IoTDB) getDataTypeAndValue(value interface{}) (client.TSDataType, inter
case "text":
return client.TEXT, strconv.FormatUint(v, 10)
default:
return client.UNKNOW, int64(0)
return client.UNKNOWN, int64(0)
}
case float64:
return client.DOUBLE, v
@ -184,7 +184,7 @@ func (s *IoTDB) getDataTypeAndValue(value interface{}) (client.TSDataType, inter
case bool:
return client.BOOLEAN, v
default:
return client.UNKNOW, int64(0)
return client.UNKNOWN, int64(0)
}
}
@ -223,7 +223,7 @@ func (s *IoTDB) convertMetricsToRecordsWithTags(metrics []telegraf.Metric) (*rec
var dataTypes []client.TSDataType
for _, field := range metric.FieldList() {
datatype, value := s.getDataTypeAndValue(field.Value)
if datatype == client.UNKNOW {
if datatype == client.UNKNOWN {
return nil, fmt.Errorf("datatype of %q is unknown, values: %v", field.Key, field.Value)
}
keys = append(keys, field.Key)
@ -284,7 +284,7 @@ func (s *IoTDB) modifyRecordsWithTags(rwt *recordsWithTags) error {
for index, tags := range rwt.TagsList { // for each record
for _, tag := range tags { // for each tag of this record, append it's Key:Value to measurements
datatype, value := s.getDataTypeAndValue(tag.Value)
if datatype == client.UNKNOW {
if datatype == client.UNKNOWN {
return fmt.Errorf("datatype of %q is unknown, values: %v", tag.Key, value)
}
rwt.MeasurementsList[index] = append(rwt.MeasurementsList[index], tag.Key)