teaproxy

Jun 25, 2020

Changes in this version

+ var HOSTNAME = os.Hostname()

type ResponseWriter

+ func (this *ResponseWriter) Hijack() (conn net.Conn, buf *bufio.ReadWriter, err error)

Mar 29, 2020

Changes in this version

+ func CleanPath(path string) string

+ type EmptyResponseWriter struct

+ func NewEmptyResponseWriter() *EmptyResponseWriter

+ func (this *EmptyResponseWriter) Header() http.Header

+ func (this *EmptyResponseWriter) Write([]byte) (int, error)

+ func (this *EmptyResponseWriter) WriteHeader(statusCode int)

+ type ForwardProxy struct

+ type HTTPServeMux struct

+ func (this *HTTPServeMux) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Request

+ func (this *Request) Forward(writer *ResponseWriter) error

Nov 25, 2019

Changes in this version

+ var ErrFTPTooManyConnections = errors.New("ftp: too many connections")

+ var SharedFTPClientPool = NewFTPClientPool()

+ var SharedHTTPClientPool = NewHTTPClientPool()

+ type FTPClient struct

+ func (this *FTPClient) Close() error

+ func (this *FTPClient) Do(req *http.Request) (*http.Response, error)

+ type FTPClientPool struct

+ func NewFTPClientPool() *FTPClientPool

+ type FTPConnectionPool struct

+ func (this *FTPConnectionPool) Close(client *ftp.ServerConn) error

+ func (this *FTPConnectionPool) CloseAll() error

+ func (this *FTPConnectionPool) Decrease()

+ func (this *FTPConnectionPool) Get() (*ftp.ServerConn, error)

+ func (this *FTPConnectionPool) Increase()

+ func (this *FTPConnectionPool) Put(client *ftp.ServerConn)

+ type FTPResponseBody struct

+ func (this *FTPResponseBody) Close() error

+ type HTTPClientPool struct

+ func NewHTTPClientPool() *HTTPClientPool

Sep 30, 2019

Changes in this version

type Request

+ func (this *Request) SetRawScheme(scheme string)

Sep 1, 2019

Changes in this version

type Manager

+ func (this *Manager) FindAllServers() []*teaconfigs.ServerConfig

Jul 21, 2019

Changes in this version

+ const TCPClientBufferSize

+ const TCPClientMaxAttempts

+ const TCPClientStreamSize

type Listener

+ func (this *Listener) CloseTCPClient(lAddr string) error

+ func (this *Listener) TCPClients(maxSize int) []*TCPClient

type Manager

+ func (this *Manager) FindServerListeners(serverId string) []*Listener

type ResponseWriter

+ func (this *ResponseWriter) Reset(httpResponseWriter http.ResponseWriter)

+ func (this *ResponseWriter) WriteString(s string) (n int, err error)

type Scheme

+ const SchemeTCP

+ const SchemeTCPTLS

+ type TCPClient struct

+ func NewTCPClient(serverPool func() *teaconfigs.ServerConfig, conn net.Conn) *TCPClient

+ func (this *TCPClient) Close() error

+ func (this *TCPClient) Connect()

+ func (this *TCPClient) LConn() net.Conn

+ func (this *TCPClient) RConn() net.Conn

+ func (this *TCPClient) ReadSpeed() int64

+ func (this *TCPClient) WriteSpeed() int64

type TunnelConnection

+ func (this *TunnelConnection) IsAuthenticated() bool

+ func (this *TunnelConnection) OnClose(handler func(tunnelConn *TunnelConnection))

+ func (this *TunnelConnection) Ping() error

+ func (this *TunnelConnection) RemoteAddr() string

Jun 9, 2019

Changes in this version

+ var SharedTunnelManager = NewTunnelManager()

type Request

+ func (this *Request) SetVarMapping(varName string, varValue string)

+ func (this *Request) WriteResponseHeaders(writer *ResponseWriter, statusCode int)

+ type Tunnel struct

+ func NewTunnel(config *teaconfigs.TunnelConfig) *Tunnel

+ func (this *Tunnel) Close() error

+ func (this *Tunnel) CountConnections() int

+ func (this *Tunnel) Id() string

+ func (this *Tunnel) Start() error

+ func (this *Tunnel) Write(req *http.Request) (resp *http.Response, err error)

+ type TunnelConnection struct

+ func NewTunnelConnection(conn net.Conn) *TunnelConnection

+ func (this *TunnelConnection) Close() error

+ func (this *TunnelConnection) Write(req *http.Request) (*http.Response, error)

+ type TunnelManager struct

+ func NewTunnelManager() *TunnelManager

+ func (this *TunnelManager) FindTunnel(serverId, tunnelId string) *Tunnel

+ func (this *TunnelManager) OnAttach(server *teaconfigs.ServerConfig)

+ func (this *TunnelManager) OnDetach(server *teaconfigs.ServerConfig)

+ type TunnelResponseBody struct

+ func (this *TunnelResponseBody) Close() error

Apr 19, 2019

Changes in this version

+ const SchemeHTTP

+ const SchemeHTTPS

+ var QPS = int32(0)

+ var ShareStaticDelivery = NewStaticDelivery()

+ var SharedManager = NewManager()

type Listener

+ Address string

+ Error error

+ IsChanged bool

+ Scheme Scheme

+ func (this *Listener) ApplyServer(server *teaconfigs.ServerConfig)

+ func (this *Listener) HasServer(serverId string) bool

+ func (this *Listener) HasServers() bool

+ func (this *Listener) Reload() error

+ func (this *Listener) RemoveServer(serverId string)

+ func (this *Listener) Reset()

+ type Manager struct

+ func NewManager() *Manager

+ func (this *Manager) ApplyServer(server *teaconfigs.ServerConfig)

+ func (this *Manager) FindServer(serverId string) *teaconfigs.ServerConfig

+ func (this *Manager) FindServerErrors(serverId string) []string

+ func (this *Manager) Reload() error

+ func (this *Manager) RemoveServer(serverId string)

+ func (this *Manager) Restart() error

+ func (this *Manager) Shutdown() error

+ func (this *Manager) Start() error

+ func (this *Manager) Wait()

+ type NamedServer struct

+ Name string

+ Server *teaconfigs.ServerConfig

type Request

+ func (this *Request) Raw() *http.Request

+ func (this *Request) SetAttr(key string, value string)

+ func (this *Request) SetHost(host string)

+ func (this *Request) SetURI(uri string)

+ type Scheme = uint8

+ type StaticDelivery struct

+ func NewStaticDelivery() *StaticDelivery

+ func (this *StaticDelivery) Read(path string, stat os.FileInfo) (reader io.Reader, shouldClose bool, err error)

+ type StaticFileCache struct

Mar 4, 2019

Changes in this version

+ var LISTENERS = []*Listener

+ var SERVERS = map[string]*teaconfigs.ServerConfig

+ var SharedClientPool = NewClientPool()

+ var StatusCodeParser func(statusCode int, headers http.Header, respData []byte, parserScript string) (string, error) = nil

+ func AddRequestHook(hook *RequestHook)

+ func CallRequestAfterHook(req *Request, writer *ResponseWriter) (goNext bool)

+ func CallRequestBeforeHook(req *Request, writer *ResponseWriter) (goNext bool)

+ func FindServer(id string) (server *teaconfigs.ServerConfig, found bool)

+ func Restart()

+ func Shutdown()

+ func Start()

+ func Wait()

+ type ClientPool struct

+ func NewClientPool() *ClientPool

+ func (this *ClientPool) Reset()

+ type Listener struct

+ func NewListener(config *teaconfigs.ListenerConfig) *Listener

+ func (this *Listener) Shutdown() error

+ func (this *Listener) Start()

+ type RedirectError struct

+ func (this *RedirectError) Error() string

+ type Request struct

+ func NewRequest(rawRequest *http.Request) *Request

+ func (this *Request) CachePolicy() *shared.CachePolicy

+ func (this *Request) Format(source string) string

+ func (this *Request) IsCacheEnabled() bool

+ func (this *Request) IsWatching() bool

+ func (this *Request) SetCacheEnabled()

+ func (this *Request) SetCachePolicy(config *shared.CachePolicy)

+ func (this *Request) SetIsWatching(isWatching bool)

+ type RequestHook struct

+ AfterRequest func(req *Request, writer *ResponseWriter) (goNext bool)

+ BeforeRequest func(req *Request, writer *ResponseWriter) (goNext bool)

+ type ResponseWriter struct

+ func NewResponseWriter(httpResponseWriter http.ResponseWriter) *ResponseWriter

+ func (this *ResponseWriter) AddHeaders(header http.Header)

+ func (this *ResponseWriter) Body() []byte

+ func (this *ResponseWriter) BodyIsCopying() bool

+ func (this *ResponseWriter) Close()

+ func (this *ResponseWriter) Gzip(level uint8, minLength int64)

+ func (this *ResponseWriter) Header() http.Header

+ func (this *ResponseWriter) HeaderData() []byte

+ func (this *ResponseWriter) Prepare(size int64)

+ func (this *ResponseWriter) Raw() http.ResponseWriter

+ func (this *ResponseWriter) SentBodyBytes() int64

+ func (this *ResponseWriter) SetBodyCopying(b bool)

+ func (this *ResponseWriter) StatusCode() int

+ func (this *ResponseWriter) Write(data []byte) (n int, err error)

+ func (this *ResponseWriter) WriteHeader(statusCode int)