icydb-core 0.70.4

IcyDB — A type-safe, embedded ORM and schema system for the Internet Computer
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

//! Module: db::executor::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 grouped_runtime;
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::route) use capability::derive_execution_capabilities_for_model;
pub(in crate::db::executor::route) use capability::direction_allows_physical_fetch_hint;
pub(in crate::db) use contracts::LoadOrderRouteContract;
pub(in crate::db::executor) use contracts::*;
pub(in crate::db::executor::route) use fast_path::aggregate_force_materialized_due_to_predicate_uncertainty_with_preparation;
pub(in crate::db::executor::route) use fast_path::pk_order_stream_fast_path_shape_supported_for_model;
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 grouped_runtime::{
    grouped_plan_metrics_strategy_for_execution_strategy, grouped_route_observability_for_runtime,
};
pub(super) use guard::*;
pub(in crate::db::executor::route) use hints::{
    aggregate_probe_fetch_hint_for_model, aggregate_seek_spec_for_model,
    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::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_with_model;
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_with_model;
pub(in crate::db::executor) use planner::build_execution_route_plan_for_mutation_with_model;
pub(in crate::db::executor) use planner::build_initial_execution_route_plan_for_load_with_model;
pub(in crate::db::executor) use planner::build_initial_execution_route_plan_for_load_with_model_store_witness;
pub(in crate::db::executor) use pushdown::access_order_satisfied_by_route_contract_for_model;
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,
};
#[cfg(test)]
pub(in crate::db::executor) use terminal::derive_load_terminal_fast_path_contract_for_model;
pub(in crate::db::executor) use terminal::{
    BytesTerminalFastPathContract, CountTerminalFastPathContract, ExistsTerminalFastPathContract,
    LoadTerminalFastPathContract,
    apply_resolved_secondary_read_authority_profile_to_load_terminal_fast_path,
    derive_count_terminal_fast_path_contract_for_model,
    derive_exists_terminal_fast_path_contract_for_model,
    derive_load_terminal_fast_path_contract_for_model_plan,
};

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

#[cfg(test)]
const fn route_execution_mode_case_count_guard() -> usize {
    4
}

#[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 strategy.
    3
}