mirrors/etcd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

*: regen proto

Browse Source 
Signed-off-by: Sam Batschelet <sbatsche@redhat.com>
This commit is contained in:
Sam Batschelet 2021-03-11 11:27:52 -05:00
parent d3aa3fb486
commit 8ff0ff836a
3 changed files with 29 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Documentation/dev-guide/apispec/swagger/rpc.swagger.json
View File

@ -1247,7 +1247,7 @@
"tags": [ "tags": [
"Maintenance" "Maintenance"
], ],
"summary": "Downgrade requests downgrade, cancel downgrade on the cluster version.", "summary": "Downgrade requests downgrades, verifies feasibility or cancels downgrade\non the cluster version.\nSupported since etcd 3.5.",
"operationId": "Maintenance_Downgrade", "operationId": "Maintenance_Downgrade",
"parameters": [ "parameters": [
{ {

8
api/etcdserverpb/rpc.pb.go
View File

@ -7295,7 +7295,9 @@ type MaintenanceClient interface {
Snapshot(ctx context.Context, in *SnapshotRequest, opts ...grpc.CallOption) (Maintenance_SnapshotClient, error) Snapshot(ctx context.Context, in *SnapshotRequest, opts ...grpc.CallOption) (Maintenance_SnapshotClient, error)
// MoveLeader requests current leader node to transfer its leadership to transferee. // MoveLeader requests current leader node to transfer its leadership to transferee.
MoveLeader(ctx context.Context, in *MoveLeaderRequest, opts ...grpc.CallOption) (*MoveLeaderResponse, error) MoveLeader(ctx context.Context, in *MoveLeaderRequest, opts ...grpc.CallOption) (*MoveLeaderResponse, error)
// Downgrade requests downgrade, cancel downgrade on the cluster version. // Downgrade requests downgrades, verifies feasibility or cancels downgrade
// on the cluster version.
// Supported since etcd 3.5.
Downgrade(ctx context.Context, in *DowngradeRequest, opts ...grpc.CallOption) (*DowngradeResponse, error) Downgrade(ctx context.Context, in *DowngradeRequest, opts ...grpc.CallOption) (*DowngradeResponse, error)
} }
@ -7424,7 +7426,9 @@ type MaintenanceServer interface {
Snapshot(*SnapshotRequest, Maintenance_SnapshotServer) error Snapshot(*SnapshotRequest, Maintenance_SnapshotServer) error
// MoveLeader requests current leader node to transfer its leadership to transferee. // MoveLeader requests current leader node to transfer its leadership to transferee.
MoveLeader(context.Context, *MoveLeaderRequest) (*MoveLeaderResponse, error) MoveLeader(context.Context, *MoveLeaderRequest) (*MoveLeaderResponse, error)
// Downgrade requests downgrade, cancel downgrade on the cluster version. // Downgrade requests downgrades, verifies feasibility or cancels downgrade
// on the cluster version.
// Supported since etcd 3.5.
Downgrade(context.Context, *DowngradeRequest) (*DowngradeResponse, error) Downgrade(context.Context, *DowngradeRequest) (*DowngradeResponse, error)
} }

37
raft/raftpb/raft.pb.go
View File

@ -67,6 +67,8 @@ func (EntryType) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_b042552c306ae59b, []int{0} return fileDescriptor_b042552c306ae59b, []int{0}
} }
// For description of different message types, see:
// https://pkg.go.dev/go.etcd.io/etcd/raft/v3#hdr-MessageType
type MessageType int32 type MessageType int32
const ( const (
@ -388,21 +390,26 @@ func (m *Snapshot) XXX_DiscardUnknown() {
var xxx_messageInfo_Snapshot proto.InternalMessageInfo var xxx_messageInfo_Snapshot proto.InternalMessageInfo
type Message struct { type Message struct {
Type MessageType `protobuf:"varint,1,opt,name=type,enum=raftpb.MessageType" json:"type"` Type MessageType `protobuf:"varint,1,opt,name=type,enum=raftpb.MessageType" json:"type"`
To uint64 `protobuf:"varint,2,opt,name=to" json:"to"` To uint64 `protobuf:"varint,2,opt,name=to" json:"to"`
From uint64 `protobuf:"varint,3,opt,name=from" json:"from"` From uint64 `protobuf:"varint,3,opt,name=from" json:"from"`
Term uint64 `protobuf:"varint,4,opt,name=term" json:"term"` Term uint64 `protobuf:"varint,4,opt,name=term" json:"term"`
LogTerm uint64 `protobuf:"varint,5,opt,name=logTerm" json:"logTerm"` // logTerm is generally used for appending Raft logs to followers. For example,
Index uint64 `protobuf:"varint,6,opt,name=index" json:"index"` // (type=MsgApp,index=100,logTerm=5) means leader appends entries starting at
Entries []Entry `protobuf:"bytes,7,rep,name=entries" json:"entries"` // index=101, and the term of entry at index 100 is 5.
Commit uint64 `protobuf:"varint,8,opt,name=commit" json:"commit"` // (type=MsgAppResp,reject=true,index=100,logTerm=5) means follower rejects some
Snapshot Snapshot `protobuf:"bytes,9,opt,name=snapshot" json:"snapshot"` // entries from its leader as it already has an entry with term 5 at index 100.
Reject bool `protobuf:"varint,10,opt,name=reject" json:"reject"` LogTerm uint64 `protobuf:"varint,5,opt,name=logTerm" json:"logTerm"`
RejectHint uint64 `protobuf:"varint,11,opt,name=rejectHint" json:"rejectHint"` Index uint64 `protobuf:"varint,6,opt,name=index" json:"index"`
Context []byte `protobuf:"bytes,12,opt,name=context" json:"context,omitempty"` Entries []Entry `protobuf:"bytes,7,rep,name=entries" json:"entries"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` Commit uint64 `protobuf:"varint,8,opt,name=commit" json:"commit"`
XXX_unrecognized []byte `json:"-"` Snapshot Snapshot `protobuf:"bytes,9,opt,name=snapshot" json:"snapshot"`
XXX_sizecache int32 `json:"-"` Reject bool `protobuf:"varint,10,opt,name=reject" json:"reject"`
RejectHint uint64 `protobuf:"varint,11,opt,name=rejectHint" json:"rejectHint"`
Context []byte `protobuf:"bytes,12,opt,name=context" json:"context,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
} }
func (m *Message) Reset() { *m = Message{} } func (m *Message) Reset() { *m = Message{} }