Trait DataWriter 

pub trait DataWriter: Send + Sync {
    // Required methods
    fn write(&self, payload: &[u8]) -> Result<()>;
    fn write_with_timestamp(
        &self,
        payload: &[u8],
        timestamp_ns: u64,
    ) -> Result<()>;
    fn topic(&self) -> &str;
    fn type_name(&self) -> &str;
}

Abstract data writer interface

Required Methods

fn write(&self, payload: &[u8]) -> Result<()>

Write a sample

fn write_with_timestamp(&self, payload: &[u8], timestamp_ns: u64) -> Result<()>

Write a sample with timestamp

fn topic(&self) -> &str

Get topic name

fn type_name(&self) -> &str

Get type name

Implementors