Commit 7fa9f2ad authored by m1093782566's avatar m1093782566

support ipvs flush API

parent d9411d67
......@@ -142,18 +142,7 @@ func (runner *runner) GetVirtualServers() ([]*VirtualServer, error) {
// Flush is part of Interface. Currently we delete IPVS services one by one
func (runner *runner) Flush() error {
vss, err := runner.GetVirtualServers()
if err != nil {
return err
}
for _, vs := range vss {
err := runner.DeleteVirtualServer(vs)
// TODO: aggregate errors?
if err != nil {
return err
}
}
return nil
return runner.ipvsHandle.Flush()
}
// AddRealServer is part of Interface.
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment