- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for NewServiceDiscovery (0.35 sec)
-
pilot/pkg/networking/core/envoyfilter/fuzz_test.go
proxy := fuzz.Struct[*model.Proxy](fg) mesh := fuzz.Struct[*meshconfig.MeshConfig](fg) c := fuzz.Struct[*cluster.Cluster](fg) serviceDiscovery := memory.NewServiceDiscovery() env := newTestEnvironment(serviceDiscovery, mesh, buildEnvoyFilterConfigStore(patches)) push := model.NewPushContext() push.InitContext(env, nil, nil) efw := push.EnvoyFilters(proxy)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 1.6K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/extension_configuration_patch_test.go
{ name: "only add extension config", requestedNames: []string{"merge-extension-config"}, wantExtensionConfig: []*core.TypedExtensionConfig{}, }, } serviceDiscovery := memory.NewServiceDiscovery() env := newTestEnvironment(serviceDiscovery, testMesh, buildEnvoyFilterConfigStore(configPatches)) push := model.NewPushContext() push.InitContext(env, nil, nil) for _, c := range testCases {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 3.4K bytes - Viewed (0) -
tests/fuzz/pilot_model_fuzzer.go
} m, err := mesh.ApplyMeshConfigDefaults(configString) if err != nil { return 0 } env := &model.Environment{} store := model.NewFakeStore() env.ConfigStore = store sd := memory.NewServiceDiscovery(services...) sd.WantGetProxyServiceTargets = slices.Map(serviceInstances, model.ServiceInstanceToTarget) env.ServiceDiscovery = sd env.Watcher = mesh.NewFixedWatcher(m)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 18:13:06 UTC 2023 - 4.6K bytes - Viewed (0) -
pilot/pkg/model/network_test.go
} }) meshNetworks := mesh.NewFixedNetworksWatcher(nil) xdsUpdater := xdsfake.NewFakeXDS() env := &model.Environment{NetworksWatcher: meshNetworks, ServiceDiscovery: memory.NewServiceDiscovery()} if err := env.InitNetworksManager(xdsUpdater); err != nil { t.Fatal(err) } var gateways []model.NetworkGateway t.Run("initial resolution", func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 16 01:18:03 UTC 2023 - 6.9K bytes - Viewed (0)