- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for serviceMap (0.29 sec)
-
pilot/pkg/serviceregistry/aggregate/controller_test.go
// Set up ground truth hostname values serviceMap := map[host.Name]bool{ mock.HelloService.Hostname: false, mock.ExtHTTPService.Hostname: false, mock.WorldService.Hostname: false, mock.ExtHTTPSService.Hostname: false, } svcCount := 0 // Compare return value to ground truth for _, svc := range services { if counted, existed := serviceMap[svc.Hostname]; existed && !counted { svcCount++
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0) -
src/net/rpc/debug.go
type debugHTTP struct { *Server } // Runs at /debug/rpc func (server debugHTTP) ServeHTTP(w http.ResponseWriter, req *http.Request) { // Build a sorted version of the data. var services serviceArray server.serviceMap.Range(func(snamei, svci any) bool { svc := svci.(*service) ds := debugService{svc, snamei.(string), make([]debugMethod, 0, len(svc.method))} for mname, method := range svc.method {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 2.3K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
if _, exists := serviceMap[serviceName]; !exists { serviceMap[serviceName] = service } } else if service.Namespace == ns && enableServiceLinks { serviceMap[serviceName] = service } } mappedServices := []*v1.Service{} for key := range serviceMap { mappedServices = append(mappedServices, serviceMap[key]) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
cluster/gce/windows/smoke-test.sh
local service="metrics-server" local service_ip service_ip=$($kubectl get service --namespace kube-system $service \ -o jsonpath='{.spec.clusterIP}') local service_port service_port=$($kubectl get service --namespace kube-system $service \ -o jsonpath='{.spec.ports[?(@.protocol=="TCP")].port}') echo "curl-ing $service address from Linux pod: $service_ip:$service_port"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 20.6K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/status_test.go
) var ( serviceIP = "1.2.3.4" hostname = "foo.bar.com" nodeIP = "10.0.0.2" ) var ingressService = &corev1.Service{ ObjectMeta: metav1.ObjectMeta{ Name: "istio-ingress", Namespace: IngressNamespace, }, Status: corev1.ServiceStatus{ LoadBalancer: corev1.LoadBalancerStatus{ Ingress: []corev1.LoadBalancerIngress{{ IP: serviceIP, }}, }, }, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.8K bytes - Viewed (0) -
pkg/registry/core/service/strategy.go
newSvc.Spec.LoadBalancerClass = nil } // If a user is switching to a type that doesn't need ExternalTrafficPolicy // AND they did not change this field, it is safe to drop it. if serviceapi.ExternallyAccessible(oldSvc) && !serviceapi.ExternallyAccessible(newSvc) && sameExternalTrafficPolicy(oldSvc, newSvc) { newSvc.Spec.ExternalTrafficPolicy = api.ServiceExternalTrafficPolicy("") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 13:09:36 UTC 2024 - 14.1K bytes - Viewed (0) -
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) -
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)