- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for NewFakeDiscoveryServer (0.51 sec)
-
pilot/pkg/xds/delta_test.go
xdsserver "istio.io/istio/pkg/xds" ) func TestDeltaAds(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) ads := s.ConnectDeltaADS().WithType(v3.ClusterType) ads.RequestResponseAck(nil) } func TestDeltaAdsClusterUpdate(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) ads := s.ConnectDeltaADS().WithType(v3.EndpointType) nonce := ""
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
pilot/pkg/xds/ads_test.go
} // Regression for connection with a bad ID func TestAdsBadId(t *testing.T) { s := xdsfake.NewFakeDiscoveryServer(t, xdsfake.FakeOptions{}) ads := s.ConnectADS().WithID("").WithType(v3.ClusterType) xds.AdsPushAll(s.Discovery) ads.ExpectNoResponse(t) } func TestVersionNonce(t *testing.T) { s := xdsfake.NewFakeDiscoveryServer(t, xdsfake.FakeOptions{}) ads := s.ConnectADS().WithType(v3.ClusterType)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0) -
pilot/pkg/xds/workload_test.go
} } func TestWorkloadReconnect(t *testing.T) { test.SetForTest(t, &features.EnableAmbient, true) t.Run("ondemand", func(t *testing.T) { expect := buildExpect(t) s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ KubernetesObjects: []runtime.Object{mkPod("pod", "sa", "127.0.0.1", "not-node")}, }) ads := s.ConnectDeltaADS().WithType(v3.AddressType).WithMetadata(model.NodeMetadata{NodeName: "node"})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
pilot/pkg/xds/xds_test.go
ID: "app.app", Type: model.SidecarProxy, IPAddresses: []string{"1.1.1.1"}, ConfigNamespace: "app", } } t.Run("STATIC", func(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ ConfigString: scopeConfig, ConfigTemplateInput: SidecarTestConfig{ ImportedNamespaces: []string{"./*", "included/*"}, Resolution: "STATIC", }, })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 13.8K bytes - Viewed (0) -
pilot/pkg/xds/lds_test.go
func TestLDS(t *testing.T) { t.Run("sidecar", func(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) ads := s.ConnectADS().WithType(v3.ListenerType) ads.RequestResponseAck(t, nil) }) // 'router' or 'gateway' type of listener t.Run("gateway", func(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ConfigString: mustReadfolder(t, "tests/testdata/config")})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_test.go
wasmcache "istio.io/istio/pkg/wasm" ) // Validates basic xds proxy flow by proxying one CDS requests end to end. func TestXdsProxyBasicFlow(t *testing.T) { proxy := setupXdsProxy(t) f := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) setDialOptions(proxy, f.BufListener) conn := setupDownstreamConnection(t, proxy) downstream := stream(t, conn) sendDownstreamWithNode(t, downstream, model.NodeMetadata{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 04:48:02 UTC 2024 - 18.6K bytes - Viewed (0) -
pilot/pkg/xds/eds_test.go
asdc2Locality = "region2/zone2/subzone2" edsIncSvc = "eds.test.svc.cluster.local" edsIncVip = "10.10.1.2" ) func TestIncrementalPush(t *testing.T) { s := xdsfake.NewFakeDiscoveryServer(t, xdsfake.FakeOptions{ ConfigString: mustReadFile(t, "tests/testdata/config/destination-rule-all.yaml") + mustReadFile(t, "tests/testdata/config/static-weighted-se.yaml"), }) ads := s.Connect(nil, nil, watchAll)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
pilot/pkg/xds/sds_test.go
t.Run(tt.name, func(t *testing.T) { if tt.proxy.Metadata == nil { tt.proxy.Metadata = &model.NodeMetadata{} } tt.proxy.Metadata.ClusterID = constants.DefaultClusterName s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ KubernetesObjects: []runtime.Object{genericCert, genericMtlsCert, genericMtlsCertCrl, genericMtlsCertSplit, genericMtlsCertSplitCa}, }) cc := s.KubeClient().Kube().(*fake.Clientset)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 17.7K bytes - Viewed (0) -
pilot/pkg/xds/ecds_test.go
"istio.io/istio/pkg/config/schema/gvk" "istio.io/istio/pkg/config/schema/kind" "istio.io/istio/pkg/spiffe" "istio.io/istio/pkg/util/sets" ) func TestECDS(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ ConfigString: mustReadFile(t, "./testdata/ecds.yaml"), }) ads := s.ConnectADS().WithType(v3.ExtensionConfigurationType) wantExtensionConfigName := "extension-config"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 12K bytes - Viewed (0) -
pilot/pkg/xds/bench_test.go
}{ {1, 100}, {10, 10}, {100, 10}, {1000, 1}, } for _, tt := range tests { b.Run(fmt.Sprintf("%d/%d", tt.endpoints, tt.services), func(b *testing.B) { s := xds.NewFakeDiscoveryServer(b, xds.FakeOptions{ Configs: createEndpointsConfig(tt.endpoints, tt.services, numNetworks), NetworksWatcher: mesh.NewFixedNetworksWatcher(&meshconfig.MeshNetworks{ Networks: createGateways(numNetworks),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 22 18:13:40 UTC 2024 - 19.7K bytes - Viewed (0)