Upgrade dependencies.

.github/workflows/ci.yaml

@@ -81,6 +81,8 @@ jobs:
       - uses: actions/checkout@v2
         with:
           submodules: 'recursive'
+      - name: Install protoc
+        run: sudo apt-get install -y protobuf-compiler
       - name: Install Rust toolchain
         run: rustup toolchain install stable --component clippy
       - name: Run check
@@ -96,6 +98,8 @@ jobs:
       - uses: actions/checkout@v2
         with:
           submodules: 'recursive'
+      - name: Install protoc
+        run: sudo apt-get install -y protobuf-compiler
       - name: Install Rust toolchain
         run: rustup toolchain install stable
       - name: Run docs

.github/workflows/codecov.yaml

@@ -30,6 +30,8 @@ jobs:
       - uses: actions/checkout@v2
         with:
           submodules: true
+      - name: Install protoc
+        run: sudo apt-get install -y protobuf-compiler
       - uses: actions-rs/toolchain@v1
         with:
           profile: minimal

Cargo.toml

@@ -38,25 +38,25 @@ mock = []  # For internal integration testing only, do not use.
 [dependencies]
 async-stream = "0.3.3"
 base64 = "0.13.0"
-bytes = "1.1.0"
+bytes = "1.2.1"
 cfg-if = "1.0.0"
 futures-core = "0.3.21"
 futures-util = "0.3.21"
-prost = "0.10.4"
-prost-derive = "0.10.1"
-serde = { version = "1.0.138", features = ["derive"] }
-thiserror = "1.0.31"
-tokio = { version = "1.18.2", features = ["parking_lot"] }
-tonic = { version = "0.7.2", features = ["codegen"] }
-tracing = "0.1.35"
-uuid = { version = "1.1.0", features = ["serde", "v4"] }
+prost = "0.11.0"
+prost-derive = "0.11.0"
+serde = { version = "1.0.143", features = ["derive"] }
+thiserror = "1.0.32"
+tokio = { version = "1.20.1", features = ["parking_lot"] }
+tonic = { version = "0.8.0", features = ["codegen"] }
+tracing = "0.1.36"
+uuid = { version = "1.1.2", features = ["serde", "v4"] }
 
 [build-dependencies]
-tonic-build = "0.7.2"
+tonic-build = "0.8.0"
 
 [dev-dependencies]
-tokio = { version = "1.18.2", features = ["rt-multi-thread", "signal"] }
-tokio-stream = { version = "0.1.8", features = ["net"] }
+tokio = { version = "1.20.1", features = ["rt-multi-thread", "signal"] }
+tokio-stream = { version = "0.1.9", features = ["net"] }
 
 [[test]]
 name = "trace_context"

e2e/docker/Dockerfile

@@ -16,7 +16,7 @@
 # under the License.
 #
 FROM rust:1.57
-RUN apt-get update && apt-get install -y cmake
+RUN apt-get update && apt-get install -y cmake protobuf-compiler
 WORKDIR /build
 COPY . /build/
 RUN cargo build --release --workspace

src/reporter/mod.rs

@@ -15,13 +15,14 @@
 //
 
 pub mod grpc;
-pub mod once_cell;
 pub mod print;
 
 use crate::skywalking_proto::v3::{LogData, SegmentObject};
+use serde::{Deserialize, Serialize};
 use std::{ops::Deref, sync::Arc};
+use tokio::sync::OnceCell;
 
-#[derive(Debug)]
+#[derive(Debug, Serialize, Deserialize)]
 #[non_exhaustive]
 pub enum CollectItem {
     Trace(SegmentObject),
@@ -51,3 +52,9 @@ impl<T: Report> Report for Arc<T> {
         Report::report(self.deref(), item)
     }
 }
+
+impl<T: Report> Report for OnceCell<T> {
+    fn report(&self, item: CollectItem) {
+        Report::report(self.get().expect("OnceCell is empty"), item)
+    }
+}