fanhuadesenlinnn/kube-vip
1
0
Fork 0
mirror of https://hubproxy.babadafafafafa.cn/https://github.com/kube-vip/kube-vip.git synced 2026-09-20 08:03:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: function calls

Browse Source 
Signed-off-by: Cellebyte <marcel.fest@live.de>
This commit is contained in:
Cellebyte
2026-09-13 21:23:34 +02:00
committed by Marcel Fest
parent 7e2dd0d262
commit 61a52e8f2a
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/cluster/service_test.go
View File

@@ -122,7 +122,7 @@ func TestBGPHealthCheckLoop_RetriesAddHostOnFailure(t *testing.T) {
bgpManager := newMockBGPRouteManager()
bgpManager.setAddErr(errTestAddHost)
startVipService(t, newBGPConfig(healthcheck.server.URL, healthcheck.caPath))
startVipService(t, newBGPConfig(healthcheck.server.URL, healthcheck.caPath), bgpManager)
expectConsistently(t, func() bool { return !bgpManager.isAnnounced() },
2*time.Second, "route should not be announced while AddHost errors")
@@ -226,7 +226,7 @@ func startVipService(t *testing.T, cfg *kubevip.Config, bgpServer bgp.BGPManager
func startRoutingTableVipService(t *testing.T, cfg *kubevip.Config, network *mockNetwork) {
t.Helper()
c, err := cluster.InitCluster(cfg, true, nil, nil, route.NewManager(), nil, nil)
c, err := cluster.InitCluster(cfg, true, nil, nil, route.NewManager(), nil)
if err != nil {
t.Fatalf("InitCluster: %v", err)
}
@@ -236,7 +236,7 @@ func startRoutingTableVipService(t *testing.T, cfg *kubevip.Config, network *moc
done := make(chan struct{})
go func() {
_ = c.StartVipService(ctx, cfg, nil, func() {})
_ = c.StartVipService(ctx, cfg, nil, nil, func() {})
close(done)
}()