Trait QueryReaddStatus 

pub trait QueryReaddStatus {
    // Required methods
    fn get_readd_status(
        &self,
        group_id: &[u8],
        installation_id: &[u8],
    ) -> Result<Option<ReaddStatus>, ConnectionError>;
    fn is_awaiting_readd(
        &self,
        group_id: &[u8],
        installation_id: &[u8],
    ) -> Result<bool, ConnectionError>;
    fn update_requested_at_sequence_id(
        &self,
        group_id: &[u8],
        installation_id: &[u8],
        sequence_id: i64,
    ) -> Result<(), ConnectionError>;
    fn update_responded_at_sequence_id(
        &self,
        group_id: &[u8],
        installation_id: &[u8],
        sequence_id: i64,
    ) -> Result<(), ConnectionError>;
    fn delete_other_readd_statuses(
        &self,
        group_id: &[u8],
        self_installation_id: &[u8],
    ) -> Result<(), ConnectionError>;
    fn delete_readd_statuses(
        &self,
        group_id: &[u8],
        installation_ids: HashSet<Vec<u8>>,
    ) -> Result<(), ConnectionError>;
    fn get_readds_awaiting_response(
        &self,
        group_id: &[u8],
        self_installation_id: &[u8],
    ) -> Result<Vec<ReaddStatus>, ConnectionError>;
}

Required Methods

fn get_readd_status( &self, group_id: &[u8], installation_id: &[u8], ) -> Result<Option<ReaddStatus>, ConnectionError>

fn is_awaiting_readd( &self, group_id: &[u8], installation_id: &[u8], ) -> Result<bool, ConnectionError>

fn update_requested_at_sequence_id( &self, group_id: &[u8], installation_id: &[u8], sequence_id: i64, ) -> Result<(), ConnectionError>

Update the requested_at_sequence_id for a given group_id and installation_id, provided it is higher than the current value. Inserts the row if it doesn’t exist.

fn update_responded_at_sequence_id( &self, group_id: &[u8], installation_id: &[u8], sequence_id: i64, ) -> Result<(), ConnectionError>

Update the responded_at_sequence_id for a given group_id and installation_id, provided it is higher than the current value. Inserts the row if it doesn’t exist.

fn delete_other_readd_statuses( &self, group_id: &[u8], self_installation_id: &[u8], ) -> Result<(), ConnectionError>

fn delete_readd_statuses( &self, group_id: &[u8], installation_ids: HashSet<Vec<u8>>, ) -> Result<(), ConnectionError>

fn get_readds_awaiting_response( &self, group_id: &[u8], self_installation_id: &[u8], ) -> Result<Vec<ReaddStatus>, ConnectionError>

Implementations on Foreign Types

impl<T> QueryReaddStatus for &T

where T: QueryReaddStatus,

fn get_readd_status( &self, group_id: &[u8], installation_id: &[u8], ) -> Result<Option<ReaddStatus>, ConnectionError>

fn is_awaiting_readd( &self, group_id: &[u8], installation_id: &[u8], ) -> Result<bool, ConnectionError>

fn update_requested_at_sequence_id( &self, group_id: &[u8], installation_id: &[u8], sequence_id: i64, ) -> Result<(), ConnectionError>

fn update_responded_at_sequence_id( &self, group_id: &[u8], installation_id: &[u8], sequence_id: i64, ) -> Result<(), ConnectionError>

fn delete_other_readd_statuses( &self, group_id: &[u8], self_installation_id: &[u8], ) -> Result<(), ConnectionError>

fn delete_readd_statuses( &self, group_id: &[u8], installation_ids: HashSet<Vec<u8>>, ) -> Result<(), ConnectionError>

fn get_readds_awaiting_response( &self, group_id: &[u8], self_installation_id: &[u8], ) -> Result<Vec<ReaddStatus>, ConnectionError>

Implementors

impl QueryReaddStatus for MockDbQuery

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