chore: update Tonic and Prost dependencies

.cargo/config

@@ -1,2 +1,5 @@
 [build]
-rustflags = ["--cfg", "tokio_unstable"]
+rustflags = ["--cfg", "tokio_unstable"]
+
+[alias]
+xtask = "run --manifest-path ./xtask/Cargo.toml --"

.github/workflows/ci.yaml

@@ -75,6 +75,11 @@ jobs:
           override: true
       - uses: Swatinem/rust-cache@v1
 
+      - name: Install Protoc
+        uses: arduino/setup-protoc@v1
+        with:
+          repo-token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: Run cargo test (API)
         uses: actions-rs/cargo@v1
         with:

Cargo.toml

@@ -2,6 +2,7 @@
 members = [
     "tokio-console",
     "console-subscriber",
-    "console-api"
+    "console-api",
+    "xtask"
 ]
 resolver = "2"

console-api/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "console-api"
-version = "0.3.0"
+version = "0.4.0"
 license = "MIT"
 edition = "2021"
 rust-version = "1.58.0"
@@ -29,17 +29,17 @@ keywords = [
 transport = ["tonic-build/transport", "tonic/transport"]
 
 [dependencies]
-tonic = { version = "0.7", default-features = false, features = [
+tonic = { version = "0.8", default-features = false, features = [
     "prost",
     "codegen",
     "transport",
 ] }
-prost = "0.10"
-prost-types = "0.10"
+prost = "0.11"
+prost-types = "0.11"
 tracing-core = "0.1.17"
 
 [dev-dependencies]
-tonic-build = { version = "0.7", default-features = false, features = [
+tonic-build = { version = "0.8", default-features = false, features = [
     "prost", "transport"
 ] }
 

console-api/src/generated/rs.tokio.console.async_ops.rs

@@ -1,85 +1,85 @@
-/// An `AsyncOp` state update. 
+///  An `AsyncOp` state update. 
 ///
-/// This includes a list of any new async ops, and updates to the associated statistics
-/// for any async ops that have changed since the last update.
+///  This includes a list of any new async ops, and updates to the associated statistics
+///  for any async ops that have changed since the last update.
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct AsyncOpUpdate {
-    /// A list of new async operations that were created since the last `AsyncOpUpdate`
-    /// was sent. Note that the fact that an async operation has been created
-    /// does not mean that is has been polled or is being polled. This information
-    /// is reflected in the `Stats` of the operation.
+    ///  A list of new async operations that were created since the last `AsyncOpUpdate`
+    ///  was sent. Note that the fact that an async operation has been created
+    ///  does not mean that is has been polled or is being polled. This information
+    ///  is reflected in the `Stats` of the operation.
     #[prost(message, repeated, tag="1")]
     pub new_async_ops: ::prost::alloc::vec::Vec<AsyncOp>,
-    /// Any async op stats that have changed since the last update.
+    ///  Any async op stats that have changed since the last update.
     #[prost(map="uint64, message", tag="2")]
     pub stats_update: ::std::collections::HashMap<u64, Stats>,
-    /// A count of how many async op events (e.g. polls, creation, etc) were not
-    /// recorded because the application's event buffer was at capacity.
+    ///  A count of how many async op events (e.g. polls, creation, etc) were not
+    ///  recorded because the application's event buffer was at capacity.
     ///
-    /// If everything is working normally, this should be 0. If it is greater
-    /// than 0, that may indicate that some data is missing from this update, and
-    /// it may be necessary to increase the number of events buffered by the
-    /// application to ensure that data loss is avoided.
+    ///  If everything is working normally, this should be 0. If it is greater
+    ///  than 0, that may indicate that some data is missing from this update, and
+    ///  it may be necessary to increase the number of events buffered by the
+    ///  application to ensure that data loss is avoided.
     ///
-    /// If the application's instrumentation ensures reliable delivery of events,
-    /// this will always be 0.
+    ///  If the application's instrumentation ensures reliable delivery of events,
+    ///  this will always be 0.
     #[prost(uint64, tag="3")]
     pub dropped_events: u64,
 }
-/// An async operation.
+///  An async operation.
 ///
-/// An async operation is an operation that is associated with a resource
-/// This could, for example, be a a read or write on a TCP stream, or a receive operation on
-/// a channel.
+///  An async operation is an operation that is associated with a resource
+///  This could, for example, be a a read or write on a TCP stream, or a receive operation on
+///  a channel.
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct AsyncOp {
-    /// The async op's ID.
+    ///  The async op's ID.
     ///
-    /// This uniquely identifies this op across all *currently live*
-    /// ones.
+    ///  This uniquely identifies this op across all *currently live*
+    ///  ones.
     #[prost(message, optional, tag="1")]
     pub id: ::core::option::Option<super::common::Id>,
-    /// The numeric ID of the op's `Metadata`.
+    ///  The numeric ID of the op's `Metadata`.
     ///
-    /// This identifies the `Metadata` that describes the `tracing` span
-    /// corresponding to this async op. The metadata for this ID will have been sent
-    /// in a prior `RegisterMetadata` message.
+    ///  This identifies the `Metadata` that describes the `tracing` span
+    ///  corresponding to this async op. The metadata for this ID will have been sent
+    ///  in a prior `RegisterMetadata` message.
     #[prost(message, optional, tag="2")]
     pub metadata: ::core::option::Option<super::common::MetaId>,
-    /// The source of this async operation. Most commonly this should be the name
-    /// of the method where the instantiation of this op has happened.
+    ///  The source of this async operation. Most commonly this should be the name
+    ///  of the method where the instantiation of this op has happened.
     #[prost(string, tag="3")]
     pub source: ::prost::alloc::string::String,
-    /// The ID of the parent async op.
+    ///  The ID of the parent async op.
     ///
-    /// This field is only set if this async op was created while inside of another
-    /// async op.  For example, `tokio::sync`'s `Mutex::lock` internally calls
-    /// `Semaphore::acquire`.
+    ///  This field is only set if this async op was created while inside of another
+    ///  async op.  For example, `tokio::sync`'s `Mutex::lock` internally calls
+    ///  `Semaphore::acquire`.
     ///
-    /// This field can be empty; if it is empty, this async op is not a child of another
-    /// async op.
+    ///  This field can be empty; if it is empty, this async op is not a child of another
+    ///  async op.
     #[prost(message, optional, tag="4")]
     pub parent_async_op_id: ::core::option::Option<super::common::Id>,
-    /// The resources's ID.
+    ///  The resources's ID.
     #[prost(message, optional, tag="5")]
     pub resource_id: ::core::option::Option<super::common::Id>,
 }
-/// Statistics associated with a given async operation.
+///  Statistics associated with a given async operation.
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct Stats {
-    /// Timestamp of when the async op has been created.
+    ///  Timestamp of when the async op has been created.
     #[prost(message, optional, tag="1")]
     pub created_at: ::core::option::Option<::prost_types::Timestamp>,
-    /// Timestamp of when the async op was dropped.
+    ///  Timestamp of when the async op was dropped.
     #[prost(message, optional, tag="2")]
     pub dropped_at: ::core::option::Option<::prost_types::Timestamp>,
-    /// The Id of the task that is awaiting on this op.
+    ///  The Id of the task that is awaiting on this op.
     #[prost(message, optional, tag="4")]
     pub task_id: ::core::option::Option<super::common::Id>,
-    /// Contains the operation poll stats.
+    ///  Contains the operation poll stats.
     #[prost(message, optional, tag="5")]
     pub poll_stats: ::core::option::Option<super::common::PollStats>,
-    /// State attributes of the async op.
+    ///  State attributes of the async op.
     #[prost(message, repeated, tag="6")]
     pub attributes: ::prost::alloc::vec::Vec<super::common::Attribute>,
 }