- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 163 for NamespacedName (0.34 sec)
-
pkg/test/framework/components/echo/common/deployment/external.go
config.IPFamilies = "IPv6, IPv4" config.IPFamilyPolicy = "RequireDualStack" } return b.WithConfig(config) } func (e *External) LoadValues(echos echo.Instances) { e.All = match.ServiceName(echo.NamespacedName{Name: ExternalSvc, Namespace: e.Namespace}).GetMatches(echos)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 20 16:01:31 UTC 2024 - 2.7K bytes - Viewed (0) -
pilot/pkg/model/service.go
MeshExternal bool // ResourceVersion represents the internal version of this object. ResourceVersion string } func (s *Service) NamespacedName() types.NamespacedName { return types.NamespacedName{Name: s.Attributes.Name, Namespace: s.Attributes.Namespace} } func (s *Service) Key() string { if s == nil { return "" }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/kube/krt/singleton_test.go
ConfigMapNames := krt.NewSingleton[string]( func(ctx krt.HandlerContext) *string { cms := krt.Fetch(ctx, ConfigMaps) return ptr.Of(slices.Join(",", slices.Map(cms, func(c *corev1.ConfigMap) string { return config.NamespacedName(c).String() })...)) }, ) ConfigMapNames.AsCollection().Synced().WaitUntilSynced(stop) tt := assert.NewTracker[string](t) ConfigMapNames.Register(TrackerHandler[string](tt)) tt.WaitOrdered("add/")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 11 08:27:29 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/kube/watcher/configmapwatcher/configmapwatcher.go
// HasSynced returns whether the underlying cache has synced and the callback has been called at least once. func (c *Controller) HasSynced() bool { return c.queue.HasSynced() } func (c *Controller) processItem(name types.NamespacedName) error { cm := c.configmaps.Get(name.Name, name.Namespace) c.callback(cm) c.hasSynced.Store(true) return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 19 07:11:52 UTC 2023 - 2.8K bytes - Viewed (0) -
pkg/revisions/tag_watcher.go
} func NewTagWatcher(client kube.Client, revision string) TagWatcher { p := &tagWatcher{ revision: revision, } p.queue = controllers.NewQueue("tag", controllers.WithReconciler(func(key types.NamespacedName) error { p.notifyHandlers() return nil })) p.webhooks = kclient.NewFiltered[*admissionregistrationv1.MutatingWebhookConfiguration](client, kubetypes.Filter{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
} p.setInitialized(true) p.syncRunner = async.NewBoundedFrequencyRunner("test-sync-runner", p.syncProxyRules, 0, time.Minute, 1) return p } func makeNSN(namespace, name string) types.NamespacedName { return types.NamespacedName{Namespace: namespace, Name: name} } func makeServiceMap(proxier *Proxier, allServices ...*v1.Service) { for i := range allServices { proxier.OnServiceAdd(allServices[i]) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0) -
pilot/pkg/autoregistration/connections.go
} func newAdsConnections() *adsConnections { return &adsConnections{byProxy: map[proxyKey]map[string]connection{}} } func (m *adsConnections) ConnectionsForGroup(wg types.NamespacedName) []connection { // collect the proxies that should be disconnected (don't remove them, OnDisconnect will) m.Lock() defer m.Unlock() var conns []connection for key, connections := range m.byProxy {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Sep 19 20:41:55 UTC 2023 - 3K bytes - Viewed (0) -
operator/pkg/controller/istiocontrolplane/istiocontrolplane_controller.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/test/framework/components/istio/ingress.go
_ ingress.Instance = &ingressImpl{} _ io.Closer = &ingressImpl{} ) type ingressConfig struct { // Service is the kubernetes Service name for the cluster Service types.NamespacedName // LabelSelector is the value for the label on the ingress kubernetes objects LabelSelector string // Cluster to be used in a multicluster environment Cluster cluster.Cluster }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 17:13:34 UTC 2024 - 8K bytes - Viewed (0) -
security/pkg/server/ca/server_test.go
id, c.certChain, v, i) } } } } } func TestCreateCertificateE2EWithImpersonateIdentity(t *testing.T) { allowZtunnel := sets.Set[types.NamespacedName]{ {Name: "ztunnel", Namespace: "istio-system"}: {}, } ztunnelCaller := security.KubernetesInfo{ PodName: "ztunnel-a", PodNamespace: "istio-system", PodUID: "12345",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 15.8K bytes - Viewed (0)