- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for NewFakeDiscoveryServer (0.46 sec)
-
pilot/pkg/xds/debug_test.go
v3 "istio.io/istio/pilot/pkg/xds/v3" xdsfake "istio.io/istio/pilot/test/xds" ) func TestSyncz(t *testing.T) { t.Run("return the sent and ack status of adsClient connections", func(t *testing.T) { s := xdsfake.NewFakeDiscoveryServer(t, xdsfake.FakeOptions{}) ads := s.ConnectADS() ads.RequestResponseAck(t, &discovery.DiscoveryRequest{TypeUrl: v3.ClusterType}) ads.RequestResponseAck(t, &discovery.DiscoveryRequest{TypeUrl: v3.ListenerType})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 7.8K bytes - Viewed (0) -
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_delta_test.go
"istio.io/istio/pkg/test/util/retry" ) // Validates basic xds proxy flow by proxying one CDS requests end to end. func TestDeltaXdsProxyBasicFlow(t *testing.T) { proxy := setupXdsProxy(t) f := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) setDialOptions(proxy, f.BufListener) conn := setupDownstreamConnection(t, proxy) downstream := deltaStream(t, conn) sendDeltaDownstreamWithNode(t, downstream, model.NodeMetadata{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 04:48:02 UTC 2024 - 6.3K 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/cds_test.go
"istio.io/istio/pkg/ptr" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/util/sets" ) func TestCDS(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) ads := s.ConnectADS().WithType(v3.ClusterType) ads.RequestResponseAck(t, nil) } func TestSAN(t *testing.T) { labels := map[string]string{"app": "test"} pod := &v1.Pod{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 01 02:06:39 UTC 2024 - 9.2K bytes - Viewed (0) -
pilot/pkg/xds/nds_test.go
Ips: []string{"9.9.9.9"}, Registry: "External", }, }, }, }, } for _, tt := range cases { t.Run(tt.name, func(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ ConfigString: mustReadFile(t, "./testdata/nds-se.yaml"), }) ads := s.ConnectADS().WithType(v3.NameTableType) res := ads.RequestResponseAck(t, &discovery.DiscoveryRequest{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 4.6K bytes - Viewed (0)