- Sort Score
- Result 10 results
- Languages All
Results 21 - 28 of 28 for SetupProxy (0.53 sec)
-
pilot/pkg/networking/core/accesslog_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 19.9K bytes - Viewed (0) -
pilot/test/xds/fake.go
watches = append(watches, sch.GroupVersionKind().String()) } return watches } func (f *FakeDiscoveryServer) ConnectUnstarted(p *model.Proxy, watch []string) *adsc.ADSC { f.t.Helper() p = f.SetupProxy(p) initialWatch := []*discovery.DiscoveryRequest{} for _, typeURL := range watch { initialWatch = append(initialWatch, &discovery.DiscoveryRequest{TypeUrl: typeURL}) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcgen_test.go
if err != nil { t.Fatal(err) } testRBAC(t, grpcServer, xdsresolver, "echo-rbac-mtls", port, lis) }) }) t.Run("persistent", func(t *testing.T) { proxy := ds.SetupProxy(&model.Proxy{Metadata: &model.NodeMetadata{ Generator: "grpc", }}) adscConn := ds.Connect(proxy, []string{}, []string{}) adscConn.Send(&discovery.DiscoveryRequest{ TypeUrl: v3.ListenerType, })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
t.Helper() retry.UntilSuccessOrFail(t, func() error { got := xdstest.ExtractLoadAssignments(s.Endpoints(s.SetupProxy(&model.Proxy{Metadata: metadata}))) sort.Strings(got[cluster]) sort.Strings(expected) if !reflect.DeepEqual(got[cluster], expected) {
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/networking/core/route/route_test.go
&model.Port{ Name: "default", Port: 8080, Protocol: protocol.HTTP, }, }, }, } node := func(cg *core.ConfigGenTest) *model.Proxy { return cg.SetupProxy(&model.Proxy{ Type: model.SidecarProxy, IPAddresses: []string{"1.1.1.1"}, ID: "someID", DNSDomain: "foo.com", IstioVersion: &model.IstioVersion{ Major: 1, Minor: 20,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 88.1K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
m.InboundTrafficPolicy.Mode = meshconfig.MeshConfig_InboundTrafficPolicy_LOCALHOST } return m }(), }) sim := simulation.NewSimulationFromConfigGen(t, s, s.SetupProxy(tt.proxy)) clusters := xdstest.FilterClusters(sim.Clusters, func(c *cluster.Cluster) bool { return strings.HasPrefix(c.Name, "inbound") }) if len(s.PushContext().ProxyStatus) != 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0) -
pilot/pkg/networking/core/gateway_simulation_test.go
runTest := func(t *testing.T) { o.ConfigString = tt.config o.KubernetesObjectString = tt.kubeConfig s := xds.NewFakeDiscoveryServer(t, o) sim := simulation.NewSimulation(t, s, s.SetupProxy(proxy)) sim.RunExpectations(tt.calls) if t.Failed() && debugMode { t.Log(xdstest.MapKeys(xdstest.ExtractClusters(sim.Clusters))) t.Log(xdstest.ExtractListenerNames(sim.Listeners))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 18:27:40 UTC 2024 - 46.5K bytes - Viewed (0) -
pilot/pkg/xds/eds_test.go
func TestSAUpdate(t *testing.T) { test.SetAtomicBoolForTest(t, features.SendUnhealthyEndpoints, false) s := xdsfake.NewFakeDiscoveryServer(t, xdsfake.FakeOptions{}) ads := s.Connect(s.SetupProxy(nil), nil, []string{v3.ClusterType}) ports := model.PortList{ { Name: "http", Port: 80, Protocol: protocol.HTTP, }, } svc := &model.Service{ Ports: ports,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0)