~/jendhub

def Queue.arm

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

import bend-kube-runtime@0.2.0.0/src/queue.bend as Queue
import Base

173# Starts a timer for key, staling any earlier one.
174def Queue.arm(q: Queue, +key: String, ms: U32) -> Queue & List<&2, Timer>:
175  match q:
176    case Queue{f, b, i, r, d, +g, fl, n, mx}:
177      (Queue{f, b, i, r, d, Mp.bump(g, key), fl, n, mx},
178        [Timer{key, (Mp.get(g, key) + 1 : U32), ms}])

Uses (10)

Used by (1)