hyperi-rustlib 2.8.15

There's plenty of sage advice out there about how to run Rust services in production at scale — config cascades, structured logging, masking secrets, multi-backend secrets management, Prometheus, OpenTelemetry, Kafka transports, tiered disk-spillover sinks, adaptive worker pools, graceful shutdown — but almost none of it as code you can just install and use. This is that code. Opinionated, drop-in, working out of the box. The patterns from blog posts, watercooler chats and beers with your Google mates as actual library — not a framework you assemble from twenty crates and 8 weeks of munging.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

// Project:   hyperi-rustlib
// File:      tests/from_cascade_deser_error.rs
// Purpose:   Pin the present-but-malformed-section -> WARN + default behaviour
// Language:  Rust
//
// License:   BUSL-1.1
// Copyright: (c) 2026 HYPERI PTY LIMITED

//! Deser-error behaviour test for the 2.8.11 fix (step 5).
//!
//! A `worker_pool` section that is PRESENT but malformed (a field has the wrong
//! type) must fall back to the default config -- it must NOT panic and must NOT
//! error the build. The `unmarshal_key_or_warn` helper emits a `tracing::warn!`
//! in this case (observability), but the data path still gets a usable default.
//!
//! Own integration binary: the config singleton is process-global, so this
//! file owns its `config::setup()`.
#![cfg(all(feature = "config", feature = "worker-pool"))]

use hyperi_rustlib::WorkerPoolConfig;
use hyperi_rustlib::config::{self, ConfigOptions};

#[test]
fn malformed_worker_pool_section_falls_back_to_default() {
    // `min_threads` must be an integer; a string is a type mismatch. The
    // section is PRESENT (so this is the malformed case, not the absent case).
    let yaml = "\
worker_pool:
  min_threads: \"not-a-number\"
  max_threads: 9
";

    let dir = std::env::temp_dir().join(format!("rustlib-deser-err-{}", std::process::id()));
    std::fs::create_dir_all(&dir).expect("create temp dir");
    let file = dir.join("config.yaml");
    std::fs::write(&file, yaml).expect("write config");

    config::setup(ConfigOptions {
        config_file: Some(file.clone()),
        ..Default::default()
    })
    .expect("config setup");

    // Must not panic, must not error -- returns a VALID default config.
    let wp = WorkerPoolConfig::from_cascade("worker_pool")
        .expect("malformed section must fall back to a valid default, not error");

    // Defaulted, not the file's bogus values.
    assert_eq!(
        wp.min_threads,
        WorkerPoolConfig::default().min_threads,
        "malformed worker_pool must default min_threads, not adopt the bad value"
    );
    assert_eq!(
        wp.max_threads,
        WorkerPoolConfig::default().max_threads,
        "a malformed section defaults wholesale (figment deser is all-or-nothing per key)"
    );

    std::fs::remove_dir_all(&dir).ok();
}