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 #981]🔥Optimize client clusting consume⚡️ #985

Merged
merged 1 commit into from
Sep 22, 2024

[ISSUE #981]🔥Optimize client clusting consume⚡️

9c7a87e
Select commit
Loading
Failed to load commit list.
Merged

[ISSUE #981]🔥Optimize client clusting consume⚡️ #985

[ISSUE #981]🔥Optimize client clusting consume⚡️
9c7a87e
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch failed Sep 22, 2024 in 1s

0.00% of diff hit (target 19.84%)

View this Pull Request on Codecov

0.00% of diff hit (target 19.84%)

Annotations

Check warning on line 178 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#L178 

Added line #L178 was not covered by tests

Check warning on line 227 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#L227 

Added line #L227 was not covered by tests

Check warning on line 263 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#L263 

Added line #L263 was not covered by tests

Check warning on line 275 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#L275 

Added line #L275 was not covered by tests

Check warning on line 303 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#L303 

Added line #L303 was not covered by tests

Check warning on line 37 in rocketmq-client/src/consumer/consumer_impl/consume_message_orderly_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_orderly_service.rs#L36-L37 

Added lines #L36 - L37 were not covered by tests

Check warning on line 64 in rocketmq-client/src/consumer/consumer_impl/consume_message_pop_concurrently_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_pop_concurrently_service.rs#L64 

Added line #L64 was not covered by tests

Check warning on line 36 in rocketmq-client/src/consumer/consumer_impl/consume_message_pop_orderly_service.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/consume_message_pop_orderly_service.rs#L36 

Added line #L36 was not covered by tests

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

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/default_mq_push_consumer_impl.rs#L100 

Added line #L100 was not covered by tests

Check warning on line 144 in rocketmq-client/src/consumer/consumer_impl/default_mq_push_consumer_impl.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/default_mq_push_consumer_impl.rs#L144 

Added line #L144 was not covered by tests

Check warning on line 378 in rocketmq-client/src/consumer/consumer_impl/default_mq_push_consumer_impl.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/default_mq_push_consumer_impl.rs#L378 

Added line #L378 was not covered by tests

Check warning on line 422 in rocketmq-client/src/consumer/consumer_impl/default_mq_push_consumer_impl.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/default_mq_push_consumer_impl.rs#L422 

Added line #L422 was not covered by tests

Check warning on line 1291 in rocketmq-client/src/consumer/consumer_impl/default_mq_push_consumer_impl.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/default_mq_push_consumer_impl.rs#L1291 

Added line #L1291 was not covered by tests

Check warning on line 464 in rocketmq-client/src/consumer/consumer_impl/re_balance/rebalance_push_impl.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/consumer_impl/re_balance/rebalance_push_impl.rs#L463-L464 

Added lines #L463 - L464 were not covered by tests

Check warning on line 1012 in rocketmq-client/src/implementation/mq_client_api_impl.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/implementation/mq_client_api_impl.rs#L1012 

Added line #L1012 was not covered by tests

Check warning on line 1019 in rocketmq-client/src/implementation/mq_client_api_impl.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/implementation/mq_client_api_impl.rs#L1019 

Added line #L1019 was not covered by tests

Check warning on line 1041 in rocketmq-client/src/implementation/mq_client_api_impl.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/implementation/mq_client_api_impl.rs#L1041 

Added line #L1041 was not covered by tests

Check warning on line 377 in rocketmq-remoting/src/clients/rocketmq_default_impl.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-remoting/src/clients/rocketmq_default_impl.rs#L376-L377 

Added lines #L376 - L377 were not covered by tests

Check warning on line 34 in rocketmq-remoting/src/protocol/header/unregister_client_request_header.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-remoting/src/protocol/header/unregister_client_request_header.rs#L34 

Added line #L34 was not covered by tests

Check warning on line 58 in rocketmq-remoting/src/protocol/header/unregister_client_request_header.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-remoting/src/protocol/header/unregister_client_request_header.rs#L58 

Added line #L58 was not covered by tests

Check warning on line 74 in rocketmq-remoting/src/protocol/header/unregister_client_request_header.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-remoting/src/protocol/header/unregister_client_request_header.rs#L65-L74 

Added lines #L65 - L74 were not covered by tests

Check warning on line 80 in rocketmq-remoting/src/protocol/header/unregister_client_request_header.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-remoting/src/protocol/header/unregister_client_request_header.rs#L76-L80 

Added lines #L76 - L80 were not covered by tests

Check warning on line 83 in rocketmq-remoting/src/protocol/header/unregister_client_request_header.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-remoting/src/protocol/header/unregister_client_request_header.rs#L82-L83 

Added lines #L82 - L83 were not covered by tests

Check warning on line 85 in rocketmq-remoting/src/protocol/header/unregister_client_request_header.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-remoting/src/protocol/header/unregister_client_request_header.rs#L85 

Added line #L85 was not covered by tests

Check warning on line 363 in rocketmq-remoting/src/protocol/remoting_command.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-remoting/src/protocol/remoting_command.rs#L360-L363 

Added lines #L360 - L363 were not covered by tests
View more details on Codecov