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))

Uses (7)

Used by (1)