Trait dynomite::DynamoDbExt

pub trait DynamoDbExt {
    fn list_backups_pages(
        self, 
        input: ListBackupsInput
    ) -> Pin<Box<dyn Stream<Item = Result<BackupSummary, RusotoError<ListBackupsError>>> + Send>>;
    fn list_tables_pages(
        self, 
        input: ListTablesInput
    ) -> Pin<Box<dyn Stream<Item = Result<String, RusotoError<ListTablesError>>> + Send>>;
    fn query_pages(
        self, 
        input: QueryInput
    ) -> Pin<Box<dyn Stream<Item = Result<HashMap<String, AttributeValue>, RusotoError<QueryError>>> + Send>>;
    fn scan_pages(
        self, 
        input: ScanInput
    ) -> Pin<Box<dyn Stream<Item = Result<HashMap<String, AttributeValue>, RusotoError<ScanError>>> + Send>>;
}

Extension methods for DynamoDb client types

A default impl is provided for DynamoDb Clone + Send + Sync + 'static which adds autopaginating Stream interfaces that require taking ownership.

Required methods

fn list_backups_pages(
    self,
    input: ListBackupsInput
) -> Pin<Box<dyn Stream<Item = Result<BackupSummary, RusotoError<ListBackupsError>>> + Send>>

An auto-paginating Stream oriented version of list_backups

fn list_tables_pages(
    self,
    input: ListTablesInput
) -> Pin<Box<dyn Stream<Item = Result<String, RusotoError<ListTablesError>>> + Send>>

An auto-paginating Stream oriented version of list_tables

fn query_pages(
    self,
    input: QueryInput
) -> Pin<Box<dyn Stream<Item = Result<HashMap<String, AttributeValue>, RusotoError<QueryError>>> + Send>>

An auto-paginating Stream oriented version of query

fn scan_pages(
    self,
    input: ScanInput
) -> Pin<Box<dyn Stream<Item = Result<HashMap<String, AttributeValue>, RusotoError<ScanError>>> + Send>>

An auto-paginating Stream oriented version of scan

Implementors

impl<D> DynamoDbExt for D where
    D: DynamoDb + Clone + Send + Sync + 'static, 

fn list_backups_pages(
    self,
    input: ListBackupsInput
) -> Pin<Box<dyn Stream<Item = Result<BackupSummary, RusotoError<ListBackupsError>>> + Send>>

fn list_tables_pages(
    self,
    input: ListTablesInput
) -> Pin<Box<dyn Stream<Item = Result<String, RusotoError<ListTablesError>>> + Send>>

fn query_pages(
    self,
    input: QueryInput
) -> Pin<Box<dyn Stream<Item = Result<HashMap<String, AttributeValue>, RusotoError<QueryError>>> + Send>>

fn scan_pages(
    self,
    input: ScanInput
) -> Pin<Box<dyn Stream<Item = Result<HashMap<String, AttributeValue>, RusotoError<ScanError>>> + Send>>