- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 74 for proxyv2 (0.3 sec)
-
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
// GetProxyServiceTargets returns service instances co-located with a given proxy // TODO: this code does not return k8s service instances when the proxy's IP is a workload entry // To tackle this, we need a ip2instance map like what we have in service entry. func (esc *endpointSliceController) GetProxyServiceTargets(proxy *model.Proxy) []model.ServiceTarget { eps := esc.slices.List(proxy.Metadata.Namespace, endpointSliceSelector) var out []model.ServiceTarget
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/networking/core/networkfilter_test.go
Services: []*model.Service{ buildServiceWithPort("example.com", 443, protocol.TLS, tnow), buildServiceWithPort("tunnel-proxy.com", 3128, protocol.HTTP, tnow), }, }) proxy := cg.SetupProxy(&model.Proxy{ConfigNamespace: ns}) lb := ListenerBuilder{node: proxy, push: cg.PushContext()} filters := lb.buildOutboundNetworkFilters(tt.routeDestinations,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 25.8K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_traffic_policy.go
opts *buildClusterOpts, proxyProtocol *networking.TrafficPolicy_ProxyProtocol, ) { if proxyProtocol == nil { return } c := opts.mutable if c.cluster.TransportSocket != nil { // add an upstream proxy protocol wrapper for transportSocket c.cluster.TransportSocket = &core.TransportSocket{ Name: "envoy.transport_sockets.upstream_proxy_protocol",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 20K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
Zone: proxy.XdsNode.Locality.GetZone(), SubZone: proxy.XdsNode.Locality.GetSubZone(), } } // add topology labels to proxy labels proxy.Labels = labelutil.AugmentLabels( proxy.Labels, proxy.Metadata.ClusterID, util.LocalityToString(proxy.Locality), proxy.GetNodeName(), proxy.Metadata.Network, ) } func localityFromProxyLabels(proxy *model.Proxy) *core.Locality {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
pkg/features/kube_features.go
// owner: @ksubrmnn // alpha: v1.14 // // Allows kube-proxy to create DSR loadbalancers for Windows WinDSR featuregate.Feature = "WinDSR" // owner: @ksubrmnn // alpha: v1.14 // beta: v1.20 // // Allows kube-proxy to run in Overlay mode for Windows WinOverlay featuregate.Feature = "WinOverlay" // owner: @marosset
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 22:51:23 UTC 2024 - 45.2K bytes - Viewed (0) -
pkg/config/validation/agent/validation.go
// but that requires additional test validation if config.DiscoveryAddress == "" { errs = multierror.Append(errs, errors.New("discovery address must be set to the proxy discovery service")) } else if err := ValidateProxyAddress(config.DiscoveryAddress); err != nil { errs = multierror.Append(errs, multierror.Prefix(err, "invalid discovery address:")) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 30.9K bytes - Viewed (0) -
pkg/security/security.go
ECCSigAlg string // The type of curve to use when generating private keys with ECC. Currently only ECDSA is supported. ECCCurve string // FileMountedCerts indicates whether the proxy is using file // mounted certs created by a foreign CA. Refresh is managed by the external // CA, by updating the Secret or VM file. We will watch the file for changes
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 19.1K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller.go
} func autoregisteredWorkloadEntryName(proxy *model.Proxy) string { if proxy.Metadata.AutoRegisterGroup == "" { return "" } if len(proxy.IPAddresses) == 0 { log.Errorf("auto-registration of %v failed: missing IP addresses", proxy.ID) return "" } if len(proxy.Metadata.Namespace) == 0 { log.Errorf("auto-registration of %v failed: missing namespace", proxy.ID) return "" }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
}, } // SidecarScope for the proxy may has not been updated based on this pushContext. // It can happen when `processRequest` comes after push context has been updated(s.initPushContext), // but before proxy's SidecarScope has been updated(s.updateProxy). if con.proxy.SidecarScope != nil && con.proxy.SidecarScope.Version != request.Push.PushVersion { s.computeProxyState(con.proxy, request) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pkg/istio-agent/agent.go
// Shared properties with Pilot Proxy struct. type Proxy struct { ID string IPAddresses []string Type model.NodeType ipMode model.IPMode DNSDomain string } func (node *Proxy) DiscoverIPMode() { node.ipMode = model.DiscoverIPMode(node.IPAddresses) } // IsIPv6 returns true if proxy only supports IPv6 addresses. func (node *Proxy) IsIPv6() bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 26.7K bytes - Viewed (0)