1 · Find the feature
Choose the alphabetical chapter that matches the user-visible behavior.
A–Z engineering index · Release 1.0
c8 documentation
Feature-first source book
The source tree is cataloged by behavior rather than directory order, so SPARQL code stays with SPARQL, reasoning stays with reasoning and Kubernetes controller code stays with operators. Use the left index like a technical book.
13
feature chapters
47
cataloged entry points
206
functions, types & contracts
01 · reading path
Choose the alphabetical chapter that matches the user-visible behavior.
Read the file purpose, then start with the named symbols in order.
Trace imported types and JSON schemas before changing transport or persistence.
Add scalar, bounded-failure and differential evidence before enabling an optimized path.
02 · implementation map
| Language | Status | Feature benefit | Boundary |
|---|---|---|---|
| Rust | Implemented · 95 files | Memory-safe services, operators, bounded concurrency, sparse joins, Arrow/Parquet, caches and NVMe spill. | Primary trusted runtime |
| Java | Implemented · 3 sources | OWLAPI/HermiT gives exact OWL 2 DL profile, consistency and Direct-Semantics entailment behavior. | Pinned subprocess adapter |
| C++ | Planned · 0 files | Potential CSR/bitmap/SIMD acceleration for measured sparse kernels after differential qualification. | Not active; no current product claim |
03 · repository verdict
The repository defines the namespaced NgkgCompilation CRD, watches it with kube_runtime::Controller, reconciles desired state, creates deterministic Jobs and patches observed status.
Helm installs CRDs, RBAC, controllers, API services and worker deployments. After installation, the Rust controllers—not Helm—continuously reconcile NgkgCompilation resources and compilation work. That makes c8 an operator-based application distributed through Helm.
04 · feature chapter
Public dataset, source, ingestion, snapshot, SPARQL, reasoning and physical-retrieval surfaces.
services/api/src/main.rsRustControl-plane HTTP service for datasets, raw TriG uploads, asynchronous compilation jobs and snapshot publication.
| Function / symbol | What it does |
|---|---|
create_dataset | Creates dataset using this file’s validated, bounded subsystem rules. |
upload_trig_source | Uploads trig source using this file’s validated, bounded subsystem rules. |
inspect_trig | Inspects trig using this file’s validated, bounded subsystem rules. |
create_ingestion | Creates ingestion using this file’s validated, bounded subsystem rules. |
get_job | Reads job using this file’s validated, bounded subsystem rules. |
cancel_job | Cancels job using this file’s validated, bounded subsystem rules. |
get_snapshot | Reads snapshot using this file’s validated, bounded subsystem rules. |
publish_snapshot | Atomically changes the active snapshot only when the expected predecessor and certification state match. |
services/online-serving/src/main.rsRustServing-plane routes for SPARQL Protocol, c8 JSON queries, Direct-Semantics validation/routing, locator lookup and hydration.
| Function / symbol | What it does |
|---|---|
sparql_get | Handles get using this file’s validated, bounded subsystem rules. |
sparql_post | Handles post using this file’s validated, bounded subsystem rules. |
sparql_service_description | Handles service description using this file’s validated, bounded subsystem rules. |
execute_sparql_protocol | Applies SPARQL Protocol dataset and content-negotiation rules, then coordinates query execution. |
query | Implements query using this file’s validated, bounded subsystem rules. |
locate | Implements locate using this file’s validated, bounded subsystem rules. |
hydrate | Hydrates hydrate using this file’s validated, bounded subsystem rules. |
This candidate exposes 32 explicit REST operations plus two Swagger asset handlers. Ingestion is polled through the jobs route; there are no callbacks or webhooks.
05 · feature chapter
Checksum-bound object-store materialization, immutable snapshot identity and compare-and-swap publication.
crates/ngkg-artifact-store/src/lib.rsRustFetches and publishes immutable artifacts while enforcing declared digests and resource budgets.
| Function / symbol | What it does |
|---|---|
from_base_url | Implements base url using this file’s validated, bounded subsystem rules. |
materialize_verified | Materializes verified using this file’s validated, bounded subsystem rules. |
materialize_verified_with_budget | Materializes verified with budget using this file’s validated, bounded subsystem rules. |
put_file_immutable | Implements file immutable using this file’s validated, bounded subsystem rules. |
crates/ngkg-snapshot/src/lib.rsRustValidates serving manifests and activates qualified snapshots without mutating prior versions.
| Function / symbol | What it does |
|---|---|
validate_manifest | Validates manifest using this file’s validated, bounded subsystem rules. |
publish | Publishes a qualified immutable snapshot through compare-and-swap activation. |
crates/ngkg-distributed-artifacts/src/lib.rsRustBuilds and finalizes partitioned Arrow/Parquet and catalog artifacts, then compares independent roots.
| Function / symbol | What it does |
|---|---|
materialize_artifact_partition | Materializes artifact partition using this file’s validated, bounded subsystem rules. |
finalize_artifact_partitions | Finalizes artifact partitions using this file’s validated, bounded subsystem rules. |
finalize_catalog_artifact_partitions | Finalizes catalog artifact partitions using this file’s validated, bounded subsystem rules. |
compare_artifact_roots | Compares artifact roots using this file’s validated, bounded subsystem rules. |
06 · feature chapter
Durable control-plane truth, deterministic entity identity and collision-safe dictionary construction.
crates/ngkg-catalog/src/lib.rsRustOwns dataset, compilation, distributed-plan, work-completion, certification and active-snapshot records in PostgreSQL.
| Function / symbol | What it does |
|---|---|
create_dataset | Creates dataset using this file’s validated, bounded subsystem rules. |
create_or_get_compilation | Creates or get compilation using this file’s validated, bounded subsystem rules. |
register_distributed_plan | Registers distributed plan using this file’s validated, bounded subsystem rules. |
commit_distributed_work | Commits distributed work using this file’s validated, bounded subsystem rules. |
commit_serving_root | Commits serving root using this file’s validated, bounded subsystem rules. |
get_active_serving_snapshot | Reads active serving snapshot using this file’s validated, bounded subsystem rules. |
publish_snapshot | Atomically changes the active snapshot only when the expected predecessor and certification state match. |
crates/ngkg-identity/src/lib.rsRustDerives stable GUIDs and fact identities from canonical IRIs and merges deterministic dictionary runs.
| Function / symbol | What it does |
|---|---|
guid_for_canonical_iri | Derives for canonical iri using this file’s validated, bounded subsystem rules. |
skolem_iri | Derives iri using this file’s validated, bounded subsystem rules. |
fact_identity | Builds identity using this file’s validated, bounded subsystem rules. |
verify_fact_collision | Verifies fact collision using this file’s validated, bounded subsystem rules. |
merge_dictionary_runs | Merges dictionary runs using this file’s validated, bounded subsystem rules. |
07 · feature chapter
Named-graph catalogs, graph roles, visibility labels and authorized active-dataset assembly.
crates/ngkg-dataset/src/lib.rsRustCompiles graph catalogs, resolves service datasets and restricts them to admitted roles before planning or reasoning.
| Function / symbol | What it does |
|---|---|
compile_catalog | Compiles catalog using this file’s validated, bounded subsystem rules. |
resolve_dataset | Resolves dataset using this file’s validated, bounded subsystem rules. |
validate_resolved_dataset | Validates resolved dataset using this file’s validated, bounded subsystem rules. |
restrict_resolved_dataset_to_roles | Restricts resolved dataset to roles using this file’s validated, bounded subsystem rules. |
valid_authorization_label | Checks authorization label using this file’s validated, bounded subsystem rules. |
services/online-serving/src/main.rsRustApplies tenant admission and graph authorization before computing the active graph-set and dataset hashes.
| Function / symbol | What it does |
|---|---|
authorize_request | Implements request using this file’s validated, bounded subsystem rules. |
resolve_authorized_dataset | Resolves authorized dataset using this file’s validated, bounded subsystem rules. |
validate_active_snapshot | Validates active snapshot using this file’s validated, bounded subsystem rules. |
08 · feature chapter
Bounded, restartable TriG scanning and partition work for compilation and physical artifact creation.
crates/ngkg-distributed-build/src/lib.rsRustScans TriG under ceilings, projects stable partitions, reduces runs and compares independently computed roots.
| Function / symbol | What it does |
|---|---|
safe_scan_trig | Safely scans scan trig using this file’s validated, bounded subsystem rules. |
project_partition | Projects partition using this file’s validated, bounded subsystem rules. |
reduce_projection_runs | Reduces projection runs using this file’s validated, bounded subsystem rules. |
finalize_reducers | Finalizes reducers using this file’s validated, bounded subsystem rules. |
compare_roots | Compares roots using this file’s validated, bounded subsystem rules. |
services/distributed-worker/src/main.rsRustWorker binary that executes locator, artifact, scan, projection, reduce, finalize and comparison work items.
| Function / symbol | What it does |
|---|---|
compile_locator | Compiles locator using this file’s validated, bounded subsystem rules. |
materialize_artifacts | Materializes artifacts using this file’s validated, bounded subsystem rules. |
safe_scan | Safely scans scan using this file’s validated, bounded subsystem rules. |
project | Projects project using this file’s validated, bounded subsystem rules. |
reduce | Reduces reduce using this file’s validated, bounded subsystem rules. |
finalize | Finalizes finalize using this file’s validated, bounded subsystem rules. |
compare | Compares compare using this file’s validated, bounded subsystem rules. |
services/distributed-worker/src/object_stage.rsRustPlans and executes object-store-backed stages through artifact and serving-root preparation.
| Function / symbol | What it does |
|---|---|
plan | Plans plan using this file’s validated, bounded subsystem rules. |
project | Projects project using this file’s validated, bounded subsystem rules. |
reduce | Reduces reduce using this file’s validated, bounded subsystem rules. |
finalize | Finalizes finalize using this file’s validated, bounded subsystem rules. |
prepare_artifacts | Prepares artifacts using this file’s validated, bounded subsystem rules. |
materialize_artifact_object_store | Materializes artifact object store using this file’s validated, bounded subsystem rules. |
prepare_serving_root_object_store | Prepares serving root object store using this file’s validated, bounded subsystem rules. |
09 · feature chapter
Whole-core budgets, bounded Rust concurrency, Grace hash joins and NVMe-backed spill accounting.
crates/ngkg-hpc-runtime/src/lib.rsRustValidates runtime thread budgets and reports node capabilities against workload saturation targets.
| Function / symbol | What it does |
|---|---|
node_saturation_target | Implements saturation target using this file’s validated, bounded subsystem rules. |
validate_thread_budget | Validates thread budget using this file’s validated, bounded subsystem rules. |
capability_report | Implements report using this file’s validated, bounded subsystem rules. |
crates/ngkg-grace-join/src/lib.rsRustRuns bounded Grace hash joins with streaming inputs and observable spill usage.
| Function / symbol | What it does |
|---|---|
open | Opens open using this file’s validated, bounded subsystem rules. |
join | Joins join using this file’s validated, bounded subsystem rules. |
join_stream | Joins stream using this file’s validated, bounded subsystem rules. |
active_spill_bytes | Implements spill bytes using this file’s validated, bounded subsystem rules. |
crates/ngkg-shuffle-cache/src/lib.rsRustCaches checksum-addressed shuffle objects with bounded usage and invalidation.
| Function / symbol | What it does |
|---|---|
digest | Computes the digest for digest using this file’s validated, bounded subsystem rules. |
open | Opens open using this file’s validated, bounded subsystem rules. |
get | Reads get using this file’s validated, bounded subsystem rules. |
insert | Inserts insert using this file’s validated, bounded subsystem rules. |
invalidate | Invalidates invalidate using this file’s validated, bounded subsystem rules. |
usage | Reports usage for usage using this file’s validated, bounded subsystem rules. |
10 · feature chapter
Turns semantic GUID results into bounded physical Parquet reads without weakening graph authorization.
crates/ngkg-locator/src/lib.rsRustCompiles and queries sharded GUID-to-Parquet locator indexes and coalesces safe byte ranges.
| Function / symbol | What it does |
|---|---|
compile_sharded_locator | Compiles sharded locator using this file’s validated, bounded subsystem rules. |
open | Opens open using this file’s validated, bounded subsystem rules. |
lookup | Implements lookup using this file’s validated, bounded subsystem rules. |
validate | Validates validate using this file’s validated, bounded subsystem rules. |
owner_for | Selects the owner for for using this file’s validated, bounded subsystem rules. |
coalesce_ranges | Coalesces ranges using this file’s validated, bounded subsystem rules. |
crates/ngkg-hydration/src/lib.rsRustPlans and performs graph-filtered payload hydration after verifying every referenced shard.
| Function / symbol | What it does |
|---|---|
verify_payload_shard | Verifies payload shard using this file’s validated, bounded subsystem rules. |
plan_hydration | Plans hydration using this file’s validated, bounded subsystem rules. |
hydrate_sharded_payload | Hydrates sharded payload using this file’s validated, bounded subsystem rules. |
hydrate_sharded_payload_for_graphs | Hydrates sharded payload for graphs using this file’s validated, bounded subsystem rules. |
truncate_optional_context | Bounds optional context using this file’s validated, bounded subsystem rules. |
crates/ngkg-index/src/lib.rsRustOpens physical indexes only after integrity checks succeed.
| Function / symbol | What it does |
|---|---|
verify_open | Verifies open using this file’s validated, bounded subsystem rules. |
11 · feature chapter
CRD state machines, phase barriers, dedicated worker pools and workload ownership for RKE2/Kubernetes.
crates/ngkg-kube/src/lib.rsRustDefines the namespaced ngkg.io/v1alpha1 NgkgCompilation custom resource shared by the API and both controllers.
| Function / symbol | What it does |
|---|---|
NgkgCompilation | Defines the NgkgCompilation type or Kubernetes/API contract used by this feature. |
NgkgCompilationSpec | Defines the NgkgCompilationSpec type or Kubernetes/API contract used by this feature. |
NgkgCompilationStatus | Defines the NgkgCompilationStatus type or Kubernetes/API contract used by this feature. |
crates/ngkg-operator-core/src/lib.rsRustPure reconciliation decisions and Phase 40 resource ceilings used by the controllers.
| Function / symbol | What it does |
|---|---|
next_action | Maps a validated stage observation to the next legal compilation action; incomplete or corrupt barriers return an error. |
Phase40Ceilings | Defines the Phase40Ceilings type or Kubernetes/API contract used by this feature. |
services/distributed-operator/src/main.rsRustSchedules distributed stages, enforces completion barriers and reconciles worker-job state.
| Function / symbol | What it does |
|---|---|
main | Bootstraps the process, loads trusted configuration and starts the service or controller runtime. |
reconcile | Compares desired NgkgCompilation state with durable catalog truth and selects the next idempotent action. |
reconcile_artifact_barrier | Advances artifact stages only after the catalog proves every expected partition and root is complete. |
schedule_stage | Builds and submits the indexed Job for one distributed compilation stage with bounded parallelism. |
ensure_job | Creates the deterministic Kubernetes Job when absent and verifies an existing Job before reusing it. |
patch_status | Writes concise, non-sensitive observed state back to the custom resource status subresource. |
services/operator/src/main.rsRustCoordinates reference compilation and top-level compilation lifecycle.
| Function / symbol | What it does |
|---|---|
main | Bootstraps the process, loads trusted configuration and starts the service or controller runtime. |
reconcile | Compares desired NgkgCompilation state with durable catalog truth and selects the next idempotent action. |
ensure_reference_job | Creates or validates the reference compilation Job for the current immutable compilation identity. |
reference_job | Builds the reference-worker Kubernetes Job specification, including resources, trusted inputs and ceiling identities. |
patch_status | Writes concise, non-sensitive observed state back to the custom resource status subresource. |
charts/ngkg-workloads/Helm / YAMLDeploys dedicated query, fragment, locator, hydration and reasoner roles with HPAs, affinity and policy.
| Function / symbol | What it does |
|---|---|
values.schema.json | Configuration or contract surface reviewed alongside the executable code in this feature. |
templates/ | Configuration or contract surface reviewed alongside the executable code in this feature. |
HPAs | Defines the HPAs type or Kubernetes/API contract used by this feature. |
NetworkPolicies | Defines the NetworkPolicies type or Kubernetes/API contract used by this feature. |
12 · feature chapter
Direct-Semantics legality, authorized ontology assembly, HermiT execution, proof binding and complete partition merging.
crates/ngkg-owl-direct/src/lib.rsRustExtracts candidate OWL Direct-Semantics BGP templates and classifies legal graph patterns.
| Function / symbol | What it does |
|---|---|
extract_direct_bgp_template | Extracts direct BGP template using this file’s validated, bounded subsystem rules. |
classify_direct_bgps | Classifies direct BGPs using this file’s validated, bounded subsystem rules. |
crates/ngkg-online-reasoning/src/lib.rsRustSelects authorized semkg modules, builds reasoner partitions, retries dispatch and rejects incomplete result sets.
| Function / symbol | What it does |
|---|---|
select_authorized_asserted_modules | Selects only authorized named graphs with the semkg role for exact ontology assembly. |
validate_ontology_snapshot_binding | Validates ontology snapshot binding using this file’s validated, bounded subsystem rules. |
build_distributed_reasoner_plan | Partitions an exact Direct-BGP candidate space into deterministic, bounded reasoner work. |
dispatch_exact_partitions_with_retry | Sends exact reasoner partitions with bounded retry while preserving work identity and duplicate safety. |
complete_distributed_exact_bgp | Accepts an exact answer only after every expected reasoner partition and certificate validates. |
crates/ngkg-direct-reasoner/src/lib.rsRustBuilds, executes and merges exact Direct-BGP partition requests with deterministic request-set identity.
| Function / symbol | What it does |
|---|---|
execute_exact_direct_bgp | Runs the complete exact OWL Direct-Semantics Basic Graph Pattern workflow. |
prepare_exact_direct_bgp_requests | Prepares exact direct BGP requests using this file’s validated, bounded subsystem rules. |
execute_exact_direct_partition | Executes exact direct partition using this file’s validated, bounded subsystem rules. |
merge_partition_results | Merges partition results using this file’s validated, bounded subsystem rules. |
direct_exact_request_set_sha256 | Implements exact request set SHA-256 using this file’s validated, bounded subsystem rules. |
crates/ngkg-reasoner-client/src/lib.rsRustValidates legality, result, certificate and proof bindings before accepting reasoner output.
| Function / symbol | What it does |
|---|---|
require_legal_direct_bgp | Requires legal direct BGP using this file’s validated, bounded subsystem rules. |
reason | Runs reasoning for reason using this file’s validated, bounded subsystem rules. |
decide_coverage | Chooses coverage using this file’s validated, bounded subsystem rules. |
crates/ngkg-reference/src/direct_exact.rsRustAssembles the active exact ontology only from authorized */semkg graphs and pinned imports.
| Function / symbol | What it does |
|---|---|
build_direct_active_ontology_bundle | Builds direct active ontology bundle using this file’s validated, bounded subsystem rules. |
crates/ngkg-reference/src/reasoner.rsRustInvokes the checksum-pinned HermiT adapter under bounded execution rules.
| Function / symbol | What it does |
|---|---|
invoke_reasoner | Launches the checksum-pinned Java/HermiT adapter under trusted time, memory and filesystem limits. |
adapters/hermit-reasoner/src/main/java/io/ngkg/reasoner/DirectBgpExecutor.javaJavaExecutes OWLAPI/HermiT Direct-BGP requests and emits bounded exact evidence.
| Function / symbol | What it does |
|---|---|
execute | Executes execute using this file’s validated, bounded subsystem rules. |
renderResults | Implements renderResults using this file’s validated, bounded subsystem rules. |
renderProofSupport | Implements renderProofSupport using this file’s validated, bounded subsystem rules. |
13 · feature chapter
Exact NFA traversal state, origin-preserving frontiers, partition ownership, checkpoints and termination.
crates/ngkg-query-executor/src/distributed_path.rsRustSeeds, partitions and expands path frontiers; validates complete iterations and atomic resume checkpoints.
| Function / symbol | What it does |
|---|---|
seed_path_frontier | Creates origin-preserving initial states for a distributed property-path traversal. |
path_partition_owner | Computes partition owner using this file’s validated, bounded subsystem rules. |
path_expansion_work_items | Computes expansion work items using this file’s validated, bounded subsystem rules. |
expand_path_work_item | Expands one deterministic adjacency range through the property-path automaton. |
complete_path_iteration | Merges and deduplicates a complete frontier iteration before allowing traversal to advance. |
build_path_checkpoint | Builds path checkpoint using this file’s validated, bounded subsystem rules. |
validate_path_checkpoint | Verifies checkpoint identity, bounds and checksums before a traversal resumes. |
The kernel and contracts are present. Live adjacency retrieval and endpoint activation still require Phase 40.13.9 integration and differential qualification.
crates/ngkg-sparql-compiler/src/lib.rsRustCompiles SPARQL path expressions into exact distributed property-path plans.
| Function / symbol | What it does |
|---|---|
distributed_property_path_plans | Implements property path plans using this file’s validated, bounded subsystem rules. |
14 · feature chapter
Scalar correctness path, semantic compilation, expected-result verification and differential gates.
crates/ngkg-reference/src/query.rsRustBuilds the standards-correct scalar store, executes compiled queries and canonicalizes results for comparison.
| Function / symbol | What it does |
|---|---|
build_store | Builds store using this file’s validated, bounded subsystem rules. |
build_store_with_dataset_policy | Builds store with dataset policy using this file’s validated, bounded subsystem rules. |
execute_compiled_query | Executes compiled query using this file’s validated, bounded subsystem rules. |
canonical_result_hash | Hashes the canonical scalar result so optimized and reference answers can be compared byte-independently. |
verify_bindings | Verifies bindings using this file’s validated, bounded subsystem rules. |
load_rdf_fixture | Loads rdf fixture using this file’s validated, bounded subsystem rules. |
crates/ngkg-reference/src/compiler.rsRustCompiles source manifests into semantic catalogs and certifies representative query behavior.
| Function / symbol | What it does |
|---|---|
compile_from_manifest | Compiles from manifest using this file’s validated, bounded subsystem rules. |
validate_graph_catalog | Validates graph catalog using this file’s validated, bounded subsystem rules. |
write_semantic_capabilities | Writes semantic capabilities using this file’s validated, bounded subsystem rules. |
certify_queries | Certifies queries using this file’s validated, bounded subsystem rules. |
crates/ngkg-reference/src/rdf.rsRustParses TriG/N-Quads, normalizes facts and enforces the RDF/datatype policy.
| Function / symbol | What it does |
|---|---|
parse_trig | Parses trig using this file’s validated, bounded subsystem rules. |
parse_nquads | Parses nquads using this file’s validated, bounded subsystem rules. |
normalized_facts | Normalizes facts using this file’s validated, bounded subsystem rules. |
nquad_line | Renders line using this file’s validated, bounded subsystem rules. |
ntriple_line | Renders line using this file’s validated, bounded subsystem rules. |
services/reference-worker/src/object_compile.rsRustRuns object-store-backed reference attempts, uploads artifacts and certifies sharded hydration.
| Function / symbol | What it does |
|---|---|
compile_object_store | Compiles object store using this file’s validated, bounded subsystem rules. |
run_attempt | Implements attempt using this file’s validated, bounded subsystem rules. |
certify_sharded_hydration | Certifies sharded hydration using this file’s validated, bounded subsystem rules. |
upload_snapshot | Uploads snapshot using this file’s validated, bounded subsystem rules. |
15 · feature chapter
Parsing, canonical algebra, graph fragments, bounded partition operators and scalar differential comparison.
crates/ngkg-sparql-compiler/src/lib.rsRustParses SPARQL, applies base IRIs, requires certifiable constructs and emits canonical or distributed plans.
| Function / symbol | What it does |
|---|---|
parse | Parses SPARQL into typed internal syntax using the standards-correct compiler path. |
parse_with_base_iri | Parses SPARQL while resolving relative IRIs against the caller-supplied base IRI. |
require_certifiable | Rejects query constructs whose current execution path cannot produce the required correctness evidence. |
canonical_sse | Serializes canonical SPARQL algebra for deterministic plan identity and differential comparison. |
distributed_graph_fragments | Implements graph fragments using this file’s validated, bounded subsystem rules. |
distributed_algebra_plan | Compiles canonical SPARQL algebra into a typed, checksum-bound distributed stage DAG. |
crates/ngkg-query-planner/src/lib.rsRustValidates typed distributed plans, computes execution waves, routes relevant graphs and chooses exchanges.
| Function / symbol | What it does |
|---|---|
validate_distributed_algebra_plan | Validates distributed algebra plan using this file’s validated, bounded subsystem rules. |
algebra_execution_waves | Implements execution waves using this file’s validated, bounded subsystem rules. |
route_relevant_graphs | Routes relevant graphs using this file’s validated, bounded subsystem rules. |
choose_exchange | Chooses exchange using this file’s validated, bounded subsystem rules. |
crates/ngkg-query-executor/src/lib.rsRustReads/writes Arrow streams and implements stable partition ownership, exact semijoins, joins, projection and frontier utilities.
| Function / symbol | What it does |
|---|---|
read_arrow_stream | Reads arrow stream using this file’s validated, bounded subsystem rules. |
write_arrow_stream | Writes arrow stream using this file’s validated, bounded subsystem rules. |
partition_rows | Partitions rows using this file’s validated, bounded subsystem rules. |
exact_semijoin | Implements semijoin using this file’s validated, bounded subsystem rules. |
inner_join | Executes join using this file’s validated, bounded subsystem rules. |
project_sparql_json | Projects SPARQL json using this file’s validated, bounded subsystem rules. |
next_frontier | Builds frontier using this file’s validated, bounded subsystem rules. |
crates/ngkg-query-executor/src/distributed_algebra.rsRustImplements native UNION, OPTIONAL/left join, MINUS, DISTINCT, grouping, ordered merge and global slicing under complete-partition barriers.
| Function / symbol | What it does |
|---|---|
execute_native_algebra_task | Executes a bounded native distributed-algebra stage only for operators admitted to the safe lane. |
union_sparql_json | Unions SPARQL json using this file’s validated, bounded subsystem rules. |
left_join_sparql_json | Executes join SPARQL json using this file’s validated, bounded subsystem rules. |
minus_sparql_json | Subtracts SPARQL json using this file’s validated, bounded subsystem rules. |
distinct_sparql_json | Deduplicates SPARQL json using this file’s validated, bounded subsystem rules. |
group_owned_partitions | Groups owned partitions using this file’s validated, bounded subsystem rules. |
merge_ordered_partitions_by | Merges ordered partitions by using this file’s validated, bounded subsystem rules. |
global_slice_sparql_json | Applies slice SPARQL json using this file’s validated, bounded subsystem rules. |
The normal endpoint retains the scalar correctness path until every optimized operator is transported to workers and passes its differential gate.
services/online-serving/src/main.rsRustCoordinates protocol parsing, scalar execution, exact reasoning and the distributed evidence lane.
| Function / symbol | What it does |
|---|---|
execute_sparql_protocol | Applies SPARQL Protocol dataset and content-negotiation rules, then coordinates query execution. |
execute_distributed_query | Coordinates the evidence-bound distributed query lane and requires all planned work to complete. |
execute_fragment | Executes fragment using this file’s validated, bounded subsystem rules. |
execute_partitioned_shuffle | Executes partitioned shuffle using this file’s validated, bounded subsystem rules. |
execute_uncertified_exact_query | Routes an uncovered semantic request through the exact scalar/HermiT correctness boundary instead of guessing. |
crates/ngkg-query-cache/src/lib.rsRustStores deterministic query results under snapshot-, graph-set- and plan-bound cache keys.
| Function / symbol | What it does |
|---|---|
digest | Computes the digest for digest using this file’s validated, bounded subsystem rules. |
open | Opens open using this file’s validated, bounded subsystem rules. |
get | Reads get using this file’s validated, bounded subsystem rules. |
insert | Inserts insert using this file’s validated, bounded subsystem rules. |
invalidate | Invalidates invalidate using this file’s validated, bounded subsystem rules. |
usage | Reports usage for usage using this file’s validated, bounded subsystem rules. |
16 · feature chapter
Typed requests, plans, certificates, proofs and manifests that bind every result to inputs and completeness evidence.
crates/ngkg-types/src/direct_bgp.rsRustDefines and validates normalized Direct-BGP result envelopes.
| Function / symbol | What it does |
|---|---|
validate_result | Validates result using this file’s validated, bounded subsystem rules. |
crates/ngkg-types/src/direct_certificate.rsRustValidates exact certificates, result hashes and snapshot/graph bindings.
| Function / symbol | What it does |
|---|---|
validate_certificate | Validates certificate using this file’s validated, bounded subsystem rules. |
validate_result_hash | Validates result hash using this file’s validated, bounded subsystem rules. |
crates/ngkg-types/src/direct_exact.rsRustDefines exact requests and partition results with integrity validation.
| Function / symbol | What it does |
|---|---|
validate_exact_request | Validates exact request using this file’s validated, bounded subsystem rules. |
validate_partition_result | Validates partition result using this file’s validated, bounded subsystem rules. |
crates/ngkg-types/src/direct_proof.rsRustBuilds support identities and validates proof manifests and bundles.
| Function / symbol | What it does |
|---|---|
support_id | Computes id using this file’s validated, bounded subsystem rules. |
support_hash | Computes hash using this file’s validated, bounded subsystem rules. |
validate_manifest | Validates manifest using this file’s validated, bounded subsystem rules. |
validate_bundle | Validates bundle using this file’s validated, bounded subsystem rules. |
contracts/JSON SchemaVersioned JSON Schemas for graph catalogs, distributed plans, snapshots, Direct-BGP evidence and serving roots.
| Function / symbol | What it does |
|---|---|
graph-catalog | Implements graph-catalog using this file’s validated, bounded subsystem rules. |
direct-bgp | Implements direct-BGP using this file’s validated, bounded subsystem rules. |
direct-proof | Implements direct-proof using this file’s validated, bounded subsystem rules. |
distributed-* | Implements distributed-* using this file’s validated, bounded subsystem rules. |
serving-root | Implements serving-root using this file’s validated, bounded subsystem rules. |