Skip to content

[ISSUE #1012]šŸš€Support client Broadcasting consume-local file storeāš”ļø

Codecov / codecov/patch failed Sep 28, 2024 in 0s

0.00% of diff hit (target 19.92%)

View this Pull Request on Codecov

0.00% of diff hit (target 19.92%)

Annotations

Check warning on line 40 in rocketmq-client/src/consumer/store/controllable_offset.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/controllable_offset.rs#L35-L40

Added lines #L35 - L40 were not covered by tests

Check warning on line 42 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L42

Added line #L42 was not covered by tests

Check warning on line 52 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L50-L52

Added lines #L50 - L52 were not covered by tests

Check warning on line 55 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L54-L55

Added lines #L54 - L55 were not covered by tests

Check warning on line 69 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L65-L69

Added lines #L65 - L69 were not covered by tests

Check warning on line 76 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L74-L76

Added lines #L74 - L76 were not covered by tests

Check warning on line 82 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L78-L82

Added lines #L78 - L82 were not covered by tests

Check warning on line 86 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L84-L86

Added lines #L84 - L86 were not covered by tests

Check warning on line 89 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L88-L89

Added lines #L88 - L89 were not covered by tests

Check warning on line 97 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L91-L97

Added lines #L91 - L97 were not covered by tests

Check warning on line 101 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L99-L101

Added lines #L99 - L101 were not covered by tests

Check warning on line 104 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L103-L104

Added lines #L103 - L104 were not covered by tests

Check warning on line 106 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L106

Added line #L106 was not covered by tests

Check warning on line 134 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L129-L134

Added lines #L129 - L134 were not covered by tests

Check warning on line 136 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L136

Added line #L136 was not covered by tests

Check warning on line 176 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L176

Added line #L176 was not covered by tests

Check warning on line 182 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L179-L182

Added lines #L179 - L182 were not covered by tests

Check warning on line 184 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L184

Added line #L184 was not covered by tests

Check warning on line 189 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L186-L189

Added lines #L186 - L189 were not covered by tests

Check warning on line 191 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L191

Added line #L191 was not covered by tests

Check warning on line 197 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L194-L197

Added lines #L194 - L197 were not covered by tests

Check warning on line 202 in rocketmq-client/src/consumer/store/local_file_offset_store.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/local_file_offset_store.rs#L201-L202

Added lines #L201 - L202 were not covered by tests

Check warning on line 24 in rocketmq-client/src/consumer/store/offset_serialize_wrapper.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/offset_serialize_wrapper.rs#L24

Added line #L24 was not covered by tests

Check warning on line 27 in rocketmq-client/src/consumer/store/offset_serialize_wrapper.rs

See this annotation in the file changed.

@codecov codecov / codecov/patch

rocketmq-client/src/consumer/store/offset_serialize_wrapper.rs#L27

Added line #L27 was not covered by tests