dialer

type Dialer interface {

	// DialContext dials out to the domain or IP address representing a destination site.
	DialContext(ctx context.Context, network, addr string) (net.Conn, error)

	// Close closes the dialer and cleans up any resources
	Close()

	// OnOptions notifies the dialer of new Options.
	OnOptions(opts *Options) Dialer
}

type Options struct {
	// The available dialers to use when creating a new dialer
	Dialers []ProxyDialer

	// OnError is the onError callback that is called when the dialer encounters a dial error
	OnError func(error, bool)

	// OnSuccess is the callback that is called by dialer after a successful dial.
	OnSuccess func(ProxyDialer)

	// BanditDir is the directory where the bandit will store its data
	BanditDir string

	OnNewDialer func(Dialer)

	// Specifies whether or not to proxy all traffic. In this case, that means bypasses the proxyless
	// dialer and uses the proxy dialers to connect to the destination site.
	ProxyAll func() bool
	// contains filtered or unexported fields
}

type ProxyDialer interface {

	// DialProxy dials the proxy but does not yet dial the origin.
	DialProxy(ctx context.Context) (net.Conn, error)

	// SupportsAddr indicates whether this Dialer supports the given addr. If it does not, the
	// balancer will not attempt to dial that addr with this Dialer.
	SupportsAddr(network, addr string) bool

	// DialContext dials out to the given origin. failedUpstream indicates whether
	// this was an upstream error (as opposed to errors connecting to the proxy).
	DialContext(ctx context.Context, network, addr string) (conn net.Conn, failedUpstream bool, err error)

	// Name returns the name for this Dialer
	Name() string

	// Label returns a label for this Dialer (includes Name plus more).
	Label() string

	// JustifiedLabel is like Label() but with elements justified for line-by
	// -line display.
	JustifiedLabel() string

	// Location returns the country code, country name and city name of the
	// dialer, in this order.
	Location() (string, string, string)

	// Protocol returns a string representation of the protocol used by this
	// Dialer.
	Protocol() string

	// Addr returns the address for this Dialer
	Addr() string

	// Trusted indicates whether or not this dialer is trusted
	Trusted() bool

	// NumPreconnecting returns the number of pending preconnect requests.
	NumPreconnecting() int

	// NumPreconnected returns the number of preconnected connections.
	NumPreconnected() int

	// MarkFailure marks a dial failure on this dialer.
	MarkFailure()

	// EstRTT provides a round trip delay time estimate, similar to how RTT is
	// estimated in TCP (https://tools.ietf.org/html/rfc6298)
	EstRTT() time.Duration

	// EstBandwidth provides the estimated bandwidth in Mbps
	EstBandwidth() float64

	// EstSuccessRate returns the estimated success rate dialing this dialer.
	EstSuccessRate() float64

	// Attempts returns the total number of dial attempts
	Attempts() int64

	// Successes returns the total number of dial successes
	Successes() int64

	// ConsecSuccesses returns the number of consecutive dial successes
	ConsecSuccesses() int64

	// Failures returns the total number of dial failures
	Failures() int64

	// ConsecFailures returns the number of consecutive dial failures
	ConsecFailures() int64

	// Succeeding indicates whether or not this dialer is currently good to use
	Succeeding() bool

	// DataSent returns total bytes of application data sent to connections
	// created via this dialer.
	DataSent() uint64
	// DataRecv returns total bytes of application data received from
	// connections created via this dialer.
	DataRecv() uint64

	// Ready returns a channel which will have a value on it only when initialization
	// of the dialer is complete. If initialization failed, the channel will have a non-nil
	// error value. If initialization is not required, this will return nil channel value.
	Ready() <-chan error

	// Stop stops background processing for this Dialer.
	Stop()

	WriteStats(w io.Writer)
}