~/bend-docscommunity

src/DbIo.bend relies on unsafe/foreign

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

6 imports
import Base
import ./Db.bend as Db
import ./Wal.bend as Wal
import ./Fs.bend as Fs
import ./CrashPoint.bend as CrashPoint
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes

Definitions

def wal_tail source · line 12 · raw

@fr:Pair(File, Result<&1, &1, Pair(U32, String), Unit>) -> @+dir:String -> IO(Result<&1, &1, Pair(U32, String), Unit>)

Handle wal tail in the database filesystem effects.

def wal.initialize.synced source · line 24 · raw

@result:Result<&1, &1, Pair(U32, String), Unit> -> @+path:String -> IO(Result<&1, &1, Pair(U32, String), Unit>)

def wal.initialize.written source · line 37 · raw

@pair:Pair(File, Result<&1, &1, Pair(U32, String), Unit>) -> @+path:String -> IO(Result<&1, &1, Pair(U32, String), Unit>)

def wal.initialize.header source · line 47 · raw

@+path:String -> IO(Result<&1, &1, Pair(U32, String), Unit>)

def wal.initialize.header_if_empty source · line 53 · raw

@empty:Bool -> @+path:String -> IO(Result<&1, &1, Pair(U32, String), Unit>)

def wal.initialize.existing source · line 63 · raw

@result:Result<&1, &1, Pair(U32, String), Nat> -> @+path:String -> IO(Result<&1, &1, Pair(U32, String), Unit>)

def wal.initialize.present source · line 73 · raw

@present:Bool -> @+path:String -> IO(Result<&1, &1, Pair(U32, String), Unit>)

def wal_initialize source · line 86 · raw

@+dir:String -> IO(Result<&1, &1, Pair(U32, String), Unit>)

Handle wal initialize in the database filesystem effects.

def wal_encoded source · line 92 · raw

@+dir:String -> @result:Result<&1, &1, 0x571fd57004366c423dfd4b51196743b5/src/Wal.Error, 0x185ae03c75e3e75be1171471f68b43cb/bytes.Bytes> -> IO(Result<&1, &1, Pair(U32, String), Unit>)

Handle wal encoded in the database filesystem effects.

def wal_append source · line 107 · raw

@+dir:String -> @batch:0x571fd57004366c423dfd4b51196743b5/src/Wal.Batch -> IO(Result<&1, &1, Pair(U32, String), Unit>)

Handle wal append in the database filesystem effects.

def db_write source · line 111 · raw

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

Handle db write in the database filesystem effects.

def db_put source · line 121 · raw

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

Handle db put in the database filesystem effects.

def db_write_staged source · line 125 · raw

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

Handle db write staged in the database filesystem effects.

def db_del source · line 131 · raw

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

Handle db del in the database filesystem effects.