proxy

Documentation

Index

• Constants
• func DnsGetDoaminIP(domain string) (string, error)
• func InitialPMuxConfig(conf *ProxyChannelConfig) *pmux.Config
• func MatchPatterns(str string, rules []string) bool
• func NewDialByConf(conf *ProxyChannelConfig) func(network, addr string) (net.Conn, error)
• func NewHTTPClient(conf *ProxyChannelConfig) (*http.Client, error)
• func RegisterProxyType(str string, p Proxy) error
• func Start(home string, monitor InternalEventMonitor) error
• func Stop() error
• func SyncConfig(addr string, localDir string) (bool, error)
• type AdminConfig
• type CipherConfig
• type GFWListConfig
• type HTTPBaseConfig
• type HTTPConfig
  • func (hcfg *HTTPConfig) UnmarshalJSON(data []byte) error
• type IPRange
• type IPRangeHolder
  • func (h *IPRangeHolder) Clear()
  • func (h *IPRangeHolder) FindCountry(ip string) (string, error)
  • func (h *IPRangeHolder) Len() int
  • func (h *IPRangeHolder) Less(i, j int) bool
  • func (h *IPRangeHolder) Swap(i, j int)
• type InternalEventMonitor
• type KCPBaseConfig
• type KCPConfig
  • func (kcfg *KCPConfig) UnmarshalJSON(data []byte) error
• type LocalConfig
• type LocalDNSConfig
• type PACConfig
  • func (pac *PACConfig) Match(protocol string, ip string, req *http.Request) bool
• type Proxy
• type ProxyChannelConfig
  • func (c *ProxyChannelConfig) ProxyURL() *url.URL
• type ProxyConfig
• type ProxyFeatureSet

Constants

const (
	BlockedByGFWRule = "BlockedByGFW"
	InHostsRule      = "InHosts"
	IsCNIPRule       = "IsCNIP"
)

Functions

func DnsGetDoaminIP

func DnsGetDoaminIP(domain string) (string, error)

func InitialPMuxConfig

func InitialPMuxConfig(conf *ProxyChannelConfig) *pmux.Config

func MatchPatterns

func MatchPatterns(str string, rules []string) bool

func NewDialByConf

func NewDialByConf(conf *ProxyChannelConfig) func(network, addr string) (net.Conn, error)

func NewHTTPClient

func NewHTTPClient(conf *ProxyChannelConfig) (*http.Client, error)

func RegisterProxyType

func RegisterProxyType(str string, p Proxy) error

func Start

func Start(home string, monitor InternalEventMonitor) error

func Stop

func Stop() error

func SyncConfig

func SyncConfig(addr string, localDir string) (bool, error)

Types

type AdminConfig

type AdminConfig struct {
	Listen        string
	BroadcastAddr string
	ConfigDir     string
}

type CipherConfig

type CipherConfig struct {
	Method string
	Key    string
}

type GFWListConfig

type GFWListConfig struct {
	URL      string
	UserRule []string
	Proxy    string
}

type HTTPBaseConfig

type HTTPBaseConfig struct {
	HTTPPushRateLimitPerSec int
}

type HTTPConfig

type HTTPConfig struct {
	HTTPBaseConfig
}

func (*HTTPConfig) UnmarshalJSON

func (hcfg *HTTPConfig) UnmarshalJSON(data []byte) error

type IPRange

type IPRange struct {
	Start, End uint64
	Country    string
}

type IPRangeHolder

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

func (*IPRangeHolder) Clear

func (h *IPRangeHolder) Clear()

func (*IPRangeHolder) FindCountry

func (h *IPRangeHolder) FindCountry(ip string) (string, error)

func (*IPRangeHolder) Len

func (h *IPRangeHolder) Len() int

func (*IPRangeHolder) Less

func (h *IPRangeHolder) Less(i, j int) bool

Less returns whether the element with index i should sort before the element with index j.

func (*IPRangeHolder) Swap

func (h *IPRangeHolder) Swap(i, j int)

Swap swaps the elements with indexes i and j.

type InternalEventMonitor

type InternalEventMonitor func(code int, desc string) error

type KCPBaseConfig

type KCPBaseConfig struct {
	Mode         string
	Conn         int
	AutoExpire   int
	ScavengeTTL  int
	MTU          int
	SndWnd       int
	RcvWnd       int
	DataShard    int
	ParityShard  int
	DSCP         int
	AckNodelay   bool
	NoDelay      int
	Interval     int
	Resend       int
	NoCongestion int
	SockBuf      int
}

type KCPConfig

type KCPConfig struct {
	KCPBaseConfig
}

func (*KCPConfig) UnmarshalJSON

func (kcfg *KCPConfig) UnmarshalJSON(data []byte) error

type LocalConfig

type LocalConfig struct {
	Log              []string
	Cipher           CipherConfig
	UserAgent        string
	User             string
	LocalDNS         LocalDNSConfig
	UDPGWAddr        string
	ChannelKeepAlive bool
	Admin            AdminConfig
	GFWList          GFWListConfig
	Proxy            []ProxyConfig
	Channel          []ProxyChannelConfig
}

var GConf LocalConfig

type LocalDNSConfig

type LocalDNSConfig struct {
	Listen     string
	TrustedDNS []string
	FastDNS    []string
	TCPConnect bool
	CacheSize  int
}

type PACConfig

type PACConfig struct {
	Method   []string
	Host     []string
	URL      []string
	Rule     []string
	Protocol []string
	Remote   string
}

func (*PACConfig) Match

func (pac *PACConfig) Match(protocol string, ip string, req *http.Request) bool

type Proxy

type Proxy interface {
	//PrintStat(w io.Writer)
	CreateMuxSession(server string, conf *ProxyChannelConfig) (mux.MuxSession, error)
	Features() ProxyFeatureSet
}

type ProxyChannelConfig

type ProxyChannelConfig struct {
	Enable              bool
	Name                string
	ServerList          []string
	ConnsPerServer      int
	SNI                 []string
	SNIProxy            string
	Proxy               string
	DialTimeout         int
	ReadTimeout         int
	ReconnectPeriod     int
	HeartBeatPeriod     int
	RCPRandomAdjustment int
	Compressor          string
	KCP                 KCPConfig
	HTTP                HTTPConfig
	// contains filtered or unexported fields
}

func (*ProxyChannelConfig) ProxyURL

func (c *ProxyChannelConfig) ProxyURL() *url.URL

type ProxyConfig

type ProxyConfig struct {
	Local    string
	PAC      []PACConfig
	SNISniff bool
}

type ProxyFeatureSet

type ProxyFeatureSet struct {
	AutoExpire bool
}