- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for svcname (0.16 sec)
-
pkg/proxy/winkernel/proxier.go
func (proxier *Proxier) cleanupAllPolicies() { for svcName, svc := range proxier.svcPortMap { svcInfo, ok := svc.(*serviceInfo) if !ok { klog.ErrorS(nil, "Failed to cast serviceInfo", "serviceName", svcName) continue } svcInfo.cleanupAllPolicies(proxier.endpointsMap[svcName], proxier.mapStaleLoadbalancers, false) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
svcPort := &servicePortInfo{BaseServicePortInfo: bsvcPortInfo} // Store the following for performance reasons. svcName := types.NamespacedName{Namespace: service.Namespace, Name: service.Name} svcPortName := proxy.ServicePortName{NamespacedName: svcName, Port: port.Name} protocol := strings.ToLower(string(svcPort.Protocol())) svcPort.nameString = svcPortName.String()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
totalEndpoints := 0 for svcName := range proxier.svcPortMap { totalEndpoints += len(proxier.endpointsMap[svcName]) } // These two variables are used to publish the sync_proxy_rules_no_endpoints_total // metric. serviceNoLocalEndpointsTotalInternal := 0 serviceNoLocalEndpointsTotalExternal := 0 // Build rules for each service-port. for svcName, svc := range proxier.svcPortMap {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pilot/pkg/model/sidecar_test.go
} func TestContainsEgressDependencies(t *testing.T) { const ( svcName = "svc1.com" nsName = "ns" drName = "dr1" vsName = "vs1" ) allContains := func(ns string, contains bool) map[ConfigKey]bool { return map[ConfigKey]bool{ {kind.ServiceEntry, svcName, ns}: contains, {kind.VirtualService, vsName, ns}: contains, {kind.DestinationRule, drName, ns}: contains, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 07 09:38:49 UTC 2024 - 74.3K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
svcPort := &servicePortInfo{BaseServicePortInfo: bsvcPortInfo} // Store the following for performance reasons. svcName := types.NamespacedName{Namespace: service.Namespace, Name: service.Name} svcPortName := proxy.ServicePortName{NamespacedName: svcName, Port: port.Name} svcPort.nameString = svcPortName.String() return svcPort }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
for i := 0; i < fakeSvcCounts; i++ { svcName := fmt.Sprintf("svc-fake-%d", i) createServiceWait(controller, svcName, "nsfake", nil, map[string]string{ annotation.AlphaKubernetesServiceAccounts.Name: k8sSaOnVM, annotation.AlphaCanonicalServiceAccounts.Name: canonicalSaOnVM, }, []int32{8080}, map[string]string{"app": "prod-app"}, t) createEndpoints(t, controller, svcName, "nsfake", portNames, svc1Ips, nil, nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pilot/pkg/model/push_context_test.go
numSvc := 0 svcList := []string{} for _, service := range services { svcName := service.Attributes.Name svcNS := service.Attributes.Namespace if svcNS != ns && svcNS != rootNS { numSvc++ } svcList = append(svcList, fmt.Sprintf("%v.%v.cluster.local", svcName, svcNS)) } if sidecarScopeEnabled && numSvc > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 95.3K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
describeNamespace = ctx.NamespaceOrDefault(ctx.Namespace()) svcName, ns := handlers.InferPodInfo(args[0], ctx.NamespaceOrDefault(ctx.Namespace())) client, err := ctx.CLIClient() if err != nil { return err } svc, err := client.Kube().CoreV1().Services(ns).Get(context.TODO(), svcName, metav1.GetOptions{}) if err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 50.4K bytes - Viewed (0) -
pkg/proxy/endpointschangetracker_test.go
} for svcName := range tc.expectedNewlyActiveUDPServices { found := false for _, newSvcName := range result.NewlyActiveUDPServices { if newSvcName == svcName { found = true } } if !found { t.Errorf("[%d] expected newlyActiveUDPServices[%v], but didn't find it: %v", tci, svcName, result.NewlyActiveUDPServices) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 79.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
return webSocket } open fun newBuilder(): Builder = Builder(this) @JvmName("-deprecated_dispatcher") @Deprecated( message = "moved to val", replaceWith = ReplaceWith(expression = "dispatcher"), level = DeprecationLevel.ERROR, ) fun dispatcher(): Dispatcher = dispatcher @JvmName("-deprecated_connectionPool") @Deprecated( message = "moved to val",
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 06 04:21:33 UTC 2024 - 52K bytes - Viewed (0)