From e710cea765bbf569f2ca0c9e45af1a7033c66ba1 Mon Sep 17 00:00:00 2001 From: Zhexuan Yang Date: Sun, 8 Feb 2026 12:44:22 +0800 Subject: [PATCH] feat: re-export CodecValue and DecodedMessage at top level Users can now use robocodec::CodecValue and robocodec::DecodedMessage directly instead of robocodec::core::value::CodecValue. --- src/lib.rs | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/src/lib.rs b/src/lib.rs index 780873b..cecbbac 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -154,6 +154,8 @@ //! - **[`ChannelInfo`]** - Channel/topic metadata //! - **[`ReaderConfig`]** - Configuration for readers (parallel processing, chunk merging) //! - **[`WriterConfig`]** - Configuration for writers +//! - **[`DecodedMessage`]** - Decoded message field name to value mapping +//! - **[`CodecValue`]** - Value type for decoded message fields //! //! ## S3 Authentication //! @@ -198,6 +200,9 @@ pub mod core; // Re-export core error type for public API pub use core::{CodecError, Result}; +// Re-export core value types (decoded message representation) +pub use core::value::{CodecValue, DecodedMessage}; + // Encoding/decoding (hidden from docs but available for advanced use) #[doc(hidden)] pub mod encoding; @@ -246,8 +251,7 @@ pub use transform::{TransformBuilder, TransformError}; /// # Example /// /// ```no_run -/// # use robocodec::{Decoder, CodecError}; -/// # use robocodec::core::DecodedMessage; +/// # use robocodec::{Decoder, CodecError, DecodedMessage}; /// # struct MyDecoder; /// # impl Decoder for MyDecoder { /// # fn decode(&self, data: &[u8], schema: &str, type_name: Option<&str>) -> Result { @@ -279,8 +283,7 @@ pub trait Decoder: Send + Sync { /// # Example /// /// ```no_run - /// # use robocodec::{Decoder, CodecError}; - /// # use robocodec::core::DecodedMessage; + /// # use robocodec::{Decoder, CodecError, DecodedMessage}; /// # fn test(decoder: &dyn Decoder, data: &[u8]) -> Result<(), CodecError> { /// let schema = "int32 value\nstring name"; /// let message = decoder.decode(data, schema, Some("test/Type"))?;