-
Notifications
You must be signed in to change notification settings - Fork 495
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 bindings rocketmq #815
Conversation
# Conflicts: # go.mod # go.sum
@cinience Like with the nacos binding, I'm making tweaks to use "the settings pattern". |
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.
@cinience In general I just made some comments that would make this component cleaner if you want to act on them. Also asked a question if using /internal/retry
makes sense at all.
# Conflicts: # go.sum
/cc: @artursouza |
Codecov Report
@@ Coverage Diff @@
## master #815 +/- ##
==========================================
- Coverage 36.59% 36.07% -0.52%
==========================================
Files 127 129 +2
Lines 10283 10441 +158
==========================================
+ Hits 3763 3767 +4
- Misses 6127 6280 +153
- Partials 393 394 +1
Continue to review full report at Codecov.
|
* master: (23 commits) Add bindings dingtalk webhook (dapr#817) add BulkGetResponse comments (dapr#845) Fix race in pulsar pubsub component (dapr#868) Add pubsub rocketmq (dapr#816) Add bindings rocketmq (dapr#815) Add bindings nacos (dapr#814) Sentinel middleware support (dapr#829) Added vaultToken support (dapr#796) Update Aerospike to v4.5.0 Add function to generate CloudEvent for raw subscribed events. (dapr#864) Configurable retry (dapr#854) Update redis metadata comments to reflect the new maxRetry default from v8 (dapr#856) fix calc ipv6num use ipv4 slice (dapr#838) Do not block indefinitely on XGroupRead for redis subscriber (dapr#855) fix go mod fix lint fix add add a ctx context variable in the Redis struct. And implement `Close() error` function. fix add add a ctx context variable in the Redis struct. And implemet `Close() error` function fix use r.ctx instead of context.Background() in pubsub redis component Fixing go.mod ... # Conflicts: # secretstores/hashicorp/vault/vault.go # secretstores/hashicorp/vault/vault_test.go
Description
A binding that allows reading / writing from Alibaba Cloud RocketMQ.
Issue reference
We strive to have all PR being opened based on an issue, where the problem or feature have been discussed prior to implementation.
Please reference the issue this PR will close: #812
Checklist
Please make sure you've completed the relevant tasks for this PR, out of the following list: