- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 163 for NamespacedName (0.19 sec)
-
istioctl/pkg/multixds/gather.go
break GetProxyLoop } namespacedName := pod.Name + "." + pod.Namespace if visited[namespacedName] { // If we already have information about the pod, skip it. continue } resp, err := queryToOnePod(&pod) if err != nil { fmt.Fprintf(os.Stderr, "Skip the agent in Pod %s due to the error: %s\n", namespacedName, err.Error()) continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 13.6K bytes - Viewed (0) -
pkg/revisions/default_watcher.go
// assumes externally locked. func (p *defaultWatcher) notifyHandlers() { for _, handler := range p.handlers { handler(p.defaultRevision) } } func (p *defaultWatcher) setDefault(key types.NamespacedName) error { revision := "" wh := p.webhooks.Get(key.Name, "") if wh != nil { revision = wh.GetLabels()[label.IoIstioRev.Name] } p.mu.Lock() defer p.mu.Unlock() p.defaultRevision = revision
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 09 02:22:47 UTC 2023 - 3.1K bytes - Viewed (0) -
pkg/test/framework/components/echo/services.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 21 16:42:24 UTC 2022 - 3.1K bytes - Viewed (0) -
pkg/test/framework/components/istio/kube.go
ingressServiceLabel = fmt.Sprintf("istio=%s", serviceLabelOverride) } name := types.NamespacedName{Name: ingressServiceName, Namespace: ingressServiceNamespace} return i.CustomIngressFor(c, name, ingressServiceLabel) } func (i *istioImpl) EastWestGatewayFor(c cluster.Cluster) ingress.Instance { name := types.NamespacedName{Name: eastWestIngressServiceName, Namespace: i.cfg.SystemNamespace}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/test/csrctrl/controllers/csr_controller.go
controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) c.csrs.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c } func (s *Signer) Reconcile(key types.NamespacedName) error { csr := s.csrs.Get(key.Name, key.Namespace) if csr == nil { // CSR was deleted, no action needed return nil } var exist bool signer, exist := s.signers[csr.Spec.SignerName] switch {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 17:36:41 UTC 2023 - 3.9K bytes - Viewed (0) -
pkg/kube/controllers/common_test.go
"istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/test/util/retry" ) func TestEnqueueForParentHandler(t *testing.T) { var written atomic.String q := NewQueue("test", WithReconciler(func(key types.NamespacedName) error { t.Logf("got event %v", key) written.Store(key.String()) return nil })) go q.Run(test.NewStop(t)) handler := EnqueueForParentHandler(q, gvk.Deployment) handler(&corev1.Pod{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 15 15:34:49 UTC 2023 - 4.1K bytes - Viewed (0) -
tests/integration/pilot/revisions/revisions_test.go
DeployAsVM: true, Ports: []echo.Port{}, }). BuildOrFail(t) echotest.New(t, echos). ConditionallyTo(echotest.ReachableDestinations). ToMatch(match.ServiceName(echo.NamespacedName{Name: "server", Namespace: canary})). Run(func(t framework.TestContext, from echo.Instance, to echo.Target) { retry.UntilSuccessOrFail(t, func() error { result, err := from.Call(echo.CallOptions{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 27 15:52:38 UTC 2022 - 3.7K bytes - Viewed (0) -
tests/integration/pilot/mcs/autoexport/autoexport_test.go
// Verify that ServiceExport is created automatically for services. ctx.NewSubTest("exported").RunParallel( func(ctx framework.TestContext) { serviceB := match.ServiceName(echo.NamespacedName{Name: common.ServiceB, Namespace: echos.Namespace}) for _, cluster := range serviceB.GetMatches(echos.Instances).Clusters() { cluster := cluster
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 4.9K bytes - Viewed (0) -
pkg/kube/inject/inject.go
// SidecarTemplateData is the data object to which the templated // version of `SidecarInjectionSpec` is applied. type SidecarTemplateData struct { TypeMeta metav1.TypeMeta DeploymentMeta types.NamespacedName ObjectMeta metav1.ObjectMeta Spec corev1.PodSpec ProxyConfig *meshconfig.ProxyConfig MeshConfig *meshconfig.MeshConfig
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 20:35:11 UTC 2024 - 28.8K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
metrics.EndpointsUpdatedPerSync.WithLabelValues().Observe(float64(totals.updated)) metrics.EndpointsRemovedPerSync.WithLabelValues().Observe(float64(totals.removed)) endpointsNN := types.NamespacedName{Name: endpoints.Name, Namespace: endpoints.Namespace} r.metricsCache.UpdateEndpointPortCache(endpointsNN, epMetrics) return r.finalize(endpoints, slices) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0)