Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewConnectionHelper (0.24 sec)

  1. pkg/test/loadbalancersim/network/helper.go

    	"istio.io/istio/pkg/test/loadbalancersim/timeseries"
    )
    
    type ConnectionHelper struct {
    	name   string
    	hist   timeseries.Instance
    	active *atomic.Uint64
    	total  *atomic.Uint64
    }
    
    func NewConnectionHelper(name string) *ConnectionHelper {
    	return &ConnectionHelper{
    		active: atomic.NewUint64(0),
    		total:  atomic.NewUint64(0),
    		name:   name,
    	}
    }
    
    func (c *ConnectionHelper) Name() string {
    	return c.name
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 03 18:19:25 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  2. pkg/test/loadbalancersim/network/connection.go

    	ActiveRequests() uint64
    	Latency() *timeseries.Instance
    }
    
    func NewConnection(name string, request func(onDone func())) Connection {
    	return &connection{
    		request: request,
    		helper:  NewConnectionHelper(name),
    	}
    }
    
    type connection struct {
    	request func(onDone func())
    	helper  *ConnectionHelper
    }
    
    func (c *connection) Name() string {
    	return c.helper.Name()
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 03 18:19:25 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  3. pkg/test/loadbalancersim/loadbalancer/weight.go

    	helper *network2.ConnectionHelper
    }
    
    func newLBConnection(name string, conns []*WeightedConnection) *weightedConnections {
    	return &weightedConnections{
    		conns:  conns,
    		helper: network2.NewConnectionHelper(name),
    	}
    }
    
    func (lb *weightedConnections) AllWeightsEqual() bool {
    	if len(lb.conns) == 0 {
    		return true
    	}
    
    	weight := lb.conns[0].Weight
    	for _, conn := range lb.conns {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 03 18:19:25 UTC 2022
    - 2.8K bytes
    - Viewed (0)
  4. pkg/test/loadbalancersim/mesh/node.go

    	qLatency        timeseries.Instance
    }
    
    func newNode(name string, serviceTime time.Duration, enableQueueLatency bool, l locality.Instance) *Node {
    	return &Node{
    		locality:        l,
    		helper:          network.NewConnectionHelper(name),
    		q:               timer.NewQueue(),
    		serviceTime:     serviceTime,
    		qLatencyEnabled: enableQueueLatency,
    	}
    }
    
    func (n *Node) Name() string {
    	return n.helper.Name()
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 03 18:19:25 UTC 2022
    - 3.7K bytes
    - Viewed (0)
Back to top