Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewServiceDiscovery (0.35 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to top