[INFO] fetching crate thalo-kafka 0.5.0... [INFO] testing thalo-kafka-0.5.0 against master#cdb45c87e2cd43495379f7e867e3cc15dcee9f93 for pr-145838-1 [INFO] extracting crate thalo-kafka 0.5.0 into /workspace/builds/worker-6-tc1/source [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-6-tc1/source/Cargo.toml [INFO] validating manifest of crates.io crate thalo-kafka 0.5.0 on toolchain cdb45c87e2cd43495379f7e867e3cc15dcee9f93 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "generate-lockfile" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Updating crates.io index [INFO] [stderr] Locking 99 packages to latest compatible versions [INFO] [stderr] Adding rdkafka v0.28.0 (available: v0.38.0) [INFO] [stderr] Adding thalo v0.5.0 (available: v0.8.0) [INFO] [stderr] Adding thiserror v1.0.69 (available: v2.0.16) [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded thalo v0.5.0 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-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:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 5c8b1a8d78f9fc6196862c4e9519d1b19f01fa981a82beace16dad2a7a91bb99 [INFO] running `Command { std: "docker" "start" "-a" "5c8b1a8d78f9fc6196862c4e9519d1b19f01fa981a82beace16dad2a7a91bb99", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "5c8b1a8d78f9fc6196862c4e9519d1b19f01fa981a82beace16dad2a7a91bb99", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "5c8b1a8d78f9fc6196862c4e9519d1b19f01fa981a82beace16dad2a7a91bb99", kill_on_drop: false }` [INFO] [stdout] 5c8b1a8d78f9fc6196862c4e9519d1b19f01fa981a82beace16dad2a7a91bb99 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-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=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-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:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] eeef7c24b81997a07b8fddbcc787517af13dcfb3d2df1a6637885e6e169b877a [INFO] running `Command { std: "docker" "start" "-a" "eeef7c24b81997a07b8fddbcc787517af13dcfb3d2df1a6637885e6e169b877a", kill_on_drop: false }` [INFO] [stderr] Compiling equivalent v1.0.2 [INFO] [stderr] Compiling hashbrown v0.15.5 [INFO] [stderr] Compiling toml_datetime v0.6.11 [INFO] [stderr] Compiling winnow v0.7.13 [INFO] [stderr] Compiling syn v2.0.106 [INFO] [stderr] Compiling libz-sys v1.1.22 [INFO] [stderr] Compiling num-traits v0.2.19 [INFO] [stderr] Compiling tokio v1.47.1 [INFO] [stderr] Compiling rdkafka-sys v4.9.0+2.10.0 [INFO] [stderr] Compiling indexmap v2.11.0 [INFO] [stderr] Compiling toml_edit v0.22.27 [INFO] [stderr] Compiling tokio-util v0.7.16 [INFO] [stderr] Compiling tokio-stream v0.1.17 [INFO] [stderr] Compiling proc-macro-crate v3.3.0 [INFO] [stderr] Compiling futures-macro v0.3.31 [INFO] [stderr] Compiling serde_derive v1.0.219 [INFO] [stderr] Compiling num_enum_derive v0.7.4 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling async-stream-impl v0.3.6 [INFO] [stderr] Compiling async-trait v0.1.89 [INFO] [stderr] Compiling tracing-attributes v0.1.30 [INFO] [stderr] Compiling async-stream v0.3.6 [INFO] [stderr] Compiling thiserror-impl v1.0.69 [INFO] [stderr] Compiling num_enum v0.7.4 [INFO] [stderr] Compiling thiserror v1.0.69 [INFO] [stderr] Compiling tracing v0.1.41 [INFO] [stderr] Compiling serde v1.0.219 [INFO] [stderr] Compiling futures-executor v0.3.31 [INFO] [stderr] Compiling futures v0.3.31 [INFO] [stderr] Compiling serde_json v1.0.143 [INFO] [stderr] Compiling chrono v0.4.41 [INFO] [stderr] Compiling thalo v0.5.0 [INFO] [stderr] Compiling rdkafka v0.28.0 [INFO] [stderr] Compiling thalo-kafka v0.5.0 (/opt/rustwide/workdir) [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 2m 20s [INFO] running `Command { std: "docker" "inspect" "eeef7c24b81997a07b8fddbcc787517af13dcfb3d2df1a6637885e6e169b877a", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "eeef7c24b81997a07b8fddbcc787517af13dcfb3d2df1a6637885e6e169b877a", kill_on_drop: false }` [INFO] [stdout] eeef7c24b81997a07b8fddbcc787517af13dcfb3d2df1a6637885e6e169b877a [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-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=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-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:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] e6ceb5ac67fadba0ca147da306cbe7ff26ba2ab22309803edb78f186443a7eab [INFO] running `Command { std: "docker" "start" "-a" "e6ceb5ac67fadba0ca147da306cbe7ff26ba2ab22309803edb78f186443a7eab", kill_on_drop: false }` [INFO] [stderr] Compiling thalo-kafka v0.5.0 (/opt/rustwide/workdir) [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 1.12s [INFO] running `Command { std: "docker" "inspect" "e6ceb5ac67fadba0ca147da306cbe7ff26ba2ab22309803edb78f186443a7eab", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "e6ceb5ac67fadba0ca147da306cbe7ff26ba2ab22309803edb78f186443a7eab", kill_on_drop: false }` [INFO] [stdout] e6ceb5ac67fadba0ca147da306cbe7ff26ba2ab22309803edb78f186443a7eab [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-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=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-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:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "test" "--frozen", kill_on_drop: false }` [INFO] [stdout] f250451998757b4bc9aeaf33921d3ab8d36dc3ecb61137f523cf8dcb8e159303 [INFO] running `Command { std: "docker" "start" "-a" "f250451998757b4bc9aeaf33921d3ab8d36dc3ecb61137f523cf8dcb8e159303", kill_on_drop: false }` [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 0.10s [INFO] [stderr] Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/thalo_kafka-698060a11abd9e10) [INFO] [stdout] [INFO] [stderr] Doc-tests thalo_kafka [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.00s [INFO] [stdout] [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::topics (line 27) ... ok [INFO] [stdout] test src/event_handler.rs - event_handler::WatchEventHandler::watch (line 105) ... FAILED [INFO] [stdout] test src/lib.rs - spawn_event_handlers (line 63) ... FAILED [INFO] [stdout] test src/event_handler.rs - event_handler::WatchEventHandler::event_stream (line 55) ... FAILED [INFO] [stdout] test src/lib.rs - (line 7) ... FAILED [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 unresolved module or unlinked crate `tokio` [INFO] [stdout] --> src/event_handler.rs:88:3 [INFO] [stdout] | [INFO] [stdout] 2 | #[tokio::main] [INFO] [stdout] | ^^^^^ use of unresolved module or unlinked crate `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:46:26 [INFO] [stdout] | [INFO] [stdout] 6 | 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:48:5 [INFO] [stdout] | [INFO] [stdout] 8 | 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:48:26 [INFO] [stdout] | [INFO] [stdout] 8 | 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:48:44 [INFO] [stdout] | [INFO] [stdout] 8 | BoxStream<'_, Result, thalo_kafka::Error>>, [INFO] [stdout] | ^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 5 | fn event_stream( [INFO] [stdout] | +++++++++++ [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `BankAccount` in this scope [INFO] [stdout] --> src/event_handler.rs:51:40 [INFO] [stdout] | [INFO] [stdout] 11 | kafka_event_stream.listen_events::() [INFO] [stdout] | ^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 5 | fn event_stream( [INFO] [stdout] | +++++++++++++ [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::watch (line 105) stdout ---- [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `tokio` [INFO] [stdout] --> src/event_handler.rs:106:3 [INFO] [stdout] | [INFO] [stdout] 2 | #[tokio::main] [INFO] [stdout] | ^^^^^ use of unresolved module or unlinked crate `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[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 unresolved module or unlinked crate `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 unresolved module or unlinked crate `tokio` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `tokio`, use `cargo add tokio` to add it to your `Cargo.toml` [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 - spawn_event_handlers (line 63) stdout ---- [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `tokio` [INFO] [stdout] --> src/lib.rs:64:3 [INFO] [stdout] | [INFO] [stdout] 2 | #[tokio::main] [INFO] [stdout] | ^^^^^ use of unresolved module or unlinked crate `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] help: consider importing this macro [INFO] [stdout] | [INFO] [stdout] 2 + use thalo_kafka::spawn_event_handlers; [INFO] [stdout] | [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] ---- 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:58:26 [INFO] [stdout] | [INFO] [stdout] 6 | 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:60:5 [INFO] [stdout] | [INFO] [stdout] 8 | 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:60:26 [INFO] [stdout] | [INFO] [stdout] 8 | 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:60:44 [INFO] [stdout] | [INFO] [stdout] 8 | BoxStream<'_, Result, thalo_kafka::Error>>, [INFO] [stdout] | ^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 5 | fn event_stream( [INFO] [stdout] | +++++++++++ [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `tokio_stream` [INFO] [stdout] --> src/event_handler.rs:63:18 [INFO] [stdout] | [INFO] [stdout] 11 | let stream = tokio_stream::StreamExt::merge( [INFO] [stdout] | ^^^^^^^^^^^^ use of unresolved module or unlinked crate `tokio_stream` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `tokio_stream`, use `cargo add tokio_stream` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this trait [INFO] [stdout] | [INFO] [stdout] 2 + use futures_util::StreamExt; [INFO] [stdout] | [INFO] [stdout] help: if you import `StreamExt`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 11 - let stream = tokio_stream::StreamExt::merge( [INFO] [stdout] 11 + let stream = StreamExt::merge( [INFO] [stdout] | [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] 12 | kafka_event_stream.listen_events::()?, [INFO] [stdout] | ^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 5 | fn event_stream( [INFO] [stdout] | ++++++ [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Auth` in this scope [INFO] [stdout] --> src/event_handler.rs:65:44 [INFO] [stdout] | [INFO] [stdout] 13 | kafka_event_stream.listen_events::()?, [INFO] [stdout] | ^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 5 | fn event_stream( [INFO] [stdout] | ++++++ [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/lib.rs - (line 7) stdout ---- [INFO] [stdout] error[E0583]: file not found for module `projections` [INFO] [stdout] --> src/lib.rs:13:1 [INFO] [stdout] | [INFO] [stdout] 8 | 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] = note: if there is a `mod projections` elsewhere in the crate already, import it with `use crate::...` instead [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `tokio` [INFO] [stdout] --> src/lib.rs:15:3 [INFO] [stdout] | [INFO] [stdout] 10 | #[tokio::main] [INFO] [stdout] | ^^^^^ use of unresolved module or unlinked crate `tokio` [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `tracing_subscriber` [INFO] [stdout] --> src/lib.rs:17:5 [INFO] [stdout] | [INFO] [stdout] 12 | tracing_subscriber::fmt().init(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `tracing_subscriber` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `tracing_subscriber`, use `cargo add tracing_subscriber` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Database` [INFO] [stdout] --> src/lib.rs:22:14 [INFO] [stdout] | [INFO] [stdout] 17 | 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 unresolved module or unlinked crate `tokio` [INFO] [stdout] --> src/lib.rs:24:19 [INFO] [stdout] | [INFO] [stdout] 19 | let handles = spawn_event_handlers!( [INFO] [stdout] | ___________________^ [INFO] [stdout] 20 | | kafka_host, [INFO] [stdout] 21 | | ("bank-account", BankAccountProjection::new(db.clone())), [INFO] [stdout] 22 | | ("assets", AssetsProjection::new(db)), [INFO] [stdout] 23 | | ); [INFO] [stdout] | |_____^ use of unresolved module or unlinked crate `tokio` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `tokio`, use `cargo add tokio` to add it to your `Cargo.toml` [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:16:1 [INFO] [stdout] | [INFO] [stdout] 11 | async fn main() -> Result<(), Box> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `main` function is not allowed to be `async` [INFO] [stdout] [INFO] [stdout] error: aborting due to 6 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0433, E0583, 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 0.58s [INFO] [stdout] [INFO] [stderr] error: doctest failed, to rerun pass `--doc` [INFO] running `Command { std: "docker" "inspect" "f250451998757b4bc9aeaf33921d3ab8d36dc3ecb61137f523cf8dcb8e159303", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "f250451998757b4bc9aeaf33921d3ab8d36dc3ecb61137f523cf8dcb8e159303", kill_on_drop: false }` [INFO] [stdout] f250451998757b4bc9aeaf33921d3ab8d36dc3ecb61137f523cf8dcb8e159303