Use stream and completed for a bulk to collect for grpc reporter.

[jmjoy]

In the past, for convenience, collect was called every time the data was received.

Now it is changed to stream mode, and only call collect once, which should improve the performance.

[codecov-commenter]

Codecov Report

Merging #54 (3e5a18c) into master (7d4b379) will decrease coverage by 0.34%.
The diff coverage is 0.00%.

@@            Coverage Diff             @@
##           master      #54      +/-   ##
==========================================
- Coverage   17.51%   17.18%   -0.34%     
==========================================
  Files          17       17              
  Lines         571      582      +11     
==========================================
  Hits          100      100              
- Misses        471      482      +11     

Impacted Files	Coverage Δ
src/reporter/grpc.rs	0.00% <0.00%> (ø)

📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more

[wu-sheng]

Is this a gRPC stream? If so, gRPC stream should be completed for a bulk. Keeping a stream always open may have side effect, and cause too much load to maintain the uncompleted status.

[jmjoy]

Is this a gRPC stream? If so, gRPC stream should be completed for a bulk. Keeping a stream always open may have side effect, and cause too much load to maintain the uncompleted status.

OK, will adjust.

[wu-sheng]

Ref this.

https://github.com/apache/skywalking/blob/master/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/handler/v8/grpc/TraceSegmentReportServiceHandler.java#L63

If you are going to implement push Command for downstream/agent. OnComplete is a trigger point. Not through trace segment report, but other gRPC service. And backend self-telemetry relies on this to summary statistics.

[jmjoy]

I want to adjust it as follows:

Every 30 seconds, the stream will end, and then collect will be called again. How about that?

[wu-sheng]

I want to adjust it as follows:

Every 30 seconds, the stream will end, and then collect will be called again. How about that?

You could control it according to rust implementation. Just keep it neither always open, nor keep open/close for every segment.

[wu-sheng]

LGTM