def snapshot.cursor.open.decision

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

import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/Client.bend as Client
import mylsm-lsm-store@0.6.0.1/src/coordinator/OwnerCursorCodec.bend as OwnerCursorCodec

294# Maps one pure open-response decision into a client result.
295def snapshot.cursor.open.decision(
296  decision: OwnerCursorCodec.OpenDecision
297) -> Result<&1, &1, Client.Error, U32>:
298  match decision:
299    case OwnerCursorCodec.Opened{cursor_id}: Done{cursor_id}
300    case OwnerCursorCodec.OpenRejected{status}:
301      Fail{Client.OwnerRejected{status}}
302    case OwnerCursorCodec.OpenMalformed{}:
303      Fail{Client.MalformedResponse{}}