Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for AllGateways (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top