- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for WorkloadsForWaypoint (0.84 sec)
-
pilot/pkg/networking/core/waypoint.go
func findWaypointResources(node *model.Proxy, push *model.PushContext) ([]model.WorkloadInfo, *waypointServices) { key := model.WaypointKeyForProxy(node) workloads := push.WorkloadsForWaypoint(key) serviceInfos := push.ServicesForWaypoint(key) waypointServices := &waypointServices{} for _, s := range serviceInfos { hostName := host.Name(s.Service.Hostname)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 3.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
res = append(res, p.ServicesForWaypoint(key)...) } return res } func (c *Controller) WorkloadsForWaypoint(key model.WaypointKey) []model.WorkloadInfo { if !features.EnableAmbientWaypoints { return nil } var res []model.WorkloadInfo for _, p := range c.GetRegistries() { res = append(res, p.WorkloadsForWaypoint(key)...) } return res }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go
"istio.io/istio/pkg/slices" "istio.io/istio/pkg/util/sets" "istio.io/istio/pkg/workloadapi" ) type Index interface { Lookup(key string) []model.AddressInfo All() []model.AddressInfo WorkloadsForWaypoint(key model.WaypointKey) []model.WorkloadInfo ServicesForWaypoint(key model.WaypointKey) []model.ServiceInfo SyncAll() HasSynced() bool model.AmbientIndexes } var _ Index = &index{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 19 17:19:41 UTC 2024 - 15.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/memory/discovery.go
return nil } func (sd *ServiceDiscovery) Waypoint(string, string) []netip.Addr { return nil } func (sd *ServiceDiscovery) WorkloadsForWaypoint(model.WaypointKey) []model.WorkloadInfo { return nil } func (sd *ServiceDiscovery) AddWorkloadInfo(infos ...*model.WorkloadInfo) { sd.mutex.Lock() defer sd.mutex.Unlock()
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/model/service.go
proxy *Proxy, allAddresses sets.String, currentSubs sets.String, ) sets.String Policies(requested sets.Set[ConfigKey]) []WorkloadAuthorization ServicesForWaypoint(WaypointKey) []ServiceInfo WorkloadsForWaypoint(WaypointKey) []WorkloadInfo } // WaypointKey is a multi-address extension of NetworkAddress which is commonly used for lookups in AmbientIndex
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
return true } } return false } // WorkloadsForWaypoint returns all workloads associated with a given waypoint identified by it's WaypointKey // Used when calculating the workloads which should be configured for a specific waypoint proxy func (ps *PushContext) WorkloadsForWaypoint(key WaypointKey) []WorkloadInfo { return ps.ambientIndex.WorkloadsForWaypoint(key) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
s := newAmbientTestServer(t, "", testNW) assertWaypoint := func(t *testing.T, waypointNetwork string, waypointAddress string, expected ...string) { t.Helper() wl := sets.New(slices.Map(s.WorkloadsForWaypoint(model.WaypointKey{ Network: waypointNetwork, Addresses: []string{waypointAddress}, }), func(e model.WorkloadInfo) string { return e.ResourceName() })...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0)