- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for SetEndpoints (0.17 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/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) -
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) -
cmd/erasure-healing.go
dryRun := opts.DryRun scanMode := opts.ScanMode storageDisks := er.getDisks() storageEndpoints := er.getEndpoints() defer func() { er.auditHealObject(ctx, bucket, object, versionID, result, err) }() if globalTrace.NumSubscribers(madmin.TraceHealing) > 0 { startTime := time.Now() defer func() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.8K bytes - Viewed (0) -
pkg/adsc/adsc.go
// GetRoutes returns all the routes. func (a *ADSC) GetRoutes() map[string]*route.RouteConfiguration { a.mutex.RLock() defer a.mutex.RUnlock() return a.routes } // GetEndpoints returns all the routes. func (a *ADSC) GetEndpoints() map[string]*endpoint.ClusterLoadAssignment { a.mutex.RLock() defer a.mutex.RUnlock() return a.eds }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0)