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 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 types: registry, provider trait, cache, call log, adapters, and backends. Inference runs on a Ring 1 worker, never Ring 0.

api

FFI-friendly API for language bindings.

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. Checkpoint recovery: selects a committed manifest and resolves its operator-state sidecar. Runtime owners restore sources, sinks, tables, and operators from that single recovered cut.

subscription

External named-subscription substrate: byte-bounded shared logs and cursor portals. SUBSCRIBE substrate: one shared byte-bounded log per object and cursor portals.

Structs

ArrowRecord

Record type for Arrow-based streaming subscriptions.

CheckpointResult

Result of a checkpoint attempt.

CheckpointStats

Checkpoint performance statistics.

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 vnode state staged during rebalance adoption for deferred apply.

RestartPolicy

Auto-restart policy for the fault supervisor (see LaminarDB::enable_supervision).

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 named-stream RecordBatch rows.

UntypedSourceHandle

Untyped handle for pushing raw RecordBatch data.

Enums

BackpressurePolicy

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

CheckpointFailureDisposition

Required runtime response when a checkpoint attempt fails.

CheckpointPhase

Phase of the checkpoint lifecycle.

ClusterStartupDisposition

Rebalance-driven state-rehydration types (cluster mode). Result of certifying a clustered process at startup.

DbError

Errors from database operations.

DeliveryGuarantee

Delivery guarantee level for the pipeline.

ExecuteResult

Result of executing a SQL statement.

PipelineNodeType

Type of a node in the pipeline topology.

PipelineState

The state of a streaming pipeline.

SubscriptionError

Terminal failure from a named subscription.

TypedSubscriptionFrame

A typed frame from a named subscription.

Traits

FromBatch

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