tiny.sql.FileSparseReadOnlyDatabase

1pub const SparseReadOnlyDatabase = struct {2    storage: [@sizeOf(SparseReadOnlyState)]u8 align(@alignOf(SparseReadOnlyState)),34    pub fn openExisting(5        dir: std.Io.Dir,6        options: SparseReadOptions,7    ) Error!SparseReadOpenResult {8        var database: SparseReadOnlyDatabase = undefined;9        database.impl().* = .{10            .io = options.io,11            .scanner = try wal.Scanner.init(options.workspace),12            .frame_capacity = options.workspace.refs.len,13            .probe = options.probe,14        };15        errdefer database.deinit();16        if (try database.impl().activate(dir, options.paths, options.control)) |reason| {17            database.deinit();18            return .{ .repair_required = reason };19        }20        return .{ .ready = database };21    }2223    pub fn deinit(self: *SparseReadOnlyDatabase) void {24        self.impl().deinit();25        self.* = undefined;26    }2728    pub fn refresh(29        self: *SparseReadOnlyDatabase,30        dir: std.Io.Dir,31        options: SparseRefreshOptions,32    ) Error!SparseRefreshResult {33        return try self.impl().refresh(dir, options);34    }3536    pub fn snapshot(self: *SparseReadOnlyDatabase) Snapshot {37        const state = self.impl();38        std.debug.assert(state.active);39        return .{40            .source = .{ .sparse = .{41                .database = self,42                .generation = state.generation,43            } },44            .view = .{45                .base_generation = state.generation,46                .end_mark = state.scanner.progress().committed_end_mark,47            },48        };49    }5051    fn impl(self: *SparseReadOnlyDatabase) *SparseReadOnlyState {52        return @ptrCast(&self.storage);53    }54};

1pub const FileSparseReadOnlyDatabase = file.SparseReadOnlyDatabase;