mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-06 10:43:56 +00:00
[kube-proxy/ipvs] Do not delete existing VS and RS when starting
This commit is contained in:
parent
eb6a1b651c
commit
96818ea31e
@ -204,21 +204,5 @@ func (m *GracefulTerminationManager) MoveRSOutofGracefulDeleteList(uniqueRS stri
|
|||||||
|
|
||||||
// Run start a goroutine to try to delete rs in the graceful delete rsList with an interval 1 minute
|
// Run start a goroutine to try to delete rs in the graceful delete rsList with an interval 1 minute
|
||||||
func (m *GracefulTerminationManager) Run() {
|
func (m *GracefulTerminationManager) Run() {
|
||||||
// before start, add leftover in delete rs to graceful delete rsList
|
|
||||||
vss, err := m.ipvs.GetVirtualServers()
|
|
||||||
if err != nil {
|
|
||||||
klog.Errorf("IPVS graceful delete manager failed to get IPVS virtualserver")
|
|
||||||
}
|
|
||||||
for _, vs := range vss {
|
|
||||||
rss, err := m.ipvs.GetRealServers(vs)
|
|
||||||
if err != nil {
|
|
||||||
klog.Errorf("IPVS graceful delete manager failed to get %v realserver", vs)
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
for _, rs := range rss {
|
|
||||||
m.GracefulDeleteRS(vs, rs)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
go wait.Until(m.tryDeleteRs, rsCheckDeleteInterval, wait.NeverStop)
|
go wait.Until(m.tryDeleteRs, rsCheckDeleteInterval, wait.NeverStop)
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user