Skip to content

Commit d01a4db

Browse files
Merge pull request #39 from stefan-brus-frequenz/time_streaming
Add time filters to streaming requests
2 parents 37ab123 + 79f15f7 commit d01a4db

2 files changed

Lines changed: 10 additions & 2 deletions

File tree

RELEASE_NOTES.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,15 +2,15 @@
22

33
## Summary
44

5-
<!-- Here goes a general summary of what this release is about -->
5+
- Add time filter options to the streaming request, to allow for streaming of historical data.
66

77
## Upgrading
88

99
<!-- Here goes notes on how to upgrade from previous versions, including deprecations and what they should be replaced with -->
1010

1111
## New Features
1212

13-
<!-- Here goes the main new features and examples or instructions on how to use them -->
13+
- The streaming requests now contain optional `TimeFilter` objects for streaming historical data.
1414

1515
## Bug Fixes
1616

proto/frequenz/api/reporting/v1/reporting.proto

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -308,6 +308,10 @@ message ReceiveMicrogridComponentsDataStreamRequest {
308308

309309
// Include options specifying additional fields to be included in the response.
310310
IncludeOptions include_options = 2;
311+
312+
// Optional time-based filter criteria.
313+
// If omitted, data will start streaming from the timestamp that the request was received.
314+
TimeFilter time_filter = 3;
311315
}
312316

313317
// Encapsulates the microgrid ID and the component IDs within that microgrid for which
@@ -499,6 +503,10 @@ message ReceiveAggregatedMicrogridComponentsDataStreamRequest {
499503
// Optional resampling options like resolution for the data, represented in seconds.
500504
// If omitted, data will be returned in its original representation.
501505
ResamplingOptions resampling_options = 1;
506+
507+
// Optional time-based filter criteria.
508+
// If omitted, data will start streaming from the timestamp that the request was received.
509+
TimeFilter time_filter = 2;
502510
}
503511

504512
// List of pairs of metric and corresponding aggregation formula.

0 commit comments

Comments
 (0)