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 |