netutils/mqtt
1
0
Fork 0
mirror of https://github.com/go-mqtt/mqtt.git synced 2025-08-08 22:42:05 +03:00
Code Activity

Annotate all errors with request context. Helps lazy loggers plus failfast for exact error matching (instead of errors.Is).

Browse Source
This commit is contained in:
Pascal S. de Kloe
2021-03-17 13:53:21 +01:00
parent dcd7329b52
commit 2b4db51604
4 changed files with 30 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
cmd/mqttc/main.go
View File

@@ -217,9 +217,6 @@ func execPubSub(client *mqtt.Client) {
}
case errors.Is(err, mqtt.ErrClosed), errors.Is(err, mqtt.ErrDown):
return
case errors.Is(err, mqtt.ErrCanceled), errors.Is(err, mqtt.ErrAbandoned):
failMQTT(client, fmt.Errorf("%s: publish timeout; %s", name, err))
return
default:
failMQTT(client, err)
return
@@ -238,8 +235,6 @@ func execPubSub(client *mqtt.Client) {
}
case errors.Is(err, mqtt.ErrClosed), errors.Is(err, mqtt.ErrDown):
break
case errors.Is(err, mqtt.ErrCanceled), errors.Is(err, mqtt.ErrAbandoned):
failMQTT(client, fmt.Errorf("%s: subscribe timeout; %s", name, err))
default:
failMQTT(client, err)
}
@@ -257,9 +252,6 @@ func execPubSub(client *mqtt.Client) {
break // OK
case errors.Is(err, mqtt.ErrClosed), errors.Is(err, mqtt.ErrDown):
return
case errors.Is(err, mqtt.ErrCanceled), errors.Is(err, mqtt.ErrAbandoned):
failMQTT(client, fmt.Errorf("%s: ping timeout; %s", name, err))
return
default:
failMQTT(client, err)
return