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 BIGINT,
    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::CheckpointResult;

pub use checkpoint_coordinator::CheckpointStats;

pub use checkpoint_coordinator::WalPrepareResult;

pub use profile::Profile;

pub use profile::ProfileError;

pub use recovery_manager::RecoveredState;

pub use recovery_manager::RecoveryManager;

Modules

checkpoint_coordinator

Unified checkpoint coordination. Unified checkpoint coordinator.

pipeline

Thread-per-core connector pipeline. Thread-per-core connector pipeline.

profile

Deployment profiles. Deployment profiles for LaminarDB.

recovery_manager

Unified recovery manager. Unified recovery manager.

Structs

ConnectorRegistry

Re-export the connector registry for custom connector registration. Registry of available connector implementations.

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.

PipelineCounters

Shared atomic counters incremented by the pipeline processing loop.

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.

SinkInfo

Information about a registered sink.

SourceCatalog

Catalog of registered 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.

TieringConfig

S3 storage class tiering configuration.

TypedSubscription

Typed subscription that deserializes RecordBatch rows.

UntypedSourceHandle

Untyped handle for pushing raw RecordBatch data.

Enums

DbError

Errors from database operations.

ExecuteResult

Result of executing a SQL statement.

IdentifierCaseSensitivity

SQL identifier case sensitivity mode.

PipelineNodeType

Type of a node in the pipeline topology.

PipelineState

The state of a streaming pipeline.

Traits

FromBatch

Trait for types that can be deserialized from a RecordBatch.