-
Notifications
You must be signed in to change notification settings - Fork 174
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 rocketMq message gray plugin #1599
Conversation
Codecov ReportAll modified and coverable lines are covered by tests ✅
Flags with carried forward coverage won't be shown. Click here to find out more. |
9ece8d0
to
d2f6ce4
Compare
Describe your core logic of this feature as list |
Core logic: If the current instance service_meta matched serviceMeta config or current thread traffic tag matched trafficTag config, current instance mark as gray instance, or is base instance. 1、produce message If current instance is gray, during produce message, set trafficTags in the message property. 2、consume message gray instance Only consume contains current consumerGroupTag corresponding traffic tags message. base instance auto model: First, exclude consumerGroupTag corresponding traffic tags message that set in excludeGroupTags, dynamically querying whether there are new gray consumer group consume message, if have, exclude corresponding traffic tags message. base mode: Exclude consumerGroupTag corresponding traffic tags message that set in excludeGroupTags, if excludeGroupTags not set, then consume all message. |
8600d70
to
40ee4e0
Compare
...t-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/SubscriptionDataUtils.java
Show resolved
Hide resolved
...t-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/SubscriptionDataUtils.java
Outdated
Show resolved
Hide resolved
...t-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/SubscriptionDataUtils.java
Outdated
Show resolved
Hide resolved
...nt-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/MqGrayConfigHandler.java
Outdated
Show resolved
Hide resolved
...mant-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/MqGrayscaleConfig.java
Outdated
Show resolved
Hide resolved
382af61
to
52aeacb
Compare
...le/sermant-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/BaseMessage.java
Outdated
Show resolved
Hide resolved
516496e
to
eaeccd9
Compare
...le/sermant-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/GrayTagItem.java
Outdated
Show resolved
Hide resolved
...le/sermant-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/GrayTagItem.java
Outdated
Show resolved
Hide resolved
...nt-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/MqGrayConfigHandler.java
Outdated
Show resolved
Hide resolved
...-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/MqGrayscaleConfigUtils.java
Outdated
Show resolved
Hide resolved
...-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/MqGrayscaleConfigUtils.java
Outdated
Show resolved
Hide resolved
...-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/MqGrayscaleConfigUtils.java
Outdated
Show resolved
Hide resolved
...-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/MqGrayscaleConfigUtils.java
Outdated
Show resolved
Hide resolved
...-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/MqGrayscaleConfigUtils.java
Outdated
Show resolved
Hide resolved
...mant-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/MqGrayscaleConfig.java
Outdated
Show resolved
Hide resolved
...t-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/SubscriptionDataUtils.java
Outdated
Show resolved
Hide resolved
...ale-plugin/src/main/resources/META-INF/services/io.sermant.core.plugin.service.PluginService
Outdated
Show resolved
Hide resolved
...in/src/main/resources/META-INF/services/io.sermant.core.plugin.agent.declarer.PluginDeclarer
Outdated
Show resolved
Hide resolved
...le/sermant-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/BaseMessage.java
Outdated
Show resolved
Hide resolved
...le/sermant-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/GrayTagItem.java
Outdated
Show resolved
Hide resolved
...le/sermant-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/GrayTagItem.java
Outdated
Show resolved
Hide resolved
...le/sermant-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/GrayTagItem.java
Outdated
Show resolved
Hide resolved
...le/sermant-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/GrayTagItem.java
Outdated
Show resolved
Hide resolved
...mant-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/MqGrayscaleConfig.java
Outdated
Show resolved
Hide resolved
...mant-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/MqGrayscaleConfig.java
Outdated
Show resolved
Hide resolved
...-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/MqGrayscaleConfigUtils.java
Show resolved
Hide resolved
...-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/MqGrayscaleConfigUtils.java
Show resolved
Hide resolved
...-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/MqGrayscaleConfigUtils.java
Outdated
Show resolved
Hide resolved
...t-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/SubscriptionDataUtils.java
Outdated
Show resolved
Hide resolved
...t-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/SubscriptionDataUtils.java
Show resolved
Hide resolved
...t-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/SubscriptionDataUtils.java
Show resolved
Hide resolved
95bef84
to
22e64d7
Compare
...le/sermant-mq-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/config/GrayTagItem.java
Outdated
Show resolved
Hide resolved
ecc6195
to
6e7ae2a
Compare
ec2e6b3
to
3c1f0c2
Compare
Signed-off-by: chengyouling <[email protected]>
dd7cc32
to
073a298
Compare
What type of PR is this?
Feature.
What this PR does / why we need it?
During gray deployment, gray instances need to consume or produce gray messages.
Which issue(s) this PR fixes?
Fixes #1539
Does this PR introduce a user-facing change?
No