- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 81 for NamespacedName (0.31 sec)
-
pilot/pkg/serviceregistry/serviceentry/util_test.go
}, } expected := map[types.NamespacedName]*config.Config{ {Namespace: "default", Name: "se-1"}: &se1, {Namespace: "default", Name: "se-3"}: &se3, } got := getWorkloadServiceEntries(ses, wle) if !reflect.DeepEqual(got, expected) { t.Errorf("recv unexpected se: %v", got) } } func TestCompareServiceEntries(t *testing.T) { oldSes := map[types.NamespacedName]*config.Config{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 17 22:32:10 UTC 2023 - 3.5K bytes - Viewed (0) -
pilot/pkg/networking/core/extension_config_builder.go
extensions = append(extensions, extension.InsertedExtensionConfigurations(wasmPlugins, extensionConfigNames, pullSecrets)...) return extensions } func parseExtensionName(names []string) []types.NamespacedName { res := make([]types.NamespacedName, 0, len(names)) for _, n := range names { if !strings.HasPrefix(n, model.WasmPluginResourceNamePrefix) { log.Warnf("ignoring unknown ECDS: %v", n) continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 2.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/workloadinstances/util.go
// corresponds to a given proxy, if any. func InstanceNameForProxy(proxy *model.Proxy) types.NamespacedName { parts := strings.Split(proxy.ID, ".") if len(parts) == 2 && proxy.ConfigNamespace == parts[1] { return types.NamespacedName{Name: parts[0], Namespace: parts[1]} } return types.NamespacedName{} } // GetInstanceForProxy returns a workload instance that // corresponds to a given proxy, if any.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 17:36:41 UTC 2023 - 2.8K bytes - Viewed (0) -
tests/integration/security/util/reachability/context.go
for index, namespacedName := range apps.EchoNamespace.All.NamespacedNames() { switch { case namespacedName.Name == ASvc: A = apps.EchoNamespace.All[index] case namespacedName.Name == BSvc: B = apps.EchoNamespace.All[index] case namespacedName.Name == CSvc: C = apps.EchoNamespace.All[index] case namespacedName.Name == DSvc: D = apps.EchoNamespace.All[index]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 23 21:20:43 UTC 2022 - 8.6K bytes - Viewed (0) -
pkg/proxy/config/api_test.go
ObjectMeta: metav1.ObjectMeta{Namespace: "testnamespace", Name: "bar"}, } expectedSvcState := map[types.NamespacedName]*v1.Service{ {Name: svc1.Name, Namespace: svc1.Namespace}: svc1, {Name: svc2.Name, Namespace: svc2.Namespace}: svc2, } expectedEpsState := map[types.NamespacedName]*discoveryv1.EndpointSlice{ {Name: eps1.Name, Namespace: eps1.Namespace}: eps1, {Name: eps2.Name, Namespace: eps2.Namespace}: eps2,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 8.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceexportcache.go
"istio.io/istio/pkg/kube/controllers" "istio.io/istio/pkg/kube/kclient" "istio.io/istio/pkg/kube/kubetypes" "istio.io/istio/pkg/kube/mcs" ) type exportedService struct { namespacedName types.NamespacedName discoverability map[host.Name]string } // serviceExportCache reads Kubernetes Multi-Cluster Services (MCS) ServiceExport resources in the // cluster and generates discoverability policies for the endpoints.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.5K bytes - Viewed (0) -
tests/integration/helm/install_test.go
nsConfig NamespaceConfig }{{ name: "isolated-istio-cni", nsConfig: NewNamespaceConfig(types.NamespacedName{ Name: CniReleaseName, Namespace: "istio-cni", }), }, { name: "isolated-istio-cni-and-ztunnel", nsConfig: NewNamespaceConfig(types.NamespacedName{ Name: CniReleaseName, Namespace: "istio-cni", }, types.NamespacedName{ Name: ZtunnelReleaseName, Namespace: "kube-system", }), }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/kube/kclient/index_test.go
} return []SaNode{{ ServiceAccount: types.NamespacedName{ Namespace: pod.Namespace, Name: pod.Spec.ServiceAccountName, }, Node: pod.Spec.NodeName, }} }) k1 := SaNode{ ServiceAccount: types.NamespacedName{ Namespace: "ns", Name: "sa", }, Node: "node", } k2 := SaNode{ ServiceAccount: types.NamespacedName{ Namespace: "ns", Name: "sa2", },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 04 03:49:30 UTC 2023 - 5.7K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/metrics/cache.go
// given Service and updates the corresponding metrics. // Parameters: // * endpointsNN refers to a NamespacedName representing the Endpoints resource. // * epCache refers to a EndpointPortCache for the specified Endpoints reosource. func (c *Cache) UpdateEndpointPortCache(endpointsNN types.NamespacedName, epCache *EndpointPortCache) { c.lock.Lock() defer c.lock.Unlock() prevNumEndpoints := 0
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 5.2K bytes - Viewed (0) -
tests/integration/security/ca_custom_root/main_test.go
} func createCustomInstances(apps *deployment.SingleNamespaceView) error { for index, namespacedName := range apps.EchoNamespace.All.NamespacedNames() { switch { case namespacedName.Name == "client": client = apps.EchoNamespace.All[index] case namespacedName.Name == "server": server = apps.EchoNamespace.All[index] case namespacedName.Name == "server-naked-foo": serverNakedFoo = apps.EchoNamespace.All[index]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 9.2K bytes - Viewed (0)