- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 128 for svcname (0.15 sec)
-
tests/integration/pilot/common/routing.go
{{. | indent 8}} `, svcName, svcName) cookieWithTTLDest := fmt.Sprintf(` --- apiVersion: networking.istio.io/v1beta1 kind: DestinationRule metadata: name: %s spec: host: %s trafficPolicy: loadBalancer: consistentHash: httpCookie: name: session-cookie ttl: 3600s `, svcName, svcName)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 21:52:51 UTC 2024 - 135.9K 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_test.go
} for svcName := range tc.expectedNewlyActiveUDPServices { found := false for _, stale := range result.NewlyActiveUDPServices { if stale == svcName { found = true break } } if !found { t.Errorf("[%d] expected staleServiceNames[%v], but didn't find it: %v", tci, svcName, result.NewlyActiveUDPServices) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K 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/registry/core/service/storage/storage_test.go
}) } } func TestDeleteWithFinalizer(t *testing.T) { svcName := "foo" storage, _, server := newStorage(t, []api.IPFamily{api.IPv4Protocol, api.IPv6Protocol}) defer server.Terminate(t) defer storage.Store.DestroyFunc() // This will allocate cluster IPs, NodePort, and HealthCheckNodePort. svc := svctest.MakeService(svcName, svctest.SetTypeLoadBalancer,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 440.2K bytes - Viewed (0) -
pkg/proxy/nftables/proxier_test.go
} for svcName := range tc.expectedNewlyActiveUDPServices { found := false for _, stale := range result.NewlyActiveUDPServices { if stale == svcName { found = true } } if !found { t.Errorf("[%d] expected staleServiceNames[%v], but didn't find it: %v", tci, svcName, result.NewlyActiveUDPServices) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 173.5K 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)