weighted

package

v0.10.0 Latest Latest Go to latest Published: Apr 13, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func Init() error

Init registers the weighted balancer.

type Balancer struct {
	// contains filtered or unexported fields
}

Balancer implements a weighted random load balancing algorithm.

func NewBalancer(proxies []proxy.Proxy) (*Balancer, error)

NewBalancer creates a new WeightedBalancer instance. It calculates the total weight and ensures it doesn't exceed MaxInt32.

func (b *Balancer) Proxies() []proxy.Proxy

Proxies returns the list of proxies managed by the balancer.

func (b *Balancer) Select(_ context.Context, _ *app.RequestContext) (proxy.Proxy, error)

Select picks a proxy based on weights.