risingwave_connector::source::base

Trait SplitMetaData

Source 
pub trait SplitMetaData: Sized {
    // Required methods
    fn id(&self) -> SplitId;
    fn encode_to_json(&self) -> JsonbVal;
    fn restore_from_json(value: JsonbVal) -> Result<Self>;
    fn update_offset(&mut self, last_seen_offset: String) -> ConnectorResult<()>;

    // Provided methods
    fn encode_to_bytes(&self) -> Bytes { ... }
    fn restore_from_bytes(bytes: &[u8]) -> Result<Self> { ... }
}
Expand description

The metadata of a split.

Required Methods§

Source

fn id(&self) -> SplitId

Source

fn encode_to_json(&self) -> JsonbVal

Encode the whole split metadata to a JSON object

Source

fn restore_from_json(value: JsonbVal) -> Result<Self>

Source

fn update_offset(&mut self, last_seen_offset: String) -> ConnectorResult<()>

Provided Methods§

Source

fn encode_to_bytes(&self) -> Bytes

Source

fn restore_from_bytes(bytes: &[u8]) -> Result<Self>

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§