def call.request.size

mylsm-lsm-store@0.6.0.1 · src/coordinator/Client.bend:321

import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/ClientPolicy.bend as Policy
import mylsm-lsm-store@0.6.0.1/src/coordinator/Protocol.bend as Protocol
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes

321def call.request.size(
322  endpoint: String,
323  fields: U32 & U32 & U32 & U32 & U32,
324  generation: U32,
325  measured_payload: Bytes.Bytes & U32
326) -> IO(Result<&1, &1, Error, Protocol.Response>):
327  match fields:
328    case (version, (request_generation, (request_id,
329        (policy_operation, wire_operation)))):
330      match measured_payload:
331        case (payload, length):
332          call.admitted(endpoint,
333            Protocol.Request{version, request_generation, request_id,
334              wire_operation, payload}, generation,
335            Policy.operation.is_mutation(policy_operation),
336            Policy.request.within_payload_limit(length))