Added range-scan support in oxia db (#479)

streamnative · May 18, 2024 · 78a820f · 78a820f
1 parent e80a1ea
commit 78a820f
Show file tree

Hide file tree

Showing 8 changed files with 1,376 additions and 265 deletions.
diff --git a/cmd/client/cmd.go b/cmd/client/cmd.go
@@ -16,6 +16,7 @@ package client
 
 import (
 	"fmt"
+
 	"github.com/streamnative/oxia/cmd/client/deleterange"
 
 	"github.com/spf13/cobra"

diff --git a/common/logging_client_rpc.go b/common/logging_client_rpc.go
@@ -72,6 +72,15 @@ func (l *loggingClientRpc) List(ctx context.Context, in *proto.ListRequest, opts
 	return res, err
 }
 
+func (l *loggingClientRpc) RangeScan(ctx context.Context, in *proto.RangeScanRequest, opts ...grpc.CallOption) (
+	res proto.OxiaClient_RangeScanClient, err error) {
+	if res, err = l.client.RangeScan(ctx, in, opts...); err != nil {
+		return nil, l.decorateErr(err)
+	}
+
+	return res, err
+}
+
 func (l *loggingClientRpc) GetNotifications(ctx context.Context, in *proto.NotificationsRequest, opts ...grpc.CallOption) (
 	res proto.OxiaClient_GetNotificationsClient, err error) {
 	if res, err = l.client.GetNotifications(ctx, in, opts...); err != nil {
-Original file line number
+Diff line change
@@ Expand Up / @@ -16,6 +16,7 @@ package client @@
     import (
     	"fmt"
     	"github.com/streamnative/oxia/cmd/client/deleterange"
     	"github.com/spf13/cobra"
@@ Expand Down @@