Module cernan::filter::delay_filter [−][src]
Filter streams to within a bounded interval of current time.
This filter is intended to remove items from the stream which are too old,
as defined by the current time and the configured tolerance. That is, if
for some time T, (T - time::now()).abs() > tolerance the item associated
with T will be rejected.
Structs
| DelayFilter |
Filter streams to within a bounded interval of current time. |
| DelayFilterConfig |
Configuration for |
Statics
| DELAY_LOG_ACCEPT |
Total number of logline accepted for age |
| DELAY_LOG_REJECT |
Total number of logline rejected for age |
| DELAY_TELEM_ACCEPT |
Total number of telemetry accepted for age |
| DELAY_TELEM_REJECT |
Total number of telemetry rejected for age |