RequestQueue.enqueue.with.metrics: def of mylsm-lsm-store@0.6.0.1
Import: import mylsm-lsm-store@0.6.0.1/src/coordinator/RequestQueue.bend as RequestQueue
Lines 124-136 of mylsm-lsm-store@0.6.0.1/src/coordinator/RequestQueue.bend: https://jend.leeeet.dev/read.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/RequestQueue.bend&start_line=124&end_line=136

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

def enqueue.with.metrics(
  pending: Pending,
  request_bytes: Nat,
  limits: Nat & Nat,
  metrics: Queue & Nat & Nat
) -> Admission:
  match limits:
    case (max_count, max_bytes):
      match metrics:
        case (retained_queue, (count, bytes)):
          enqueue.result(retained_queue, pending,
            Policy.admit.state(Policy.Occupancy{count, bytes},
              request_bytes, max_count, max_bytes))

Uses (9):
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Nat
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Pair
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Sigma
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/QueuePolicy.bend&name=State
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/QueuePolicy.bend&name=admit.state
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/RequestQueue.bend&name=Admission
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/RequestQueue.bend&name=Pending
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/RequestQueue.bend&name=Queue
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/RequestQueue.bend&name=enqueue.result