Struct dynamo_subscriber::types::Lineages

pub struct Lineages(/* private fields */);

A representation of group of shard lineage(parent and children).

Implementations

impl Lineages

pub async fn get_records<Client>( self, client: Arc<Client> ) -> (Vec<Shard>, Vec<Record>)where Client: DynamodbClient + 'static,

Get records in the correct order and shards with renewed shard iterator ids.

Each lineage is processed in the correct order (parent shard is processed before the children), and lineages without any releationships are processed concurrently.

Returned records are sorted by its sequence number.

Trait Implementations

impl Clone for Lineages

fn clone(&self) -> Lineages

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Lineages

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<Vec<Shard>> for Lineages

fn from(shards: Vec<Shard>) -> Self

Converts to this type from the input type.