def pending.head.metadata
mylsm-lsm-store@0.6.0.1 · src/coordinator/RequestQueue.bend:234
import mylsm-lsm-store@0.6.0.1/src/coordinator/RequestQueue.bend as RequestQueue
import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/QueuePolicy.bend as Policy
234def pending.head.metadata(pending: Pending)
235 -> Pending & HeadMetadata:
236 match pending:
237 case Pending{connection_id, accepted_sequence, deadline_ms,
238 encoded_bytes, response_peak, request}:
239 pending.head.metadata.values(u32.clone.pair(connection_id),
240 Policy.nat.clone.pair(accepted_sequence),
241 Policy.nat.clone.pair(deadline_ms),
242 Policy.nat.clone.pair(encoded_bytes),
243 Policy.nat.clone.pair(response_peak),
244 request.opcode.copy(request))