Skip to content

Commit ff3778c

Browse files
Merge pull request #1144 from hongkailiu/OTA-1427-watch-mcp
OTA-1427: Recompute node insights when MC/MCP changes
2 parents fecdb0c + c3483f4 commit ff3778c

File tree

3 files changed

+456
-112
lines changed

3 files changed

+456
-112
lines changed

pkg/updatestatus/controlplaneinformer_test.go

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,15 +6,14 @@ import (
66
"testing"
77
"time"
88

9-
kerrors "k8s.io/apimachinery/pkg/api/errors"
10-
119
"github.com/google/go-cmp/cmp"
1210
"github.com/google/go-cmp/cmp/cmpopts"
1311
"gopkg.in/yaml.v3"
1412
"k8s.io/utils/ptr"
1513

1614
appsv1 "k8s.io/api/apps/v1"
1715
corev1 "k8s.io/api/core/v1"
16+
kerrors "k8s.io/apimachinery/pkg/api/errors"
1817
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
1918
"k8s.io/apimachinery/pkg/runtime"
2019
fakekubeclient "k8s.io/client-go/kubernetes/fake"
@@ -662,6 +661,12 @@ func newTestSyncContext(queueKey string) factory.SyncContext {
662661
return testSyncContext{
663662
queueKey: queueKey,
664663
eventRecorder: events.NewInMemoryRecorder("test", clocktesting.NewFakePassiveClock(time.Now())),
664+
queue: workqueue.NewTypedRateLimitingQueueWithConfig(
665+
workqueue.DefaultTypedControllerRateLimiter[any](),
666+
workqueue.TypedRateLimitingQueueConfig[any]{
667+
Name: "test",
668+
},
669+
),
665670
}
666671
}
667672

0 commit comments

Comments
 (0)