type StreamReadState

mylsm-lsm-store@0.6.0.1 · src/SstStreamIo.bend:96

import Base
import mylsm-lsm-store@0.6.0.1/src/Sstable.bend as Sstable
import mylsm-lsm-store@0.6.0.1/src/SstFile.bend as SstFile
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes

96# Represent StreamReadState data used by the streaming SSTable filesystem effects.
97type StreamReadState is Type:
98  ReadHeader{file: File, size: Nat}
99  ReadHeaderResult{pair: File & Result<&1, &1, U32 & String, Bytes.Bytes>, size: Nat}
100  ReadBlocks{file: File, size: Nat, used: Nat, parser: SstFile.StreamState}
101  ReadBlockHeaderResult{pair: File & Result<&1, &1, U32 & String, Bytes.Bytes>,
102    size: Nat, used: Nat, parser: SstFile.StreamState}
103  ReadBlockBody{file: File, size: Nat, used: Nat,
104    parser: SstFile.StreamState, header: Bytes.Bytes, tail_len: U32}
105  ReadBlockBodyResult{pair: File & Result<&1, &1, U32 & String, Bytes.Bytes>,
106    size: Nat, used: Nat, parser: SstFile.StreamState,
107    header: Bytes.Bytes, tail_len: U32}
108  ReadFooterResult{pair: File & Result<&1, &1, U32 & String, Bytes.Bytes>,
109    size: Nat, used: Nat, parser: SstFile.StreamState}
110  ReadClose{file: File, result: Result<&1, &1, U32 & String, Sstable.Table>}