Struct SqlConnect 

pub struct SqlConnect { /* private fields */ }

Connect handler implementing store.sql.v1.Service.

Implementations

impl SqlConnect

pub fn new(server: Arc<SqlServer>) -> Self

Trait Implementations

impl Clone for SqlConnect

fn clone(&self) -> SqlConnect

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Service for SqlConnect

fn subscribe( &self, ctx: Context, request: OwnedView<SubscribeRequestView<'static>>, ) -> impl Future<Output = Result<(Pin<Box<dyn Stream<Item = Result<SubscribeResponse, ConnectError>> + Send>>, Context), ConnectError>> + Send

Re-run a SQL WHERE predicate against every incoming batch that touches table’s primary-key codec family. Emits one SubscribeResponse per matched batch containing just the rows that satisfied the predicate.

fn tables( &self, ctx: Context, _request: OwnedView<TablesRequestView<'static>>, ) -> impl Future<Output = Result<(TablesResponse, Context), ConnectError>> + Send

Describe every registered table. Carries KV-specific metadata (primary-key order, secondary indexes with their layout + cover columns) that DataFusion’s information_schema doesn’t surface.

fn query( &self, ctx: Context, request: OwnedView<QueryRequestView<'static>>, ) -> impl Future<Output = Result<(QueryResponse, Context), ConnectError>> + Send

Ad-hoc unary SQL against the server-side session. Useful for inspecting the current table state alongside the live subscription.