Crate query_router 

Query Router - Module 5 of Neumann

Parses shell commands, routes to appropriate engine(s), and combines results.

Command Syntax

Relational Commands

• SELECT <table> [WHERE <condition>]
• INSERT <table> <col>=<val>, ...
• UPDATE <table> SET <col>=<val>, ... [WHERE <condition>]
• DELETE <table> [WHERE <condition>]
• CREATE TABLE <table> (<col>:<type>, ...)

Graph Commands

• NODE CREATE <label> [<key>=<val>, ...]
• NODE GET <id>
• EDGE CREATE <from> -> <to> [<label>]
• NEIGHBORS <id> [OUT|IN|BOTH]
• PATH <from> -> <to>

Vector Commands

• EMBED <key> [<val>, ...]
• SIMILAR <key> [TOP <k>]
• SIMILAR [<val>, ...] [TOP <k>]

Unified Commands

• FIND <entity> WHERE <condition> SIMILAR TO <key> CONNECTED TO <entity>

Re-exports

pub use cursor::CursorError;

pub use cursor::CursorId;

pub use cursor::CursorResultType;

pub use cursor::CursorState;

pub use cursor_store::CursorStore;

pub use cursor_store::CursorStoreConfig;

pub use distributed::DistributedQueryConfig;

pub use distributed::MergeStrategy;

pub use distributed::QueryPlan;

pub use distributed::QueryPlanner;

pub use distributed::ResultMerger;

pub use distributed::ShardId;

pub use distributed::ShardResult;

Modules

cursor

Cursor state management for paginated query results.

cursor_store

Thread-safe cursor storage with TTL-based expiration.

cypher

Cypher query execution for the query router.

distributed

Distributed query execution with semantic routing and scatter-gather.

Structs

ArtifactInfoResult

Artifact info result from blob query.

BatchOperationResult

Batch operation result.

BlobStatsResult

Blob storage statistics result.

CentralityItem

Centrality score for a single node.

CentralityResult

Centrality result with algorithm metadata.

ChainBlockInfo

Block info from chain.

ChainCodebookInfo

Codebook info.

ChainDriftResult

Chain drift metrics.

ChainHistoryEntry

Entry in chain history.

ChainSimilarResult

Similar result from chain query.

ChainTransitionAnalysis

Transition analysis result.

CheckpointInfo

Checkpoint information for display.

CommunityItem

Community assignment for a single node.

CommunityResult

Community detection result with algorithm metadata.

ConstraintInfo

Constraint information.

EdgeResult

Edge result from graph query.

FilteredSearchConfig

Configuration for filtered search behavior.

NodeResult

Node result from graph query.

PageRankItem

PageRank score for a single node.

PageRankResult

PageRank result with algorithm metadata.

PagedQueryResult

Result of a paginated query execution.

PaginationOptions

Options for paginated query execution.

PatternMatchBinding

A single match with variable bindings.

PatternMatchResultValue

Pattern match result value for serialization.

PatternMatchStatsValue

Statistics from pattern matching.

QueryRouter

Query Router that orchestrates queries across engines.

SimilarResult

Similarity search result.

SpatialResult

Result from a spatial range query.

UnifiedResult

Result from unified cross-engine query.

Enums

AggregateResultValue

Aggregate result value.

BindingValue

A binding to a graph element.

CentralityType

Centrality algorithm type.

ChainResult

Chain operation result.

FilterCondition

Filter condition for filtered similarity search.

FilterStrategy

Strategy for filtered search execution.

FilterValue

Filter value for comparisons.

QueryResult

Result of a query execution.

RouterError

Error types for query routing.

Type Aliases

Result