Trait QueryLocalCommitLog 

pub trait QueryLocalCommitLog {
    // Required methods
    fn get_group_logs(
        &self,
        group_id: &[u8],
    ) -> Result<Vec<LocalCommitLog>, ConnectionError>;
    fn get_local_commit_log_after_cursor(
        &self,
        group_id: &[u8],
        after_cursor: i64,
        order_by: LocalCommitLogOrder,
    ) -> Result<Vec<LocalCommitLog>, ConnectionError>;
    fn get_latest_log_for_group(
        &self,
        group_id: &[u8],
    ) -> Result<Option<LocalCommitLog>, ConnectionError>;
    fn get_local_commit_log_cursor(
        &self,
        group_id: &[u8],
    ) -> Result<Option<i32>, ConnectionError>;
}

Required Methods

fn get_group_logs( &self, group_id: &[u8], ) -> Result<Vec<LocalCommitLog>, ConnectionError>

fn get_local_commit_log_after_cursor( &self, group_id: &[u8], after_cursor: i64, order_by: LocalCommitLogOrder, ) -> Result<Vec<LocalCommitLog>, ConnectionError>

fn get_latest_log_for_group( &self, group_id: &[u8], ) -> Result<Option<LocalCommitLog>, ConnectionError>

fn get_local_commit_log_cursor( &self, group_id: &[u8], ) -> Result<Option<i32>, ConnectionError>

Implementations on Foreign Types

impl<T> QueryLocalCommitLog for &T

where T: QueryLocalCommitLog,

fn get_group_logs( &self, group_id: &[u8], ) -> Result<Vec<LocalCommitLog>, ConnectionError>

fn get_local_commit_log_after_cursor( &self, group_id: &[u8], after_cursor: i64, order_by: LocalCommitLogOrder, ) -> Result<Vec<LocalCommitLog>, ConnectionError>

fn get_latest_log_for_group( &self, group_id: &[u8], ) -> Result<Option<LocalCommitLog>, ConnectionError>

fn get_local_commit_log_cursor( &self, group_id: &[u8], ) -> Result<Option<i32>, ConnectionError>

Implementors

impl QueryLocalCommitLog for MockDbQuery

impl<C: ConnectionExt> QueryLocalCommitLog for DbConnection<C>