clientv3: retry remote connection on txn write failure
@@ -143,11 +143,12 @@ func (txn *txn) Commit() (*TxnResponse, error) {
return (*TxnResponse)(resp), nil
}
- if txn.isWrite {
+ if isRPCError(err) {
return nil, err
- if isRPCError(err) {
+ if txn.isWrite {
+ go kv.switchRemote(err)