fix(api): update fetch stream url (#236)

* fix(api): update fetch stream url
reinfer · Nov 1, 2023 · 45cb013 · 45cb013
1 parent 3e94d53
commit 45cb013
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 0 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,7 @@
+## Unreleased
+- Fix url used for fetching streams
+- Return `is_end_sequence` on stream fetch
+
 ## v0.20.0
 
 - Add ability to get dataset stats

diff --git a/api/src/lib.rs b/api/src/lib.rs
@@ -1308,7 +1308,9 @@ impl Endpoints {
                 "v1",
                 "datasets",
                 &stream_name.dataset.0,
+                "streams",
                 &stream_name.stream.0,
+                "fetch",
             ],
         )
     }

diff --git a/api/src/resources/stream.rs b/api/src/resources/stream.rs
@@ -134,6 +134,7 @@ pub struct Batch {
     pub results: Vec<StreamResult>,
     pub filtered: u32,
     pub sequence_id: SequenceId,
+    pub is_end_sequence: bool,
 }
 
 #[derive(Debug, Clone, Serialize, Deserialize)]