feat(proxy): add metrics and trace for remoting send and pull RPC #844
26.56% of diff hit (within 50.00% threshold of 55.49%)
View this Pull Request on Codecov
26.56% of diff hit (within 50.00% threshold of 55.49%)
Annotations
codecov / codecov/patch
proxy/src/main/java/com/automq/rocketmq/proxy/remoting/activity/ExtendPullMessageActivity.java#L105-L108
Added lines #L105 - L108 were not covered by tests
codecov / codecov/patch
proxy/src/main/java/com/automq/rocketmq/proxy/remoting/activity/ExtendPullMessageActivity.java#L114-L123
Added lines #L114 - L123 were not covered by tests
codecov / codecov/patch
proxy/src/main/java/com/automq/rocketmq/proxy/remoting/activity/ExtendPullMessageActivity.java#L259-L260
Added lines #L259 - L260 were not covered by tests
codecov / codecov/patch
proxy/src/main/java/com/automq/rocketmq/proxy/remoting/activity/ExtendPullMessageActivity.java#L267
Added line #L267 was not covered by tests
codecov / codecov/patch
proxy/src/main/java/com/automq/rocketmq/proxy/remoting/activity/ExtendSendMessageActivity.java#L87-L96
Added lines #L87 - L96 were not covered by tests
codecov / codecov/patch
proxy/src/main/java/com/automq/rocketmq/proxy/remoting/activity/ExtendSendMessageActivity.java#L157
Added line #L157 was not covered by tests
codecov / codecov/patch
proxy/src/main/java/com/automq/rocketmq/proxy/remoting/activity/ExtendSendMessageActivity.java#L167-L176
Added lines #L167 - L176 were not covered by tests
codecov / codecov/patch
proxy/src/main/java/com/automq/rocketmq/proxy/remoting/activity/ExtendSendMessageActivity.java#L187
Added line #L187 was not covered by tests
codecov / codecov/patch
proxy/src/main/java/com/automq/rocketmq/proxy/remoting/activity/ExtendSendMessageActivity.java#L210-L213
Added lines #L210 - L213 were not covered by tests
codecov / codecov/patch
proxy/src/main/java/com/automq/rocketmq/proxy/service/MessageServiceImpl.java#L834
Added line #L834 was not covered by tests
Check warning on line 184 in store/src/main/java/com/automq/rocketmq/store/MessageStoreImpl.java
codecov / codecov/patch
store/src/main/java/com/automq/rocketmq/store/MessageStoreImpl.java#L184
Added line #L184 was not covered by tests
Check warning on line 186 in store/src/main/java/com/automq/rocketmq/store/MessageStoreImpl.java
codecov / codecov/patch
store/src/main/java/com/automq/rocketmq/store/MessageStoreImpl.java#L186
Added line #L186 was not covered by tests