Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for buildEndpoints (0.22 sec)

  1. pilot/pkg/xds/eds.go

    	if !edsNeedsPush(req.ConfigsUpdated) {
    		return nil, model.DefaultXdsLogDetails, nil
    	}
    	resources, logDetails := eds.buildEndpoints(proxy, req, w)
    	return resources, logDetails, nil
    }
    
    func (eds *EdsGenerator) GenerateDeltas(proxy *model.Proxy, req *model.PushRequest,
    	w *model.WatchedResource,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 15:58:06 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/serviceentry/controller.go

    			s.XdsUpdater.EDSUpdate(shard, string(k.hostname), k.namespace, eps)
    		}
    	}
    }
    
    // buildEndpoints builds endpoints for the instance keys.
    func (s *Controller) buildEndpoints(keys map[instancesKey]struct{}) map[instancesKey][]*model.IstioEndpoint {
    	var endpoints map[instancesKey][]*model.IstioEndpoint
    	allInstances := []*model.ServiceInstance{}
    	s.mutex.RLock()
    	for key := range keys {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/loadbalancer/loadbalancer_test.go

    							SubZone: "subzone1",
    						},
    						LbEndpoints: []*endpoint.LbEndpoint{
    							{
    								HostIdentifier: buildEndpoint("1.1.1.1"),
    								LoadBalancingWeight: &wrappers.UInt32Value{
    									Value: 1,
    								},
    							},
    							{
    								HostIdentifier: buildEndpoint("2.2.2.2"),
    								LoadBalancingWeight: &wrappers.UInt32Value{
    									Value: 1,
    								},
    							},
    						},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 23 05:38:57 UTC 2024
    - 39.1K bytes
    - Viewed (0)
Back to top