- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for NetworkGateways (0.26 sec)
-
pilot/pkg/model/network.go
xdsUpdater XDSUpdater // just to ensure NetworkGateways and Unresolved are updated together mu sync.RWMutex // embedded NetworkGateways only includes gateways with IPs // hostnames are resolved in control plane (or filtered out if feature is disabled) *NetworkGateways // includes all gateways with no DNS resolution or filtering, regardless of feature flags Unresolved *NetworkGateways }
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/serviceregistry/memory/discovery.go
return l } } return nil } func (sd *ServiceDiscovery) AddGateways(gws ...model.NetworkGateway) { sd.networkGateways = append(sd.networkGateways, gws...) sd.NotifyGatewayHandlers() } func (sd *ServiceDiscovery) NetworkGateways() []model.NetworkGateway { return sd.networkGateways } func (sd *ServiceDiscovery) MCSServices() []model.MCSServiceInfo { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 23:10:01 UTC 2024 - 12.4K bytes - Viewed (0) -
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) -
pilot/pkg/serviceregistry/kube/controller/network_test.go
ClusterID: constants.DefaultClusterName, NetworksWatcher: meshNetworks, DomainSuffix: "cluster.local", CRDs: []schema.GroupVersionResource{gvr.KubernetesGateway}, }) if len(c.NetworkGateways()) != 0 { t.Fatal("did not expect any gateways yet") } notifyCh := make(chan struct{}, 1) var ( gwMu sync.Mutex gws []model.NetworkGateway ) setGws := func(v []model.NetworkGateway) {
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
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) -
pilot/pkg/xds/endpoints/endpoint_builder.go
return &endpoint.ClusterLoadAssignment{ ClusterName: clusterName, } } func (b *EndpointBuilder) gateways() *model.NetworkGateways { if b.IsDNSCluster() { return b.push.NetworkManager().Unresolved } return b.push.NetworkManager().NetworkGateways } func ExtractEnvoyEndpoints(locEps []*LocalityEndpoints) []*endpoint.LocalityLbEndpoints { var locLbEps []*endpoint.LocalityLbEndpoints
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
_, _ = w.Write(out) } // PushContextDebug holds debug information for push context. type PushContextDebug struct { AuthorizationPolicies *model.AuthorizationPolicies NetworkGateways []model.NetworkGateway UnresolvedGateways []model.NetworkGateway } // pushContextHandler dumps the current PushContext
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0) -
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) -
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)