Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for networkGateways (0.28 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

    			continue
    		}
    		for _, l := range slices.Filter(gw.Spec.Listeners, autoPassthrough) {
    			networkGateway := base
    			networkGateway.Addr = addr.Value
    			networkGateway.Port = uint32(l.Port)
    			newGateways.Insert(networkGateway)
    		}
    	}
    	n.gatewaysFromResource[gw.UID] = newGateways
    
    	if len(previousGateways) != len(newGateways) {
    		gatewaysChanged = true
    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)
  5. pilot/pkg/networking/core/fake.go

    	ConfigTemplateInput any
    
    	// Services to pre-populate as part of the service discovery
    	Services  []*model.Service
    	Instances []*model.ServiceInstance
    	Gateways  []model.NetworkGateway
    
    	// If provided, this mesh config will be used
    	MeshConfig      *meshconfig.MeshConfig
    	NetworksWatcher mesh.NetworksWatcher
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  6. pilot/test/xds/fake.go

    	EnableFakeXDSUpdater       bool
    	DisableSecretAuthorization bool
    	Services                   []*model.Service
    	Gateways                   []model.NetworkGateway
    }
    
    type FakeDiscoveryServer struct {
    	*core.ConfigGenTest
    	t            test.Failer
    	Discovery    *xds.DiscoveryServer
    	Listener     net.Listener
    	BufListener  *bufconn.Listener
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 16:08:52 UTC 2024
    - 18.4K bytes
    - Viewed (0)
Back to top