def enqueue.with.metrics

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

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

124def enqueue.with.metrics(
125  pending: Pending,
126  request_bytes: Nat,
127  limits: Nat & Nat,
128  metrics: Queue & Nat & Nat
129) -> Admission:
130  match limits:
131    case (max_count, max_bytes):
132      match metrics:
133        case (retained_queue, (count, bytes)):
134          enqueue.result(retained_queue, pending,
135            Policy.admit.state(Policy.Occupancy{count, bytes},
136              request_bytes, max_count, max_bytes))