Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for PriorityWeightedConnectionFactory (0.42 sec)

  1. pkg/test/loadbalancersim/loadbalancer/weight.go

    	return func(src *mesh2.Client, dest *mesh2.Node) *WeightedConnection {
    		return &WeightedConnection{
    			Connection: src.Mesh().NewConnection(src, dest),
    			Weight:     1,
    		}
    	}
    }
    
    func PriorityWeightedConnectionFactory(selectPriority PrioritySelector, priorityWeightMap map[uint32]uint32) WeightedConnectionFactory {
    	return func(src *mesh2.Client, dest *mesh2.Node) *WeightedConnection {
    		// Select the priority for this node.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 03 18:19:25 UTC 2022
    - 2.8K bytes
    - Viewed (0)
  2. pkg/test/loadbalancersim/lb_test.go

    	}{
    		{
    			enableWeighting:       false,
    			newWeightedConnection: loadbalancer.EquallyWeightedConnectionFactory(),
    		},
    		{
    			enableWeighting:       true,
    			newWeightedConnection: loadbalancer.PriorityWeightedConnectionFactory(loadbalancer.LocalityPrioritySelector, priorityWeights),
    		},
    	}
    
    	algorithmCases := []struct {
    		name  string
    		newLB func(conns []*loadbalancer.WeightedConnection) network.Connection
    	}{
    		{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 19 23:29:30 UTC 2022
    - 11K bytes
    - Viewed (0)
Back to top