proxy

Documentation

Index

• Constants
• type Cipher
  • func (gc *Cipher) Decrypt(buf []byte, ss ...byte) []byte
  • func (gc *Cipher) DecryptDecompress(str string, rkey ...byte) string
  • func (gc *Cipher) DecryptString(text string, rkey ...byte) string
  • func (gc *Cipher) Encrypt(buf []byte, ss ...byte) []byte
  • func (gc *Cipher) EncryptCompress(str string, rkey ...byte) string
  • func (gc *Cipher) EncryptString(text string, rkey ...byte) string
  • func (gc *Cipher) Init(key string) (err error)
  • func (gc *Cipher) NewIV(o Options, payload []byte, auth string) (string, []byte)
  • func (gc *Cipher) ReverseIV(key string) (o Options, iv []byte, auth []byte)
• type ClientConfig
• type IOConfig
• type IOReadCloserCipher
  • func (rc *IOReadCloserCipher) Close() error
  • func (rc *IOReadCloserCipher) Read(p []byte) (n int, err error)
• type OneBytePool
  • func NewOneBytePool(s int) *OneBytePool
  • func (p *OneBytePool) Free(buf []byte)
  • func (p *OneBytePool) Get() []byte
• type Options
  • func (o *Options) IsSet(option byte) bool
  • func (o *Options) Set(option byte)
  • func (o *Options) UnSet(option byte)
  • func (o *Options) Val() byte
• type ProxyClient
  • func NewClient(localaddr string, config *ClientConfig) *ProxyClient
  • func (proxy *ProxyClient) PACFile(w http.ResponseWriter, r *http.Request)
  • func (proxy *ProxyClient) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (proxy *ProxyClient) Start() error
  • func (proxy *ProxyClient) UpdateKey(newKey string)
• type ProxyUpstream
  • func NewServer(addr string, config *ServerConfig) *ProxyUpstream
  • func (proxy *ProxyUpstream) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (proxy *ProxyUpstream) Start() error
  • func (proxy *ProxyUpstream) Write(w http.ResponseWriter, key, p []byte, code int) (n int, err error)
• type ServerConfig
• type TokenBucket
  • func NewTokenBucket(speed, max int64) *TokenBucket
  • func (tb *TokenBucket) Consume(n int64)
• type UserConfig

Constants

const (
	PolicyDisabled = 1 << iota
	PolicyManInTheMiddle
	PolicyGlobal
	PolicyTrustClientDNS
	PolicyAggrClosing
	PolicyWebSocket
)

Types

type Cipher

type Cipher struct {
	IO io_t

	Key       []byte
	KeyString string
	Block     cipher.Block
	Rand      *rand.ConcurrentRand
	Partial   bool
	Alias     string
}

func (*Cipher) Decrypt

func (gc *Cipher) Decrypt(buf []byte, ss ...byte) []byte

func (*Cipher) DecryptDecompress

func (gc *Cipher) DecryptDecompress(str string, rkey ...byte) string

func (*Cipher) DecryptString

func (gc *Cipher) DecryptString(text string, rkey ...byte) string

func (*Cipher) Encrypt

func (gc *Cipher) Encrypt(buf []byte, ss ...byte) []byte

func (*Cipher) EncryptCompress

func (gc *Cipher) EncryptCompress(str string, rkey ...byte) string

func (*Cipher) EncryptString

func (gc *Cipher) EncryptString(text string, rkey ...byte) string

func (*Cipher) Init

func (gc *Cipher) Init(key string) (err error)

func (*Cipher) NewIV

func (gc *Cipher) NewIV(o Options, payload []byte, auth string) (string, []byte)

func (*Cipher) ReverseIV

func (gc *Cipher) ReverseIV(key string) (o Options, iv []byte, auth []byte)

type ClientConfig

type ClientConfig struct {
	Upstream string
	Policy   Options
	UserAuth string

	Connect2     string
	Connect2Auth string
	DummyDomain  string
	URLHeader    string

	UDPRelayPort   int
	UDPRelayCoconn int

	Mux int

	DNSCache *lru.Cache
	CA       tls.Certificate
	CACache  *lru.Cache

	*Cipher
}

type IOConfig

type IOConfig struct {
	Bucket  *TokenBucket
	Chunked bool
	Partial bool
	WSCtrl  byte
}

type IOReadCloserCipher

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

func (*IOReadCloserCipher) Close

func (rc *IOReadCloserCipher) Close() error

func (*IOReadCloserCipher) Read

func (rc *IOReadCloserCipher) Read(p []byte) (n int, err error)

type OneBytePool

type OneBytePool chan []byte

func NewOneBytePool

func NewOneBytePool(s int) *OneBytePool

func (*OneBytePool) Free

func (p *OneBytePool) Free(buf []byte)

func (*OneBytePool) Get

func (p *OneBytePool) Get() []byte

type Options

type Options byte

func (*Options) IsSet

func (o *Options) IsSet(option byte) bool

func (*Options) Set

func (o *Options) Set(option byte)

func (*Options) UnSet

func (o *Options) UnSet(option byte)

func (*Options) Val

func (o *Options) Val() byte

type ProxyClient

type ProxyClient struct {
	*ClientConfig

	UDP struct {
		sync.Mutex
		Conns map[string]*udp_tcp_conn_t
		Addrs map[net.Addr]bool
	}

	Localaddr string
	Listener  *listenerWrapper
	// contains filtered or unexported fields
}

func NewClient

func NewClient(localaddr string, config *ClientConfig) *ProxyClient

func (*ProxyClient) PACFile

func (proxy *ProxyClient) PACFile(w http.ResponseWriter, r *http.Request)

func (*ProxyClient) ServeHTTP

func (proxy *ProxyClient) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*ProxyClient) Start

func (proxy *ProxyClient) Start() error

func (*ProxyClient) UpdateKey

func (proxy *ProxyClient) UpdateKey(newKey string)

type ProxyUpstream

type ProxyUpstream struct {
	Localaddr string

	*ServerConfig
	// contains filtered or unexported fields
}

func NewServer

func NewServer(addr string, config *ServerConfig) *ProxyUpstream

func (*ProxyUpstream) ServeHTTP

func (proxy *ProxyUpstream) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*ProxyUpstream) Start

func (proxy *ProxyUpstream) Start() error

func (*ProxyUpstream) Write

func (proxy *ProxyUpstream) Write(w http.ResponseWriter, key, p []byte, code int) (n int, err error)

type ServerConfig

type ServerConfig struct {
	Throttling     int64
	ThrottlingMax  int64
	UDPRelayListen int
	ProxyPassAddr  string

	Mux bool

	Users map[string]UserConfig

	*Cipher
}

type TokenBucket

type TokenBucket struct {
	Speed int64 // bytes per second
	// contains filtered or unexported fields
}

func NewTokenBucket

func NewTokenBucket(speed, max int64) *TokenBucket

func (*TokenBucket) Consume

func (tb *TokenBucket) Consume(n int64)

type UserConfig

type UserConfig struct {
	Auth          string
	Throttling    int64
	ThrottlingMax int64
}

for multi-users server, not implemented yet