Struct AqlServiceImpl 

pub struct AqlServiceImpl<S: StorageEngine> { /* private fields */ }

AQL service implementation

This service handles all AQL query requests and connects them to the underlying storage engine.

Implementations

impl<S: StorageEngine> AqlServiceImpl<S>

pub fn new(storage: Arc<S>) -> Self

Create a new AQL service with the given storage engine (without compute)

pub async fn execute_query(&self, request: QueryRequest) -> QueryResponse

Execute a query and return the result

pub async fn execute_batch(&self, request: BatchRequest) -> BatchResponse

Execute a batch of queries as a transaction

All queries are executed sequentially. If any query fails, all previously completed write operations (Set/Delete) are rolled back, and an error response is returned. Read-only operations (Get/Range) are not tracked for rollback since they don’t mutate state.

pub fn execute_stream( &self, request: QueryRequest, config: StreamConfig, ) -> BoxStream<'static, Result<StreamResponse, NetError>>

Execute a streaming query that returns results in chunks

This method executes a range or filter query and returns results as a stream of StreamResponse messages, each containing a batch of key-value pairs. The chunk size controls how many items are included per message.

Arguments

• request - The query request to execute
• config - Streaming configuration (chunk size, max results, timeout)

Returns

A boxed stream of Result<aql::StreamResponse, NetError> messages

pub async fn health_check( &self, _request: HealthCheckRequest, ) -> HealthCheckResponse

Health check

pub async fn get_server_info( &self, _request: ServerInfoRequest, ) -> ServerInfoResponse

Get server information