- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for networkFromSystemNamespace (0.31 sec)
-
pilot/pkg/serviceregistry/kube/controller/network_test.go
tracker.Record(o.GetName()) })) expectNetwork := func(t *testing.T, c *FakeController, network string) { t.Helper() retry.UntilSuccessOrFail(t, func() error { t.Helper() if c.networkFromSystemNamespace().String() != network { return fmt.Errorf("no network system notify") } podNames := sets.New[string]("pod1", "pod2") svcNames := sets.New[string]("svc1") addresses := c.ambientIndex.All()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 10.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
nw := ns.Labels[label.TopologyNetwork.Name] n.Lock() defer n.Unlock() oldDefaultNetwork := n.network n.network = network.ID(nw) return oldDefaultNetwork != n.network } func (n *networkManager) networkFromSystemNamespace() network.ID { n.RLock() defer n.RUnlock() return n.network } func (n *networkManager) networkFromMeshNetworks(endpointIP string) network.ID { n.RLock() defer n.RUnlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
// 1. check the pod/workloadEntry label if nw := labels[label.TopologyNetwork.Name]; nw != "" { return network.ID(nw) } // 2. check the system namespace labels if nw := c.networkFromSystemNamespace(); nw != "" { return nw } // 3. check the meshNetworks config if nw := c.networkFromMeshNetworks(endpointIP); nw != "" { return nw } return "" }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0)