Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 14 of 14 for IsProxylessGrpc (0.27 sec)

  1. pilot/pkg/model/context.go

    }
    
    func (node *Proxy) IsVM() bool {
    	// TODO use node metadata to indicate that this is a VM instead of the TestVMLabel
    	return node.Metadata.Labels[constants.TestVMLabel] != ""
    }
    
    func (node *Proxy) IsProxylessGrpc() bool {
    	return node.Metadata != nil && node.Metadata.Generator == "grpc"
    }
    
    func (node *Proxy) GetNodeName() string {
    	if node.Metadata != nil && len(node.Metadata.NodeName) > 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 33.6K bytes
    - Viewed (0)
  2. tests/integration/pilot/common/routing.go

    						}
    						return nil
    					})
    			},
    			setupOpts: func(src echo.Caller, opts *echo.CallOptions) {
    				// TODO force this globally in echotest?
    				if src, ok := src.(echo.Instance); ok && src.Config().IsProxylessGRPC() {
    					opts.Port.Name = "grpc"
    				}
    			},
    			opts: echo.CallOptions{
    				Port: echo.Port{
    					Name: "http",
    				},
    				Count: 100,
    			},
    			workloadAgnostic: true,
    		})
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 21:52:51 UTC 2024
    - 135.9K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/gateway.go

    		Name:                           routeName,
    		VirtualHosts:                   virtualHosts,
    		ValidateClusters:               proto.BoolFalse,
    		IgnorePortInHostMatching:       !node.IsProxylessGrpc(),
    		MaxDirectResponseBodySizeBytes: istio_route.DefaultMaxDirectResponseBodySizeBytes,
    	}
    
    	return routeCfg
    }
    
    // hashRouteList returns a hash of a list of pointers
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 46.4K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/route/route.go

    	// Configure timeouts specified by Virtual Service if they are provided, otherwise set it to defaults.
    	action.Timeout = Notimeout
    	if vsTimeout != nil {
    		action.Timeout = vsTimeout
    	}
    	if node != nil && node.IsProxylessGrpc() {
    		// TODO(stevenctl) merge these paths; grpc's xDS impl will not read the deprecated value
    		action.MaxStreamDuration = &route.RouteAction_MaxStreamDuration{
    			MaxStreamDuration: action.Timeout,
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 56.1K bytes
    - Viewed (0)
Back to top