Merge pull request #69322 from jpbetz/etcd-client-3.3.9
Update etcd client to 3.3 for 1.13
This commit is contained in:
@@ -314,12 +314,33 @@ func toTTLOptions(r *pb.Request) store.TTLOptionSet {
|
||||
}
|
||||
|
||||
func applyRequest(r *pb.Request, applyV2 etcdserver.ApplierV2) {
|
||||
// TODO: find a sane way to perform this cast or avoid it in the first place
|
||||
reqV2 := &etcdserver.RequestV2{
|
||||
ID: r.ID,
|
||||
Method: r.Method,
|
||||
Path: r.Path,
|
||||
Val: r.Val,
|
||||
Dir: r.Dir,
|
||||
PrevValue: r.PrevValue,
|
||||
PrevIndex: r.PrevIndex,
|
||||
PrevExist: r.PrevExist,
|
||||
Expiration: r.Expiration,
|
||||
Wait: r.Wait,
|
||||
Since: r.Since,
|
||||
Recursive: r.Recursive,
|
||||
Sorted: r.Sorted,
|
||||
Quorum: r.Quorum,
|
||||
Time: r.Time,
|
||||
Stream: r.Stream,
|
||||
Refresh: r.Refresh,
|
||||
XXX_unrecognized: r.XXX_unrecognized,
|
||||
}
|
||||
toTTLOptions(r)
|
||||
switch r.Method {
|
||||
case "PUT":
|
||||
applyV2.Put(r)
|
||||
applyV2.Put(reqV2)
|
||||
case "DELETE":
|
||||
applyV2.Delete(r)
|
||||
applyV2.Delete(reqV2)
|
||||
case "POST", "QGET", "SYNC":
|
||||
return
|
||||
default:
|
||||
|
Reference in New Issue
Block a user