prolly-map 0.5.0

Content-addressed versioned map storage primitives.
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

use prolly::{Config, Error, ExecutionConfig};

#[test]
fn execution_config_rejects_every_zero_limit() {
    for (field, values) in [
        ("read_parallelism", [0, 1, 1, 1]),
        ("max_in_flight_bytes", [1, 0, 1, 1]),
        ("node_cache_max_nodes", [1, 1, 0, 1]),
        ("node_cache_max_bytes", [1, 1, 1, 0]),
    ] {
        assert!(matches!(
            ExecutionConfig::try_new(values[0], values[1], values[2], values[3]),
            Err(Error::InvalidExecutionConfig {
                field: found_field,
                value: 0,
            }) if found_field == field
        ));
    }
}

#[test]
fn execution_defaults_are_finite_and_nonzero() {
    let config = ExecutionConfig::default();
    assert!(config.read_parallelism().get() > 0);
    assert!(config.max_in_flight_bytes().get() > 0);
    assert!(config.node_cache_max_nodes().get() > 0);
    assert!(config.node_cache_max_bytes().get() > 0);

    let legacy_defaults = Config::default();
    assert!(legacy_defaults.runtime.node_cache_max_nodes.is_some());
    assert!(legacy_defaults.runtime.node_cache_max_bytes.is_some());
    assert!(legacy_defaults.runtime.read_parallelism > 0);
}