- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for IsProxylessGRPC (0.26 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)