- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 46 for istioEndpoints (0.18 sec)
-
pilot/pkg/model/endpointshards.go
} ep.Lock() defer ep.Unlock() newIstioEndpoints := istioEndpoints oldIstioEndpoints := ep.Shards[shard] needPush := false if oldIstioEndpoints == nil { // If there are no old endpoints, we should push with incoming endpoints as there is nothing to compare. needPush = true } else { newIstioEndpoints = make([]*IstioEndpoint, 0, len(istioEndpoints)) // Check if new Endpoints are ready to be pushed. This check
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/xds/eds.go
func (s *DiscoveryServer) EDSUpdate(shard model.ShardKey, serviceName string, namespace string, istioEndpoints []*model.IstioEndpoint, ) { inboundEDSUpdates.Increment() // Update the endpoint shards pushType := s.Env.EndpointIndex.UpdateServiceEndpoints(shard, serviceName, namespace, istioEndpoints) if pushType == model.IncrementalPush || pushType == model.FullPush { // Trigger a push
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 15:58:06 UTC 2024 - 9.9K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder.go
return configs } type LocalityEndpoints struct { istioEndpoints []*model.IstioEndpoint // The protobuf message which contains LbEndpoint slice. llbEndpoints endpoint.LocalityLbEndpoints } func (e *LocalityEndpoints) append(ep *model.IstioEndpoint, le *endpoint.LbEndpoint) { e.istioEndpoints = append(e.istioEndpoints, ep) e.llbEndpoints.LbEndpoints = append(e.llbEndpoints.LbEndpoints, le) }
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/networking/core/loadbalancer/loadbalancer_test.go
{ IstioEndpoints: []*model.IstioEndpoint{ { Labels: map[string]string{ "topology.istio.io/network": "n1", "topology.istio.io/cluster": "c1", }, Address: "1.1.1.1", }, }, LocalityLbEndpoints: cluster.LoadAssignment.Endpoints[0], }, { IstioEndpoints: []*model.IstioEndpoint{ { Labels: map[string]string{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 39.1K bytes - Viewed (0) -
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/xds/eds_sh_test.go
Protocol: protocol.HTTP, }, }, Attributes: model.ServiceAttributes{Namespace: "default"}, }) istioEndpoints := make([]*model.IstioEndpoint, numOfEndpoints) for i := 0; i < numOfEndpoints; i++ { addr := fmt.Sprintf("10.%d.0.%d", networkNum, i+1) istioEndpoints[i] = &model.IstioEndpoint{ Address: addr, EndpointPort: 2080, ServicePortName: "http-main", Network: networkID,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 10.8K bytes - Viewed (0) -
pilot/pkg/networking/core/loadbalancer/loadbalancer.go
} } } } // WrappedLocalityLbEndpoints contain an envoy LocalityLbEndpoints // and the original IstioEndpoints used to generate it. // It is used to do failover priority label match with proxy labels. type WrappedLocalityLbEndpoints struct { IstioEndpoints []*model.IstioEndpoint LocalityLbEndpoints *endpoint.LocalityLbEndpoints } // set loadbalancing priority by failover priority label.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 11.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice_test.go
// add a new endpoint ep2 := &model.IstioEndpoint{ Address: "2.3.4.5", ServicePortName: "http", } cache.Update(hostname, "slice1", []*model.IstioEndpoint{ep1, ep2}) if !testEndpointsEqual(cache.Get(hostname), []*model.IstioEndpoint{ep1, ep2}) { t.Fatalf("unexpected endpoints") } // change service port name ep1 = &model.IstioEndpoint{ Address: "1.2.3.4", ServicePortName: "http2", }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 4.5K bytes - Viewed (0) -
pilot/pkg/model/service.go
} // DeepCopy creates a clone of IstioEndpoint. func (ep *IstioEndpoint) DeepCopy() *IstioEndpoint { return copyInternal(ep).(*IstioEndpoint) } // ShallowCopy creates a shallow clone of IstioEndpoint. func (ep *IstioEndpoint) ShallowCopy() *IstioEndpoint { // nolint: govet cpy := *ep return &cpy }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/model/endpointshards_test.go
expect: false, }, { name: "added new sa", shardKey: c1Key, endpoints: append(cluster1Endppoints, &IstioEndpoint{Address: "10.172.0.3", ServiceAccount: "sa2"}), expect: true, }, { name: "updated endpoints address", shardKey: c1Key, endpoints: []*IstioEndpoint{ {Address: "10.172.0.5", ServiceAccount: "sa1"},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 15:48:05 UTC 2023 - 2.7K bytes - Viewed (0)