- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 128 for svcname (0.2 sec)
-
pilot/pkg/networking/grpcgen/grpcgen_test.go
func initPersistent(sd *memory.ServiceDiscovery) { ns := "test" svcname := "echo-persistent" hn := svcname + "." + ns + ".svc.cluster.local" sd.AddService(&model.Service{ Attributes: model.ServiceAttributes{ Name: svcname, Namespace: ns, Labels: map[string]string{features.PersistentSessionLabel: "test-cookie:/Service/Method"}, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/xds/proxy_dependencies_test.go
"istio.io/istio/pkg/spiffe" "istio.io/istio/pkg/test" "istio.io/istio/pkg/util/sets" ) func TestProxyNeedsPush(t *testing.T) { const ( svcName = "svc1.com" privateSvcName = "private.com" drName = "dr1" vsName = "vs1" scName = "sc1" nsName = "ns1" nsRoot = "rootns" generalName = "name1" invalidNameSuffix = "invalid" )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/test/framework/components/istio/util.go
} svc, err := cluster.Kube().CoreV1().Services(ns).Get(context.TODO(), svcName, metav1.GetOptions{}) if err != nil { return nil, false, err } if len(svc.Spec.Ports) == 0 { return nil, false, fmt.Errorf("no ports found in service: %s/%s", ns, svcName) } var nodePort int32 for _, svcPort := range svc.Spec.Ports { if svcPort.Protocol == "TCP" && svcPort.Port == int32(port) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 17:13:34 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/proxy/util/utils.go
errMsg := fmt.Sprintf("%s in %s has incorrect IP version", fieldValue, fieldName) klog.ErrorS(nil, "Incorrect IP version", "service", klog.KRef(svcNamespace, svcName), "field", fieldName, "value", fieldValue) if recorder != nil { recorder.Eventf( &v1.ObjectReference{ Kind: "Service", Name: svcName, Namespace: svcNamespace,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 7.4K bytes - Viewed (0) -
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/registry/core/service/storage/storage.go
} } obj, err := r.endpoints.Get(ctx, svcName, &metav1.GetOptions{}) if err != nil { return nil, nil, err } eps := obj.(*api.Endpoints) if len(eps.Subsets) == 0 { return nil, nil, errors.NewServiceUnavailable(fmt.Sprintf("no endpoints available for service %q", svcName)) } // Pick a random Subset to start searching from.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 13:09:33 UTC 2024 - 22.3K 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/controller/endpointslicemirroring/endpointslicemirroring_controller.go
// ensures that we handle changes to this label. svcName := endpointSlice.Labels[discovery.LabelServiceName] prevSvcName := prevEndpointSlice.Labels[discovery.LabelServiceName] if svcName != prevSvcName { logger.Info("LabelServiceName changed", "labelServiceName", discovery.LabelServiceName, "oldName", prevSvcName, "newName", svcName, "endpointSlice", klog.KObj(endpointSlice))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.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) -
pkg/controller/endpointslice/endpointslice_controller.go
// ensures that we handle changes to this label. svcName := endpointSlice.Labels[discovery.LabelServiceName] prevSvcName := prevEndpointSlice.Labels[discovery.LabelServiceName] if svcName != prevSvcName { logger.Info("label changed", "label", discovery.LabelServiceName, "oldService", prevSvcName, "newService", svcName, "endpointslice", klog.KObj(endpointSlice)) c.queueServiceForEndpointSlice(endpointSlice)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0)