def write_batch.measured

mylsm-lsm-store@0.6.0.1 · src/ByteDurableDb.bend:1894

import Base
import mylsm-lsm-store@0.6.0.1/src/DurableBatchPolicy.bend as BatchPolicy
import mylsm-lsm-store@0.6.0.1/src/coordinator/QueuePolicy.bend as QueuePolicy

1894def write_batch.measured(
1895  handle: Handle,
1896  measured: BatchPolicy.ByteBatchMeasurement
1897) -> IO(Handle & Result<&1, &1, Error, Unit>):
1898  match measured:
1899    case BatchPolicy.BatchMeasured{mutations, count, encoded_bytes}:
1900      write_batch.validation.counted(handle, mutations,
1901        QueuePolicy.nat.clone.pair(count), encoded_bytes)
1902    case BatchPolicy.BatchTooMany{}:
1903      IO.pure(Handle & Result<&1, &1, Error, Unit>,
1904        (handle, Fail{ResourceLimit{}}))