Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for serviceMap (0.17 sec)

  1. 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)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/addresses_test.go

    			ServerAddress: "ExternalAddress",
    		},
    	}
    	internalAddressCIDRMap := []metav1.ServerAddressByClientCIDR{
    		publicAddressCIDRMap[0],
    		{
    			ClientCIDR:    "10.0.0.0/24",
    			ServerAddress: "serviceIP",
    		},
    	}
    	internalIP := "10.0.0.1"
    	publicIP := "1.1.1.1"
    	testCases := []struct {
    		Request     http.Request
    		ExpectedMap []metav1.ServerAddressByClientCIDR
    	}{
    		{
    			Request:     http.Request{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 20 08:42:09 UTC 2021
    - 2.7K bytes
    - Viewed (0)
  3. 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)
  4. pkg/controlplane/controller/kubernetesservice/controller.go

    }
    
    type Config struct {
    	PublicIP net.IP
    
    	EndpointReconciler reconcilers.EndpointReconciler
    	EndpointInterval   time.Duration
    
    	// ServiceIP indicates where the kubernetes service will live.  It may not be nil.
    	ServiceIP                 net.IP
    	ServicePort               int
    	PublicServicePort         int
    	KubernetesServiceNodePort int
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 16 16:33:01 UTC 2023
    - 9.3K bytes
    - Viewed (0)
  5. 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)
  6. 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)
Back to top