Skip to content
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.

Sign up for GitHub

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

Jump to bottom

add mq gray plugin declare/service #1609

Merged
merged 1 commit into from
Sep 18, 2024
Merged

add mq gray plugin declare/service #1609

merged 1 commit into from
Sep 18, 2024

Conversation

chengyouling
Copy link
Collaborator

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

@chengyouling chengyouling self-assigned this Aug 31, 2024
@codecov Codecov
Copy link

codecov bot commented Aug 31, 2024 •
edited
Loading

Codecov Report

All modified and coverable lines are covered by tests ✅

Flag Coverage Δ Complexity Δ
unittests 43.97% <ø> (+1.13%) 182.00 <ø> (ø)

Flags with carried forward coverage won't be shown. Click here to find out more.

see 79 files with indirect coverage changes

@chengyouling chengyouling force-pushed the develop-mq-gray-declare branch from 6afad8d to 12af47e Compare August 31, 2024 11:10
hanbingleixue
hanbingleixue reviewed Sep 4, 2024
View reviewed changes
...main/java/io/sermant/mq/grayscale/interceptor/MqSchedulerRebuildSubscriptionInterceptor.java Outdated Show resolved Hide resolved
...main/java/io/sermant/mq/grayscale/interceptor/MqSchedulerRebuildSubscriptionInterceptor.java Outdated Show resolved Hide resolved
...main/java/io/sermant/mq/grayscale/interceptor/PullConsumerSubscriptionUpdateInterceptor.java Outdated Show resolved Hide resolved
...grayscale-plugin/src/main/java/io/sermant/mq/grayscale/service/MqConsumerGroupAutoCheck.java Outdated Show resolved Hide resolved
...grayscale-plugin/src/main/java/io/sermant/mq/grayscale/service/MqConsumerGroupAutoCheck.java Outdated Show resolved Hide resolved
...ayscale-plugin/src/main/java/io/sermant/mq/grayscale/service/MqGrayDynamicConfigService.java Outdated Show resolved Hide resolved
@chengyouling chengyouling force-pushed the develop-mq-gray-declare branch 2 times, most recently from 9a0da0b to 76ed33b Compare September 4, 2024 07:25
@chengyouling chengyouling force-pushed the develop-mq-gray-declare branch 2 times, most recently from ba43a7e to 82e56c4 Compare September 5, 2024 01:32
@chengyouling chengyouling force-pushed the develop-mq-gray-declare branch 2 times, most recently from 6f46c4f to 3b6b813 Compare September 6, 2024 01:49
daizhenyu
daizhenyu reviewed Sep 7, 2024
View reviewed changes
...mq-plugin/src/main/java/io/sermant/mq/grayscale/interceptor/RocketMqAbstractIntercepter.java Outdated Show resolved Hide resolved
...a/io/sermant/mq/grayscale/interceptor/RocketMqPullConsumerSubscriptionUpdateInterceptor.java Outdated Show resolved Hide resolved
...a/io/sermant/mq/grayscale/interceptor/RocketMqPullConsumerSubscriptionUpdateInterceptor.java Outdated Show resolved Hide resolved
...e/mq-grayscale-rocketmq-plugin/src/main/java/io/sermant/mq/grayscale/config/BaseMessage.java Outdated Show resolved Hide resolved
...cketmq-plugin/src/main/java/io/sermant/mq/grayscale/utils/RocketMqSubscriptionDataUtils.java Outdated Show resolved Hide resolved
...tmq-plugin/src/main/java/io/sermant/mq/grayscale/service/RocketMqConsumerGroupAutoCheck.java Outdated Show resolved Hide resolved
@chengyouling chengyouling force-pushed the develop-mq-gray-declare branch 2 times, most recently from bdb8945 to 7cc85b3 Compare September 7, 2024 07:28
@chengyouling chengyouling force-pushed the develop-mq-gray-declare branch 2 times, most recently from 4a4ba0c to a8ff652 Compare September 12, 2024 11:57
@chengyouling chengyouling force-pushed the develop-mq-gray-declare branch 2 times, most recently from cd67bd8 to a020b74 Compare September 13, 2024 00:57
@chengyouling chengyouling force-pushed the develop-mq-gray-declare branch from 535ecc9 to bd5bd28 Compare September 13, 2024 03:31
@chengyouling chengyouling force-pushed the develop-mq-gray-declare branch 2 times, most recently from 1fa334d to 0673593 Compare September 13, 2024 09:24
@chengyouling chengyouling force-pushed the develop-mq-gray-declare branch from 66bb408 to cd60332 Compare September 14, 2024 01:55
@Sherlockhan Sherlockhan merged commit 03c241a into sermant-io:develop Sep 18, 2024
4 checks passed
@chengyouling chengyouling deleted the develop-mq-gray-declare branch January 7, 2025 01:25
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers

@hanbingleixue hanbingleixue hanbingleixue left review comments

@daizhenyu daizhenyu daizhenyu approved these changes

@lilai23 lilai23 lilai23 approved these changes

Assignees

@chengyouling chengyouling

Labels
None yet
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.

support rocketMq grayscale message
5 participants
@chengyouling @hanbingleixue @lilai23 @daizhenyu @Sherlockhan