[INFO] cloning repository https://github.com/Rustixir/tokio_sky
[INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/Rustixir/tokio_sky" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2FRustixir%2Ftokio_sky", kill_on_drop: false }`
[INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2FRustixir%2Ftokio_sky'...
[INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }`
[INFO] [stdout] aa58347b963c17870c401c00d4a104c6b3bee6f6
[INFO] testing Rustixir/tokio_sky against 1.69.0 for beta-1.70-1
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2FRustixir%2Ftokio_sky" "/workspace/builds/worker-0-tc1/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-0-tc1/source'...
[INFO] [stderr] done.
[INFO] validating manifest of git repo https://github.com/Rustixir/tokio_sky on toolchain 1.69.0
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.69.0" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] started tweaking git repo https://github.com/Rustixir/tokio_sky
[INFO] finished tweaking git repo https://github.com/Rustixir/tokio_sky
[INFO] tweaked toml for git repo https://github.com/Rustixir/tokio_sky written to /workspace/builds/worker-0-tc1/source/Cargo.toml
[INFO] crate git repo https://github.com/Rustixir/tokio_sky already has a lockfile, it will not be regenerated
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.69.0" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded zstd-safe v4.1.3+zstd.1.5.1
[INFO] [stderr]   Downloaded zstd v0.9.2+zstd.1.5.1
[INFO] [stderr]   Downloaded pulsar v4.1.1
[INFO] [stderr]   Downloaded hashring v0.3.0
[INFO] [stderr]   Downloaded zstd-sys v1.6.2+zstd.1.5.1
[INFO] [stderr]   Downloaded rdkafka-sys v4.2.0+1.8.2
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:5ff2268d62e97bff2cde7d5815dd6ed5b47097566f13b8d0ca110b04b60e07ed" "/opt/rustwide/cargo-home/bin/cargo" "+1.69.0" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] c2c70b33913c61ea43775f88ff2a871c1d1a4070d81fe6166a5c17a7296518da
[INFO] running `Command { std: "docker" "start" "-a" "c2c70b33913c61ea43775f88ff2a871c1d1a4070d81fe6166a5c17a7296518da", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "c2c70b33913c61ea43775f88ff2a871c1d1a4070d81fe6166a5c17a7296518da", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "c2c70b33913c61ea43775f88ff2a871c1d1a4070d81fe6166a5c17a7296518da", kill_on_drop: false }`
[INFO] [stdout] c2c70b33913c61ea43775f88ff2a871c1d1a4070d81fe6166a5c17a7296518da
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:5ff2268d62e97bff2cde7d5815dd6ed5b47097566f13b8d0ca110b04b60e07ed" "/opt/rustwide/cargo-home/bin/cargo" "+1.69.0" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] ba864fd7cd37fd85e25779983e8984d3221d730476bc78a6d544bf1e4cc5e63b
[INFO] running `Command { std: "docker" "start" "-a" "ba864fd7cd37fd85e25779983e8984d3221d730476bc78a6d544bf1e4cc5e63b", kill_on_drop: false }`
[INFO] [stderr]    Compiling proc-macro2 v1.0.37
[INFO] [stderr]    Compiling unicode-xid v0.2.3
[INFO] [stderr]    Compiling syn v1.0.92
[INFO] [stderr]    Compiling libc v0.2.125
[INFO] [stderr]    Compiling async-trait v0.1.53
[INFO] [stderr]    Compiling hashbrown v0.11.2
[INFO] [stderr]    Compiling siphasher v0.3.10
[INFO] [stderr]    Compiling indexmap v1.8.1
[INFO] [stderr]    Compiling once_cell v1.10.0
[INFO] [stderr]    Compiling pin-project-lite v0.2.9
[INFO] [stderr]    Compiling hashring v0.3.0
[INFO] [stderr]    Compiling quote v1.0.18
[INFO] [stderr]    Compiling num_cpus v1.13.1
[INFO] [stderr]    Compiling tokio-macros v1.7.0
[INFO] [stderr]    Compiling tokio v1.18.1
[INFO] [stderr]    Compiling tokio_sky v1.0.0 (/opt/rustwide/workdir)
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/producer.rs:42:12
[INFO] [stdout]    |
[INFO] [stdout] 42 | pub struct Context<T, Prod> 
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/producer.rs:57:12
[INFO] [stdout]    |
[INFO] [stdout] 57 |     pub fn new(dispatcher: Dispatcher<T>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `run` is never used
[INFO] [stdout]   --> src/producer.rs:78:12
[INFO] [stdout]    |
[INFO] [stdout] 78 |     pub fn run(mut self) {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/batcher.rs:29:12
[INFO] [stdout]    |
[INFO] [stdout] 29 | pub struct Context<Input, Proc>
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/batcher.rs:48:12
[INFO] [stdout]    |
[INFO] [stdout] 48 |     pub fn new(recv: mpsc::Receiver<Input>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `run` is never used
[INFO] [stdout]   --> src/batcher.rs:64:12
[INFO] [stdout]    |
[INFO] [stdout] 64 |     pub fn run(mut self) {        
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/processor.rs:39:12
[INFO] [stdout]    |
[INFO] [stdout] 39 | pub struct Context<Input, Output, Proc>
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/processor.rs:56:12
[INFO] [stdout]    |
[INFO] [stdout] 56 |     pub fn new(recv: mpsc::Receiver<Input>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `run` is never used
[INFO] [stdout]   --> src/processor.rs:69:12
[INFO] [stdout]    |
[INFO] [stdout] 69 |     pub fn run(mut self) {        
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_shutdown_manager` is never used
[INFO] [stdout]  --> src/shutdown_manager.rs:5:8
[INFO] [stdout]   |
[INFO] [stdout] 5 | pub fn start_shutdown_manager(shutdown_recv: oneshot::Receiver<()>, list_shutdown: Vec<oneshot::Sender<()>>) {
[INFO] [stdout]   |        ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `PRODUCER_FILLBUFFER_TIMEOUT_REALTIME` is never used
[INFO] [stdout]   --> src/topology.rs:14:11
[INFO] [stdout]    |
[INFO] [stdout] 14 | pub const PRODUCER_FILLBUFFER_TIMEOUT_REALTIME: Duration = Duration::from_millis(2);
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `PRODUCER_FILLBUFFER_TIMEOUT_BATCH` is never used
[INFO] [stdout]   --> src/topology.rs:15:11
[INFO] [stdout]    |
[INFO] [stdout] 15 | pub const PRODUCER_FILLBUFFER_TIMEOUT_BATCH: Duration = Duration::from_millis(50);
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BATCH_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:17:11
[INFO] [stdout]    |
[INFO] [stdout] 17 | pub const BATCH_SIZE: usize = 100;
[INFO] [stdout]    |           ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BATCH_TIMEOUT` is never used
[INFO] [stdout]   --> src/topology.rs:18:11
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub const BATCH_TIMEOUT: Duration = Duration::from_millis(50);
[INFO] [stdout]    |           ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `CONCURRENCY` is never used
[INFO] [stdout]   --> src/topology.rs:19:11
[INFO] [stdout]    |
[INFO] [stdout] 19 | pub const CONCURRENCY: i32 = 1;
[INFO] [stdout]    |           ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BUFFER_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:20:11
[INFO] [stdout]    |
[INFO] [stdout] 20 | pub const BUFFER_SIZE: usize = 10;
[INFO] [stdout]    |           ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BUFFER_POOL_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:21:11
[INFO] [stdout]    |
[INFO] [stdout] 21 | pub const BUFFER_POOL_SIZE: usize = 100;
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `ProcessingType` is never used
[INFO] [stdout]   --> src/topology.rs:39:10
[INFO] [stdout]    |
[INFO] [stdout] 39 | pub enum ProcessingType {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_producer` is never used
[INFO] [stdout]   --> src/topology.rs:48:4
[INFO] [stdout]    |
[INFO] [stdout] 48 | fn start_producer<T, Prod, F> (producer_factory: F,
[INFO] [stdout]    |    ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Config` is never constructed
[INFO] [stdout]   --> src/topology.rs:98:12
[INFO] [stdout]    |
[INFO] [stdout] 98 | pub struct Config<Output> {
[INFO] [stdout]    |            ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_processor` is never used
[INFO] [stdout]    --> src/topology.rs:104:4
[INFO] [stdout]     |
[INFO] [stdout] 104 | fn start_processor<Input, Output, Proc, F> (processor_factory: F,
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_batch_processor` is never used
[INFO] [stdout]    --> src/topology.rs:152:4
[INFO] [stdout]     |
[INFO] [stdout] 152 | fn start_batch_processor<Input, Proc, F> (batcher_factory: F,
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_1` is never used
[INFO] [stdout]    --> src/topology.rs:215:8
[INFO] [stdout]     |
[INFO] [stdout] 215 | pub fn run_topology_1<Prod, ProdFactory, Input, Output, Proc, ProcFactory>
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_2` is never used
[INFO] [stdout]    --> src/topology.rs:261:8
[INFO] [stdout]     |
[INFO] [stdout] 261 | pub fn run_topology_2<Prod, ProdFactory, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_3` is never used
[INFO] [stdout]    --> src/topology.rs:332:8
[INFO] [stdout]     |
[INFO] [stdout] 332 | pub fn run_topology_3<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_4` is never used
[INFO] [stdout]    --> src/topology.rs:421:8
[INFO] [stdout]     |
[INFO] [stdout] 421 | pub fn run_topology_4<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_5` is never used
[INFO] [stdout]    --> src/topology.rs:530:8
[INFO] [stdout]     |
[INFO] [stdout] 530 | pub fn run_topology_5<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_1_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:663:8
[INFO] [stdout]     |
[INFO] [stdout] 663 | pub fn run_topology_1_with_batcher<Prod, ProdFactory, Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_2_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:735:8
[INFO] [stdout]     |
[INFO] [stdout] 735 | pub fn run_topology_2_with_batcher<Prod, ProdFactory, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_3_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:825:8
[INFO] [stdout]     |
[INFO] [stdout] 825 | pub fn run_topology_3_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_4_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:934:8
[INFO] [stdout]     |
[INFO] [stdout] 934 | pub fn run_topology_4_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_5_with_batcher` is never used
[INFO] [stdout]     --> src/topology.rs:1062:8
[INFO] [stdout]      |
[INFO] [stdout] 1062 | pub fn run_topology_5_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]      |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type alias `StageName` is never used
[INFO] [stdout]  --> src/dispatcher.rs:9:10
[INFO] [stdout]   |
[INFO] [stdout] 9 | pub type StageName = String;
[INFO] [stdout]   |          ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `InternalDispatchError` is never used
[INFO] [stdout]   --> src/dispatcher.rs:22:6
[INFO] [stdout]    |
[INFO] [stdout] 22 | enum InternalDispatchError<T> {
[INFO] [stdout]    |      ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `DispatchError` is never used
[INFO] [stdout]   --> src/dispatcher.rs:34:10
[INFO] [stdout]    |
[INFO] [stdout] 34 | pub enum DispatchError<T> {
[INFO] [stdout]    |          ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `SendersRepetive` is never constructed
[INFO] [stdout]   --> src/dispatcher.rs:52:5
[INFO] [stdout]    |
[INFO] [stdout] 51 | pub enum StatusResult {
[INFO] [stdout]    |          ------------ variant in this enum
[INFO] [stdout] 52 |     SendersRepetive
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `StatusResult` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Dispatcher` is never constructed
[INFO] [stdout]   --> src/dispatcher.rs:56:12
[INFO] [stdout]    |
[INFO] [stdout] 56 | pub struct Dispatcher<T> {
[INFO] [stdout]    |            ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/dispatcher.rs:69:12
[INFO] [stdout]    |
[INFO] [stdout] 69 |     pub fn new(channels: IndexMap<StageName, mpsc::Sender<T>>, 
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `dispatch` is never used
[INFO] [stdout]    --> src/dispatcher.rs:104:18
[INFO] [stdout]     |
[INFO] [stdout] 104 |     pub async fn dispatch(&mut self, msg: T, batch_key: Option<String>) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |                  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `partition` is never used
[INFO] [stdout]    --> src/dispatcher.rs:179:14
[INFO] [stdout]     |
[INFO] [stdout] 179 |     async fn partition(&mut self, msg: T, batch_key: String) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `broadcast` is never used
[INFO] [stdout]    --> src/dispatcher.rs:218:14
[INFO] [stdout]     |
[INFO] [stdout] 218 |     async fn broadcast(&mut self, msg: T) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `roundrobin` is never used
[INFO] [stdout]    --> src/dispatcher.rs:270:14
[INFO] [stdout]     |
[INFO] [stdout] 270 |     async fn roundrobin(&mut self, mut msg: T) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `logic_roundrobin` is never used
[INFO] [stdout]    --> src/dispatcher.rs:319:14
[INFO] [stdout]     |
[INFO] [stdout] 319 |     async fn logic_roundrobin(&mut self, mut msg: T) -> Result<(), InternalDispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `next_index` is never used
[INFO] [stdout]    --> src/dispatcher.rs:368:8
[INFO] [stdout]     |
[INFO] [stdout] 368 |     fn next_index(&mut self) -> usize {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `list_check` is never used
[INFO] [stdout]    --> src/dispatcher.rs:383:8
[INFO] [stdout]     |
[INFO] [stdout] 383 |     fn list_check(channels: &IndexMap<StageName, mpsc::Sender<T>>) -> Result<(), ()> {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 45 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished dev [unoptimized + debuginfo] target(s) in 8.00s
[INFO] running `Command { std: "docker" "inspect" "ba864fd7cd37fd85e25779983e8984d3221d730476bc78a6d544bf1e4cc5e63b", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "ba864fd7cd37fd85e25779983e8984d3221d730476bc78a6d544bf1e4cc5e63b", kill_on_drop: false }`
[INFO] [stdout] ba864fd7cd37fd85e25779983e8984d3221d730476bc78a6d544bf1e4cc5e63b
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:5ff2268d62e97bff2cde7d5815dd6ed5b47097566f13b8d0ca110b04b60e07ed" "/opt/rustwide/cargo-home/bin/cargo" "+1.69.0" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 6f02b5701b244f388b3842cbe943d6dbd8be49c2b786985752bdaee0108ba744
[INFO] running `Command { std: "docker" "start" "-a" "6f02b5701b244f388b3842cbe943d6dbd8be49c2b786985752bdaee0108ba744", kill_on_drop: false }`
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/producer.rs:42:12
[INFO] [stdout]    |
[INFO] [stdout] 42 | pub struct Context<T, Prod> 
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/producer.rs:57:12
[INFO] [stdout]    |
[INFO] [stdout] 57 |     pub fn new(dispatcher: Dispatcher<T>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `run` is never used
[INFO] [stdout]   --> src/producer.rs:78:12
[INFO] [stdout]    |
[INFO] [stdout] 78 |     pub fn run(mut self) {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/batcher.rs:29:12
[INFO] [stdout]    |
[INFO] [stdout] 29 | pub struct Context<Input, Proc>
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/batcher.rs:48:12
[INFO] [stdout]    |
[INFO] [stdout] 48 |     pub fn new(recv: mpsc::Receiver<Input>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `run` is never used
[INFO] [stdout]   --> src/batcher.rs:64:12
[INFO] [stdout]    |
[INFO] [stdout] 64 |     pub fn run(mut self) {        
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/processor.rs:39:12
[INFO] [stdout]    |
[INFO] [stdout] 39 | pub struct Context<Input, Output, Proc>
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/processor.rs:56:12
[INFO] [stdout]    |
[INFO] [stdout] 56 |     pub fn new(recv: mpsc::Receiver<Input>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `run` is never used
[INFO] [stdout]   --> src/processor.rs:69:12
[INFO] [stdout]    |
[INFO] [stdout] 69 |     pub fn run(mut self) {        
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_shutdown_manager` is never used
[INFO] [stdout]  --> src/shutdown_manager.rs:5:8
[INFO] [stdout]   |
[INFO] [stdout] 5 | pub fn start_shutdown_manager(shutdown_recv: oneshot::Receiver<()>, list_shutdown: Vec<oneshot::Sender<()>>) {
[INFO] [stdout]   |        ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `PRODUCER_FILLBUFFER_TIMEOUT_REALTIME` is never used
[INFO] [stdout]   --> src/topology.rs:14:11
[INFO] [stdout]    |
[INFO] [stdout] 14 | pub const PRODUCER_FILLBUFFER_TIMEOUT_REALTIME: Duration = Duration::from_millis(2);
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `PRODUCER_FILLBUFFER_TIMEOUT_BATCH` is never used
[INFO] [stdout]   --> src/topology.rs:15:11
[INFO] [stdout]    |
[INFO] [stdout] 15 | pub const PRODUCER_FILLBUFFER_TIMEOUT_BATCH: Duration = Duration::from_millis(50);
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BATCH_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:17:11
[INFO] [stdout]    |
[INFO] [stdout] 17 | pub const BATCH_SIZE: usize = 100;
[INFO] [stdout]    |           ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BATCH_TIMEOUT` is never used
[INFO] [stdout]   --> src/topology.rs:18:11
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub const BATCH_TIMEOUT: Duration = Duration::from_millis(50);
[INFO] [stdout]    |           ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `CONCURRENCY` is never used
[INFO] [stdout]   --> src/topology.rs:19:11
[INFO] [stdout]    |
[INFO] [stdout] 19 | pub const CONCURRENCY: i32 = 1;
[INFO] [stdout]    |           ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BUFFER_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:20:11
[INFO] [stdout]    |
[INFO] [stdout] 20 | pub const BUFFER_SIZE: usize = 10;
[INFO] [stdout]    |           ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BUFFER_POOL_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:21:11
[INFO] [stdout]    |
[INFO] [stdout] 21 | pub const BUFFER_POOL_SIZE: usize = 100;
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `ProcessingType` is never used
[INFO] [stdout]   --> src/topology.rs:39:10
[INFO] [stdout]    |
[INFO] [stdout] 39 | pub enum ProcessingType {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_producer` is never used
[INFO] [stdout]   --> src/topology.rs:48:4
[INFO] [stdout]    |
[INFO] [stdout] 48 | fn start_producer<T, Prod, F> (producer_factory: F,
[INFO] [stdout]    |    ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Config` is never constructed
[INFO] [stdout]   --> src/topology.rs:98:12
[INFO] [stdout]    |
[INFO] [stdout] 98 | pub struct Config<Output> {
[INFO] [stdout]    |            ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_processor` is never used
[INFO] [stdout]    --> src/topology.rs:104:4
[INFO] [stdout]     |
[INFO] [stdout] 104 | fn start_processor<Input, Output, Proc, F> (processor_factory: F,
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_batch_processor` is never used
[INFO] [stdout]    --> src/topology.rs:152:4
[INFO] [stdout]     |
[INFO] [stdout] 152 | fn start_batch_processor<Input, Proc, F> (batcher_factory: F,
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_1` is never used
[INFO] [stdout]    --> src/topology.rs:215:8
[INFO] [stdout]     |
[INFO] [stdout] 215 | pub fn run_topology_1<Prod, ProdFactory, Input, Output, Proc, ProcFactory>
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_2` is never used
[INFO] [stdout]    --> src/topology.rs:261:8
[INFO] [stdout]     |
[INFO] [stdout] 261 | pub fn run_topology_2<Prod, ProdFactory, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_3` is never used
[INFO] [stdout]    --> src/topology.rs:332:8
[INFO] [stdout]     |
[INFO] [stdout] 332 | pub fn run_topology_3<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_4` is never used
[INFO] [stdout]    --> src/topology.rs:421:8
[INFO] [stdout]     |
[INFO] [stdout] 421 | pub fn run_topology_4<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_5` is never used
[INFO] [stdout]    --> src/topology.rs:530:8
[INFO] [stdout]     |
[INFO] [stdout] 530 | pub fn run_topology_5<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_1_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:663:8
[INFO] [stdout]     |
[INFO] [stdout] 663 | pub fn run_topology_1_with_batcher<Prod, ProdFactory, Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_2_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:735:8
[INFO] [stdout]     |
[INFO] [stdout] 735 | pub fn run_topology_2_with_batcher<Prod, ProdFactory, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_3_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:825:8
[INFO] [stdout]     |
[INFO] [stdout] 825 | pub fn run_topology_3_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_4_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:934:8
[INFO] [stdout]     |
[INFO] [stdout] 934 | pub fn run_topology_4_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_5_with_batcher` is never used
[INFO] [stdout]     --> src/topology.rs:1062:8
[INFO] [stdout]      |
[INFO] [stdout] 1062 | pub fn run_topology_5_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]      |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type alias `StageName` is never used
[INFO] [stdout]  --> src/dispatcher.rs:9:10
[INFO] [stdout]   |
[INFO] [stdout] 9 | pub type StageName = String;
[INFO] [stdout]   |          ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `InternalDispatchError` is never used
[INFO] [stdout]   --> src/dispatcher.rs:22:6
[INFO] [stdout]    |
[INFO] [stdout] 22 | enum InternalDispatchError<T> {
[INFO] [stdout]    |      ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `DispatchError` is never used
[INFO] [stdout]   --> src/dispatcher.rs:34:10
[INFO] [stdout]    |
[INFO] [stdout] 34 | pub enum DispatchError<T> {
[INFO] [stdout]    |          ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `SendersRepetive` is never constructed
[INFO] [stdout]   --> src/dispatcher.rs:52:5
[INFO] [stdout]    |
[INFO] [stdout] 51 | pub enum StatusResult {
[INFO] [stdout]    |          ------------ variant in this enum
[INFO] [stdout] 52 |     SendersRepetive
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `StatusResult` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Dispatcher` is never constructed
[INFO] [stdout]   --> src/dispatcher.rs:56:12
[INFO] [stdout]    |
[INFO] [stdout] 56 | pub struct Dispatcher<T> {
[INFO] [stdout]    |            ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/dispatcher.rs:69:12
[INFO] [stdout]    |
[INFO] [stdout] 69 |     pub fn new(channels: IndexMap<StageName, mpsc::Sender<T>>, 
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `dispatch` is never used
[INFO] [stdout]    --> src/dispatcher.rs:104:18
[INFO] [stdout]     |
[INFO] [stdout] 104 |     pub async fn dispatch(&mut self, msg: T, batch_key: Option<String>) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |                  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `partition` is never used
[INFO] [stdout]    --> src/dispatcher.rs:179:14
[INFO] [stdout]     |
[INFO] [stdout] 179 |     async fn partition(&mut self, msg: T, batch_key: String) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `broadcast` is never used
[INFO] [stdout]    --> src/dispatcher.rs:218:14
[INFO] [stdout]     |
[INFO] [stdout] 218 |     async fn broadcast(&mut self, msg: T) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]    Compiling tokio_sky v1.0.0 (/opt/rustwide/workdir)
[INFO] [stdout] warning: method `roundrobin` is never used
[INFO] [stdout]    --> src/dispatcher.rs:270:14
[INFO] [stdout]     |
[INFO] [stdout] 270 |     async fn roundrobin(&mut self, mut msg: T) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `logic_roundrobin` is never used
[INFO] [stdout]    --> src/dispatcher.rs:319:14
[INFO] [stdout]     |
[INFO] [stdout] 319 |     async fn logic_roundrobin(&mut self, mut msg: T) -> Result<(), InternalDispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `next_index` is never used
[INFO] [stdout]    --> src/dispatcher.rs:368:8
[INFO] [stdout]     |
[INFO] [stdout] 368 |     fn next_index(&mut self) -> usize {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `list_check` is never used
[INFO] [stdout]    --> src/dispatcher.rs:383:8
[INFO] [stdout]     |
[INFO] [stdout] 383 |     fn list_check(channels: &IndexMap<StageName, mpsc::Sender<T>>) -> Result<(), ()> {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 45 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:73:3
[INFO] [stdout]    |
[INFO] [stdout] 73 | #[async_trait]
[INFO] [stdout]    |   ^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider importing one of these items:
[INFO] [stdout]            async_trait::async_trait
[INFO] [stdout]            tokio_sky::async_trait
[INFO] [stdout]    = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:100:3
[INFO] [stdout]     |
[INFO] [stdout] 100 | #[async_trait]
[INFO] [stdout]     |   ^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider importing one of these items:
[INFO] [stdout]             async_trait::async_trait
[INFO] [stdout]             tokio_sky::async_trait
[INFO] [stdout]     = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `tokio_sky::builtin::pulsar_processor`
[INFO] [stdout]  --> examples/pulsar_batcher.rs:2:25
[INFO] [stdout]   |
[INFO] [stdout] 2 | use tokio_sky::builtin::pulsar_processor::PulsarProcessor;
[INFO] [stdout]   |                         ^^^^^^^^^^^^^^^^ could not find `pulsar_processor` in `builtin`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:127:3
[INFO] [stdout]     |
[INFO] [stdout] 127 | #[async_trait]
[INFO] [stdout]     |   ^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider importing one of these items:
[INFO] [stdout]             async_trait::async_trait
[INFO] [stdout]             tokio_sky::async_trait
[INFO] [stdout]     = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `pulsar`
[INFO] [stdout]  --> examples/pulsar_batcher.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use pulsar::ProducerOptions;
[INFO] [stdout]   |     ^^^^^^ use of undeclared crate or module `pulsar`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find macro `params` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:143:43
[INFO] [stdout]     |
[INFO] [stdout] 143 |             .with(batch.iter().map(|user| params! {
[INFO] [stdout]     |                                           ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: expected type, found `}`
[INFO] [stdout]    --> examples/kafka_processor_complex.rs:103:1
[INFO] [stdout]     |
[INFO] [stdout] 101 | struct DeliveryHandler {
[INFO] [stdout]     |        --------------- while parsing this struct
[INFO] [stdout] 102 |     deadletter_destination: /* .... */
[INFO] [stdout] 103 | }
[INFO] [stdout]     | ^ expected type
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]  --> examples/batch_insert_mysql.rs:9:27
[INFO] [stdout]   |
[INFO] [stdout] 9 |     let producer_router = RouterType::RoundRobin;
[INFO] [stdout]   |                           ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:15:23
[INFO] [stdout]    |
[INFO] [stdout] 15 |     let proc_router = RouterType::Partition;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `mysql_async`
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:21:16
[INFO] [stdout]    |
[INFO] [stdout] 21 |     let pool = mysql_async::Pool::new(database_url);
[INFO] [stdout]    |                ^^^^^^^^^^^ use of undeclared crate or module `mysql_async`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `tokio_sky::builtin::kafka_processor`
[INFO] [stdout]  --> examples/pulsar_processor_complex.rs:2:25
[INFO] [stdout]   |
[INFO] [stdout] 2 | use tokio_sky::builtin::kafka_processor::KafkaProcessor;
[INFO] [stdout]   |                         ^^^^^^^^^^^^^^^ could not find `kafka_processor` in `builtin`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `pulsar`
[INFO] [stdout]  --> examples/pulsar_processor_complex.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use pulsar::Error;
[INFO] [stdout]   |     ^^^^^^ use of undeclared crate or module `pulsar`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `BATCH_TIMEOUT` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:28:32
[INFO] [stdout]    |
[INFO] [stdout] 28 |     let batcher_batch_timeout: BATCH_TIMEOUT;
[INFO] [stdout]    |                                ^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Producer` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:74:6
[INFO] [stdout]    |
[INFO] [stdout] 74 | impl Producer<User> for Prod {
[INFO] [stdout]    |      ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]    |
[INFO] [stdout] 1  | use tokio_sky::Producer;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:80:40
[INFO] [stdout]    |
[INFO] [stdout] 80 |     async fn drain(&mut self, _buffer: VecDeque<User>) {}
[INFO] [stdout]    |                                        ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 1  | use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:82:67
[INFO] [stdout]    |
[INFO] [stdout] 82 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<User>, Terminate> {
[INFO] [stdout]    |                                                                   ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 1  | use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Terminate` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:82:83
[INFO] [stdout]    |
[INFO] [stdout] 82 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<User>, Terminate> {
[INFO] [stdout]    |                                                                                   ^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 74 | impl<Terminate> Producer<User> for Prod {
[INFO] [stdout]    |     +++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:92:24
[INFO] [stdout]    |
[INFO] [stdout] 92 |             .collect::<VecDeque<User>>())
[INFO] [stdout]    |                        ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 1  | use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Processor` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:101:6
[INFO] [stdout]     |
[INFO] [stdout] 101 | impl Processor<User, User> for Layer1Process {
[INFO] [stdout]     |      ^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]     |
[INFO] [stdout] 1   | use tokio_sky::Processor;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find derive macro `Serialize` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:79:10
[INFO] [stdout]    |
[INFO] [stdout] 79 | #[derive(Serialize, Deserialize)]
[INFO] [stdout]    |          ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcResult` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:105:55
[INFO] [stdout]     |
[INFO] [stdout] 105 |     async fn handle_message(&mut self, msg: User) ->  ProcResult<User> {
[INFO] [stdout]     |                                                       ^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 1   | use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find derive macro `Deserialize` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:79:21
[INFO] [stdout]    |
[INFO] [stdout] 79 | #[derive(Serialize, Deserialize)]
[INFO] [stdout]    |                     ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `ProcResult`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:111:9
[INFO] [stdout]     |
[INFO] [stdout] 111 |         ProcResult::Dispatch(msg, pk)
[INFO] [stdout]     |         ^^^^^^^^^^ use of undeclared type `ProcResult`
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 1   | use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Pool` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:118:11
[INFO] [stdout]     |
[INFO] [stdout] 118 |     pool: Pool
[INFO] [stdout]     |           ^^^^ help: a builtin type with a similar name exists: `bool`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Pool` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:122:22
[INFO] [stdout]     |
[INFO] [stdout] 122 |     pub fn new(pool: Pool) -> MysqlBatcher {
[INFO] [stdout]     |                      ^^^^ help: a builtin type with a similar name exists: `bool`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `BatcherTerminate` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:137:70
[INFO] [stdout]     |
[INFO] [stdout] 137 |     async fn handle_batch(&mut self, batch: Vec<User>) -> Result<(), BatcherTerminate<User>> {
[INFO] [stdout]     |                                                                      ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 1   | use tokio_sky::BatcherTerminate;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:82:3
[INFO] [stdout]    |
[INFO] [stdout] 82 | #[async_trait]
[INFO] [stdout]    |   ^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider importing one of these items:
[INFO] [stdout]            async_trait::async_trait
[INFO] [stdout]            tokio_sky::async_trait
[INFO] [stdout]    = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:97:3
[INFO] [stdout]    |
[INFO] [stdout] 97 | #[async_trait]
[INFO] [stdout]    |   ^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider importing one of these items:
[INFO] [stdout]            async_trait::async_trait
[INFO] [stdout]            tokio_sky::async_trait
[INFO] [stdout]    = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `pool` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:139:20
[INFO] [stdout]     |
[INFO] [stdout] 139 |         let conn = pool.get_conn().await.unwrap();
[INFO] [stdout]     |                    ^^^^ help: you might have meant to use the available field: `self.pool`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Strnig` in this scope
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:157:15
[INFO] [stdout]     |
[INFO] [stdout] 157 |     fullname: Strnig
[INFO] [stdout]     |               ^^^^^^ help: a struct with a similar name exists: `String`
[INFO] [stdout]    --> /rustc/84c898d65adf2f39a5a98507f1fe0ce10a2b8dbc/library/alloc/src/string.rs:365:1
[INFO] [stdout]     |
[INFO] [stdout]     = note: similarly named struct `String` defined here
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]    --> examples/pulsar_batcher.rs:123:3
[INFO] [stdout]     |
[INFO] [stdout] 123 | #[async_trait]
[INFO] [stdout]     |   ^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider importing one of these items:
[INFO] [stdout]             async_trait::async_trait
[INFO] [stdout]             tokio_sky::async_trait
[INFO] [stdout]     = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:10:27
[INFO] [stdout]    |
[INFO] [stdout] 10 |     let producer_router = RouterType::RoundRobin;
[INFO] [stdout]    |                           ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:16:24
[INFO] [stdout]    |
[INFO] [stdout] 16 |     let proc1_router = RouterType::RoundRobin;
[INFO] [stdout]    |                        ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]    --> examples/pulsar_processor_complex.rs:112:3
[INFO] [stdout]     |
[INFO] [stdout] 112 | #[async_trait]
[INFO] [stdout]     |   ^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider importing one of these items:
[INFO] [stdout]             async_trait::async_trait
[INFO] [stdout]             tokio_sky::async_trait
[INFO] [stdout]     = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:10:27
[INFO] [stdout]    |
[INFO] [stdout] 10 |     let producer_router = RouterType::RoundRobin;
[INFO] [stdout]    |                           ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `tokio_sky::builtin::kafka_processor`
[INFO] [stdout]  --> examples/kafka_processor_complex.rs:1:25
[INFO] [stdout]   |
[INFO] [stdout] 1 | use tokio_sky::builtin::kafka_processor::KafkaProcessor;
[INFO] [stdout]   |                         ^^^^^^^^^^^^^^^ could not find `kafka_processor` in `builtin`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `producer`
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:20:16
[INFO] [stdout]    |
[INFO] [stdout] 20 |     let opts = producer::ProducerOptions {
[INFO] [stdout]    |                ^^^^^^^^ use of undeclared crate or module `producer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `proto`
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:21:22
[INFO] [stdout]    |
[INFO] [stdout] 21 |         schema: Some(proto::Schema {
[INFO] [stdout]    |                      ^^^^^ use of undeclared crate or module `proto`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `proto`
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:22:21
[INFO] [stdout]    |
[INFO] [stdout] 22 |             r#type: proto::schema::Type::String as i32,
[INFO] [stdout]    |                     ^^^^^ use of undeclared crate or module `proto`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:31:30
[INFO] [stdout]    |
[INFO] [stdout] 31 |     let pulsar_proc_router = RouterType::RoundRobin;
[INFO] [stdout]    |                              ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:76:5
[INFO] [stdout]    |
[INFO] [stdout] 76 |     async fn init(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:78:5
[INFO] [stdout]    |
[INFO] [stdout] 78 |     async fn terminate(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:80:5
[INFO] [stdout]    |
[INFO] [stdout] 80 |     async fn drain(&mut self, _buffer: VecDeque<User>) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: invalid character `'('` in crate name: `complex(2 layer)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: invalid character `' '` in crate name: `complex(2 layer)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: invalid character `')'` in crate name: `complex(2 layer)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:82:5
[INFO] [stdout]    |
[INFO] [stdout] 82 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<User>, Terminate> {
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:102:5
[INFO] [stdout]     |
[INFO] [stdout] 102 |     async fn init(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `proto`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:28:22
[INFO] [stdout]    |
[INFO] [stdout] 28 |         schema: Some(proto::Schema {
[INFO] [stdout]    |                      ^^^^^ use of undeclared crate or module `proto`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:103:5
[INFO] [stdout]     |
[INFO] [stdout] 103 |     async fn terminate(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `proto`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:29:21
[INFO] [stdout]    |
[INFO] [stdout] 29 |             r#type: proto::schema::Type::String as i32,
[INFO] [stdout]    |                     ^^^^^ use of undeclared crate or module `proto`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:105:5
[INFO] [stdout]     |
[INFO] [stdout] 105 |     async fn handle_message(&mut self, msg: User) ->  ProcResult<User> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:130:5
[INFO] [stdout]     |
[INFO] [stdout] 130 |     async fn init(&mut self) { }
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 3 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:132:5
[INFO] [stdout]     |
[INFO] [stdout] 132 |     async fn terminate(&mut self) { }
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:134:5
[INFO] [stdout]     |
[INFO] [stdout] 134 |     async fn drain(&mut self, batch: Vec<User>) { }
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` due to 4 previous errors
[INFO] [stderr] warning: build failed, waiting for other jobs to finish...
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]   --> examples/kafka_processor.rs:62:3
[INFO] [stdout]    |
[INFO] [stdout] 62 | #[async_trait]
[INFO] [stdout]    |   ^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider importing one of these items:
[INFO] [stdout]            async_trait::async_trait
[INFO] [stdout]            tokio_sky::async_trait
[INFO] [stdout]    = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]  --> examples/kafka_processor.rs:7:27
[INFO] [stdout]   |
[INFO] [stdout] 7 |     let producer_router = RouterType::RoundRobin;
[INFO] [stdout]   |                           ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/batch_insert_mysql.rs:137:5
[INFO] [stdout]     |
[INFO] [stdout] 137 |     async fn handle_batch(&mut self, batch: Vec<User>) -> Result<(), BatcherTerminate<User>> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `producer`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:85:49
[INFO] [stdout]    |
[INFO] [stdout] 85 |     fn serialize_message(input: Self) -> Result<producer::Message, PulsarError> {
[INFO] [stdout]    |                                                 ^^^^^^^^ use of undeclared crate or module `producer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `ProcResult`
[INFO] [stdout]    --> examples/pulsar_processor_complex.rs:133:9
[INFO] [stdout]     |
[INFO] [stdout] 133 |         ProcResult::Continue
[INFO] [stdout]     |         ^^^^^^^^^^ use of undeclared type `ProcResult`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Pulsar` in this scope
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:19:17
[INFO] [stdout]    |
[INFO] [stdout] 19 |     let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await.unwrap();
[INFO] [stdout]    |                 ^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `TokioExecutor` in this scope
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:19:51
[INFO] [stdout]    |
[INFO] [stdout] 19 |     let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await.unwrap();
[INFO] [stdout]    |                                                   ^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:72:3
[INFO] [stdout]    |
[INFO] [stdout] 72 | #[async_trait]
[INFO] [stdout]    |   ^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = help: consider importing one of these items:
[INFO] [stdout]            async_trait::async_trait
[INFO] [stdout]            tokio_sky::async_trait
[INFO] [stdout]    = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Producer` in this scope
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:83:6
[INFO] [stdout]    |
[INFO] [stdout] 83 | impl Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |      ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]    |
[INFO] [stdout] 1  | use tokio_sky::Producer;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcKafkaMessage` in this scope
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:83:15
[INFO] [stdout]    |
[INFO] [stdout] 83 | impl Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |               ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 83 | impl<ProcKafkaMessage> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |     ++++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: cannot find attribute `async_trait` in this scope
[INFO] [stdout]    --> examples/kafka_processor_complex.rs:105:3
[INFO] [stdout]     |
[INFO] [stdout] 105 | #[async_trait]
[INFO] [stdout]     |   ^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider importing one of these items:
[INFO] [stdout]             async_trait::async_trait
[INFO] [stdout]             tokio_sky::async_trait
[INFO] [stdout]     = note: `async_trait` is in scope, but it is a crate, not an attribute
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]  --> examples/kafka_processor_complex.rs:9:27
[INFO] [stdout]   |
[INFO] [stdout] 9 |     let producer_router = RouterType::RoundRobin;
[INFO] [stdout]   |                           ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RouterType`
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:21:29
[INFO] [stdout]    |
[INFO] [stdout] 21 |     let kafka_proc_router = RouterType::RoundRobin;
[INFO] [stdout]    |                             ^^^^^^^^^^ use of undeclared type `RouterType`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:89:40
[INFO] [stdout]    |
[INFO] [stdout] 89 |     async fn drain(&mut self, _buffer: VecDeque<ProcKafkaMessage>) {}
[INFO] [stdout]    |                                        ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 1  | use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcKafkaMessage` in this scope
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:89:49
[INFO] [stdout]    |
[INFO] [stdout] 89 |     async fn drain(&mut self, _buffer: VecDeque<ProcKafkaMessage>) {}
[INFO] [stdout]    |                                                 ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 83 | impl<ProcKafkaMessage> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |     ++++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:91:67
[INFO] [stdout]    |
[INFO] [stdout] 91 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<ProcKafkaMessage>, Terminate> {
[INFO] [stdout]    |                                                                   ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 1  | use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcKafkaMessage` in this scope
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:91:76
[INFO] [stdout]    |
[INFO] [stdout] 91 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<ProcKafkaMessage>, Terminate> {
[INFO] [stdout]    |                                                                            ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 83 | impl<ProcKafkaMessage> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |     ++++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Terminate` in this scope
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:91:95
[INFO] [stdout]    |
[INFO] [stdout] 91 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<ProcKafkaMessage>, Terminate> {
[INFO] [stdout]    |                                                                                               ^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 83 | impl<Terminate> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |     +++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0422]: cannot find struct, variant or union type `ProcKafkaMessage` in this scope
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:96:17
[INFO] [stdout]    |
[INFO] [stdout] 96 |                 ProcKafkaMessage {
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]    --> examples/pulsar_processor_complex.rs:103:24
[INFO] [stdout]     |
[INFO] [stdout] 103 |             .collect::<VecDeque<ProcKafkaMessage>>())
[INFO] [stdout]     |                        ^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 1   | use std::collections::VecDeque;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcKafkaMessage` in this scope
[INFO] [stdout]    --> examples/pulsar_processor_complex.rs:103:33
[INFO] [stdout]     |
[INFO] [stdout] 103 |             .collect::<VecDeque<ProcKafkaMessage>>())
[INFO] [stdout]     |                                 ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]     |
[INFO] [stdout] 83  | impl<ProcKafkaMessage> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]     |     ++++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `run_topology_1_with_batcher` in this scope
[INFO] [stdout]   --> examples/batch_insert_mysql.rs:40:17
[INFO] [stdout]    |
[INFO] [stdout] 40 |                 run_topology_1_with_batcher(
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 33 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0405, E0412, E0425, E0433, E0706.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0405`.
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `producer`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:87:12
[INFO] [stdout]    |
[INFO] [stdout] 87 |         Ok(producer::Message {
[INFO] [stdout]    |            ^^^^^^^^ use of undeclared crate or module `producer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Processor` in this scope
[INFO] [stdout]    --> examples/pulsar_processor_complex.rs:113:6
[INFO] [stdout]     |
[INFO] [stdout] 113 | impl Processor<DeliveryResult, ()> for Layer2Process {
[INFO] [stdout]     |      ^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]     |
[INFO] [stdout] 1   | use tokio_sky::Processor;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `DeliveryResult` in this scope
[INFO] [stdout]    --> examples/pulsar_processor_complex.rs:113:16
[INFO] [stdout]     |
[INFO] [stdout] 113 | impl Processor<DeliveryResult, ()> for Layer2Process {
[INFO] [stdout]     |                ^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]     |
[INFO] [stdout] 113 | impl<DeliveryResult> Processor<DeliveryResult, ()> for Layer2Process {
[INFO] [stdout]     |     ++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Layer2Process` in this scope
[INFO] [stdout]    --> examples/pulsar_processor_complex.rs:113:40
[INFO] [stdout]     |
[INFO] [stdout] 113 | impl Processor<DeliveryResult, ()> for Layer2Process {
[INFO] [stdout]     |                                        ^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `DeliveryResult` in this scope
[INFO] [stdout]    --> examples/pulsar_processor_complex.rs:117:45
[INFO] [stdout]     |
[INFO] [stdout] 117 |     async fn handle_message(&mut self, msg: DeliveryResult) ->  ProcResult<()> {
[INFO] [stdout]     |                                             ^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcResult` in this scope
[INFO] [stdout]    --> examples/pulsar_processor_complex.rs:117:65
[INFO] [stdout]     |
[INFO] [stdout] 117 |     async fn handle_message(&mut self, msg: DeliveryResult) ->  ProcResult<()> {
[INFO] [stdout]     |                                                                 ^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 1   | use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` due to 34 previous errors
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:85:5
[INFO] [stdout]    |
[INFO] [stdout] 85 |     async fn init(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Producer` in this scope
[INFO] [stdout]   --> examples/kafka_processor.rs:63:6
[INFO] [stdout]    |
[INFO] [stdout] 63 | impl Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |      ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]    |
[INFO] [stdout] 2  | use tokio_sky::Producer;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcKafkaMessage` in this scope
[INFO] [stdout]   --> examples/kafka_processor.rs:63:15
[INFO] [stdout]    |
[INFO] [stdout] 63 | impl Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |               ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 63 | impl<ProcKafkaMessage> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |     ++++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/kafka_processor.rs:69:40
[INFO] [stdout]    |
[INFO] [stdout] 69 |     async fn drain(&mut self, _buffer: VecDeque<ProcKafkaMessage>) {}
[INFO] [stdout]    |                                        ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 2  | use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:87:5
[INFO] [stdout]    |
[INFO] [stdout] 87 |     async fn terminate(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:89:5
[INFO] [stdout]    |
[INFO] [stdout] 89 |     async fn drain(&mut self, _buffer: VecDeque<ProcKafkaMessage>) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:91:5
[INFO] [stdout]    |
[INFO] [stdout] 91 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<ProcKafkaMessage>, Terminate> {
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcKafkaMessage` in this scope
[INFO] [stdout]   --> examples/kafka_processor.rs:69:49
[INFO] [stdout]    |
[INFO] [stdout] 69 |     async fn drain(&mut self, _buffer: VecDeque<ProcKafkaMessage>) {}
[INFO] [stdout]    |                                                 ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 63 | impl<ProcKafkaMessage> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |     ++++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_processor_complex.rs:114:5
[INFO] [stdout]     |
[INFO] [stdout] 114 |     async fn init(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_processor_complex.rs:115:5
[INFO] [stdout]     |
[INFO] [stdout] 115 |     async fn terminate(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/kafka_processor.rs:71:67
[INFO] [stdout]    |
[INFO] [stdout] 71 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<ProcKafkaMessage>, Terminate> {
[INFO] [stdout]    |                                                                   ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 2  | use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_processor_complex.rs:117:5
[INFO] [stdout]     |
[INFO] [stdout] 117 |     async fn handle_message(&mut self, msg: DeliveryResult) ->  ProcResult<()> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcKafkaMessage` in this scope
[INFO] [stdout]   --> examples/kafka_processor.rs:71:76
[INFO] [stdout]    |
[INFO] [stdout] 71 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<ProcKafkaMessage>, Terminate> {
[INFO] [stdout]    |                                                                            ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 63 | impl<ProcKafkaMessage> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |     ++++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Pulsar` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:26:17
[INFO] [stdout]    |
[INFO] [stdout] 26 |     let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await.unwrap();
[INFO] [stdout]    |                 ^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `TokioExecutor` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:26:51
[INFO] [stdout]    |
[INFO] [stdout] 26 |     let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await.unwrap();
[INFO] [stdout]    |                                                   ^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `BATCH_TIMEOUT` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:40:32
[INFO] [stdout]    |
[INFO] [stdout] 40 |     let batcher_batch_timeout: BATCH_TIMEOUT;
[INFO] [stdout]    |                                ^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Terminate` in this scope
[INFO] [stdout]   --> examples/kafka_processor.rs:71:95
[INFO] [stdout]    |
[INFO] [stdout] 71 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<ProcKafkaMessage>, Terminate> {
[INFO] [stdout]    |                                                                                               ^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 63 | impl<Terminate> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |     +++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `proc_factory` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:57:20
[INFO] [stdout]    |
[INFO] [stdout] 57 |                    proc_factory,
[INFO] [stdout]    |                    ^^^^^^^^^^^^ help: a local variable with a similar name exists: `proc1_factory`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0422]: cannot find struct, variant or union type `ProcKafkaMessage` in this scope
[INFO] [stdout]   --> examples/kafka_processor.rs:76:17
[INFO] [stdout]    |
[INFO] [stdout] 76 |                 ProcKafkaMessage {
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `proc_concurrency` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:58:20
[INFO] [stdout]    |
[INFO] [stdout] 58 |                    proc_concurrency,
[INFO] [stdout]    |                    ^^^^^^^^^^^^^^^^ help: a local variable with a similar name exists: `proc1_concurrency`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Pulsar`
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:19:29
[INFO] [stdout]    |
[INFO] [stdout] 19 |     let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await.unwrap();
[INFO] [stdout]    |                             ^^^^^^ use of undeclared type `Pulsar`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `proc_router` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:59:20
[INFO] [stdout]    |
[INFO] [stdout] 59 |                    proc_router,
[INFO] [stdout]    |                    ^^^^^^^^^^^ help: a local variable with a similar name exists: `proc1_router`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `PulsarProcessor`
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:29:37
[INFO] [stdout]    |
[INFO] [stdout] 29 |     let pulsar_proc_factory = || || PulsarProcessor::new(pulsar, opts, topic, pulsar_instance_name).unwrap();
[INFO] [stdout]    |                                     ^^^^^^^^^^^^^^^ use of undeclared type `PulsarProcessor`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `run_topology_2` in this scope
[INFO] [stdout]   --> examples/pulsar_processor_complex.rs:57:17
[INFO] [stdout]    |
[INFO] [stdout] 57 |                 run_topology_2(
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 37 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0405, E0412, E0422, E0425, E0432, E0433, E0706.
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `proc_buffer_size` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:60:20
[INFO] [stdout]    |
[INFO] [stdout] 60 |                    proc_buffer_size,
[INFO] [stdout]    |                    ^^^^^^^^^^^^^^^^ help: a local variable with a similar name exists: `proc1_buffer_size`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0405`.
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/kafka_processor.rs:83:24
[INFO] [stdout]    |
[INFO] [stdout] 83 |             .collect::<VecDeque<ProcKafkaMessage>>())
[INFO] [stdout]    |                        ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 2  | use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `SerializeMessage` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:84:6
[INFO] [stdout]    |
[INFO] [stdout] 84 | impl SerializeMessage for Cat {
[INFO] [stdout]    |      ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `PulsarError` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:85:68
[INFO] [stdout]    |
[INFO] [stdout] 85 |     fn serialize_message(input: Self) -> Result<producer::Message, PulsarError> {
[INFO] [stdout]    |                                                                    ^^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 84 | impl<PulsarError> SerializeMessage for Cat {
[INFO] [stdout]    |     +++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Producer` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:98:6
[INFO] [stdout]    |
[INFO] [stdout] 98 | impl Producer<Cat> for Prod {
[INFO] [stdout]    |      ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]    |
[INFO] [stdout] 1  | use tokio_sky::Producer;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcKafkaMessage` in this scope
[INFO] [stdout]   --> examples/kafka_processor.rs:83:33
[INFO] [stdout]    |
[INFO] [stdout] 83 |             .collect::<VecDeque<ProcKafkaMessage>>())
[INFO] [stdout]    |                                 ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 63 | impl<ProcKafkaMessage> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |     ++++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]    --> examples/pulsar_batcher.rs:104:40
[INFO] [stdout]     |
[INFO] [stdout] 104 |     async fn drain(&mut self, _buffer: VecDeque<Cat>) {}
[INFO] [stdout]     |                                        ^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 1   | use std::collections::VecDeque;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]    --> examples/pulsar_batcher.rs:106:67
[INFO] [stdout]     |
[INFO] [stdout] 106 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<Cat>, Terminate> {
[INFO] [stdout]     |                                                                   ^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 1   | use std::collections::VecDeque;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Terminate` in this scope
[INFO] [stdout]    --> examples/pulsar_batcher.rs:106:82
[INFO] [stdout]     |
[INFO] [stdout] 106 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<Cat>, Terminate> {
[INFO] [stdout]     |                                                                                  ^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]     |
[INFO] [stdout] 98  | impl<Terminate> Producer<Cat> for Prod {
[INFO] [stdout]     |     +++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]    --> examples/pulsar_batcher.rs:115:24
[INFO] [stdout]     |
[INFO] [stdout] 115 |             .collect::<VecDeque<Cat>>())
[INFO] [stdout]     |                        ^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]     |
[INFO] [stdout] 1   | use std::collections::VecDeque;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Processor` in this scope
[INFO] [stdout]    --> examples/pulsar_batcher.rs:124:6
[INFO] [stdout]     |
[INFO] [stdout] 124 | impl Processor<Cat, Cat> for Layer1Process {
[INFO] [stdout]     |      ^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]     |
[INFO] [stdout] 1   | use tokio_sky::Processor;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcResult` in this scope
[INFO] [stdout]    --> examples/pulsar_batcher.rs:128:54
[INFO] [stdout]     |
[INFO] [stdout] 128 |     async fn handle_message(&mut self, msg: Cat) ->  ProcResult<Cat> {
[INFO] [stdout]     |                                                      ^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 1   | use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `ProcResult`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:131:9
[INFO] [stdout]     |
[INFO] [stdout] 131 |         ProcResult::Dispatch(msg,  None)
[INFO] [stdout]     |         ^^^^^^^^^^ use of undeclared type `ProcResult`
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 1   | use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` due to 38 previous errors
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:100:5
[INFO] [stdout]     |
[INFO] [stdout] 100 |     async fn init(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:102:5
[INFO] [stdout]     |
[INFO] [stdout] 102 |     async fn terminate(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `ProcResult`
[INFO] [stdout]    --> examples/kafka_processor_complex.rs:122:9
[INFO] [stdout]     |
[INFO] [stdout] 122 |         ProcResult::Continue
[INFO] [stdout]     |         ^^^^^^^^^^ use of undeclared type `ProcResult`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:104:5
[INFO] [stdout]     |
[INFO] [stdout] 104 |     async fn drain(&mut self, _buffer: VecDeque<Cat>) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0423]: expected value, found struct `DeliveryHandler`
[INFO] [stdout]    --> examples/kafka_processor_complex.rs:25:42
[INFO] [stdout]     |
[INFO] [stdout] 25  |       let result_handler_proc_factory = || DeliveryHandler;
[INFO] [stdout]     |                                            ^^^^^^^^^^^^^^^ help: use struct literal syntax instead: `DeliveryHandler {}`
[INFO] [stdout] ...
[INFO] [stdout] 101 | / struct DeliveryHandler {
[INFO] [stdout] 102 | |     deadletter_destination: /* .... */
[INFO] [stdout] 103 | | }
[INFO] [stdout]     | |_- `DeliveryHandler` defined here
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/kafka_processor.rs:65:5
[INFO] [stdout]    |
[INFO] [stdout] 65 |     async fn init(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:106:5
[INFO] [stdout]     |
[INFO] [stdout] 106 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<Cat>, Terminate> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/kafka_processor.rs:67:5
[INFO] [stdout]    |
[INFO] [stdout] 67 |     async fn terminate(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Producer` in this scope
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:73:6
[INFO] [stdout]    |
[INFO] [stdout] 73 | impl Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |      ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]    |
[INFO] [stdout] 1  | use tokio_sky::Producer;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/kafka_processor.rs:69:5
[INFO] [stdout]    |
[INFO] [stdout] 69 |     async fn drain(&mut self, _buffer: VecDeque<ProcKafkaMessage>) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:125:5
[INFO] [stdout]     |
[INFO] [stdout] 125 |     async fn init(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/kafka_processor.rs:71:5
[INFO] [stdout]    |
[INFO] [stdout] 71 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<ProcKafkaMessage>, Terminate> {
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcKafkaMessage` in this scope
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:73:15
[INFO] [stdout]    |
[INFO] [stdout] 73 | impl Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |               ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 73 | impl<ProcKafkaMessage> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |     ++++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:79:40
[INFO] [stdout]    |
[INFO] [stdout] 79 |     async fn drain(&mut self, _buffer: VecDeque<ProcKafkaMessage>) {}
[INFO] [stdout]    |                                        ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 1  | use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:126:5
[INFO] [stdout]     |
[INFO] [stdout] 126 |     async fn terminate(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcKafkaMessage` in this scope
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:79:49
[INFO] [stdout]    |
[INFO] [stdout] 79 |     async fn drain(&mut self, _buffer: VecDeque<ProcKafkaMessage>) {}
[INFO] [stdout]    |                                                 ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 73 | impl<ProcKafkaMessage> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |     ++++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:81:67
[INFO] [stdout]    |
[INFO] [stdout] 81 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<ProcKafkaMessage>, Terminate> {
[INFO] [stdout]    |                                                                   ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 1  | use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `KafkaProcessor`
[INFO] [stdout]   --> examples/kafka_processor.rs:17:12
[INFO] [stdout]    |
[INFO] [stdout] 17 |         || KafkaProcessor::new(brokers, 
[INFO] [stdout]    |            ^^^^^^^^^^^^^^ use of undeclared type `KafkaProcessor`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/pulsar_batcher.rs:128:5
[INFO] [stdout]     |
[INFO] [stdout] 128 |     async fn handle_message(&mut self, msg: Cat) ->  ProcResult<Cat> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `run_topology_1` in this scope
[INFO] [stdout]   --> examples/kafka_processor.rs:42:17
[INFO] [stdout]    |
[INFO] [stdout] 42 |                 run_topology_1(
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 18 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0405, E0412, E0422, E0425, E0433, E0706.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0405`.
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcKafkaMessage` in this scope
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:81:76
[INFO] [stdout]    |
[INFO] [stdout] 81 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<ProcKafkaMessage>, Terminate> {
[INFO] [stdout]    |                                                                            ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 73 | impl<ProcKafkaMessage> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |     ++++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Terminate` in this scope
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:81:95
[INFO] [stdout]    |
[INFO] [stdout] 81 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<ProcKafkaMessage>, Terminate> {
[INFO] [stdout]    |                                                                                               ^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 73 | impl<Terminate> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |     +++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0422]: cannot find struct, variant or union type `ProcKafkaMessage` in this scope
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:86:17
[INFO] [stdout]    |
[INFO] [stdout] 86 |                 ProcKafkaMessage {
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Pulsar`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:26:29
[INFO] [stdout]    |
[INFO] [stdout] 26 |     let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await.unwrap();
[INFO] [stdout]    |                             ^^^^^^ use of undeclared type `Pulsar`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `VecDeque` in this scope
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:93:24
[INFO] [stdout]    |
[INFO] [stdout] 93 |             .collect::<VecDeque<ProcKafkaMessage>>())
[INFO] [stdout]    |                        ^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 1  | use std::collections::VecDeque;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcKafkaMessage` in this scope
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:93:33
[INFO] [stdout]    |
[INFO] [stdout] 93 |             .collect::<VecDeque<ProcKafkaMessage>>())
[INFO] [stdout]    |                                 ^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]    |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]    |
[INFO] [stdout] 73 | impl<ProcKafkaMessage> Producer<ProcKafkaMessage> for Prod {
[INFO] [stdout]    |     ++++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0405]: cannot find trait `Processor` in this scope
[INFO] [stdout]    --> examples/kafka_processor_complex.rs:106:6
[INFO] [stdout]     |
[INFO] [stdout] 106 | impl Processor<OwnedDeliveryResult, ()> for Layer2Process {
[INFO] [stdout]     |      ^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this trait
[INFO] [stdout]     |
[INFO] [stdout] 1   | use tokio_sky::Processor;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `OwnedDeliveryResult` in this scope
[INFO] [stdout]    --> examples/kafka_processor_complex.rs:106:16
[INFO] [stdout]     |
[INFO] [stdout] 106 | impl Processor<OwnedDeliveryResult, ()> for Layer2Process {
[INFO] [stdout]     |                ^^^^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: you might be missing a type parameter
[INFO] [stdout]     |
[INFO] [stdout] 106 | impl<OwnedDeliveryResult> Processor<OwnedDeliveryResult, ()> for Layer2Process {
[INFO] [stdout]     |     +++++++++++++++++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `Layer2Process` in this scope
[INFO] [stdout]    --> examples/kafka_processor_complex.rs:106:45
[INFO] [stdout]     |
[INFO] [stdout] 106 | impl Processor<OwnedDeliveryResult, ()> for Layer2Process {
[INFO] [stdout]     |                                             ^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `OwnedDeliveryResult` in this scope
[INFO] [stdout]    --> examples/kafka_processor_complex.rs:110:45
[INFO] [stdout]     |
[INFO] [stdout] 110 |     async fn handle_message(&mut self, msg: OwnedDeliveryResult) ->  ProcResult<()> {
[INFO] [stdout]     |                                             ^^^^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `ProcResult` in this scope
[INFO] [stdout]    --> examples/kafka_processor_complex.rs:110:70
[INFO] [stdout]     |
[INFO] [stdout] 110 |     async fn handle_message(&mut self, msg: OwnedDeliveryResult) ->  ProcResult<()> {
[INFO] [stdout]     |                                                                      ^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: consider importing this enum
[INFO] [stdout]     |
[INFO] [stdout] 1   | use tokio_sky::ProcResult;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` due to 19 previous errors
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `serde_json`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:86:23
[INFO] [stdout]    |
[INFO] [stdout] 86 |         let payload = serde_json::to_vec(&input).map_err(|e| PulsarError::Custom(e.to_string()))?;
[INFO] [stdout]    |                       ^^^^^^^^^^ use of undeclared crate or module `serde_json`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `PulsarError`
[INFO] [stdout]   --> examples/pulsar_batcher.rs:86:62
[INFO] [stdout]    |
[INFO] [stdout] 86 |         let payload = serde_json::to_vec(&input).map_err(|e| PulsarError::Custom(e.to_string()))?;
[INFO] [stdout]    |                                                              ^^^^^^^^^^^ use of undeclared type `PulsarError`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `run_topology_1_with_batcher` in this scope
[INFO] [stdout]   --> examples/pulsar_batcher.rs:51:17
[INFO] [stdout]    |
[INFO] [stdout] 51 |                 run_topology_1_with_batcher(
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 40 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0405, E0412, E0425, E0432, E0433, E0706.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0405`.
[INFO] [stdout] 
[INFO] [stdout] error: invalid character `'('` in crate name: `complex(3 layer)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: invalid character `' '` in crate name: `complex(3 layer)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: invalid character `')'` in crate name: `complex(3 layer)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 3 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:75:5
[INFO] [stdout]    |
[INFO] [stdout] 75 |     async fn init(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` due to 4 previous errors
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:77:5
[INFO] [stdout]    |
[INFO] [stdout] 77 |     async fn terminate(&mut self) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` due to 41 previous errors
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:79:5
[INFO] [stdout]    |
[INFO] [stdout] 79 |     async fn drain(&mut self, _buffer: VecDeque<ProcKafkaMessage>) {}
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:81:5
[INFO] [stdout]    |
[INFO] [stdout] 81 |     async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<ProcKafkaMessage>, Terminate> {
[INFO] [stdout]    |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |     |
[INFO] [stdout]    |     `async` because of this
[INFO] [stdout]    |
[INFO] [stdout]    = note: `async` trait functions are not currently supported
[INFO] [stdout]    = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]    = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/kafka_processor_complex.rs:107:5
[INFO] [stdout]     |
[INFO] [stdout] 107 |     async fn init(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/kafka_processor_complex.rs:108:5
[INFO] [stdout]     |
[INFO] [stdout] 108 |     async fn terminate(&mut self) {}
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0706]: functions in traits cannot be declared `async`
[INFO] [stdout]    --> examples/kafka_processor_complex.rs:110:5
[INFO] [stdout]     |
[INFO] [stdout] 110 |     async fn handle_message(&mut self, msg: OwnedDeliveryResult) ->  ProcResult<()> {
[INFO] [stdout]     |     -----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |     |
[INFO] [stdout]     |     `async` because of this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `async` trait functions are not currently supported
[INFO] [stdout]     = note: consider using the `async-trait` crate: https://crates.io/crates/async-trait
[INFO] [stdout]     = note: see issue #91611 <https://github.com/rust-lang/rust/issues/91611> for more information
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find function `run_topology_2` in this scope
[INFO] [stdout]   --> examples/kafka_processor_complex.rs:47:17
[INFO] [stdout]    |
[INFO] [stdout] 47 |                 run_topology_2(
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 31 previous errors
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0405, E0412, E0422, E0423, E0425, E0432, E0433, E0706.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0405`.
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `tokio_sky` due to 32 previous errors
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/producer.rs:42:12
[INFO] [stdout]    |
[INFO] [stdout] 42 | pub struct Context<T, Prod> 
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/producer.rs:57:12
[INFO] [stdout]    |
[INFO] [stdout] 57 |     pub fn new(dispatcher: Dispatcher<T>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `run` is never used
[INFO] [stdout]   --> src/producer.rs:78:12
[INFO] [stdout]    |
[INFO] [stdout] 78 |     pub fn run(mut self) {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/batcher.rs:29:12
[INFO] [stdout]    |
[INFO] [stdout] 29 | pub struct Context<Input, Proc>
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/batcher.rs:48:12
[INFO] [stdout]    |
[INFO] [stdout] 48 |     pub fn new(recv: mpsc::Receiver<Input>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `run` is never used
[INFO] [stdout]   --> src/batcher.rs:64:12
[INFO] [stdout]    |
[INFO] [stdout] 64 |     pub fn run(mut self) {        
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Context` is never constructed
[INFO] [stdout]   --> src/processor.rs:39:12
[INFO] [stdout]    |
[INFO] [stdout] 39 | pub struct Context<Input, Output, Proc>
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/processor.rs:56:12
[INFO] [stdout]    |
[INFO] [stdout] 56 |     pub fn new(recv: mpsc::Receiver<Input>,
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `run` is never used
[INFO] [stdout]   --> src/processor.rs:69:12
[INFO] [stdout]    |
[INFO] [stdout] 69 |     pub fn run(mut self) {        
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_shutdown_manager` is never used
[INFO] [stdout]  --> src/shutdown_manager.rs:5:8
[INFO] [stdout]   |
[INFO] [stdout] 5 | pub fn start_shutdown_manager(shutdown_recv: oneshot::Receiver<()>, list_shutdown: Vec<oneshot::Sender<()>>) {
[INFO] [stdout]   |        ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `PRODUCER_FILLBUFFER_TIMEOUT_REALTIME` is never used
[INFO] [stdout]   --> src/topology.rs:14:11
[INFO] [stdout]    |
[INFO] [stdout] 14 | pub const PRODUCER_FILLBUFFER_TIMEOUT_REALTIME: Duration = Duration::from_millis(2);
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `PRODUCER_FILLBUFFER_TIMEOUT_BATCH` is never used
[INFO] [stdout]   --> src/topology.rs:15:11
[INFO] [stdout]    |
[INFO] [stdout] 15 | pub const PRODUCER_FILLBUFFER_TIMEOUT_BATCH: Duration = Duration::from_millis(50);
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BATCH_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:17:11
[INFO] [stdout]    |
[INFO] [stdout] 17 | pub const BATCH_SIZE: usize = 100;
[INFO] [stdout]    |           ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BATCH_TIMEOUT` is never used
[INFO] [stdout]   --> src/topology.rs:18:11
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub const BATCH_TIMEOUT: Duration = Duration::from_millis(50);
[INFO] [stdout]    |           ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `CONCURRENCY` is never used
[INFO] [stdout]   --> src/topology.rs:19:11
[INFO] [stdout]    |
[INFO] [stdout] 19 | pub const CONCURRENCY: i32 = 1;
[INFO] [stdout]    |           ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BUFFER_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:20:11
[INFO] [stdout]    |
[INFO] [stdout] 20 | pub const BUFFER_SIZE: usize = 10;
[INFO] [stdout]    |           ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `BUFFER_POOL_SIZE` is never used
[INFO] [stdout]   --> src/topology.rs:21:11
[INFO] [stdout]    |
[INFO] [stdout] 21 | pub const BUFFER_POOL_SIZE: usize = 100;
[INFO] [stdout]    |           ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `ProcessingType` is never used
[INFO] [stdout]   --> src/topology.rs:39:10
[INFO] [stdout]    |
[INFO] [stdout] 39 | pub enum ProcessingType {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_producer` is never used
[INFO] [stdout]   --> src/topology.rs:48:4
[INFO] [stdout]    |
[INFO] [stdout] 48 | fn start_producer<T, Prod, F> (producer_factory: F,
[INFO] [stdout]    |    ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Config` is never constructed
[INFO] [stdout]   --> src/topology.rs:98:12
[INFO] [stdout]    |
[INFO] [stdout] 98 | pub struct Config<Output> {
[INFO] [stdout]    |            ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_processor` is never used
[INFO] [stdout]    --> src/topology.rs:104:4
[INFO] [stdout]     |
[INFO] [stdout] 104 | fn start_processor<Input, Output, Proc, F> (processor_factory: F,
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `start_batch_processor` is never used
[INFO] [stdout]    --> src/topology.rs:152:4
[INFO] [stdout]     |
[INFO] [stdout] 152 | fn start_batch_processor<Input, Proc, F> (batcher_factory: F,
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_1` is never used
[INFO] [stdout]    --> src/topology.rs:215:8
[INFO] [stdout]     |
[INFO] [stdout] 215 | pub fn run_topology_1<Prod, ProdFactory, Input, Output, Proc, ProcFactory>
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_2` is never used
[INFO] [stdout]    --> src/topology.rs:261:8
[INFO] [stdout]     |
[INFO] [stdout] 261 | pub fn run_topology_2<Prod, ProdFactory, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_3` is never used
[INFO] [stdout]    --> src/topology.rs:332:8
[INFO] [stdout]     |
[INFO] [stdout] 332 | pub fn run_topology_3<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_4` is never used
[INFO] [stdout]    --> src/topology.rs:421:8
[INFO] [stdout]     |
[INFO] [stdout] 421 | pub fn run_topology_4<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_5` is never used
[INFO] [stdout]    --> src/topology.rs:530:8
[INFO] [stdout]     |
[INFO] [stdout] 530 | pub fn run_topology_5<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_1_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:663:8
[INFO] [stdout]     |
[INFO] [stdout] 663 | pub fn run_topology_1_with_batcher<Prod, ProdFactory, Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_2_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:735:8
[INFO] [stdout]     |
[INFO] [stdout] 735 | pub fn run_topology_2_with_batcher<Prod, ProdFactory, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_3_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:825:8
[INFO] [stdout]     |
[INFO] [stdout] 825 | pub fn run_topology_3_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_4_with_batcher` is never used
[INFO] [stdout]    --> src/topology.rs:934:8
[INFO] [stdout]     |
[INFO] [stdout] 934 | pub fn run_topology_4_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_topology_5_with_batcher` is never used
[INFO] [stdout]     --> src/topology.rs:1062:8
[INFO] [stdout]      |
[INFO] [stdout] 1062 | pub fn run_topology_5_with_batcher<Prod, ProdFactory, Layer1Input, 
[INFO] [stdout]      |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type alias `StageName` is never used
[INFO] [stdout]  --> src/dispatcher.rs:9:10
[INFO] [stdout]   |
[INFO] [stdout] 9 | pub type StageName = String;
[INFO] [stdout]   |          ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `InternalDispatchError` is never used
[INFO] [stdout]   --> src/dispatcher.rs:22:6
[INFO] [stdout]    |
[INFO] [stdout] 22 | enum InternalDispatchError<T> {
[INFO] [stdout]    |      ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `DispatchError` is never used
[INFO] [stdout]   --> src/dispatcher.rs:34:10
[INFO] [stdout]    |
[INFO] [stdout] 34 | pub enum DispatchError<T> {
[INFO] [stdout]    |          ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `SendersRepetive` is never constructed
[INFO] [stdout]   --> src/dispatcher.rs:52:5
[INFO] [stdout]    |
[INFO] [stdout] 51 | pub enum StatusResult {
[INFO] [stdout]    |          ------------ variant in this enum
[INFO] [stdout] 52 |     SendersRepetive
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `StatusResult` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Dispatcher` is never constructed
[INFO] [stdout]   --> src/dispatcher.rs:56:12
[INFO] [stdout]    |
[INFO] [stdout] 56 | pub struct Dispatcher<T> {
[INFO] [stdout]    |            ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/dispatcher.rs:69:12
[INFO] [stdout]    |
[INFO] [stdout] 69 |     pub fn new(channels: IndexMap<StageName, mpsc::Sender<T>>, 
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `dispatch` is never used
[INFO] [stdout]    --> src/dispatcher.rs:104:18
[INFO] [stdout]     |
[INFO] [stdout] 104 |     pub async fn dispatch(&mut self, msg: T, batch_key: Option<String>) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |                  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `partition` is never used
[INFO] [stdout]    --> src/dispatcher.rs:179:14
[INFO] [stdout]     |
[INFO] [stdout] 179 |     async fn partition(&mut self, msg: T, batch_key: String) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `broadcast` is never used
[INFO] [stdout]    --> src/dispatcher.rs:218:14
[INFO] [stdout]     |
[INFO] [stdout] 218 |     async fn broadcast(&mut self, msg: T) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `roundrobin` is never used
[INFO] [stdout]    --> src/dispatcher.rs:270:14
[INFO] [stdout]     |
[INFO] [stdout] 270 |     async fn roundrobin(&mut self, mut msg: T) -> Result<(), DispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `logic_roundrobin` is never used
[INFO] [stdout]    --> src/dispatcher.rs:319:14
[INFO] [stdout]     |
[INFO] [stdout] 319 |     async fn logic_roundrobin(&mut self, mut msg: T) -> Result<(), InternalDispatchError<T>> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `next_index` is never used
[INFO] [stdout]    --> src/dispatcher.rs:368:8
[INFO] [stdout]     |
[INFO] [stdout] 368 |     fn next_index(&mut self) -> usize {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `list_check` is never used
[INFO] [stdout]    --> src/dispatcher.rs:383:8
[INFO] [stdout]     |
[INFO] [stdout] 383 |     fn list_check(channels: &IndexMap<StageName, mpsc::Sender<T>>) -> Result<(), ()> {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 45 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] running `Command { std: "docker" "inspect" "6f02b5701b244f388b3842cbe943d6dbd8be49c2b786985752bdaee0108ba744", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "6f02b5701b244f388b3842cbe943d6dbd8be49c2b786985752bdaee0108ba744", kill_on_drop: false }`
[INFO] [stdout] 6f02b5701b244f388b3842cbe943d6dbd8be49c2b786985752bdaee0108ba744
