def Ctl.dispatch.put

bend-kube-runtime@0.2.0.0 · src/runtime.bend:426

import Base
import bend-kube-runtime@0.2.0.0/src/json.bend as J
import bend-kube-runtime@0.2.0.0/src/queue.bend as Q

426def Ctl.dispatch.put(+key: String, m: Maybe<&2, J.Json>, q: Q.Queue, jobs: List<&2, Job>) ->
427  Q.Queue & List<&2, Job>:
428  match m:
429    case Some{o}:
430      (q, Job{key, o} <> jobs)
431    case None{}:
432      # gone from the store: nothing to reconcile
433      Ctl.dispatch.drop(Q.Queue.done(q, key, Q.AwaitChange{}), jobs)