- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 53 for NamespacedName (0.17 sec)
-
pkg/proxy/config/config_test.go
h.lock.Lock() defer h.lock.Unlock() namespacedName := types.NamespacedName{Namespace: service.Namespace, Name: service.Name} h.state[namespacedName] = service h.sendServices() } func (h *ServiceHandlerMock) OnServiceUpdate(oldService, service *v1.Service) { h.lock.Lock() defer h.lock.Unlock() namespacedName := types.NamespacedName{Namespace: service.Namespace, Name: service.Name}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/kube/util_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 04:16:49 UTC 2024 - 10.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod.go
needResync map[string]sets.Set[types.NamespacedName] queueEndpointEvent func(types.NamespacedName) c *Controller } func newPodCache(c *Controller, pods kclient.Client[*v1.Pod], queueEndpointEvent func(types.NamespacedName)) *PodCache { out := &PodCache{ pods: pods, c: c, podsByIP: make(map[string]sets.Set[types.NamespacedName]),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
pkg/proxy/endpointslicecache_test.go
testCases := map[string]struct { endpointSlices []*discovery.EndpointSlice hostname string namespacedName types.NamespacedName expectedMap map[ServicePortName][]*BaseEndpointInfo }{ "1 slice, 2 hosts, ports 80,443": { namespacedName: types.NamespacedName{Name: "svc1", Namespace: "ns1"}, hostname: "host1", endpointSlices: []*discovery.EndpointSlice{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 24.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
namespacedName := getServiceNamespacedName(ep) log.Debugf("Handle EDS endpoint %s %s in namespace %s", namespacedName.Name, event, namespacedName.Namespace) if event == model.EventDelete { esc.deleteEndpointSlice(ep) } else { esc.updateEndpointSlice(ep) } hostnames := esc.c.hostNamesForNamespacedName(namespacedName) // Trigger EDS push for all hostnames.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
return func(ctx context.Context, fireAt time.Time, args *WorkArgs) error { ns := args.NamespacedName.Namespace name := args.NamespacedName.Name klog.FromContext(ctx).Info("Deleting pod", "controller", controllerName, "pod", args.NamespacedName) if emitEventFunc != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/proxy/endpointslicecache.go
} // checkoutChanges returns a map of all endpointsChanges that are // pending and then marks them as applied. func (cache *EndpointSliceCache) checkoutChanges() map[types.NamespacedName]*endpointsChange { changes := make(map[types.NamespacedName]*endpointsChange) cache.lock.Lock() defer cache.lock.Unlock() for serviceNN, esTracker := range cache.trackerByServiceMap { if len(esTracker.pending) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 11.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
assert.Equal(t, c.pods.getPodKeys("128.0.0.1"), []types.NamespacedName{{Name: "pod1", Namespace: "ns"}}) events.WaitOrdered("pod1/add", "pod1/update") createPod("128.0.0.1", "pod2") events.WaitOrdered("pod2/add", "pod2/update") assert.Equal(t, sets.New(c.pods.getPodKeys("128.0.0.1")...), sets.New( types.NamespacedName{Name: "pod1", Namespace: "ns"}, types.NamespacedName{Name: "pod2", Namespace: "ns"}, ))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
pkg/proxy/healthcheck/healthcheck_test.go
} func testHandler(hcs *server, nsn types.NamespacedName, status int, endpoints int, t *testing.T) { tHandler(hcs, nsn, status, endpoints, true, t) } func testHandlerWithHealth(hcs *server, nsn types.NamespacedName, status int, endpoints int, kubeProxyHealthy bool, t *testing.T) { tHandler(hcs, nsn, status, endpoints, kubeProxyHealthy, t) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 21.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache.go
vips := ic.getClusterSetIPs(namespacedName) name := namespacedName.Name ns := namespacedName.Namespace if len(vips) == 0 || (event == model.EventDelete && ic.opts.MeshServiceController.GetService(kube.ServiceHostname(name, ns, ic.opts.DomainSuffix)) == nil) { if prevMcsService != nil { // There are no vips in this cluster. Just delete the MCS service now.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.2K bytes - Viewed (0)