Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #13083 from lilic/add-downgrade-client

Browse Source 
client/v3/maintenance.go: Add Downgrade support to client
This commit is contained in:
Gyuho Lee 2021-06-04 15:31:48 -07:00 committed by GitHub
commit 23e6bf3671
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 27 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
client/v3/maintenance.go
View File

@ -16,6 +16,7 @@ package clientv3
import ( import (
"context" "context"
"errors"
"fmt" "fmt"
"io" "io"
@ -31,6 +32,7 @@ type (
StatusResponse pb.StatusResponse StatusResponse pb.StatusResponse
HashKVResponse pb.HashKVResponse HashKVResponse pb.HashKVResponse
MoveLeaderResponse pb.MoveLeaderResponse MoveLeaderResponse pb.MoveLeaderResponse
DowngradeResponse pb.DowngradeResponse
) )
type Maintenance interface { type Maintenance interface {
@ -65,6 +67,15 @@ type Maintenance interface {
// MoveLeader requests current leader to transfer its leadership to the transferee. // MoveLeader requests current leader to transfer its leadership to the transferee.
// Request must be made to the leader. // Request must be made to the leader.
MoveLeader(ctx context.Context, transfereeID uint64) (*MoveLeaderResponse, error) MoveLeader(ctx context.Context, transfereeID uint64) (*MoveLeaderResponse, error)
// Downgrade requests downgrades, verifies feasibility or cancels downgrade
// on the cluster version.
// action is one of the following:
// VALIDATE = 0;
// ENABLE = 1;
// CANCEL = 2;
// Supported since etcd 3.5.
Downgrade(ctx context.Context, action int32, version string) (*DowngradeResponse, error)
} }
type maintenance struct { type maintenance struct {
@ -252,3 +263,19 @@ func (m *maintenance) MoveLeader(ctx context.Context, transfereeID uint64) (*Mov
resp, err := m.remote.MoveLeader(ctx, &pb.MoveLeaderRequest{TargetID: transfereeID}, m.callOpts...) resp, err := m.remote.MoveLeader(ctx, &pb.MoveLeaderRequest{TargetID: transfereeID}, m.callOpts...)
return (*MoveLeaderResponse)(resp), toErr(ctx, err) return (*MoveLeaderResponse)(resp), toErr(ctx, err)
} }
func (m *maintenance) Downgrade(ctx context.Context, action int32, version string) (*DowngradeResponse, error) {
actionType := pb.DowngradeRequest_VALIDATE
switch action {
case 0:
actionType = pb.DowngradeRequest_VALIDATE
case 1:
actionType = pb.DowngradeRequest_ENABLE
case 2:
actionType = pb.DowngradeRequest_CANCEL
default:
return nil, errors.New("etcdclient: unknown downgrade action")
}
resp, err := m.remote.Downgrade(ctx, &pb.DowngradeRequest{Action: actionType, Version: version}, m.callOpts...)
return (*DowngradeResponse)(resp), toErr(ctx, err)
}