From f38a611b556e3f23c7a25d7e5cbca90df9a5d4da Mon Sep 17 00:00:00 2001 From: Gyu-Ho Lee Date: Fri, 18 Mar 2016 15:50:44 -0700 Subject: [PATCH] clientv3: set Serializable from Op Fix https://github.com/coreos/etcd/issues/4809. --- clientv3/kv.go | 2 +- clientv3/op.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/clientv3/kv.go b/clientv3/kv.go index 6d9a9aedd..6a1b55d83 100644 --- a/clientv3/kv.go +++ b/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) diff --git a/clientv3/op.go b/clientv3/op.go index 0af89dfc2..7caba60d7 100644 --- a/clientv3/op.go +++ b/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)