Trait KinesisClientTrait

pub trait KinesisClientTrait: Send + Sync {
    // Required methods
    fn list_shards<'life0, 'life1, 'async_trait>(
        &'life0 self,
        stream_name: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<Shard>, KinesisClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn get_shard_iterator<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
        &'life0 self,
        stream_name: &'life1 str,
        shard_id: &'life2 str,
        iterator_type: ShardIteratorType,
        sequence_number: Option<&'life3 str>,
        timestamp: Option<&'life4 DateTime<Utc>>,
    ) -> Pin<Box<dyn Future<Output = Result<String, KinesisClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait,
             'life4: 'async_trait;
    fn get_records<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        iterator: &'life1 str,
        limit: i32,
        retry_count: u32,
        max_retries: Option<u32>,
        shutdown: &'life2 mut Receiver<bool>,
    ) -> Pin<Box<dyn Future<Output = Result<(Vec<Record>, Option<String>), KinesisClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
}

Required Methods

fn list_shards<'life0, 'life1, 'async_trait>( &'life0 self, stream_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Shard>, KinesisClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List all shards in the stream

fn get_shard_iterator<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, stream_name: &'life1 str, shard_id: &'life2 str, iterator_type: ShardIteratorType, sequence_number: Option<&'life3 str>, timestamp: Option<&'life4 DateTime<Utc>>, ) -> Pin<Box<dyn Future<Output = Result<String, KinesisClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Get a shard iterator

fn get_records<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, iterator: &'life1 str, limit: i32, retry_count: u32, max_retries: Option<u32>, shutdown: &'life2 mut Receiver<bool>, ) -> Pin<Box<dyn Future<Output = Result<(Vec<Record>, Option<String>), KinesisClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Get records from the stream

Implementations on Foreign Types

impl KinesisClientTrait for Client

fn list_shards<'life0, 'life1, 'async_trait>( &'life0 self, stream_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Shard>, KinesisClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn get_shard_iterator<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, stream_name: &'life1 str, shard_id: &'life2 str, iterator_type: ShardIteratorType, sequence_number: Option<&'life3 str>, timestamp: Option<&'life4 DateTime<Utc>>, ) -> Pin<Box<dyn Future<Output = Result<String, KinesisClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

fn get_records<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, iterator: &'life1 str, limit: i32, retry_count: u32, max_retries: Option<u32>, shutdown: &'life2 mut Receiver<bool>, ) -> Pin<Box<dyn Future<Output = Result<(Vec<Record>, Option<String>), KinesisClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Implementors