loadbalance

package

v1.1.0 Latest Latest Go to latest Published: May 28, 2026 License: GPL-3.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func NewAdaptive(dials []proxyclient.Dial) proxyclient.Dial

NewAdaptive creates a Dial that tracks success/failure/latency per node and routes traffic to the best-performing nodes.

func NewHash(proxies []proxyclient.Dial) proxyclient.Dial

func NewRandom(proxies []proxyclient.Dial) proxyclient.Dial

func NewRoundRobin(proxies []proxyclient.Dial) proxyclient.Dial

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

Tracker wraps a set of Dials with dead-node detection. Nodes that fail consecutively are temporarily removed from rotation.

func NewTracker(dials []proxyclient.Dial) *Tracker

func (t *Tracker) AliveIndices() []int

AliveIndices returns indices of nodes currently considered alive.

func (t *Tracker) Dial(ctx context.Context, network, address string, pick int) (net.Conn, error)

Dial tries the node at index, records success/failure, and falls back on error.

func (t *Tracker) Len() int