risingwave_connector::source::base

Trait FsListInner

source
pub trait FsListInner: Sized {
    // Required methods
    fn get_next_page<'life0, 'async_trait, T>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<(Vec<T>, bool)>> + Send + 'async_trait>>
       where T: 'async_trait + for<'a> From<&'a Object>,
             Self: 'async_trait,
             'life0: 'async_trait;
    fn filter_policy(
        &self,
        ctx: &FsFilterCtrlCtx,
        page_num: usize,
        item: &FsPageItem,
    ) -> bool;
}

Required Methods§

source

fn get_next_page<'life0, 'async_trait, T>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(Vec<T>, bool)>> + Send + 'async_trait>>
where T: 'async_trait + for<'a> From<&'a Object>, Self: 'async_trait, 'life0: 'async_trait,

source

fn filter_policy( &self, ctx: &FsFilterCtrlCtx, page_num: usize, item: &FsPageItem, ) -> bool

Object Safety§

This trait is not object safe.

Implementors§