[INFO] cloning repository https://github.com/alexbezrukov/streaming
[INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/alexbezrukov/streaming" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Falexbezrukov%2Fstreaming", kill_on_drop: false }`
[INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Falexbezrukov%2Fstreaming'...
[INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }`
[INFO] [stdout] 89ef77cb437a89a335bb9bf3a904f7aa16f945b7
[INFO] testing alexbezrukov/streaming against 1.99.0-beta.8 for beta-1.100-4
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Falexbezrukov%2Fstreaming" "/workspace/builds/worker-4-tc1/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-4-tc1/source'...
[INFO] [stderr] done.
[INFO] started tweaking git repo https://github.com/alexbezrukov/streaming
[INFO] finished tweaking git repo https://github.com/alexbezrukov/streaming
[INFO] tweaked toml for git repo https://github.com/alexbezrukov/streaming written to /workspace/builds/worker-4-tc1/source/Cargo.toml
[INFO] validating manifest of git repo https://github.com/alexbezrukov/streaming on toolchain 1.99.0-beta.8
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.99.0-beta.8" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] crate git repo https://github.com/alexbezrukov/streaming already has a lockfile, it will not be regenerated
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.99.0-beta.8" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Updating crates.io index
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded wasm-bindgen v0.2.106
[INFO] [stderr]   Downloaded wasm-bindgen-macro v0.2.106
[INFO] [stderr]   Downloaded js-sys v0.3.83
[INFO] [stderr]   Downloaded tracing-serde v0.2.0
[INFO] [stderr]   Downloaded matchers v0.2.0
[INFO] [stderr]   Downloaded wasm-bindgen-shared v0.2.106
[INFO] [stderr]   Downloaded compression-core v0.4.31
[INFO] [stderr]   Downloaded alloc-stdlib v0.2.2
[INFO] [stderr]   Downloaded alloc-no-stdlib v2.0.4
[INFO] [stderr]   Downloaded futures-macro v0.3.31
[INFO] [stderr]   Downloaded valuable v0.1.1
[INFO] [stderr]   Downloaded tracing-log v0.2.0
[INFO] [stderr]   Downloaded nu-ansi-term v0.50.3
[INFO] [stderr]   Downloaded zmij v1.0.12
[INFO] [stderr]   Downloaded tokio-macros v2.6.0
[INFO] [stderr]   Downloaded simd-adler32 v0.3.8
[INFO] [stderr]   Downloaded pin-project-internal v1.1.10
[INFO] [stderr]   Downloaded toml_write v0.1.2
[INFO] [stderr]   Downloaded toml_datetime v0.6.11
[INFO] [stderr]   Downloaded serde_spanned v0.6.9
[INFO] [stderr]   Downloaded compression-codecs v0.4.35
[INFO] [stderr]   Downloaded slab v0.4.11
[INFO] [stderr]   Downloaded wasm-bindgen-macro-support v0.2.106
[INFO] [stderr]   Downloaded find-msvc-tools v0.1.7
[INFO] [stderr]   Downloaded crc32fast v1.5.0
[INFO] [stderr]   Downloaded getrandom v0.2.16
[INFO] [stderr]   Downloaded toml v0.8.23
[INFO] [stderr]   Downloaded tokio-test v0.4.5
[INFO] [stderr]   Downloaded wasm-bindgen-futures v0.4.56
[INFO] [stderr]   Downloaded wit-bindgen v0.46.0
[INFO] [stderr]   Downloaded sharded-slab v0.1.7
[INFO] [stderr]   Downloaded tokio-stream v0.1.18
[INFO] [stderr]   Downloaded flate2 v1.1.5
[INFO] [stderr]   Downloaded miniz_oxide v0.8.9
[INFO] [stderr]   Downloaded pin-project v1.1.10
[INFO] [stderr]   Downloaded toml_edit v0.22.27
[INFO] [stderr]   Downloaded rustls-pki-types v1.13.2
[INFO] [stderr]   Downloaded async-compression v0.4.36
[INFO] [stderr]   Downloaded cc v1.2.52
[INFO] [stderr]   Downloaded zerocopy-derive v0.8.33
[INFO] [stderr]   Downloaded rustls-webpki v0.103.8
[INFO] [stderr]   Downloaded openssl-probe v0.2.0
[INFO] [stderr]   Downloaded wasip2 v1.0.1+wasi-0.2.4
[INFO] [stderr]   Downloaded tower-http v0.5.2
[INFO] [stderr]   Downloaded brotli-decompressor v5.0.0
[INFO] [stderr]   Downloaded reqwest v0.13.1
[INFO] [stderr]   Downloaded tracing-subscriber v0.3.22
[INFO] [stderr]   Downloaded zerocopy v0.8.33
[INFO] [stderr]   Downloaded webpki-root-certs v1.0.5
[INFO] [stderr]   Downloaded thiserror v2.0.17
[INFO] [stderr]   Downloaded thiserror-impl v2.0.17
[INFO] [stderr]   Downloaded system-configuration v0.6.1
[INFO] [stderr]   Downloaded num_cpus v1.17.0
[INFO] [stderr]   Downloaded lru v0.12.5
[INFO] [stderr]   Downloaded hdrhistogram v7.5.4
[INFO] [stderr]   Downloaded aws-lc-rs v1.15.2
[INFO] [stderr]   Downloaded tokio-retry v0.3.0
[INFO] [stderr]   Downloaded sha1_smol v1.0.1
[INFO] [stderr]   Downloaded crc16 v0.4.0
[INFO] [stderr]   Downloaded socket2 v0.4.10
[INFO] [stderr]   Downloaded futures-executor v0.3.31
[INFO] [stderr]   Downloaded dotenvy v0.15.7
[INFO] [stderr]   Downloaded dashmap v5.5.3
[INFO] [stderr]   Downloaded is-terminal v0.4.17
[INFO] [stderr]   Downloaded clap_lex v0.7.6
[INFO] [stderr]   Downloaded crunchy v0.2.4
[INFO] [stderr]   Downloaded utf-8 v0.7.6
[INFO] [stderr]   Downloaded regex-syntax v0.8.8
[INFO] [stderr]   Downloaded hyper-util v0.1.19
[INFO] [stderr]   Downloaded ryu v1.0.22
[INFO] [stderr]   Downloaded serde_path_to_error v0.1.20
[INFO] [stderr]   Downloaded oorandom v11.1.5
[INFO] [stderr]   Downloaded tokio-tungstenite v0.24.0
[INFO] [stderr]   Downloaded data-encoding v2.9.0
[INFO] [stderr]   Downloaded arc-swap v1.8.0
[INFO] [stderr]   Downloaded tungstenite v0.24.0
[INFO] [stderr]   Downloaded axum-macros v0.4.2
[INFO] [stderr]   Downloaded anyhow v1.0.100
[INFO] [stderr]   Downloaded clap v4.5.54
[INFO] [stderr]   Downloaded half v2.7.1
[INFO] [stderr]   Downloaded hashbrown v0.14.5
[INFO] [stderr]   Downloaded regex v1.12.2
[INFO] [stderr]   Downloaded redis v0.24.0
[INFO] [stderr]   Downloaded clap_builder v4.5.54
[INFO] [stderr]   Downloaded web-sys v0.3.83
[INFO] [stderr]   Downloaded regex-automata v0.4.13
[INFO] [stderr]   Downloaded zstd-sys v2.0.16+zstd.1.5.7
[INFO] [stderr]   Downloaded brotli v8.0.2
[INFO] [stderr]   Downloaded aws-lc-sys v0.35.0
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc1/target:/opt/rustwide/target:rw,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" "-m" "1610612736" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:77db811e55d90add9212f6832c23229e3de5f1c1f9905e8cb07319ea15df73ac" "sleep" "infinity", kill_on_drop: false }`
[INFO] [stdout] 9a78478e0d9b7047f669200108f6b5c48d87ede5954b478e300323214bfa21d6
[INFO] running `Command { std: "docker" "start" "9a78478e0d9b7047f669200108f6b5c48d87ede5954b478e300323214bfa21d6", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "9a78478e0d9b7047f669200108f6b5c48d87ede5954b478e300323214bfa21d6", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-w" "/opt/rustwide/workdir" "--user" "0:0" "9a78478e0d9b7047f669200108f6b5c48d87ede5954b478e300323214bfa21d6" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "9a78478e0d9b7047f669200108f6b5c48d87ede5954b478e300323214bfa21d6", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-w" "/opt/rustwide/workdir" "--user" "0:0" "9a78478e0d9b7047f669200108f6b5c48d87ede5954b478e300323214bfa21d6" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stderr]    Compiling proc-macro2 v1.0.105
[INFO] [stderr]    Compiling quote v1.0.43
[INFO] [stderr]    Compiling unicode-ident v1.0.22
[INFO] [stderr]    Compiling libc v0.2.180
[INFO] [stderr]    Compiling cfg-if v1.0.4
[INFO] [stderr]    Compiling smallvec v1.15.1
[INFO] [stderr]    Compiling pin-project-lite v0.2.16
[INFO] [stderr]    Compiling shlex v1.3.0
[INFO] [stderr]    Compiling bytes v1.11.0
[INFO] [stderr]    Compiling find-msvc-tools v0.1.7
[INFO] [stderr]    Compiling futures-core v0.3.31
[INFO] [stderr]    Compiling parking_lot_core v0.9.12
[INFO] [stderr]    Compiling scopeguard v1.2.0
[INFO] [stderr]    Compiling memchr v2.7.6
[INFO] [stderr]    Compiling lock_api v0.4.14
[INFO] [stderr]    Compiling itoa v1.0.17
[INFO] [stderr]    Compiling futures-sink v0.3.31
[INFO] [stderr]    Compiling log v0.4.29
[INFO] [stderr]    Compiling tracing-core v0.1.36
[INFO] [stderr]    Compiling serde_core v1.0.228
[INFO] [stderr]    Compiling stable_deref_trait v1.2.1
[INFO] [stderr]    Compiling slab v0.4.11
[INFO] [stderr]    Compiling futures-channel v0.3.31
[INFO] [stderr]    Compiling pin-utils v0.1.0
[INFO] [stderr]    Compiling http v1.4.0
[INFO] [stderr]    Compiling futures-io v0.3.31
[INFO] [stderr]    Compiling futures-task v0.3.31
[INFO] [stderr]    Compiling fs_extra v1.3.0
[INFO] [stderr]    Compiling syn v2.0.114
[INFO] [stderr]    Compiling dunce v1.0.5
[INFO] [stderr]    Compiling zerocopy v0.8.33
[INFO] [stderr]    Compiling typenum v1.19.0
[INFO] [stderr]    Compiling equivalent v1.0.2
[INFO] [stderr]    Compiling version_check v0.9.5
[INFO] [stderr]    Compiling zeroize v1.8.2
[INFO] [stderr]    Compiling jobserver v0.1.34
[INFO] [stderr]    Compiling errno v0.3.14
[INFO] [stderr]    Compiling socket2 v0.6.1
[INFO] [stderr]    Compiling mio v1.1.1
[INFO] [stderr]    Compiling parking_lot v0.12.5
[INFO] [stderr]    Compiling cc v1.2.52
[INFO] [stderr]    Compiling signal-hook-registry v1.4.8
[INFO] [stderr]    Compiling generic-array v0.14.7
[INFO] [stderr]    Compiling http-body v1.0.1
[INFO] [stderr]    Compiling getrandom v0.2.16
[INFO] [stderr]    Compiling httparse v1.10.1
[INFO] [stderr]    Compiling aws-lc-rs v1.15.2
[INFO] [stderr]    Compiling tower-service v0.3.3
[INFO] [stderr]    Compiling writeable v0.6.2
[INFO] [stderr]    Compiling litemap v0.8.1
[INFO] [stderr]    Compiling hashbrown v0.16.1
[INFO] [stderr]    Compiling rand_core v0.6.4
[INFO] [stderr]    Compiling icu_normalizer_data v2.1.1
[INFO] [stderr]    Compiling percent-encoding v2.3.2
[INFO] [stderr]    Compiling cmake v0.1.57
[INFO] [stderr]    Compiling icu_properties_data v2.1.2
[INFO] [stderr]    Compiling rustls-pki-types v1.13.2
[INFO] [stderr]    Compiling indexmap v2.13.0
[INFO] [stderr]    Compiling tower-layer v0.3.3
[INFO] [stderr]    Compiling aws-lc-sys v0.35.0
[INFO] [stderr]    Compiling zstd-sys v2.0.16+zstd.1.5.7
[INFO] [stderr]    Compiling zstd-safe v7.2.4
[INFO] [stderr]    Compiling fnv v1.0.7
[INFO] [stderr]    Compiling alloc-no-stdlib v2.0.4
[INFO] [stderr]    Compiling block-buffer v0.10.4
[INFO] [stderr]    Compiling crypto-common v0.1.7
[INFO] [stderr]    Compiling zmij v1.0.12
[INFO] [stderr]    Compiling rustversion v1.0.22
[INFO] [stderr]    Compiling atomic-waker v1.1.2
[INFO] [stderr]    Compiling try-lock v0.2.5
[INFO] [stderr]    Compiling untrusted v0.9.0
[INFO] [stderr]    Compiling crc32fast v1.5.0
[INFO] [stderr]    Compiling rustls v0.23.36
[INFO] [stderr]    Compiling want v0.3.1
[INFO] [stderr]    Compiling digest v0.10.7
[INFO] [stderr]    Compiling alloc-stdlib v0.2.2
[INFO] [stderr]    Compiling form_urlencoded v1.2.2
[INFO] [stderr]    Compiling sync_wrapper v1.0.2
[INFO] [stderr]    Compiling ppv-lite86 v0.2.21
[INFO] [stderr]    Compiling subtle v2.6.1
[INFO] [stderr]    Compiling simd-adler32 v0.3.8
[INFO] [stderr]    Compiling serde_json v1.0.149
[INFO] [stderr]    Compiling byteorder v1.5.0
[INFO] [stderr]    Compiling thiserror v1.0.69
[INFO] [stderr]    Compiling cpufeatures v0.2.17
[INFO] [stderr]    Compiling httpdate v1.0.3
[INFO] [stderr]    Compiling adler2 v2.0.1
[INFO] [stderr]    Compiling miniz_oxide v0.8.9
[INFO] [stderr]    Compiling brotli-decompressor v5.0.0
[INFO] [stderr]    Compiling rand_chacha v0.3.1
[INFO] [stderr]    Compiling rand v0.8.5
[INFO] [stderr]    Compiling num-traits v0.2.19
[INFO] [stderr]    Compiling http-body-util v0.1.3
[INFO] [stderr]    Compiling base64 v0.22.1
[INFO] [stderr]    Compiling utf8_iter v1.0.4
[INFO] [stderr]    Compiling ipnet v2.11.0
[INFO] [stderr]    Compiling flate2 v1.1.5
[INFO] [stderr]    Compiling brotli v8.0.2
[INFO] [stderr]    Compiling synstructure v0.13.2
[INFO] [stderr]    Compiling sha1 v0.10.6
[INFO] [stderr]    Compiling indexmap v1.9.3
[INFO] [stderr]    Compiling mime v0.3.17
[INFO] [stderr]    Compiling openssl-probe v0.2.0
[INFO] [stderr]    Compiling bitflags v2.10.0
[INFO] [stderr]    Compiling compression-core v0.4.31
[INFO] [stderr]    Compiling crc16 v0.4.0
[INFO] [stderr]    Compiling ryu v1.0.22
[INFO] [stderr]    Compiling regex-syntax v0.8.8
[INFO] [stderr]    Compiling getrandom v0.3.4
[INFO] [stderr]    Compiling data-encoding v2.9.0
[INFO] [stderr]    Compiling utf-8 v0.7.6
[INFO] [stderr]    Compiling rustls-native-certs v0.8.3
[INFO] [stderr]    Compiling iri-string v0.7.10
[INFO] [stderr]    Compiling allocator-api2 v0.2.21
[INFO] [stderr]    Compiling tokio-macros v2.6.0
[INFO] [stderr]    Compiling zerofrom-derive v0.1.6
[INFO] [stderr]    Compiling yoke-derive v0.8.1
[INFO] [stderr]    Compiling tokio v1.49.0
[INFO] [stderr]    Compiling futures-macro v0.3.31
[INFO] [stderr]    Compiling zerofrom v0.1.6
[INFO] [stderr]    Compiling zerovec-derive v0.11.2
[INFO] [stderr]    Compiling yoke v0.8.1
[INFO] [stderr]    Compiling tracing-attributes v0.1.31
[INFO] [stderr]    Compiling displaydoc v0.2.5
[INFO] [stderr]    Compiling futures-util v0.3.31
[INFO] [stderr]    Compiling serde_derive v1.0.228
[INFO] [stderr]    Compiling zerotrie v0.2.3
[INFO] [stderr]    Compiling zerovec v0.11.5
[INFO] [stderr]    Compiling pin-project-internal v1.1.10
[INFO] [stderr]    Compiling tracing v0.1.44
[INFO] [stderr]    Compiling thiserror-impl v1.0.69
[INFO] [stderr]    Compiling tinystr v0.8.2
[INFO] [stderr]    Compiling icu_locale_core v2.1.1
[INFO] [stderr]    Compiling potential_utf v0.1.4
[INFO] [stderr]    Compiling icu_collections v2.1.1
[INFO] [stderr]    Compiling pin-project v1.1.10
[INFO] [stderr]    Compiling async-trait v0.1.89
[INFO] [stderr]    Compiling icu_provider v2.1.1
[INFO] [stderr]    Compiling tungstenite v0.24.0
[INFO] [stderr]    Compiling icu_normalizer v2.1.1
[INFO] [stderr]    Compiling icu_properties v2.1.2
[INFO] [stderr]    Compiling serde v1.0.228
[INFO] [stderr]    Compiling futures-executor v0.3.31
[INFO] [stderr]    Compiling regex-automata v0.4.13
[INFO] [stderr]    Compiling hashbrown v0.12.3
[INFO] [stderr]    Compiling tokio-util v0.7.18
[INFO] [stderr]    Compiling tower v0.5.2
[INFO] [stderr]    Compiling idna_adapter v1.2.1
[INFO] [stderr]    Compiling idna v1.1.0
[INFO] [stderr]    Compiling h2 v0.4.13
[INFO] [stderr]    Compiling toml_datetime v0.6.11
[INFO] [stderr]    Compiling url v2.5.8
[INFO] [stderr]    Compiling serde_spanned v0.6.9
[INFO] [stderr]    Compiling winnow v0.7.14
[INFO] [stderr]    Compiling toml_write v0.1.2
[INFO] [stderr]    Compiling anyhow v1.0.100
[INFO] [stderr]    Compiling lazy_static v1.5.0
[INFO] [stderr]    Compiling sharded-slab v0.1.7
[INFO] [stderr]    Compiling hashbrown v0.15.5
[INFO] [stderr]    Compiling zstd v0.13.3
[INFO] [stderr]    Compiling compression-codecs v0.4.35
[INFO] [stderr]    Compiling matchers v0.2.0
[INFO] [stderr]    Compiling tower-http v0.6.8
[INFO] [stderr]    Compiling combine v4.6.7
[INFO] [stderr]    Compiling toml_edit v0.22.27
[INFO] [stderr]    Compiling async-compression v0.4.36
[INFO] [stderr]    Compiling tracing-serde v0.2.0
[INFO] [stderr]    Compiling serde_urlencoded v0.7.1
[INFO] [stderr]    Compiling tokio-tungstenite v0.24.0
[INFO] [stderr]    Compiling tokio-retry v0.3.0
[INFO] [stderr]    Compiling futures v0.3.31
[INFO] [stderr]    Compiling axum-core v0.4.5
[INFO] [stderr]    Compiling hdrhistogram v7.5.4
[INFO] [stderr]    Compiling axum-macros v0.4.2
[INFO] [stderr]    Compiling arc-swap v1.8.0
[INFO] [stderr]    Compiling serde_path_to_error v0.1.20
[INFO] [stderr]    Compiling socket2 v0.4.10
[INFO] [stderr]    Compiling tracing-log v0.2.0
[INFO] [stderr]    Compiling encoding_rs v0.8.35
[INFO] [stderr]    Compiling thread_local v1.1.9
[INFO] [stderr]    Compiling nu-ansi-term v0.50.3
[INFO] [stderr]    Compiling sha1_smol v1.0.1
[INFO] [stderr]    Compiling hyper v1.8.1
[INFO] [stderr]    Compiling hashbrown v0.14.5
[INFO] [stderr]    Compiling matchit v0.7.3
[INFO] [stderr]    Compiling dashmap v5.5.3
[INFO] [stderr]    Compiling toml v0.8.23
[INFO] [stderr]    Compiling tracing-subscriber v0.3.22
[INFO] [stderr]    Compiling hyper-util v0.1.19
[INFO] [stderr]    Compiling uuid v1.19.0
[INFO] [stderr]    Compiling tower v0.4.13
[INFO] [stderr]    Compiling tower-http v0.5.2
[INFO] [stderr]    Compiling redis v0.24.0
[INFO] [stderr]    Compiling lru v0.12.5
[INFO] [stderr]    Compiling sha2 v0.10.9
[INFO] [stderr]    Compiling num_cpus v1.17.0
[INFO] [stderr]    Compiling hex v0.4.3
[INFO] [stderr]    Compiling base64 v0.21.7
[INFO] [stderr]    Compiling dotenvy v0.15.7
[INFO] [stderr]    Compiling axum v0.7.9
[INFO] [stderr]    Compiling rustls-webpki v0.103.8
[INFO] [stderr]    Compiling tokio-rustls v0.26.4
[INFO] [stderr]    Compiling rustls-platform-verifier v0.6.2
[INFO] [stderr]    Compiling hyper-rustls v0.27.7
[INFO] [stderr]    Compiling reqwest v0.13.1
[INFO] [stderr]    Compiling live-streaming-cdn v0.1.0 (/opt/rustwide/workdir)
[INFO] [stdout] warning: unused import: `UNIX_EPOCH`
[INFO] [stdout]  --> src/api/health.rs:3:29
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::time::{SystemTime, UNIX_EPOCH};
[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: `create_stream`, `end_stream`, `get_stream`, and `list_streams`
[INFO] [stdout]   --> src/api/mod.rs:10:19
[INFO] [stdout]    |
[INFO] [stdout] 10 | pub use streams::{create_stream, list_streams, get_stream, end_stream};
[INFO] [stdout]    |                   ^^^^^^^^^^^^^  ^^^^^^^^^^^^  ^^^^^^^^^^  ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `hls_master_playlist`, `hls_media_playlist`, and `hls_segment`
[INFO] [stdout]   --> src/api/mod.rs:11:15
[INFO] [stdout]    |
[INFO] [stdout] 11 | pub use hls::{hls_master_playlist, hls_media_playlist, hls_segment};
[INFO] [stdout]    |               ^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `dash::dash_manifest`
[INFO] [stdout]   --> src/api/mod.rs:12:9
[INFO] [stdout]    |
[INFO] [stdout] 12 | pub use dash::dash_manifest;
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `watch_stream` and `webrtc_signaling`
[INFO] [stdout]   --> src/api/mod.rs:13:21
[INFO] [stdout]    |
[INFO] [stdout] 13 | pub use websocket::{watch_stream, webrtc_signaling};
[INFO] [stdout]    |                     ^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `cache_stats`, `register_edge_node`, and `select_edge_node`
[INFO] [stdout]   --> src/api/mod.rs:14:15
[INFO] [stdout]    |
[INFO] [stdout] 14 | pub use cdn::{register_edge_node, select_edge_node, cache_stats};
[INFO] [stdout]    |               ^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^  ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `metrics::get_metrics`
[INFO] [stdout]   --> src/api/mod.rs:15:9
[INFO] [stdout]    |
[INFO] [stdout] 15 | pub use metrics::get_metrics;
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `health::health_check`
[INFO] [stdout]   --> src/api/mod.rs:16:9
[INFO] [stdout]    |
[INFO] [stdout] 16 | pub use health::health_check;
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Deserialize`
[INFO] [stdout]  --> src/cdn/edge_manager.rs:7:13
[INFO] [stdout]   |
[INFO] [stdout] 7 | use serde::{Deserialize, Serialize};
[INFO] [stdout]   |             ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `CdnConfig`, `RedisConfig`, `ServerConfig`, and `StreamingConfig`
[INFO] [stdout]  --> src/config/mod.rs:3:28
[INFO] [stdout]   |
[INFO] [stdout] 3 | pub use settings::{Config, ServerConfig, RedisConfig, CdnConfig, StreamingConfig};
[INFO] [stdout]   |                            ^^^^^^^^^^^^  ^^^^^^^^^^^  ^^^^^^^^^  ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Semaphore`
[INFO] [stdout]  --> src/ingest/transcoder_pool.rs:2:25
[INFO] [stdout]   |
[INFO] [stdout] 2 | use tokio::sync::{mpsc, Semaphore};
[INFO] [stdout]   |                         ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `bytes::Bytes`
[INFO] [stdout]  --> src/ingest/transcoder_pool.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use bytes::Bytes;
[INFO] [stdout]   |     ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `quality::StreamQuality`
[INFO] [stdout]  --> src/ingest/transcoder_pool.rs:8:14
[INFO] [stdout]   |
[INFO] [stdout] 8 |     domain::{quality::StreamQuality, stream::VideoSegment},
[INFO] [stdout]   |              ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `AccelType`, `HardwareAcceleration`, `SimpleTranscoder`, `TranscoderError`, `TranscoderService`, and `TranscodingStats`
[INFO] [stdout]   --> src/ingest/mod.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 |     TranscoderService, 
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 14 |     TranscoderError, 
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout] 15 |     SimpleTranscoder,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^
[INFO] [stdout] 16 |     HardwareAcceleration,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 17 |     AccelType,
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout] 18 |     TranscodingStats,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `PoolStats` and `TranscoderPool`
[INFO] [stdout]   --> src/ingest/mod.rs:22:27
[INFO] [stdout]    |
[INFO] [stdout] 22 | pub use transcoder_pool::{TranscoderPool, PoolStats};
[INFO] [stdout]    |                           ^^^^^^^^^^^^^^  ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `segment_buffer::SegmentBuffer`
[INFO] [stdout]   --> src/ingest/mod.rs:25:9
[INFO] [stdout]    |
[INFO] [stdout] 25 | pub use segment_buffer::SegmentBuffer;
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `stream_manager::StreamManager`
[INFO] [stdout]  --> src/manager/mod.rs:3:9
[INFO] [stdout]   |
[INFO] [stdout] 3 | pub use stream_manager::StreamManager;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `app_state::AppState`
[INFO] [stdout]  --> src/state/mod.rs:3:9
[INFO] [stdout]   |
[INFO] [stdout] 3 | pub use app_state::AppState;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `manifest::HLSManifestGenerator`
[INFO] [stdout]  --> src/streaming/hls/mod.rs:3:9
[INFO] [stdout]   |
[INFO] [stdout] 3 | pub use manifest::HLSManifestGenerator;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `manifest::DASHManifestGenerator`
[INFO] [stdout]  --> src/streaming/dash/mod.rs:3:9
[INFO] [stdout]   |
[INFO] [stdout] 3 | pub use manifest::DASHManifestGenerator;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `HashMap` and `VecDeque`
[INFO] [stdout]  --> src/streaming/webrtc/connection.rs:9:24
[INFO] [stdout]   |
[INFO] [stdout] 9 | use std::collections::{HashMap, VecDeque};
[INFO] [stdout]   |                        ^^^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `StreamQuality` and `VideoSegment`
[INFO] [stdout]   --> src/streaming/webrtc/connection.rs:11:21
[INFO] [stdout]    |
[INFO] [stdout] 11 | use crate::domain::{StreamQuality, VideoSegment};
[INFO] [stdout]    |                     ^^^^^^^^^^^^^  ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `connection::WebRTCConnection`
[INFO] [stdout]  --> src/streaming/webrtc/mod.rs:4:9
[INFO] [stdout]   |
[INFO] [stdout] 4 | pub use connection::WebRTCConnection;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `WebRTCManager` and `WebRTCSignal`
[INFO] [stdout]  --> src/streaming/webrtc/mod.rs:5:21
[INFO] [stdout]   |
[INFO] [stdout] 5 | pub use signaling::{WebRTCManager, WebRTCSignal};
[INFO] [stdout]   |                     ^^^^^^^^^^^^^  ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `hls::manifest::HLSManifestGenerator`
[INFO] [stdout]  --> src/streaming/mod.rs:5:9
[INFO] [stdout]   |
[INFO] [stdout] 5 | pub use hls::manifest::HLSManifestGenerator;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `dash::manifest::DASHManifestGenerator`
[INFO] [stdout]  --> src/streaming/mod.rs:6:9
[INFO] [stdout]   |
[INFO] [stdout] 6 | pub use dash::manifest::DASHManifestGenerator;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `WebRTCManager` and `WebRTCSignal`
[INFO] [stdout]  --> src/streaming/mod.rs:7:29
[INFO] [stdout]   |
[INFO] [stdout] 7 | pub use webrtc::signaling::{WebRTCManager, WebRTCSignal};
[INFO] [stdout]   |                             ^^^^^^^^^^^^^  ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `addr`
[INFO] [stdout]   --> src/ingest/rtmp.rs:88:5
[INFO] [stdout]    |
[INFO] [stdout] 88 |     addr: SocketAddr,
[INFO] [stdout]    |     ^^^^ help: if this is intentional, prefix it with an underscore: `_addr`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable `sequence` is assigned to, but never used
[INFO] [stdout]    --> src/ingest/transcoder.rs:314:17
[INFO] [stdout]     |
[INFO] [stdout] 314 |             let mut sequence = 0u64;
[INFO] [stdout]     |                 ^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: consider using `_sequence` instead
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `data`
[INFO] [stdout]    --> src/ingest/transcoder.rs:321:21
[INFO] [stdout]     |
[INFO] [stdout] 321 |                 let data = Bytes::copy_from_slice(&buffer[..n]);
[INFO] [stdout]     |                     ^^^^ help: if this is intentional, prefix it with an underscore: `_data`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `sequence` is never read
[INFO] [stdout]    --> src/ingest/transcoder.rs:331:17
[INFO] [stdout]     |
[INFO] [stdout] 331 |                 sequence += 1;
[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: unused variable: `viewer_location`
[INFO] [stdout]    --> src/manager/stream_manager.rs:247:36
[INFO] [stdout]     |
[INFO] [stdout] 247 |     pub fn select_edge_node(&self, viewer_location: &str) -> Option<EdgeNode> {
[INFO] [stdout]     |                                    ^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_viewer_location`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `quality`
[INFO] [stdout]    --> src/manager/stream_manager.rs:259:9
[INFO] [stdout]     |
[INFO] [stdout] 259 |         quality: StreamQuality,
[INFO] [stdout]     |         ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_quality`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `stream_id`
[INFO] [stdout]   --> src/streaming/hls/manifest.rs:18:44
[INFO] [stdout]    |
[INFO] [stdout] 18 |     pub fn generate_master_playlist(&self, stream_id: &str, qualities: &[StreamQuality]) -> String {
[INFO] [stdout]    |                                            ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_stream_id`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `stream_id`
[INFO] [stdout]   --> src/streaming/hls/manifest.rs:51:9
[INFO] [stdout]    |
[INFO] [stdout] 51 |         stream_id: &str,
[INFO] [stdout]    |         ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_stream_id`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `quality`
[INFO] [stdout]   --> src/streaming/hls/manifest.rs:52:9
[INFO] [stdout]    |
[INFO] [stdout] 52 |         quality: StreamQuality,
[INFO] [stdout]    |         ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_quality`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `segments`
[INFO] [stdout]   --> src/streaming/dash/manifest.rs:16:9
[INFO] [stdout]    |
[INFO] [stdout] 16 |         segments: &HashMap<StreamQuality, VecDeque<VideoSegment>>,
[INFO] [stdout]    |         ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_segments`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `stream_cache_stats` is never used
[INFO] [stdout]    --> src/api/cdn.rs:148:14
[INFO] [stdout]     |
[INFO] [stdout] 148 | pub async fn stream_cache_stats(
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `clear_stream_cache` is never used
[INFO] [stdout]    --> src/api/cdn.rs:168:14
[INFO] [stdout]     |
[INFO] [stdout] 168 | pub async fn clear_stream_cache(
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `EdgeNodeHealthResponse` is never constructed
[INFO] [stdout]    --> src/api/cdn.rs:187:12
[INFO] [stdout]     |
[INFO] [stdout] 187 | pub struct EdgeNodeHealthResponse {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `EdgeNodeStatus` is never constructed
[INFO] [stdout]    --> src/api/cdn.rs:194:12
[INFO] [stdout]     |
[INFO] [stdout] 194 | pub struct EdgeNodeStatus {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `edge_nodes_health` is never used
[INFO] [stdout]    --> src/api/cdn.rs:203:14
[INFO] [stdout]     |
[INFO] [stdout] 203 | pub async fn edge_nodes_health(
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `CdnMetrics` is never constructed
[INFO] [stdout]    --> src/api/cdn.rs:244:12
[INFO] [stdout]     |
[INFO] [stdout] 244 | pub struct CdnMetrics {
[INFO] [stdout]     |            ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `StreamBandwidth` is never constructed
[INFO] [stdout]    --> src/api/cdn.rs:255:12
[INFO] [stdout]     |
[INFO] [stdout] 255 | pub struct StreamBandwidth {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `cdn_metrics` is never used
[INFO] [stdout]    --> src/api/cdn.rs:262:14
[INFO] [stdout]     |
[INFO] [stdout] 262 | pub async fn cdn_metrics(
[INFO] [stdout]     |              ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `get`, `record_hit`, and `record_miss` are never used
[INFO] [stdout]    --> src/cdn/cache.rs:39:18
[INFO] [stdout]     |
[INFO] [stdout]  26 | impl EdgeCache {
[INFO] [stdout]     | -------------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout]  39 |     pub async fn get(&self, key: &str) -> Option<Bytes> {
[INFO] [stdout]     |                  ^^^
[INFO] [stdout] ...
[INFO] [stdout] 105 |     fn record_hit(&self, key: &str) {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 112 |     fn record_miss(&self, key: &str) {
[INFO] [stdout]     |        ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `nodes`, `regions`, `strategy`, and `health_config` are never read
[INFO] [stdout]   --> src/cdn/edge_manager.rs:14:5
[INFO] [stdout]    |
[INFO] [stdout] 12 | pub struct EdgeNodeManager {
[INFO] [stdout]    |            --------------- fields in this struct
[INFO] [stdout] 13 |     /// Active edge nodes
[INFO] [stdout] 14 |     nodes: DashMap<String, Arc<RwLock<EdgeNode>>>,
[INFO] [stdout]    |     ^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 17 |     regions: DashMap<String, Vec<String>>,
[INFO] [stdout]    |     ^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 20 |     strategy: LoadBalancingStrategy,
[INFO] [stdout]    |     ^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 23 |     health_config: HealthCheckConfig,
[INFO] [stdout]    |     ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `heartbeat_timeout`, `max_load_percentage`, and `auto_failover` are never read
[INFO] [stdout]   --> src/cdn/edge_manager.rs:49:9
[INFO] [stdout]    |
[INFO] [stdout] 47 | pub struct HealthCheckConfig {
[INFO] [stdout]    |            ----------------- fields in this struct
[INFO] [stdout] 48 |     /// Maximum time since last heartbeat before node is unhealthy
[INFO] [stdout] 49 |     pub heartbeat_timeout: Duration,
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 52 |     pub max_load_percentage: f64,
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 55 |     pub auto_failover: bool,
[INFO] [stdout]    |         ^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `HealthCheckConfig` 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: struct `NodeSelection` is never constructed
[INFO] [stdout]   --> src/cdn/edge_manager.rs:70:12
[INFO] [stdout]    |
[INFO] [stdout] 70 | pub struct NodeSelection {
[INFO] [stdout]    |            ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `SelectionReason` is never used
[INFO] [stdout]   --> src/cdn/edge_manager.rs:77:10
[INFO] [stdout]    |
[INFO] [stdout] 77 | pub enum SelectionReason {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `EdgeNodeStats` is never constructed
[INFO] [stdout]   --> src/cdn/edge_manager.rs:87:12
[INFO] [stdout]    |
[INFO] [stdout] 87 | pub struct EdgeNodeStats {
[INFO] [stdout]    |            ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: multiple associated items are never used
[INFO] [stdout]    --> src/cdn/edge_manager.rs:109:12
[INFO] [stdout]     |
[INFO] [stdout]  97 | impl EdgeNodeManager {
[INFO] [stdout]     | -------------------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 109 |     pub fn with_health_config(
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 122 |     pub async fn register_node(&self, node: EdgeNode) {
[INFO] [stdout]     |                  ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 145 |     pub async fn unregister_node(&self, node_id: &str) -> bool {
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 163 |     pub async fn update_heartbeat(&self, node_id: &str, load: usize) -> bool {
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 179 |     pub async fn select_node(
[INFO] [stdout]     |                  ^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 203 |     async fn select_least_loaded(&self) -> Option<NodeSelection> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 238 |     async fn select_by_geography(
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 282 |     async fn select_weighted(&self) -> Option<NodeSelection> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 326 |     async fn select_round_robin(&self) -> Option<NodeSelection> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 355 |     async fn select_random(&self) -> Option<NodeSelection> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 373 |     pub async fn get_healthy_nodes(&self) -> Vec<EdgeNode> {
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 387 |     async fn is_node_healthy(&self, node: &EdgeNode) -> bool {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 410 |     pub async fn get_all_nodes(&self) -> Vec<EdgeNode> {
[INFO] [stdout]     |                  ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 422 |     pub async fn get_node(&self, node_id: &str) -> Option<EdgeNode> {
[INFO] [stdout]     |                  ^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 432 |     pub fn get_nodes_in_region(&self, location: &str) -> Vec<String> {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 440 |     async fn get_alternative_nodes(&self, exclude_id: &str, count: usize) -> Vec<String> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 452 |     fn find_closest_region(&self, viewer_location: &str) -> Option<String> {
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 471 |     pub async fn get_node_stats(&self, node_id: &str) -> Option<EdgeNodeStats> {
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 491 |     pub async fn get_cluster_stats(&self) -> ClusterStats {
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 517 |     pub async fn run_health_check(&self) -> HealthCheckReport {
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 546 |     pub fn set_strategy(&mut self, strategy: LoadBalancingStrategy) {
[INFO] [stdout]     |            ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 552 |     pub fn get_strategy(&self) -> LoadBalancingStrategy {
[INFO] [stdout]     |            ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ClusterStats` is never constructed
[INFO] [stdout]    --> src/cdn/edge_manager.rs:559:12
[INFO] [stdout]     |
[INFO] [stdout] 559 | pub struct ClusterStats {
[INFO] [stdout]     |            ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `HealthCheckReport` is never constructed
[INFO] [stdout]    --> src/cdn/edge_manager.rs:571:12
[INFO] [stdout]     |
[INFO] [stdout] 571 | pub struct HealthCheckReport {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `total_nodes` and `health_percentage` are never used
[INFO] [stdout]    --> src/cdn/edge_manager.rs:577:12
[INFO] [stdout]     |
[INFO] [stdout] 576 | impl HealthCheckReport {
[INFO] [stdout]     | ---------------------- methods in this implementation
[INFO] [stdout] 577 |     pub fn total_nodes(&self) -> usize {
[INFO] [stdout]     |            ^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 581 |     pub fn health_percentage(&self) -> f64 {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `MissingField` is never constructed
[INFO] [stdout]    --> src/config/settings.rs:324:5
[INFO] [stdout]     |
[INFO] [stdout] 313 | pub enum ConfigError {
[INFO] [stdout]     |          ----------- variant in this enum
[INFO] [stdout] ...
[INFO] [stdout] 324 |     MissingField(String),
[INFO] [stdout]     |     ^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `ConfigError` 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 `keyframe` and `timestamp` are never read
[INFO] [stdout]   --> src/domain/stream.rs:25:9
[INFO] [stdout]    |
[INFO] [stdout] 21 | pub struct VideoSegment {
[INFO] [stdout]    |            ------------ fields in this struct
[INFO] [stdout] ...
[INFO] [stdout] 25 |     pub keyframe: bool,
[INFO] [stdout]    |         ^^^^^^^^
[INFO] [stdout] 26 |     pub timestamp: u64,
[INFO] [stdout]    |         ^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `VideoSegment` 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 `quality`, `bitrate_kbps`, and `resolution` are never read
[INFO] [stdout]   --> src/domain/stream.rs:32:9
[INFO] [stdout]    |
[INFO] [stdout] 31 | pub struct AdaptiveStream {
[INFO] [stdout]    |            -------------- fields in this struct
[INFO] [stdout] 32 |     pub quality: StreamQuality,
[INFO] [stdout]    |         ^^^^^^^
[INFO] [stdout] 33 |     pub bitrate_kbps: u32,
[INFO] [stdout]    |         ^^^^^^^^^^^^
[INFO] [stdout] 34 |     pub resolution: (u32, u32),
[INFO] [stdout]    |         ^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `AdaptiveStream` 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: methods `bitrate_kbps` and `resolution` are never used
[INFO] [stdout]   --> src/domain/quality.rs:21:12
[INFO] [stdout]    |
[INFO] [stdout] 11 | impl StreamQuality {
[INFO] [stdout]    | ------------------ methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 21 |     pub fn bitrate_kbps(&self) -> u32 {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 30 |     pub fn resolution(&self) -> (u32, u32) {
[INFO] [stdout]    |            ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `update_load` and `is_available` are never used
[INFO] [stdout]   --> src/domain/edge_node.rs:24:12
[INFO] [stdout]    |
[INFO] [stdout] 13 | impl EdgeNode {
[INFO] [stdout]    | ------------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 24 |     pub fn update_load(&mut self, load: usize) {
[INFO] [stdout]    |            ^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 29 |     pub fn is_available(&self) -> bool {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `is_keyframe_data` is never used
[INFO] [stdout]    --> src/ingest/rtmp.rs:376:4
[INFO] [stdout]     |
[INFO] [stdout] 376 | fn is_keyframe_data(data: &[u8]) -> bool {
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `RtmpServerBuilder` is never constructed
[INFO] [stdout]    --> src/ingest/rtmp.rs:393:12
[INFO] [stdout]     |
[INFO] [stdout] 393 | pub struct RtmpServerBuilder {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `bind_addr`, `max_connections`, `connection_timeout`, `buffer_size`, and `build` are never used
[INFO] [stdout]    --> src/ingest/rtmp.rs:401:12
[INFO] [stdout]     |
[INFO] [stdout] 400 | impl RtmpServerBuilder {
[INFO] [stdout]     | ---------------------- associated items in this implementation
[INFO] [stdout] 401 |     pub fn new() -> Self {
[INFO] [stdout]     |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 410 |     pub fn bind_addr(mut self, addr: SocketAddr) -> Self {
[INFO] [stdout]     |            ^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 415 |     pub fn max_connections(mut self, max: usize) -> Self {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 420 |     pub fn connection_timeout(mut self, timeout: Duration) -> Self {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 425 |     pub fn buffer_size(mut self, size: usize) -> Self {
[INFO] [stdout]     |            ^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 430 |     pub fn build(self, state: AppState) -> Result<RtmpServer, RtmpError> {
[INFO] [stdout]     |            ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `TranscoderService` is never constructed
[INFO] [stdout]   --> src/ingest/transcoder.rs:18:12
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub struct TranscoderService {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `HardwareAcceleration` is never constructed
[INFO] [stdout]   --> src/ingest/transcoder.rs:34:12
[INFO] [stdout]    |
[INFO] [stdout] 34 | pub struct HardwareAcceleration {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `AccelType` is never used
[INFO] [stdout]   --> src/ingest/transcoder.rs:40:10
[INFO] [stdout]    |
[INFO] [stdout] 40 | pub enum AccelType {
[INFO] [stdout]    |          ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `TranscodingSession` is never constructed
[INFO] [stdout]   --> src/ingest/transcoder.rs:49:8
[INFO] [stdout]    |
[INFO] [stdout] 49 | struct TranscodingSession {
[INFO] [stdout]    |        ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `TranscodingProcess` is never constructed
[INFO] [stdout]   --> src/ingest/transcoder.rs:55:8
[INFO] [stdout]    |
[INFO] [stdout] 55 | struct TranscodingProcess {
[INFO] [stdout]    |        ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `TranscodedSegment` is never constructed
[INFO] [stdout]   --> src/ingest/transcoder.rs:63:12
[INFO] [stdout]    |
[INFO] [stdout] 63 | pub struct TranscodedSegment {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `TranscoderError` is never used
[INFO] [stdout]   --> src/ingest/transcoder.rs:72:10
[INFO] [stdout]    |
[INFO] [stdout] 72 | pub enum TranscoderError {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: multiple associated items are never used
[INFO] [stdout]    --> src/ingest/transcoder.rs:97:12
[INFO] [stdout]     |
[INFO] [stdout]  95 | impl TranscoderService {
[INFO] [stdout]     | ---------------------- associated items in this implementation
[INFO] [stdout]  96 |     /// Create new transcoder service
[INFO] [stdout]  97 |     pub fn new(config: Arc<Config>) -> Result<Arc<Self>, TranscoderError> {
[INFO] [stdout]     |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 115 |     fn check_ffmpeg_installation() -> Result<(), TranscoderError> {
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 127 |     fn detect_hardware_acceleration() -> HardwareAcceleration {
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 160 |     fn check_nvidia_support() -> bool {
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 166 |     fn check_intel_support() -> bool {
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 179 |     pub async fn start_session(
[INFO] [stdout]     |                  ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 225 |     async fn spawn_transcoding_process(
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 343 |     fn add_hw_accel_args(&self, cmd: &mut Command) {
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 368 |     fn get_video_codec(&self) -> &'static str {
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 383 |     fn profile_to_quality(profile: &TranscodingProfile) -> StreamQuality {
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 394 |     pub async fn stop_session(&self, stream_id: &str) -> Result<(), TranscoderError> {
[INFO] [stdout]     |                  ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 409 |     pub fn active_sessions(&self) -> usize {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 414 |     pub fn has_session(&self, stream_id: &str) -> bool {
[INFO] [stdout]     |            ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `SimpleTranscoder` is never constructed
[INFO] [stdout]    --> src/ingest/transcoder.rs:425:12
[INFO] [stdout]     |
[INFO] [stdout] 425 | pub struct SimpleTranscoder;
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `transcode` is never used
[INFO] [stdout]    --> src/ingest/transcoder.rs:428:12
[INFO] [stdout]     |
[INFO] [stdout] 427 | impl SimpleTranscoder {
[INFO] [stdout]     | --------------------- associated function in this implementation
[INFO] [stdout] 428 |     pub fn transcode(data: &Bytes, quality: StreamQuality) -> Bytes {
[INFO] [stdout]     |            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `TranscodingStats` is never constructed
[INFO] [stdout]    --> src/ingest/transcoder.rs:446:12
[INFO] [stdout]     |
[INFO] [stdout] 446 | pub struct TranscodingStats {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `compression_ratio` is never used
[INFO] [stdout]    --> src/ingest/transcoder.rs:455:12
[INFO] [stdout]     |
[INFO] [stdout] 454 | impl TranscodingStats {
[INFO] [stdout]     | --------------------- method in this implementation
[INFO] [stdout] 455 |     pub fn compression_ratio(&self) -> f64 {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `TranscoderPool` is never constructed
[INFO] [stdout]   --> src/ingest/transcoder_pool.rs:14:12
[INFO] [stdout]    |
[INFO] [stdout] 14 | pub struct TranscoderPool {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `get_next_worker`, `start_session`, `stop_session`, and `get_stats` are never used
[INFO] [stdout]   --> src/ingest/transcoder_pool.rs:30:12
[INFO] [stdout]    |
[INFO] [stdout] 28 | impl TranscoderPool {
[INFO] [stdout]    | ------------------- associated items in this implementation
[INFO] [stdout] 29 |     /// Create new transcoder pool
[INFO] [stdout] 30 |     pub fn new(config: Arc<Config>, pool_size: usize) -> Result<Arc<Self>, TranscoderError> {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 51 |     fn get_next_worker(&self) -> Arc<TranscoderService> {
[INFO] [stdout]    |        ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 72 |     pub async fn start_session(
[INFO] [stdout]    |                  ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 81 |     pub async fn stop_session(&self, stream_id: &str) -> Result<(), TranscoderError> {
[INFO] [stdout]    |                  ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 90 |     pub fn get_stats(&self) -> PoolStats {
[INFO] [stdout]    |            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `PoolStats` is never constructed
[INFO] [stdout]    --> src/ingest/transcoder_pool.rs:110:12
[INFO] [stdout]     |
[INFO] [stdout] 110 | pub struct PoolStats {
[INFO] [stdout]     |            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `SegmentBuffer` is never constructed
[INFO] [stdout]  --> src/ingest/segment_buffer.rs:6:12
[INFO] [stdout]   |
[INFO] [stdout] 6 | pub struct SegmentBuffer {
[INFO] [stdout]   |            ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: multiple associated items are never used
[INFO] [stdout]   --> src/ingest/segment_buffer.rs:14:12
[INFO] [stdout]    |
[INFO] [stdout] 13 | impl SegmentBuffer {
[INFO] [stdout]    | ------------------ associated items in this implementation
[INFO] [stdout] 14 |     pub fn new(max_size: usize, max_duration: Duration) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 24 |     pub fn push(&mut self, segment: VideoSegment) -> bool {
[INFO] [stdout]    |            ^^^^
[INFO] [stdout] ...
[INFO] [stdout] 38 |     pub fn pop(&mut self) -> Option<VideoSegment> {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 43 |     pub fn is_full(&self) -> bool {
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 48 |     pub fn is_expired(&self) -> bool {
[INFO] [stdout]    |            ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 57 |     pub fn fill_percentage(&self) -> f64 {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 62 |     pub fn clear(&mut self) {
[INFO] [stdout]    |            ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `edge_manager` is never read
[INFO] [stdout]   --> src/manager/stream_manager.rs:24:9
[INFO] [stdout]    |
[INFO] [stdout]  8 | pub struct StreamManager {
[INFO] [stdout]    |            ------------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 24 |     pub edge_manager: Arc<EdgeNodeManager>,
[INFO] [stdout]    |         ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `get_hls_master_playlist`, `get_segment`, `invalidate_cache`, and `get_all_edge_nodes` are never used
[INFO] [stdout]    --> src/manager/stream_manager.rs:166:12
[INFO] [stdout]     |
[INFO] [stdout]  35 | impl StreamManager {
[INFO] [stdout]     | ------------------ methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 166 |     pub fn get_hls_master_playlist(&self, stream_id: &str) -> Option<String> {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 217 |     pub async fn get_segment(
[INFO] [stdout]     |                  ^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 334 |     pub async fn invalidate_cache(&self, stream_id: &str) {
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 340 |     pub fn get_all_edge_nodes(&self) -> Vec<EdgeNode> {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/state/app_state.rs:16:12
[INFO] [stdout]    |
[INFO] [stdout] 14 | impl AppState {
[INFO] [stdout]    | ------------- associated function in this implementation
[INFO] [stdout] 15 |     /// Create new application state
[INFO] [stdout] 16 |     pub fn new(stream_manager: Arc<StreamManager>, config: Config) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `playlist_type` is never read
[INFO] [stdout]  --> src/streaming/hls/manifest.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | pub struct HLSManifestGenerator {
[INFO] [stdout]   |            -------------------- field in this struct
[INFO] [stdout] 6 |     target_duration: u32,
[INFO] [stdout] 7 |     playlist_type: String,
[INFO] [stdout]   |     ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `generate_master_playlist` is never used
[INFO] [stdout]   --> src/streaming/hls/manifest.rs:18:12
[INFO] [stdout]    |
[INFO] [stdout] 10 | impl HLSManifestGenerator {
[INFO] [stdout]    | ------------------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 18 |     pub fn generate_master_playlist(&self, stream_id: &str, qualities: &[StreamQuality]) -> String {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `peer_id` and `stream_id` are never read
[INFO] [stdout]  --> src/streaming/webrtc/connection.rs:2:9
[INFO] [stdout]   |
[INFO] [stdout] 1 | pub struct WebRTCConnection {
[INFO] [stdout]   |            ---------------- fields in this struct
[INFO] [stdout] 2 |     pub peer_id: String,
[INFO] [stdout]   |         ^^^^^^^
[INFO] [stdout] 3 |     pub stream_id: String,
[INFO] [stdout]   |         ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished `dev` profile [unoptimized + debuginfo] target(s) in 3m 58s
[INFO] [stderr] warning: the following packages contain code that will be rejected by a future version of Rust: redis v0.24.0
[INFO] [stderr] note: to see what the problems were, use the option `--future-incompat-report`, or run `cargo report future-incompatibilities --id 1`
[INFO] running `Command { std: "docker" "inspect" "9a78478e0d9b7047f669200108f6b5c48d87ede5954b478e300323214bfa21d6", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-w" "/opt/rustwide/workdir" "--user" "0:0" "9a78478e0d9b7047f669200108f6b5c48d87ede5954b478e300323214bfa21d6" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stderr]    Compiling tokio v1.49.0
[INFO] [stderr]    Compiling zerocopy v0.8.33
[INFO] [stderr]    Compiling zerocopy-derive v0.8.33
[INFO] [stderr]    Compiling serde v1.0.228
[INFO] [stderr]    Compiling crossbeam-utils v0.8.21
[INFO] [stderr]    Compiling regex-automata v0.4.13
[INFO] [stderr]    Compiling either v1.15.0
[INFO] [stderr]    Compiling rayon-core v1.13.0
[INFO] [stderr]    Compiling ciborium-io v0.2.2
[INFO] [stderr]    Compiling plotters-backend v0.3.7
[INFO] [stderr]    Compiling clap_lex v0.7.6
[INFO] [stderr]    Compiling anstyle v1.0.13
[INFO] [stderr]    Compiling itertools v0.10.5
[INFO] [stderr]    Compiling plotters-svg v0.3.7
[INFO] [stderr]    Compiling clap_builder v4.5.54
[INFO] [stderr]    Compiling cast v0.3.0
[INFO] [stderr]    Compiling crossbeam-epoch v0.9.18
[INFO] [stderr]    Compiling same-file v1.0.6
[INFO] [stderr]    Compiling walkdir v2.5.0
[INFO] [stderr]    Compiling crossbeam-deque v0.8.6
[INFO] [stderr]    Compiling toml_datetime v0.6.11
[INFO] [stderr]    Compiling serde_spanned v0.6.9
[INFO] [stderr]    Compiling toml_edit v0.22.27
[INFO] [stderr]    Compiling tinytemplate v1.2.1
[INFO] [stderr]    Compiling criterion-plot v0.5.0
[INFO] [stderr]    Compiling rayon v1.11.0
[INFO] [stderr]    Compiling serde_urlencoded v0.7.1
[INFO] [stderr]    Compiling tracing-serde v0.2.0
[INFO] [stderr]    Compiling plotters v0.3.7
[INFO] [stderr]    Compiling is-terminal v0.4.17
[INFO] [stderr]    Compiling anes v0.1.6
[INFO] [stderr]    Compiling oorandom v11.1.5
[INFO] [stderr]    Compiling clap v4.5.54
[INFO] [stderr]    Compiling regex v1.12.2
[INFO] [stderr]    Compiling matchers v0.2.0
[INFO] [stderr]    Compiling tracing-subscriber v0.3.22
[INFO] [stderr]    Compiling ppv-lite86 v0.2.21
[INFO] [stderr]    Compiling half v2.7.1
[INFO] [stderr]    Compiling ciborium-ll v0.2.2
[INFO] [stderr]    Compiling rand_chacha v0.3.1
[INFO] [stderr]    Compiling toml v0.8.23
[INFO] [stderr]    Compiling ciborium v0.2.2
[INFO] [stderr]    Compiling rand v0.8.5
[INFO] [stderr]    Compiling criterion v0.5.1
[INFO] [stderr]    Compiling tungstenite v0.24.0
[INFO] [stderr]    Compiling tokio-util v0.7.18
[INFO] [stderr]    Compiling tower v0.5.2
[INFO] [stderr]    Compiling tokio-rustls v0.26.4
[INFO] [stderr]    Compiling tokio-stream v0.1.18
[INFO] [stderr]    Compiling async-compression v0.4.36
[INFO] [stderr]    Compiling tokio-retry v0.3.0
[INFO] [stderr]    Compiling tokio-tungstenite v0.24.0
[INFO] [stderr]    Compiling tokio-test v0.4.5
[INFO] [stderr]    Compiling h2 v0.4.13
[INFO] [stderr]    Compiling combine v4.6.7
[INFO] [stderr]    Compiling tower-http v0.6.8
[INFO] [stderr]    Compiling tower-http v0.5.2
[INFO] [stderr]    Compiling tower v0.4.13
[INFO] [stderr]    Compiling hyper v1.8.1
[INFO] [stderr]    Compiling redis v0.24.0
[INFO] [stderr]    Compiling hyper-util v0.1.19
[INFO] [stderr]    Compiling hyper-rustls v0.27.7
[INFO] [stderr]    Compiling axum v0.7.9
[INFO] [stderr]    Compiling reqwest v0.13.1
[INFO] [stderr]    Compiling live-streaming-cdn v0.1.0 (/opt/rustwide/workdir)
[INFO] [stdout] warning: unused import: `UNIX_EPOCH`
[INFO] [stdout]  --> src/api/health.rs:3:29
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::time::{SystemTime, UNIX_EPOCH};
[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: `create_stream`, `end_stream`, `get_stream`, and `list_streams`
[INFO] [stdout]   --> src/api/mod.rs:10:19
[INFO] [stdout]    |
[INFO] [stdout] 10 | pub use streams::{create_stream, list_streams, get_stream, end_stream};
[INFO] [stdout]    |                   ^^^^^^^^^^^^^  ^^^^^^^^^^^^  ^^^^^^^^^^  ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `hls_master_playlist`, `hls_media_playlist`, and `hls_segment`
[INFO] [stdout]   --> src/api/mod.rs:11:15
[INFO] [stdout]    |
[INFO] [stdout] 11 | pub use hls::{hls_master_playlist, hls_media_playlist, hls_segment};
[INFO] [stdout]    |               ^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `dash::dash_manifest`
[INFO] [stdout]   --> src/api/mod.rs:12:9
[INFO] [stdout]    |
[INFO] [stdout] 12 | pub use dash::dash_manifest;
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `watch_stream` and `webrtc_signaling`
[INFO] [stdout]   --> src/api/mod.rs:13:21
[INFO] [stdout]    |
[INFO] [stdout] 13 | pub use websocket::{watch_stream, webrtc_signaling};
[INFO] [stdout]    |                     ^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `cache_stats`, `register_edge_node`, and `select_edge_node`
[INFO] [stdout]   --> src/api/mod.rs:14:15
[INFO] [stdout]    |
[INFO] [stdout] 14 | pub use cdn::{register_edge_node, select_edge_node, cache_stats};
[INFO] [stdout]    |               ^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^  ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `metrics::get_metrics`
[INFO] [stdout]   --> src/api/mod.rs:15:9
[INFO] [stdout]    |
[INFO] [stdout] 15 | pub use metrics::get_metrics;
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `health::health_check`
[INFO] [stdout]   --> src/api/mod.rs:16:9
[INFO] [stdout]    |
[INFO] [stdout] 16 | pub use health::health_check;
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Deserialize`
[INFO] [stdout]  --> src/cdn/edge_manager.rs:7:13
[INFO] [stdout]   |
[INFO] [stdout] 7 | use serde::{Deserialize, Serialize};
[INFO] [stdout]   |             ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `CdnConfig`, `RedisConfig`, `ServerConfig`, and `StreamingConfig`
[INFO] [stdout]  --> src/config/mod.rs:3:28
[INFO] [stdout]   |
[INFO] [stdout] 3 | pub use settings::{Config, ServerConfig, RedisConfig, CdnConfig, StreamingConfig};
[INFO] [stdout]   |                            ^^^^^^^^^^^^  ^^^^^^^^^^^  ^^^^^^^^^  ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Semaphore`
[INFO] [stdout]  --> src/ingest/transcoder_pool.rs:2:25
[INFO] [stdout]   |
[INFO] [stdout] 2 | use tokio::sync::{mpsc, Semaphore};
[INFO] [stdout]   |                         ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `bytes::Bytes`
[INFO] [stdout]  --> src/ingest/transcoder_pool.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use bytes::Bytes;
[INFO] [stdout]   |     ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `quality::StreamQuality`
[INFO] [stdout]  --> src/ingest/transcoder_pool.rs:8:14
[INFO] [stdout]   |
[INFO] [stdout] 8 |     domain::{quality::StreamQuality, stream::VideoSegment},
[INFO] [stdout]   |              ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `AccelType`, `HardwareAcceleration`, `SimpleTranscoder`, `TranscoderError`, `TranscoderService`, and `TranscodingStats`
[INFO] [stdout]   --> src/ingest/mod.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 |     TranscoderService, 
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 14 |     TranscoderError, 
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout] 15 |     SimpleTranscoder,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^
[INFO] [stdout] 16 |     HardwareAcceleration,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 17 |     AccelType,
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout] 18 |     TranscodingStats,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `PoolStats` and `TranscoderPool`
[INFO] [stdout]   --> src/ingest/mod.rs:22:27
[INFO] [stdout]    |
[INFO] [stdout] 22 | pub use transcoder_pool::{TranscoderPool, PoolStats};
[INFO] [stdout]    |                           ^^^^^^^^^^^^^^  ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `segment_buffer::SegmentBuffer`
[INFO] [stdout]   --> src/ingest/mod.rs:25:9
[INFO] [stdout]    |
[INFO] [stdout] 25 | pub use segment_buffer::SegmentBuffer;
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `stream_manager::StreamManager`
[INFO] [stdout]  --> src/manager/mod.rs:3:9
[INFO] [stdout]   |
[INFO] [stdout] 3 | pub use stream_manager::StreamManager;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `app_state::AppState`
[INFO] [stdout]  --> src/state/mod.rs:3:9
[INFO] [stdout]   |
[INFO] [stdout] 3 | pub use app_state::AppState;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `manifest::HLSManifestGenerator`
[INFO] [stdout]  --> src/streaming/hls/mod.rs:3:9
[INFO] [stdout]   |
[INFO] [stdout] 3 | pub use manifest::HLSManifestGenerator;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `manifest::DASHManifestGenerator`
[INFO] [stdout]  --> src/streaming/dash/mod.rs:3:9
[INFO] [stdout]   |
[INFO] [stdout] 3 | pub use manifest::DASHManifestGenerator;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `HashMap` and `VecDeque`
[INFO] [stdout]  --> src/streaming/webrtc/connection.rs:9:24
[INFO] [stdout]   |
[INFO] [stdout] 9 | use std::collections::{HashMap, VecDeque};
[INFO] [stdout]   |                        ^^^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `StreamQuality` and `VideoSegment`
[INFO] [stdout]   --> src/streaming/webrtc/connection.rs:11:21
[INFO] [stdout]    |
[INFO] [stdout] 11 | use crate::domain::{StreamQuality, VideoSegment};
[INFO] [stdout]    |                     ^^^^^^^^^^^^^  ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `connection::WebRTCConnection`
[INFO] [stdout]  --> src/streaming/webrtc/mod.rs:4:9
[INFO] [stdout]   |
[INFO] [stdout] 4 | pub use connection::WebRTCConnection;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `WebRTCManager` and `WebRTCSignal`
[INFO] [stdout]  --> src/streaming/webrtc/mod.rs:5:21
[INFO] [stdout]   |
[INFO] [stdout] 5 | pub use signaling::{WebRTCManager, WebRTCSignal};
[INFO] [stdout]   |                     ^^^^^^^^^^^^^  ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `hls::manifest::HLSManifestGenerator`
[INFO] [stdout]  --> src/streaming/mod.rs:5:9
[INFO] [stdout]   |
[INFO] [stdout] 5 | pub use hls::manifest::HLSManifestGenerator;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `dash::manifest::DASHManifestGenerator`
[INFO] [stdout]  --> src/streaming/mod.rs:6:9
[INFO] [stdout]   |
[INFO] [stdout] 6 | pub use dash::manifest::DASHManifestGenerator;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `WebRTCManager` and `WebRTCSignal`
[INFO] [stdout]  --> src/streaming/mod.rs:7:29
[INFO] [stdout]   |
[INFO] [stdout] 7 | pub use webrtc::signaling::{WebRTCManager, WebRTCSignal};
[INFO] [stdout]   |                             ^^^^^^^^^^^^^  ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `addr`
[INFO] [stdout]   --> src/ingest/rtmp.rs:88:5
[INFO] [stdout]    |
[INFO] [stdout] 88 |     addr: SocketAddr,
[INFO] [stdout]    |     ^^^^ help: if this is intentional, prefix it with an underscore: `_addr`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable `sequence` is assigned to, but never used
[INFO] [stdout]    --> src/ingest/transcoder.rs:314:17
[INFO] [stdout]     |
[INFO] [stdout] 314 |             let mut sequence = 0u64;
[INFO] [stdout]     |                 ^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: consider using `_sequence` instead
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `data`
[INFO] [stdout]    --> src/ingest/transcoder.rs:321:21
[INFO] [stdout]     |
[INFO] [stdout] 321 |                 let data = Bytes::copy_from_slice(&buffer[..n]);
[INFO] [stdout]     |                     ^^^^ help: if this is intentional, prefix it with an underscore: `_data`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `sequence` is never read
[INFO] [stdout]    --> src/ingest/transcoder.rs:331:17
[INFO] [stdout]     |
[INFO] [stdout] 331 |                 sequence += 1;
[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: unused variable: `viewer_location`
[INFO] [stdout]    --> src/manager/stream_manager.rs:247:36
[INFO] [stdout]     |
[INFO] [stdout] 247 |     pub fn select_edge_node(&self, viewer_location: &str) -> Option<EdgeNode> {
[INFO] [stdout]     |                                    ^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_viewer_location`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `quality`
[INFO] [stdout]    --> src/manager/stream_manager.rs:259:9
[INFO] [stdout]     |
[INFO] [stdout] 259 |         quality: StreamQuality,
[INFO] [stdout]     |         ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_quality`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `stream_id`
[INFO] [stdout]   --> src/streaming/hls/manifest.rs:18:44
[INFO] [stdout]    |
[INFO] [stdout] 18 |     pub fn generate_master_playlist(&self, stream_id: &str, qualities: &[StreamQuality]) -> String {
[INFO] [stdout]    |                                            ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_stream_id`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `stream_id`
[INFO] [stdout]   --> src/streaming/hls/manifest.rs:51:9
[INFO] [stdout]    |
[INFO] [stdout] 51 |         stream_id: &str,
[INFO] [stdout]    |         ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_stream_id`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `quality`
[INFO] [stdout]   --> src/streaming/hls/manifest.rs:52:9
[INFO] [stdout]    |
[INFO] [stdout] 52 |         quality: StreamQuality,
[INFO] [stdout]    |         ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_quality`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `segments`
[INFO] [stdout]   --> src/streaming/dash/manifest.rs:16:9
[INFO] [stdout]    |
[INFO] [stdout] 16 |         segments: &HashMap<StreamQuality, VecDeque<VideoSegment>>,
[INFO] [stdout]    |         ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_segments`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `stream_cache_stats` is never used
[INFO] [stdout]    --> src/api/cdn.rs:148:14
[INFO] [stdout]     |
[INFO] [stdout] 148 | pub async fn stream_cache_stats(
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `clear_stream_cache` is never used
[INFO] [stdout]    --> src/api/cdn.rs:168:14
[INFO] [stdout]     |
[INFO] [stdout] 168 | pub async fn clear_stream_cache(
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `EdgeNodeHealthResponse` is never constructed
[INFO] [stdout]    --> src/api/cdn.rs:187:12
[INFO] [stdout]     |
[INFO] [stdout] 187 | pub struct EdgeNodeHealthResponse {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `EdgeNodeStatus` is never constructed
[INFO] [stdout]    --> src/api/cdn.rs:194:12
[INFO] [stdout]     |
[INFO] [stdout] 194 | pub struct EdgeNodeStatus {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `edge_nodes_health` is never used
[INFO] [stdout]    --> src/api/cdn.rs:203:14
[INFO] [stdout]     |
[INFO] [stdout] 203 | pub async fn edge_nodes_health(
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `CdnMetrics` is never constructed
[INFO] [stdout]    --> src/api/cdn.rs:244:12
[INFO] [stdout]     |
[INFO] [stdout] 244 | pub struct CdnMetrics {
[INFO] [stdout]     |            ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `StreamBandwidth` is never constructed
[INFO] [stdout]    --> src/api/cdn.rs:255:12
[INFO] [stdout]     |
[INFO] [stdout] 255 | pub struct StreamBandwidth {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `cdn_metrics` is never used
[INFO] [stdout]    --> src/api/cdn.rs:262:14
[INFO] [stdout]     |
[INFO] [stdout] 262 | pub async fn cdn_metrics(
[INFO] [stdout]     |              ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `get`, `record_hit`, and `record_miss` are never used
[INFO] [stdout]    --> src/cdn/cache.rs:39:18
[INFO] [stdout]     |
[INFO] [stdout]  26 | impl EdgeCache {
[INFO] [stdout]     | -------------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout]  39 |     pub async fn get(&self, key: &str) -> Option<Bytes> {
[INFO] [stdout]     |                  ^^^
[INFO] [stdout] ...
[INFO] [stdout] 105 |     fn record_hit(&self, key: &str) {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 112 |     fn record_miss(&self, key: &str) {
[INFO] [stdout]     |        ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `strategy` is never read
[INFO] [stdout]   --> src/cdn/edge_manager.rs:20:5
[INFO] [stdout]    |
[INFO] [stdout] 12 | pub struct EdgeNodeManager {
[INFO] [stdout]    |            --------------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 20 |     strategy: LoadBalancingStrategy,
[INFO] [stdout]    |     ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `auto_failover` is never read
[INFO] [stdout]   --> src/cdn/edge_manager.rs:55:9
[INFO] [stdout]    |
[INFO] [stdout] 47 | pub struct HealthCheckConfig {
[INFO] [stdout]    |            ----------------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 55 |     pub auto_failover: bool,
[INFO] [stdout]    |         ^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `HealthCheckConfig` 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 `reason` and `alternatives` are never read
[INFO] [stdout]   --> src/cdn/edge_manager.rs:72:9
[INFO] [stdout]    |
[INFO] [stdout] 70 | pub struct NodeSelection {
[INFO] [stdout]    |            ------------- fields in this struct
[INFO] [stdout] 71 |     pub node: EdgeNode,
[INFO] [stdout] 72 |     pub reason: SelectionReason,
[INFO] [stdout]    |         ^^^^^^
[INFO] [stdout] 73 |     pub alternatives: Vec<String>,
[INFO] [stdout]    |         ^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `NodeSelection` 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 `Weighted`, `RoundRobin`, and `OnlyAvailable` are never constructed
[INFO] [stdout]   --> src/cdn/edge_manager.rs:80:5
[INFO] [stdout]    |
[INFO] [stdout] 77 | pub enum SelectionReason {
[INFO] [stdout]    |          --------------- variants in this enum
[INFO] [stdout] ...
[INFO] [stdout] 80 |     Weighted,
[INFO] [stdout]    |     ^^^^^^^^
[INFO] [stdout] 81 |     RoundRobin,
[INFO] [stdout]    |     ^^^^^^^^^^
[INFO] [stdout] 82 |     OnlyAvailable,
[INFO] [stdout]    |     ^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `SelectionReason` 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: struct `EdgeNodeStats` is never constructed
[INFO] [stdout]   --> src/cdn/edge_manager.rs:87:12
[INFO] [stdout]    |
[INFO] [stdout] 87 | pub struct EdgeNodeStats {
[INFO] [stdout]    |            ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: multiple associated items are never used
[INFO] [stdout]    --> src/cdn/edge_manager.rs:109:12
[INFO] [stdout]     |
[INFO] [stdout]  97 | impl EdgeNodeManager {
[INFO] [stdout]     | -------------------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 109 |     pub fn with_health_config(
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 163 |     pub async fn update_heartbeat(&self, node_id: &str, load: usize) -> bool {
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 179 |     pub async fn select_node(
[INFO] [stdout]     |                  ^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 282 |     async fn select_weighted(&self) -> Option<NodeSelection> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 326 |     async fn select_round_robin(&self) -> Option<NodeSelection> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 355 |     async fn select_random(&self) -> Option<NodeSelection> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 410 |     pub async fn get_all_nodes(&self) -> Vec<EdgeNode> {
[INFO] [stdout]     |                  ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 422 |     pub async fn get_node(&self, node_id: &str) -> Option<EdgeNode> {
[INFO] [stdout]     |                  ^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 432 |     pub fn get_nodes_in_region(&self, location: &str) -> Vec<String> {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 471 |     pub async fn get_node_stats(&self, node_id: &str) -> Option<EdgeNodeStats> {
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 491 |     pub async fn get_cluster_stats(&self) -> ClusterStats {
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 546 |     pub fn set_strategy(&mut self, strategy: LoadBalancingStrategy) {
[INFO] [stdout]     |            ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 552 |     pub fn get_strategy(&self) -> LoadBalancingStrategy {
[INFO] [stdout]     |            ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ClusterStats` is never constructed
[INFO] [stdout]    --> src/cdn/edge_manager.rs:559:12
[INFO] [stdout]     |
[INFO] [stdout] 559 | pub struct ClusterStats {
[INFO] [stdout]     |            ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `total_nodes` and `health_percentage` are never used
[INFO] [stdout]    --> src/cdn/edge_manager.rs:577:12
[INFO] [stdout]     |
[INFO] [stdout] 576 | impl HealthCheckReport {
[INFO] [stdout]     | ---------------------- methods in this implementation
[INFO] [stdout] 577 |     pub fn total_nodes(&self) -> usize {
[INFO] [stdout]     |            ^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 581 |     pub fn health_percentage(&self) -> f64 {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `MissingField` is never constructed
[INFO] [stdout]    --> src/config/settings.rs:324:5
[INFO] [stdout]     |
[INFO] [stdout] 313 | pub enum ConfigError {
[INFO] [stdout]     |          ----------- variant in this enum
[INFO] [stdout] ...
[INFO] [stdout] 324 |     MissingField(String),
[INFO] [stdout]     |     ^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `ConfigError` 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 `keyframe` and `timestamp` are never read
[INFO] [stdout]   --> src/domain/stream.rs:25:9
[INFO] [stdout]    |
[INFO] [stdout] 21 | pub struct VideoSegment {
[INFO] [stdout]    |            ------------ fields in this struct
[INFO] [stdout] ...
[INFO] [stdout] 25 |     pub keyframe: bool,
[INFO] [stdout]    |         ^^^^^^^^
[INFO] [stdout] 26 |     pub timestamp: u64,
[INFO] [stdout]    |         ^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `VideoSegment` 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 `quality`, `bitrate_kbps`, and `resolution` are never read
[INFO] [stdout]   --> src/domain/stream.rs:32:9
[INFO] [stdout]    |
[INFO] [stdout] 31 | pub struct AdaptiveStream {
[INFO] [stdout]    |            -------------- fields in this struct
[INFO] [stdout] 32 |     pub quality: StreamQuality,
[INFO] [stdout]    |         ^^^^^^^
[INFO] [stdout] 33 |     pub bitrate_kbps: u32,
[INFO] [stdout]    |         ^^^^^^^^^^^^
[INFO] [stdout] 34 |     pub resolution: (u32, u32),
[INFO] [stdout]    |         ^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `AdaptiveStream` 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: methods `bitrate_kbps` and `resolution` are never used
[INFO] [stdout]   --> src/domain/quality.rs:21:12
[INFO] [stdout]    |
[INFO] [stdout] 11 | impl StreamQuality {
[INFO] [stdout]    | ------------------ methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 21 |     pub fn bitrate_kbps(&self) -> u32 {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 30 |     pub fn resolution(&self) -> (u32, u32) {
[INFO] [stdout]    |            ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `build` is never used
[INFO] [stdout]    --> src/ingest/rtmp.rs:430:12
[INFO] [stdout]     |
[INFO] [stdout] 400 | impl RtmpServerBuilder {
[INFO] [stdout]     | ---------------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 430 |     pub fn build(self, state: AppState) -> Result<RtmpServer, RtmpError> {
[INFO] [stdout]     |            ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `config`, `sessions`, `job_limiter`, and `hw_accel` are never read
[INFO] [stdout]   --> src/ingest/transcoder.rs:20:5
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub struct TranscoderService {
[INFO] [stdout]    |            ----------------- fields in this struct
[INFO] [stdout] 19 |     /// Application configuration
[INFO] [stdout] 20 |     config: Arc<Config>,
[INFO] [stdout]    |     ^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 23 |     sessions: DashMap<String, Arc<TranscodingSession>>,
[INFO] [stdout]    |     ^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 26 |     job_limiter: Arc<Semaphore>,
[INFO] [stdout]    |     ^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 29 |     hw_accel: HardwareAcceleration,
[INFO] [stdout]    |     ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `enabled` and `accel_type` are never read
[INFO] [stdout]   --> src/ingest/transcoder.rs:35:9
[INFO] [stdout]    |
[INFO] [stdout] 34 | pub struct HardwareAcceleration {
[INFO] [stdout]    |            -------------------- fields in this struct
[INFO] [stdout] 35 |     pub enabled: bool,
[INFO] [stdout]    |         ^^^^^^^
[INFO] [stdout] 36 |     pub accel_type: AccelType,
[INFO] [stdout]    |         ^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `HardwareAcceleration` 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 `Amd` and `VideoToolbox` are never constructed
[INFO] [stdout]   --> src/ingest/transcoder.rs:44:5
[INFO] [stdout]    |
[INFO] [stdout] 40 | pub enum AccelType {
[INFO] [stdout]    |          --------- variants in this enum
[INFO] [stdout] ...
[INFO] [stdout] 44 |     Amd,      // AMF
[INFO] [stdout]    |     ^^^
[INFO] [stdout] 45 |     VideoToolbox, // macOS
[INFO] [stdout]    |     ^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `AccelType` 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 `stream_id` and `processes` are never read
[INFO] [stdout]   --> src/ingest/transcoder.rs:50:5
[INFO] [stdout]    |
[INFO] [stdout] 49 | struct TranscodingSession {
[INFO] [stdout]    |        ------------------ fields in this struct
[INFO] [stdout] 50 |     stream_id: String,
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout] 51 |     processes: DashMap<StreamQuality, TranscodingProcess>,
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `quality`, `child`, and `input_tx` are never read
[INFO] [stdout]   --> src/ingest/transcoder.rs:56:5
[INFO] [stdout]    |
[INFO] [stdout] 55 | struct TranscodingProcess {
[INFO] [stdout]    |        ------------------ fields in this struct
[INFO] [stdout] 56 |     quality: StreamQuality,
[INFO] [stdout]    |     ^^^^^^^
[INFO] [stdout] 57 |     child: Arc<RwLock<Option<tokio::process::Child>>>,
[INFO] [stdout]    |     ^^^^^
[INFO] [stdout] 58 |     input_tx: mpsc::Sender<Bytes>,
[INFO] [stdout]    |     ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `TranscodedSegment` is never constructed
[INFO] [stdout]   --> src/ingest/transcoder.rs:63:12
[INFO] [stdout]    |
[INFO] [stdout] 63 | pub struct TranscodedSegment {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variants `ProcessSpawnError`, `WriteError`, `ReadError`, `SessionNotFound`, `InvalidVideoData`, and `JobLimitReached` are never constructed
[INFO] [stdout]   --> src/ingest/transcoder.rs:77:5
[INFO] [stdout]    |
[INFO] [stdout] 72 | pub enum TranscoderError {
[INFO] [stdout]    |          --------------- variants in this enum
[INFO] [stdout] ...
[INFO] [stdout] 77 |     ProcessSpawnError(String),
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 80 |     WriteError(String),
[INFO] [stdout]    |     ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 83 |     ReadError(String),
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 86 |     SessionNotFound(String),
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 89 |     InvalidVideoData,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 92 |     JobLimitReached,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `TranscoderError` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: multiple associated items are never used
[INFO] [stdout]    --> src/ingest/transcoder.rs:97:12
[INFO] [stdout]     |
[INFO] [stdout]  95 | impl TranscoderService {
[INFO] [stdout]     | ---------------------- associated items in this implementation
[INFO] [stdout]  96 |     /// Create new transcoder service
[INFO] [stdout]  97 |     pub fn new(config: Arc<Config>) -> Result<Arc<Self>, TranscoderError> {
[INFO] [stdout]     |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 179 |     pub async fn start_session(
[INFO] [stdout]     |                  ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 225 |     async fn spawn_transcoding_process(
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 343 |     fn add_hw_accel_args(&self, cmd: &mut Command) {
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 368 |     fn get_video_codec(&self) -> &'static str {
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 383 |     fn profile_to_quality(profile: &TranscodingProfile) -> StreamQuality {
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 394 |     pub async fn stop_session(&self, stream_id: &str) -> Result<(), TranscoderError> {
[INFO] [stdout]     |                  ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 409 |     pub fn active_sessions(&self) -> usize {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 414 |     pub fn has_session(&self, stream_id: &str) -> bool {
[INFO] [stdout]     |            ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `TranscodingStats` is never constructed
[INFO] [stdout]    --> src/ingest/transcoder.rs:446:12
[INFO] [stdout]     |
[INFO] [stdout] 446 | pub struct TranscodingStats {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `compression_ratio` is never used
[INFO] [stdout]    --> src/ingest/transcoder.rs:455:12
[INFO] [stdout]     |
[INFO] [stdout] 454 | impl TranscodingStats {
[INFO] [stdout]     | --------------------- method in this implementation
[INFO] [stdout] 455 |     pub fn compression_ratio(&self) -> f64 {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `TranscoderPool` is never constructed
[INFO] [stdout]   --> src/ingest/transcoder_pool.rs:14:12
[INFO] [stdout]    |
[INFO] [stdout] 14 | pub struct TranscoderPool {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `get_next_worker`, `start_session`, `stop_session`, and `get_stats` are never used
[INFO] [stdout]   --> src/ingest/transcoder_pool.rs:30:12
[INFO] [stdout]    |
[INFO] [stdout] 28 | impl TranscoderPool {
[INFO] [stdout]    | ------------------- associated items in this implementation
[INFO] [stdout] 29 |     /// Create new transcoder pool
[INFO] [stdout] 30 |     pub fn new(config: Arc<Config>, pool_size: usize) -> Result<Arc<Self>, TranscoderError> {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 51 |     fn get_next_worker(&self) -> Arc<TranscoderService> {
[INFO] [stdout]    |        ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 72 |     pub async fn start_session(
[INFO] [stdout]    |                  ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 81 |     pub async fn stop_session(&self, stream_id: &str) -> Result<(), TranscoderError> {
[INFO] [stdout]    |                  ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 90 |     pub fn get_stats(&self) -> PoolStats {
[INFO] [stdout]    |            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `PoolStats` is never constructed
[INFO] [stdout]    --> src/ingest/transcoder_pool.rs:110:12
[INFO] [stdout]     |
[INFO] [stdout] 110 | pub struct PoolStats {
[INFO] [stdout]     |            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `SegmentBuffer` is never constructed
[INFO] [stdout]  --> src/ingest/segment_buffer.rs:6:12
[INFO] [stdout]   |
[INFO] [stdout] 6 | pub struct SegmentBuffer {
[INFO] [stdout]   |            ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: multiple associated items are never used
[INFO] [stdout]   --> src/ingest/segment_buffer.rs:14:12
[INFO] [stdout]    |
[INFO] [stdout] 13 | impl SegmentBuffer {
[INFO] [stdout]    | ------------------ associated items in this implementation
[INFO] [stdout] 14 |     pub fn new(max_size: usize, max_duration: Duration) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 24 |     pub fn push(&mut self, segment: VideoSegment) -> bool {
[INFO] [stdout]    |            ^^^^
[INFO] [stdout] ...
[INFO] [stdout] 38 |     pub fn pop(&mut self) -> Option<VideoSegment> {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 43 |     pub fn is_full(&self) -> bool {
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 48 |     pub fn is_expired(&self) -> bool {
[INFO] [stdout]    |            ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 57 |     pub fn fill_percentage(&self) -> f64 {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 62 |     pub fn clear(&mut self) {
[INFO] [stdout]    |            ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `edge_manager` is never read
[INFO] [stdout]   --> src/manager/stream_manager.rs:24:9
[INFO] [stdout]    |
[INFO] [stdout]  8 | pub struct StreamManager {
[INFO] [stdout]    |            ------------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 24 |     pub edge_manager: Arc<EdgeNodeManager>,
[INFO] [stdout]    |         ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `get_hls_master_playlist`, `get_segment`, `invalidate_cache`, and `get_all_edge_nodes` are never used
[INFO] [stdout]    --> src/manager/stream_manager.rs:166:12
[INFO] [stdout]     |
[INFO] [stdout]  35 | impl StreamManager {
[INFO] [stdout]     | ------------------ methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 166 |     pub fn get_hls_master_playlist(&self, stream_id: &str) -> Option<String> {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 217 |     pub async fn get_segment(
[INFO] [stdout]     |                  ^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 334 |     pub async fn invalidate_cache(&self, stream_id: &str) {
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 340 |     pub fn get_all_edge_nodes(&self) -> Vec<EdgeNode> {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/state/app_state.rs:16:12
[INFO] [stdout]    |
[INFO] [stdout] 14 | impl AppState {
[INFO] [stdout]    | ------------- associated function in this implementation
[INFO] [stdout] 15 |     /// Create new application state
[INFO] [stdout] 16 |     pub fn new(stream_manager: Arc<StreamManager>, config: Config) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `playlist_type` is never read
[INFO] [stdout]  --> src/streaming/hls/manifest.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | pub struct HLSManifestGenerator {
[INFO] [stdout]   |            -------------------- field in this struct
[INFO] [stdout] 6 |     target_duration: u32,
[INFO] [stdout] 7 |     playlist_type: String,
[INFO] [stdout]   |     ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `generate_master_playlist` is never used
[INFO] [stdout]   --> src/streaming/hls/manifest.rs:18:12
[INFO] [stdout]    |
[INFO] [stdout] 10 | impl HLSManifestGenerator {
[INFO] [stdout]    | ------------------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 18 |     pub fn generate_master_playlist(&self, stream_id: &str, qualities: &[StreamQuality]) -> String {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `peer_id` and `stream_id` are never read
[INFO] [stdout]  --> src/streaming/webrtc/connection.rs:2:9
[INFO] [stdout]   |
[INFO] [stdout] 1 | pub struct WebRTCConnection {
[INFO] [stdout]   |            ---------------- fields in this struct
[INFO] [stdout] 2 |     pub peer_id: String,
[INFO] [stdout]   |         ^^^^^^^
[INFO] [stdout] 3 |     pub stream_id: String,
[INFO] [stdout]   |         ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 1m 43s
[INFO] [stderr] warning: the following packages contain code that will be rejected by a future version of Rust: redis v0.24.0
[INFO] [stderr] note: to see what the problems were, use the option `--future-incompat-report`, or run `cargo report future-incompatibilities --id 1`
[INFO] running `Command { std: "docker" "inspect" "9a78478e0d9b7047f669200108f6b5c48d87ede5954b478e300323214bfa21d6", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-w" "/opt/rustwide/workdir" "--user" "0:0" "9a78478e0d9b7047f669200108f6b5c48d87ede5954b478e300323214bfa21d6" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "test" "--frozen", kill_on_drop: false }`
[INFO] [stderr] warning: unused import: `UNIX_EPOCH`
[INFO] [stderr]  --> src/api/health.rs:3:29
[INFO] [stderr]   |
[INFO] [stderr] 3 | use std::time::{SystemTime, UNIX_EPOCH};
[INFO] [stderr]   |                             ^^^^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `create_stream`, `end_stream`, `get_stream`, and `list_streams`
[INFO] [stderr]   --> src/api/mod.rs:10:19
[INFO] [stderr]    |
[INFO] [stderr] 10 | pub use streams::{create_stream, list_streams, get_stream, end_stream};
[INFO] [stderr]    |                   ^^^^^^^^^^^^^  ^^^^^^^^^^^^  ^^^^^^^^^^  ^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `hls_master_playlist`, `hls_media_playlist`, and `hls_segment`
[INFO] [stderr]   --> src/api/mod.rs:11:15
[INFO] [stderr]    |
[INFO] [stderr] 11 | pub use hls::{hls_master_playlist, hls_media_playlist, hls_segment};
[INFO] [stderr]    |               ^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `dash::dash_manifest`
[INFO] [stderr]   --> src/api/mod.rs:12:9
[INFO] [stderr]    |
[INFO] [stderr] 12 | pub use dash::dash_manifest;
[INFO] [stderr]    |         ^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `watch_stream` and `webrtc_signaling`
[INFO] [stderr]   --> src/api/mod.rs:13:21
[INFO] [stderr]    |
[INFO] [stderr] 13 | pub use websocket::{watch_stream, webrtc_signaling};
[INFO] [stderr]    |                     ^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `cache_stats`, `register_edge_node`, and `select_edge_node`
[INFO] [stderr]   --> src/api/mod.rs:14:15
[INFO] [stderr]    |
[INFO] [stderr] 14 | pub use cdn::{register_edge_node, select_edge_node, cache_stats};
[INFO] [stderr]    |               ^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^  ^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `metrics::get_metrics`
[INFO] [stderr]   --> src/api/mod.rs:15:9
[INFO] [stderr]    |
[INFO] [stderr] 15 | pub use metrics::get_metrics;
[INFO] [stderr]    |         ^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `health::health_check`
[INFO] [stderr]   --> src/api/mod.rs:16:9
[INFO] [stderr]    |
[INFO] [stderr] 16 | pub use health::health_check;
[INFO] [stderr]    |         ^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Deserialize`
[INFO] [stderr]  --> src/cdn/edge_manager.rs:7:13
[INFO] [stderr]   |
[INFO] [stderr] 7 | use serde::{Deserialize, Serialize};
[INFO] [stderr]   |             ^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `CdnConfig`, `RedisConfig`, `ServerConfig`, and `StreamingConfig`
[INFO] [stderr]  --> src/config/mod.rs:3:28
[INFO] [stderr]   |
[INFO] [stderr] 3 | pub use settings::{Config, ServerConfig, RedisConfig, CdnConfig, StreamingConfig};
[INFO] [stderr]   |                            ^^^^^^^^^^^^  ^^^^^^^^^^^  ^^^^^^^^^  ^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Semaphore`
[INFO] [stderr]  --> src/ingest/transcoder_pool.rs:2:25
[INFO] [stderr]   |
[INFO] [stderr] 2 | use tokio::sync::{mpsc, Semaphore};
[INFO] [stderr]   |                         ^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `bytes::Bytes`
[INFO] [stderr]  --> src/ingest/transcoder_pool.rs:4:5
[INFO] [stderr]   |
[INFO] [stderr] 4 | use bytes::Bytes;
[INFO] [stderr]   |     ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `quality::StreamQuality`
[INFO] [stderr]  --> src/ingest/transcoder_pool.rs:8:14
[INFO] [stderr]   |
[INFO] [stderr] 8 |     domain::{quality::StreamQuality, stream::VideoSegment},
[INFO] [stderr]   |              ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `AccelType`, `HardwareAcceleration`, `SimpleTranscoder`, `TranscoderError`, `TranscoderService`, and `TranscodingStats`
[INFO] [stderr]   --> src/ingest/mod.rs:13:5
[INFO] [stderr]    |
[INFO] [stderr] 13 |     TranscoderService, 
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^
[INFO] [stderr] 14 |     TranscoderError, 
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^
[INFO] [stderr] 15 |     SimpleTranscoder,
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^
[INFO] [stderr] 16 |     HardwareAcceleration,
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 17 |     AccelType,
[INFO] [stderr]    |     ^^^^^^^^^
[INFO] [stderr] 18 |     TranscodingStats,
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `PoolStats` and `TranscoderPool`
[INFO] [stderr]   --> src/ingest/mod.rs:22:27
[INFO] [stderr]    |
[INFO] [stderr] 22 | pub use transcoder_pool::{TranscoderPool, PoolStats};
[INFO] [stderr]    |                           ^^^^^^^^^^^^^^  ^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `segment_buffer::SegmentBuffer`
[INFO] [stderr]   --> src/ingest/mod.rs:25:9
[INFO] [stderr]    |
[INFO] [stderr] 25 | pub use segment_buffer::SegmentBuffer;
[INFO] [stderr]    |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `stream_manager::StreamManager`
[INFO] [stderr]  --> src/manager/mod.rs:3:9
[INFO] [stderr]   |
[INFO] [stderr] 3 | pub use stream_manager::StreamManager;
[INFO] [stderr]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `app_state::AppState`
[INFO] [stderr]  --> src/state/mod.rs:3:9
[INFO] [stderr]   |
[INFO] [stderr] 3 | pub use app_state::AppState;
[INFO] [stderr]   |         ^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `manifest::HLSManifestGenerator`
[INFO] [stderr]  --> src/streaming/hls/mod.rs:3:9
[INFO] [stderr]   |
[INFO] [stderr] 3 | pub use manifest::HLSManifestGenerator;
[INFO] [stderr]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `manifest::DASHManifestGenerator`
[INFO] [stderr]  --> src/streaming/dash/mod.rs:3:9
[INFO] [stderr]   |
[INFO] [stderr] 3 | pub use manifest::DASHManifestGenerator;
[INFO] [stderr]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `HashMap` and `VecDeque`
[INFO] [stderr]  --> src/streaming/webrtc/connection.rs:9:24
[INFO] [stderr]   |
[INFO] [stderr] 9 | use std::collections::{HashMap, VecDeque};
[INFO] [stderr]   |                        ^^^^^^^  ^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `StreamQuality` and `VideoSegment`
[INFO] [stderr]   --> src/streaming/webrtc/connection.rs:11:21
[INFO] [stderr]    |
[INFO] [stderr] 11 | use crate::domain::{StreamQuality, VideoSegment};
[INFO] [stderr]    |                     ^^^^^^^^^^^^^  ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `connection::WebRTCConnection`
[INFO] [stderr]  --> src/streaming/webrtc/mod.rs:4:9
[INFO] [stderr]   |
[INFO] [stderr] 4 | pub use connection::WebRTCConnection;
[INFO] [stderr]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `WebRTCManager` and `WebRTCSignal`
[INFO] [stderr]  --> src/streaming/webrtc/mod.rs:5:21
[INFO] [stderr]   |
[INFO] [stderr] 5 | pub use signaling::{WebRTCManager, WebRTCSignal};
[INFO] [stderr]   |                     ^^^^^^^^^^^^^  ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `hls::manifest::HLSManifestGenerator`
[INFO] [stderr]  --> src/streaming/mod.rs:5:9
[INFO] [stderr]   |
[INFO] [stderr] 5 | pub use hls::manifest::HLSManifestGenerator;
[INFO] [stderr]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `dash::manifest::DASHManifestGenerator`
[INFO] [stderr]  --> src/streaming/mod.rs:6:9
[INFO] [stderr]   |
[INFO] [stderr] 6 | pub use dash::manifest::DASHManifestGenerator;
[INFO] [stderr]   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `WebRTCManager` and `WebRTCSignal`
[INFO] [stderr]  --> src/streaming/mod.rs:7:29
[INFO] [stderr]   |
[INFO] [stderr] 7 | pub use webrtc::signaling::{WebRTCManager, WebRTCSignal};
[INFO] [stderr]   |                             ^^^^^^^^^^^^^  ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `addr`
[INFO] [stderr]   --> src/ingest/rtmp.rs:88:5
[INFO] [stderr]    |
[INFO] [stderr] 88 |     addr: SocketAddr,
[INFO] [stderr]    |     ^^^^ help: if this is intentional, prefix it with an underscore: `_addr`
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variable `sequence` is assigned to, but never used
[INFO] [stderr]    --> src/ingest/transcoder.rs:314:17
[INFO] [stderr]     |
[INFO] [stderr] 314 |             let mut sequence = 0u64;
[INFO] [stderr]     |                 ^^^^^^^^^^^^
[INFO] [stderr]     |
[INFO] [stderr]     = note: consider using `_sequence` instead
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `data`
[INFO] [stderr]    --> src/ingest/transcoder.rs:321:21
[INFO] [stderr]     |
[INFO] [stderr] 321 |                 let data = Bytes::copy_from_slice(&buffer[..n]);
[INFO] [stderr]     |                     ^^^^ help: if this is intentional, prefix it with an underscore: `_data`
[INFO] [stderr] 
[INFO] [stderr] warning: value assigned to `sequence` is never read
[INFO] [stderr]    --> src/ingest/transcoder.rs:331:17
[INFO] [stderr]     |
[INFO] [stderr] 331 |                 sequence += 1;
[INFO] [stderr]     |                 ^^^^^^^^^^^^^
[INFO] [stderr]     |
[INFO] [stderr]     = help: maybe it is overwritten before being read?
[INFO] [stderr]     = note: `#[warn(unused_assignments)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `viewer_location`
[INFO] [stderr]    --> src/manager/stream_manager.rs:247:36
[INFO] [stderr]     |
[INFO] [stderr] 247 |     pub fn select_edge_node(&self, viewer_location: &str) -> Option<EdgeNode> {
[INFO] [stderr]     |                                    ^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_viewer_location`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `quality`
[INFO] [stderr]    --> src/manager/stream_manager.rs:259:9
[INFO] [stderr]     |
[INFO] [stderr] 259 |         quality: StreamQuality,
[INFO] [stderr]     |         ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_quality`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `stream_id`
[INFO] [stderr]   --> src/streaming/hls/manifest.rs:18:44
[INFO] [stderr]    |
[INFO] [stderr] 18 |     pub fn generate_master_playlist(&self, stream_id: &str, qualities: &[StreamQuality]) -> String {
[INFO] [stderr]    |                                            ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_stream_id`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `stream_id`
[INFO] [stderr]   --> src/streaming/hls/manifest.rs:51:9
[INFO] [stderr]    |
[INFO] [stderr] 51 |         stream_id: &str,
[INFO] [stderr]    |         ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_stream_id`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `quality`
[INFO] [stderr]   --> src/streaming/hls/manifest.rs:52:9
[INFO] [stderr]    |
[INFO] [stderr] 52 |         quality: StreamQuality,
[INFO] [stderr]    |         ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_quality`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `segments`
[INFO] [stderr]   --> src/streaming/dash/manifest.rs:16:9
[INFO] [stderr]    |
[INFO] [stderr] 16 |         segments: &HashMap<StreamQuality, VecDeque<VideoSegment>>,
[INFO] [stderr]    |         ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_segments`
[INFO] [stderr] 
[INFO] [stderr] warning: function `stream_cache_stats` is never used
[INFO] [stderr]    --> src/api/cdn.rs:148:14
[INFO] [stderr]     |
[INFO] [stderr] 148 | pub async fn stream_cache_stats(
[INFO] [stderr]     |              ^^^^^^^^^^^^^^^^^^
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: function `clear_stream_cache` is never used
[INFO] [stderr]    --> src/api/cdn.rs:168:14
[INFO] [stderr]     |
[INFO] [stderr] 168 | pub async fn clear_stream_cache(
[INFO] [stderr]     |              ^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `EdgeNodeHealthResponse` is never constructed
[INFO] [stderr]    --> src/api/cdn.rs:187:12
[INFO] [stderr]     |
[INFO] [stderr] 187 | pub struct EdgeNodeHealthResponse {
[INFO] [stderr]     |            ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `EdgeNodeStatus` is never constructed
[INFO] [stderr]    --> src/api/cdn.rs:194:12
[INFO] [stderr]     |
[INFO] [stderr] 194 | pub struct EdgeNodeStatus {
[INFO] [stderr]     |            ^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `edge_nodes_health` is never used
[INFO] [stderr]    --> src/api/cdn.rs:203:14
[INFO] [stderr]     |
[INFO] [stderr] 203 | pub async fn edge_nodes_health(
[INFO] [stderr]     |              ^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `CdnMetrics` is never constructed
[INFO] [stderr]    --> src/api/cdn.rs:244:12
[INFO] [stderr]     |
[INFO] [stderr] 244 | pub struct CdnMetrics {
[INFO] [stderr]     |            ^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `StreamBandwidth` is never constructed
[INFO] [stderr]    --> src/api/cdn.rs:255:12
[INFO] [stderr]     |
[INFO] [stderr] 255 | pub struct StreamBandwidth {
[INFO] [stderr]     |            ^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `cdn_metrics` is never used
[INFO] [stderr]    --> src/api/cdn.rs:262:14
[INFO] [stderr]     |
[INFO] [stderr] 262 | pub async fn cdn_metrics(
[INFO] [stderr]     |              ^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: methods `get`, `record_hit`, and `record_miss` are never used
[INFO] [stderr]    --> src/cdn/cache.rs:39:18
[INFO] [stderr]     |
[INFO] [stderr]  26 | impl EdgeCache {
[INFO] [stderr]     | -------------- methods in this implementation
[INFO] [stderr] ...
[INFO] [stderr]  39 |     pub async fn get(&self, key: &str) -> Option<Bytes> {
[INFO] [stderr]     |                  ^^^
[INFO] [stderr] ...
[INFO] [stderr] 105 |     fn record_hit(&self, key: &str) {
[INFO] [stderr]     |        ^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 112 |     fn record_miss(&self, key: &str) {
[INFO] [stderr]     |        ^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field `strategy` is never read
[INFO] [stderr]   --> src/cdn/edge_manager.rs:20:5
[INFO] [stderr]    |
[INFO] [stderr] 12 | pub struct EdgeNodeManager {
[INFO] [stderr]    |            --------------- field in this struct
[INFO] [stderr] ...
[INFO] [stderr] 20 |     strategy: LoadBalancingStrategy,
[INFO] [stderr]    |     ^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field `auto_failover` is never read
[INFO] [stderr]   --> src/cdn/edge_manager.rs:55:9
[INFO] [stderr]    |
[INFO] [stderr] 47 | pub struct HealthCheckConfig {
[INFO] [stderr]    |            ----------------- field in this struct
[INFO] [stderr] ...
[INFO] [stderr] 55 |     pub auto_failover: bool,
[INFO] [stderr]    |         ^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `HealthCheckConfig` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: fields `reason` and `alternatives` are never read
[INFO] [stderr]   --> src/cdn/edge_manager.rs:72:9
[INFO] [stderr]    |
[INFO] [stderr] 70 | pub struct NodeSelection {
[INFO] [stderr]    |            ------------- fields in this struct
[INFO] [stderr] 71 |     pub node: EdgeNode,
[INFO] [stderr] 72 |     pub reason: SelectionReason,
[INFO] [stderr]    |         ^^^^^^
[INFO] [stderr] 73 |     pub alternatives: Vec<String>,
[INFO] [stderr]    |         ^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `NodeSelection` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: variants `Weighted`, `RoundRobin`, and `OnlyAvailable` are never constructed
[INFO] [stderr]   --> src/cdn/edge_manager.rs:80:5
[INFO] [stderr]    |
[INFO] [stderr] 77 | pub enum SelectionReason {
[INFO] [stderr]    |          --------------- variants in this enum
[INFO] [stderr] ...
[INFO] [stderr] 80 |     Weighted,
[INFO] [stderr]    |     ^^^^^^^^
[INFO] [stderr] 81 |     RoundRobin,
[INFO] [stderr]    |     ^^^^^^^^^^
[INFO] [stderr] 82 |     OnlyAvailable,
[INFO] [stderr]    |     ^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `SelectionReason` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: struct `EdgeNodeStats` is never constructed
[INFO] [stderr]   --> src/cdn/edge_manager.rs:87:12
[INFO] [stderr]    |
[INFO] [stderr] 87 | pub struct EdgeNodeStats {
[INFO] [stderr]    |            ^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: multiple associated items are never used
[INFO] [stderr]    --> src/cdn/edge_manager.rs:109:12
[INFO] [stderr]     |
[INFO] [stderr]  97 | impl EdgeNodeManager {
[INFO] [stderr]     | -------------------- associated items in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 109 |     pub fn with_health_config(
[INFO] [stderr]     |            ^^^^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 163 |     pub async fn update_heartbeat(&self, node_id: &str, load: usize) -> bool {
[INFO] [stderr]     |                  ^^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 179 |     pub async fn select_node(
[INFO] [stderr]     |                  ^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 282 |     async fn select_weighted(&self) -> Option<NodeSelection> {
[INFO] [stderr]     |              ^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 326 |     async fn select_round_robin(&self) -> Option<NodeSelection> {
[INFO] [stderr]     |              ^^^^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 355 |     async fn select_random(&self) -> Option<NodeSelection> {
[INFO] [stderr]     |              ^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 410 |     pub async fn get_all_nodes(&self) -> Vec<EdgeNode> {
[INFO] [stderr]     |                  ^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 422 |     pub async fn get_node(&self, node_id: &str) -> Option<EdgeNode> {
[INFO] [stderr]     |                  ^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 432 |     pub fn get_nodes_in_region(&self, location: &str) -> Vec<String> {
[INFO] [stderr]     |            ^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 471 |     pub async fn get_node_stats(&self, node_id: &str) -> Option<EdgeNodeStats> {
[INFO] [stderr]     |                  ^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 491 |     pub async fn get_cluster_stats(&self) -> ClusterStats {
[INFO] [stderr]     |                  ^^^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 546 |     pub fn set_strategy(&mut self, strategy: LoadBalancingStrategy) {
[INFO] [stderr]     |            ^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 552 |     pub fn get_strategy(&self) -> LoadBalancingStrategy {
[INFO] [stderr]     |            ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `ClusterStats` is never constructed
[INFO] [stderr]    --> src/cdn/edge_manager.rs:559:12
[INFO] [stderr]     |
[INFO] [stderr] 559 | pub struct ClusterStats {
[INFO] [stderr]     |            ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: methods `total_nodes` and `health_percentage` are never used
[INFO] [stderr]    --> src/cdn/edge_manager.rs:577:12
[INFO] [stderr]     |
[INFO] [stderr] 576 | impl HealthCheckReport {
[INFO] [stderr]     | ---------------------- methods in this implementation
[INFO] [stderr] 577 |     pub fn total_nodes(&self) -> usize {
[INFO] [stderr]     |            ^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 581 |     pub fn health_percentage(&self) -> f64 {
[INFO] [stderr]     |            ^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: variant `MissingField` is never constructed
[INFO] [stderr]    --> src/config/settings.rs:324:5
[INFO] [stderr]     |
[INFO] [stderr] 313 | pub enum ConfigError {
[INFO] [stderr]     |          ----------- variant in this enum
[INFO] [stderr] ...
[INFO] [stderr] 324 |     MissingField(String),
[INFO] [stderr]     |     ^^^^^^^^^^^^
[INFO] [stderr]     |
[INFO] [stderr]     = note: `ConfigError` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: fields `keyframe` and `timestamp` are never read
[INFO] [stderr]   --> src/domain/stream.rs:25:9
[INFO] [stderr]    |
[INFO] [stderr] 21 | pub struct VideoSegment {
[INFO] [stderr]    |            ------------ fields in this struct
[INFO] [stderr] ...
[INFO] [stderr] 25 |     pub keyframe: bool,
[INFO] [stderr]    |         ^^^^^^^^
[INFO] [stderr] 26 |     pub timestamp: u64,
[INFO] [stderr]    |         ^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `VideoSegment` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: fields `quality`, `bitrate_kbps`, and `resolution` are never read
[INFO] [stderr]   --> src/domain/stream.rs:32:9
[INFO] [stderr]    |
[INFO] [stderr] 31 | pub struct AdaptiveStream {
[INFO] [stderr]    |            -------------- fields in this struct
[INFO] [stderr] 32 |     pub quality: StreamQuality,
[INFO] [stderr]    |         ^^^^^^^
[INFO] [stderr] 33 |     pub bitrate_kbps: u32,
[INFO] [stderr]    |         ^^^^^^^^^^^^
[INFO] [stderr] 34 |     pub resolution: (u32, u32),
[INFO] [stderr]    |         ^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `AdaptiveStream` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: methods `bitrate_kbps` and `resolution` are never used
[INFO] [stderr]   --> src/domain/quality.rs:21:12
[INFO] [stderr]    |
[INFO] [stderr] 11 | impl StreamQuality {
[INFO] [stderr]    | ------------------ methods in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 21 |     pub fn bitrate_kbps(&self) -> u32 {
[INFO] [stderr]    |            ^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 30 |     pub fn resolution(&self) -> (u32, u32) {
[INFO] [stderr]    |            ^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `build` is never used
[INFO] [stderr]    --> src/ingest/rtmp.rs:430:12
[INFO] [stderr]     |
[INFO] [stderr] 400 | impl RtmpServerBuilder {
[INFO] [stderr]     | ---------------------- method in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 430 |     pub fn build(self, state: AppState) -> Result<RtmpServer, RtmpError> {
[INFO] [stderr]     |            ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: fields `config`, `sessions`, `job_limiter`, and `hw_accel` are never read
[INFO] [stderr]   --> src/ingest/transcoder.rs:20:5
[INFO] [stderr]    |
[INFO] [stderr] 18 | pub struct TranscoderService {
[INFO] [stderr]    |            ----------------- fields in this struct
[INFO] [stderr] 19 |     /// Application configuration
[INFO] [stderr] 20 |     config: Arc<Config>,
[INFO] [stderr]    |     ^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 23 |     sessions: DashMap<String, Arc<TranscodingSession>>,
[INFO] [stderr]    |     ^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 26 |     job_limiter: Arc<Semaphore>,
[INFO] [stderr]    |     ^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 29 |     hw_accel: HardwareAcceleration,
[INFO] [stderr]    |     ^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: fields `enabled` and `accel_type` are never read
[INFO] [stderr]   --> src/ingest/transcoder.rs:35:9
[INFO] [stderr]    |
[INFO] [stderr] 34 | pub struct HardwareAcceleration {
[INFO] [stderr]    |            -------------------- fields in this struct
[INFO] [stderr] 35 |     pub enabled: bool,
[INFO] [stderr]    |         ^^^^^^^
[INFO] [stderr] 36 |     pub accel_type: AccelType,
[INFO] [stderr]    |         ^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `HardwareAcceleration` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: variants `Amd` and `VideoToolbox` are never constructed
[INFO] [stderr]   --> src/ingest/transcoder.rs:44:5
[INFO] [stderr]    |
[INFO] [stderr] 40 | pub enum AccelType {
[INFO] [stderr]    |          --------- variants in this enum
[INFO] [stderr] ...
[INFO] [stderr] 44 |     Amd,      // AMF
[INFO] [stderr]    |     ^^^
[INFO] [stderr] 45 |     VideoToolbox, // macOS
[INFO] [stderr]    |     ^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `AccelType` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: fields `stream_id` and `processes` are never read
[INFO] [stderr]   --> src/ingest/transcoder.rs:50:5
[INFO] [stderr]    |
[INFO] [stderr] 49 | struct TranscodingSession {
[INFO] [stderr]    |        ------------------ fields in this struct
[INFO] [stderr] 50 |     stream_id: String,
[INFO] [stderr]    |     ^^^^^^^^^
[INFO] [stderr] 51 |     processes: DashMap<StreamQuality, TranscodingProcess>,
[INFO] [stderr]    |     ^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: fields `quality`, `child`, and `input_tx` are never read
[INFO] [stderr]   --> src/ingest/transcoder.rs:56:5
[INFO] [stderr]    |
[INFO] [stderr] 55 | struct TranscodingProcess {
[INFO] [stderr]    |        ------------------ fields in this struct
[INFO] [stderr] 56 |     quality: StreamQuality,
[INFO] [stderr]    |     ^^^^^^^
[INFO] [stderr] 57 |     child: Arc<RwLock<Option<tokio::process::Child>>>,
[INFO] [stderr]    |     ^^^^^
[INFO] [stderr] 58 |     input_tx: mpsc::Sender<Bytes>,
[INFO] [stderr]    |     ^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `TranscodedSegment` is never constructed
[INFO] [stderr]   --> src/ingest/transcoder.rs:63:12
[INFO] [stderr]    |
[INFO] [stderr] 63 | pub struct TranscodedSegment {
[INFO] [stderr]    |            ^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: variants `ProcessSpawnError`, `WriteError`, `ReadError`, `SessionNotFound`, `InvalidVideoData`, and `JobLimitReached` are never constructed
[INFO] [stderr]   --> src/ingest/transcoder.rs:77:5
[INFO] [stderr]    |
[INFO] [stderr] 72 | pub enum TranscoderError {
[INFO] [stderr]    |          --------------- variants in this enum
[INFO] [stderr] ...
[INFO] [stderr] 77 |     ProcessSpawnError(String),
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 80 |     WriteError(String),
[INFO] [stderr]    |     ^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 83 |     ReadError(String),
[INFO] [stderr]    |     ^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 86 |     SessionNotFound(String),
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 89 |     InvalidVideoData,
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 92 |     JobLimitReached,
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `TranscoderError` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: multiple associated items are never used
[INFO] [stderr]    --> src/ingest/transcoder.rs:97:12
[INFO] [stderr]     |
[INFO] [stderr]  95 | impl TranscoderService {
[INFO] [stderr]     | ---------------------- associated items in this implementation
[INFO] [stderr]  96 |     /// Create new transcoder service
[INFO] [stderr]  97 |     pub fn new(config: Arc<Config>) -> Result<Arc<Self>, TranscoderError> {
[INFO] [stderr]     |            ^^^
[INFO] [stderr] ...
[INFO] [stderr] 179 |     pub async fn start_session(
[INFO] [stderr]     |                  ^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 225 |     async fn spawn_transcoding_process(
[INFO] [stderr]     |              ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 343 |     fn add_hw_accel_args(&self, cmd: &mut Command) {
[INFO] [stderr]     |        ^^^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 368 |     fn get_video_codec(&self) -> &'static str {
[INFO] [stderr]     |        ^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 383 |     fn profile_to_quality(profile: &TranscodingProfile) -> StreamQuality {
[INFO] [stderr]     |        ^^^^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 394 |     pub async fn stop_session(&self, stream_id: &str) -> Result<(), TranscoderError> {
[INFO] [stderr]     |                  ^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 409 |     pub fn active_sessions(&self) -> usize {
[INFO] [stderr]     |            ^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 414 |     pub fn has_session(&self, stream_id: &str) -> bool {
[INFO] [stderr]     |            ^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `TranscodingStats` is never constructed
[INFO] [stderr]    --> src/ingest/transcoder.rs:446:12
[INFO] [stderr]     |
[INFO] [stderr] 446 | pub struct TranscodingStats {
[INFO] [stderr]     |            ^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `compression_ratio` is never used
[INFO] [stderr]    --> src/ingest/transcoder.rs:455:12
[INFO] [stderr]     |
[INFO] [stderr] 454 | impl TranscodingStats {
[INFO] [stderr]     | --------------------- method in this implementation
[INFO] [stderr] 455 |     pub fn compression_ratio(&self) -> f64 {
[INFO] [stderr]     |            ^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `TranscoderPool` is never constructed
[INFO] [stderr]   --> src/ingest/transcoder_pool.rs:14:12
[INFO] [stderr]    |
[INFO] [stderr] 14 | pub struct TranscoderPool {
[INFO] [stderr]    |            ^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: associated items `new`, `get_next_worker`, `start_session`, `stop_session`, and `get_stats` are never used
[INFO] [stderr]   --> src/ingest/transcoder_pool.rs:30:12
[INFO] [stderr]    |
[INFO] [stderr] 28 | impl TranscoderPool {
[INFO] [stderr]    | ------------------- associated items in this implementation
[INFO] [stderr] 29 |     /// Create new transcoder pool
[INFO] [stderr] 30 |     pub fn new(config: Arc<Config>, pool_size: usize) -> Result<Arc<Self>, TranscoderError> {
[INFO] [stderr]    |            ^^^
[INFO] [stderr] ...
[INFO] [stderr] 51 |     fn get_next_worker(&self) -> Arc<TranscoderService> {
[INFO] [stderr]    |        ^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 72 |     pub async fn start_session(
[INFO] [stderr]    |                  ^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 81 |     pub async fn stop_session(&self, stream_id: &str) -> Result<(), TranscoderError> {
[INFO] [stderr]    |                  ^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 90 |     pub fn get_stats(&self) -> PoolStats {
[INFO] [stderr]    |            ^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `PoolStats` is never constructed
[INFO] [stderr]    --> src/ingest/transcoder_pool.rs:110:12
[INFO] [stderr]     |
[INFO] [stderr] 110 | pub struct PoolStats {
[INFO] [stderr]     |            ^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `SegmentBuffer` is never constructed
[INFO] [stderr]  --> src/ingest/segment_buffer.rs:6:12
[INFO] [stderr]   |
[INFO] [stderr] 6 | pub struct SegmentBuffer {
[INFO] [stderr]   |            ^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: multiple associated items are never used
[INFO] [stderr]   --> src/ingest/segment_buffer.rs:14:12
[INFO] [stderr]    |
[INFO] [stderr] 13 | impl SegmentBuffer {
[INFO] [stderr]    | ------------------ associated items in this implementation
[INFO] [stderr] 14 |     pub fn new(max_size: usize, max_duration: Duration) -> Self {
[INFO] [stderr]    |            ^^^
[INFO] [stderr] ...
[INFO] [stderr] 24 |     pub fn push(&mut self, segment: VideoSegment) -> bool {
[INFO] [stderr]    |            ^^^^
[INFO] [stderr] ...
[INFO] [stderr] 38 |     pub fn pop(&mut self) -> Option<VideoSegment> {
[INFO] [stderr]    |            ^^^
[INFO] [stderr] ...
[INFO] [stderr] 43 |     pub fn is_full(&self) -> bool {
[INFO] [stderr]    |            ^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 48 |     pub fn is_expired(&self) -> bool {
[INFO] [stderr]    |            ^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 57 |     pub fn fill_percentage(&self) -> f64 {
[INFO] [stderr]    |            ^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 62 |     pub fn clear(&mut self) {
[INFO] [stderr]    |            ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field `edge_manager` is never read
[INFO] [stderr]   --> src/manager/stream_manager.rs:24:9
[INFO] [stderr]    |
[INFO] [stderr]  8 | pub struct StreamManager {
[INFO] [stderr]    |            ------------- field in this struct
[INFO] [stderr] ...
[INFO] [stderr] 24 |     pub edge_manager: Arc<EdgeNodeManager>,
[INFO] [stderr]    |         ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: methods `get_hls_master_playlist`, `get_segment`, `invalidate_cache`, and `get_all_edge_nodes` are never used
[INFO] [stderr]    --> src/manager/stream_manager.rs:166:12
[INFO] [stderr]     |
[INFO] [stderr]  35 | impl StreamManager {
[INFO] [stderr]     | ------------------ methods in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 166 |     pub fn get_hls_master_playlist(&self, stream_id: &str) -> Option<String> {
[INFO] [stderr]     |            ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 217 |     pub async fn get_segment(
[INFO] [stderr]     |                  ^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 334 |     pub async fn invalidate_cache(&self, stream_id: &str) {
[INFO] [stderr]     |                  ^^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 340 |     pub fn get_all_edge_nodes(&self) -> Vec<EdgeNode> {
[INFO] [stderr]     |            ^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: associated function `new` is never used
[INFO] [stderr]   --> src/state/app_state.rs:16:12
[INFO] [stderr]    |
[INFO] [stderr] 14 | impl AppState {
[INFO] [stderr]    | ------------- associated function in this implementation
[INFO] [stderr] 15 |     /// Create new application state
[INFO] [stderr] 16 |     pub fn new(stream_manager: Arc<StreamManager>, config: Config) -> Self {
[INFO] [stderr]    |            ^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field `playlist_type` is never read
[INFO] [stderr]  --> src/streaming/hls/manifest.rs:7:5
[INFO] [stderr]   |
[INFO] [stderr] 5 | pub struct HLSManifestGenerator {
[INFO] [stderr]   |            -------------------- field in this struct
[INFO] [stderr] 6 |     target_duration: u32,
[INFO] [stderr] 7 |     playlist_type: String,
[INFO] [stderr]   |     ^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `generate_master_playlist` is never used
[INFO] [stderr]   --> src/streaming/hls/manifest.rs:18:12
[INFO] [stderr]    |
[INFO] [stderr] 10 | impl HLSManifestGenerator {
[INFO] [stderr]    | ------------------------- method in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 18 |     pub fn generate_master_playlist(&self, stream_id: &str, qualities: &[StreamQuality]) -> String {
[INFO] [stderr]    |            ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: fields `peer_id` and `stream_id` are never read
[INFO] [stderr]  --> src/streaming/webrtc/connection.rs:2:9
[INFO] [stderr]   |
[INFO] [stderr] 1 | pub struct WebRTCConnection {
[INFO] [stderr]   |            ---------------- fields in this struct
[INFO] [stderr] 2 |     pub peer_id: String,
[INFO] [stderr]   |         ^^^^^^^
[INFO] [stderr] 3 |     pub stream_id: String,
[INFO] [stderr]   |         ^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: `live-streaming-cdn` (bin "live-streaming-cdn" test) generated 80 warnings (run `cargo fix --bin "live-streaming-cdn" -p live-streaming-cdn --tests` to apply 35 suggestions)
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 0.46s
[INFO] [stderr] warning: the following packages contain code that will be rejected by a future version of Rust: redis v0.24.0
[INFO] [stderr] note: to see what the problems were, use the option `--future-incompat-report`, or run `cargo report future-incompatibilities --id 1`
[INFO] [stderr]      Running unittests src/main.rs (/opt/rustwide/target/debug/deps/live_streaming_cdn-76a28037de352574)
[INFO] [stdout] 
[INFO] [stdout] running 14 tests
[INFO] [stdout] test api::websocket::tests::test_parse_quality ... ok
[INFO] [stdout] test config::settings::tests::test_addresses ... ok
[INFO] [stdout] test cdn::edge_manager::tests::test_least_connections_selection ... ok
[INFO] [stdout] test cdn::edge_manager::tests::test_geographic_selection ... ok
[INFO] [stdout] test config::settings::tests::test_default_config ... ok
[INFO] [stdout] test cdn::edge_manager::tests::test_health_check ... ok
[INFO] [stdout] test ingest::rtmp::tests::test_keyframe_detection ... ok
[INFO] [stdout] test config::settings::tests::test_node_type_helpers ... ok
[INFO] [stdout] test ingest::rtmp::tests::test_rtmp_server_builder ... ok
[INFO] [stdout] test cdn::edge_manager::tests::test_register_and_unregister ... ok
[INFO] [stdout] test ingest::transcoder::tests::test_simple_transcoder ... ok
[INFO] [stdout] test config::settings::tests::test_config_validation ... ok
[INFO] [stdout] test ingest::transcoder::tests::test_hw_accel_detection ... ok
[INFO] [stdout] test ingest::transcoder::tests::test_ffmpeg_check ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 14 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s
[INFO] [stdout] 
[INFO] running `Command { std: "docker" "inspect" "9a78478e0d9b7047f669200108f6b5c48d87ede5954b478e300323214bfa21d6", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "9a78478e0d9b7047f669200108f6b5c48d87ede5954b478e300323214bfa21d6", kill_on_drop: false }`
[INFO] [stdout] 9a78478e0d9b7047f669200108f6b5c48d87ede5954b478e300323214bfa21d6
