Authors: : Ulf Wiger (ulf@wiger.net
).
entry() = {timestamp(), job()}
info_item() = max_time | oldest_job | length
job() = {pid(), reference()}
all/1 | |
delete/1 | |
empty/1 | |
in/3 | |
info/2 | |
is_empty/1 | |
new/2 | |
out/2 | |
peek/1 | |
representation/1 | |
timedout/1 | |
timedout/2 |
all(Queue::#queue{}) -> [entry()]
delete(Queue) -> any()
empty(Queue) -> any()
in(TS::timestamp(), Job::job(), Queue::#queue{}) -> #queue{}
info(X1::info_item(), Queue::#queue{}) -> any()
is_empty(Queue::#queue{}) -> boolean()
new(Options, Q) -> any()
out(N::integer(), Queue::#queue{}) -> {[entry()], #queue{}}
peek(Queue) -> any()
representation(Queue) -> any()
timedout(Queue::#queue{}) -> {[entry()], #queue{}}
timedout(TO, Queue) -> any()