From 20a4649a0f2087e2637884b565a0c33158178ee3 Mon Sep 17 00:00:00 2001 From: Adin Schmahmann Date: Mon, 2 Dec 2019 19:39:15 -0500 Subject: [PATCH] update datastore interface --- flatfs.go | 10 ++++++++++ go.mod | 2 +- go.sum | 4 ++-- 3 files changed, 13 insertions(+), 3 deletions(-) diff --git a/flatfs.go b/flatfs.go index 873e3d4..de2514a 100644 --- a/flatfs.go +++ b/flatfs.go @@ -388,6 +388,16 @@ func (fs *Datastore) Put(key datastore.Key, value []byte) error { return err } +func (fs *Datastore) Sync(prefix datastore.Key) error { + fs.shutdownLock.RLock() + defer fs.shutdownLock.RUnlock() + if fs.shutdown { + return ErrClosed + } + + return nil +} + func (fs *Datastore) doOp(oper *op) error { switch oper.typ { case opPut: diff --git a/go.mod b/go.mod index 0084a83..11f14d5 100644 --- a/go.mod +++ b/go.mod @@ -1,7 +1,7 @@ module github.com/ipfs/go-ds-flatfs require ( - github.com/ipfs/go-datastore v0.2.0 + github.com/ipfs/go-datastore v0.3.0 github.com/ipfs/go-log v0.0.1 github.com/jbenet/goprocess v0.1.3 ) diff --git a/go.sum b/go.sum index 83ef54c..408cd41 100644 --- a/go.sum +++ b/go.sum @@ -6,8 +6,8 @@ github.com/gogo/protobuf v1.2.1 h1:/s5zKNz0uPFCZ5hddgPdo2TK2TVrUNMn0OOX8/aZMTE= github.com/gogo/protobuf v1.2.1/go.mod h1:hp+jE20tsWTFYpLwKvXlhS1hjn+gTNwPg2I6zVXpSg4= github.com/google/uuid v1.1.1 h1:Gkbcsh/GbpXz7lPftLA3P6TYMwjCLYm83jiFQZF/3gY= github.com/google/uuid v1.1.1/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= -github.com/ipfs/go-datastore v0.2.0 h1:5Wjw6YXzZmtqU1MSrlws64+oLmSqea7gEajTcJickh8= -github.com/ipfs/go-datastore v0.2.0/go.mod h1:w38XXW9kVFNp57Zj5knbKWM2T+KOZCGDRVNdgPHtbHw= +github.com/ipfs/go-datastore v0.3.0 h1:9au0tYi/+n7xeUnGHG6davnS8x9hWbOzP/388Vx3CMs= +github.com/ipfs/go-datastore v0.3.0/go.mod h1:w38XXW9kVFNp57Zj5knbKWM2T+KOZCGDRVNdgPHtbHw= github.com/ipfs/go-ipfs-delay v0.0.0-20181109222059-70721b86a9a8/go.mod h1:8SP1YXK1M1kXuc4KJZINY3TQQ03J2rwBG9QfXmbRPrw= github.com/ipfs/go-log v0.0.1 h1:9XTUN/rW64BCG1YhPK9Hoy3q8nr4gOmHHBpgFdfw6Lc= github.com/ipfs/go-log v0.0.1/go.mod h1:kL1d2/hzSpI0thNYjiKfjanbVNU+IIGA/WnNESY9leM=