Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for AddWorkloadInfo (0.24 sec)

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

    	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()
    	for _, info := range infos {
    		sd.addresses[info.ResourceName()] = workloadToAddressInfo(info.Workload)
    	}
    }
    
    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/xds/delta_test.go

    		},
    	}
    	svcC := &model.ServiceInfo{
    		Service: &workloadapi.Service{
    			Name:      "c",
    			Namespace: "default",
    			Hostname:  "c.default.svc.cluster.local",
    		},
    	}
    	s.MemRegistry.AddWorkloadInfo(wlA, wlB, wlC)
    	s.MemRegistry.AddServiceInfo(svcA, svcB, svcC)
    
    	// 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)
Back to top