- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for serviceMap (0.17 sec)
-
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) -
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) -
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/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) -
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/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)