Skip to main content

aimdb_core/
lib.rs

1//! AimDB Core Database Engine
2//!
3//! # aimdb-core
4//!
5//! Type-safe, async in-memory database for data synchronization
6//! across MCU → edge → cloud environments.
7//!
8//! # Architecture
9//!
10//! - **RecordKey/RecordId**: Stable identifiers for multi-instance records
11//! - **Unified API**: Single `Database<A>` type for all operations
12//! - **Runtime Agnostic**: Works with Tokio (std) or Embassy (embedded)
13//! - **Producer-Consumer**: Built-in typed message passing
14//!
15//! See examples in the repository for usage patterns.
16
17#![cfg_attr(not(feature = "std"), no_std)]
18
19pub mod buffer;
20pub mod builder;
21pub mod connector;
22pub mod context;
23pub mod database;
24mod error;
25pub mod ext_macros;
26pub mod extensions;
27pub mod graph;
28pub mod record_id;
29#[cfg(feature = "std")]
30pub mod remote;
31pub mod router;
32pub mod time;
33pub mod transform;
34pub mod transport;
35pub mod typed_api;
36pub mod typed_record;
37
38// Public API exports
39pub use context::RuntimeContext;
40pub use error::{DbError, DbResult};
41pub use extensions::Extensions;
42
43// Runtime trait re-exports from aimdb-executor
44// These traits define the platform-specific execution, timing, and logging capabilities
45pub use aimdb_executor::{
46    ExecutorError, ExecutorResult, Logger, Runtime, RuntimeAdapter, RuntimeInfo, Spawn, TimeOps,
47};
48
49// Database implementation exports
50pub use database::Database;
51
52// Producer-Consumer Pattern exports
53#[cfg(feature = "alloc")]
54pub use builder::OutboundRoute;
55pub use builder::{AimDb, AimDbBuilder};
56pub use connector::ConnectorBuilder;
57pub use transport::{Connector, ConnectorConfig, PublishError};
58pub use typed_api::{Consumer, Producer, RecordRegistrar, RecordT};
59pub use typed_record::{AnyRecord, AnyRecordExt, TypedRecord};
60
61// Connector Infrastructure exports
62pub use connector::TopicResolverFn;
63pub use connector::{ConnectorClient, ConnectorLink, ConnectorUrl, SerializeError};
64pub use connector::{TopicProvider, TopicProviderAny, TopicProviderFn, TopicProviderWrapper};
65
66// Router exports for connector implementations
67pub use router::{Route, Router, RouterBuilder};
68
69// Record identification exports
70pub use record_id::{RecordId, RecordKey, StringKey};
71
72// Graph exports (dependency graph for record topology)
73pub use graph::{DependencyGraph, EdgeType, GraphEdge, GraphNode, RecordGraphInfo, RecordOrigin};
74
75// Transform API exports
76#[cfg(feature = "std")]
77pub use transform::{JoinBuilder, JoinPipeline, JoinTrigger};
78pub use transform::{TransformBuilder, TransformPipeline};