- Sort Score
- Result 10 results
- Languages All
Results 11 - 16 of 16 for PassthroughCluster (0.78 sec)
-
istioctl/pkg/writer/envoy/configdump/testdata/endpoint/configdump.json
{ "endpoint_config": { "@type": "type.googleapis.com/envoy.config.endpoint.v3.ClusterLoadAssignment", "cluster_name": "PassthroughCluster", "policy": { "overprovisioning_factor": 140 } } }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 12 02:25:59 UTC 2022 - 66K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder.go
var egressCluster string if util.IsAllowAnyOutbound(node) { // We need a passthrough filter to fill in the filter stack for orig_dst listener egressCluster = util.PassthroughCluster // no need to check for nil value as the previous if check has checked if node.SidecarScope.OutboundTrafficPolicy.EgressProxy != nil { // user has provided an explicit destination for all the unknown traffic.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 17.9K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder.go
// This cluster is used to catch all traffic to unknown listener ports func (cb *ClusterBuilder) buildDefaultPassthroughCluster() *cluster.Cluster { cluster := &cluster.Cluster{ Name: util.PassthroughCluster, ClusterDiscoveryType: &cluster.Cluster_Type{Type: cluster.Cluster_ORIGINAL_DST}, ConnectTimeout: proto.Clone(cb.req.Push.Mesh.ConnectTimeout).(*durationpb.Duration),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0) -
pilot/pkg/networking/core/httproute.go
} return } func buildCatchAllVirtualHost(node *model.Proxy, includeRequestAttemptCount bool) *route.VirtualHost { if util.IsAllowAnyOutbound(node) { egressCluster := util.PassthroughCluster notimeout := durationpb.New(0) // no need to check for nil value as the previous if check has checked if node.SidecarScope.OutboundTrafficPolicy.EgressProxy != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 32.7K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
meshconfig.MeshConfig_OutboundTrafficPolicy_REGISTRY_ONLY: util.BlackHoleCluster, meshconfig.MeshConfig_OutboundTrafficPolicy_ALLOW_ANY: util.PassthroughCluster, }[tp] t.Run("with VIP", func(t *testing.T) { testCalls := []simulation.Expect{} for name, call := range calls { e := simulation.Expect{ Name: name, Call: call,
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/listener_test.go
verifyListenerFilters(t, l.ListenerFilters) } func verifyPassThroughTCPFilterChain(t *testing.T, fc *listener.FilterChain) { t.Helper() f := fc.Filters[0] expectedStatPrefix := util.PassthroughCluster cfg, _ := conversion.MessageToStruct(f.GetTypedConfig()) statPrefix := cfg.Fields["stat_prefix"].GetStringValue() if statPrefix != expectedStatPrefix {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 93.6K bytes - Viewed (0)