Inline Publishing #8
Merged
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
added 7 commits
January 5, 2022 13:13
Ensure we're not committing any binaries
When the broker is embedded in a larger Go codebase, it is beneficial to be able to publish messages directly from the system to topics. This change provides a Publish method which adds messages to an inline publishing queue in a separate goroutine, which are then processed in the standard way and issued to all clients with matching topic filters.
Adds an example file which demonstrates the usage of the `Publish` method. This file will also be used to demonstrate event hooks.
Adds information about direct publishing and moves performance section
Codecov Report
@@ Coverage Diff @@
## master #8 +/- ##
==========================================
+ Coverage 98.94% 98.95% +0.01%
==========================================
Files 18 18
Lines 1989 2017 +28
==========================================
+ Hits 1968 1996 +28
Misses 19 19
Partials 2 2
Continue to review full report at Codecov.
|
Closed
Closed
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Adds the ability to directly publish messages from the embedding service using the
func (s *Server) Publish(topic string, payload []byte, retain bool) errormethod.Also provides various commentary cleanups for clarity.