- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for SetEndpoints (0.24 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) -
cmd/endpoint-ellipses.go
// Endpoint set represents parsed ellipses values, also provides // methods to get the sets of endpoints. type endpointSet struct { argPatterns []ellipses.ArgPattern endpoints []string // Endpoints saved from previous GetEndpoints(). setIndexes [][]uint64 // All the sets. } // Supported set sizes this is used to find the optimal // single set size. var setSizes = []uint64{2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16}
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.7K bytes - Viewed (0)