Skip to content

Commit 0d33635

Browse files
chore: add schema to dataset api response (#1260)
1 parent 6fe35a6 commit 0d33635

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/prism/logstream/mod.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -204,6 +204,8 @@ pub struct PrismDatasetResponse {
204204
stream: String,
205205
/// Basic information about the stream
206206
info: StreamInfo,
207+
/// Schema of the stream
208+
schema: Arc<Schema>,
207209
/// Statistics for the queried timeframe
208210
stats: QueriedStats,
209211
/// Retention policy details
@@ -268,9 +270,9 @@ impl PrismDatasetRequest {
268270

269271
let PrismLogstreamInfo {
270272
info,
273+
schema,
271274
stats,
272275
retention,
273-
..
274276
} = get_prism_logstream_info(stream).await?;
275277

276278
let hottier = match HotTierManager::global() {
@@ -304,6 +306,7 @@ impl PrismDatasetRequest {
304306
responses.push(PrismDatasetResponse {
305307
stream: stream.clone(),
306308
info,
309+
schema,
307310
stats,
308311
retention,
309312
hottier,

0 commit comments

Comments
 (0)