Rename load balanced dialer to loadBalancedSocks5Dialer

This commit is contained in:
9seconds
2021-03-09 18:23:39 +03:00
parent c8914f90db
commit 9124ffabf1
@@ -8,15 +8,15 @@ import (
"net/url" "net/url"
) )
type loadBalancedDialer struct { type loadBalancedSocks5Dialer struct {
dialers []Dialer dialers []Dialer
} }
func (l loadBalancedDialer) Dial(network, address string) (net.Conn, error) { func (l loadBalancedSocks5Dialer) Dial(network, address string) (net.Conn, error) {
return l.DialContext(context.Background(), network, address) return l.DialContext(context.Background(), network, address)
} }
func (l loadBalancedDialer) DialContext(ctx context.Context, network, address string) (net.Conn, error) { func (l loadBalancedSocks5Dialer) DialContext(ctx context.Context, network, address string) (net.Conn, error) {
length := len(l.dialers) length := len(l.dialers)
start := rand.Intn(length) start := rand.Intn(length)
moved := false moved := false
@@ -31,7 +31,7 @@ func (l loadBalancedDialer) DialContext(ctx context.Context, network, address st
return nil, ErrCannotDialWithAllProxies return nil, ErrCannotDialWithAllProxies
} }
func NewLoadBalancedDialer(baseDialer Dialer, proxyURLs []*url.URL) (Dialer, error) { func NewLoadBalancedSocks5Dialer(baseDialer Dialer, proxyURLs []*url.URL) (Dialer, error) {
var dialers []Dialer var dialers []Dialer
for _, u := range proxyURLs { for _, u := range proxyURLs {
@@ -43,7 +43,7 @@ func NewLoadBalancedDialer(baseDialer Dialer, proxyURLs []*url.URL) (Dialer, err
dialers = append(dialers, dialer) dialers = append(dialers, dialer)
} }
return loadBalancedDialer{ return loadBalancedSocks5Dialer{
dialers: dialers, dialers: dialers,
}, nil }, nil
} }