Struct Shard 

pub struct Shard { /* private fields */ }

A shard representation to retreive DynamoDB Streams records.

Implementations

impl Shard

pub fn new(shard: Shard) -> Option<Self>

Create a new shard from aws_sdk_dynamodbstreams::types::Shard. If the input’s shard_id is None, this method also returns None.

use aws_sdk_dynamodbstreams as dynamodbstreams;
use dynamo_subscriber::types::Shard;

// Create a aws_sdk_dynamodbstreams's Shard with shard_id
let original = dynamodbstreams::types::Shard::builder()
    .shard_id("0001")
    .build();
assert!(original.shard_id().is_some());

// This case, the shard should exist.
let shard = Shard::new(original);
assert!(shard.is_some());

// Create a aws_sdk_dynamodbstreams's Shard without shard_id
let original = dynamodbstreams::types::Shard::builder()
    .build();
assert!(original.shard_id().is_none());

// This case, the shard should not exist.
let shard = Shard::new(original);
assert!(shard.is_none());

pub fn id(&self) -> &str

Return the shard id.

pub fn iterator(&self) -> Option<&str>

Return the shard iterator id.

pub fn parent_shard_id(&self) -> Option<&str>

Return the parent shard id.

pub fn set_iterator(self, iterator: Option<String>) -> Option<Self>

Return Option<Shard> with passed shard iterator id. Setting None as the shard iterator means the shard drops because None shard iterator will get no records from the DynamoDB Table.

Trait Implementations

impl Clone for Shard

fn clone(&self) -> Shard

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Shard

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

Formats the value using the given formatter.