- Sort Score
- Result 10 results
- Languages All
Results 21 - 26 of 26 for NewFixedWatcher (0.31 sec)
-
pilot/pkg/model/authentication_test.go
if _, err := configStore.Create(*cfg); err != nil { t.Fatalf("getTestAuthenticationPolicies %v", err) } } environment := &Environment{ ConfigStore: configStore, Watcher: mesh.NewFixedWatcher(&meshconfig.MeshConfig{RootNamespace: rootNamespace}), } return initAuthenticationPolicies(environment) } func createTestRequestAuthenticationResource(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 45.1K bytes - Viewed (0) -
pkg/kube/inject/webhook_test.go
EnvironmentVariables: map[string]string{ fmt.Sprintf("VAR_%d", i): fmt.Sprint(i), }, })) } pcs := model.GetProxyConfigs(store, m) env := model.Environment{ Watcher: mesh.NewFixedWatcher(m), ConfigStore: store, } env.SetPushContext(&model.PushContext{ ProxyConfigs: pcs, }) watcher, err := NewFileWatcher(configFile, valuesFile) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 39K bytes - Viewed (1) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
go configController.Run(stop) fx := xdsfake.NewFakeXDS() go func() { for { select { case <-stop: return case <-fx.Events: // drain } } }() meshcfg := mesh.NewFixedWatcher(mesh.DefaultMeshConfig()) serviceController := NewController(configController, fx, meshcfg) return configController, serviceController }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/listener_patch_test.go
configStore model.ConfigStore, ) *model.Environment { e := &model.Environment{ ServiceDiscovery: serviceDiscovery, ConfigStore: configStore, Watcher: mesh.NewFixedWatcher(meshConfig), } pushContext := model.NewPushContext() e.Init() _ = pushContext.InitContext(e, nil, nil) e.SetPushContext(pushContext) return e }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 70.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
delegate := model.NewEndpointIndexUpdater(endpoints) xdsUpdater := xdsfake.NewWithDelegate(delegate) delegate.ConfigUpdateFunc = xdsUpdater.ConfigUpdate meshWatcher := mesh.NewFixedWatcher(&meshconfig.MeshConfig{}) kc := kubecontroller.NewController( client, kubecontroller.Options{ XDSUpdater: xdsUpdater, DomainSuffix: "cluster.local",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
}, }, } svcList := controller.Services() servicesEqual(svcList, expectedSvcList) } func TestController_ServiceWithFixedDiscoveryNamespaces(t *testing.T) { meshWatcher := mesh.NewFixedWatcher(&meshconfig.MeshConfig{ DiscoverySelectors: []*meshconfig.LabelSelector{ { MatchLabels: map[string]string{ "pilot-discovery": "enabled", }, }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0)