- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for NamespacedName (0.17 sec)
-
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) -
pilot/pkg/model/sidecar_test.go
virtualServices []config.Config services []*Service expectedIndex map[host.Name]types.NamespacedName oldestWins bool }{ { name: "most specific", virtualServices: virtualServices, services: services, expectedIndex: map[host.Name]types.NamespacedName{ "foo.example.com": {Name: "foo", Namespace: "default"},
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) -
tests/integration/ambient/baseline_test.go
New(t, apps.All). // TODO eventually we can do this for uncaptured -> l7 FromMatch(match.Not(match.ServiceName(echo.NamespacedName{ Name: "uncaptured", Namespace: apps.Namespace, }))). ToMatch(match.ServiceName(echo.NamespacedName{ Name: "uncaptured", Namespace: apps.Namespace, })). Config(cfg.WithParams(param.Params{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 78.4K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
args.GwMatches = make([]types.NamespacedName, 0, len(args.Matches)) for _, m := range args.Matches { spl := strings.Split(m, ".") if len(spl) != 5 { t.Skipf("unsupported match: %v", spl) } if spl[0] == "*" { t.Skipf("unsupported match: %v", spl) } args.GwMatches = append(args.GwMatches, types.NamespacedName{ Namespace: spl[1], Name: spl[0],
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
true, schema.GroupResource{Resource: "pods"}, "1", ) forgetWatcherFn = forgetWatcher(cacher, w, 0, namespacedName{}, "", false) addWatcher := func(w *cacheWatcher) { cacher.Lock() defer cacher.Unlock() cacher.watchers.addWatcher(w, 0, namespacedName{}, "", false) } addWatcher(w) assertCacherInternalState(1, 0) forgetWatcherWrapped(false)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
Phase: corev1.PodRunning, }, } controller, fx := NewFakeControllerWithOptions(t, FakeControllerOptions{}) addPods(t, controller, fx, inputPod) output := controller.pods.getPodByKey(config.NamespacedName(expectPod)) // The final pod status conditions will be determined by the function addPods. // So we assign these status conditions to expect pod. expectPod.Status.Conditions = output.Status.Conditions
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0)