Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for InboundPassthroughCluster (0.43 sec)

  1. pilot/pkg/networking/core/peer_authentication_simulation_test.go

    				{
    					Name:   "mtls",
    					Call:   mkCall(8000, simulation.MTLS),
    					Result: simulation.Result{ClusterMatched: "InboundPassthroughCluster"},
    				},
    				{
    					Name:   "plaintext",
    					Call:   mkCall(8000, simulation.Plaintext),
    					Result: simulation.Result{ClusterMatched: "InboundPassthroughCluster"},
    				},
    			},
    		},
    		{
    			name:   "global strict",
    			config: paStrict,
    			calls: []simulation.Expect{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/cluster_test.go

    		{
    			"no config",
    			[]string{"outbound|8080||static.test", "BlackHoleCluster", "PassthroughCluster", "InboundPassthroughCluster"},
    			nil,
    			model.SidecarProxy,
    			service,
    		},
    		{
    			"add cluster",
    			[]string{"outbound|8080||static.test", "BlackHoleCluster", "PassthroughCluster", "InboundPassthroughCluster", "new-cluster1"},
    			[]*networking.EnvoyFilter{{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 108.8K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/sidecar_simulation_test.go

    				CallMode: simulation.CallModeInbound,
    			},
    			Disabled: simulation.Result{
    				ClusterMatched: "InboundPassthroughCluster",
    			},
    			Permissive: simulation.Result{
    				ClusterMatched: "InboundPassthroughCluster",
    			},
    			Strict: simulation.Result{
    				ClusterMatched: "InboundPassthroughCluster",
    			},
    		},
    	}
    	t.Run("Disable", func(t *testing.T) {
    		calls := []simulation.Expect{}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  4. pilot/pkg/xds/deltatest.go

    	"istio.io/istio/pilot/pkg/model"
    	v3 "istio.io/istio/pilot/pkg/xds/v3"
    	"istio.io/istio/pkg/slices"
    	"istio.io/istio/pkg/util/sets"
    )
    
    var knownOptimizationGaps = sets.New(
    	"BlackHoleCluster",
    	"InboundPassthroughCluster",
    	"PassthroughCluster",
    )
    
    // compareDiff compares a Delta and SotW XDS response. This allows checking that the Delta XDS
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. pilot/pkg/xds/delta_test.go

    		ResourceNamesUnsubscribe: []string{"outbound|81||local.default.svc.cluster.local"},
    	})
    	ads.ExpectNoResponse()
    }
    
    func TestDeltaCDS(t *testing.T) {
    	base := sets.New("BlackHoleCluster", "PassthroughCluster", "InboundPassthroughCluster")
    	assertResources := func(resp *discovery.DeltaDiscoveryResponse, names ...string) {
    		t.Helper()
    		got := slices.Map(resp.Resources, (*discovery.Resource).GetName)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  6. pilot/pkg/networking/util/util.go

    	PassthroughFilterChain = "PassthroughFilterChain"
    
    	// Inbound pass through cluster need to the bind the loopback ip address for the security and loop avoidance.
    	InboundPassthroughCluster = "InboundPassthroughCluster"
    
    	// IstioMetadataKey is the key under which metadata is added to a route or cluster
    	// regarding the virtual service or destination rule used for each
    	IstioMetadataKey = "istio"
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  7. pilot/pkg/networking/core/cluster_builder.go

    				Address:       InboundPassthroughBindIpv6,
    				PortSpecifier: &core.SocketAddress_PortValue{PortValue: uint32(0)},
    			},
    		})
    	}
    	c := cb.buildDefaultPassthroughCluster()
    	c.Name = util.InboundPassthroughCluster
    	c.Filters = nil
    	c.UpstreamBindConfig = &core.BindConfig{
    		SourceAddress: &core.SocketAddress{
    			Address:       src,
    			PortSpecifier: &core.SocketAddress_PortValue{PortValue: uint32(0)},
    		},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 31.6K bytes
    - Viewed (0)
  8. pilot/pkg/networking/core/listener_inbound.go

    					// but this is backwards compatible and there aren't any perfect options.
    					Port:     0,
    					Protocol: protocol.Unsupported,
    				},
    				TargetPort: mtls.Port,
    			},
    			clusterName: util.InboundPassthroughCluster,
    			passthrough: true,
    			hbone:       lb.node.IsWaypointProxy(),
    		}
    		opts := getFilterChainMatchOptions(mtls, istionetworking.ListenerProtocolAuto)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 35.1K bytes
    - Viewed (0)
Back to top