feat(datastore): expose datastore Close()

ipfs · Jan 27, 2019 · 0fd19d9 · 0fd19d9
1 parent 3a9490a
commit 0fd19d9
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 0 deletions.
diff --git a/autobatch/autobatch.go b/autobatch/autobatch.go
@@ -112,3 +112,7 @@ func (d *Datastore) Query(q dsq.Query) (dsq.Results, error) {
 func (d *Datastore) DiskUsage() (uint64, error) {
 	return ds.DiskUsage(d.child)
 }
+
+func (d *Datastore) Close() error {
+	return nil
+}
diff --git a/datastore.go b/datastore.go
@@ -2,6 +2,7 @@ package datastore
 
 import (
 	"errors"
+	"io"
 	"time"
 
 	query "github.com/ipfs/go-datastore/query"
@@ -33,6 +34,7 @@ should be checked by callers.
 type Datastore interface {
 	Read
 	Write
+	io.Closer
 }
 
 // Write is the write-side of the Datastore interface.

diff --git a/failstore/failstore.go b/failstore/failstore.go
@@ -94,6 +94,11 @@ func (d *Failstore) DiskUsage() (uint64, error) {
 	return ds.DiskUsage(d.child)
 }
 
+//  Close implements the Datastore interface
+func (d *Failstore) Close() error {
+	return d.child.Close()
+}
+
 // FailBatch implements batching operations on the Failstore.
 type FailBatch struct {
 	cb     ds.Batch