milvus
milvus copied to clipboard
enhance: implement streaming node server service
issue: #33285
- implement producing and consuming server of message
- implement management operation for streaming node server
@chyezh E2e jenkins job failed, comment /run-cpu-e2e can trigger the job again.
Codecov Report
Attention: Patch coverage is 85.53191% with 68 lines in your changes missing coverage. Please review.
Project coverage is 79.81%. Comparing base (
ba04981) to head (e611725). Report is 21 commits behind head on master.
Additional details and impacted files
@@ Coverage Diff @@
## master #34166 +/- ##
==========================================
+ Coverage 79.70% 79.81% +0.10%
==========================================
Files 1119 1127 +8
Lines 138783 139380 +597
==========================================
+ Hits 110614 111241 +627
+ Misses 23926 23864 -62
- Partials 4243 4275 +32
| Files | Coverage Δ | |
|---|---|---|
| internal/proxy/search_util.go | 84.61% <ø> (ø) |
|
| ...ice/handler/consumer/consume_grpc_server_helper.go | 100.00% <100.00%> (ø) |
|
| ...ice/handler/producer/produce_grpc_server_helper.go | 100.00% <100.00%> (ø) |
|
| ...al/streamingnode/server/walmanager/manager_impl.go | 87.14% <100.00%> (ø) |
|
| ...al/streamingnode/server/walmanager/wal_lifetime.go | 89.55% <100.00%> (ø) |
|
| ...reamingutil/service/contextutil/create_consumer.go | 100.00% <100.00%> (ø) |
|
| ...reamingutil/service/contextutil/create_producer.go | 100.00% <100.00%> (ø) |
|
| internal/util/streamingutil/status/rpc_error.go | 83.33% <ø> (ø) |
|
| ...ernal/util/streamingutil/status/streaming_error.go | 95.83% <100.00%> (+0.18%) |
:arrow_up: |
| .../util/streamingutil/typeconverter/pchannel_info.go | 100.00% <100.00%> (ø) |
|
| ... and 13 more |
@chyezh Thanks for your contribution. Please submit with DCO, see the contributing guide https://github.com/milvus-io/milvus/blob/master/CONTRIBUTING.md#developer-certificate-of-origin-dco.
rerun ut
@chyezh E2e jenkins job failed, comment /run-cpu-e2e can trigger the job again.
rerun ut
/lgtm
[APPROVALNOTIFIER] This PR is APPROVED
Approval requirements bypassed by manually added approval.
This pull-request has been approved by: chyezh
The full list of commands accepted by this bot can be found here.
The pull request process is described here
Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment