def admit.state.copies
mylsm-lsm-store@0.6.0.1 · src/coordinator/QueuePolicy.bend:123
import mylsm-lsm-store@0.6.0.1/src/coordinator/QueuePolicy.bend as QueuePolicy
import Base
123def admit.state.copies(
124 count_copies: Nat & Nat,
125 byte_copies: Nat & Nat,
126 request_bytes: Nat,
127 max_count: Nat,
128 max_queue_bytes: Nat
129) -> Admission:
130 match count_copies:
131 case (checked_count, retained_count):
132 match byte_copies:
133 case (checked_bytes, retained_bytes):
134 admit.state.result(Occupancy{retained_count, retained_bytes},
135 admit(checked_count, checked_bytes, request_bytes,
136 max_count, max_queue_bytes))