Trait QueryRemoteCommitLog 

pub trait QueryRemoteCommitLog {
    // Required methods
    fn get_latest_remote_log_for_group(
        &self,
        group_id: &[u8],
    ) -> Result<Option<RemoteCommitLog>, ConnectionError>;
    fn get_remote_commit_log_after_cursor(
        &self,
        group_id: &[u8],
        after_cursor: i64,
        order_by: RemoteCommitLogOrder,
    ) -> Result<Vec<RemoteCommitLog>, ConnectionError>;
}

Required Methods

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

fn get_remote_commit_log_after_cursor( &self, group_id: &[u8], after_cursor: i64, order_by: RemoteCommitLogOrder, ) -> Result<Vec<RemoteCommitLog>, ConnectionError>

Implementations on Foreign Types

impl<T> QueryRemoteCommitLog for &T

where T: QueryRemoteCommitLog,

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

fn get_remote_commit_log_after_cursor( &self, group_id: &[u8], after_cursor: i64, order_by: RemoteCommitLogOrder, ) -> Result<Vec<RemoteCommitLog>, ConnectionError>

Implementors

impl QueryRemoteCommitLog for MockDbQuery

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