src/CompactIo.bend relies on unsafe/foreign

raw source on the hub · import mylsm-lsm-store@0.4.0.0/src/CompactIo.bend as CompactIo

11 imports

import Base
import ./Compact.bend as Compact
import ./MemTable.bend as MemTable
import ./Sstable.bend as Sstable
import ./SstStreamIo.bend as SstStreamIo
import ./Wal.bend as Wal
import ./Manifest.bend as Manifest
import ./Flush.bend as Flush
import ./Fs.bend as Fs
import ./Db.bend as Db
import ./CrashPoint.bend as CrashPoint

Definitions

def remove_list source · line 14 · raw

@names:List<&2, String> -> IO(Result<&1, &1, Pair(U32, String), Unit>)

Handle remove list in the compaction filesystem effects.

def compact_goB source · line 24 · raw

@+dir:String -> @+mpath:String -> @+mtmp:String -> @+m2:0x571fd57004366c423dfd4b51196743b5/src/Manifest.Manifest -> @+dels:List<&2, String> -> @+mem:0x571fd57004366c423dfd4b51196743b5/src/MemTable.MemTable -> @+levels2:List<&2, List<&2, 0x571fd57004366c423dfd4b51196743b5/src/Sstable.Table>> -> @+flushed:Nat -> @+frozen:0x571fd57004366c423dfd4b51196743b5/src/MemTable.MemTable -> @+batch_cap:Nat -> @+mem_count:Nat -> @+frozen_count:Nat -> IO(Result<&1, &1, Pair(U32, String), 0x571fd57004366c423dfd4b51196743b5/src/Db.Db>)

Compact goB for the compaction filesystem effects.

def drift_go source · line 48 · raw

@ok:Bool -> @+dir:String -> @+mpath:String -> @+mtmp:String -> @+mfst:0x571fd57004366c423dfd4b51196743b5/src/Manifest.Manifest -> @+oldl1:List<&2, 0x571fd57004366c423dfd4b51196743b5/src/Sstable.Table> -> @+remt:List<&2, 0x571fd57004366c423dfd4b51196743b5/src/Sstable.Table> -> @+outname:String -> @+mem:0x571fd57004366c423dfd4b51196743b5/src/MemTable.MemTable -> @+levels2:List<&2, List<&2, 0x571fd57004366c423dfd4b51196743b5/src/Sstable.Table>> -> @+flushed:Nat -> @+frozen:0x571fd57004366c423dfd4b51196743b5/src/MemTable.MemTable -> @+batch_cap:Nat -> @+mem_count:Nat -> @+frozen_count:Nat -> IO(Result<&1, &1, Pair(U32, String), 0x571fd57004366c423dfd4b51196743b5/src/Db.Db>)

Handle drift go in the compaction filesystem effects.

def compact_goA source · line 75 · raw

@+dir:String -> @+l1dir:String -> @+tmp:String -> @+final:String -> @+mpath:String -> @+mtmp:String -> @+entries:List<&2, 0x571fd57004366c423dfd4b51196743b5/src/MemTable.Entry> -> @+level:U32 -> @+outname:String -> @+mem:0x571fd57004366c423dfd4b51196743b5/src/MemTable.MemTable -> @+levels2:List<&2, List<&2, 0x571fd57004366c423dfd4b51196743b5/src/Sstable.Table>> -> @+oldl1:List<&2, 0x571fd57004366c423dfd4b51196743b5/src/Sstable.Table> -> @+remt:List<&2, 0x571fd57004366c423dfd4b51196743b5/src/Sstable.Table> -> @+flushed:Nat -> @+manifest_token:String -> @+frozen:0x571fd57004366c423dfd4b51196743b5/src/MemTable.MemTable -> @+batch_cap:Nat -> @+mem_count:Nat -> @+frozen_count:Nat -> IO(Result<&1, &1, Pair(U32, String), 0x571fd57004366c423dfd4b51196743b5/src/Db.Db>)

Compact goA for the compaction filesystem effects.

def compact_pre source · line 107 · raw

@+dir:String -> @+mem:0x571fd57004366c423dfd4b51196743b5/src/MemTable.MemTable -> @+levels:List<&2, List<&2, 0x571fd57004366c423dfd4b51196743b5/src/Sstable.Table>> -> @+flushed:Nat -> @+manifest_token:String -> @+frozen:0x571fd57004366c423dfd4b51196743b5/src/MemTable.MemTable -> @+batch_cap:Nat -> @+mem_count:Nat -> @+frozen_count:Nat -> IO(Result<&1, &1, Pair(U32, String), 0x571fd57004366c423dfd4b51196743b5/src/Db.Db>)

Compact pre for the compaction filesystem effects.

def compact_trig source · line 133 · raw

@gt:Bool -> @+dir:String -> @+mem:0x571fd57004366c423dfd4b51196743b5/src/MemTable.MemTable -> @+levels:List<&2, List<&2, 0x571fd57004366c423dfd4b51196743b5/src/Sstable.Table>> -> @+flushed:Nat -> @+manifest_token:String -> @+frozen:0x571fd57004366c423dfd4b51196743b5/src/MemTable.MemTable -> @+batch_cap:Nat -> @+bcache:List<&2, 0x571fd57004366c423dfd4b51196743b5/src/Db.BEntry> -> @+mem_count:Nat -> @+frozen_count:Nat -> IO(Result<&1, &1, Pair(U32, String), 0x571fd57004366c423dfd4b51196743b5/src/Db.Db>)

Compact trig for the compaction filesystem effects.

def compact source · line 153 · raw

@+db:0x571fd57004366c423dfd4b51196743b5/src/Db.Db -> IO(Result<&1, &1, Pair(U32, String), 0x571fd57004366c423dfd4b51196743b5/src/Db.Db>)

Handle compact in the compaction filesystem effects.