server

server copied to clipboard

[WIP] OTEL Observability

4

### Feature Using OTEL lib to instrument the server. Happy to take suggestions on things that we should track, metrics to add, and how to allow maximum configurability for the...

IshanDaga

dgduncan

Concurrency issues when reading and writing retain messages

4

Hi there, I'm trying to embed the broker into an application, but I've noticed while testing the library, the race detector goes off when publishing and subscribing to retain messages...

yh742

add 0x04 Reason Code functionality

1

Adds functionality for DISCONNECT REASON CODE 0x04. This increases compliance of the [SPARKPLUG B 3.0.0 ](https://www.eclipse.org/tahu/spec/sparkplug_spec.pdf)specification documentation. Sparkplug `[tck-id-payloads-ndeath-will-message-publisher-disconnect-mqtt50]` MQTT V5 `[MQTT-3.1.2.5] Non-normative comment`

dgduncan

Add logging level file config

1

Adds the ability to configure logging level from the file based config. It does this by creating a logger with a `Levelvar` during file based configuration and parsing the included....

dgduncan

Logging level is not supported via `config` file using Docker. This causes some configurations to not operate as intended. For example `hooks.debug.enable` enables debug features; however, this has minimal effect...

dgduncan

Sparkplug PDF - https://www.eclipse.org/tahu/spec/sparkplug_spec.pdf As per [tck-id-payloads-ndeath-will-message-publisher-disconnect-mqtt50], when an Edge Node is sending a DISCONNECT packet, `Disconnect With Will Message` reason code must be passed back. Upon receiving this reason...

dgduncan

Bypassing asdine/storm and directly using bbolt.

1

For #390, Bypassing asdine/storm and directly using bbolt.

werbenhu

Merge 2 version of storm

3

@mochi-co, we seem to be using 2 different versions of storm: https://github.com/mochi-mqtt/server/blob/57997ef0c1460e4ef359c1b8a6b8b10094ead4b7/go.mod#L7-L8 This is because bolt.go is using older version of gob: https://github.com/mochi-mqtt/server/blob/57997ef0c1460e4ef359c1b8a6b8b10094ead4b7/hooks/storage/bolt/bolt.go#L18 Can this be updated to also use...

thedevop

Update README example to reflect new listeners API

1

thedevop