cano 0.11.0

High-performance orchestration engine for building resilient, self-healing systems in Rust. Uses Finite State Machines (FSM) for strict, type-safe transitions.
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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129

use cano::prelude::*;
use criterion::{BenchmarkId, Criterion, criterion_group, criterion_main};
use std::sync::Arc;

/// Benchmark 1: Resources::get with string key (hot path overhead vs direct &MemoryStore)
fn bench_resources_get_string_key(c: &mut Criterion) {
    let mut group = c.benchmark_group("resources_get");

    // Direct MemoryStore reference (baseline — old API pattern)
    group.bench_function("direct_store_get", |b| {
        let store = MemoryStore::new();
        store.put("counter", 42u64).unwrap();
        b.iter(|| {
            let _: u64 = store.get("counter").unwrap();
        });
    });

    // Resources::get → Arc<MemoryStore> → store.get (new API)
    group.bench_function("resources_get_string_key", |b| {
        let resources: Resources<String> =
            Resources::new().insert("store".to_owned(), MemoryStore::new());
        resources
            .get::<MemoryStore, str>("store")
            .unwrap()
            .put("counter", 42u64)
            .unwrap();
        b.iter(|| {
            let store = resources.get::<MemoryStore, str>("store").unwrap();
            let _: u64 = store.get("counter").unwrap();
        });
    });

    group.finish();
}

/// Benchmark 2: Resources::get with enum key
fn bench_resources_get_enum_key(c: &mut Criterion) {
    #[derive(Hash, Eq, PartialEq)]
    enum Key {
        Store,
    }

    let mut group = c.benchmark_group("resources_get_enum");
    group.bench_function("enum_key_get", |b| {
        let resources = Resources::<Key>::new().insert(Key::Store, MemoryStore::new());
        resources
            .get::<MemoryStore, Key>(&Key::Store)
            .unwrap()
            .put("counter", 42u64)
            .unwrap();
        b.iter(|| {
            let store = resources.get::<MemoryStore, Key>(&Key::Store).unwrap();
            let _: u64 = store.get("counter").unwrap();
        });
    });
    group.finish();
}

/// Benchmark 3: Lifecycle overhead for N no-op resources
fn bench_lifecycle_n_resources(c: &mut Criterion) {
    struct Noop;

    #[cano::resource]
    impl cano::resource::Resource for Noop {}

    let runtime = tokio::runtime::Runtime::new().unwrap();
    let mut group = c.benchmark_group("lifecycle_n_resources");

    for n in [1usize, 5, 10, 50] {
        group.bench_with_input(BenchmarkId::from_parameter(n), &n, |b, &n| {
            // Build the dictionary once per parameter — key allocation and insert
            // chaining are not part of what we want to measure. setup_all and
            // teardown_all take &self and Noop's hooks are no-ops, so the same
            // instance is reused across iterations.
            let mut resources: Resources<String> = Resources::new();
            for i in 0..n {
                resources = resources.insert(format!("r{i}"), Noop);
            }
            b.to_async(&runtime).iter(|| async {
                resources.setup_all().await.unwrap();
                // teardown_all returns (); per-resource errors are logged
                // internally. Noop never fails, so nothing to assert here.
                resources.teardown_all().await;
            });
        });
    }
    group.finish();
}

/// Benchmark 4: Concurrent Arc clone from get() (split pattern simulation)
fn bench_resources_get_concurrent(c: &mut Criterion) {
    let runtime = tokio::runtime::Runtime::new().unwrap();
    let mut group = c.benchmark_group("resources_concurrent_get");

    for concurrency in [2usize, 8, 16] {
        group.bench_with_input(
            BenchmarkId::from_parameter(concurrency),
            &concurrency,
            |b, &concurrency| {
                let resources: Arc<Resources<String>> =
                    Arc::new(Resources::new().insert("store".to_owned(), MemoryStore::new()));
                b.iter(|| {
                    runtime.block_on(async {
                        let mut handles = Vec::with_capacity(concurrency);
                        for _ in 0..concurrency {
                            let res = Arc::clone(&resources);
                            handles.push(tokio::spawn(async move {
                                let _store = res.get::<MemoryStore, str>("store").unwrap();
                            }));
                        }
                        for h in handles {
                            h.await.unwrap();
                        }
                    });
                });
            },
        );
    }
    group.finish();
}

criterion_group!(
    resource_benches,
    bench_resources_get_string_key,
    bench_resources_get_enum_key,
    bench_lifecycle_n_resources,
    bench_resources_get_concurrent,
);
criterion_main!(resource_benches);