Moved client out of Config struct

src/iterator.rs

@@ -18,6 +18,7 @@ pub fn latest<'a, K: StreamClient>(
 }
 
 pub fn at_sequence<'a, K: StreamClient>(
+    client: &'a K,
     client: &'a K,
     config: &'a ShardProcessorConfig,
     starting_sequence_number: &'a str,
@@ -30,6 +31,7 @@ pub fn at_sequence<'a, K: StreamClient>(
 }
 
 pub fn at_timestamp<'a, K: StreamClient>(
+    client: &'a K,
     client: &'a K,
     config: &'a ShardProcessorConfig,
     timestamp: &'a chrono::DateTime<Utc>,
@@ -42,17 +44,20 @@ pub fn at_timestamp<'a, K: StreamClient>(
 }
 
 pub struct LatestShardIterator<'a, K: StreamClient> {
+    client: &'a K,
     client: &'a K,
     config: &'a ShardProcessorConfig,
 }
 
 pub struct AtSequenceShardIterator<'a, K: StreamClient> {
+    client: &'a K,
     client: &'a K,
     config: &'a ShardProcessorConfig,
     starting_sequence_number: &'a str,
 }
 
 pub struct AtTimestampShardIterator<'a, K: StreamClient> {
+    client: &'a K,
     client: &'a K,
     config: &'a ShardProcessorConfig,
     timestamp: &'a chrono::DateTime<Utc>,

src/kinesis.rs

@@ -24,6 +24,8 @@ pub mod ticker;
 pub trait IteratorProvider<K: StreamClient>: Send + Sync {
     fn get_client(&self) -> &K;
 
+    fn get_client(&self) -> &K;
+
     fn get_config(&self) -> &ShardProcessorConfig;
 
     async fn get_iterator(&self) -> Result<GetShardIteratorOutput>;

src/kinesis/models.rs

@@ -57,12 +57,14 @@ pub struct ShardProcessorConfig {
 
 #[derive(Clone)]
 pub struct ShardProcessorLatest<K: StreamClient> {
+    pub client: K,
     pub client: K,
     pub config: ShardProcessorConfig,
 }
 
 #[derive(Clone)]
 pub struct ShardProcessorAtTimestamp<K: StreamClient> {
+    pub client: K,
     pub client: K,
     pub config: ShardProcessorConfig,
     pub from_datetime: chrono::DateTime<Utc>,