- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for networkGateways (0.33 sec)
-
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
}) 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) { gwMu.Lock() defer gwMu.Unlock() gws = v } getGws := func() []model.NetworkGateway { gwMu.Lock() defer gwMu.Unlock() return gws }
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
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) -
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 func (s *DiscoveryServer) pushContextHandler(w http.ResponseWriter, req *http.Request) { push := PushContextDebug{}
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) -
pilot/pkg/model/push_context_test.go
panic("implement me") } func (l *localServiceDiscovery) GetIstioServiceAccounts(*Service) []string { return nil } func (l *localServiceDiscovery) NetworkGateways() []NetworkGateway { // TODO implement fromRegistry logic from kube controller if needed return nil } func (l *localServiceDiscovery) MCSServices() []MCSServiceInfo { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 95.3K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/ep_filters.go
} return weight } // Apply the weight for this endpoint to the network gateways. func splitWeightAmongGateways(weight uint32, gateways []model.NetworkGateway, gatewayWeights map[model.NetworkGateway]uint32) { // Spread the weight across the gateways. weightPerGateway := weight / uint32(len(gateways)) for _, gateway := range gateways { gatewayWeights[gateway] += weightPerGateway } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 9.1K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/api.go
} type ZtunnelWorkload struct { WorkloadIPs []string `json:"workloadIps"` Waypoint *GatewayAddress `json:"waypoint,omitempty"` NetworkGateway *GatewayAddress `json:"networkGateway,omitempty"` Protocol string `json:"protocol"` Name string `json:"name"` Namespace string `json:"namespace"`
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 5.5K bytes - Viewed (0)