- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for SetEndpoints (0.14 sec)
-
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) -
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) -
pilot/pkg/serviceregistry/kube/controller/endpointslice_test.go
createEndpoints(t, controller, svcName, ns, portNames, svc1Ips, nil, map[string]string{ mcs.LabelServiceName: svcName, }) fx.AssertEmpty(t, time.Millisecond*50) // Ensure that no endpoint is create endpoints := GetEndpoints(svc, controller.Endpoints) assert.Equal(t, len(endpoints), 0) } func TestEndpointSliceCache(t *testing.T) { cache := newEndpointSliceCache() hostname := host.Name("foo") // add a endpoint
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 4.5K bytes - Viewed (0)