c8 documentation

Code file & function catalog

Feature-first source book

Every important file. Every entry point. What it does.

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

Trace behavior from route to evidence

1 · Find the feature

Choose the alphabetical chapter that matches the user-visible behavior.

2 · Open the file

Read the file purpose, then start with the named symbols in order.

3 · Follow contracts

Trace imported types and JSON schemas before changing transport or persistence.

4 · Prove the invariant

Add scalar, bounded-failure and differential evidence before enabling an optimized path.

02 · implementation map

Current code versus the native acceleration boundary

LanguageStatusFeature benefitBoundary
RustImplemented · 95 filesMemory-safe services, operators, bounded concurrency, sparse joins, Arrow/Parquet, caches and NVMe spill.Primary trusted runtime
JavaImplemented · 3 sourcesOWLAPI/HermiT gives exact OWL 2 DL profile, consistency and Direct-Semantics entailment behavior.Pinned subprocess adapter
C++Planned · 0 filesPotential CSR/bitmap/SIMD acceleration for measured sparse kernels after differential qualification.Not active; no current product claim

03 · repository verdict

Yes: c8 contains Kubernetes operators

Operator criteria satisfied

The repository defines the namespaced NgkgCompilation CRD, watches it with kube_runtime::Controller, reconciles desired state, creates deterministic Jobs and patches observed status.

Helm and operator are different layers

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

API & protocols

Public dataset, source, ingestion, snapshot, SPARQL, reasoning and physical-retrieval surfaces.

services/api/src/main.rsRust

Control-plane HTTP service for datasets, raw TriG uploads, asynchronous compilation jobs and snapshot publication.

Function / symbolWhat it does
create_datasetCreates dataset using this file’s validated, bounded subsystem rules.
upload_trig_sourceUploads trig source using this file’s validated, bounded subsystem rules.
inspect_trigInspects trig using this file’s validated, bounded subsystem rules.
create_ingestionCreates ingestion using this file’s validated, bounded subsystem rules.
get_jobReads job using this file’s validated, bounded subsystem rules.
cancel_jobCancels job using this file’s validated, bounded subsystem rules.
get_snapshotReads snapshot using this file’s validated, bounded subsystem rules.
publish_snapshotAtomically changes the active snapshot only when the expected predecessor and certification state match.
services/online-serving/src/main.rsRust

Serving-plane routes for SPARQL Protocol, c8 JSON queries, Direct-Semantics validation/routing, locator lookup and hydration.

Function / symbolWhat it does
sparql_getHandles get using this file’s validated, bounded subsystem rules.
sparql_postHandles post using this file’s validated, bounded subsystem rules.
sparql_service_descriptionHandles service description using this file’s validated, bounded subsystem rules.
execute_sparql_protocolApplies SPARQL Protocol dataset and content-negotiation rules, then coordinates query execution.
queryImplements query using this file’s validated, bounded subsystem rules.
locateImplements locate using this file’s validated, bounded subsystem rules.
hydrateHydrates 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

Artifacts & snapshots

Checksum-bound object-store materialization, immutable snapshot identity and compare-and-swap publication.

crates/ngkg-artifact-store/src/lib.rsRust

Fetches and publishes immutable artifacts while enforcing declared digests and resource budgets.

Function / symbolWhat it does
from_base_urlImplements base url using this file’s validated, bounded subsystem rules.
materialize_verifiedMaterializes verified using this file’s validated, bounded subsystem rules.
materialize_verified_with_budgetMaterializes verified with budget using this file’s validated, bounded subsystem rules.
put_file_immutableImplements file immutable using this file’s validated, bounded subsystem rules.
crates/ngkg-snapshot/src/lib.rsRust

Validates serving manifests and activates qualified snapshots without mutating prior versions.

Function / symbolWhat it does
validate_manifestValidates manifest using this file’s validated, bounded subsystem rules.
publishPublishes a qualified immutable snapshot through compare-and-swap activation.
crates/ngkg-distributed-artifacts/src/lib.rsRust

Builds and finalizes partitioned Arrow/Parquet and catalog artifacts, then compares independent roots.

Function / symbolWhat it does
materialize_artifact_partitionMaterializes artifact partition using this file’s validated, bounded subsystem rules.
finalize_artifact_partitionsFinalizes artifact partitions using this file’s validated, bounded subsystem rules.
finalize_catalog_artifact_partitionsFinalizes catalog artifact partitions using this file’s validated, bounded subsystem rules.
compare_artifact_rootsCompares artifact roots using this file’s validated, bounded subsystem rules.

06 · feature chapter

Catalog & identity

Durable control-plane truth, deterministic entity identity and collision-safe dictionary construction.

crates/ngkg-catalog/src/lib.rsRust

Owns dataset, compilation, distributed-plan, work-completion, certification and active-snapshot records in PostgreSQL.

Function / symbolWhat it does
create_datasetCreates dataset using this file’s validated, bounded subsystem rules.
create_or_get_compilationCreates or get compilation using this file’s validated, bounded subsystem rules.
register_distributed_planRegisters distributed plan using this file’s validated, bounded subsystem rules.
commit_distributed_workCommits distributed work using this file’s validated, bounded subsystem rules.
commit_serving_rootCommits serving root using this file’s validated, bounded subsystem rules.
get_active_serving_snapshotReads active serving snapshot using this file’s validated, bounded subsystem rules.
publish_snapshotAtomically changes the active snapshot only when the expected predecessor and certification state match.
crates/ngkg-identity/src/lib.rsRust

Derives stable GUIDs and fact identities from canonical IRIs and merges deterministic dictionary runs.

Function / symbolWhat it does
guid_for_canonical_iriDerives for canonical iri using this file’s validated, bounded subsystem rules.
skolem_iriDerives iri using this file’s validated, bounded subsystem rules.
fact_identityBuilds identity using this file’s validated, bounded subsystem rules.
verify_fact_collisionVerifies fact collision using this file’s validated, bounded subsystem rules.
merge_dictionary_runsMerges dictionary runs using this file’s validated, bounded subsystem rules.

07 · feature chapter

Dataset & authorization

Named-graph catalogs, graph roles, visibility labels and authorized active-dataset assembly.

crates/ngkg-dataset/src/lib.rsRust

Compiles graph catalogs, resolves service datasets and restricts them to admitted roles before planning or reasoning.

Function / symbolWhat it does
compile_catalogCompiles catalog using this file’s validated, bounded subsystem rules.
resolve_datasetResolves dataset using this file’s validated, bounded subsystem rules.
validate_resolved_datasetValidates resolved dataset using this file’s validated, bounded subsystem rules.
restrict_resolved_dataset_to_rolesRestricts resolved dataset to roles using this file’s validated, bounded subsystem rules.
valid_authorization_labelChecks authorization label using this file’s validated, bounded subsystem rules.
services/online-serving/src/main.rsRust

Applies tenant admission and graph authorization before computing the active graph-set and dataset hashes.

Function / symbolWhat it does
authorize_requestImplements request using this file’s validated, bounded subsystem rules.
resolve_authorized_datasetResolves authorized dataset using this file’s validated, bounded subsystem rules.
validate_active_snapshotValidates active snapshot using this file’s validated, bounded subsystem rules.

08 · feature chapter

Distributed build

Bounded, restartable TriG scanning and partition work for compilation and physical artifact creation.

crates/ngkg-distributed-build/src/lib.rsRust

Scans TriG under ceilings, projects stable partitions, reduces runs and compares independently computed roots.

Function / symbolWhat it does
safe_scan_trigSafely scans scan trig using this file’s validated, bounded subsystem rules.
project_partitionProjects partition using this file’s validated, bounded subsystem rules.
reduce_projection_runsReduces projection runs using this file’s validated, bounded subsystem rules.
finalize_reducersFinalizes reducers using this file’s validated, bounded subsystem rules.
compare_rootsCompares roots using this file’s validated, bounded subsystem rules.
services/distributed-worker/src/main.rsRust

Worker binary that executes locator, artifact, scan, projection, reduce, finalize and comparison work items.

Function / symbolWhat it does
compile_locatorCompiles locator using this file’s validated, bounded subsystem rules.
materialize_artifactsMaterializes artifacts using this file’s validated, bounded subsystem rules.
safe_scanSafely scans scan using this file’s validated, bounded subsystem rules.
projectProjects project using this file’s validated, bounded subsystem rules.
reduceReduces reduce using this file’s validated, bounded subsystem rules.
finalizeFinalizes finalize using this file’s validated, bounded subsystem rules.
compareCompares compare using this file’s validated, bounded subsystem rules.
services/distributed-worker/src/object_stage.rsRust

Plans and executes object-store-backed stages through artifact and serving-root preparation.

Function / symbolWhat it does
planPlans plan using this file’s validated, bounded subsystem rules.
projectProjects project using this file’s validated, bounded subsystem rules.
reduceReduces reduce using this file’s validated, bounded subsystem rules.
finalizeFinalizes finalize using this file’s validated, bounded subsystem rules.
prepare_artifactsPrepares artifacts using this file’s validated, bounded subsystem rules.
materialize_artifact_object_storeMaterializes artifact object store using this file’s validated, bounded subsystem rules.
prepare_serving_root_object_storePrepares serving root object store using this file’s validated, bounded subsystem rules.

09 · feature chapter

HPC, joins & spill

Whole-core budgets, bounded Rust concurrency, Grace hash joins and NVMe-backed spill accounting.

crates/ngkg-hpc-runtime/src/lib.rsRust

Validates runtime thread budgets and reports node capabilities against workload saturation targets.

Function / symbolWhat it does
node_saturation_targetImplements saturation target using this file’s validated, bounded subsystem rules.
validate_thread_budgetValidates thread budget using this file’s validated, bounded subsystem rules.
capability_reportImplements report using this file’s validated, bounded subsystem rules.
crates/ngkg-grace-join/src/lib.rsRust

Runs bounded Grace hash joins with streaming inputs and observable spill usage.

Function / symbolWhat it does
openOpens open using this file’s validated, bounded subsystem rules.
joinJoins join using this file’s validated, bounded subsystem rules.
join_streamJoins stream using this file’s validated, bounded subsystem rules.
active_spill_bytesImplements spill bytes using this file’s validated, bounded subsystem rules.
crates/ngkg-shuffle-cache/src/lib.rsRust

Caches checksum-addressed shuffle objects with bounded usage and invalidation.

Function / symbolWhat it does
digestComputes the digest for digest using this file’s validated, bounded subsystem rules.
openOpens open using this file’s validated, bounded subsystem rules.
getReads get using this file’s validated, bounded subsystem rules.
insertInserts insert using this file’s validated, bounded subsystem rules.
invalidateInvalidates invalidate using this file’s validated, bounded subsystem rules.
usageReports usage for usage using this file’s validated, bounded subsystem rules.

10 · feature chapter

Hydration & retrieval

Turns semantic GUID results into bounded physical Parquet reads without weakening graph authorization.

crates/ngkg-locator/src/lib.rsRust

Compiles and queries sharded GUID-to-Parquet locator indexes and coalesces safe byte ranges.

Function / symbolWhat it does
compile_sharded_locatorCompiles sharded locator using this file’s validated, bounded subsystem rules.
openOpens open using this file’s validated, bounded subsystem rules.
lookupImplements lookup using this file’s validated, bounded subsystem rules.
validateValidates validate using this file’s validated, bounded subsystem rules.
owner_forSelects the owner for for using this file’s validated, bounded subsystem rules.
coalesce_rangesCoalesces ranges using this file’s validated, bounded subsystem rules.
crates/ngkg-hydration/src/lib.rsRust

Plans and performs graph-filtered payload hydration after verifying every referenced shard.

Function / symbolWhat it does
verify_payload_shardVerifies payload shard using this file’s validated, bounded subsystem rules.
plan_hydrationPlans hydration using this file’s validated, bounded subsystem rules.
hydrate_sharded_payloadHydrates sharded payload using this file’s validated, bounded subsystem rules.
hydrate_sharded_payload_for_graphsHydrates sharded payload for graphs using this file’s validated, bounded subsystem rules.
truncate_optional_contextBounds optional context using this file’s validated, bounded subsystem rules.
crates/ngkg-index/src/lib.rsRust

Opens physical indexes only after integrity checks succeed.

Function / symbolWhat it does
verify_openVerifies open using this file’s validated, bounded subsystem rules.

11 · feature chapter

Kubernetes & operators

CRD state machines, phase barriers, dedicated worker pools and workload ownership for RKE2/Kubernetes.

crates/ngkg-kube/src/lib.rsRust

Defines the namespaced ngkg.io/v1alpha1 NgkgCompilation custom resource shared by the API and both controllers.

Function / symbolWhat it does
NgkgCompilationDefines the NgkgCompilation type or Kubernetes/API contract used by this feature.
NgkgCompilationSpecDefines the NgkgCompilationSpec type or Kubernetes/API contract used by this feature.
NgkgCompilationStatusDefines the NgkgCompilationStatus type or Kubernetes/API contract used by this feature.
crates/ngkg-operator-core/src/lib.rsRust

Pure reconciliation decisions and Phase 40 resource ceilings used by the controllers.

Function / symbolWhat it does
next_actionMaps a validated stage observation to the next legal compilation action; incomplete or corrupt barriers return an error.
Phase40CeilingsDefines the Phase40Ceilings type or Kubernetes/API contract used by this feature.
services/distributed-operator/src/main.rsRust

Schedules distributed stages, enforces completion barriers and reconciles worker-job state.

Function / symbolWhat it does
mainBootstraps the process, loads trusted configuration and starts the service or controller runtime.
reconcileCompares desired NgkgCompilation state with durable catalog truth and selects the next idempotent action.
reconcile_artifact_barrierAdvances artifact stages only after the catalog proves every expected partition and root is complete.
schedule_stageBuilds and submits the indexed Job for one distributed compilation stage with bounded parallelism.
ensure_jobCreates the deterministic Kubernetes Job when absent and verifies an existing Job before reusing it.
patch_statusWrites concise, non-sensitive observed state back to the custom resource status subresource.
services/operator/src/main.rsRust

Coordinates reference compilation and top-level compilation lifecycle.

Function / symbolWhat it does
mainBootstraps the process, loads trusted configuration and starts the service or controller runtime.
reconcileCompares desired NgkgCompilation state with durable catalog truth and selects the next idempotent action.
ensure_reference_jobCreates or validates the reference compilation Job for the current immutable compilation identity.
reference_jobBuilds the reference-worker Kubernetes Job specification, including resources, trusted inputs and ceiling identities.
patch_statusWrites concise, non-sensitive observed state back to the custom resource status subresource.
charts/ngkg-workloads/Helm / YAML

Deploys dedicated query, fragment, locator, hydration and reasoner roles with HPAs, affinity and policy.

Function / symbolWhat it does
values.schema.jsonConfiguration or contract surface reviewed alongside the executable code in this feature.
templates/Configuration or contract surface reviewed alongside the executable code in this feature.
HPAsDefines the HPAs type or Kubernetes/API contract used by this feature.
NetworkPoliciesDefines the NetworkPolicies type or Kubernetes/API contract used by this feature.

12 · feature chapter

OWL & exact reasoning

Direct-Semantics legality, authorized ontology assembly, HermiT execution, proof binding and complete partition merging.

crates/ngkg-owl-direct/src/lib.rsRust

Extracts candidate OWL Direct-Semantics BGP templates and classifies legal graph patterns.

Function / symbolWhat it does
extract_direct_bgp_templateExtracts direct BGP template using this file’s validated, bounded subsystem rules.
classify_direct_bgpsClassifies direct BGPs using this file’s validated, bounded subsystem rules.
crates/ngkg-online-reasoning/src/lib.rsRust

Selects authorized semkg modules, builds reasoner partitions, retries dispatch and rejects incomplete result sets.

Function / symbolWhat it does
select_authorized_asserted_modulesSelects only authorized named graphs with the semkg role for exact ontology assembly.
validate_ontology_snapshot_bindingValidates ontology snapshot binding using this file’s validated, bounded subsystem rules.
build_distributed_reasoner_planPartitions an exact Direct-BGP candidate space into deterministic, bounded reasoner work.
dispatch_exact_partitions_with_retrySends exact reasoner partitions with bounded retry while preserving work identity and duplicate safety.
complete_distributed_exact_bgpAccepts an exact answer only after every expected reasoner partition and certificate validates.
crates/ngkg-direct-reasoner/src/lib.rsRust

Builds, executes and merges exact Direct-BGP partition requests with deterministic request-set identity.

Function / symbolWhat it does
execute_exact_direct_bgpRuns the complete exact OWL Direct-Semantics Basic Graph Pattern workflow.
prepare_exact_direct_bgp_requestsPrepares exact direct BGP requests using this file’s validated, bounded subsystem rules.
execute_exact_direct_partitionExecutes exact direct partition using this file’s validated, bounded subsystem rules.
merge_partition_resultsMerges partition results using this file’s validated, bounded subsystem rules.
direct_exact_request_set_sha256Implements exact request set SHA-256 using this file’s validated, bounded subsystem rules.
crates/ngkg-reasoner-client/src/lib.rsRust

Validates legality, result, certificate and proof bindings before accepting reasoner output.

Function / symbolWhat it does
require_legal_direct_bgpRequires legal direct BGP using this file’s validated, bounded subsystem rules.
reasonRuns reasoning for reason using this file’s validated, bounded subsystem rules.
decide_coverageChooses coverage using this file’s validated, bounded subsystem rules.
crates/ngkg-reference/src/direct_exact.rsRust

Assembles the active exact ontology only from authorized */semkg graphs and pinned imports.

Function / symbolWhat it does
build_direct_active_ontology_bundleBuilds direct active ontology bundle using this file’s validated, bounded subsystem rules.
crates/ngkg-reference/src/reasoner.rsRust

Invokes the checksum-pinned HermiT adapter under bounded execution rules.

Function / symbolWhat it does
invoke_reasonerLaunches the checksum-pinned Java/HermiT adapter under trusted time, memory and filesystem limits.
adapters/hermit-reasoner/src/main/java/io/ngkg/reasoner/DirectBgpExecutor.javaJava

Executes OWLAPI/HermiT Direct-BGP requests and emits bounded exact evidence.

Function / symbolWhat it does
executeExecutes execute using this file’s validated, bounded subsystem rules.
renderResultsImplements renderResults using this file’s validated, bounded subsystem rules.
renderProofSupportImplements renderProofSupport using this file’s validated, bounded subsystem rules.

13 · feature chapter

Property paths

Exact NFA traversal state, origin-preserving frontiers, partition ownership, checkpoints and termination.

crates/ngkg-query-executor/src/distributed_path.rsRust

Seeds, partitions and expands path frontiers; validates complete iterations and atomic resume checkpoints.

Function / symbolWhat it does
seed_path_frontierCreates origin-preserving initial states for a distributed property-path traversal.
path_partition_ownerComputes partition owner using this file’s validated, bounded subsystem rules.
path_expansion_work_itemsComputes expansion work items using this file’s validated, bounded subsystem rules.
expand_path_work_itemExpands one deterministic adjacency range through the property-path automaton.
complete_path_iterationMerges and deduplicates a complete frontier iteration before allowing traversal to advance.
build_path_checkpointBuilds path checkpoint using this file’s validated, bounded subsystem rules.
validate_path_checkpointVerifies 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.rsRust

Compiles SPARQL path expressions into exact distributed property-path plans.

Function / symbolWhat it does
distributed_property_path_plansImplements property path plans using this file’s validated, bounded subsystem rules.

14 · feature chapter

Reference oracle & qualification

Scalar correctness path, semantic compilation, expected-result verification and differential gates.

crates/ngkg-reference/src/query.rsRust

Builds the standards-correct scalar store, executes compiled queries and canonicalizes results for comparison.

Function / symbolWhat it does
build_storeBuilds store using this file’s validated, bounded subsystem rules.
build_store_with_dataset_policyBuilds store with dataset policy using this file’s validated, bounded subsystem rules.
execute_compiled_queryExecutes compiled query using this file’s validated, bounded subsystem rules.
canonical_result_hashHashes the canonical scalar result so optimized and reference answers can be compared byte-independently.
verify_bindingsVerifies bindings using this file’s validated, bounded subsystem rules.
load_rdf_fixtureLoads rdf fixture using this file’s validated, bounded subsystem rules.
crates/ngkg-reference/src/compiler.rsRust

Compiles source manifests into semantic catalogs and certifies representative query behavior.

Function / symbolWhat it does
compile_from_manifestCompiles from manifest using this file’s validated, bounded subsystem rules.
validate_graph_catalogValidates graph catalog using this file’s validated, bounded subsystem rules.
write_semantic_capabilitiesWrites semantic capabilities using this file’s validated, bounded subsystem rules.
certify_queriesCertifies queries using this file’s validated, bounded subsystem rules.
crates/ngkg-reference/src/rdf.rsRust

Parses TriG/N-Quads, normalizes facts and enforces the RDF/datatype policy.

Function / symbolWhat it does
parse_trigParses trig using this file’s validated, bounded subsystem rules.
parse_nquadsParses nquads using this file’s validated, bounded subsystem rules.
normalized_factsNormalizes facts using this file’s validated, bounded subsystem rules.
nquad_lineRenders line using this file’s validated, bounded subsystem rules.
ntriple_lineRenders line using this file’s validated, bounded subsystem rules.
services/reference-worker/src/object_compile.rsRust

Runs object-store-backed reference attempts, uploads artifacts and certifies sharded hydration.

Function / symbolWhat it does
compile_object_storeCompiles object store using this file’s validated, bounded subsystem rules.
run_attemptImplements attempt using this file’s validated, bounded subsystem rules.
certify_sharded_hydrationCertifies sharded hydration using this file’s validated, bounded subsystem rules.
upload_snapshotUploads snapshot using this file’s validated, bounded subsystem rules.

15 · feature chapter

SPARQL & distributed algebra

Parsing, canonical algebra, graph fragments, bounded partition operators and scalar differential comparison.

crates/ngkg-sparql-compiler/src/lib.rsRust

Parses SPARQL, applies base IRIs, requires certifiable constructs and emits canonical or distributed plans.

Function / symbolWhat it does
parseParses SPARQL into typed internal syntax using the standards-correct compiler path.
parse_with_base_iriParses SPARQL while resolving relative IRIs against the caller-supplied base IRI.
require_certifiableRejects query constructs whose current execution path cannot produce the required correctness evidence.
canonical_sseSerializes canonical SPARQL algebra for deterministic plan identity and differential comparison.
distributed_graph_fragmentsImplements graph fragments using this file’s validated, bounded subsystem rules.
distributed_algebra_planCompiles canonical SPARQL algebra into a typed, checksum-bound distributed stage DAG.
crates/ngkg-query-planner/src/lib.rsRust

Validates typed distributed plans, computes execution waves, routes relevant graphs and chooses exchanges.

Function / symbolWhat it does
validate_distributed_algebra_planValidates distributed algebra plan using this file’s validated, bounded subsystem rules.
algebra_execution_wavesImplements execution waves using this file’s validated, bounded subsystem rules.
route_relevant_graphsRoutes relevant graphs using this file’s validated, bounded subsystem rules.
choose_exchangeChooses exchange using this file’s validated, bounded subsystem rules.
crates/ngkg-query-executor/src/lib.rsRust

Reads/writes Arrow streams and implements stable partition ownership, exact semijoins, joins, projection and frontier utilities.

Function / symbolWhat it does
read_arrow_streamReads arrow stream using this file’s validated, bounded subsystem rules.
write_arrow_streamWrites arrow stream using this file’s validated, bounded subsystem rules.
partition_rowsPartitions rows using this file’s validated, bounded subsystem rules.
exact_semijoinImplements semijoin using this file’s validated, bounded subsystem rules.
inner_joinExecutes join using this file’s validated, bounded subsystem rules.
project_sparql_jsonProjects SPARQL json using this file’s validated, bounded subsystem rules.
next_frontierBuilds frontier using this file’s validated, bounded subsystem rules.
crates/ngkg-query-executor/src/distributed_algebra.rsRust

Implements native UNION, OPTIONAL/left join, MINUS, DISTINCT, grouping, ordered merge and global slicing under complete-partition barriers.

Function / symbolWhat it does
execute_native_algebra_taskExecutes a bounded native distributed-algebra stage only for operators admitted to the safe lane.
union_sparql_jsonUnions SPARQL json using this file’s validated, bounded subsystem rules.
left_join_sparql_jsonExecutes join SPARQL json using this file’s validated, bounded subsystem rules.
minus_sparql_jsonSubtracts SPARQL json using this file’s validated, bounded subsystem rules.
distinct_sparql_jsonDeduplicates SPARQL json using this file’s validated, bounded subsystem rules.
group_owned_partitionsGroups owned partitions using this file’s validated, bounded subsystem rules.
merge_ordered_partitions_byMerges ordered partitions by using this file’s validated, bounded subsystem rules.
global_slice_sparql_jsonApplies 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.rsRust

Coordinates protocol parsing, scalar execution, exact reasoning and the distributed evidence lane.

Function / symbolWhat it does
execute_sparql_protocolApplies SPARQL Protocol dataset and content-negotiation rules, then coordinates query execution.
execute_distributed_queryCoordinates the evidence-bound distributed query lane and requires all planned work to complete.
execute_fragmentExecutes fragment using this file’s validated, bounded subsystem rules.
execute_partitioned_shuffleExecutes partitioned shuffle using this file’s validated, bounded subsystem rules.
execute_uncertified_exact_queryRoutes an uncovered semantic request through the exact scalar/HermiT correctness boundary instead of guessing.
crates/ngkg-query-cache/src/lib.rsRust

Stores deterministic query results under snapshot-, graph-set- and plan-bound cache keys.

Function / symbolWhat it does
digestComputes the digest for digest using this file’s validated, bounded subsystem rules.
openOpens open using this file’s validated, bounded subsystem rules.
getReads get using this file’s validated, bounded subsystem rules.
insertInserts insert using this file’s validated, bounded subsystem rules.
invalidateInvalidates invalidate using this file’s validated, bounded subsystem rules.
usageReports usage for usage using this file’s validated, bounded subsystem rules.

16 · feature chapter

Types, contracts & integrity

Typed requests, plans, certificates, proofs and manifests that bind every result to inputs and completeness evidence.

crates/ngkg-types/src/direct_bgp.rsRust

Defines and validates normalized Direct-BGP result envelopes.

Function / symbolWhat it does
validate_resultValidates result using this file’s validated, bounded subsystem rules.
crates/ngkg-types/src/direct_certificate.rsRust

Validates exact certificates, result hashes and snapshot/graph bindings.

Function / symbolWhat it does
validate_certificateValidates certificate using this file’s validated, bounded subsystem rules.
validate_result_hashValidates result hash using this file’s validated, bounded subsystem rules.
crates/ngkg-types/src/direct_exact.rsRust

Defines exact requests and partition results with integrity validation.

Function / symbolWhat it does
validate_exact_requestValidates exact request using this file’s validated, bounded subsystem rules.
validate_partition_resultValidates partition result using this file’s validated, bounded subsystem rules.
crates/ngkg-types/src/direct_proof.rsRust

Builds support identities and validates proof manifests and bundles.

Function / symbolWhat it does
support_idComputes id using this file’s validated, bounded subsystem rules.
support_hashComputes hash using this file’s validated, bounded subsystem rules.
validate_manifestValidates manifest using this file’s validated, bounded subsystem rules.
validate_bundleValidates bundle using this file’s validated, bounded subsystem rules.
contracts/JSON Schema

Versioned JSON Schemas for graph catalogs, distributed plans, snapshots, Direct-BGP evidence and serving roots.

Function / symbolWhat it does
graph-catalogImplements graph-catalog using this file’s validated, bounded subsystem rules.
direct-bgpImplements direct-BGP using this file’s validated, bounded subsystem rules.
direct-proofImplements direct-proof using this file’s validated, bounded subsystem rules.
distributed-*Implements distributed-* using this file’s validated, bounded subsystem rules.
serving-rootImplements serving-root using this file’s validated, bounded subsystem rules.