- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for AllGateways (0.1 sec)
-
pilot/pkg/model/network_test.go
assert.EventuallyEqual(t, env.NetworkManager.AllGateways, gateways) xdsUpdater.WaitOrFail(t, "xds full") }) workingDNSServer.setFailure(true) gateways = env.NetworkManager.AllGateways() t.Run("resolution failed", func(t *testing.T) { xdsUpdater.AssertEmpty(t, 10*model.MinGatewayTTL) // the gateways should remain currentGateways := env.NetworkManager.AllGateways()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 16 01:18:03 UTC 2023 - 6.9K bytes - Viewed (0) -
pilot/pkg/model/network.go
gws.mu.RLock() defer gws.mu.RUnlock() return gws.lcm } func (gws *NetworkGateways) AllGateways() []NetworkGateway { gws.mu.RLock() defer gws.mu.RUnlock() return gws.allGateways() } func (gws *NetworkGateways) allGateways() []NetworkGateway { if gws.byNetwork == nil { return nil } out := make([]NetworkGateway, 0)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 16.9K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
if pc == nil { return } push.AuthorizationPolicies = pc.AuthzPolicies if pc.NetworkManager() != nil { push.NetworkGateways = pc.NetworkManager().AllGateways() push.UnresolvedGateways = pc.NetworkManager().Unresolved.AllGateways() } writeJSON(w, push, req) } // Debug lists all the supported debug endpoints. func (s *DiscoveryServer) Debug(w http.ResponseWriter, req *http.Request) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0)