- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 24 for serviceMap (0.19 sec)
-
pilot/pkg/serviceregistry/kube/controller/controller.go
namespaceDiscoveryHandlers []func(ns string, event model.Event) // This is only used for test stop chan struct{} sync.RWMutex // servicesMap stores hostname ==> service, it is used to reduce convertService calls. servicesMap map[host.Name]*model.Service // nodeSelectorsForServices stores hostname => label selectors that can be used to // refine the set of node port IPs for a service.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
tests/integration/pilot/mcs/discoverability/discoverability_test.go
} return nil }) } // Now wait for ServiceImport to be created serviceA = match.ServiceName(echo.NamespacedName{Name: common.ServiceA, Namespace: echos.Namespace}) importClusters := serviceA.GetMatches(echos.Instances).Clusters() if common.IsMCSControllerEnabled(t) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/proxy/winkernel/hns_test.go
id := loadBalancerIdentifier{protocol: protocol, internalPort: internalPort, externalPort: externalPort, vip: serviceVip, endpointsHash: hash} lbs[id] = &loadBalancerInfo{hnsID: LoadBalancer.Id} lb, err := hns.getLoadBalancer(endpoints, loadBalancerFlags{}, sourceVip, serviceVip, protocol, internalPort, externalPort, lbs) if err != nil { t.Error(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 15.4K bytes - Viewed (0) -
tests/integration/pilot/mcs/common/common.go
"istio.io/istio/pkg/test/framework/components/namespace" "istio.io/istio/pkg/test/framework/resource" "istio.io/istio/pkg/test/framework/resource/config/apply" "istio.io/istio/pkg/test/util/tmpl" ) const ( ServiceA = "svc-a" ServiceB = "svc-b" ) func IsMCSControllerEnabled(t resource.Context) bool { return KubeSettings(t).MCSControllerEnabled } func KubeSettings(t resource.Context) *kube.Settings {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 27 17:09:00 UTC 2022 - 3.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
// It iterates over all services, because mesh networks can be set with a service name. func (c *Controller) reloadNetworkGateways() { c.Lock() gwsChanged := false for _, svc := range c.servicesMap { if c.extractGatewaysInner(svc) { gwsChanged = true break } } c.Unlock() if gwsChanged { c.NotifyGatewayHandlers() // TODO ConfigUpdate via gateway handler
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceexportcache.go
clusterSetLocalHost := serviceClusterSetLocalHostname(es.namespacedName) for _, hostName := range []host.Name{clusterLocalHost, clusterSetLocalHost} { if svc := ec.servicesMap[hostName]; svc != nil { es.discoverability[hostName] = ec.EndpointDiscoverabilityPolicy(svc).String() } } out = append(out, es) } ec.RUnlock() return out }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache.go
info := importedService{ namespacedName: config.NamespacedName(usi), } // Lookup the synthetic MCS service. hostName := serviceClusterSetLocalHostnameForKR(usi) svc := ic.servicesMap[hostName] if svc != nil { if vips := svc.ClusterVIPs.GetAddressesFor(ic.Cluster()); len(vips) > 0 { info.clusterSetVIP = vips[0] } } out = append(out, info) } ic.RUnlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.2K bytes - Viewed (0) -
pilot/pkg/model/sidecar.go
// each listener imports an independent set of virtual services. // Listener 1 could import a public virtual service for serviceA from // namespace A that has some path rewrite, while listener2 could import // a private virtual service for serviceA from the local namespace, // with a different path rewrite or no path rewrites. virtualServices []config.Config
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 20:32:23 UTC 2024 - 38.4K bytes - Viewed (0) -
cluster/gce/util.sh
function create-certs { local -r primary_cn="${1}" # Determine extra certificate names for master # Create service_ip by stripping the network mask part from # SERVICE_CLUSTER_IP_RANGE and incrementing the host part with 1 service_ip=${SERVICE_CLUSTER_IP_RANGE%/*} service_ip="${service_ip%.*}.$((${service_ip##*.} + 1))" local sans="" for extra in "$@"; do if [[ -n "${extra}" ]]; then
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 21:47:17 UTC 2024 - 161.6K bytes - Viewed (0) -
pkg/controlplane/instance.go
PublicIP: c.ControlPlane.Generic.PublicAddress, EndpointReconciler: c.Extra.EndpointReconcilerConfig.Reconciler, EndpointInterval: c.Extra.EndpointReconcilerConfig.Interval, ServiceIP: c.Extra.APIServerServiceIP, ServicePort: c.Extra.APIServerServicePort, PublicServicePort: publicServicePort, KubernetesServiceNodePort: c.Extra.KubernetesServiceNodePort,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.2K bytes - Viewed (0)