icydb-core 0.98.1

IcyDB — A schema-first typed query engine and persistence runtime for Internet Computer canisters
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

//! Module: db::executor::planning::route
//! Responsibility: derive runtime route decisions from validated executor/query inputs.
//! Does not own: logical query semantics or stream/kernel execution internals.
//! Boundary: produces one immutable execution-route contract consumed by runtime dispatch.

mod capability;
mod contracts;
mod fast_path;
mod guard;
mod hints;
mod mode;
mod planner;
mod pushdown;
mod semantics;
mod terminal;

///
/// TESTS
///

#[cfg(test)]
mod tests;

pub(in crate::db::executor) use capability::derive_budget_safety_flags_for_model;
pub(in crate::db::executor::planning::route) use capability::derive_execution_capabilities_for_model;
pub(in crate::db::executor::planning::route) use capability::direction_allows_physical_fetch_hint;
pub(in crate::db) use contracts::AggregateRouteShape;
pub use contracts::RouteExecutionMode;
pub(in crate::db::executor) use contracts::*;
pub(in crate::db) use contracts::{LoadOrderRouteContract, LoadOrderRouteReason};
pub(in crate::db::executor::planning::route) use fast_path::aggregate_force_materialized_due_to_predicate_uncertainty_with_preparation;
pub(in crate::db::executor::planning::route) use fast_path::pk_order_stream_fast_path_shape_supported;
pub(in crate::db::executor) use fast_path::try_first_verified_fast_path_hit;
pub(in crate::db::executor) use fast_path::verify_pk_stream_fast_path_access;
pub(in crate::db::executor) use guard::*;
pub(in crate::db::executor) use hints::widened_residual_predicate_pushdown_fetch;
pub(in crate::db::executor::planning::route) use hints::{
    aggregate_probe_fetch_hint, aggregate_seek_spec, assess_index_range_limit_pushdown_for_model,
    bounded_probe_hint_is_safe, count_pushdown_fetch_hint, load_scan_budget_hint,
    top_n_seek_spec_for_model,
};
pub(in crate::db::executor) use mode::{
    aggregate_non_count_streaming_allowed, load_streaming_allowed,
};
pub(in crate::db::executor::planning::route) use mode::{
    derive_aggregate_route_direction, derive_load_route_direction,
};
pub(in crate::db::executor) use planner::build_execution_route_plan_for_aggregate_spec;
pub(in crate::db::executor) use planner::build_execution_route_plan_for_grouped_plan;
pub(in crate::db::executor) use planner::build_execution_route_plan_for_load;
pub(in crate::db::executor) use planner::build_execution_route_plan_for_mutation;
pub(in crate::db::executor) use planner::build_initial_execution_route_plan_for_load;
pub(in crate::db::executor) use planner::build_initial_execution_route_plan_for_load_with_fast_path;
pub(in crate::db::executor) use pushdown::access_order_satisfied_by_route_contract;
pub(in crate::db) use pushdown::derive_secondary_pushdown_applicability_from_contract;
pub(in crate::db::executor) use pushdown::secondary_order_contract_active;
pub(in crate::db::executor) use semantics::{
    aggregate_bounded_probe_fetch_hint, aggregate_extrema_direction,
    aggregate_materialized_fold_direction, aggregate_supports_bounded_probe_hint,
};
pub(in crate::db::executor) use terminal::{
    BytesTerminalFastPathContract, CountTerminalFastPathContract, ExistsTerminalFastPathContract,
    LoadTerminalFastPathContract, derive_count_terminal_fast_path_contract_for_model,
    derive_exists_terminal_fast_path_contract_for_model,
    derive_load_terminal_fast_path_contract_for_plan,
};

#[cfg(test)]
const fn route_capability_flag_count_guard() -> usize {
    6
}

#[cfg(test)]
const fn route_shape_kind_count_guard() -> usize {
    5
}

#[cfg(test)]
const fn grouped_ordered_runtime_revalidation_flag_count_guard() -> usize {
    // Runtime grouped revalidation should stay capability-focused and consume
    // only eligibility, rejection reason, and grouped execution mode.
    3
}