Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NetworkGateways (0.17 sec)

  1. pilot/pkg/serviceregistry/aggregate/controller.go

    		dst.ClusterVIPs.SetAddressesFor(clusterID, newAddresses)
    	}
    }
    
    // NetworkGateways merges the service-based cross-network gateways from each registry.
    func (c *Controller) NetworkGateways() []model.NetworkGateway {
    	var gws []model.NetworkGateway
    	for _, r := range c.GetRegistries() {
    		gws = append(gws, r.NetworkGateways()...)
    	}
    	return gws
    }
    
    func (c *Controller) MCSServices() []model.MCSServiceInfo {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 06:28:11 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/controller/network.go

    						Network: network.ID(id),
    						Cluster: n.clusterID,
    						Port:    gw.GetPort(),
    					})
    				}
    			}
    		}
    
    	}
    	n.ranger = ranger
    }
    
    func (c *Controller) NetworkGateways() []model.NetworkGateway {
    	c.networkManager.RLock()
    	defer c.networkManager.RUnlock()
    
    	// Merge all the gateways into a single set to eliminate duplicates.
    	out := make(model.NetworkGatewaySet)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 22:23:22 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  3. pilot/pkg/xds/endpoints/ep_filters_test.go

    	//  - 1 DNS gateway for network2
    	//  - 1 IP gateway for network3
    	//  - 0 gateways for network4
    	ds := environment(t)
    	origServices := ds.Env().Services()
    	origGateways := ds.Env().NetworkGateways()
    	ds.MemRegistry.AddService(&model.Service{
    		Hostname: "istio-ingressgateway.istio-system.svc.cluster.local",
    		Attributes: model.ServiceAttributes{
    			ClusterExternalAddresses: &model.AddressMap{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 01:17:58 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/serviceentry/controller.go

    			if proxy.Metadata.Namespace == "" || i.Service.Attributes.Namespace == proxy.Metadata.Namespace {
    				return i.Endpoint.Labels
    			}
    		}
    	}
    	return nil
    }
    
    func (s *Controller) NetworkGateways() []model.NetworkGateway {
    	// TODO implement mesh networks loading logic from kube controller if needed
    	return nil
    }
    
    func (s *Controller) MCSServices() []model.MCSServiceInfo {
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
Back to top