- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for serviceMap (0.24 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/server.go
Error string // error, if any. next *Response // for free list in Server } // Server represents an RPC Server. type Server struct { serviceMap sync.Map // map[string]*service reqLock sync.Mutex // protects freeReq freeReq *Request respLock sync.Mutex // protects freeResp freeResp *Response } // NewServer returns a new [Server].
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 21.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/egressselector/egress_selector.go
func NewEgressSelector(config *apiserver.EgressSelectorConfiguration) (*EgressSelector, error) { if config == nil || config.EgressSelections == nil { // No Connection Services configured, leaving the serviceMap empty, will return default dialer. return nil, nil } cs := &EgressSelector{ egressToDialer: make(map[EgressType]utilnet.DialFunc), } for _, service := range config.EgressSelections {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 12.5K 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) -
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) -
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)