Crate laminar_db 

Unified database facade for LaminarDB.

Provides a single entry point (LaminarDB) that ties together the SQL parser, query planner, DataFusion context, and streaming API.

Example

use laminar_db::LaminarDB;

let db = LaminarDB::open()?;

db.execute("CREATE SOURCE trades (
    symbol VARCHAR, price DOUBLE, ts TIMESTAMP,
    WATERMARK FOR ts AS ts - INTERVAL '1' SECOND
)").await?;

let query = db.execute("SELECT symbol, AVG(price)
    FROM trades GROUP BY symbol, TUMBLE(ts, INTERVAL '1' MINUTE)
").await?;

Re-exports

pub use checkpoint_coordinator::CheckpointConfig;

pub use checkpoint_coordinator::CheckpointCoordinator;

pub use checkpoint_coordinator::CheckpointPhase;

pub use checkpoint_coordinator::CheckpointRequest;

pub use checkpoint_coordinator::CheckpointResult;

pub use checkpoint_coordinator::CheckpointStats;

pub use engine_metrics::EngineMetrics;

pub use profile::Profile;

pub use profile::ProfileError;

pub use recovery_manager::RecoveredState;

pub use recovery_manager::RecoveryManager;

pub use recovery_manager::VnodeRehydration;

pub use recovery_manager::VnodeRehydrator;

Modules

ai

AI inference module, containing model registry, provider trait, and backends. Backend-agnostic AI inference for LaminarDB.

api

FFI-friendly API for language bindings.

checkpoint_coordinator

Unified checkpoint coordination. Unified checkpoint coordinator.

engine_metrics

Prometheus metrics for the streaming engine. Prometheus metrics for the streaming engine.

ffi

C FFI layer for LaminarDB.

pipeline

Thread-per-core connector pipeline. Streaming connector pipeline. Each source connector runs as a tokio task pushing batches via crossfire mpsc to the StreamingCoordinator, which drives SQL execution cycles, routes results to sinks, and manages checkpoint barriers. See the streaming_coordinator submodule for the runtime topology.

profile

Deployment profiles. Deployment profiles for LaminarDB.

rebalance

Dynamic vnode rebalance control plane. Dynamic vnode rebalance control plane.

recovery_manager

Unified recovery manager. Unified recovery manager.

subscription

External SUBSCRIBE substrate: per-name broadcast channel and the per-portal pump task. SUBSCRIBE substrate: per-name broadcast registry and per-portal pump.

Structs

ArrowRecord

Record type for Arrow-based streaming subscriptions.

ConfigKeySpec

Re-export connector metadata types for the control-plane HTTP API (connector catalog / source-creation wizard). Specification for a configuration key.

ConnectorInfo

Re-export connector metadata types for the control-plane HTTP API (connector catalog / source-creation wizard). Metadata about a connector implementation.

ConnectorRegistry

Re-export the connector registry for custom connector registration. Registry of available connector implementations. Connectors register a factory per type string; the runtime looks up by the connector property in CREATE SOURCE/SINK DDL.

DdlInfo

Information about a completed DDL statement.

LaminarConfig

Configuration for a LaminarDB instance.

LaminarDB

The main LaminarDB database handle.

LaminarDbBuilder

Fluent builder for constructing a LaminarDB instance.

MaterializedViewInfo

JSON-serializable projection of a MaterializedView for the control-plane HTTP API.

PipelineEdge

A directed edge in the pipeline topology graph.

PipelineMetrics

Pipeline-wide metrics snapshot.

PipelineNode

A node in the pipeline topology graph.

PipelineTopology

The complete pipeline topology: nodes and edges.

QueryHandle

Handle to a running streaming query.

QueryInfo

Information about a running query.

RehydratedVnode

Rebalance-driven state-rehydration types (cluster mode). Committed state for a single vnode, staged during rebalance adoption so newly-acquired vnodes resume from the last committed epoch.

SinkInfo

Information about a registered sink.

SnapshotAdoption

Rebalance-driven state-rehydration types (cluster mode). Summary of a single LaminarDB::adopt_assignment_snapshot call.

SourceCatalog

Central registry of sources, sinks, streams, and queries.

SourceEntry

A registered source in the catalog.

SourceHandle

Typed handle for pushing data into a registered source.

SourceInfo

Information about a registered source.

SourceMetrics

Metrics for a single registered source.

StreamInfo

Metadata about a registered stream.

StreamMetrics

Metrics for a single registered stream.

TypedSubscription

Typed subscription that deserializes RecordBatch rows.

UntypedSourceHandle

Untyped handle for pushing raw RecordBatch data.

Enums

BackpressurePolicy

What to do when an operator’s input buffer exceeds its cap.

DbError

Errors from database operations.

ExecuteResult

Result of executing a SQL statement.

PipelineNodeType

Type of a node in the pipeline topology.

PipelineState

The state of a streaming pipeline.

Traits

FromBatch

Deserialize rows from a RecordBatch. Auto-generated by #[derive(FromRecordBatch)].