+2
-1
recording_blockstore/recording_blockstore.go
+2
-1
recording_blockstore/recording_blockstore.go
···
2
2
3
3
import (
4
4
"context"
5
+
"fmt"
5
6
6
7
blockformat "github.com/ipfs/go-block-format"
7
8
"github.com/ipfs/go-cid"
···
58
59
}
59
60
60
61
func (bs *RecordingBlockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error) {
61
-
return bs.AllKeysChan(ctx)
62
+
return nil, fmt.Errorf("iteration not allowed on recording blockstore")
62
63
}
63
64
64
65
func (bs *RecordingBlockstore) HashOnRead(enabled bool) {
+1
-1
sqlite_blockstore/sqlite_blockstore.go
+1
-1
sqlite_blockstore/sqlite_blockstore.go
···
129
129
}
130
130
131
131
func (bs *SqliteBlockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error) {
132
-
panic("not implemented")
132
+
return nil, fmt.Errorf("iteration not allowed on sqlite blockstore")
133
133
}
134
134
135
135
func (bs *SqliteBlockstore) HashOnRead(enabled bool) {