def enqueue.result

mylsm-lsm-store@0.6.0.1 · src/coordinator/RequestQueue.bend:108

import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/QueuePolicy.bend as Policy

108def enqueue.result(
109  queue: Queue,
110  pending: Pending,
111  decision: Policy.Admission
112) -> Admission:
113  match decision:
114    case Policy.Enqueued{Policy.Occupancy{count, bytes}}:
115      enqueue.accepted(queue, pending, count, bytes)
116    case Policy.Rejected{_, reason}:
117      Rejected{queue, pending, reason}