Browse Source

Merge pull request #4810 from gyuho/client_serialized_read

clientv3: set Serializable from Op
Gyu-Ho Lee 9 years ago
parent
commit
053bc83fe4
2 changed files with 2 additions and 2 deletions
  1. 1 1
      clientv3/kv.go
  2. 1 1
      clientv3/op.go

+ 1 - 1
clientv3/kv.go

@@ -138,7 +138,7 @@ func (kv *kv) Do(ctx context.Context, op Op) (OpResponse, error) {
 		// TODO: handle other ops
 		case tRange:
 			var resp *pb.RangeResponse
-			r := &pb.RangeRequest{Key: op.key, RangeEnd: op.end, Limit: op.limit, Revision: op.rev}
+			r := &pb.RangeRequest{Key: op.key, RangeEnd: op.end, Limit: op.limit, Revision: op.rev, Serializable: op.serializable}
 			if op.sort != nil {
 				r.SortOrder = pb.RangeRequest_SortOrder(op.sort.Order)
 				r.SortTarget = pb.RangeRequest_SortTarget(op.sort.Target)

+ 1 - 1
clientv3/op.go

@@ -56,7 +56,7 @@ type Op struct {
 func (op Op) toRequestUnion() *pb.RequestUnion {
 	switch op.t {
 	case tRange:
-		r := &pb.RangeRequest{Key: op.key, RangeEnd: op.end, Limit: op.limit, Revision: op.rev}
+		r := &pb.RangeRequest{Key: op.key, RangeEnd: op.end, Limit: op.limit, Revision: op.rev, Serializable: op.serializable}
 		if op.sort != nil {
 			r.SortOrder = pb.RangeRequest_SortOrder(op.sort.Order)
 			r.SortTarget = pb.RangeRequest_SortTarget(op.sort.Target)