Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for AddressInfo (0.25 sec)

  1. pilot/pkg/serviceregistry/memory/discovery.go

    }
    
    func workloadToAddressInfo(w *workloadapi.Workload) model.AddressInfo {
    	return model.AddressInfo{
    		Address: &workloadapi.Address{
    			Type: &workloadapi.Address_Workload{
    				Workload: w,
    			},
    		},
    	}
    }
    
    func serviceToAddressInfo(s *workloadapi.Service) model.AddressInfo {
    	return model.AddressInfo{
    		Address: &workloadapi.Address{
    			Type: &workloadapi.Address_Service{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 23:10:01 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/controller/ambient/helpers.go

    func workloadToAddressInfo(w *workloadapi.Workload) model.AddressInfo {
    	return model.AddressInfo{
    		Address: &workloadapi.Address{
    			Type: &workloadapi.Address_Workload{
    				Workload: w,
    			},
    		},
    	}
    }
    
    func modelWorkloadToAddressInfo(w model.WorkloadInfo) model.AddressInfo {
    	return workloadToAddressInfo(w.Workload)
    }
    
    func serviceToAddressInfo(s *workloadapi.Service) model.AddressInfo {
    	return model.AddressInfo{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Mar 22 20:35:23 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_serviceentry_test.go

    	s.assertEvent(t, s.seIPXdsName("name1", "127.0.0.1"), "ns1/se.istio.io")
    	s.assertWorkloads(t, "", workloadapi.WorkloadStatus_HEALTHY, "name1")
    	assert.Equal(t, s.lookup(s.addrXdsName("127.0.0.1")), []model.AddressInfo{{
    		Address: &workloadapi.Address{
    			Type: &workloadapi.Address_Workload{
    				Workload: &workloadapi.Workload{
    					Uid:               s.seIPXdsName("name1", "127.0.0.1"),
    					Name:              "name1",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 03:01:04 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go

    	"istio.io/istio/pkg/network"
    	"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
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 19 17:19:41 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  5. pilot/pkg/model/service.go

    	return nil
    }
    
    func (u NoopAmbientIndexes) WorkloadsForWaypoint(WaypointKey) []WorkloadInfo {
    	return nil
    }
    
    var _ AmbientIndexes = NoopAmbientIndexes{}
    
    type AddressInfo struct {
    	*workloadapi.Address
    }
    
    func (i AddressInfo) Aliases() []string {
    	switch addr := i.Type.(type) {
    	case *workloadapi.Address_Workload:
    		aliases := make([]string, 0, len(addr.Workload.Addresses))
    		network := addr.Workload.Network
    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/serviceregistry/aggregate/controller.go

    	}
    	for _, p := range c.GetRegistries() {
    		res = append(res, p.Policies(requested)...)
    	}
    	return res
    }
    
    func (c *Controller) AddressInformation(addresses sets.String) ([]model.AddressInfo, sets.String) {
    	i := []model.AddressInfo{}
    	if !features.EnableAmbient {
    		return i, nil
    	}
    	removed := sets.String{}
    	for _, p := range c.GetRegistries() {
    		wis, r := p.AddressInformation(addresses)
    		i = append(i, wis...)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 06:28:11 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  7. pkg/controller/endpointslicemirroring/reconciler_test.go

    	t.Helper()
    	type addressInfo struct {
    		ready     bool
    		epAddress corev1.EndpointAddress
    	}
    
    	// This approach assumes that each IP is unique within an EndpointSubset.
    	expectedEndpoints := map[string]addressInfo{}
    
    	for _, address := range epSubset.Addresses {
    		at := getAddressType(address.IP)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 42.7K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go

    	s.assertAddresses(t, s.addrXdsName("127.0.0.2"), "pod2")
    	for _, key := range []string{s.podXdsName("pod3"), s.addrXdsName("127.0.0.3")} {
    		assert.Equal(t, s.lookup(key), []model.AddressInfo{
    			{
    				Address: &workloadapi.Address{
    					Type: &workloadapi.Address_Workload{
    						Workload: &workloadapi.Workload{
    							Name:              "pod3",
    							Namespace:         testNS,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 70.2K bytes
    - Viewed (0)
  9. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_workloadentry_test.go

    	s.assertWorkloads(t, s.addrXdsName("127.0.0.2"), workloadapi.WorkloadStatus_HEALTHY, "name2")
    	assert.Equal(t, s.lookup(s.addrXdsName("127.0.0.3")), []model.AddressInfo{{
    		Address: &workloadapi.Address{
    			Type: &workloadapi.Address_Workload{
    				Workload: &workloadapi.Workload{
    					Uid:               s.wleXdsName("name3"),
    					Name:              "name3",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 15.6K bytes
    - Viewed (0)
Back to top