- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for istioEndpoints (0.22 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/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/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) -
pilot/pkg/model/proxy_view.go
visible: sets.New(node.Metadata.RequestedNetworkView...).Insert(identifier.Undefined), getValue: func(ep *IstioEndpoint) string { return ep.Network.String() }, } } type proxyViewImpl struct { visible sets.String getValue func(ep *IstioEndpoint) string } func (v *proxyViewImpl) IsVisible(ep *IstioEndpoint) bool { return v.visible.Contains(v.getValue(ep)) } func (v *proxyViewImpl) String() string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 15 16:11:16 UTC 2023 - 1.8K bytes - Viewed (0) -
pilot/pkg/model/validation_test.go
&Port{Name: "http-alt", Port: 8081, Protocol: protocol.HTTP}, }, } func TestServiceInstanceValidate(t *testing.T) { endpointWithLabels := func(lbls labels.Instance) *IstioEndpoint { return &IstioEndpoint{ Address: "192.168.1.1", EndpointPort: 10001, Labels: lbls, } } cases := []struct { name string instance *ServiceInstance valid bool }{ {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 23 19:35:35 UTC 2023 - 4K 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/serviceexportcache_test.go
} func (ec *serviceExportCacheImpl) getEndpoint(endpoints *model.EndpointIndex) *model.IstioEndpoint { svcs := ec.Services() for _, s := range svcs { ep := GetEndpoints(s, endpoints) if len(ep) > 0 { return ep[0] } } return nil } func GetEndpoints(s *model.Service, endpoints *model.EndpointIndex) []*model.IstioEndpoint { return GetEndpointsForPort(s, endpoints, 0) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 9.1K 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/model/fuzz_test.go
fuzzDeepCopy[*ServiceInstance](f) } func FuzzDeepCopyWorkloadInstance(f *testing.F) { fuzzDeepCopy[*WorkloadInstance](f) } func FuzzDeepCopyIstioEndpoint(f *testing.F) { fuzzDeepCopy[*IstioEndpoint](f) } type deepCopier[T any] interface { DeepCopy() T } func fuzzDeepCopy[T deepCopier[T]](f test.Fuzzer) { fuzz.Fuzz(f, func(fg fuzz.Helper) { orig := fuzz.Struct[T](fg)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 10 17:36:04 UTC 2023 - 1.3K bytes - Viewed (0)