[INFO] cloning repository https://github.com/fahlevi77/engine [INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/fahlevi77/engine" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Ffahlevi77%2Fengine", kill_on_drop: false }` [INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Ffahlevi77%2Fengine'... [INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }` [INFO] [stdout] 2643b4869c4f859968e06cf80390f37a16ce7045 [INFO] checking fahlevi77/engine against master#42f4793e5a514858221b07ac379029d90353913e for pr-148952 [INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Ffahlevi77%2Fengine" "/workspace/builds/worker-2-tc1/source", kill_on_drop: false }` [INFO] [stderr] Cloning into '/workspace/builds/worker-2-tc1/source'... [INFO] [stderr] done. [INFO] started tweaking git repo https://github.com/fahlevi77/engine [INFO] finished tweaking git repo https://github.com/fahlevi77/engine [INFO] tweaked toml for git repo https://github.com/fahlevi77/engine written to /workspace/builds/worker-2-tc1/source/Cargo.toml [INFO] validating manifest of git repo https://github.com/fahlevi77/engine on toolchain 42f4793e5a514858221b07ac379029d90353913e [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+42f4793e5a514858221b07ac379029d90353913e" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] crate git repo https://github.com/fahlevi77/engine 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" "+42f4793e5a514858221b07ac379029d90353913e" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Updating crates.io index [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded tokio-io-timeout v1.2.1 [INFO] [stderr] Downloaded nom-tracable-macros v0.9.1 [INFO] [stderr] Downloaded bytecount v0.6.9 [INFO] [stderr] Downloaded sdd v3.0.10 [INFO] [stderr] Downloaded deadpool-redis v0.15.1 [INFO] [stderr] Downloaded consul v0.4.2 [INFO] [stderr] Downloaded kube-derive v0.87.2 [INFO] [stderr] Downloaded etcd-rs v1.0.1 [INFO] [stderr] Downloaded kube-runtime v0.87.2 [INFO] [stderr] Downloaded scc v2.4.0 [INFO] [stderr] Downloaded kube-client v0.87.2 [INFO] [stderr] Downloaded rusqlite v0.29.0 [INFO] [stderr] Downloaded sqlparser v0.39.0 [INFO] [stderr] Downloaded kube-core v0.87.2 [INFO] [stderr] Downloaded json-patch v1.4.0 [INFO] [stderr] Downloaded vault v10.1.5 [INFO] [stderr] Downloaded cron v0.11.0 [INFO] [stderr] Downloaded jsonpath-rust v0.3.5 [INFO] [stderr] Downloaded redis v0.25.4 [INFO] [stderr] Downloaded kube v0.87.2 [INFO] [stderr] Downloaded nom-tracable v0.9.1 [INFO] [stderr] Downloaded k8s-openapi v0.20.0 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-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" "+42f4793e5a514858221b07ac379029d90353913e" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 3d08affde24c5a7e85dc880778d5bd0b446f744b34ec92c0355873590cc4857e [INFO] running `Command { std: "docker" "start" "-a" "3d08affde24c5a7e85dc880778d5bd0b446f744b34ec92c0355873590cc4857e", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "3d08affde24c5a7e85dc880778d5bd0b446f744b34ec92c0355873590cc4857e", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "3d08affde24c5a7e85dc880778d5bd0b446f744b34ec92c0355873590cc4857e", kill_on_drop: false }` [INFO] [stdout] 3d08affde24c5a7e85dc880778d5bd0b446f744b34ec92c0355873590cc4857e [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-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" "+42f4793e5a514858221b07ac379029d90353913e" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] c322fcd1a43e63883d44db0d524dc226ad54bea6636c88880922b7b0414118ea [INFO] running `Command { std: "docker" "start" "-a" "c322fcd1a43e63883d44db0d524dc226ad54bea6636c88880922b7b0414118ea", kill_on_drop: false }` [INFO] [stderr] Compiling syn v2.0.106 [INFO] [stderr] Compiling either v1.15.0 [INFO] [stderr] Compiling libc v0.2.174 [INFO] [stderr] Compiling anyhow v1.0.99 [INFO] [stderr] Compiling memchr v2.7.5 [INFO] [stderr] Compiling rustversion v1.0.21 [INFO] [stderr] Checking parking_lot_core v0.9.11 [INFO] [stderr] Checking signal-hook-registry v1.4.6 [INFO] [stderr] Checking hashbrown v0.15.4 [INFO] [stderr] Checking socket2 v0.5.10 [INFO] [stderr] Checking rand v0.8.5 [INFO] [stderr] Compiling smallvec v1.15.1 [INFO] [stderr] Compiling prettyplease v0.2.37 [INFO] [stderr] Compiling crunchy v0.2.4 [INFO] [stderr] Compiling bytes v1.10.1 [INFO] [stderr] Compiling itertools v0.11.0 [INFO] [stderr] Checking parking_lot v0.12.4 [INFO] [stderr] Compiling rustix v1.0.8 [INFO] [stderr] Compiling lock_api v0.4.13 [INFO] [stderr] Compiling indexmap v1.9.3 [INFO] [stderr] Compiling multimap v0.10.1 [INFO] [stderr] Compiling new_debug_unreachable v1.0.6 [INFO] [stderr] Compiling rustls v0.22.4 [INFO] [stderr] Compiling tiny-keccak v2.0.2 [INFO] [stderr] Checking indexmap v2.10.0 [INFO] [stderr] Checking form_urlencoded v1.2.2 [INFO] [stderr] Compiling ena v0.14.3 [INFO] [stderr] Compiling unicode-xid v0.2.6 [INFO] [stderr] Checking regex-automata v0.4.9 [INFO] [stderr] Checking hashbrown v0.14.5 [INFO] [stderr] Checking num_cpus v1.17.0 [INFO] [stderr] Checking getrandom v0.3.3 [INFO] [stderr] Checking option-ext v0.2.0 [INFO] [stderr] Checking sha1_smol v1.0.1 [INFO] [stderr] Compiling aho-corasick v1.1.3 [INFO] [stderr] Checking arc-swap v1.7.1 [INFO] [stderr] Compiling snap v1.1.1 [INFO] [stderr] Compiling jobserver v0.1.33 [INFO] [stderr] Compiling dirs-sys-next v0.1.2 [INFO] [stderr] Compiling axum-core v0.3.4 [INFO] [stderr] Compiling axum v0.6.20 [INFO] [stderr] Compiling petgraph v0.6.5 [INFO] [stderr] Compiling cc v1.2.29 [INFO] [stderr] Compiling tempfile v3.20.0 [INFO] [stderr] Checking clap_builder v4.5.41 [INFO] [stderr] Checking dirs-sys v0.4.1 [INFO] [stderr] Checking nom v7.1.3 [INFO] [stderr] Compiling dirs-next v2.0.0 [INFO] [stderr] Checking fallible-iterator v0.2.0 [INFO] [stderr] Checking unsafe-libyaml v0.2.11 [INFO] [stderr] Compiling term v0.7.0 [INFO] [stderr] Checking rayon v1.10.0 [INFO] [stderr] Checking dirs v5.0.1 [INFO] [stderr] Checking hashlink v0.8.4 [INFO] [stderr] Compiling string_cache v0.8.9 [INFO] [stderr] Checking crossbeam v0.8.4 [INFO] [stderr] Checking uuid v1.17.0 [INFO] [stderr] Checking sqlparser v0.39.0 [INFO] [stderr] Checking libloading v0.8.8 [INFO] [stderr] Compiling ascii-canvas v3.0.0 [INFO] [stderr] Checking thread_local v1.1.9 [INFO] [stderr] Checking sdd v3.0.10 [INFO] [stderr] Checking scc v2.4.0 [INFO] [stderr] Checking lalrpop-util v0.20.2 [INFO] [stderr] Checking regex v1.11.1 [INFO] [stderr] Compiling ring v0.17.14 [INFO] [stderr] Compiling zstd-sys v2.0.15+zstd.1.5.7 [INFO] [stderr] Compiling lz4-sys v1.11.1+lz4-1.10.0 [INFO] [stderr] Compiling libsqlite3-sys v0.26.0 [INFO] [stderr] Compiling synstructure v0.13.2 [INFO] [stderr] Compiling lalrpop v0.20.2 [INFO] [stderr] Compiling tokio-macros v2.5.0 [INFO] [stderr] Compiling zerofrom-derive v0.1.6 [INFO] [stderr] Compiling yoke-derive v0.8.0 [INFO] [stderr] Compiling zerovec-derive v0.11.1 [INFO] [stderr] Compiling futures-macro v0.3.31 [INFO] [stderr] Compiling displaydoc v0.2.5 [INFO] [stderr] Compiling prost-derive v0.12.6 [INFO] [stderr] Compiling serde_derive v1.0.219 [INFO] [stderr] Compiling pin-project-internal v1.1.10 [INFO] [stderr] Compiling tracing-attributes v0.1.30 [INFO] [stderr] Checking tokio v1.47.1 [INFO] [stderr] Compiling async-trait v0.1.89 [INFO] [stderr] Checking futures-util v0.3.31 [INFO] [stderr] Compiling zstd-safe v7.2.4 [INFO] [stderr] Compiling async-stream-impl v0.3.6 [INFO] [stderr] Checking pin-project v1.1.10 [INFO] [stderr] Compiling clap_derive v4.5.41 [INFO] [stderr] Compiling thiserror-impl v1.0.69 [INFO] [stderr] Checking zstd v0.13.3 [INFO] [stderr] Checking async-stream v0.3.6 [INFO] [stderr] Compiling prost v0.12.6 [INFO] [stderr] Checking zerofrom v0.1.6 [INFO] [stderr] Checking yoke v0.8.0 [INFO] [stderr] Compiling prost-types v0.12.6 [INFO] [stderr] Compiling serial_test_derive v3.2.0 [INFO] [stderr] Checking tracing v0.1.41 [INFO] [stderr] Checking zerovec v0.11.4 [INFO] [stderr] Checking zerotrie v0.2.2 [INFO] [stderr] Checking rustls-webpki v0.102.8 [INFO] [stderr] Checking thiserror v1.0.69 [INFO] [stderr] Checking serde v1.0.219 [INFO] [stderr] Checking clap v4.5.41 [INFO] [stderr] Checking tinystr v0.8.1 [INFO] [stderr] Checking potential_utf v0.1.2 [INFO] [stderr] Checking icu_collections v2.0.0 [INFO] [stderr] Checking icu_locale_core v2.0.0 [INFO] [stderr] Compiling prost-build v0.12.6 [INFO] [stderr] Checking icu_provider v2.0.0 [INFO] [stderr] Compiling tonic-build v0.11.0 [INFO] [stderr] Checking icu_properties v2.0.1 [INFO] [stderr] Checking icu_normalizer v2.0.0 [INFO] [stderr] Checking futures-executor v0.3.31 [INFO] [stderr] Checking futures v0.3.31 [INFO] [stderr] Checking serial_test v3.2.0 [INFO] [stderr] Checking idna_adapter v1.2.1 [INFO] [stderr] Checking idna v1.1.0 [INFO] [stderr] Checking url v2.5.6 [INFO] [stderr] Checking chrono v0.4.41 [INFO] [stderr] Checking serde_json v1.0.142 [INFO] [stderr] Checking serde_yaml v0.9.34+deprecated [INFO] [stderr] Checking bincode v1.3.3 [INFO] [stderr] Checking tokio-util v0.7.16 [INFO] [stderr] Checking tokio-retry v0.3.0 [INFO] [stderr] Checking tokio-io-timeout v1.2.1 [INFO] [stderr] Checking deadpool-runtime v0.1.4 [INFO] [stderr] Checking tokio-stream v0.1.17 [INFO] [stderr] Checking tokio-rustls v0.25.0 [INFO] [stderr] Checking deadpool v0.12.2 [INFO] [stderr] Checking lz4 v1.28.1 [INFO] [stderr] Checking h2 v0.3.27 [INFO] [stderr] Checking combine v4.6.7 [INFO] [stderr] Checking tower v0.4.13 [INFO] [stderr] Checking cron v0.11.0 [INFO] [stderr] Checking rusqlite v0.29.0 [INFO] [stderr] Compiling eventflux_rust v0.1.0 (/opt/rustwide/workdir) [INFO] [stderr] Checking hyper v0.14.32 [INFO] [stderr] Checking redis v0.25.4 [INFO] [stderr] Checking hyper-timeout v0.4.1 [INFO] [stderr] Checking deadpool-redis v0.15.1 [INFO] [stderr] Checking tonic v0.11.0 [INFO] [stdout] warning: unused import: `std::collections::HashMap` [INFO] [stdout] --> src/core/distributed/distributed_runtime.rs:11:5 [INFO] [stdout] | [INFO] [stdout] 11 | use std::collections::HashMap; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Server` [INFO] [stdout] --> src/core/distributed/grpc/simple_transport.rs:18:33 [INFO] [stdout] | [INFO] [stdout] 18 | use tonic::transport::{Channel, Server}; [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Response` and `Status` [INFO] [stdout] --> src/core/distributed/grpc/simple_transport.rs:19:22 [INFO] [stdout] | [INFO] [stdout] 19 | use tonic::{Request, Response, Status}; [INFO] [stdout] | ^^^^^^^^ ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `TransportServer` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:11:62 [INFO] [stdout] | [INFO] [stdout] 11 | use super::transport_server::{Transport as TransportService, TransportServer}; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `EventRequest` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:13:35 [INFO] [stdout] | [INFO] [stdout] 13 | ClusterInfo, CompressionType, EventRequest, HeartbeatRequest, HeartbeatResponse, MessageType, [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `StreamExt` and `Stream` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:24:15 [INFO] [stdout] | [INFO] [stdout] 24 | use futures::{Stream, StreamExt}; [INFO] [stdout] | ^^^^^^ ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Identity`, `ServerTlsConfig`, and `Server` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:30:63 [INFO] [stdout] | [INFO] [stdout] 30 | use tonic::transport::{Certificate, Channel, ClientTlsConfig, Identity, Server, ServerTlsConfig}; [INFO] [stdout] | ^^^^^^^^ ^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Streaming` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:31:40 [INFO] [stdout] | [INFO] [stdout] 31 | use tonic::{Request, Response, Status, Streaming}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tower::service_fn` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:32:5 [INFO] [stdout] | [INFO] [stdout] 32 | use tower::service_fn; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `DistributedError` [INFO] [stdout] --> src/core/distributed/coordinator.rs:10:13 [INFO] [stdout] | [INFO] [stdout] 10 | use super::{DistributedError, DistributedResult}; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `DistributedError` [INFO] [stdout] --> src/core/distributed/message_broker.rs:10:13 [INFO] [stdout] | [INFO] [stdout] 10 | use super::{DistributedError, DistributedResult}; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::sync::Arc` [INFO] [stdout] --> src/core/distributed/mod.rs:23:5 [INFO] [stdout] | [INFO] [stdout] 23 | use std::sync::Arc; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `AccessPattern`, `ChangeLog`, and `StateSize` [INFO] [stdout] --> src/core/persistence/state_manager.rs:15:5 [INFO] [stdout] | [INFO] [stdout] 15 | AccessPattern, ChangeLog, CheckpointId, ComponentId, CompressionType, SerializationHints, [INFO] [stdout] | ^^^^^^^^^^^^^ ^^^^^^^^^ [INFO] [stdout] 16 | StateError, StateHolder, StateSize, StateSnapshot, [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `ComponentId` [INFO] [stdout] --> src/core/query/processor/stream/window/session_window_state_holder.rs:20:45 [INFO] [stdout] | [INFO] [stdout] 20 | AccessPattern, ChangeLog, CheckpointId, ComponentId, CompressionType, SchemaVersion, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `session_window_state_holder::SessionWindowStateHolder` [INFO] [stdout] --> src/core/query/processor/stream/window/mod.rs:30:5 [INFO] [stdout] | [INFO] [stdout] 30 | use session_window_state_holder::SessionWindowStateHolder; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `ProcessorConfigReader` and `eventflux_context::EventFluxContext` [INFO] [stdout] --> src/core/query/processor/stream/window/sort_window_processor.rs:7:49 [INFO] [stdout] | [INFO] [stdout] 7 | eventflux_app_context::EventFluxAppContext, eventflux_context::EventFluxContext, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] 8 | eventflux_query_context::EventFluxQueryContext, ConfigValue, ProcessorConfigReader, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Sink` [INFO] [stdout] --> src/core/stream/output/sink/sink_factory.rs:8:50 [INFO] [stdout] | [INFO] [stdout] 8 | use crate::core::stream::output::sink::{LogSink, Sink}; [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::query_api::execution::query::selection::selector::Selector` [INFO] [stdout] --> src/sql_compiler/converter.rs:19:5 [INFO] [stdout] | [INFO] [stdout] 19 | use crate::query_api::execution::query::selection::selector::Selector; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `super::preprocessor::TimeUnit` [INFO] [stdout] --> src/sql_compiler/converter.rs:405:13 [INFO] [stdout] | [INFO] [stdout] 405 | use super::preprocessor::TimeUnit; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::query_api::definition::attribute::Type as AttributeType` [INFO] [stdout] --> src/sql_compiler/ddl.rs:11:5 [INFO] [stdout] | [INFO] [stdout] 11 | use crate::query_api::definition::attribute::Type as AttributeType; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `sqlparser::ast::Expr as SqlExpr` [INFO] [stdout] --> src/sql_compiler/preprocessor.rs:10:5 [INFO] [stdout] | [INFO] [stdout] 10 | use sqlparser::ast::Expr as SqlExpr; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:290:13 [INFO] [stdout] | [INFO] [stdout] 290 | let mut client = TransportClient::new(channel); [INFO] [stdout] | ----^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Transport` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:11:31 [INFO] [stdout] | [INFO] [stdout] 11 | use super::transport_server::{Transport as TransportService, TransportServer}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `eventflux_app_string` [INFO] [stdout] --> src/core/eventflux_app_runtime.rs:172:9 [INFO] [stdout] | [INFO] [stdout] 172 | eventflux_app_string: Option, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_eventflux_app_string` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable `is_playback` is assigned to, but never used [INFO] [stdout] --> src/core/eventflux_app_runtime.rs:177:13 [INFO] [stdout] | [INFO] [stdout] 177 | let mut is_playback = false; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: consider using `_is_playback` instead [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable `enforce_order` is assigned to, but never used [INFO] [stdout] --> src/core/eventflux_app_runtime.rs:178:13 [INFO] [stdout] | [INFO] [stdout] 178 | let mut enforce_order = false; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: consider using `_enforce_order` instead [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: value assigned to `is_playback` is never read [INFO] [stdout] --> src/core/eventflux_app_runtime.rs:203:35 [INFO] [stdout] | [INFO] [stdout] 203 | "playback" => is_playback = el.value.eq_ignore_ascii_case("true"), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = help: maybe it is overwritten before being read? [INFO] [stdout] = note: `#[warn(unused_assignments)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: value assigned to `enforce_order` is never read [INFO] [stdout] --> src/core/eventflux_app_runtime.rs:205:25 [INFO] [stdout] | [INFO] [stdout] 205 | enforce_order = el.value.eq_ignore_ascii_case("true") [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = help: maybe it is overwritten before being read? [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `connection` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:356:29 [INFO] [stdout] | [INFO] [stdout] 356 | async fn receive(&self, connection: &Connection) -> DistributedResult { [INFO] [stdout] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_connection` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/distributed/processing_engine.rs:242:17 [INFO] [stdout] | [INFO] [stdout] 242 | let mut junction = junction.lock().await; [INFO] [stdout] | ----^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `event` [INFO] [stdout] --> src/core/distributed/processing_engine.rs:329:52 [INFO] [stdout] | [INFO] [stdout] 329 | async fn process_event(&self, stream_id: &str, event: Event) -> DistributedResult<()> { [INFO] [stdout] | ^^^^^ help: if this is intentional, prefix it with an underscore: `_event` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `query_id` [INFO] [stdout] --> src/core/distributed/processing_engine.rs:507:34 [INFO] [stdout] | [INFO] [stdout] 507 | async fn assign_query(&self, query_id: &str) -> DistributedResult { [INFO] [stdout] | ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_query_id` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `component` [INFO] [stdout] --> src/core/persistence/state_manager.rs:415:9 [INFO] [stdout] | [INFO] [stdout] 415 | component: Arc, [INFO] [stdout] | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_component` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `snapshot` [INFO] [stdout] --> src/core/persistence/state_manager.rs:416:9 [INFO] [stdout] | [INFO] [stdout] 416 | snapshot: StateSnapshot, [INFO] [stdout] | ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_snapshot` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `component` [INFO] [stdout] --> src/core/persistence/state_manager.rs:429:13 [INFO] [stdout] | [INFO] [stdout] 429 | let component = self [INFO] [stdout] | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_component` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `analysis` [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:486:13 [INFO] [stdout] | [INFO] [stdout] 486 | let analysis = self.analyze_chain(incrementals); [INFO] [stdout] | ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_analysis` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `start_time` [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:541:13 [INFO] [stdout] | [INFO] [stdout] 541 | let start_time = Instant::now(); [INFO] [stdout] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_start_time` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `before` [INFO] [stdout] --> src/core/persistence/incremental/persistence_backend.rs:548:35 [INFO] [stdout] | [INFO] [stdout] 548 | fn cleanup_checkpoints(&self, before: Instant) -> Result { [INFO] [stdout] | ^^^^^^ help: if this is intentional, prefix it with an underscore: `_before` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `operation` [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:432:21 [INFO] [stdout] | [INFO] [stdout] 432 | for operation in &changes.operations { [INFO] [stdout] | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_operation` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `component_id` [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:459:14 [INFO] [stdout] | [INFO] [stdout] 459 | for (component_id, snapshot) in results { [INFO] [stdout] | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_component_id` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `segment_id` [INFO] [stdout] --> src/core/persistence/incremental/write_ahead_log.rs:404:19 [INFO] [stdout] | [INFO] [stdout] 404 | for (&segment_id, segment) in completed_segments.iter() { [INFO] [stdout] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_segment_id` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/processor/stream/window/length_window_state_holder.rs:277:35 [INFO] [stdout] | [INFO] [stdout] 277 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/processor/stream/window/time_window_state_holder.rs:197:13 [INFO] [stdout] | [INFO] [stdout] 197 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/processor/stream/window/length_batch_window_state_holder.rs:232:13 [INFO] [stdout] | [INFO] [stdout] 232 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/processor/stream/window/length_batch_window_state_holder.rs:331:35 [INFO] [stdout] | [INFO] [stdout] 331 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/processor/stream/window/time_batch_window_state_holder.rs:271:13 [INFO] [stdout] | [INFO] [stdout] 271 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/processor/stream/window/time_batch_window_state_holder.rs:388:35 [INFO] [stdout] | [INFO] [stdout] 388 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/processor/stream/window/external_time_window_state_holder.rs:177:13 [INFO] [stdout] | [INFO] [stdout] 177 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/processor/stream/window/external_time_window_state_holder.rs:272:35 [INFO] [stdout] | [INFO] [stdout] 272 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/sum_aggregator_state_holder.rs:161:13 [INFO] [stdout] | [INFO] [stdout] 161 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/sum_aggregator_state_holder.rs:244:35 [INFO] [stdout] | [INFO] [stdout] 244 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/count_aggregator_state_holder.rs:123:13 [INFO] [stdout] | [INFO] [stdout] 123 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/count_aggregator_state_holder.rs:204:35 [INFO] [stdout] | [INFO] [stdout] 204 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/avg_aggregator_state_holder.rs:158:13 [INFO] [stdout] | [INFO] [stdout] 158 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/avg_aggregator_state_holder.rs:240:35 [INFO] [stdout] | [INFO] [stdout] 240 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/min_aggregator_state_holder.rs:136:13 [INFO] [stdout] | [INFO] [stdout] 136 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/min_aggregator_state_holder.rs:218:35 [INFO] [stdout] | [INFO] [stdout] 218 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/max_aggregator_state_holder.rs:136:13 [INFO] [stdout] | [INFO] [stdout] 136 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/max_aggregator_state_holder.rs:218:35 [INFO] [stdout] | [INFO] [stdout] 218 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/distinctcount_aggregator_state_holder.rs:152:13 [INFO] [stdout] | [INFO] [stdout] 152 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/distinctcount_aggregator_state_holder.rs:233:35 [INFO] [stdout] | [INFO] [stdout] 233 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `shutdown_flag` [INFO] [stdout] --> src/core/stream/optimized_stream_junction.rs:348:13 [INFO] [stdout] | [INFO] [stdout] 348 | let shutdown_flag = Arc::clone(&self.shutdown); [INFO] [stdout] | ^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_shutdown_flag` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `where_clause` [INFO] [stdout] --> src/sql_compiler/converter.rs:274:9 [INFO] [stdout] | [INFO] [stdout] 274 | where_clause: &Option, [INFO] [stdout] | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_where_clause` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `get_name` is never used [INFO] [stdout] --> src/core/eventflux_manager.rs:524:8 [INFO] [stdout] | [INFO] [stdout] 523 | impl ApiEventFluxApp { [INFO] [stdout] | -------------------- method in this implementation [INFO] [stdout] 524 | fn get_name(&self) -> Option { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `is_kubernetes_environment` is never used [INFO] [stdout] --> src/core/config/manager.rs:119:8 [INFO] [stdout] | [INFO] [stdout] 53 | impl ConfigManager { [INFO] [stdout] | ------------------ method in this implementation [INFO] [stdout] ... [INFO] [stdout] 119 | fn is_kubernetes_environment(&self) -> bool { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `extract_config_value` is never used [INFO] [stdout] --> src/core/config/processor_config_reader.rs:272:8 [INFO] [stdout] | [INFO] [stdout] 33 | impl ProcessorConfigReader { [INFO] [stdout] | -------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 272 | fn extract_config_value( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `config` is never read [INFO] [stdout] --> src/core/config/security.rs:340:5 [INFO] [stdout] | [INFO] [stdout] 335 | pub struct ExternalSecretProvider { [INFO] [stdout] | ---------------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 340 | config: HashMap, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `ExternalSecretProvider` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `server_handle` is never read [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:41:5 [INFO] [stdout] | [INFO] [stdout] 35 | pub struct GrpcTransport { [INFO] [stdout] | ------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 41 | server_handle: Arc>>, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `shutdown_tx` and `join_handle` are never read [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:109:5 [INFO] [stdout] | [INFO] [stdout] 107 | struct GrpcServerHandle { [INFO] [stdout] | ---------------- fields in this struct [INFO] [stdout] 108 | /// Shutdown signal [INFO] [stdout] 109 | shutdown_tx: oneshot::Sender<()>, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] 110 | /// Server join handle [INFO] [stdout] 111 | join_handle: tokio::task::JoinHandle>, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `client`, `message_tx`, and `response_rx` are never read [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:123:5 [INFO] [stdout] | [INFO] [stdout] 115 | pub struct GrpcConnection { [INFO] [stdout] | -------------- fields in this struct [INFO] [stdout] ... [INFO] [stdout] 123 | client: TransportClient, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] 124 | /// Message sender for streaming [INFO] [stdout] 125 | message_tx: Option>, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] 126 | /// Response receiver for streaming [INFO] [stdout] 127 | response_rx: Option>, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `server_handle` and `connection_rx` are never read [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:135:5 [INFO] [stdout] | [INFO] [stdout] 131 | pub struct GrpcListener { [INFO] [stdout] | ------------ fields in this struct [INFO] [stdout] ... [INFO] [stdout] 135 | server_handle: Option, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] 136 | /// Connection acceptor [INFO] [stdout] 137 | connection_rx: Arc>>>, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `from_proto_message` and `from_proto_message_type` are never used [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:196:8 [INFO] [stdout] | [INFO] [stdout] 140 | impl GrpcTransport { [INFO] [stdout] | ------------------ methods in this implementation [INFO] [stdout] ... [INFO] [stdout] 196 | fn from_proto_message(&self, proto_msg: &TransportMessage) -> Message { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 218 | fn from_proto_message_type(&self, proto_type: i32) -> LocalMessageType { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `connection_tx` is never read [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:387:5 [INFO] [stdout] | [INFO] [stdout] 385 | pub struct GrpcTransportService { [INFO] [stdout] | -------------------- field in this struct [INFO] [stdout] 386 | /// Connection notifier [INFO] [stdout] 387 | connection_tx: mpsc::UnboundedSender, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `distributed_state` is never read [INFO] [stdout] --> src/core/distributed/processing_engine.rs:428:5 [INFO] [stdout] | [INFO] [stdout] 423 | struct HybridEngine { [INFO] [stdout] | ------------ field in this struct [INFO] [stdout] ... [INFO] [stdout] 428 | distributed_state: Arc>>>, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `config` is never read [INFO] [stdout] --> src/core/distributed/runtime_mode.rs:20:5 [INFO] [stdout] | [INFO] [stdout] 15 | pub struct RuntimeModeManager { [INFO] [stdout] | ------------------ field in this struct [INFO] [stdout] ... [INFO] [stdout] 20 | config: Arc, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `config` is never read [INFO] [stdout] --> src/core/distributed/runtime_mode.rs:191:5 [INFO] [stdout] | [INFO] [stdout] 190 | struct SingleNodeMode { [INFO] [stdout] | -------------- field in this struct [INFO] [stdout] 191 | config: Arc, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `coordinator` and `start_time` are never read [INFO] [stdout] --> src/core/distributed/runtime_mode.rs:266:5 [INFO] [stdout] | [INFO] [stdout] 264 | struct DistributedMode { [INFO] [stdout] | --------------- fields in this struct [INFO] [stdout] 265 | config: Arc, [INFO] [stdout] 266 | coordinator: Option>, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] 267 | start_time: std::time::Instant, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `config` and `distributed_state` are never read [INFO] [stdout] --> src/core/distributed/runtime_mode.rs:374:5 [INFO] [stdout] | [INFO] [stdout] 373 | struct HybridMode { [INFO] [stdout] | ---------- fields in this struct [INFO] [stdout] 374 | config: Arc, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] 375 | single_node: SingleNodeMode, [INFO] [stdout] 376 | distributed_state: Option>, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `0` is never read [INFO] [stdout] --> src/core/distributed/transport.rs:58:10 [INFO] [stdout] | [INFO] [stdout] 58 | Grpc(String), [INFO] [stdout] | ---- ^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | field in this variant [INFO] [stdout] | [INFO] [stdout] = note: `ConnectionHandle` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] help: consider changing the field to be of unit type to suppress this warning while preserving the field numbering, or remove the field [INFO] [stdout] | [INFO] [stdout] 58 - Grpc(String), [INFO] [stdout] 58 + Grpc(()), [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple fields are never read [INFO] [stdout] --> src/core/persistence/incremental/mod.rs:214:5 [INFO] [stdout] | [INFO] [stdout] 212 | pub struct IncrementalCheckpointSystem { [INFO] [stdout] | --------------------------- fields in this struct [INFO] [stdout] 213 | /// System configuration [INFO] [stdout] 214 | config: IncrementalCheckpointConfig, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 217 | wal: Arc, [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 220 | merger: Arc, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 223 | backend: Arc, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 226 | recovery: Arc, [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 229 | coordinator: Option>, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 232 | current_chain: Vec, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | last_full_checkpoint: Option, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 238 | metrics: IncrementalCheckpointMetrics, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `compression_level` is never read [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:114:5 [INFO] [stdout] | [INFO] [stdout] 109 | pub struct CompressionEngine { [INFO] [stdout] | ----------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 114 | compression_level: u8, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `MergeResult` is never constructed [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:141:8 [INFO] [stdout] | [INFO] [stdout] 141 | struct MergeResult { [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `MergedComponentState` is never constructed [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:157:8 [INFO] [stdout] | [INFO] [stdout] 157 | struct MergedComponentState { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `MergeMetadata` is never constructed [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:173:8 [INFO] [stdout] | [INFO] [stdout] 173 | struct MergeMetadata { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `total_checkpoints`, `total_size`, `component_frequencies`, and `operation_counts` are never read [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:725:5 [INFO] [stdout] | [INFO] [stdout] 724 | struct ChainAnalysis { [INFO] [stdout] | ------------- fields in this struct [INFO] [stdout] 725 | total_checkpoints: usize, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] 726 | total_size: usize, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] 727 | component_frequencies: HashMap, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] 728 | operation_counts: HashMap, [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `ChainAnalysis` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `checkpoint_range`, `overlapping_components`, `potential_savings`, and `merge_type` are never read [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:735:5 [INFO] [stdout] | [INFO] [stdout] 734 | struct MergeOpportunity { [INFO] [stdout] | ---------------- fields in this struct [INFO] [stdout] 735 | checkpoint_range: (CheckpointId, CheckpointId), [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] 736 | overlapping_components: usize, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] 737 | potential_savings: usize, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] 738 | merge_type: MergeOpportunityType, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `MergeOpportunity` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variants `ConsecutiveUpdates` and `RedundantOperations` are never constructed [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:746:5 [INFO] [stdout] | [INFO] [stdout] 743 | enum MergeOpportunityType { [INFO] [stdout] | -------------------- variants in this enum [INFO] [stdout] ... [INFO] [stdout] 746 | ConsecutiveUpdates, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] 747 | RedundantOperations, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `MergeOpportunityType` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `last_heartbeat` and `health` are never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:71:5 [INFO] [stdout] | [INFO] [stdout] 57 | struct NodeState { [INFO] [stdout] | --------- fields in this struct [INFO] [stdout] ... [INFO] [stdout] 71 | last_heartbeat: Instant, [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 74 | health: NodeHealth, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `NodeState` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variants `Degraded` and `Failed` are never constructed [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:89:5 [INFO] [stdout] | [INFO] [stdout] 87 | enum NodeHealth { [INFO] [stdout] | ---------- variants in this enum [INFO] [stdout] 88 | Healthy, [INFO] [stdout] 89 | Degraded { reason: String }, [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] 90 | Failed { reason: String }, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `NodeHealth` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `node_id`, `endpoints`, `last_seen`, and `capabilities` are never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:97:5 [INFO] [stdout] | [INFO] [stdout] 95 | struct NodeInfo { [INFO] [stdout] | -------- fields in this struct [INFO] [stdout] 96 | /// Node identifier [INFO] [stdout] 97 | node_id: String, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 100 | endpoints: Vec, [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 103 | last_seen: Instant, [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 106 | capabilities: NodeCapabilities, [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `NodeInfo` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `can_be_leader`, `storage_capacity`, `processing_capacity`, and `network_bandwidth` are never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:116:5 [INFO] [stdout] | [INFO] [stdout] 114 | struct NodeCapabilities { [INFO] [stdout] | ---------------- fields in this struct [INFO] [stdout] 115 | /// Can participate in leader election [INFO] [stdout] 116 | can_be_leader: bool, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 119 | storage_capacity: u64, [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 122 | processing_capacity: u32, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 125 | network_bandwidth: u64, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `NodeCapabilities` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `checkpoint_id` and `expected_completion` are never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:132:5 [INFO] [stdout] | [INFO] [stdout] 130 | struct CheckpointProgress { [INFO] [stdout] | ------------------ fields in this struct [INFO] [stdout] 131 | /// Checkpoint identifier [INFO] [stdout] 132 | checkpoint_id: CheckpointId, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 147 | expected_completion: Option, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `CheckpointProgress` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `checkpoint_type`, `coordinator_node`, and `timeout` are never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:157:5 [INFO] [stdout] | [INFO] [stdout] 155 | struct CheckpointMetadata { [INFO] [stdout] | ------------------ fields in this struct [INFO] [stdout] 156 | /// Checkpoint type [INFO] [stdout] 157 | checkpoint_type: String, [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 160 | coordinator_node: String, [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | timeout: Duration, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `CheckpointMetadata` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `term`, `index`, `entry_type`, `data`, and `timestamp` are never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:189:5 [INFO] [stdout] | [INFO] [stdout] 187 | struct ConsensusEntry { [INFO] [stdout] | -------------- fields in this struct [INFO] [stdout] 188 | /// Entry term [INFO] [stdout] 189 | term: u64, [INFO] [stdout] | ^^^^ [INFO] [stdout] ... [INFO] [stdout] 192 | index: u64, [INFO] [stdout] | ^^^^^ [INFO] [stdout] ... [INFO] [stdout] 195 | entry_type: ConsensusEntryType, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 198 | data: Vec, [INFO] [stdout] | ^^^^ [INFO] [stdout] ... [INFO] [stdout] 201 | timestamp: Instant, [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `ConsensusEntry` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variants `NodeJoin`, `NodeLeave`, and `Configuration` are never constructed [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:209:5 [INFO] [stdout] | [INFO] [stdout] 206 | enum ConsensusEntryType { [INFO] [stdout] | ------------------ variants in this enum [INFO] [stdout] ... [INFO] [stdout] 209 | NodeJoin, [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] 210 | NodeLeave, [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] 211 | Configuration, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `ConsensusEntryType` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `leader_elections`, `network_partitions`, and `avg_cluster_size` are never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:230:9 [INFO] [stdout] | [INFO] [stdout] 216 | struct CoordinatorStatistics { [INFO] [stdout] | --------------------- fields in this struct [INFO] [stdout] ... [INFO] [stdout] 230 | pub leader_elections: u64, [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 233 | pub network_partitions: u64, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 236 | pub avg_cluster_size: f64, [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `CoordinatorStatistics` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `checkpoints` is never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:249:5 [INFO] [stdout] | [INFO] [stdout] 241 | struct SimulatedClusterState { [INFO] [stdout] | --------------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 249 | checkpoints: HashMap, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `SimulatedClusterState` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `replication_factor` and `stats` are never read [INFO] [stdout] --> src/core/persistence/incremental/persistence_backend.rs:61:5 [INFO] [stdout] | [INFO] [stdout] 53 | pub struct DistributedPersistenceBackend { [INFO] [stdout] | ----------------------------- fields in this struct [INFO] [stdout] ... [INFO] [stdout] 61 | replication_factor: usize, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 67 | stats: Arc>, [INFO] [stdout] | ^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `failed_operations` and `cache_hit_rate` are never read [INFO] [stdout] --> src/core/persistence/incremental/persistence_backend.rs:124:9 [INFO] [stdout] | [INFO] [stdout] 104 | struct BackendStatistics { [INFO] [stdout] | ----------------- fields in this struct [INFO] [stdout] ... [INFO] [stdout] 124 | pub failed_operations: u64, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 127 | pub cache_hit_rate: f64, [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `BackendStatistics` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `calculate_file_checksum` is never used [INFO] [stdout] --> src/core/persistence/incremental/persistence_backend.rs:334:8 [INFO] [stdout] | [INFO] [stdout] 156 | impl FilePersistenceBackend { [INFO] [stdout] | --------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 334 | fn calculate_file_checksum(&self, data: &[u8]) -> u64 { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `merger` and `stats` are never read [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:27:5 [INFO] [stdout] | [INFO] [stdout] 22 | pub struct AdvancedRecoveryEngine { [INFO] [stdout] | ---------------------- fields in this struct [INFO] [stdout] ... [INFO] [stdout] 27 | merger: Arc, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 36 | stats: RecoveryStatistics, [INFO] [stdout] | ^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `checkpoint_id` and `components` are never read [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:103:9 [INFO] [stdout] | [INFO] [stdout] 101 | struct CheckpointInfo { [INFO] [stdout] | -------------- fields in this struct [INFO] [stdout] 102 | /// Checkpoint identifier [INFO] [stdout] 103 | pub checkpoint_id: CheckpointId, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 118 | pub components: HashSet, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `CheckpointInfo` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variants `Full` and `Incremental` are never constructed [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:124:5 [INFO] [stdout] | [INFO] [stdout] 123 | enum CheckpointType { [INFO] [stdout] | -------------- variants in this enum [INFO] [stdout] 124 | Full, [INFO] [stdout] | ^^^^ [INFO] [stdout] 125 | Incremental { base: CheckpointId }, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `CheckpointType` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `estimated_duration`, `total_size`, and `checkpoints_needed` are never read [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:157:9 [INFO] [stdout] | [INFO] [stdout] 152 | struct RecoveryPlan { [INFO] [stdout] | ------------ fields in this struct [INFO] [stdout] ... [INFO] [stdout] 157 | pub estimated_duration: Duration, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 160 | pub total_size: usize, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub checkpoints_needed: Vec, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `RecoveryPlan` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `dependencies` is never read [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:176:9 [INFO] [stdout] | [INFO] [stdout] 168 | struct RecoveryStage { [INFO] [stdout] | ------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 176 | pub dependencies: Vec, [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `RecoveryStage` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `start_time` is never read [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:195:9 [INFO] [stdout] | [INFO] [stdout] 184 | struct RecoveryContext { [INFO] [stdout] | --------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 195 | pub start_time: Instant, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `RecoveryContext` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `build_checkpoint_cache` is never used [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:225:8 [INFO] [stdout] | [INFO] [stdout] 208 | impl AdvancedRecoveryEngine { [INFO] [stdout] | --------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 225 | fn build_checkpoint_cache(&mut self) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `SerializableSessionChunk` is never constructed [INFO] [stdout] --> src/core/query/processor/stream/window/session_window_state_holder.rs:31:8 [INFO] [stdout] | [INFO] [stdout] 31 | struct SerializableSessionChunk { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `SerializableStreamEvent` is never constructed [INFO] [stdout] --> src/core/query/processor/stream/window/session_window_state_holder.rs:40:8 [INFO] [stdout] | [INFO] [stdout] 40 | struct SerializableStreamEvent { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `SerializableSessionContainer` is never constructed [INFO] [stdout] --> src/core/query/processor/stream/window/session_window_state_holder.rs:52:8 [INFO] [stdout] | [INFO] [stdout] 52 | struct SerializableSessionContainer { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `SerializableSessionState` is never constructed [INFO] [stdout] --> src/core/query/processor/stream/window/session_window_state_holder.rs:59:8 [INFO] [stdout] | [INFO] [stdout] 59 | struct SerializableSessionState { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `SessionWindowStateHolder` is never constructed [INFO] [stdout] --> src/core/query/processor/stream/window/session_window_state_holder.rs:66:12 [INFO] [stdout] | [INFO] [stdout] 66 | pub struct SessionWindowStateHolder { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> src/core/query/processor/stream/window/session_window_state_holder.rs:92:12 [INFO] [stdout] | [INFO] [stdout] 90 | impl SessionWindowStateHolder { [INFO] [stdout] | ----------------------------- associated items in this implementation [INFO] [stdout] 91 | /// Create a new enhanced state holder [INFO] [stdout] 92 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub fn record_session_created(&self, session_key: String) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 123 | pub fn record_event_added(&self, session_key: &str, event: &StreamEvent) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 135 | pub fn record_session_expired(&self, session_key: String) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 145 | fn serialize_event(&self, event: &StreamEvent) -> Vec { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 169 | fn deserialize_event(&self, data: &[u8]) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 204 | fn chunk_to_serializable(&self, chunk: &SessionEventChunk) -> SerializableSessionChunk { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | fn serializable_to_chunk(&self, serializable: &SerializableSessionChunk) -> SessionEventChunk { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `comparator` is never read [INFO] [stdout] --> src/core/query/processor/stream/window/sort_window_processor.rs:30:5 [INFO] [stdout] | [INFO] [stdout] 22 | pub struct SortWindowProcessor { [INFO] [stdout] | ------------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 30 | comparator: OrderByEventComparator, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `SortWindowProcessor` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `should_use_memory_optimization` is never used [INFO] [stdout] --> src/core/query/processor/stream/window/sort_window_processor.rs:131:8 [INFO] [stdout] | [INFO] [stdout] 33 | impl SortWindowProcessor { [INFO] [stdout] | ------------------------ method in this implementation [INFO] [stdout] ... [INFO] [stdout] 131 | fn should_use_memory_optimization(&self) -> bool { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `record_event_added`, `record_event_removed`, `generate_event_key`, `hash_event_data`, and `clear_change_log` are never used [INFO] [stdout] --> src/core/query/processor/stream/window/length_window_state_holder.rs:63:12 [INFO] [stdout] | [INFO] [stdout] 45 | impl LengthWindowStateHolder { [INFO] [stdout] | ---------------------------- methods in this implementation [INFO] [stdout] ... [INFO] [stdout] 63 | pub fn record_event_added(&self, event: &StreamEvent) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 77 | pub fn record_event_removed(&self, event: &StreamEvent) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 88 | fn generate_event_key(&self, event: &StreamEvent) -> Vec { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 101 | fn hash_event_data(&self, data: &[crate::core::event::value::AttributeValue]) -> u64 { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 159 | pub fn clear_change_log(&self, checkpoint_id: CheckpointId) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `update_window_start_time` and `clear_change_log` are never used [INFO] [stdout] --> src/core/query/processor/stream/window/time_window_state_holder.rs:96:12 [INFO] [stdout] | [INFO] [stdout] 51 | impl TimeWindowStateHolder { [INFO] [stdout] | -------------------------- methods in this implementation [INFO] [stdout] ... [INFO] [stdout] 96 | pub fn update_window_start_time(&self, timestamp: i64) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 146 | pub fn clear_change_log(&self, checkpoint_id: CheckpointId) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `clear_change_log` is never used [INFO] [stdout] --> src/core/query/processor/stream/window/length_batch_window_state_holder.rs:164:12 [INFO] [stdout] | [INFO] [stdout] 50 | impl LengthBatchWindowStateHolder { [INFO] [stdout] | --------------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 164 | pub fn clear_change_log(&self, checkpoint_id: CheckpointId) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `clear_change_log` is never used [INFO] [stdout] --> src/core/query/processor/stream/window/time_batch_window_state_holder.rs:200:12 [INFO] [stdout] | [INFO] [stdout] 53 | impl TimeBatchWindowStateHolder { [INFO] [stdout] | ------------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 200 | pub fn clear_change_log(&self, checkpoint_id: CheckpointId) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `ExternalTimeWindowStateHolder` is never constructed [INFO] [stdout] --> src/core/query/processor/stream/window/external_time_window_state_holder.rs:24:12 [INFO] [stdout] | [INFO] [stdout] 24 | pub struct ExternalTimeWindowStateHolder { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> src/core/query/processor/stream/window/external_time_window_state_holder.rs:46:12 [INFO] [stdout] | [INFO] [stdout] 44 | impl ExternalTimeWindowStateHolder { [INFO] [stdout] | ---------------------------------- associated items in this implementation [INFO] [stdout] 45 | /// Create a new enhanced state holder [INFO] [stdout] 46 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 62 | pub fn record_event_added(&self, event: &StreamEvent) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 76 | pub fn record_event_expired(&self, event: &StreamEvent) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 87 | fn generate_event_key(&self, event: &StreamEvent) -> Vec { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 100 | fn hash_event_data(&self, data: &[crate::core::event::value::AttributeValue]) -> u64 { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 114 | fn serialize_event(&self, event: &StreamEvent) -> Vec { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 125 | fn deserialize_event(&self, data: &[u8]) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 145 | pub fn clear_change_log(&self, checkpoint_id: CheckpointId) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `ExternalTimeWindowStateData` is never constructed [INFO] [stdout] --> src/core/query/processor/stream/window/external_time_window_state_holder.rs:331:8 [INFO] [stdout] | [INFO] [stdout] 331 | struct ExternalTimeWindowStateData { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `event_pool` is never read [INFO] [stdout] --> src/core/stream/optimized_stream_junction.rs:48:5 [INFO] [stdout] | [INFO] [stdout] 40 | pub struct OptimizedStreamJunction { [INFO] [stdout] | ----------------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 48 | event_pool: Arc, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `snappy_contexts` is never read [INFO] [stdout] --> src/core/util/compression.rs:180:5 [INFO] [stdout] | [INFO] [stdout] 176 | pub struct OptimizedCompressionEngine { [INFO] [stdout] | -------------------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 180 | snappy_contexts: ThreadLocal, [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `encoder` and `decoder` are never read [INFO] [stdout] --> src/core/util/compression.rs:196:5 [INFO] [stdout] | [INFO] [stdout] 195 | struct SnapContext { [INFO] [stdout] | ----------- fields in this struct [INFO] [stdout] 196 | encoder: snap::raw::Encoder, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] 197 | decoder: snap::raw::Decoder, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `get_first_stream_id_placeholder` is never used [INFO] [stdout] --> src/core/util/parser/eventflux_app_parser.rs:326:8 [INFO] [stdout] | [INFO] [stdout] 325 | impl ApiInputStream { [INFO] [stdout] | ------------------- method in this implementation [INFO] [stdout] 326 | fn get_first_stream_id_placeholder(&self) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function `new` is never used [INFO] [stdout] --> src/core/util/pipeline/object_pool.rs:26:8 [INFO] [stdout] | [INFO] [stdout] 24 | impl PooledEvent { [INFO] [stdout] | ---------------- associated function in this implementation [INFO] [stdout] 25 | /// Create a new pooled event [INFO] [stdout] 26 | fn new(pool: Arc) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `eventflux_element_ref` and `eventflux_element_mut_ref` are never used [INFO] [stdout] --> src/query_api/execution/query/input/handler/stream_handler.rs:27:8 [INFO] [stdout] | [INFO] [stdout] 25 | impl StreamHandler { [INFO] [stdout] | ------------------ methods in this implementation [INFO] [stdout] 26 | // Accessing the composed eventflux_element from the variants [INFO] [stdout] 27 | fn eventflux_element_ref(&self) -> &EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 35 | fn eventflux_element_mut_ref(&mut self) -> &mut EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `eventflux_element_ref` and `eventflux_element_mut_ref` are never used [INFO] [stdout] --> src/query_api/execution/query/input/state/state_element.rs:26:8 [INFO] [stdout] | [INFO] [stdout] 25 | impl StateElement { [INFO] [stdout] | ----------------- methods in this implementation [INFO] [stdout] 26 | fn eventflux_element_ref(&self) -> &EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 37 | fn eventflux_element_mut_ref(&mut self) -> &mut EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `get_stream_id` is never used [INFO] [stdout] --> src/query_api/execution/query/input/state/stream_state_element.rs:35:19 [INFO] [stdout] | [INFO] [stdout] 18 | impl StreamStateElement { [INFO] [stdout] | ----------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 35 | pub(crate) fn get_stream_id(&self) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `eventflux_element_ref` and `eventflux_element_mut_ref` are never used [INFO] [stdout] --> src/query_api/execution/query/input/store/input_store.rs:39:8 [INFO] [stdout] | [INFO] [stdout] 27 | impl InputStore { [INFO] [stdout] | --------------- methods in this implementation [INFO] [stdout] ... [INFO] [stdout] 39 | fn eventflux_element_ref(&self) -> &EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 46 | fn eventflux_element_mut_ref(&mut self) -> &mut EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `eventflux_element_ref` and `eventflux_element_mut_ref` are never used [INFO] [stdout] --> src/query_api/execution/query/input/stream/input_stream.rs:39:8 [INFO] [stdout] | [INFO] [stdout] 36 | impl InputStream { [INFO] [stdout] | ---------------- methods in this implementation [INFO] [stdout] ... [INFO] [stdout] 39 | fn eventflux_element_ref(&self) -> &EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 47 | fn eventflux_element_mut_ref(&mut self) -> &mut EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `parse_attribute_type` is never used [INFO] [stdout] --> src/query_compiler/eventflux_compiler.rs:163:4 [INFO] [stdout] | [INFO] [stdout] 163 | fn parse_attribute_type(t: &str) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Checking custom_dyn_ext v0.1.0 (/opt/rustwide/workdir/tests/custom_dyn_ext) [INFO] [stdout] warning: unused import: `parse_expression` [INFO] [stdout] --> tests/join_queries.rs:21:42 [INFO] [stdout] | [INFO] [stdout] 21 | use eventflux_rust::core::util::parser::{parse_expression, ExpressionParserContext}; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `eventflux_rust::core::config::eventflux_context::EventFluxContext` [INFO] [stdout] --> tests/async_annotation_tests.rs:11:5 [INFO] [stdout] | [INFO] [stdout] 11 | use eventflux_rust::core::config::eventflux_context::EventFluxContext; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `eventflux_rust::query_api::definition::attribute::Type as AttributeType` [INFO] [stdout] --> tests/async_annotation_tests.rs:13:5 [INFO] [stdout] | [INFO] [stdout] 13 | use eventflux_rust::query_api::definition::attribute::Type as AttributeType; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Sink` [INFO] [stdout] --> tests/source_sink.rs:8:53 [INFO] [stdout] | [INFO] [stdout] 8 | use eventflux_rust::core::stream::output::{LogSink, Sink, StreamCallback}; [INFO] [stdout] | ^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/async_annotation_tests.rs:18:9 [INFO] [stdout] | [INFO] [stdout] 18 | let mut manager = EventFluxManager::new(); [INFO] [stdout] | ----^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/async_annotation_tests.rs:80:9 [INFO] [stdout] | [INFO] [stdout] 80 | let mut manager = EventFluxManager::new(); [INFO] [stdout] | ----^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/async_annotation_tests.rs:118:9 [INFO] [stdout] | [INFO] [stdout] 118 | let mut manager = EventFluxManager::new(); [INFO] [stdout] | ----^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/async_annotation_tests.rs:164:9 [INFO] [stdout] | [INFO] [stdout] 164 | let mut manager = EventFluxManager::new(); [INFO] [stdout] | ----^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/async_annotation_tests.rs:194:9 [INFO] [stdout] | [INFO] [stdout] 194 | let mut manager = EventFluxManager::new(); [INFO] [stdout] | ----^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/async_annotation_tests.rs:270:9 [INFO] [stdout] | [INFO] [stdout] 270 | let mut manager = EventFluxManager::new(); [INFO] [stdout] | ----^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `ctx` [INFO] [stdout] --> tests/join_queries.rs:388:9 [INFO] [stdout] | [INFO] [stdout] 388 | let ctx = ExpressionParserContext { [INFO] [stdout] | ^^^ help: if this is intentional, prefix it with an underscore: `_ctx` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] 34 | pub async fn new(app_string: &str, out_stream: &str) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] 34 | pub async fn new(app_string: &str, out_stream: &str) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] 34 | pub async fn new(app_string: &str, out_stream: &str) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 191 | pub fn send(&self, stream_id: &str, data: Vec) { [INFO] [stdout] | ^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> tests/builtin_function_parsing.rs:31:21 [INFO] [stdout] | [INFO] [stdout] 31 | fn empty_ctx(query: &str) -> ExpressionParserContext { [INFO] [stdout] | ^^^^ ^^^^^^^^^^^^^^^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] = note: `#[warn(mismatched_lifetime_syntaxes)]` on by default [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 31 | fn empty_ctx(query: &str) -> ExpressionParserContext<'_> { [INFO] [stdout] | ++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `StreamEvent` [INFO] [stdout] --> tests/integration_config_runtime_integration.rs:14:42 [INFO] [stdout] | [INFO] [stdout] 14 | use eventflux_rust::core::event::{Event, StreamEvent}; [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `eventflux_rust::core::eventflux_manager::EventFluxManager as Manager` [INFO] [stdout] --> tests/integration_config_runtime_integration.rs:15:5 [INFO] [stdout] | [INFO] [stdout] 15 | use eventflux_rust::core::eventflux_manager::EventFluxManager as Manager; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::collections::HashMap` [INFO] [stdout] --> tests/integration_config_runtime_integration.rs:19:5 [INFO] [stdout] | [INFO] [stdout] 19 | use std::collections::HashMap; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `common::AppRunner` [INFO] [stdout] --> tests/auto_sink_initialization_test.rs:11:5 [INFO] [stdout] | [INFO] [stdout] 11 | use common::AppRunner; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `ApplicationConfig` and `EventFluxConfig` [INFO] [stdout] --> tests/auto_sink_initialization_test.rs:12:36 [INFO] [stdout] | [INFO] [stdout] 12 | use eventflux_rust::core::config::{ApplicationConfig, ConfigManager, EventFluxConfig}; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Mutex` [INFO] [stdout] --> tests/auto_sink_initialization_test.rs:17:22 [INFO] [stdout] | [INFO] [stdout] 17 | use std::sync::{Arc, Mutex}; [INFO] [stdout] | ^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:83:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 191 | pub fn send(&self, stream_id: &str, data: Vec) { [INFO] [stdout] | ^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `input_handler` [INFO] [stdout] --> tests/integration_config_runtime_integration.rs:217:9 [INFO] [stdout] | [INFO] [stdout] 217 | let input_handler = eventflux_app_runtime [INFO] [stdout] | ^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_input_handler` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `get_events` and `get_callback_count` are never used [INFO] [stdout] --> tests/integration_config_runtime_integration.rs:40:8 [INFO] [stdout] | [INFO] [stdout] 32 | impl TestEventCollector { [INFO] [stdout] | ----------------------- methods in this implementation [INFO] [stdout] ... [INFO] [stdout] 40 | fn get_events(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 44 | fn get_callback_count(&self) -> usize { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/auto_sink_initialization_test.rs:70:9 [INFO] [stdout] | [INFO] [stdout] 70 | let mut manager = EventFluxManager::new_with_config_manager(config_manager); [INFO] [stdout] | ----^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `CollectCallback` is never constructed [INFO] [stdout] --> tests/common/mod.rs:13:8 [INFO] [stdout] | [INFO] [stdout] 13 | struct CollectCallback { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `AppRunner` is never constructed [INFO] [stdout] --> tests/common/mod.rs:27:12 [INFO] [stdout] | [INFO] [stdout] 27 | pub struct AppRunner { [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] 34 | pub async fn new(app_string: &str, out_stream: &str) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 191 | pub fn send(&self, stream_id: &str, data: Vec) { [INFO] [stdout] | ^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 226 | pub fn shutdown(self) -> Vec> { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/incremental_aggregation.rs:68:9 [INFO] [stdout] | [INFO] [stdout] 68 | let mut inc = IncrementalExecutor::new( [INFO] [stdout] | ----^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `CollectCallback` is never constructed [INFO] [stdout] --> tests/common/mod.rs:13:8 [INFO] [stdout] | [INFO] [stdout] 13 | struct CollectCallback { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `AppRunner` is never constructed [INFO] [stdout] --> tests/common/mod.rs:27:12 [INFO] [stdout] | [INFO] [stdout] 27 | pub struct AppRunner { [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] 34 | pub async fn new(app_string: &str, out_stream: &str) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 191 | pub fn send(&self, stream_id: &str, data: Vec) { [INFO] [stdout] | ^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 226 | pub fn shutdown(self) -> Vec> { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/jdbc_table.rs:56:9 [INFO] [stdout] | [INFO] [stdout] 56 | let mut conn = conn_arc.lock().unwrap(); [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::collections::HashMap` [INFO] [stdout] --> tests/app_runner_async_pool_stress.rs:7:5 [INFO] [stdout] | [INFO] [stdout] 7 | use std::collections::HashMap; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] 34 | pub async fn new(app_string: &str, out_stream: &str) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `AlertingConfig` and `EventFluxConfig` [INFO] [stdout] --> tests/integration_config_monitoring.rs:10:20 [INFO] [stdout] | [INFO] [stdout] 10 | AlertRule, AlertingConfig, CheckResult, CustomMetric, EndpointConfig, HealthCheck, [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 15 | ConfigManager, EventFluxConfig, [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] 34 | pub async fn new(app_string: &str, out_stream: &str) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] 34 | pub async fn new(app_string: &str, out_stream: &str) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `ApplicationConfig` and `EventFluxConfig` [INFO] [stdout] --> tests/verify_auto_sink_test.rs:8:36 [INFO] [stdout] | [INFO] [stdout] 8 | use eventflux_rust::core::config::{ApplicationConfig, ConfigManager, EventFluxConfig}; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 191 | pub fn send(&self, stream_id: &str, data: Vec) { [INFO] [stdout] | ^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Mutex` [INFO] [stdout] --> tests/verify_auto_sink_test.rs:13:22 [INFO] [stdout] | [INFO] [stdout] 13 | use std::sync::{Arc, Mutex}; [INFO] [stdout] | ^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] 34 | pub async fn new(app_string: &str, out_stream: &str) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `CollectCallback` is never constructed [INFO] [stdout] --> tests/common/mod.rs:13:8 [INFO] [stdout] | [INFO] [stdout] 13 | struct CollectCallback { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `AppRunner` is never constructed [INFO] [stdout] --> tests/common/mod.rs:27:12 [INFO] [stdout] | [INFO] [stdout] 27 | pub struct AppRunner { [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] 34 | pub async fn new(app_string: &str, out_stream: &str) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 191 | pub fn send(&self, stream_id: &str, data: Vec) { [INFO] [stdout] | ^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 226 | pub fn shutdown(self) -> Vec> { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/verify_auto_sink_test.rs:53:9 [INFO] [stdout] | [INFO] [stdout] 53 | let mut manager = EventFluxManager::new_with_config_manager(config_manager); [INFO] [stdout] | ----^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `CollectCallback` is never constructed [INFO] [stdout] --> tests/common/mod.rs:13:8 [INFO] [stdout] | [INFO] [stdout] 13 | struct CollectCallback { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `AppRunner` is never constructed [INFO] [stdout] --> tests/common/mod.rs:27:12 [INFO] [stdout] | [INFO] [stdout] 27 | pub struct AppRunner { [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] 34 | pub async fn new(app_string: &str, out_stream: &str) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 191 | pub fn send(&self, stream_id: &str, data: Vec) { [INFO] [stdout] | ^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 226 | pub fn shutdown(self) -> Vec> { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 191 | pub fn send(&self, stream_id: &str, data: Vec) { [INFO] [stdout] | ^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `OutputAttribute` [INFO] [stdout] --> tests/expression_parser_complex.rs:709:55 [INFO] [stdout] | [INFO] [stdout] 709 | use eventflux_rust::query_api::execution::query::{OutputAttribute, Query}; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/app_runner_tables.rs:63:9 [INFO] [stdout] | [INFO] [stdout] 63 | let mut conn = conn_arc.lock().unwrap(); [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/app_runner_tables.rs:112:9 [INFO] [stdout] | [INFO] [stdout] 112 | let mut manager = EventFluxManager::new(); [INFO] [stdout] | ----^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `eventflux_rust::query_api::eventflux_app::EventFluxApp` [INFO] [stdout] --> tests/udf_invocation.rs:16:5 [INFO] [stdout] | [INFO] [stdout] 16 | use eventflux_rust::query_api::eventflux_app::EventFluxApp; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/app_runner_tables.rs:192:9 [INFO] [stdout] | [INFO] [stdout] 192 | let mut manager = EventFluxManager::new(); [INFO] [stdout] | ----^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::collections::HashMap` [INFO] [stdout] --> tests/integration_config_validation_api.rs:20:5 [INFO] [stdout] | [INFO] [stdout] 20 | use std::collections::HashMap; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/app_runner_tables.rs:236:9 [INFO] [stdout] | [INFO] [stdout] 236 | let mut manager = EventFluxManager::new(); [INFO] [stdout] | ----^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] 34 | pub async fn new(app_string: &str, out_stream: &str) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:83:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `table` [INFO] [stdout] --> tests/expression_parser_complex.rs:156:9 [INFO] [stdout] | [INFO] [stdout] 156 | let table = TableDefinition::new("T".to_string()).attribute("val".to_string(), AttrType::INT); [INFO] [stdout] | ^^^^^ help: if this is intentional, prefix it with an underscore: `_table` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `transport` [INFO] [stdout] --> tests/distributed_grpc_integration.rs:12:9 [INFO] [stdout] | [INFO] [stdout] 12 | let transport = SimpleGrpcTransport::new(); [INFO] [stdout] | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_transport` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `count` is never used [INFO] [stdout] --> tests/sql_integration_tests.rs:28:8 [INFO] [stdout] | [INFO] [stdout] 17 | impl TestCallback { [INFO] [stdout] | ----------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 28 | fn count(&self) -> usize { [INFO] [stdout] | ^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/expression_parser_complex.rs:303:9 [INFO] [stdout] | [INFO] [stdout] 303 | let mut selector = eventflux_rust::query_api::execution::query::selection::Selector::new(); [INFO] [stdout] | ----^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/expression_parser_complex.rs:369:9 [INFO] [stdout] | [INFO] [stdout] 369 | let mut left_meta = MetaStreamEvent::new_for_single_input(Arc::clone(&left_def)); [INFO] [stdout] | ----^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/expression_parser_complex.rs:411:9 [INFO] [stdout] | [INFO] [stdout] 411 | let mut selector = eventflux_rust::query_api::execution::query::selection::Selector::new(); [INFO] [stdout] | ----^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/udf_invocation.rs:75:9 [INFO] [stdout] | [INFO] [stdout] 75 | let mut manager = EventFluxManager::new(); [INFO] [stdout] | ----^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] 34 | pub async fn new(app_string: &str, out_stream: &str) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/integration_config_validation_api.rs:26:9 [INFO] [stdout] | [INFO] [stdout] 26 | let mut report = ValidationReport::new(); [INFO] [stdout] | ----^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/expression_parser_complex.rs:845:9 [INFO] [stdout] | [INFO] [stdout] 845 | let mut manager = EventFluxManager::new(); [INFO] [stdout] | ----^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:83:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `PerformanceLevel` [INFO] [stdout] --> tests/optimized_stream_junction_integration.rs:18:79 [INFO] [stdout] | [INFO] [stdout] 18 | JunctionBenchmark, JunctionConfig, JunctionType, OptimizedStreamJunction, PerformanceLevel, [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 57 | pub async fn new_from_api( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 212 | pub fn send_batch(&self, stream_id: &str, batch: Vec>) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: comparison is useless due to type limits [INFO] [stdout] --> tests/integration_config_validation_api.rs:442:13 [INFO] [stdout] | [INFO] [stdout] 442 | assert!(report.validation_duration.as_nanos() >= 0); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_comparisons)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `received_time` [INFO] [stdout] --> tests/optimized_stream_junction_integration.rs:67:13 [INFO] [stdout] | [INFO] [stdout] 67 | let received_time = Instant::now(); [INFO] [stdout] | ^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_received_time` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `se` [INFO] [stdout] --> tests/optimized_stream_junction_integration.rs:72:25 [INFO] [stdout] | [INFO] [stdout] 72 | if let Some(se) = ce.as_any().downcast_ref::() { [INFO] [stdout] | ^^ help: if this is intentional, prefix it with an underscore: `_se` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> tests/common/mod.rs:83:18 [INFO] [stdout] | [INFO] [stdout] 33 | impl AppRunner { [INFO] [stdout] | -------------- associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 83 | pub async fn new_from_api_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 111 | pub async fn new_from_api_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 137 | pub async fn new_with_manager( [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | pub async fn new_with_store( [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | pub fn send_with_ts(&self, stream_id: &str, ts: i64, data: Vec) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | pub fn persist(&self) -> String { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub fn restore_revision(&self, rev: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 239 | pub fn snapshot(&self) -> Vec { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub fn restore(&self, snap: &[u8]) { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 247 | pub fn runtime(&self) -> Arc { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 252 | pub fn get_table_input_handler(&self, table_id: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 257 | pub fn get_aggregation_data( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `PerformanceConfig` [INFO] [stdout] --> src/core/config/validator.rs:392:31 [INFO] [stdout] | [INFO] [stdout] 392 | use crate::core::config::{PerformanceConfig, RuntimeMode}; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::collections::HashMap` [INFO] [stdout] --> src/core/distributed/distributed_runtime.rs:11:5 [INFO] [stdout] | [INFO] [stdout] 11 | use std::collections::HashMap; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Server` [INFO] [stdout] --> src/core/distributed/grpc/simple_transport.rs:18:33 [INFO] [stdout] | [INFO] [stdout] 18 | use tonic::transport::{Channel, Server}; [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Response` and `Status` [INFO] [stdout] --> src/core/distributed/grpc/simple_transport.rs:19:22 [INFO] [stdout] | [INFO] [stdout] 19 | use tonic::{Request, Response, Status}; [INFO] [stdout] | ^^^^^^^^ ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::core::distributed::transport::MessageType` [INFO] [stdout] --> src/core/distributed/grpc/simple_transport.rs:220:9 [INFO] [stdout] | [INFO] [stdout] 220 | use crate::core::distributed::transport::MessageType; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `TransportServer` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:11:62 [INFO] [stdout] | [INFO] [stdout] 11 | use super::transport_server::{Transport as TransportService, TransportServer}; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `EventRequest` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:13:35 [INFO] [stdout] | [INFO] [stdout] 13 | ClusterInfo, CompressionType, EventRequest, HeartbeatRequest, HeartbeatResponse, MessageType, [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `StreamExt` and `Stream` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:24:15 [INFO] [stdout] | [INFO] [stdout] 24 | use futures::{Stream, StreamExt}; [INFO] [stdout] | ^^^^^^ ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Identity`, `ServerTlsConfig`, and `Server` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:30:63 [INFO] [stdout] | [INFO] [stdout] 30 | use tonic::transport::{Certificate, Channel, ClientTlsConfig, Identity, Server, ServerTlsConfig}; [INFO] [stdout] | ^^^^^^^^ ^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Streaming` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:31:40 [INFO] [stdout] | [INFO] [stdout] 31 | use tonic::{Request, Response, Status, Streaming}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tower::service_fn` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:32:5 [INFO] [stdout] | [INFO] [stdout] 32 | use tower::service_fn; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `DistributedError` [INFO] [stdout] --> src/core/distributed/coordinator.rs:10:13 [INFO] [stdout] | [INFO] [stdout] 10 | use super::{DistributedError, DistributedResult}; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `DistributedError` [INFO] [stdout] --> src/core/distributed/message_broker.rs:10:13 [INFO] [stdout] | [INFO] [stdout] 10 | use super::{DistributedError, DistributedResult}; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::sync::Arc` [INFO] [stdout] --> src/core/distributed/mod.rs:23:5 [INFO] [stdout] | [INFO] [stdout] 23 | use std::sync::Arc; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::core::executor::constant_expression_executor::ConstantExpressionExecutor` [INFO] [stdout] --> src/core/executor/incremental/should_update.rs:61:9 [INFO] [stdout] | [INFO] [stdout] 61 | use crate::core::executor::constant_expression_executor::ConstantExpressionExecutor; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `STREAM_ATTRIBUTE_INDEX_IN_TYPE` and `STREAM_ATTRIBUTE_TYPE_INDEX` [INFO] [stdout] --> src/core/executor/incremental/should_update.rs:64:35 [INFO] [stdout] | [INFO] [stdout] 64 | BEFORE_WINDOW_DATA_INDEX, STREAM_ATTRIBUTE_INDEX_IN_TYPE, STREAM_ATTRIBUTE_TYPE_INDEX, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::core::event::value::AttributeValue` [INFO] [stdout] --> src/core/query/processor/stream/window/session_window_processor.rs:585:9 [INFO] [stdout] | [INFO] [stdout] 585 | use crate::core::event::value::AttributeValue; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `ComponentId` [INFO] [stdout] --> src/core/query/processor/stream/window/session_window_state_holder.rs:20:45 [INFO] [stdout] | [INFO] [stdout] 20 | AccessPattern, ChangeLog, CheckpointId, ComponentId, CompressionType, SchemaVersion, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `session_window_state_holder::SessionWindowStateHolder` [INFO] [stdout] --> src/core/query/processor/stream/window/mod.rs:30:5 [INFO] [stdout] | [INFO] [stdout] 30 | use session_window_state_holder::SessionWindowStateHolder; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `ProcessorConfigReader` [INFO] [stdout] --> src/core/query/processor/stream/window/sort_window_processor.rs:8:66 [INFO] [stdout] | [INFO] [stdout] 8 | eventflux_query_context::EventFluxQueryContext, ConfigValue, ProcessorConfigReader, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Sink` [INFO] [stdout] --> src/core/stream/output/sink/sink_factory.rs:8:50 [INFO] [stdout] | [INFO] [stdout] 8 | use crate::core::stream::output::sink::{LogSink, Sink}; [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary parentheses around closure body [INFO] [stdout] --> src/core/util/compression.rs:746:35 [INFO] [stdout] | [INFO] [stdout] 746 | (0..size).map(|i| ((i % 1000) as u8)).collect() [INFO] [stdout] | ^ ^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_parens)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] help: remove these parentheses [INFO] [stdout] | [INFO] [stdout] 746 - (0..size).map(|i| ((i % 1000) as u8)).collect() [INFO] [stdout] 746 + (0..size).map(|i| (i % 1000) as u8).collect() [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::sync::Arc` [INFO] [stdout] --> src/core/util/pipeline/mod.rs:36:9 [INFO] [stdout] | [INFO] [stdout] 36 | use std::sync::Arc; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Duration` [INFO] [stdout] --> src/core/util/pipeline/mod.rs:37:21 [INFO] [stdout] | [INFO] [stdout] 37 | use std::time::{Duration, Instant}; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Attribute` [INFO] [stdout] --> src/query_api/definition/stream_definition.rs:90:51 [INFO] [stdout] | [INFO] [stdout] 90 | use crate::query_api::definition::attribute::{Attribute, Type as AttributeType}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `ConstantValueWithFloat` [INFO] [stdout] --> src/query_api/execution/query/selection/selector.rs:215:60 [INFO] [stdout] | [INFO] [stdout] 215 | use crate::query_api::expression::constant::{Constant, ConstantValueWithFloat}; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::query_api::execution::query::selection::selector::Selector` [INFO] [stdout] --> src/sql_compiler/converter.rs:19:5 [INFO] [stdout] | [INFO] [stdout] 19 | use crate::query_api::execution::query::selection::selector::Selector; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `super::preprocessor::TimeUnit` [INFO] [stdout] --> src/sql_compiler/converter.rs:405:13 [INFO] [stdout] | [INFO] [stdout] 405 | use super::preprocessor::TimeUnit; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `sqlparser::ast::Expr as SqlExpr` [INFO] [stdout] --> src/sql_compiler/preprocessor.rs:10:5 [INFO] [stdout] | [INFO] [stdout] 10 | use sqlparser::ast::Expr as SqlExpr; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::collections::HashMap` [INFO] [stdout] --> src/lib.rs:10:9 [INFO] [stdout] | [INFO] [stdout] 10 | use std::collections::HashMap; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::core::event::event::Event` [INFO] [stdout] --> src/lib.rs:41:9 [INFO] [stdout] | [INFO] [stdout] 41 | use crate::core::event::event::Event; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:290:13 [INFO] [stdout] | [INFO] [stdout] 290 | let mut client = TransportClient::new(channel); [INFO] [stdout] | ----^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Transport` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:11:31 [INFO] [stdout] | [INFO] [stdout] 11 | use super::transport_server::{Transport as TransportService, TransportServer}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `eventflux_app_string` [INFO] [stdout] --> src/core/eventflux_app_runtime.rs:172:9 [INFO] [stdout] | [INFO] [stdout] 172 | eventflux_app_string: Option, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_eventflux_app_string` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable `is_playback` is assigned to, but never used [INFO] [stdout] --> src/core/eventflux_app_runtime.rs:177:13 [INFO] [stdout] | [INFO] [stdout] 177 | let mut is_playback = false; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: consider using `_is_playback` instead [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable `enforce_order` is assigned to, but never used [INFO] [stdout] --> src/core/eventflux_app_runtime.rs:178:13 [INFO] [stdout] | [INFO] [stdout] 178 | let mut enforce_order = false; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: consider using `_enforce_order` instead [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: value assigned to `is_playback` is never read [INFO] [stdout] --> src/core/eventflux_app_runtime.rs:203:35 [INFO] [stdout] | [INFO] [stdout] 203 | "playback" => is_playback = el.value.eq_ignore_ascii_case("true"), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = help: maybe it is overwritten before being read? [INFO] [stdout] = note: `#[warn(unused_assignments)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: value assigned to `enforce_order` is never read [INFO] [stdout] --> src/core/eventflux_app_runtime.rs:205:25 [INFO] [stdout] | [INFO] [stdout] 205 | enforce_order = el.value.eq_ignore_ascii_case("true") [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = help: maybe it is overwritten before being read? [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/config/resolver.rs:355:13 [INFO] [stdout] | [INFO] [stdout] 355 | let mut config = EventFluxConfig::default(); [INFO] [stdout] | ----^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `serialized` [INFO] [stdout] --> src/core/config/types/mod.rs:163:13 [INFO] [stdout] | [INFO] [stdout] 163 | let serialized = serde_json::to_string(&duration).unwrap(); [INFO] [stdout] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_serialized` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `connection` [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:356:29 [INFO] [stdout] | [INFO] [stdout] 356 | async fn receive(&self, connection: &Connection) -> DistributedResult { [INFO] [stdout] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_connection` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/distributed/processing_engine.rs:242:17 [INFO] [stdout] | [INFO] [stdout] 242 | let mut junction = junction.lock().await; [INFO] [stdout] | ----^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `event` [INFO] [stdout] --> src/core/distributed/processing_engine.rs:329:52 [INFO] [stdout] | [INFO] [stdout] 329 | async fn process_event(&self, stream_id: &str, event: Event) -> DistributedResult<()> { [INFO] [stdout] | ^^^^^ help: if this is intentional, prefix it with an underscore: `_event` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `query_id` [INFO] [stdout] --> src/core/distributed/processing_engine.rs:507:34 [INFO] [stdout] | [INFO] [stdout] 507 | async fn assign_query(&self, query_id: &str) -> DistributedResult { [INFO] [stdout] | ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_query_id` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `component` [INFO] [stdout] --> src/core/persistence/state_manager.rs:415:9 [INFO] [stdout] | [INFO] [stdout] 415 | component: Arc, [INFO] [stdout] | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_component` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `snapshot` [INFO] [stdout] --> src/core/persistence/state_manager.rs:416:9 [INFO] [stdout] | [INFO] [stdout] 416 | snapshot: StateSnapshot, [INFO] [stdout] | ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_snapshot` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `component` [INFO] [stdout] --> src/core/persistence/state_manager.rs:429:13 [INFO] [stdout] | [INFO] [stdout] 429 | let component = self [INFO] [stdout] | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_component` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `analysis` [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:486:13 [INFO] [stdout] | [INFO] [stdout] 486 | let analysis = self.analyze_chain(incrementals); [INFO] [stdout] | ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_analysis` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `start_time` [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:541:13 [INFO] [stdout] | [INFO] [stdout] 541 | let start_time = Instant::now(); [INFO] [stdout] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_start_time` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `before` [INFO] [stdout] --> src/core/persistence/incremental/persistence_backend.rs:548:35 [INFO] [stdout] | [INFO] [stdout] 548 | fn cleanup_checkpoints(&self, before: Instant) -> Result { [INFO] [stdout] | ^^^^^^ help: if this is intentional, prefix it with an underscore: `_before` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `operation` [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:432:21 [INFO] [stdout] | [INFO] [stdout] 432 | for operation in &changes.operations { [INFO] [stdout] | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_operation` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `component_id` [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:459:14 [INFO] [stdout] | [INFO] [stdout] 459 | for (component_id, snapshot) in results { [INFO] [stdout] | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_component_id` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `segment_id` [INFO] [stdout] --> src/core/persistence/incremental/write_ahead_log.rs:404:19 [INFO] [stdout] | [INFO] [stdout] 404 | for (&segment_id, segment) in completed_segments.iter() { [INFO] [stdout] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_segment_id` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/processor/stream/window/length_window_state_holder.rs:277:35 [INFO] [stdout] | [INFO] [stdout] 277 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/processor/stream/window/time_window_state_holder.rs:197:13 [INFO] [stdout] | [INFO] [stdout] 197 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/processor/stream/window/length_batch_window_state_holder.rs:232:13 [INFO] [stdout] | [INFO] [stdout] 232 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/processor/stream/window/length_batch_window_state_holder.rs:331:35 [INFO] [stdout] | [INFO] [stdout] 331 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/processor/stream/window/time_batch_window_state_holder.rs:271:13 [INFO] [stdout] | [INFO] [stdout] 271 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/processor/stream/window/time_batch_window_state_holder.rs:388:35 [INFO] [stdout] | [INFO] [stdout] 388 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/processor/stream/window/external_time_window_state_holder.rs:177:13 [INFO] [stdout] | [INFO] [stdout] 177 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/processor/stream/window/external_time_window_state_holder.rs:272:35 [INFO] [stdout] | [INFO] [stdout] 272 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/sum_aggregator_state_holder.rs:161:13 [INFO] [stdout] | [INFO] [stdout] 161 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/sum_aggregator_state_holder.rs:244:35 [INFO] [stdout] | [INFO] [stdout] 244 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/count_aggregator_state_holder.rs:123:13 [INFO] [stdout] | [INFO] [stdout] 123 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/count_aggregator_state_holder.rs:204:35 [INFO] [stdout] | [INFO] [stdout] 204 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/avg_aggregator_state_holder.rs:158:13 [INFO] [stdout] | [INFO] [stdout] 158 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/avg_aggregator_state_holder.rs:240:35 [INFO] [stdout] | [INFO] [stdout] 240 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/min_aggregator_state_holder.rs:136:13 [INFO] [stdout] | [INFO] [stdout] 136 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/min_aggregator_state_holder.rs:218:35 [INFO] [stdout] | [INFO] [stdout] 218 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/max_aggregator_state_holder.rs:136:13 [INFO] [stdout] | [INFO] [stdout] 136 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/max_aggregator_state_holder.rs:218:35 [INFO] [stdout] | [INFO] [stdout] 218 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/distinctcount_aggregator_state_holder.rs:152:13 [INFO] [stdout] | [INFO] [stdout] 152 | let mut data = to_bytes(&state_data).map_err(|e| StateError::SerializationError { [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `changes` [INFO] [stdout] --> src/core/query/selector/attribute/aggregator/distinctcount_aggregator_state_holder.rs:233:35 [INFO] [stdout] | [INFO] [stdout] 233 | fn apply_changelog(&mut self, changes: &ChangeLog) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_changes` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `shutdown_flag` [INFO] [stdout] --> src/core/stream/optimized_stream_junction.rs:348:13 [INFO] [stdout] | [INFO] [stdout] 348 | let shutdown_flag = Arc::clone(&self.shutdown); [INFO] [stdout] | ^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_shutdown_flag` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `where_clause` [INFO] [stdout] --> src/sql_compiler/converter.rs:274:9 [INFO] [stdout] | [INFO] [stdout] 274 | where_clause: &Option, [INFO] [stdout] | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_where_clause` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `get_name` is never used [INFO] [stdout] --> src/core/eventflux_manager.rs:524:8 [INFO] [stdout] | [INFO] [stdout] 523 | impl ApiEventFluxApp { [INFO] [stdout] | -------------------- method in this implementation [INFO] [stdout] 524 | fn get_name(&self) -> Option { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `is_kubernetes_environment` is never used [INFO] [stdout] --> src/core/config/manager.rs:119:8 [INFO] [stdout] | [INFO] [stdout] 53 | impl ConfigManager { [INFO] [stdout] | ------------------ method in this implementation [INFO] [stdout] ... [INFO] [stdout] 119 | fn is_kubernetes_environment(&self) -> bool { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `extract_config_value` is never used [INFO] [stdout] --> src/core/config/processor_config_reader.rs:272:8 [INFO] [stdout] | [INFO] [stdout] 33 | impl ProcessorConfigReader { [INFO] [stdout] | -------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 272 | fn extract_config_value( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `config` is never read [INFO] [stdout] --> src/core/config/security.rs:340:5 [INFO] [stdout] | [INFO] [stdout] 335 | pub struct ExternalSecretProvider { [INFO] [stdout] | ---------------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 340 | config: HashMap, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `ExternalSecretProvider` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `server_handle` is never read [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:41:5 [INFO] [stdout] | [INFO] [stdout] 35 | pub struct GrpcTransport { [INFO] [stdout] | ------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 41 | server_handle: Arc>>, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `shutdown_tx` and `join_handle` are never read [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:109:5 [INFO] [stdout] | [INFO] [stdout] 107 | struct GrpcServerHandle { [INFO] [stdout] | ---------------- fields in this struct [INFO] [stdout] 108 | /// Shutdown signal [INFO] [stdout] 109 | shutdown_tx: oneshot::Sender<()>, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] 110 | /// Server join handle [INFO] [stdout] 111 | join_handle: tokio::task::JoinHandle>, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `client`, `message_tx`, and `response_rx` are never read [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:123:5 [INFO] [stdout] | [INFO] [stdout] 115 | pub struct GrpcConnection { [INFO] [stdout] | -------------- fields in this struct [INFO] [stdout] ... [INFO] [stdout] 123 | client: TransportClient, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] 124 | /// Message sender for streaming [INFO] [stdout] 125 | message_tx: Option>, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] 126 | /// Response receiver for streaming [INFO] [stdout] 127 | response_rx: Option>, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `server_handle` and `connection_rx` are never read [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:135:5 [INFO] [stdout] | [INFO] [stdout] 131 | pub struct GrpcListener { [INFO] [stdout] | ------------ fields in this struct [INFO] [stdout] ... [INFO] [stdout] 135 | server_handle: Option, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] 136 | /// Connection acceptor [INFO] [stdout] 137 | connection_rx: Arc>>>, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `connection_tx` is never read [INFO] [stdout] --> src/core/distributed/grpc/transport.rs:387:5 [INFO] [stdout] | [INFO] [stdout] 385 | pub struct GrpcTransportService { [INFO] [stdout] | -------------------- field in this struct [INFO] [stdout] 386 | /// Connection notifier [INFO] [stdout] 387 | connection_tx: mpsc::UnboundedSender, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `distributed_state` is never read [INFO] [stdout] --> src/core/distributed/processing_engine.rs:428:5 [INFO] [stdout] | [INFO] [stdout] 423 | struct HybridEngine { [INFO] [stdout] | ------------ field in this struct [INFO] [stdout] ... [INFO] [stdout] 428 | distributed_state: Arc>>>, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `config` is never read [INFO] [stdout] --> src/core/distributed/runtime_mode.rs:20:5 [INFO] [stdout] | [INFO] [stdout] 15 | pub struct RuntimeModeManager { [INFO] [stdout] | ------------------ field in this struct [INFO] [stdout] ... [INFO] [stdout] 20 | config: Arc, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `config` is never read [INFO] [stdout] --> src/core/distributed/runtime_mode.rs:191:5 [INFO] [stdout] | [INFO] [stdout] 190 | struct SingleNodeMode { [INFO] [stdout] | -------------- field in this struct [INFO] [stdout] 191 | config: Arc, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `coordinator` and `start_time` are never read [INFO] [stdout] --> src/core/distributed/runtime_mode.rs:266:5 [INFO] [stdout] | [INFO] [stdout] 264 | struct DistributedMode { [INFO] [stdout] | --------------- fields in this struct [INFO] [stdout] 265 | config: Arc, [INFO] [stdout] 266 | coordinator: Option>, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] 267 | start_time: std::time::Instant, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `config` and `distributed_state` are never read [INFO] [stdout] --> src/core/distributed/runtime_mode.rs:374:5 [INFO] [stdout] | [INFO] [stdout] 373 | struct HybridMode { [INFO] [stdout] | ---------- fields in this struct [INFO] [stdout] 374 | config: Arc, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] 375 | single_node: SingleNodeMode, [INFO] [stdout] 376 | distributed_state: Option>, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `0` is never read [INFO] [stdout] --> src/core/distributed/transport.rs:58:10 [INFO] [stdout] | [INFO] [stdout] 58 | Grpc(String), [INFO] [stdout] | ---- ^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | field in this variant [INFO] [stdout] | [INFO] [stdout] = note: `ConnectionHandle` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] help: consider changing the field to be of unit type to suppress this warning while preserving the field numbering, or remove the field [INFO] [stdout] | [INFO] [stdout] 58 - Grpc(String), [INFO] [stdout] 58 + Grpc(()), [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple fields are never read [INFO] [stdout] --> src/core/persistence/incremental/mod.rs:214:5 [INFO] [stdout] | [INFO] [stdout] 212 | pub struct IncrementalCheckpointSystem { [INFO] [stdout] | --------------------------- fields in this struct [INFO] [stdout] 213 | /// System configuration [INFO] [stdout] 214 | config: IncrementalCheckpointConfig, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 217 | wal: Arc, [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 220 | merger: Arc, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 223 | backend: Arc, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 226 | recovery: Arc, [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 229 | coordinator: Option>, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 232 | current_chain: Vec, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | last_full_checkpoint: Option, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 238 | metrics: IncrementalCheckpointMetrics, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `compression_level` is never read [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:114:5 [INFO] [stdout] | [INFO] [stdout] 109 | pub struct CompressionEngine { [INFO] [stdout] | ----------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 114 | compression_level: u8, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `MergeResult` is never constructed [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:141:8 [INFO] [stdout] | [INFO] [stdout] 141 | struct MergeResult { [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `MergedComponentState` is never constructed [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:157:8 [INFO] [stdout] | [INFO] [stdout] 157 | struct MergedComponentState { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `MergeMetadata` is never constructed [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:173:8 [INFO] [stdout] | [INFO] [stdout] 173 | struct MergeMetadata { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `total_checkpoints`, `total_size`, `component_frequencies`, and `operation_counts` are never read [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:725:5 [INFO] [stdout] | [INFO] [stdout] 724 | struct ChainAnalysis { [INFO] [stdout] | ------------- fields in this struct [INFO] [stdout] 725 | total_checkpoints: usize, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] 726 | total_size: usize, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] 727 | component_frequencies: HashMap, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] 728 | operation_counts: HashMap, [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `ChainAnalysis` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `checkpoint_range`, `overlapping_components`, `potential_savings`, and `merge_type` are never read [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:735:5 [INFO] [stdout] | [INFO] [stdout] 734 | struct MergeOpportunity { [INFO] [stdout] | ---------------- fields in this struct [INFO] [stdout] 735 | checkpoint_range: (CheckpointId, CheckpointId), [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] 736 | overlapping_components: usize, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] 737 | potential_savings: usize, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] 738 | merge_type: MergeOpportunityType, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `MergeOpportunity` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variants `ConsecutiveUpdates` and `RedundantOperations` are never constructed [INFO] [stdout] --> src/core/persistence/incremental/checkpoint_merger.rs:746:5 [INFO] [stdout] | [INFO] [stdout] 743 | enum MergeOpportunityType { [INFO] [stdout] | -------------------- variants in this enum [INFO] [stdout] ... [INFO] [stdout] 746 | ConsecutiveUpdates, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] 747 | RedundantOperations, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `MergeOpportunityType` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `last_heartbeat` and `health` are never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:71:5 [INFO] [stdout] | [INFO] [stdout] 57 | struct NodeState { [INFO] [stdout] | --------- fields in this struct [INFO] [stdout] ... [INFO] [stdout] 71 | last_heartbeat: Instant, [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 74 | health: NodeHealth, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `NodeState` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variants `Degraded` and `Failed` are never constructed [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:89:5 [INFO] [stdout] | [INFO] [stdout] 87 | enum NodeHealth { [INFO] [stdout] | ---------- variants in this enum [INFO] [stdout] 88 | Healthy, [INFO] [stdout] 89 | Degraded { reason: String }, [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] 90 | Failed { reason: String }, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `NodeHealth` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `node_id`, `endpoints`, `last_seen`, and `capabilities` are never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:97:5 [INFO] [stdout] | [INFO] [stdout] 95 | struct NodeInfo { [INFO] [stdout] | -------- fields in this struct [INFO] [stdout] 96 | /// Node identifier [INFO] [stdout] 97 | node_id: String, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 100 | endpoints: Vec, [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 103 | last_seen: Instant, [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 106 | capabilities: NodeCapabilities, [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `NodeInfo` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `can_be_leader`, `storage_capacity`, `processing_capacity`, and `network_bandwidth` are never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:116:5 [INFO] [stdout] | [INFO] [stdout] 114 | struct NodeCapabilities { [INFO] [stdout] | ---------------- fields in this struct [INFO] [stdout] 115 | /// Can participate in leader election [INFO] [stdout] 116 | can_be_leader: bool, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 119 | storage_capacity: u64, [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 122 | processing_capacity: u32, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 125 | network_bandwidth: u64, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `NodeCapabilities` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `expected_completion` is never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:147:5 [INFO] [stdout] | [INFO] [stdout] 130 | struct CheckpointProgress { [INFO] [stdout] | ------------------ field in this struct [INFO] [stdout] ... [INFO] [stdout] 147 | expected_completion: Option, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `CheckpointProgress` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `checkpoint_type` and `timeout` are never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:157:5 [INFO] [stdout] | [INFO] [stdout] 155 | struct CheckpointMetadata { [INFO] [stdout] | ------------------ fields in this struct [INFO] [stdout] 156 | /// Checkpoint type [INFO] [stdout] 157 | checkpoint_type: String, [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 163 | timeout: Duration, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `CheckpointMetadata` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `term`, `index`, `entry_type`, `data`, and `timestamp` are never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:189:5 [INFO] [stdout] | [INFO] [stdout] 187 | struct ConsensusEntry { [INFO] [stdout] | -------------- fields in this struct [INFO] [stdout] 188 | /// Entry term [INFO] [stdout] 189 | term: u64, [INFO] [stdout] | ^^^^ [INFO] [stdout] ... [INFO] [stdout] 192 | index: u64, [INFO] [stdout] | ^^^^^ [INFO] [stdout] ... [INFO] [stdout] 195 | entry_type: ConsensusEntryType, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 198 | data: Vec, [INFO] [stdout] | ^^^^ [INFO] [stdout] ... [INFO] [stdout] 201 | timestamp: Instant, [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `ConsensusEntry` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variants `NodeJoin`, `NodeLeave`, and `Configuration` are never constructed [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:209:5 [INFO] [stdout] | [INFO] [stdout] 206 | enum ConsensusEntryType { [INFO] [stdout] | ------------------ variants in this enum [INFO] [stdout] ... [INFO] [stdout] 209 | NodeJoin, [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] 210 | NodeLeave, [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] 211 | Configuration, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `ConsensusEntryType` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `leader_elections`, `network_partitions`, and `avg_cluster_size` are never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:230:9 [INFO] [stdout] | [INFO] [stdout] 216 | struct CoordinatorStatistics { [INFO] [stdout] | --------------------- fields in this struct [INFO] [stdout] ... [INFO] [stdout] 230 | pub leader_elections: u64, [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 233 | pub network_partitions: u64, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 236 | pub avg_cluster_size: f64, [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `CoordinatorStatistics` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `checkpoints` is never read [INFO] [stdout] --> src/core/persistence/incremental/distributed_coordinator.rs:249:5 [INFO] [stdout] | [INFO] [stdout] 241 | struct SimulatedClusterState { [INFO] [stdout] | --------------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 249 | checkpoints: HashMap, [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `SimulatedClusterState` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `replication_factor` and `stats` are never read [INFO] [stdout] --> src/core/persistence/incremental/persistence_backend.rs:61:5 [INFO] [stdout] | [INFO] [stdout] 53 | pub struct DistributedPersistenceBackend { [INFO] [stdout] | ----------------------------- fields in this struct [INFO] [stdout] ... [INFO] [stdout] 61 | replication_factor: usize, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 67 | stats: Arc>, [INFO] [stdout] | ^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `failed_operations` and `cache_hit_rate` are never read [INFO] [stdout] --> src/core/persistence/incremental/persistence_backend.rs:124:9 [INFO] [stdout] | [INFO] [stdout] 104 | struct BackendStatistics { [INFO] [stdout] | ----------------- fields in this struct [INFO] [stdout] ... [INFO] [stdout] 124 | pub failed_operations: u64, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 127 | pub cache_hit_rate: f64, [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `BackendStatistics` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `calculate_file_checksum` is never used [INFO] [stdout] --> src/core/persistence/incremental/persistence_backend.rs:334:8 [INFO] [stdout] | [INFO] [stdout] 156 | impl FilePersistenceBackend { [INFO] [stdout] | --------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 334 | fn calculate_file_checksum(&self, data: &[u8]) -> u64 { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `merger` and `stats` are never read [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:27:5 [INFO] [stdout] | [INFO] [stdout] 22 | pub struct AdvancedRecoveryEngine { [INFO] [stdout] | ---------------------- fields in this struct [INFO] [stdout] ... [INFO] [stdout] 27 | merger: Arc, [INFO] [stdout] | ^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 36 | stats: RecoveryStatistics, [INFO] [stdout] | ^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `checkpoint_id` and `components` are never read [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:103:9 [INFO] [stdout] | [INFO] [stdout] 101 | struct CheckpointInfo { [INFO] [stdout] | -------------- fields in this struct [INFO] [stdout] 102 | /// Checkpoint identifier [INFO] [stdout] 103 | pub checkpoint_id: CheckpointId, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 118 | pub components: HashSet, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `CheckpointInfo` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `estimated_duration` is never read [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:157:9 [INFO] [stdout] | [INFO] [stdout] 152 | struct RecoveryPlan { [INFO] [stdout] | ------------ field in this struct [INFO] [stdout] ... [INFO] [stdout] 157 | pub estimated_duration: Duration, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `RecoveryPlan` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `dependencies` is never read [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:176:9 [INFO] [stdout] | [INFO] [stdout] 168 | struct RecoveryStage { [INFO] [stdout] | ------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 176 | pub dependencies: Vec, [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `RecoveryStage` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `start_time` is never read [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:195:9 [INFO] [stdout] | [INFO] [stdout] 184 | struct RecoveryContext { [INFO] [stdout] | --------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 195 | pub start_time: Instant, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `RecoveryContext` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `build_checkpoint_cache` is never used [INFO] [stdout] --> src/core/persistence/incremental/recovery_engine.rs:225:8 [INFO] [stdout] | [INFO] [stdout] 208 | impl AdvancedRecoveryEngine { [INFO] [stdout] | --------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 225 | fn build_checkpoint_cache(&mut self) -> Result<(), StateError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `deserialize_event` is never used [INFO] [stdout] --> src/core/query/processor/stream/window/session_window_state_holder.rs:169:8 [INFO] [stdout] | [INFO] [stdout] 90 | impl SessionWindowStateHolder { [INFO] [stdout] | ----------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 169 | fn deserialize_event(&self, data: &[u8]) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `comparator` is never read [INFO] [stdout] --> src/core/query/processor/stream/window/sort_window_processor.rs:30:5 [INFO] [stdout] | [INFO] [stdout] 22 | pub struct SortWindowProcessor { [INFO] [stdout] | ------------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 30 | comparator: OrderByEventComparator, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `SortWindowProcessor` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `should_use_memory_optimization` is never used [INFO] [stdout] --> src/core/query/processor/stream/window/sort_window_processor.rs:131:8 [INFO] [stdout] | [INFO] [stdout] 33 | impl SortWindowProcessor { [INFO] [stdout] | ------------------------ method in this implementation [INFO] [stdout] ... [INFO] [stdout] 131 | fn should_use_memory_optimization(&self) -> bool { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `clear_change_log` is never used [INFO] [stdout] --> src/core/query/processor/stream/window/length_window_state_holder.rs:159:12 [INFO] [stdout] | [INFO] [stdout] 45 | impl LengthWindowStateHolder { [INFO] [stdout] | ---------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 159 | pub fn clear_change_log(&self, checkpoint_id: CheckpointId) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `clear_change_log` is never used [INFO] [stdout] --> src/core/query/processor/stream/window/time_window_state_holder.rs:146:12 [INFO] [stdout] | [INFO] [stdout] 51 | impl TimeWindowStateHolder { [INFO] [stdout] | -------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 146 | pub fn clear_change_log(&self, checkpoint_id: CheckpointId) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `clear_change_log` is never used [INFO] [stdout] --> src/core/query/processor/stream/window/length_batch_window_state_holder.rs:164:12 [INFO] [stdout] | [INFO] [stdout] 50 | impl LengthBatchWindowStateHolder { [INFO] [stdout] | --------------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 164 | pub fn clear_change_log(&self, checkpoint_id: CheckpointId) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `clear_change_log` is never used [INFO] [stdout] --> src/core/query/processor/stream/window/time_batch_window_state_holder.rs:200:12 [INFO] [stdout] | [INFO] [stdout] 53 | impl TimeBatchWindowStateHolder { [INFO] [stdout] | ------------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 200 | pub fn clear_change_log(&self, checkpoint_id: CheckpointId) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `clear_change_log` is never used [INFO] [stdout] --> src/core/query/processor/stream/window/external_time_window_state_holder.rs:145:12 [INFO] [stdout] | [INFO] [stdout] 44 | impl ExternalTimeWindowStateHolder { [INFO] [stdout] | ---------------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 145 | pub fn clear_change_log(&self, checkpoint_id: CheckpointId) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `event_pool` is never read [INFO] [stdout] --> src/core/stream/optimized_stream_junction.rs:48:5 [INFO] [stdout] | [INFO] [stdout] 40 | pub struct OptimizedStreamJunction { [INFO] [stdout] | ----------------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 48 | event_pool: Arc, [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `snappy_contexts` is never read [INFO] [stdout] --> src/core/util/compression.rs:180:5 [INFO] [stdout] | [INFO] [stdout] 176 | pub struct OptimizedCompressionEngine { [INFO] [stdout] | -------------------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 180 | snappy_contexts: ThreadLocal, [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `encoder` and `decoder` are never read [INFO] [stdout] --> src/core/util/compression.rs:196:5 [INFO] [stdout] | [INFO] [stdout] 195 | struct SnapContext { [INFO] [stdout] | ----------- fields in this struct [INFO] [stdout] 196 | encoder: snap::raw::Encoder, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] 197 | decoder: snap::raw::Decoder, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `get_first_stream_id_placeholder` is never used [INFO] [stdout] --> src/core/util/parser/eventflux_app_parser.rs:326:8 [INFO] [stdout] | [INFO] [stdout] 325 | impl ApiInputStream { [INFO] [stdout] | ------------------- method in this implementation [INFO] [stdout] 326 | fn get_first_stream_id_placeholder(&self) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function `new` is never used [INFO] [stdout] --> src/core/util/pipeline/object_pool.rs:26:8 [INFO] [stdout] | [INFO] [stdout] 24 | impl PooledEvent { [INFO] [stdout] | ---------------- associated function in this implementation [INFO] [stdout] 25 | /// Create a new pooled event [INFO] [stdout] 26 | fn new(pool: Arc) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `eventflux_element_ref` and `eventflux_element_mut_ref` are never used [INFO] [stdout] --> src/query_api/execution/query/input/handler/stream_handler.rs:27:8 [INFO] [stdout] | [INFO] [stdout] 25 | impl StreamHandler { [INFO] [stdout] | ------------------ methods in this implementation [INFO] [stdout] 26 | // Accessing the composed eventflux_element from the variants [INFO] [stdout] 27 | fn eventflux_element_ref(&self) -> &EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 35 | fn eventflux_element_mut_ref(&mut self) -> &mut EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `eventflux_element_ref` and `eventflux_element_mut_ref` are never used [INFO] [stdout] --> src/query_api/execution/query/input/state/state_element.rs:26:8 [INFO] [stdout] | [INFO] [stdout] 25 | impl StateElement { [INFO] [stdout] | ----------------- methods in this implementation [INFO] [stdout] 26 | fn eventflux_element_ref(&self) -> &EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 37 | fn eventflux_element_mut_ref(&mut self) -> &mut EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `get_stream_id` is never used [INFO] [stdout] --> src/query_api/execution/query/input/state/stream_state_element.rs:35:19 [INFO] [stdout] | [INFO] [stdout] 18 | impl StreamStateElement { [INFO] [stdout] | ----------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 35 | pub(crate) fn get_stream_id(&self) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `eventflux_element_ref` and `eventflux_element_mut_ref` are never used [INFO] [stdout] --> src/query_api/execution/query/input/store/input_store.rs:39:8 [INFO] [stdout] | [INFO] [stdout] 27 | impl InputStore { [INFO] [stdout] | --------------- methods in this implementation [INFO] [stdout] ... [INFO] [stdout] 39 | fn eventflux_element_ref(&self) -> &EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 46 | fn eventflux_element_mut_ref(&mut self) -> &mut EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `eventflux_element_ref` and `eventflux_element_mut_ref` are never used [INFO] [stdout] --> src/query_api/execution/query/input/stream/input_stream.rs:39:8 [INFO] [stdout] | [INFO] [stdout] 36 | impl InputStream { [INFO] [stdout] | ---------------- methods in this implementation [INFO] [stdout] ... [INFO] [stdout] 39 | fn eventflux_element_ref(&self) -> &EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 47 | fn eventflux_element_mut_ref(&mut self) -> &mut EventFluxElement { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `parse_attribute_type` is never used [INFO] [stdout] --> src/query_compiler/eventflux_compiler.rs:163:4 [INFO] [stdout] | [INFO] [stdout] 163 | fn parse_attribute_type(t: &str) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: comparison is useless due to type limits [INFO] [stdout] --> src/core/config/validation_api.rs:1150:17 [INFO] [stdout] | [INFO] [stdout] 1150 | assert!(report.validation_duration.as_nanos() >= 0); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_comparisons)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 1m 53s [INFO] [stderr] warning: the following packages contain code that will be rejected by a future version of Rust: redis v0.25.4 [INFO] [stderr] note: to see what the problems were, use the option `--future-incompat-report`, or run `cargo report future-incompatibilities --id 4` [INFO] running `Command { std: "docker" "inspect" "c322fcd1a43e63883d44db0d524dc226ad54bea6636c88880922b7b0414118ea", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "c322fcd1a43e63883d44db0d524dc226ad54bea6636c88880922b7b0414118ea", kill_on_drop: false }` [INFO] [stdout] c322fcd1a43e63883d44db0d524dc226ad54bea6636c88880922b7b0414118ea