removed mentions of channels and removed methods; removed claim about overhead

Author: fresheed

aimdb-sync/src/consumer.rs

@@ -193,7 +193,7 @@ where
 
     /// Get the latest value by draining all queued values.
     ///
-    /// This method drains the internal channel to get the most recent value,
+    /// This method drains the buffer to get the most recent value,
     /// discarding any intermediate values. This is useful for SingleLatest-like
     /// semantics where you only care about the most recent data.
     ///

aimdb-sync/src/error.rs

@@ -5,9 +5,9 @@ use aimdb_core::DbError;
 
 /// Errors from the synchronous (blocking) API.
 ///
-/// Facade-specific failures (attach/detach, channel timeouts, runtime-thread
-/// shutdown) are their own variants; anything from the underlying database
-/// wraps a [`DbError`] via [`SyncError::Db`].
+/// Facade-specific failures (attach/detach, runtime-thread shutdown) are their
+/// own variants; anything from the underlying database wraps a [`DbError`]
+/// via [`SyncError::Db`].
 #[derive(Debug, thiserror::Error)]
 pub enum SyncError {
     /// Failed to attach the database to the runtime thread.

aimdb-sync/src/lib.rs

@@ -6,8 +6,8 @@
 //! ## Overview
 //!
 //! This crate provides a synchronous interface to AimDB by running the
-//! async runtime on a dedicated background thread and using channels
-//! to bridge between synchronous and asynchronous contexts.
+//! async runtime on a dedicated background thread, blocking on it directly
+//! for reads that must wait for data.
 //!
 //! ## Features
 //!
@@ -126,11 +126,9 @@
 //!
 //! - **User threads**: Unlimited - any number of threads can call operations concurrently
 //! - **Runtime thread**: One dedicated thread named "aimdb-sync-runtime"
-//! - **Channels**: Lock-free MPSC channels for efficient communication
 //!
 //! ## Performance
 //!
-//! - **Overhead**: ~100-500μs per operation vs pure async (channel + context switch)
 //! - **Latency**: Excellent for <50ms target, not suitable for hard low-latency requirements
 //!
 //! ## Error Handling

aimdb-sync/src/producer.rs

@@ -8,7 +8,7 @@ use std::{fmt::Debug, marker::PhantomData};
 /// Synchronous producer for records of type `T`.
 ///
 /// Thread-safe, can be cloned and shared across threads.
-/// Values are moved (not cloned) through channels for zero-copy performance.
+/// Values are moved (not cloned) directly into the record's buffer.
 ///
 /// # Thread Safety
 ///
@@ -29,7 +29,7 @@ use std::{fmt::Debug, marker::PhantomData};
 /// // Try to set (non-blocking)
 /// match producer.try_set(Temperature { celsius: 27.0 }) {
 ///     Ok(()) => println!("Success"),
-///     Err(_) => println!("Channel full, try later"),
+///     Err(_) => println!("Buffer full, try later"),
 /// }
 /// # Ok(())
 /// # }
@@ -99,16 +99,13 @@ where
 
     /// Try to set the value without blocking.
     ///
-    /// Attempts to send the value immediately. Returns an error if the channel is full
-    /// or the runtime thread has shut down.
-    ///
-    /// **Note**: This method returns immediately after sending to the channel, but does NOT
-    /// wait for the produce operation to complete. Use `set()` if
-    /// you need to know whether the produce operation succeeded.
+    /// Pushes the value directly into the record's buffer. Unlike `set()`, this never
+    /// blocks: it fails immediately if the buffer is full instead of waiting for space.
     ///
     /// # Errors
     ///
-    /// Returns `SyncError::SetTimeout` if the channel is full.
+    /// Returns `SyncError::SetTimeout` for bounded, non-overwriting buffer
+    /// implementations if the buffer is full.
     /// Returns `SyncError::RuntimeShutdown` if the runtime thread has been detached.
     ///
     /// # Example
@@ -129,7 +126,7 @@ where
     /// let producer = handle.producer::<MyData>("my_data")?;
     /// match producer.try_set(MyData { value: 42 }) {
     ///     Ok(()) => println!("Sent immediately"),
-    ///     Err(_) => println!("Channel full or runtime shutdown"),
+    ///     Err(_) => println!("Buffer full or runtime shutdown"),
     /// }
     /// # Ok(())
     /// # }