proxy

package

v1.0.0 Latest Latest Go to latest Published: Sep 11, 2017 License: MIT Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/JeffJiangHub/goflyway

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func ADecrypt(buf []byte) []byte
func ADecryptString(text string) string
func AEncrypt(buf []byte) []byte
func AEncryptString(text string) string
func Base35Decode(text string) []byte
func Base35Encode(buf []byte) string
func DecryptHost(text, mark string) string
func DecryptRequest(req *http.Request) string
func EncryptHost(text, mark string) string
func EncryptRequest(req *http.Request) string
func NewRand() *rand.Rand
func RandomKey() string
func ReverseRandomKey(key string) []byte
func SafeAddHeader(req *http.Request, k, v string)
func SafeGetHeader(req *http.Request, k string) string
func SplitHostPort(host string) (string, string)
func StartClient(localaddr, upstream string)
func StartServer(addr string)
func TwoWayBridge(target, source net.Conn, key string, throttleTargetToSource bool)
func XorWrite(w http.ResponseWriter, r *http.Request, p []byte, code int) (n int, err error)
type IOCopyCipher
- func (cc *IOCopyCipher) DoCopy() (written int64, err error)
type IOReaderCipher
- func (rc *IOReaderCipher) Init() *IOReaderCipher
- func (rc *IOReaderCipher) Read(p []byte) (n int, err error)
type InplaceCTR
- func GetCipherStream(key []byte) *InplaceCTR
- func (x *InplaceCTR) XorBuffer(buf []byte)
type ProxyHttpServer
- func (proxy *ProxyHttpServer) CanDirectConnect(host string) bool
- func (proxy *ProxyHttpServer) ServeHTTP(w http.ResponseWriter, r *http.Request)
type ProxyUpstreamHttpServer
- func (proxy *ProxyUpstreamHttpServer) ServeHTTP(w http.ResponseWriter, r *http.Request)
type TokenBucket
- func NewTokenBucket(speed, max int64) *TokenBucket
- func (tb *TokenBucket) Consume(n int64)

Constants ¶

View Source

const IV_LENGTH = 16

Variables ¶

View Source

var (
	OK200 = []byte("HTTP/1.0 200 OK\r\n\r\n")
)

Functions ¶

func ADecrypt ¶

func ADecrypt(buf []byte) []byte

func ADecryptString ¶

func ADecryptString(text string) string

func AEncrypt ¶

func AEncrypt(buf []byte) []byte

func AEncryptString ¶

func AEncryptString(text string) string

func Base35Decode ¶

func Base35Decode(text string) []byte

func Base35Encode ¶

func Base35Encode(buf []byte) string

func DecryptHost ¶

func DecryptHost(text, mark string) string

func DecryptRequest ¶

func DecryptRequest(req *http.Request) string

func EncryptHost ¶

func EncryptHost(text, mark string) string

func EncryptRequest ¶

func EncryptRequest(req *http.Request) string

func NewRand ¶

func NewRand() *rand.Rand

func RandomKey ¶

func RandomKey() string

func ReverseRandomKey ¶

func ReverseRandomKey(key string) []byte

func SafeAddHeader ¶

func SafeAddHeader(req *http.Request, k, v string)

func SafeGetHeader ¶

func SafeGetHeader(req *http.Request, k string) string

func SplitHostPort ¶

func SplitHostPort(host string) (string, string)

func StartClient ¶

func StartClient(localaddr, upstream string)

func StartServer ¶

func StartServer(addr string)

func TwoWayBridge ¶

func TwoWayBridge(target, source net.Conn, key string, throttleTargetToSource bool)

func XorWrite ¶

func XorWrite(w http.ResponseWriter, r *http.Request, p []byte, code int) (n int, err error)

Types ¶

type IOCopyCipher ¶

type IOCopyCipher struct {
	Dst        io.Writer
	Src        io.Reader
	Key        []byte
	Throttling *TokenBucket
	Partial    bool
}

func (*IOCopyCipher) DoCopy ¶

func (cc *IOCopyCipher) DoCopy() (written int64, err error)

type IOReaderCipher ¶

type IOReaderCipher struct {
	Src io.Reader
	Key []byte
	// contains filtered or unexported fields
}

func (*IOReaderCipher) Init ¶

func (rc *IOReaderCipher) Init() *IOReaderCipher

func (*IOReaderCipher) Read ¶

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

type InplaceCTR ¶

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

func GetCipherStream ¶

func GetCipherStream(key []byte) *InplaceCTR

func (*InplaceCTR) XorBuffer ¶

func (x *InplaceCTR) XorBuffer(buf []byte)

From src/crypto/cipher/ctr.go

type ProxyHttpServer ¶

type ProxyHttpServer struct {
	Tr       *http.Transport
	TrDirect *http.Transport
	Upstream string
}

func (*ProxyHttpServer) CanDirectConnect ¶

func (proxy *ProxyHttpServer) CanDirectConnect(host string) bool

func (*ProxyHttpServer) ServeHTTP ¶

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

type ProxyUpstreamHttpServer ¶

type ProxyUpstreamHttpServer struct {
	Tr *http.Transport
}

func (*ProxyUpstreamHttpServer) ServeHTTP ¶

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

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL