- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 53 for NamespacedName (0.34 sec)
-
pilot/pkg/config/kube/ingress/controller.go
// by ingress using port name. namespacedName := config.NamespacedName(curSvc).String() for _, ingress := range c.ingress.List(curSvc.GetNamespace(), klabels.Everything()) { referredSvcSet := extractServicesByPortNameType(ingress) if referredSvcSet.Contains(namespacedName) { c.queue.AddObject(ingress) } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 03:53:05 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier_test.go
svcPort1 := 80 svcNodePort1 := 3001 svcPortName1 := proxy.ServicePortName{ NamespacedName: makeNSN("ns1", "svc1"), Port: "p80", Protocol: v1.ProtocolTCP, } svcIP2 := "10.20.30.42" svcPort2 := 80 svcNodePort2 := 3002 svcPortName2 := proxy.ServicePortName{ NamespacedName: makeNSN("ns1", "svc2"), Port: "p80", Protocol: v1.ProtocolTCP, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 28 14:30:51 UTC 2024 - 30.2K bytes - Viewed (0) -
tests/integration/ambient/main_test.go
echos = match.Not(match.ServiceName(echo.NamespacedName{Name: cdeployment.ExternalSvc, Namespace: apps.ExternalNamespace})).GetMatches(echos) apps.All = echos apps.WorkloadAddressedWaypoint = match.ServiceName(echo.NamespacedName{Name: WorkloadAddressedWaypoint, Namespace: apps.Namespace}).GetMatches(echos)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 10.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
configKey: key, parent: namespacedName, } if event == model.EventDelete { s.serviceInstances.deleteServiceEntryInstances(namespacedName, key) s.serviceInstances.deleteInstanceKeys(parentKey, instancesUpdated) } else { s.serviceInstances.updateInstances(parentKey, instancesUpdated) s.serviceInstances.updateServiceEntryInstancesPerConfig(namespacedName, key, instance) } addConfigs(se, services)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
pilot/pkg/model/virtualservice.go
importedVirtualServices := make([]config.Config, 0) vsset := sets.New[types.NamespacedName]() addVirtualService := func(vs config.Config, hc hostClassification) { key := vs.NamespacedName() if vsset.Contains(key) { return } rule := vs.Spec.(*networking.VirtualService) useGatewaySemantics := UseGatewaySemantics(vs)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 11:17:03 UTC 2024 - 17.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/waypoints.go
return nil, true } namespacedName := strings.Split(labelValue, "/") switch len(namespacedName) { case 1: return &krt.Named{ Name: namespacedName[0], Namespace: defaultNamespace, }, false case 2: return &krt.Named{ Name: namespacedName[1], Namespace: namespacedName[0], }, false default: // malformed label error
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:28 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/config/model.go
func (c Config) GetNamespace() string { return c.Namespace } func (c Config) GetCreationTimestamp() time.Time { return c.CreationTimestamp } func (c Config) NamespacedName() kubetypes.NamespacedName { return kubetypes.NamespacedName{ Namespace: c.Namespace, Name: c.Name, } } var _ fmt.Stringer = GroupVersionKind{} type GroupVersionKind struct { Group string `json:"group"`
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 12.6K bytes - Viewed (0) -
pkg/test/framework/components/echo/config.go
} } // NamespaceName returns the string name of the namespace. func (c Config) NamespaceName() string { return c.NamespacedName().NamespaceName() } // NamespacedName returns the namespaced name for the service. func (c Config) NamespacedName() NamespacedName { return NamespacedName{ Name: c.Service, Namespace: c.Namespace, } } func (c Config) AccountName() string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 12:26:52 UTC 2024 - 18.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
outMap[se.namespacedName] = mcsService } // Add the ServiceImport info. for _, si := range c.imports.ImportedServices() { mcsService := outMap[si.namespacedName] mcsService.Cluster = c.Cluster() mcsService.Name = si.namespacedName.Name mcsService.Namespace = si.namespacedName.Namespace mcsService.Imported = true mcsService.ClusterSetVIP = si.clusterSetVIP outMap[si.namespacedName] = mcsService }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pilot/pkg/model/extensions.go
if matcher.ShouldAttachPolicy(gvk.WasmPlugin, p.NamespacedName(), p) { return matchTrafficSelectors(p.Match, li) } // If it doesn't match one of the above cases, the plugin is not bound to this workload return false } func (p *WasmPluginWrapper) NamespacedName() types.NamespacedName { return types.NamespacedName{Name: p.Name, Namespace: p.Namespace} }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 11K bytes - Viewed (0)