- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for podsByIP (0.1 sec)
-
pilot/pkg/serviceregistry/kube/controller/pod.go
type PodCache struct { pods kclient.Client[*v1.Pod] sync.RWMutex // podsByIP maintains stable pod IP to name key mapping // this allows us to retrieve the latest status by pod IP. // This should only contain RUNNING or PENDING pods with an allocated IP. podsByIP map[string]sets.Set[types.NamespacedName] // IPByPods is a reverse map of podsByIP. This exists to allow us to prune stale entries in the // pod cache if a pod changes IP.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
assert.EventuallyEqual(t, fetch, nil) } func waitForPod(t test.Failer, c *FakeController, ip string) { retry.UntilOrFail(t, func() bool { c.pods.RLock() defer c.pods.RUnlock() if _, ok := c.pods.podsByIP[ip]; ok { return true } return false }) } func waitForNode(t test.Failer, c *FakeController, name string) { retry.UntilOrFail(t, func() bool { return c.nodes.Get(name, "") != nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0)