def Queue.add

bend-kube-runtime@0.2.0.0 · src/queue.bend:81

import Base

81# Queues key unless it waits already; a running key is marked dirty
82# instead. Either way its pending timer, if any, goes stale.
83def Queue.add(q: Queue, +key: String) -> Queue:
84  match q:
85    case Queue{f, b, +inq, +run, d, +g, fl, n, mx}:
86      Queue.add.go(f, b, inq, run, d, Mp.bump(g, key), fl, n, mx, key, Mp.has(run, key),
87        Mp.has(inq, key))