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

fix(serializers.influx): Restore disabled uint support by default (#13164)

This commit is contained in:
Joshua Powers 2023-05-02 05:45:19 -06:00 committed by GitHub
parent 3d40659387
commit 80b8fe6333
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugins/outputs/influxdb/influxdb.go
View File

@ -169,7 +169,7 @@ func (i *InfluxDB) Write(metrics []telegraf.Metric) error {
} }
func (i *InfluxDB) udpClient(address *url.URL) (Client, error) { func (i *InfluxDB) udpClient(address *url.URL) (Client, error) {
serializer := &influx.Serializer{UintSupport: true} serializer := &influx.Serializer{UintSupport: i.InfluxUintSupport}
if err := serializer.Init(); err != nil { if err := serializer.Init(); err != nil {
return nil, err return nil, err
} }
@ -195,7 +195,7 @@ func (i *InfluxDB) httpClient(ctx context.Context, address *url.URL, proxy *url.
return nil, err return nil, err
} }
serializer := &influx.Serializer{UintSupport: true} serializer := &influx.Serializer{UintSupport: i.InfluxUintSupport}
if err := serializer.Init(); err != nil { if err := serializer.Init(); err != nil {
return nil, err return nil, err
} }

2
plugins/outputs/influxdb/udp.go
View File

@ -46,7 +46,7 @@ func NewUDPClient(config UDPConfig) (*udpClient, error) {
serializer := config.Serializer serializer := config.Serializer
if serializer == nil { if serializer == nil {
serializer = &influx.Serializer{UintSupport: true} serializer = &influx.Serializer{}
if err := serializer.Init(); err != nil { if err := serializer.Init(); err != nil {
return nil, err return nil, err
} }

2
plugins/outputs/influxdb_v2/influxdb_v2.go
View File

@ -125,7 +125,7 @@ func (i *InfluxDB) getHTTPClient(address *url.URL, proxy *url.URL) (Client, erro
return nil, err return nil, err
} }
serializer := &influx.Serializer{UintSupport: true} serializer := &influx.Serializer{UintSupport: i.UintSupport}
if err := serializer.Init(); err != nil { if err := serializer.Init(); err != nil {
return nil, err return nil, err
} }