Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for WorkloadsForWaypoint (0.84 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top