[INFO] fetching crate thalo-kafka 0.5.0... [INFO] testing thalo-kafka-0.5.0 against master#c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38 for pr-146098-8 [INFO] extracting crate thalo-kafka 0.5.0 into /workspace/builds/worker-7-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-7-tc1/source/Cargo.toml [INFO] validating manifest of crates.io crate thalo-kafka 0.5.0 on toolchain c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "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" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "generate-lockfile" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Updating crates.io index [INFO] [stderr] Locking 78 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.17) [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded thalo v0.5.0 [INFO] [stderr] Downloaded rdkafka v0.28.0 [INFO] [stderr] Downloaded rdkafka-sys v4.9.0+2.10.0 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-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:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 9f1274f97feab6e128a92e21b0301b3aac5c777c4ddf908188714a585f8a8995 [INFO] running `Command { std: "docker" "start" "-a" "9f1274f97feab6e128a92e21b0301b3aac5c777c4ddf908188714a585f8a8995", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "9f1274f97feab6e128a92e21b0301b3aac5c777c4ddf908188714a585f8a8995", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "9f1274f97feab6e128a92e21b0301b3aac5c777c4ddf908188714a585f8a8995", kill_on_drop: false }` [INFO] [stdout] 9f1274f97feab6e128a92e21b0301b3aac5c777c4ddf908188714a585f8a8995 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-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:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] c2fd64736ec02fd68115431b3622b3d8f113008e6b8866e41fab72553b8d1fd1 [INFO] running `Command { std: "docker" "start" "-a" "c2fd64736ec02fd68115431b3622b3d8f113008e6b8866e41fab72553b8d1fd1", kill_on_drop: false }` [INFO] [stderr] Compiling memchr v2.7.6 [INFO] [stderr] Compiling futures-channel v0.3.31 [INFO] [stderr] Compiling tokio v1.48.0 [INFO] [stderr] Compiling rdkafka-sys v4.9.0+2.10.0 [INFO] [stderr] Compiling syn v2.0.110 [INFO] [stderr] Compiling libz-sys v1.1.23 [INFO] [stderr] Compiling serde_json v1.0.145 [INFO] [stderr] Compiling tokio-util v0.7.17 [INFO] [stderr] Compiling tokio-stream v0.1.17 [INFO] [stderr] Compiling futures-macro v0.3.31 [INFO] [stderr] Compiling serde_derive v1.0.228 [INFO] [stderr] Compiling num_enum_derive v0.7.5 [INFO] [stderr] Compiling async-stream-impl v0.3.6 [INFO] [stderr] Compiling thiserror-impl v1.0.69 [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 futures-util v0.3.31 [INFO] [stderr] Compiling num_enum v0.7.5 [INFO] [stderr] Compiling tracing v0.1.41 [INFO] [stderr] Compiling thiserror v1.0.69 [INFO] [stderr] Compiling serde v1.0.228 [INFO] [stderr] Compiling futures-executor v0.3.31 [INFO] [stderr] Compiling chrono v0.4.42 [INFO] [stderr] Compiling futures v0.3.31 [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 47.11s [INFO] running `Command { std: "docker" "inspect" "c2fd64736ec02fd68115431b3622b3d8f113008e6b8866e41fab72553b8d1fd1", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "c2fd64736ec02fd68115431b3622b3d8f113008e6b8866e41fab72553b8d1fd1", kill_on_drop: false }` [INFO] [stdout] c2fd64736ec02fd68115431b3622b3d8f113008e6b8866e41fab72553b8d1fd1 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-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:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 4e96af5a2ef9f19c14d03054fa4d8b5a6466564aea8c4d9e7fff4e14f9c6eed1 [INFO] running `Command { std: "docker" "start" "-a" "4e96af5a2ef9f19c14d03054fa4d8b5a6466564aea8c4d9e7fff4e14f9c6eed1", 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 0.68s [INFO] running `Command { std: "docker" "inspect" "4e96af5a2ef9f19c14d03054fa4d8b5a6466564aea8c4d9e7fff4e14f9c6eed1", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "4e96af5a2ef9f19c14d03054fa4d8b5a6466564aea8c4d9e7fff4e14f9c6eed1", kill_on_drop: false }` [INFO] [stdout] 4e96af5a2ef9f19c14d03054fa4d8b5a6466564aea8c4d9e7fff4e14f9c6eed1 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-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:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "test" "--frozen", kill_on_drop: false }` [INFO] [stdout] d835f85db3018585044e4205b8c5e7b1124bcad94aff24e1e3fa774be33829fd [INFO] running `Command { std: "docker" "start" "-a" "d835f85db3018585044e4205b8c5e7b1124bcad94aff24e1e3fa774be33829fd", kill_on_drop: false }` [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 0.09s [INFO] [stderr] Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/thalo_kafka-f92bc214075d744f) [INFO] [stdout] [INFO] [stdout] running 2 tests [INFO] [stderr] Doc-tests thalo_kafka [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/lib.rs - spawn_event_handlers (line 63) ... FAILED [INFO] [stdout] test src/event_handler.rs - event_handler::WatchEventHandler::watch (line 87) ... FAILED [INFO] [stdout] test src/event_handler.rs - event_handler::WatchEventHandler::watch (line 105) ... 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::event_stream (line 43) ... FAILED [INFO] [stdout] test src/lib.rs - (line 7) ... 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/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] 64 | #[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] 71 | let handles = spawn_event_handlers!( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] help: consider importing this macro [INFO] [stdout] | [INFO] [stdout] 64 + 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] 69 | 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] 65 | 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::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] 88 | #[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] 93 | 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] 95 | 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] 89 | 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::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] 106 | #[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] 121 | 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] 111 | 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] 114 | ("bank-account", BankAccountProjection::new(db.clone())), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ use of undeclared type `BankAccountProjection` [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> src/event_handler.rs:111:9 [INFO] [stdout] | [INFO] [stdout] 111 | let db = Database::connect(&database_url).await?; [INFO] [stdout] | ^^ [INFO] [stdout] ... [INFO] [stdout] 114 | ("bank-account", BankAccountProjection::new(db.clone())), [INFO] [stdout] | -- type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `db` an explicit type [INFO] [stdout] | [INFO] [stdout] 111 | let db: /* Type */ = Database::connect(&database_url).await?; [INFO] [stdout] | ++++++++++++ [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] 115 | ("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] 121 | 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[E0282]: type annotations needed for `(_, _)` [INFO] [stdout] --> src/event_handler.rs:120:15 [INFO] [stdout] | [INFO] [stdout] 120 | .map(|(group_id, projection)| { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] 121 | tokio::spawn(async move { projection.watch(&redpanda_host, group_id).await }) [INFO] [stdout] | ---------- type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving this closure parameter an explicit type, where the placeholders `_` are specified [INFO] [stdout] | [INFO] [stdout] 120 | .map(|(group_id, projection): (_, _)| { [INFO] [stdout] | ++++++++ [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] 107 | async fn main() -> Result<(), Box> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `main` function is not allowed to be `async` [INFO] [stdout] [INFO] [stdout] error: aborting due to 9 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0282, E0425, E0433, E0752. [INFO] [stdout] For more information about an error, try `rustc --explain E0282`. [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] 58 | kafka_event_stream: &KafkaEventStream, [INFO] [stdout] | ^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 54 + 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] 60 | 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] 54 + 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] 60 | 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] 54 + 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] 60 | 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] 57 | 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] 63 | 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] 54 + use futures_util::StreamExt; [INFO] [stdout] | [INFO] [stdout] help: if you import `StreamExt`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 63 - let stream = tokio_stream::StreamExt::merge( [INFO] [stdout] 63 + 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] 64 | 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] 57 | 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] 65 | 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] 57 | 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/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] 46 | kafka_event_stream: &KafkaEventStream, [INFO] [stdout] | ^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 42 + 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] 48 | 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] 42 + 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] 48 | 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] 42 + 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] 48 | 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] 45 | 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] 51 | 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] 45 | 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/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] 13 | 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] 15 | #[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] 17 | 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] 22 | let db = Database::connect(&database_url).await?; [INFO] [stdout] | ^^^^^^^^ use of undeclared type `Database` [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> src/lib.rs:22:9 [INFO] [stdout] | [INFO] [stdout] 22 | let db = Database::connect(&database_url).await?; [INFO] [stdout] | ^^ [INFO] [stdout] ... [INFO] [stdout] 26 | ("bank-account", BankAccountProjection::new(db.clone())), [INFO] [stdout] | -- type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `db` an explicit type [INFO] [stdout] | [INFO] [stdout] 22 | let db: /* Type */ = Database::connect(&database_url).await?; [INFO] [stdout] | ++++++++++++ [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] 24 | let handles = spawn_event_handlers!( [INFO] [stdout] | ___________________^ [INFO] [stdout] 25 | | kafka_host, [INFO] [stdout] 26 | | ("bank-account", BankAccountProjection::new(db.clone())), [INFO] [stdout] 27 | | ("assets", AssetsProjection::new(db)), [INFO] [stdout] 28 | | ); [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] 16 | 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: E0282, E0433, E0583, E0752. [INFO] [stdout] For more information about an error, try `rustc --explain E0282`. [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.22s [INFO] [stdout] [INFO] [stderr] error: doctest failed, to rerun pass `--doc` [INFO] running `Command { std: "docker" "inspect" "d835f85db3018585044e4205b8c5e7b1124bcad94aff24e1e3fa774be33829fd", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "d835f85db3018585044e4205b8c5e7b1124bcad94aff24e1e3fa774be33829fd", kill_on_drop: false }` [INFO] [stdout] d835f85db3018585044e4205b8c5e7b1124bcad94aff24e1e3fa774be33829fd