forked from TrueCloudLab/frostfs-node
[#177] metabase: Add index by object ID
Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
This commit is contained in:
parent
dbf6c9efef
commit
ffeea2c003
4 changed files with 22 additions and 1 deletions
2
go.mod
2
go.mod
|
@ -14,7 +14,7 @@ require (
|
||||||
github.com/multiformats/go-multiaddr-net v0.1.2 // v0.1.1 => v0.1.2
|
github.com/multiformats/go-multiaddr-net v0.1.2 // v0.1.1 => v0.1.2
|
||||||
github.com/multiformats/go-multihash v0.0.13 // indirect
|
github.com/multiformats/go-multihash v0.0.13 // indirect
|
||||||
github.com/nspcc-dev/neo-go v0.91.1-pre.0.20201030072836-71216865717b
|
github.com/nspcc-dev/neo-go v0.91.1-pre.0.20201030072836-71216865717b
|
||||||
github.com/nspcc-dev/neofs-api-go v1.20.2
|
github.com/nspcc-dev/neofs-api-go v1.20.3-0.20201120074117-20ede88fe753
|
||||||
github.com/nspcc-dev/neofs-crypto v0.3.0
|
github.com/nspcc-dev/neofs-crypto v0.3.0
|
||||||
github.com/nspcc-dev/tzhash v1.4.0
|
github.com/nspcc-dev/tzhash v1.4.0
|
||||||
github.com/panjf2000/ants/v2 v2.3.0
|
github.com/panjf2000/ants/v2 v2.3.0
|
||||||
|
|
BIN
go.sum
BIN
go.sum
Binary file not shown.
|
@ -124,6 +124,10 @@ func objectIndices(obj *object.Object, parent bool) []bucketItem {
|
||||||
key: v2object.FilterHeaderParent,
|
key: v2object.FilterHeaderParent,
|
||||||
val: obj.ParentID().String(),
|
val: obj.ParentID().String(),
|
||||||
},
|
},
|
||||||
|
bucketItem{
|
||||||
|
key: v2object.FilterHeaderObjectID,
|
||||||
|
val: obj.ID().String(),
|
||||||
|
},
|
||||||
// TODO: add remaining fields after neofs-api#72
|
// TODO: add remaining fields after neofs-api#72
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
|
@ -207,3 +207,20 @@ func TestSelectParentID(t *testing.T) {
|
||||||
|
|
||||||
testSelect(t, db, fs, obj1.Address())
|
testSelect(t, db, fs, obj1.Address())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestSelectObjectID(t *testing.T) {
|
||||||
|
db := newDB(t)
|
||||||
|
defer releaseDB(db)
|
||||||
|
|
||||||
|
// generate object
|
||||||
|
obj := generateObject(t, testPrm{})
|
||||||
|
|
||||||
|
// store objects
|
||||||
|
require.NoError(t, db.Put(obj))
|
||||||
|
|
||||||
|
// filter by object ID
|
||||||
|
fs := objectSDK.SearchFilters{}
|
||||||
|
fs.AddObjectIDFilter(objectSDK.MatchStringEqual, obj.ID())
|
||||||
|
|
||||||
|
testSelect(t, db, fs, obj.Address())
|
||||||
|
}
|
||||||
|
|
Loading…
Reference in a new issue