strategy

Documentation

Index

• func OnRecord(dialer proxy.Dialer, success bool)
• type Config
• type Forwarder
  • func DirectForwarder(intface string, dialTimeout, relayTimeout time.Duration) *Forwarder
  • func ForwarderFromURL(s, intface string, dialTimeout, relayTimeout time.Duration) (f *Forwarder, err error)
  • func (f *Forwarder) AddHandler(h StatusHandler)
  • func (f *Forwarder) Addr() string
  • func (f *Forwarder) Dial(network, addr string) (c net.Conn, err error)
  • func (f *Forwarder) Disable()
  • func (f *Forwarder) Enable()
  • func (f *Forwarder) Enabled() bool
  • func (f *Forwarder) Failures() uint32
  • func (f *Forwarder) IncFailures()
  • func (f *Forwarder) Latency() int64
  • func (f *Forwarder) MaxFailures() uint32
  • func (f *Forwarder) Priority() uint32
  • func (f *Forwarder) SetLatency(l int64)
  • func (f *Forwarder) SetMaxFailures(l uint32)
  • func (f *Forwarder) SetPriority(l uint32)
• type Proxy
  • func NewProxy(name string, s []string, c *Config) *Proxy
  • func (p *Proxy) Check()
  • func (p *Proxy) Dial(network, addr string) (net.Conn, proxy.Dialer, error)
  • func (p *Proxy) DialUDP(network, addr string) (pc net.PacketConn, writeTo net.Addr, err error)
  • func (p *Proxy) NextDialer(dstAddr string) proxy.Dialer
  • func (p *Proxy) Priority() uint32
  • func (p *Proxy) Record(dialer proxy.Dialer, success bool)
  • func (p *Proxy) SetPriority(pri uint32)
• type StatusHandler

Functions

func OnRecord

func OnRecord(dialer proxy.Dialer, success bool)

OnRecord records result while using the dialer from proxy.

Types

type Config

type Config struct {
	Strategy          string
	CheckWebSite      string
	CheckInterval     int
	CheckTimeout      int
	CheckDisabledOnly bool
	MaxFailures       int
	DialTimeout       int
	RelayTimeout      int
	IntFace           string
}

Config is strategy config struct.

type Forwarder

type Forwarder struct {
	proxy.Dialer
	// contains filtered or unexported fields
}

Forwarder is a forwarder

func DirectForwarder

func DirectForwarder(intface string, dialTimeout, relayTimeout time.Duration) *Forwarder

DirectForwarder returns a direct forwarder.

func ForwarderFromURL

func ForwarderFromURL(s, intface string, dialTimeout, relayTimeout time.Duration) (f *Forwarder, err error)

ForwarderFromURL parses `forward=` command value and returns a new forwarder.

func (*Forwarder) AddHandler

func (f *Forwarder) AddHandler(h StatusHandler)

AddHandler adds a custom handler to handle the status change event.

func (*Forwarder) Addr

func (f *Forwarder) Addr() string

Addr returns the forwarder's addr.

func (*Forwarder) Dial

func (f *Forwarder) Dial(network, addr string) (c net.Conn, err error)

Dial dials to addr and returns conn.

func (*Forwarder) Disable

func (f *Forwarder) Disable()

Disable the forwarder.

func (*Forwarder) Enable

func (f *Forwarder) Enable()

Enable the forwarder.

func (*Forwarder) Enabled

func (f *Forwarder) Enabled() bool

Enabled returns the status of forwarder.

func (*Forwarder) Failures

func (f *Forwarder) Failures() uint32

Failures returns the failuer count of forwarder.

func (*Forwarder) IncFailures

func (f *Forwarder) IncFailures()

IncFailures increase the failuer count by 1.

func (*Forwarder) Latency

func (f *Forwarder) Latency() int64

Latency returns the latency of forwarder.

func (*Forwarder) MaxFailures

func (f *Forwarder) MaxFailures() uint32

MaxFailures returns the maxFailures of forwarder.

func (*Forwarder) Priority

func (f *Forwarder) Priority() uint32

Priority returns the priority of forwarder.

func (*Forwarder) SetLatency

func (f *Forwarder) SetLatency(l int64)

SetLatency sets the latency of forwarder.

func (*Forwarder) SetMaxFailures

func (f *Forwarder) SetMaxFailures(l uint32)

SetMaxFailures sets the maxFailures of forwarder.

func (*Forwarder) SetPriority

func (f *Forwarder) SetPriority(l uint32)

SetPriority sets the priority of forwarder.

type Proxy

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

Proxy is base proxy struct.

func NewProxy

func NewProxy(name string, s []string, c *Config) *Proxy

NewProxy returns a new strategy proxy.

func (*Proxy) Check

func (p *Proxy) Check()

Check implements the Checker interface.

func (*Proxy) Dial

func (p *Proxy) Dial(network, addr string) (net.Conn, proxy.Dialer, error)

Dial connects to the address addr on the network net.

func (*Proxy) DialUDP

func (p *Proxy) DialUDP(network, addr string) (pc net.PacketConn, writeTo net.Addr, err error)

DialUDP connects to the given address.

func (*Proxy) NextDialer

func (p *Proxy) NextDialer(dstAddr string) proxy.Dialer

NextDialer returns the next dialer.

func (*Proxy) Priority

func (p *Proxy) Priority() uint32

Priority returns the active priority of dialer.

func (*Proxy) Record

func (p *Proxy) Record(dialer proxy.Dialer, success bool)

Record records result while using the dialer from proxy.

func (*Proxy) SetPriority

func (p *Proxy) SetPriority(pri uint32)

SetPriority sets the active priority of daler.

type StatusHandler

type StatusHandler func(*Forwarder)

StatusHandler function will be called when the forwarder's status changed