- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for SetEndpoints (0.16 sec)
-
pilot/pkg/xds/eds_test.go
endpoints1 := adsc.GetEndpoints() endpoints2 := adsc2.GetEndpoints() verifyLocalityPriorities(asdcLocality, endpoints1["outbound|80||locality.cluster.local"].GetEndpoints(), t) verifyLocalityPriorities(asdc2Locality, endpoints2["outbound|80||locality.cluster.local"].GetEndpoints(), t) // No outlier detection specified for this cluster, so we shouldn't apply priority.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
} s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) addTestClientEndpoints(s.MemRegistry) s.MemRegistry.AddHTTPService(edsIncSvc, edsIncVip, 8080) s.MemRegistry.SetEndpoints(edsIncSvc, "", newEndpointWithAccount("127.0.0.1", "hello-sa", "v1")) // Wait until the above debounce, to ensure we can precisely check XDS responses without spurious pushes s.EnsureSynced(t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcgen_test.go
if err != nil { t.Fatal("Failed to receive endpoint", err) } ep := adscConn.GetEndpoints()[clusterName] if ep == nil { t.Fatal("Endpoints not found for persistent session cluster") } if len(ep.GetEndpoints()) == 0 { t.Fatal("No endpoint not found for persistent session cluster") } lbep1 := ep.GetEndpoints()[0] if lbep1.LbEndpoints[0].HealthStatus.Number() != 3 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/networking/apigen/apigen_test.go
func initDS(t *testing.T) *xds.FakeDiscoveryServer { ds := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) sd := ds.MemRegistry sd.AddHTTPService("fortio1.fortio.svc.cluster.local", "10.10.10.1", 8081) sd.SetEndpoints("fortio1.fortio.svc.cluster.local", "", []*model.IstioEndpoint{ { Address: "127.0.0.1", EndpointPort: uint32(14056), ServicePortName: "http-main", }, }) return ds }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/memory/discovery.go
Port: servicePort, Protocol: protocol.HTTP, }, } sd.AddInstance(instance) return instance } // SetEndpoints update the list of endpoints for a service, similar with K8S controller. func (sd *ServiceDiscovery) SetEndpoints(service string, namespace string, endpoints []*model.IstioEndpoint) { sh := host.Name(service) sd.mutex.Lock() svc := sd.services[sh] if svc == 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/xds/eds_sh_test.go
Network: networkID, Locality: model.Locality{ Label: "az", ClusterID: clusterID, }, Labels: svcLabels, TLSMode: model.IstioMutualTLSModeLabel, } } memRegistry.SetEndpoints("service5.default.svc.cluster.local", "default", istioEndpoints) } func addNetwork(server *xds.FakeDiscoveryServer, id network.ID, network *meshconfig.Network) { meshNetworks := server.Env().NetworksWatcher.Networks()
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/xds/ads_test.go
Attributes: model.ServiceAttributes{ Name: "adsupdate", Namespace: "default", }, }) s.Discovery.ConfigUpdate(&model.PushRequest{Full: true}) time.Sleep(time.Millisecond * 200) s.MemRegistry.SetEndpoints("adsupdate.default.svc.cluster.local", "default", newEndpointWithAccount("10.2.0.1", "hello-sa", "v1")) cluster := "outbound|2080||adsupdate.default.svc.cluster.local"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0) -
cmd/erasure.go
getDisks func() []StorageAPI // getLockers returns list of remote and local lockers. getLockers func() ([]dsync.NetLocker, string) // getEndpoints returns list of endpoint belonging this set. // some may be local and some remote. getEndpoints func() []Endpoint // getEndpoints returns list of endpoint strings belonging this set. // some may be local and some remote. getEndpointStrings func() []string // Locker mutex map.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 16K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/feature/feature_support_checker_test.go
Error error } // MockEtcdClient is a mock implementation of the EtcdClientInterface interface. type MockEtcdClient struct { EndpointVersion []mockEndpointVersion } func (m MockEtcdClient) getEndpoints() []string { var endpoints []string for _, ev := range m.EndpointVersion { endpoints = append(endpoints, ev.Endpoint) } return endpoints }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 8.3K 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)