Trait QueryLocalCommitLog 

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

Required Methods

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

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

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

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

fn get_latest_chain_start_rowid( &self, group_id: &GroupId, ) -> Result<Option<i32>, ConnectionError>

Rowid of the most recent chain-start entry for this group, if any. Chain-start entries have commit_sequence_id == 0 (Welcome / GroupCreation / BackupRestore) and mark the beginning of the member’s current membership session.

Implementations on Foreign Types

impl<T> QueryLocalCommitLog for &T

where T: QueryLocalCommitLog,

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

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

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

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

fn get_latest_chain_start_rowid( &self, group_id: &GroupId, ) -> Result<Option<i32>, ConnectionError>

Implementors

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