* Fix the bug where inline subscribers do not receive messages after all non-inline clients unsubscribe.
* Bypassing asdine/storm and directly using bbolt.
* Fixed erroneous removal of FileContributor.
---------
Co-authored-by: JB <28275108+mochi-co@users.noreply.github.com>
* Replace badgerhold with directly using BadgerDB v4.
* Optimize code and test cases.
* Optimize code.
* Set the default size of the log file to 100 MB.
* Resolve merge conflicts.
* Implementing Pebble as a persistence database hook.
* Fixed failing test cases.
* Add Pebble DB configuration for file-based configuration, optimize part of the code.
* Resolve test failure issues and perform code optimization.
* Optimized the test cases.
* For issues #370, #369, and #363, add BadgerDB garbage collection.
* Add default configuration for defaultGcInterval.
* Solve DATA RACE.
* Place Badger's configuration in main.go for users to adjust as needed.
* Add TestGcLoop() for coverage.
* Modify GcInterval to shorten test time.
* Add the GcDiscardRatio option for the Badger hook, and include more detailed comments in the example.
---------
Co-authored-by: JB <28275108+mochi-co@users.noreply.github.com>
* Begin adding new slog calls
* Fixed unit tests
* Add leveler example
* Add debug log level to Redis example
* Change location of server.Close() and add logs to example/hooks
* Begin removing references to zerolog
* Removed final references to zerolog
* Change where server.Close() occurs in main
* Change to 1.21 to remove x dependency
* Add slog
* Update references to 1.21
* Begin change of LogAttrs to standard logging interface
* Change the rest of LogAttrs to default
* Fix bad log
* Update badger.go
Changing "data" to "key" or "id" here might be more appropriate.
* Update badger.go
Changing "data" to "key" or "id" here might be more appropriate.
* Update server.go
Not checking if err is equal to nil
* Update server.go
printing information for ID or error is missing.
* Change references of err.Error() to err in slog
* Remove missed removal of Error() references for logging
---------
Co-authored-by: Derek Duncan <dduncan@atlassian.com>
Co-authored-by: Derek Duncan <derekduncan@gmail.com>
Co-authored-by: JB <28275108+mochi-co@users.noreply.github.com>
Co-authored-by: werbenhu <werben@qq.com>
* WriterSize parameter is incorrectly set
The WriterSize parameter is incorrectly set in the newClient method.
* Use JSONeq to compare JSON
This ensures that test results pass even if the field order is inconsistent.
---------
Co-authored-by: JB <28275108+mochi-co@users.noreply.github.com>
* storage hook should not execute the relevant code if the client has been reconnected #78
* add test cases for coverage decrease
add test cases for coverage decrease
* Update redis.go
Save the subscription properties for mqqtv5
* Update badger.go
Save the subscription properties for mqqtv5
* Update bolt.go
Save the subscription properties for mqqtv5
Co-authored-by: JB <28275108+mochi-co@users.noreply.github.com>
