Trait dynomite::DynamoDbExt

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

Extension methods for DynamoDb client types

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

Required methods

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

An auto-paginating Stream oriented version of list_backups

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

An auto-paginating Stream oriented version of list_tables

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

An auto-paginating Stream oriented version of query

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

An auto-paginating Stream oriented version of scan

Loading content...

Implementors

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

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

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

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

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

Loading content...