x/services/syncbase: Implementing deleteRange for the mojo implementaion.
MultiPart: 1/2
Change-Id: If7f9a2fb1b1b95f27106e0162457b16b2c4c08f0
diff --git a/services/syncbase/server/mojo_impl.go b/services/syncbase/server/mojo_impl.go
index 9ad431b..556350c 100644
--- a/services/syncbase/server/mojo_impl.go
+++ b/services/syncbase/server/mojo_impl.go
@@ -422,7 +422,13 @@
}
func (m *mojoImpl) TableDeleteRange(name string, start, limit []byte) (mojom.Error, error) {
- return mojom.Error{}, nil
+ ctx, call := m.newCtxCall(name, methodDesc(nosqlwire.TableDesc, "DeleteRange"))
+ stub, err := m.getTable(ctx, call, name)
+ if err != nil {
+ return toMojoError(err), nil
+ }
+ err = stub.DeleteRange(ctx, call, NoSchema, start, limit)
+ return toMojoError(err), nil
}
type scanStreamImpl struct {
