Trait QueryGroupVersion 

pub trait QueryGroupVersion {
    // Required methods
    fn set_group_paused(
        &self,
        group_id: &GroupId,
        min_version: &str,
    ) -> Result<(), StorageError>;
    fn unpause_group(&self, group_id: &GroupId) -> Result<(), StorageError>;
    fn get_group_paused_version(
        &self,
        group_id: &GroupId,
    ) -> Result<Option<String>, StorageError>;
    fn get_paused_groups_with_versions(
        &self,
    ) -> Result<Vec<(GroupId, String)>, StorageError>;
}

Required Methods

fn set_group_paused( &self, group_id: &GroupId, min_version: &str, ) -> Result<(), StorageError>

fn unpause_group(&self, group_id: &GroupId) -> Result<(), StorageError>

fn get_group_paused_version( &self, group_id: &GroupId, ) -> Result<Option<String>, StorageError>

fn get_paused_groups_with_versions( &self, ) -> Result<Vec<(GroupId, String)>, StorageError>

Return every group currently flagged as paused, with the paused_for_version floor it’s pinned to. Used by the startup/sweep recovery path to re-evaluate paused groups against the now-current pkg_version without having to sync each group individually.

Implementations on Foreign Types

impl<T> QueryGroupVersion for &T

where T: QueryGroupVersion,

fn set_group_paused( &self, group_id: &GroupId, min_version: &str, ) -> Result<(), StorageError>

fn unpause_group(&self, group_id: &GroupId) -> Result<(), StorageError>

fn get_group_paused_version( &self, group_id: &GroupId, ) -> Result<Option<String>, StorageError>

fn get_paused_groups_with_versions( &self, ) -> Result<Vec<(GroupId, String)>, StorageError>

Implementors

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