Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for IsProxylessGRPC (0.32 sec)

  1. pkg/test/framework/components/echo/kube/deployment.go

    	// and all other ports on another. Additionally, we bind one port for communication between the custom image
    	// container, and the regular Go server.
    	if cfg.IsProxylessGRPC() && settings.CustomGRPCEchoImage != "" {
    		var grpcPorts, otherPorts echoCommon.PortList
    		for _, port := range containerPorts {
    			if port.Protocol == protocol.GRPC {
    				grpcPorts = append(grpcPorts, port)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 12:26:52 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  2. pkg/test/framework/components/echo/config.go

    			// Sidecar injection is enabled - it's not naked.
    			return false
    		}
    	}
    	// All subsets were annotated indicating no sidecar injection.
    	return true
    }
    
    func (c Config) IsProxylessGRPC() bool {
    	// TODO make these check if any subset has a matching annotation
    	return len(c.Subsets) > 0 && c.Subsets[0].Annotations != nil && strings.HasPrefix(c.Subsets[0].Annotations[annotation.InjectTemplates.Name], "grpc-")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 12:26:52 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  3. pilot/pkg/xds/endpoints/endpoint_builder.go

    	h.Write(Separator)
    	h.WriteString(string(b.nodeType))
    	h.Write(Separator)
    	h.WriteString(strconv.FormatBool(b.clusterLocal))
    	h.Write(Separator)
    	if b.proxy != nil {
    		h.WriteString(strconv.FormatBool(b.proxy.IsProxylessGrpc()))
    		h.Write(Separator)
    		h.WriteString(strconv.FormatBool(bool(b.proxy.Metadata.DisableHBONESend)))
    		h.Write(Separator)
    	}
    	h.WriteString(util.LocalityToString(b.locality))
    	h.Write(Separator)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 02:18:19 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  4. pkg/test/framework/components/echo/common/deployment/echos.go

    		defaultConfigs = append(defaultConfigs, proxylessGRPC)
    	}
    
    	if t.Settings().Ambient {
    		if t.Settings().AmbientEverywhere {
    			for i, config := range defaultConfigs {
    				if !config.HasSidecar() && !config.IsProxylessGRPC() {
    					scopes.Framework.Infof("adding waypoint to %s", config.NamespacedName())
    					defaultConfigs[i].ServiceWaypointProxy = "shared"
    					defaultConfigs[i].WorkloadWaypointProxy = "shared"
    				}
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 20 16:01:31 UTC 2024
    - 16K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/httproute.go

    		panic(fmt.Sprintf("unexpectedly matched multiple virtual hosts for %v: %v", routeName, virtualHosts))
    	}
    	return virtualHosts
    }
    
    func SidecarIgnorePort(node *model.Proxy) bool {
    	return !node.IsProxylessGrpc()
    }
    
    // generateVirtualHostDomains generates the set of domain matches for a service being accessed from
    // a proxy node
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 32.7K bytes
    - Viewed (0)
  6. 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)
  7. 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)
Back to top