pub struct SerdeEncoder;Expand description
A serde-based encoder that uses rmp-serde (MessagePack) for binary serialization.
This implementation targets Phase 1 MVP requirements for rapid iteration. It uses a fixed-size header followed by the raw component payload.
Implementations§
Source§impl SerdeEncoder
impl SerdeEncoder
Sourcepub fn encode_event(&self, event: &NetworkEvent) -> Result<Vec<u8>, EncodeError>
pub fn encode_event(&self, event: &NetworkEvent) -> Result<Vec<u8>, EncodeError>
Encodes a NetworkEvent into raw bytes for transmission.
§Errors
Returns EncodeError if the event fails to serialize or is a local-only variant.
Sourcepub fn decode_event(&self, data: &[u8]) -> Result<NetworkEvent, EncodeError>
pub fn decode_event(&self, data: &[u8]) -> Result<NetworkEvent, EncodeError>
Decodes raw bytes into a NetworkEvent.
§Errors
Returns EncodeError if the bytes are not a valid WireEvent.
Trait Implementations§
Source§impl Debug for SerdeEncoder
impl Debug for SerdeEncoder
Source§impl Default for SerdeEncoder
impl Default for SerdeEncoder
Source§fn default() -> SerdeEncoder
fn default() -> SerdeEncoder
Returns the “default value” for a type. Read more
Source§impl Encoder for SerdeEncoder
impl Encoder for SerdeEncoder
Source§fn encode_event(&self, event: &NetworkEvent) -> Result<Vec<u8>, EncodeError>
fn encode_event(&self, event: &NetworkEvent) -> Result<Vec<u8>, EncodeError>
Encodes a high-level
NetworkEvent into a byte vector. Read moreSource§fn decode_event(&self, data: &[u8]) -> Result<NetworkEvent, EncodeError>
fn decode_event(&self, data: &[u8]) -> Result<NetworkEvent, EncodeError>
Decodes a high-level
NetworkEvent from a byte slice. Read moreSource§fn encode(
&self,
event: &ReplicationEvent,
buffer: &mut [u8],
) -> Result<usize, EncodeError>
fn encode( &self, event: &ReplicationEvent, buffer: &mut [u8], ) -> Result<usize, EncodeError>
Serializes a replication event into the provided buffer. Read more
Source§fn decode(&self, buffer: &[u8]) -> Result<ComponentUpdate, EncodeError>
fn decode(&self, buffer: &[u8]) -> Result<ComponentUpdate, EncodeError>
Deserializes raw bytes into a component update. Read more
Source§fn max_encoded_size(&self) -> usize
fn max_encoded_size(&self) -> usize
Returns the maximum possible encoded size for a single event. Read more
Auto Trait Implementations§
impl Freeze for SerdeEncoder
impl RefUnwindSafe for SerdeEncoder
impl Send for SerdeEncoder
impl Sync for SerdeEncoder
impl Unpin for SerdeEncoder
impl UnsafeUnpin for SerdeEncoder
impl UnwindSafe for SerdeEncoder
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more