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

chore(deps): Bump github.com/eclipse/paho.golang from 0.11.0 to 0.20.0 (#14769) 

Co-authored-by: Josh Powers <powersj@fastmail.com>
This commit is contained in:
dependabot[bot] 2024-02-13 13:26:26 -06:00 committed by GitHub
parent 6f62f9072f
commit f6dcb701a2
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
go.mod
View File

@ -71,7 +71,7 @@ require (
github.com/docker/docker v25.0.0+incompatible
github.com/docker/go-connections v0.5.0
github.com/dynatrace-oss/dynatrace-metric-utils-go v0.5.0
github.com/eclipse/paho.golang v0.11.0
github.com/eclipse/paho.golang v0.20.0
github.com/eclipse/paho.mqtt.golang v1.4.3
github.com/facebook/time v0.0.0-20240125155343-557f84f4ad3e
github.com/fatih/color v1.16.0

4
go.sum
View File

@ -1090,8 +1090,8 @@ github.com/echlebek/crock v1.0.1 h1:KbzamClMIfVIkkjq/GTXf+N16KylYBpiaTitO3f1ujg=
github.com/echlebek/crock v1.0.1/go.mod h1:/kvwHRX3ZXHj/kHWJkjXDmzzRow54EJuHtQ/PapL/HI=
github.com/echlebek/timeproxy v1.0.0 h1:V41/v8tmmMDNMA2GrBPI45nlXb3F7+OY+nJz1BqKsCk=
github.com/echlebek/timeproxy v1.0.0/go.mod h1:0dg2Lnb8no/jFwoMQKMTU6iAivgoMptGqSTprhnrRtk=
github.com/eclipse/paho.golang v0.11.0 h1:6Avu5dkkCfcB61/y1vx+XrPQ0oAl4TPYtY0uw3HbQdM=
github.com/eclipse/paho.golang v0.11.0/go.mod h1:rhrV37IEwauUyx8FHrvmXOKo+QRKng5ncoN1vJiJMcs=
github.com/eclipse/paho.golang v0.20.0 h1:SQw/d7YhphDPkIURTQzyWK+dnS36scSVLvFbcVvNm+o=
github.com/eclipse/paho.golang v0.20.0/go.mod h1:TSDCUivu9JnoR9Hl+H7sQMcHkejWH2/xKK1NJGtLbIE=
github.com/eclipse/paho.mqtt.golang v1.4.3 h1:2kwcUGn8seMUfWndX0hGbvH8r7crgcJguQNCyp70xik=
github.com/eclipse/paho.mqtt.golang v1.4.3/go.mod h1:CSYvoAlsMkhYOXh/oKyxa8EcBci6dVkLCbo5tTC1RIE=
github.com/emicklei/go-restful/v3 v3.11.0 h1:rAQeMHw1c7zTmncogyy8VvRZwtkmkZ4FxERmMY4rD+g=

7
plugins/common/mqtt/mqtt_v5.go
View File

@ -30,10 +30,10 @@ func NewMQTTv5Client(cfg *MqttConfig) (*mqttv5Client, error) {
KeepAlive: uint16(cfg.KeepAlive),
OnConnectError: cfg.OnConnectionLost,
}
opts.SetConnectPacketConfigurator(func(c *mqttv5.Connect) *mqttv5.Connect {
opts.ConnectPacketBuilder = func(c *mqttv5.Connect, _ *url.URL) *mqttv5.Connect {
c.CleanStart = cfg.PersistentSession
return c
})
}
if time.Duration(cfg.ConnectionTimeout) >= 1*time.Second {
opts.ConnectTimeout = time.Duration(cfg.ConnectionTimeout)
@ -115,7 +115,8 @@ func (m *mqttv5Client) Connect() (bool, error) {
return false, fmt.Errorf("getting password failed: %w", err)
}
defer pass.Destroy()
m.options.SetUsernamePassword(user.TemporaryString(), pass.Bytes())
m.options.ConnectUsername = user.TemporaryString()
m.options.ConnectPassword = pass.Bytes()
client, err := mqttv5auto.NewConnection(context.Background(), m.options)
if err != nil {