Versions in this module Expand all Collapse all v0 v0.30.0 Oct 29, 2017 Changes in this version + const DirectChannelName + const LocalVersion + const RemoteVersion + var DirectSchemes = []string + var LocalChannelTypeTable map[string]reflect.Type = make(map[string]reflect.Type) + func AllowedSchema() []string + func DialServerByConf(server string, conf *ProxyChannelConfig) (net.Conn, error) + func DumpLoaclChannelStat(w io.Writer) + func InitialPMuxConfig(cipher *CipherConfig) *pmux.Config + func IsDirectScheme(scheme string) bool + func NewDialByConf(conf *ProxyChannelConfig, scheme string) func(network, addr string) (net.Conn, error) + func NewHTTPClient(conf *ProxyChannelConfig, scheme string) (*http.Client, error) + func NewTLSConfig(conf *ProxyChannelConfig) *tls.Config + func RegisterLocalChannelType(str string, p LocalChannel) error + func ServProxyMuxSession(session mux.MuxSession) error + func SetDefaultMuxConfig(cfg MuxConfig) + func StopLocalChannels() + type CipherConfig struct + Key string + Method string + User string + var DefaultServerCipher CipherConfig + func (conf *CipherConfig) Adjust() + func (conf *CipherConfig) AllowUsers(users string) + func (conf *CipherConfig) VerifyUser(user string) bool + type FeatureSet struct + AutoExpire bool + Pingable bool + type HTTPBaseConfig struct + HTTPPushRateLimitPerSec int + ReadTimeout int + UserAgent string + type HTTPConfig struct + func (hcfg *HTTPConfig) UnmarshalJSON(data []byte) error + type HopServers []string + func (i *HopServers) Set(value string) error + func (i *HopServers) String() string + type KCPBaseConfig struct + AckNodelay bool + AutoExpire int + Conn int + DSCP int + DataShard int + Interval int + MTU int + Mode string + NoCongestion int + NoDelay int + ParityShard int + RcvWnd int + Resend int + ScavengeTTL int + SndWnd int + SockBuf int + type KCPConfig struct + func (kcfg *KCPConfig) UnmarshalJSON(data []byte) error + type LocalChannel interface + CreateMuxSession func(server string, conf *ProxyChannelConfig) (mux.MuxSession, error) + Features func() FeatureSet + type LocalProxyChannel struct + Conf ProxyChannelConfig + func NewProxyChannel(conf *ProxyChannelConfig) *LocalProxyChannel + func (ch *LocalProxyChannel) Init(lock bool) bool + type MuxConfig struct + MaxStreamWindow string + StreamMinRefresh string + func (m *MuxConfig) ToPMuxConf() *pmux.Config + type ProxyChannelConfig struct + Cipher CipherConfig + Compressor string + ConnsPerServer int + Enable bool + HTTP HTTPConfig + HeartBeatPeriod int + Hops HopServers + KCP KCPConfig + LocalDialMSTimeout int + Name string + Proxy string + RCPRandomAdjustment int + ReconnectPeriod int + RemoteDNSReadMSTimeout int + RemoteDialMSTimeout int + RemoteUDPReadMSTimeout int + SNI []string + SNIProxy string + ServerList []string + func GetMuxStreamByChannel(name string) (mux.MuxStream, *ProxyChannelConfig, error) + func GetMuxStreamByURL(u *url.URL, defaultUser string, defaultCipher *CipherConfig) (mux.MuxStream, *ProxyChannelConfig, error) + func (c *ProxyChannelConfig) ProxyURL() *url.URL + func (conf *ProxyChannelConfig) Adjust()