- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 61 for svcname (0.12 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/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/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/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) -
pkg/scheduler/framework/plugins/volumezone/volume_zone.go
continue } pvcName := volume.PersistentVolumeClaim.ClaimName if pvcName == "" { return nil, framework.NewStatus(framework.UnschedulableAndUnresolvable, "PersistentVolumeClaim had no name") } pvc, err := pl.pvcLister.PersistentVolumeClaims(pod.Namespace).Get(pvcName) if s := getErrorAsStatus(err); !s.IsSuccess() { return nil, s } pvName := pvc.Spec.VolumeName if pvName == "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/csi.go
namespace := pvc.Namespace pvcName := pvc.Name scName := storagehelpers.GetPersistentVolumeClaimClass(pvc) // If StorageClass is not set or not found, then PVC must be using immediate binding mode // and hence it must be bound before scheduling. So it is safe to not count it. if scName == "" { logger.V(5).Info("PVC has no StorageClass", "PVC", klog.KObj(pvc)) return "", ""
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/csi_test.go
pvLister: getFakeCSIPVLister(test.filterName, test.driverNames...), pvcLister: append(getFakeCSIPVCLister(test.filterName, scName, test.driverNames...), test.extraClaims...), scLister: getFakeCSIStorageClassLister(scName, test.driverNames[0]), randomVolumeIDPrefix: rand.String(32), translator: csiTranslator, } _, ctx := ktesting.NewTestContext(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 28.6K bytes - Viewed (0) -
src/cmd/compile/internal/walk/switch.go
} // walkSwitchType generates an AST that implements sw, where sw is a // type switch. func walkSwitchType(sw *ir.SwitchStmt) { var s typeSwitch s.srcName = sw.Tag.(*ir.TypeSwitchGuard).X s.srcName = walkExpr(s.srcName, sw.PtrInit()) s.srcName = copyExpr(s.srcName, s.srcName.Type(), &sw.Compiled) s.okName = typecheck.TempAt(base.Pos, ir.CurFunc, types.Types[types.TBOOL])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 17:34:01 UTC 2024 - 30.1K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
return true } func (c *Controller) processPVC(ctx context.Context, pvcNamespace, pvcName string) error { logger := klog.FromContext(ctx) logger.V(4).Info("Processing PVC", "PVC", klog.KRef(pvcNamespace, pvcName)) startTime := time.Now() defer func() { logger.V(4).Info("Finished processing PVC", "PVC", klog.KRef(pvcNamespace, pvcName), "duration", time.Since(startTime)) }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0)