- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for istioEndpoints (0.19 sec)
-
pilot/pkg/xds/endpoints/ep_filters.go
// Process all the endpoints. for i, lbEp := range ep.llbEndpoints.LbEndpoints { istioEndpoint := ep.istioEndpoints[i] // If the proxy can't view the network for this endpoint, exclude it entirely. if !b.proxyView.IsVisible(istioEndpoint) { continue } // Copy the endpoint in order to expand the load balancing weight.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 9.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/workloadinstances/index_test.go
Name: selector.Name, Namespace: selector.Namespace, Endpoint: &model.IstioEndpoint{ Address: "2.2.2.2", Labels: map[string]string{"app": "wle"}, // should match }, } wi2 := &model.WorkloadInstance{ Name: "same-ip", Namespace: selector.Namespace, Endpoint: &model.IstioEndpoint{ Address: "2.2.2.2", Labels: map[string]string{"app": "wle"}, // should match },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpoint_builder.go
"istio.io/istio/pkg/config/labels" kubeUtil "istio.io/istio/pkg/kube" "istio.io/istio/pkg/network" ) // EndpointBuilder is a stateful IstioEndpoint builder with metadata used to build IstioEndpoint type EndpointBuilder struct { controller controllerInterface labels labels.Instance metaNetwork network.ID serviceAccount string locality model.Locality
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/xdsfake/updater.go
Reason model.ReasonStats Namespace string // The endpoints associated with an EDS push if any Endpoints []*model.IstioEndpoint // EndpointCount, used in matches only EndpointCount int } func (fx *Updater) EDSUpdate(c model.ShardKey, hostname string, ns string, entry []*model.IstioEndpoint) { select { case fx.Events <- Event{Type: "eds", ID: hostname, Endpoints: entry, Namespace: ns}: default: }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 18:40:34 UTC 2024 - 6.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/conversion.go
} return istioService } func ExternalNameEndpoints(svc *model.Service) []*model.IstioEndpoint { if svc.Attributes.ExternalName == "" { return nil } out := make([]*model.IstioEndpoint, 0, len(svc.Ports)) discoverabilityPolicy := model.AlwaysDiscoverable if features.EnableMCSServiceDiscovery {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 9.4K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/context.go
} func (gc GatewayContext) GetService(hostname, namespace string) *model.Service { return gc.ps.ServiceIndex.HostnameAndNamespace[host.Name(hostname)][namespace] } func instancesEmpty(m map[int][]*model.IstioEndpoint) bool { for _, instances := range m { if len(instances) > 0 { return false } } return true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 18:33:02 UTC 2024 - 6.2K bytes - Viewed (0)