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

Update MinimalEtcdVersion to read DowngradeVersionTest.Ver as WAL version

Browse Source 
Signed-off-by: Benjamin Wang <benjamin.ahrtr@gmail.com>
This commit is contained in:
Benjamin Wang
2025-01-26 09:40:35 +00:00
parent 1036e4e7e5
commit d741e69263
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
server/storage/wal/version.go
View File

@ -112,6 +112,16 @@ func visitEntryData(entryType raftpb.EntryType, data []byte, visitor Visitor) er
break break
} }
msg = proto.MessageReflect(&raftReq) msg = proto.MessageReflect(&raftReq)
if raftReq.DowngradeVersionTest != nil {
ver, err := semver.NewVersion(raftReq.DowngradeVersionTest.Ver)
if err != nil {
return err
}
err = visitor(msg.Descriptor().FullName(), ver)
if err != nil {
return err
}
}
case raftpb.EntryConfChange: case raftpb.EntryConfChange:
var confChange raftpb.ConfChange var confChange raftpb.ConfChange
err := pbutil.Unmarshaler(&confChange).Unmarshal(data) err := pbutil.Unmarshaler(&confChange).Unmarshal(data)