diff options
author | EuAndreh <eu@euandre.org> | 2025-02-08 10:10:01 -0300 |
---|---|---|
committer | EuAndreh <eu@euandre.org> | 2025-02-08 10:10:01 -0300 |
commit | 3e518232f84b4471e065cde33f5d599e9f060964 (patch) | |
tree | 258ed66a52f001d15cee8e52796de15ab4b2d00f /src/dedo.go | |
parent | src/dedo.go: Comment implementation of InMemory (diff) | |
download | dedo-3e518232f84b4471e065cde33f5d599e9f060964.tar.gz dedo-3e518232f84b4471e065cde33f5d599e9f060964.tar.xz |
src/dedo.go: Rename DedoI -> DatabaseI
Diffstat (limited to 'src/dedo.go')
-rw-r--r-- | src/dedo.go | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/dedo.go b/src/dedo.go index baf0d37..e69dbd4 100644 --- a/src/dedo.go +++ b/src/dedo.go @@ -138,7 +138,7 @@ type TransactionI interface{ OnCommit(func()) } -type DedoI interface{ +type DatabaseI interface{ Close() error View (func(tx SnapshotI) error) error Update(func(tx TransactionI) error) error @@ -330,7 +330,7 @@ type argsT struct{ type commandT struct{ name string getopt func(argsT, io.Writer) (argsT, bool) - exec func(argsT, DedoI, io.Reader, io.Writer) error + exec func(argsT, DatabaseI, io.Reader, io.Writer) error } @@ -1755,14 +1755,14 @@ func (m *InMemory) View(func(SnapshotI) error) error { return nil } -func OpenMemory() DedoI { +func OpenMemory() DatabaseI { return &InMemory{pds.NewMap[[]byte, *Bucket](nil)} } */ /// Open creates and opens a database at the given path. If the file does not /// exist then it will be created automatically. -func OpenWith(path string, options OpenOptionsT) (DedoI, error) { +func OpenWith(path string, options OpenOptionsT) (DatabaseI, error) { file, err := openFile(path) if err != nil { return nil, err @@ -1809,7 +1809,7 @@ func OpenWith(path string, options OpenOptionsT) (DedoI, error) { return db, nil } -func Open(path string) (DedoI, error) { +func Open(path string) (DatabaseI, error) { return OpenWith(path, defaultOptions) } @@ -3968,7 +3968,7 @@ func setGetopt(args argsT, w io.Writer) (argsT, bool) { return args, true } -func checkExec(args argsT, db DedoI, _r io.Reader, _w io.Writer) error { +func checkExec(args argsT, db DatabaseI, _r io.Reader, _w io.Writer) error { return db.View(func(snapshot SnapshotI) error { var errs error for err := range snapshot.Check() { @@ -3978,7 +3978,7 @@ func checkExec(args argsT, db DedoI, _r io.Reader, _w io.Writer) error { }) } -func getExec(args argsT, db DedoI, r io.Reader, w io.Writer) error { +func getExec(args argsT, db DatabaseI, r io.Reader, w io.Writer) error { return db.View(func(snapshot SnapshotI) error { bucket := snapshot.Bucket(args.bucket) if bucket == nil { @@ -3995,7 +3995,7 @@ func getExec(args argsT, db DedoI, r io.Reader, w io.Writer) error { }) } -func setExec(args argsT, db DedoI, r io.Reader, w io.Writer) error { +func setExec(args argsT, db DatabaseI, r io.Reader, w io.Writer) error { return db.Update(func(tx TransactionI) error { bucket, err := tx.CreateBucketIfNotExists(args.bucket) if err != nil { @@ -4006,7 +4006,7 @@ func setExec(args argsT, db DedoI, r io.Reader, w io.Writer) error { }) } -func rmExec(args argsT, db DedoI, r io.Reader, w io.Writer) error { +func rmExec(args argsT, db DatabaseI, r io.Reader, w io.Writer) error { return db.Update(func(tx TransactionI) error { bucket := tx.Bucket(args.bucket) if bucket == nil { @@ -4017,7 +4017,7 @@ func rmExec(args argsT, db DedoI, r io.Reader, w io.Writer) error { }) } -func listExec(args argsT, db DedoI, r io.Reader, w io.Writer) error { +func listExec(args argsT, db DatabaseI, r io.Reader, w io.Writer) error { return db.View(func(snapshot SnapshotI) error { if len(args.bucket) == 0 { return snapshot.ForEach(func( |