chore: update proto and associated types for non-optional `start_seq_…

…num` (#97)

src/client.rs

@@ -796,7 +796,7 @@ fn read_resumption_stream(
                     }
                     if let Ok(types::ReadOutput::Batch(types::SequencedRecordBatch { records })) = &item {
                         if let Some(record) = records.last() {
-                            request.set_start_seq_num(Some(record.seq_num + 1));
+                            request.set_start_seq_num(record.seq_num + 1);
                         }
                     }
                     yield item;

src/service/stream.rs

@@ -122,7 +122,7 @@ impl ReadSessionServiceRequest {
         }
     }
 
-    pub fn set_start_seq_num(&mut self, start_seq_num: Option<u64>) {
+    pub fn set_start_seq_num(&mut self, start_seq_num: u64) {
         self.req.start_seq_num = start_seq_num;
     }
 }

src/types.rs

@@ -1361,19 +1361,15 @@ pub struct ReadLimit {
 #[sync_docs]
 #[derive(Debug, Clone, Default)]
 pub struct ReadRequest {
-    pub start_seq_num: Option<u64>,
+    pub start_seq_num: u64,
     pub limit: Option<ReadLimit>,
 }
 
 impl ReadRequest {
-    pub fn new() -> Self {
-        Self::default()
-    }
-
-    pub fn with_start_seq_num(self, start_seq_num: impl Into<u64>) -> Self {
+    pub fn new(start_seq_num: u64) -> Self {
         Self {
-            start_seq_num: Some(start_seq_num.into()),
-            ..self
+            start_seq_num,
+            ..Default::default()
         }
     }
 
@@ -1532,19 +1528,15 @@ impl TryFrom<api::ReadResponse> for ReadOutput {
 #[sync_docs]
 #[derive(Debug, Clone, Default)]
 pub struct ReadSessionRequest {
-    pub start_seq_num: Option<u64>,
+    pub start_seq_num: u64,
     pub limit: Option<ReadLimit>,
 }
 
 impl ReadSessionRequest {
-    pub fn new() -> Self {
-        Self::default()
-    }
-
-    pub fn with_start_seq_num(self, start_seq_num: impl Into<u64>) -> Self {
+    pub fn new(start_seq_num: u64) -> Self {
         Self {
-            start_seq_num: Some(start_seq_num.into()),
-            ..self
+            start_seq_num,
+            ..Default::default()
         }
     }