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

[ISSUE #972]🔥Supports client clusting consume🚀 #980

Merged
merged 2 commits into from
Sep 20, 2024

fix cmd cargo clippy error

ef9380c
Select commit
Loading
Failed to load commit list.
Merged

[ISSUE #972]🔥Supports client clusting consume🚀 #980

fix cmd cargo clippy error
ef9380c
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch failed Sep 20, 2024 in 1s

0.00% of diff hit (target 21.02%)

View this Pull Request on Codecov

0.00% of diff hit (target 21.02%)

Annotations

Check warning on line 145 in rocketmq-client/src/base/client_config.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/base/client_config.rs#L145 

Added line #L145 was not covered by tests

Check warning on line 149 in rocketmq-client/src/base/client_config.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/base/client_config.rs#L148-L149 

Added lines #L148 - L149 were not covered by tests

Check warning on line 153 in rocketmq-client/src/base/client_config.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/base/client_config.rs#L153 

Added line #L153 was not covered by tests

Check warning on line 156 in rocketmq-client/src/base/client_config.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/base/client_config.rs#L156 

Added line #L156 was not covered by tests

Check warning on line 56 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L56 

Added line #L56 was not covered by tests

Check warning on line 67 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L67 

Added line #L67 was not covered by tests

Check warning on line 69 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L69 

Added line #L69 was not covered by tests

Check warning on line 75 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L74-L75 

Added lines #L74 - L75 were not covered by tests

Check warning on line 93 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L87-L93 

Added lines #L87 - L93 were not covered by tests

Check warning on line 97 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L96-L97 

Added lines #L96 - L97 were not covered by tests

Check warning on line 100 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L99-L100 

Added lines #L99 - L100 were not covered by tests

Check warning on line 104 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L103-L104 

Added lines #L103 - L104 were not covered by tests

Check warning on line 108 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L108 

Added line #L108 was not covered by tests

Check warning on line 111 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L110-L111 

Added lines #L110 - L111 were not covered by tests

Check warning on line 120 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L115-L120 

Added lines #L115 - L120 were not covered by tests

Check warning on line 122 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L122 

Added line #L122 was not covered by tests

Check warning on line 136 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L130-L136 

Added lines #L130 - L136 were not covered by tests

Check warning on line 138 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L138 

Added line #L138 was not covered by tests

Check warning on line 142 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L140-L142 

Added lines #L140 - L142 were not covered by tests

Check warning on line 153 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L149-L153 

Added lines #L149 - L153 were not covered by tests

Check warning on line 155 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L155 

Added line #L155 was not covered by tests

Check warning on line 157 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L157 

Added line #L157 was not covered by tests

Check warning on line 162 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L159-L162 

Added lines #L159 - L162 were not covered by tests

Check warning on line 166 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L166 

Added line #L166 was not covered by tests

Check warning on line 168 in rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_concurrently_service.rs#L168 

Added line #L168 was not covered by tests
View more details on Codecov