File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed
Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff 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,
You can’t perform that action at this time.
0 commit comments