-
Notifications
You must be signed in to change notification settings - Fork 21
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add super stream producer #288
Conversation
Add Murmur32 strategy Add RoutingStrategy interface Signed-off-by: Gabriele Santomaggio <[email protected]>
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## main #288 +/- ##
==========================================
+ Coverage 83.43% 83.79% +0.36%
==========================================
Files 24 25 +1
Lines 3350 3610 +260
==========================================
+ Hits 2795 3025 +230
- Misses 402 419 +17
- Partials 153 166 +13 ☔ View full report in Codecov by Sentry. |
Signed-off-by: Gabriele Santomaggio <[email protected]>
Signed-off-by: Gabriele Santomaggio <[email protected]>
Signed-off-by: Gabriele Santomaggio <[email protected]>
Signed-off-by: Gabriele Santomaggio <[email protected]>
to reconnect the stream. Signed-off-by: Gabriele Santomaggio <[email protected]>
add route query Signed-off-by: Gabriele Santomaggio <[email protected]>
add channel for channel close Signed-off-by: Gabriele Santomaggio <[email protected]>
Signed-off-by: Gabriele Santomaggio <[email protected]>
during the reconnection Signed-off-by: Gabriele Santomaggio <[email protected]>
Signed-off-by: Gabriele Santomaggio <[email protected]>
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It looks good to me after the pairing session. Just added a few minor comments!
pkg/test_helper/http_utils.go
Outdated
} | ||
//type queue struct { | ||
// Messages int `json:"messages"` | ||
//} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can this commented rows be deleted?
Signed-off-by: Gabriele Santomaggio <[email protected]>
Will merge after pairing with @DanielePalaia |
SuperStreamProducer
New struct to create the super stream producer:
The main features are:
RoutingStrategy
interfaceHashRoutingStrategy
structKeyRoutingStrategy
structSuperStreamProducer
structPartitionContext
structExample:
Here the full code example