description: "Only list tasks since this UNIX epoch.",
optional: true,
},
+ until: {
+ type: i64,
+ description: "Only list tasks until this UNIX epoch.",
+ optional: true,
+ },
typefilter: {
optional: true,
type: String,
running: bool,
userfilter: Option<String>,
since: Option<i64>,
+ until: Option<i64>,
typefilter: Option<String>,
statusfilter: Option<Vec<TaskStateType>>,
param: Value,
let limit = if limit > 0 { limit as usize } else { usize::MAX };
let result: Vec<TaskListItem> = list
+ .skip_while(|info| {
+ match (info, until) {
+ (Ok(info), Some(until)) => info.upid.starttime > until,
+ (Ok(_), None) => false,
+ (Err(_), _) => false,
+ }
+ })
.take_while(|info| {
match (info, since) {
(Ok(info), Some(since)) => info.upid.starttime > since,