opendata-log 0.2.2

//! OpenData Log - A key-oriented log system built on SlateDB.
//!
//! OpenData Log provides a simple log abstraction where each key represents an
//! independent log stream. Unlike traditional messaging systems with partitions,
//! users write directly to keys and can create new keys as access patterns evolve.
//!
//! # Architecture
//!
//! The log is built on SlateDB's LSM tree. Writes append entries to the WAL and
//! memtable, then flush to sorted string tables (SSTs). LSM compaction naturally
//! organizes data for log locality, grouping entries by key prefix over time.
//!
//! # Key Concepts
//!
//! - **LogDb**: The main entry point providing both read and write operations.
//! - **LogDbReader**: A read-only view of the log, useful for consumers that should
//!   not have write access.
//! - **Sequence Numbers**: Each entry is assigned a global sequence number at
//!   append time. Sequence numbers are monotonically increasing within a key's
//!   log but not contiguous (other keys' appends are interleaved).
//!
//! # Example
//!
//! ```
//! # use log::{LogDb, LogRead, Config, Record};
//! # use bytes::Bytes;
//! # use common::StorageConfig;
//! # #[tokio::main]
//! # async fn main() -> Result<(), Box<dyn std::error::Error>> {
//! let config = Config { storage: StorageConfig::InMemory, ..Default::default() };
//! let log = LogDb::open(config).await?;
//!
//! // Append records
//! let records = vec![
//!     Record { key: Bytes::from("orders"), value: Bytes::from("order-123") },
//! ];
//! log.try_append(records).await?;
//! log.flush().await?;
//!
//! // Scan a key's log
//! let mut iter = log.scan(Bytes::from("orders"), ..).await?;
//! while let Some(entry) = iter.next().await? {
//!     println!("seq={}, value={:?}", entry.sequence, entry.value);
//! }
//! # Ok(())
//! # }
//! ```

mod config;
mod error;
mod listing;
mod log;
mod model;
mod range;
mod reader;
mod segment;
mod serde;
#[cfg(feature = "http-server")]
pub mod server;
mod storage;
mod writer;

pub use config::{Config, CountOptions, ReaderConfig, ScanOptions, SegmentConfig};
pub use error::{AppendError, AppendResult, Error, Result};
pub use listing::{LogKey, LogKeyIterator};
pub use log::{LogDb, LogDbBuilder};
pub use model::{AppendOutput, LogEntry, Record, Segment, SegmentId, Sequence};

pub use reader::{LogDbReader, LogIterator, LogRead};

// Re-export proto types for use by clients
#[cfg(feature = "http-server")]
pub mod proto {
    pub use crate::server::proto::*;
}