Trait dynomite::DynamoDbExt

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

Extension methods for DynamoDb client types

A default impl is provided for Arc instances of DynamoDb which adds automatinting Stream interfaces that require taking ownership. In practice clone your Arc'd client when calling the stream methods.

Required methods

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

An auto-paginating Stream oriented version of list_backups

fn list_tables_pages(
    self,
    input: ListTablesInput
) -> Box<dyn Stream<Item = String, Error = 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 = QueryError> + Send>

An auto-paginating Stream oriented version of query

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

An auto-paginating Stream oriented version of scan

Loading content...

Implementations on Foreign Types

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

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

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

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

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

Loading content...

Implementors

Loading content...