Add size() to BaseDb
This commit is contained in:
@@ -74,6 +74,10 @@ export default class FileFlatDb implements BaseDb {
|
||||
this._fileSize = fs.fstatSync(this._fd).size;
|
||||
}
|
||||
|
||||
size (): number {
|
||||
return this._fileSize;
|
||||
}
|
||||
|
||||
rename (base: string, file: string): void {
|
||||
assert(this._fd === -1, 'Database cannot be open for renaming');
|
||||
|
||||
|
||||
@@ -58,6 +58,12 @@ export default class FileTreeDb implements BaseDb {
|
||||
l.error('rename() is not implemented');
|
||||
}
|
||||
|
||||
size (): number {
|
||||
l.error('size() is not implemented');
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
maintain (fn: ProgressCb): void {
|
||||
fn({
|
||||
isCompleted: true,
|
||||
|
||||
@@ -53,6 +53,10 @@ export default class LruDb implements BaseDb {
|
||||
this.backing.maintain(fn);
|
||||
}
|
||||
|
||||
size (): number {
|
||||
return this.backing.size();
|
||||
}
|
||||
|
||||
del (key: Uint8Array): void {
|
||||
const keyStr = key.toString();
|
||||
|
||||
|
||||
@@ -43,6 +43,12 @@ export default class MemoryDb implements BaseDb {
|
||||
});
|
||||
}
|
||||
|
||||
size (): number {
|
||||
l.error('size() is not implemented');
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
del (key: Uint8Array): void {
|
||||
l.debug(() => ['del', { key }]);
|
||||
|
||||
|
||||
@@ -72,6 +72,10 @@ export default class TransactionDb implements TxDb {
|
||||
this.backing.maintain(fn);
|
||||
}
|
||||
|
||||
size (): number {
|
||||
return this.backing.size();
|
||||
}
|
||||
|
||||
del (key: Uint8Array): void {
|
||||
if (this.txStarted) {
|
||||
this.txOverlay[key.toString()] = {
|
||||
|
||||
Vendored
+2
-2
@@ -18,9 +18,9 @@ export interface BaseDb {
|
||||
close (): void;
|
||||
open (): void;
|
||||
empty (): void;
|
||||
rename (base: string, file: string): void;
|
||||
|
||||
maintain (fn: ProgressCb): void;
|
||||
rename (base: string, file: string): void;
|
||||
size (): number;
|
||||
|
||||
del (key: Uint8Array): void;
|
||||
get (key: Uint8Array): Uint8Array | null;
|
||||
|
||||
Reference in New Issue
Block a user