risingwave_connector::source::filesystem::opendal_source

Trait OpendalSource

source 
pub trait OpendalSource:
    Send
    + Sync
    + 'static
    + Clone
    + PartialEq {
    type Properties: SourceProperties + Send + Sync;

    // Required method
    fn new_enumerator(
        properties: Self::Properties,
    ) -> ConnectorResult<OpendalEnumerator<Self>>;
}

Required Associated Types§

source

type Properties: SourceProperties + Send + Sync

Required Methods§

source

fn new_enumerator( properties: Self::Properties, ) -> ConnectorResult<OpendalEnumerator<Self>>

Object Safety§

This trait is not object safe.

Implementors§