- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for NewTestWatcher (0.29 sec)
-
pilot/pkg/serviceregistry/kube/controller/namespacecontroller_test.go
client := kube.NewFakeClient() t.Cleanup(client.Shutdown) watcher := keycertbundle.NewWatcher() caBundle := []byte("caBundle") watcher.SetAndNotify(nil, nil, caBundle) meshWatcher := mesh.NewTestWatcher(&meshconfig.MeshConfig{}) stop := test.NewStop(t) discoveryNamespacesFilter := filter.NewDiscoveryNamespacesFilter( kclient.New[*v1.Namespace](client), meshWatcher, stop, )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/config/mesh/watcher_test_utils.go
type TestWatcher struct { internalWatcher doneCh chan struct{} // used to implement a blocking Update method } func NewTestWatcher(meshConfig *meshconfig.MeshConfig) *TestWatcher { w := &TestWatcher{ internalWatcher: internalWatcher{}, } w.internalWatcher.MeshConfig.Store(meshConfig) w.doneCh = make(chan struct{}, 1)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Nov 03 00:26:45 UTC 2023 - 1.5K bytes - Viewed (0) -
pkg/kube/kclient/client_test.go
} }) } } func TestFilterNamespace(t *testing.T) { tracker := assert.NewTracker[string](t) c := kube.NewFakeClient() meshWatcher := mesh.NewTestWatcher(&meshconfig.MeshConfig{DiscoverySelectors: []*meshconfig.LabelSelector{{ MatchLabels: map[string]string{"kubernetes.io/metadata.name": "selected"}, }}}) testns := clienttest.NewWriter[*corev1.Namespace](t, c)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 15:12:54 UTC 2024 - 17.2K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/controller_test.go
"istio.io/istio/pkg/kube" "istio.io/istio/pkg/kube/kclient/clienttest" "istio.io/istio/pkg/util/sets" ) func newFakeController() (model.ConfigStoreController, kube.Client) { meshHolder := mesh.NewTestWatcher(&meshconfig.MeshConfig{ IngressControllerMode: meshconfig.MeshConfig_DEFAULT, }) fakeClient := kube.NewFakeClient() return NewController(fakeClient, meshHolder, kubecontroller.Options{}), fakeClient }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 18:34:32 UTC 2023 - 10.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
fx.WaitOrFail(t, "service") } eventually(t, func() bool { svcList := controller.Services() return servicesEqual(svcList, expectedSvcList) }) } meshWatcher := mesh.NewTestWatcher(&meshconfig.MeshConfig{}) controller, fx := NewFakeControllerWithOptions(t, FakeControllerOptions{ MeshWatcher: meshWatcher, }) nsA := "nsA" nsB := "nsB" nsC := "nsC"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0)