chore: mandatory read start_seq_num (#58)

re: s2-streamstore/s2-sdk-rust#97
s2-streamstore · Dec 5, 2024 · a5ea940 · a5ea940
1 parent d67d1ba
commit a5ea940
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -26,4 +26,4 @@ tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
 
 [dependencies.streamstore]
 git = "https://github.com/s2-streamstore/s2-sdk-rust.git"
-rev = "924594f84c33562aae67ee465dfd9cdfd9917230"
+rev = "b1547bcd55a4f3b5b76104a6ffd374014671d617"
diff --git a/src/main.rs b/src/main.rs
@@ -253,9 +253,9 @@ enum Commands {
         /// Name of the stream.
         stream: String,
 
-        /// Starting sequence number (inclusive). If not specified, the latest record.
-        #[arg(short = 's', long)]
-        start_seq_num: Option<u64>,
+        /// Starting sequence number (inclusive).
+        #[arg(short = 's', long, default_value_t = 0)]
+        start_seq_num: u64,
 
         /// Output records to a file or stdout.
         /// Use "-" to write to stdout.

diff --git a/src/stream.rs b/src/stream.rs
@@ -106,7 +106,7 @@ impl StreamService {
 
     pub async fn read_session(
         &self,
-        start_seq_num: Option<u64>,
+        start_seq_num: u64,
         limit_count: Option<u64>,
         limit_bytes: Option<u64>,
     ) -> Result<Streaming<ReadOutput>, ServiceError> {