def request.cursor.identifier

mylsm-lsm-store@0.6.0.1 · src/coordinator/RequestQueue.bend:294

import Base
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

294def request.cursor.identifier(request: Protocol.Request)
295  -> Protocol.Request & Maybe<&2, U32>:
296  match request:
297    case Protocol.Request{version, generation, request_id, operation,
298        payload}:
299      match operation:
300        case 13:
301          request.cursor.identifier.read(version, generation, request_id,
302            Bytes.get.u32be(payload, 0))
303        case opcode:
304          (Protocol.Request{version, generation, request_id, opcode,
305            payload}, None{})