[INFO] fetching crate thalo-kafka 0.5.0... [INFO] testing thalo-kafka-0.5.0 against beta-2022-04-10 for beta-1.61-1 [INFO] extracting crate thalo-kafka 0.5.0 into /workspace/builds/worker-4/source [INFO] validating manifest of crates.io crate thalo-kafka 0.5.0 on toolchain beta-2022-04-10 [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+beta-2022-04-10" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] started tweaking crates.io crate thalo-kafka 0.5.0 [INFO] finished tweaking crates.io crate thalo-kafka 0.5.0 [INFO] tweaked toml for crates.io crate thalo-kafka 0.5.0 written to /workspace/builds/worker-4/source/Cargo.toml [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+beta-2022-04-10" "generate-lockfile" "--manifest-path" "Cargo.toml" "-Zno-index-update", kill_on_drop: false }` [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+beta-2022-04-10" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4/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:eaef2f80f755933c374d2ae5edccceec0c1312ceb8a4e0b6404e8ab76561e1e5" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2022-04-10" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap. [INFO] [stdout] eeb7b1a695944ced29c7a469b98af00c4d0e8fbc6433fafbc6acd400668109ba [INFO] running `Command { std: "docker" "start" "-a" "eeb7b1a695944ced29c7a469b98af00c4d0e8fbc6433fafbc6acd400668109ba", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "eeb7b1a695944ced29c7a469b98af00c4d0e8fbc6433fafbc6acd400668109ba", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "eeb7b1a695944ced29c7a469b98af00c4d0e8fbc6433fafbc6acd400668109ba", kill_on_drop: false }` [INFO] [stdout] eeb7b1a695944ced29c7a469b98af00c4d0e8fbc6433fafbc6acd400668109ba [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4/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" "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:eaef2f80f755933c374d2ae5edccceec0c1312ceb8a4e0b6404e8ab76561e1e5" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2022-04-10" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 4e45473988e91036f5c5940d0b8ca71af586610b2dbb428653a6834f041c1745 [INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap. [INFO] running `Command { std: "docker" "start" "-a" "4e45473988e91036f5c5940d0b8ca71af586610b2dbb428653a6834f041c1745", kill_on_drop: false }` [INFO] [stderr] Compiling tokio v1.17.0 [INFO] [stderr] Compiling rdkafka-sys v4.2.0+1.8.2 [INFO] [stderr] Compiling futures-util v0.3.21 [INFO] [stderr] Compiling proc-macro-crate v1.1.3 [INFO] [stderr] Compiling chrono v0.4.19 [INFO] [stderr] Compiling num_enum_derive v0.5.7 [INFO] [stderr] Compiling tokio-util v0.6.9 [INFO] [stderr] Compiling tokio-stream v0.1.8 [INFO] [stderr] Compiling num_enum v0.5.7 [INFO] [stderr] Compiling futures-executor v0.3.21 [INFO] [stderr] Compiling thalo v0.5.0 [INFO] [stderr] Compiling futures v0.3.21 [INFO] [stderr] Compiling rdkafka v0.28.0 [INFO] [stderr] Compiling thalo-kafka v0.5.0 (/opt/rustwide/workdir) [INFO] [stderr] Finished dev [unoptimized + debuginfo] target(s) in 1m 52s [INFO] running `Command { std: "docker" "inspect" "4e45473988e91036f5c5940d0b8ca71af586610b2dbb428653a6834f041c1745", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "4e45473988e91036f5c5940d0b8ca71af586610b2dbb428653a6834f041c1745", kill_on_drop: false }` [INFO] [stdout] 4e45473988e91036f5c5940d0b8ca71af586610b2dbb428653a6834f041c1745 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4/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" "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:eaef2f80f755933c374d2ae5edccceec0c1312ceb8a4e0b6404e8ab76561e1e5" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2022-04-10" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap. [INFO] [stdout] c5e43873648a8535d641de947e79a808e6acbf0e328320950f212e41602fbf0f [INFO] running `Command { std: "docker" "start" "-a" "c5e43873648a8535d641de947e79a808e6acbf0e328320950f212e41602fbf0f", kill_on_drop: false }` [INFO] [stderr] Compiling thalo-kafka v0.5.0 (/opt/rustwide/workdir) [INFO] [stderr] Finished test [unoptimized + debuginfo] target(s) in 3.27s [INFO] [stderr] Executable unittests src/lib.rs (/opt/rustwide/target/debug/deps/thalo_kafka-ee8dd509585a07b3) [INFO] running `Command { std: "docker" "inspect" "c5e43873648a8535d641de947e79a808e6acbf0e328320950f212e41602fbf0f", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "c5e43873648a8535d641de947e79a808e6acbf0e328320950f212e41602fbf0f", kill_on_drop: false }` [INFO] [stdout] c5e43873648a8535d641de947e79a808e6acbf0e328320950f212e41602fbf0f [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4/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" "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:eaef2f80f755933c374d2ae5edccceec0c1312ceb8a4e0b6404e8ab76561e1e5" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2022-04-10" "test" "--frozen", kill_on_drop: false }` [INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap. [INFO] [stdout] b75f9676cd38b547e34aad7347f7a5b0bf5c2047b98398d473978f6a3304cc59 [INFO] running `Command { std: "docker" "start" "-a" "b75f9676cd38b547e34aad7347f7a5b0bf5c2047b98398d473978f6a3304cc59", kill_on_drop: false }` [INFO] [stderr] Finished test [unoptimized + debuginfo] target(s) in 0.09s [INFO] [stderr] Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/thalo_kafka-ee8dd509585a07b3) [INFO] [stdout] [INFO] [stdout] running 2 tests [INFO] [stdout] test config::tests::new_recommended ... ok [INFO] [stdout] test config::tests::set ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 2 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Doc-tests thalo-kafka [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test src/event_handler.rs - event_handler::WatchEventHandler::watch (line 87) ... FAILED [INFO] [stdout] test src/event_handler.rs - event_handler::WatchEventHandler::event_stream (line 43) ... FAILED [INFO] [stdout] test src/event_handler.rs - event_handler::WatchEventHandler::event_stream (line 55) ... FAILED [INFO] [stdout] test src/event_handler.rs - event_handler::WatchEventHandler::watch (line 105) ... FAILED [INFO] [stdout] test src/lib.rs - (line 7) ... FAILED [INFO] [stdout] test src/lib.rs - spawn_event_handlers (line 63) ... FAILED [INFO] [stdout] test src/event_handler.rs - event_handler::WatchEventHandler::topics (line 27) ... ok [INFO] [stdout] [INFO] [stdout] failures: [INFO] [stdout] [INFO] [stdout] ---- src/event_handler.rs - event_handler::WatchEventHandler::watch (line 87) stdout ---- [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `tokio` [INFO] [stdout] --> src/event_handler.rs:88:3 [INFO] [stdout] | [INFO] [stdout] 2 | #[tokio::main] [INFO] [stdout] | ^^^^^ use of undeclared crate or module `tokio` [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Database` [INFO] [stdout] --> src/event_handler.rs:93:14 [INFO] [stdout] | [INFO] [stdout] 7 | let db = Database::connect(&database_url).await?; [INFO] [stdout] | ^^^^^^^^ use of undeclared type `Database` [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `BankAccountProjection` [INFO] [stdout] --> src/event_handler.rs:95:22 [INFO] [stdout] | [INFO] [stdout] 9 | let projection = BankAccountProjection::new(db); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ use of undeclared type `BankAccountProjection` [INFO] [stdout] [INFO] [stdout] error[E0752]: `main` function is not allowed to be `async` [INFO] [stdout] --> src/event_handler.rs:89:1 [INFO] [stdout] | [INFO] [stdout] 3 | async fn main() -> Result<(), Box> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `main` function is not allowed to be `async` [INFO] [stdout] [INFO] [stdout] error: aborting due to 4 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0433, E0752. [INFO] [stdout] For more information about an error, try `rustc --explain E0433`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/event_handler.rs - event_handler::WatchEventHandler::event_stream (line 43) stdout ---- [INFO] [stdout] error[E0412]: cannot find type `KafkaEventStream` in this scope [INFO] [stdout] --> src/event_handler.rs:45:26 [INFO] [stdout] | [INFO] [stdout] 5 | kafka_event_stream: &KafkaEventStream, [INFO] [stdout] | ^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 2 | use thalo_kafka::KafkaEventStream; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `BoxStream` in this scope [INFO] [stdout] --> src/event_handler.rs:47:5 [INFO] [stdout] | [INFO] [stdout] 7 | BoxStream<'_, Result, thalo_kafka::Error>>, [INFO] [stdout] | ^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this type alias [INFO] [stdout] | [INFO] [stdout] 2 | use futures_util::stream::BoxStream; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `KafkaEventMessage` in this scope [INFO] [stdout] --> src/event_handler.rs:47:26 [INFO] [stdout] | [INFO] [stdout] 7 | BoxStream<'_, Result, thalo_kafka::Error>>, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 2 | use thalo_kafka::KafkaEventMessage; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `AuthEvent` in this scope [INFO] [stdout] --> src/event_handler.rs:47:44 [INFO] [stdout] | [INFO] [stdout] 4 | fn event_stream( [INFO] [stdout] | - help: you might be missing a type parameter: `` [INFO] [stdout] ... [INFO] [stdout] 7 | BoxStream<'_, Result, thalo_kafka::Error>>, [INFO] [stdout] | ^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `BankAccount` in this scope [INFO] [stdout] --> src/event_handler.rs:50:40 [INFO] [stdout] | [INFO] [stdout] 4 | fn event_stream( [INFO] [stdout] | - help: you might be missing a type parameter: `` [INFO] [stdout] ... [INFO] [stdout] 10 | kafka_event_stream.listen_events::() [INFO] [stdout] | ^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error: aborting due to 5 previous errors [INFO] [stdout] [INFO] [stdout] For more information about this error, try `rustc --explain E0412`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/event_handler.rs - event_handler::WatchEventHandler::event_stream (line 55) stdout ---- [INFO] [stdout] error[E0412]: cannot find type `KafkaEventStream` in this scope [INFO] [stdout] --> src/event_handler.rs:57:26 [INFO] [stdout] | [INFO] [stdout] 5 | kafka_event_stream: &KafkaEventStream, [INFO] [stdout] | ^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 2 | use thalo_kafka::KafkaEventStream; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `BoxStream` in this scope [INFO] [stdout] --> src/event_handler.rs:59:5 [INFO] [stdout] | [INFO] [stdout] 7 | BoxStream<'_, Result, thalo_kafka::Error>>, [INFO] [stdout] | ^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this type alias [INFO] [stdout] | [INFO] [stdout] 2 | use futures_util::stream::BoxStream; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `KafkaEventMessage` in this scope [INFO] [stdout] --> src/event_handler.rs:59:26 [INFO] [stdout] | [INFO] [stdout] 7 | BoxStream<'_, Result, thalo_kafka::Error>>, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 2 | use thalo_kafka::KafkaEventMessage; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `AuthEvent` in this scope [INFO] [stdout] --> src/event_handler.rs:59:44 [INFO] [stdout] | [INFO] [stdout] 4 | fn event_stream( [INFO] [stdout] | - help: you might be missing a type parameter: `` [INFO] [stdout] ... [INFO] [stdout] 7 | BoxStream<'_, Result, thalo_kafka::Error>>, [INFO] [stdout] | ^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `tokio_stream` [INFO] [stdout] --> src/event_handler.rs:62:32 [INFO] [stdout] | [INFO] [stdout] 10 | let stream = tokio_stream::StreamExt::merge( [INFO] [stdout] | ^^^^^^^^^ not found in `tokio_stream` [INFO] [stdout] | [INFO] [stdout] help: consider importing this trait [INFO] [stdout] | [INFO] [stdout] 2 | use futures_util::StreamExt; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Auth` in this scope [INFO] [stdout] --> src/event_handler.rs:63:44 [INFO] [stdout] | [INFO] [stdout] 4 | fn event_stream( [INFO] [stdout] | - help: you might be missing a type parameter: `` [INFO] [stdout] ... [INFO] [stdout] 11 | kafka_event_stream.listen_events::()?, [INFO] [stdout] | ^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Auth` in this scope [INFO] [stdout] --> src/event_handler.rs:64:44 [INFO] [stdout] | [INFO] [stdout] 4 | fn event_stream( [INFO] [stdout] | - help: you might be missing a type parameter: `` [INFO] [stdout] ... [INFO] [stdout] 12 | kafka_event_stream.listen_events::()?, [INFO] [stdout] | ^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error: aborting due to 7 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0412, E0433. [INFO] [stdout] For more information about an error, try `rustc --explain E0412`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/event_handler.rs - event_handler::WatchEventHandler::watch (line 105) stdout ---- [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `tokio` [INFO] [stdout] --> src/event_handler.rs:106:3 [INFO] [stdout] | [INFO] [stdout] 2 | #[tokio::main] [INFO] [stdout] | ^^^^^ use of undeclared crate or module `tokio` [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Database` [INFO] [stdout] --> src/event_handler.rs:111:14 [INFO] [stdout] | [INFO] [stdout] 7 | let db = Database::connect(&database_url).await?; [INFO] [stdout] | ^^^^^^^^ use of undeclared type `Database` [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `BankAccountProjection` [INFO] [stdout] --> src/event_handler.rs:114:26 [INFO] [stdout] | [INFO] [stdout] 10 | ("bank-account", BankAccountProjection::new(db.clone())), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ use of undeclared type `BankAccountProjection` [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `TransactionsProjection` [INFO] [stdout] --> src/event_handler.rs:115:26 [INFO] [stdout] | [INFO] [stdout] 11 | ("transactions", TransactionsProjection::new(db)), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ use of undeclared type `TransactionsProjection` [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `tokio` [INFO] [stdout] --> src/event_handler.rs:121:13 [INFO] [stdout] | [INFO] [stdout] 17 | tokio::spawn(async move { projection.watch(&redpanda_host, group_id).await }) [INFO] [stdout] | ^^^^^ use of undeclared crate or module `tokio` [INFO] [stdout] [INFO] [stdout] error[E0425]: cannot find value `redpanda_host` in this scope [INFO] [stdout] --> src/event_handler.rs:121:57 [INFO] [stdout] | [INFO] [stdout] 17 | tokio::spawn(async move { projection.watch(&redpanda_host, group_id).await }) [INFO] [stdout] | ^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0752]: `main` function is not allowed to be `async` [INFO] [stdout] --> src/event_handler.rs:107:1 [INFO] [stdout] | [INFO] [stdout] 3 | async fn main() -> Result<(), Box> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `main` function is not allowed to be `async` [INFO] [stdout] [INFO] [stdout] error: aborting due to 7 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0425, E0433, E0752. [INFO] [stdout] For more information about an error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib.rs - (line 7) stdout ---- [INFO] [stdout] error[E0583]: file not found for module `projections` [INFO] [stdout] --> src/lib.rs:12:1 [INFO] [stdout] | [INFO] [stdout] 7 | mod projections; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = help: to create the module `projections`, create file "src/projections.rs" or "src/projections/mod.rs" [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved imports `crate::projections::BankAccountProjection`, `crate::projections::AssetsProjection` [INFO] [stdout] --> src/lib.rs:10:26 [INFO] [stdout] | [INFO] [stdout] 5 | use crate::projections::{BankAccountProjection, AssetsProjection}; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^ no `AssetsProjection` in `projections` [INFO] [stdout] | | [INFO] [stdout] | no `BankAccountProjection` in `projections` [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `tokio` [INFO] [stdout] --> src/lib.rs:14:3 [INFO] [stdout] | [INFO] [stdout] 9 | #[tokio::main] [INFO] [stdout] | ^^^^^ use of undeclared crate or module `tokio` [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `tracing_subscriber` [INFO] [stdout] --> src/lib.rs:16:5 [INFO] [stdout] | [INFO] [stdout] 11 | tracing_subscriber::fmt().init(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ use of undeclared crate or module `tracing_subscriber` [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Database` [INFO] [stdout] --> src/lib.rs:21:14 [INFO] [stdout] | [INFO] [stdout] 16 | let db = Database::connect(&database_url).await?; [INFO] [stdout] | ^^^^^^^^ use of undeclared type `Database` [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `tokio` [INFO] [stdout] --> src/lib.rs:23:19 [INFO] [stdout] | [INFO] [stdout] 18 | let handles = spawn_event_handlers!( [INFO] [stdout] | ___________________^ [INFO] [stdout] 19 | | kafka_host, [INFO] [stdout] 20 | | ("bank-account", BankAccountProjection::new(db.clone())), [INFO] [stdout] 21 | | ("assets", AssetsProjection::new(db)), [INFO] [stdout] 22 | | ); [INFO] [stdout] | |_____^ use of undeclared crate or module `tokio` [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the macro `spawn_event_handlers` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] error[E0752]: `main` function is not allowed to be `async` [INFO] [stdout] --> src/lib.rs:15:1 [INFO] [stdout] | [INFO] [stdout] 10 | async fn main() -> Result<(), Box> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `main` function is not allowed to be `async` [INFO] [stdout] [INFO] [stdout] error: aborting due to 7 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0432, E0433, E0583, E0752. [INFO] [stdout] For more information about an error, try `rustc --explain E0432`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/lib.rs - spawn_event_handlers (line 63) stdout ---- [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared crate or module `tokio` [INFO] [stdout] --> src/lib.rs:64:3 [INFO] [stdout] | [INFO] [stdout] 2 | #[tokio::main] [INFO] [stdout] | ^^^^^ use of undeclared crate or module `tokio` [INFO] [stdout] [INFO] [stdout] error: cannot find macro `spawn_event_handlers` in this scope [INFO] [stdout] --> src/lib.rs:71:19 [INFO] [stdout] | [INFO] [stdout] 9 | let handles = spawn_event_handlers!( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: consider importing this macro: [INFO] [stdout] thalo_kafka::spawn_event_handlers [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Database` [INFO] [stdout] --> src/lib.rs:69:14 [INFO] [stdout] | [INFO] [stdout] 7 | let db = Database::connect(&database_url).await?; [INFO] [stdout] | ^^^^^^^^ use of undeclared type `Database` [INFO] [stdout] [INFO] [stdout] error[E0752]: `main` function is not allowed to be `async` [INFO] [stdout] --> src/lib.rs:65:1 [INFO] [stdout] | [INFO] [stdout] 3 | async fn main() -> Result<(), Box> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `main` function is not allowed to be `async` [INFO] [stdout] [INFO] [stdout] error: aborting due to 4 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0433, E0752. [INFO] [stdout] For more information about an error, try `rustc --explain E0433`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] [INFO] [stdout] failures: [INFO] [stdout] src/event_handler.rs - event_handler::WatchEventHandler::event_stream (line 43) [INFO] [stdout] src/event_handler.rs - event_handler::WatchEventHandler::event_stream (line 55) [INFO] [stdout] src/event_handler.rs - event_handler::WatchEventHandler::watch (line 105) [INFO] [stdout] src/event_handler.rs - event_handler::WatchEventHandler::watch (line 87) [INFO] [stdout] src/lib.rs - (line 7) [INFO] [stdout] src/lib.rs - spawn_event_handlers (line 63) [INFO] [stdout] [INFO] [stdout] test result: FAILED. 1 passed; 6 failed; 0 ignored; 0 measured; 0 filtered out; finished in 2.25s [INFO] [stdout] [INFO] [stderr] error: test failed, to rerun pass '--doc' [INFO] running `Command { std: "docker" "inspect" "b75f9676cd38b547e34aad7347f7a5b0bf5c2047b98398d473978f6a3304cc59", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "b75f9676cd38b547e34aad7347f7a5b0bf5c2047b98398d473978f6a3304cc59", kill_on_drop: false }` [INFO] [stdout] b75f9676cd38b547e34aad7347f7a5b0bf5c2047b98398d473978f6a3304cc59