utils

package
v10.0.4+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 13, 2019 License: GPL-3.0 Imports: 34 Imported by: 0

Documentation

Overview

Provides leaky buffer, based on the example in Effective Go.

Index

Constants

View Source
const LeakyBufSize = 2048 // data.len(2) + hmacsha1(10) + data(4096)

Variables

View Source
var LeakyBuffer = NewLeakyBuf(maxNBuf, LeakyBufSize)

Functions

func BuildBytesPacket

func BuildBytesPacket(packetType uint8, data ...[]byte) []byte

func BuildPacket

func BuildPacket(packetType uint8, data ...string) []byte

func BuildPacketBytes

func BuildPacketBytes(data ...[]byte) []byte

func BuildPacketData

func BuildPacketData(data ...string) []byte

func CloseConn

func CloseConn(conn *net.Conn)

func ConnectHost

func ConnectHost(hostAndPort string, timeout int) (conn net.Conn, err error)

func ConnectKCPHost

func ConnectKCPHost(hostAndPort string, config kcpcfg.KCPConfigArgs) (conn net.Conn, err error)

func GetAllInterfaceAddr

func GetAllInterfaceAddr() ([]net.IP, error)

func GetKCPBlock

func GetKCPBlock(method, key string) (block kcp.BlockCrypt)

func HTTPGet

func HTTPGet(URL string, timeout int) (err error)

func HttpGet

func HttpGet(URL string, timeout int, host ...string) (body []byte, code int, err error)

func InsertProxyHeaders

func InsertProxyHeaders(head []byte, headers string) []byte

func IoBind

func IoBind(dst io.ReadWriteCloser, src io.ReadWriteCloser, fn func(err interface{}), log *logger.Logger)

func IoBindNoClose

func IoBindNoClose(dst io.ReadWriteCloser, src io.ReadWriteCloser, fn func(err interface{}), log *logger.Logger)

func IsHTTP

func IsHTTP(head []byte) bool

func IsInternalIP

func IsInternalIP(domainOrIP string, always bool) bool

func IsNetClosedErr

func IsNetClosedErr(err error) bool

func IsNetDeadlineErr

func IsNetDeadlineErr(err error) bool

func IsNetRefusedErr

func IsNetRefusedErr(err error) bool

func IsNetSocketNotConnectedErr

func IsNetSocketNotConnectedErr(err error) bool

func IsNetTimeoutErr

func IsNetTimeoutErr(err error) bool

func IsSocks5

func IsSocks5(head []byte) bool

func LBMethod

func LBMethod(key string) int

func LookupIP

func LookupIP(host string) ([]net.IP, error)

func NewCompConn

func NewCompConn(conn net.Conn) net.Conn

func NewDefaultLogger

func NewDefaultLogger() *logger.Logger

func PathExists

func PathExists(_path string) bool

func RandInt

func RandInt(strLen int) int64

func RandString

func RandString(strlen int) string

func ReadBytes

func ReadBytes(r io.Reader) (data []byte, err error)

func ReadBytesPacket

func ReadBytesPacket(r io.Reader, packetType *uint8, data ...*[]byte) (err error)

typed packet with bytes

func ReadData

func ReadData(r io.Reader) (data string, err error)

func ReadPacket

func ReadPacket(r io.Reader, packetType *uint8, data ...*string) (err error)

typed packet with string

func ReadPacketBytes

func ReadPacketBytes(r io.Reader, data ...*[]byte) (err error)

non typed packet with Bytes

func ReadPacketData

func ReadPacketData(r io.Reader, data ...*string) (err error)

non typed packet with string

func ReadUDPPacket

func ReadUDPPacket(_reader io.Reader) (srcAddr string, packet []byte, err error)

func RemoveProxyHeaders

func RemoveProxyHeaders(head []byte) []byte

func SingleTlsConfig

func SingleTlsConfig(caCertBytes []byte) (conf *tls.Config, err error)

func SingleTlsConnect

func SingleTlsConnect(host string, port, timeout int, caCertBytes []byte) (conn tls.Conn, err error)

func SingleTlsConnectHost

func SingleTlsConnectHost(host string, timeout int, caCertBytes []byte) (conn tls.Conn, err error)

func SubBytes

func SubBytes(bytes []byte, start, end int) []byte

func SubStr

func SubStr(str string, start, end int) string

func TlsBytes

func TlsBytes(cert, key string) (certBytes, keyBytes []byte, err error)

func TlsConfig

func TlsConfig(certBytes, keyBytes, caCertBytes []byte) (conf *tls.Config, err error)

func TlsConnect

func TlsConnect(host string, port, timeout int, certBytes, keyBytes, caCertBytes []byte) (conn tls.Conn, err error)

func TlsConnectHost

func TlsConnectHost(host string, timeout int, certBytes, keyBytes, caCertBytes []byte) (conn tls.Conn, err error)

func UDPCopy

func UDPCopy(dst, src *net.UDPConn, dstAddr net.Addr, readTimeout time.Duration, beforeWriteFn func(data []byte) []byte, deferFn func(e interface{}))

func UDPPacket

func UDPPacket(srcAddr string, packet []byte) []byte

func Uniqueid

func Uniqueid() string

Types

type BasicAuth

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

func NewBasicAuth

func NewBasicAuth(dns *dnsx.DomainResolver, log *logger.Logger) BasicAuth

func (*BasicAuth) Add

func (ba *BasicAuth) Add(userpassArr []string) (n int)

func (*BasicAuth) AddFromFile

func (ba *BasicAuth) AddFromFile(file string) (n int, err error)

func (*BasicAuth) Check

func (ba *BasicAuth) Check(userpass string, userIP, localIP, target string) (ok bool)

func (*BasicAuth) CheckUserPass

func (ba *BasicAuth) CheckUserPass(user, pass, userIP, localIP, target string) (ok bool)

func (*BasicAuth) Delete

func (ba *BasicAuth) Delete(userArr []string)

func (*BasicAuth) SetAuthURL

func (ba *BasicAuth) SetAuthURL(URL string, code, timeout, retry int)

func (*BasicAuth) Total

func (ba *BasicAuth) Total() (n int)

type BufferedConn

type BufferedConn struct {
	net.Conn // So that most methods are embedded
	// contains filtered or unexported fields
}

func NewBufferedConn

func NewBufferedConn(c net.Conn) BufferedConn

func NewBufferedConnSize

func NewBufferedConnSize(c net.Conn, n int) BufferedConn

func (BufferedConn) Buffered

func (b BufferedConn) Buffered() int

func (BufferedConn) Peek

func (b BufferedConn) Peek(n int) ([]byte, error)

func (BufferedConn) Read

func (b BufferedConn) Read(p []byte) (int, error)

func (BufferedConn) ReadByte

func (b BufferedConn) ReadByte() (byte, error)

func (BufferedConn) UnreadByte

func (b BufferedConn) UnreadByte() error

type Checker

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

func NewChecker

func NewChecker(timeout int, interval int64, blockedFile, directFile string, log *logger.Logger, intelligent string) Checker

NewChecker args: timeout : tcp timeout milliseconds ,connect to host interval: recheck domain interval seconds

func (*Checker) Add

func (c *Checker) Add(domain, address string)

func (*Checker) IsBlocked

func (c *Checker) IsBlocked(domain string) (blocked, isInMap bool, failN, successN uint)

func (*Checker) Stop

func (c *Checker) Stop()

type CheckerItem

type CheckerItem struct {
	Domain       string
	Address      string
	SuccessCount uint
	FailCount    uint
	Lasttime     int64
}

type ClientKeyRouter

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

func NewClientKeyRouter

func NewClientKeyRouter(ctrl *mapx.ConcurrentMap, size int) ClientKeyRouter

func (*ClientKeyRouter) GetKey

func (c *ClientKeyRouter) GetKey() string

type CompStream

type CompStream struct {
	net.Conn
	// contains filtered or unexported fields
}

func NewCompStream

func NewCompStream(conn net.Conn) *CompStream

func (*CompStream) Close

func (c *CompStream) Close() error

func (*CompStream) LocalAddr

func (c *CompStream) LocalAddr() net.Addr

func (*CompStream) Read

func (c *CompStream) Read(p []byte) (n int, err error)

func (*CompStream) RemoteAddr

func (c *CompStream) RemoteAddr() net.Addr

func (*CompStream) SetDeadline

func (c *CompStream) SetDeadline(t time.Time) error

func (*CompStream) SetReadDeadline

func (c *CompStream) SetReadDeadline(t time.Time) error

func (*CompStream) SetWriteDeadline

func (c *CompStream) SetWriteDeadline(t time.Time) error

func (*CompStream) Write

func (c *CompStream) Write(p []byte) (n int, err error)

type ConnManager

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

func NewConnManager

func NewConnManager(log *logger.Logger) ConnManager

func (*ConnManager) Add

func (cm *ConnManager) Add(key, ID string, conn *net.Conn)

func (*ConnManager) Remove

func (cm *ConnManager) Remove(key string)

func (*ConnManager) RemoveAll

func (cm *ConnManager) RemoveAll()

func (*ConnManager) RemoveOne

func (cm *ConnManager) RemoveOne(key string, ID string)

type HTTPRequest

type HTTPRequest struct {
	HeadBuf []byte

	Host   string
	Method string
	URL    string

	IsSNI bool
	// contains filtered or unexported fields
}

func NewHTTPRequest

func NewHTTPRequest(inConn *net.Conn, bufSize int, isBasicAuth bool, basicAuth *BasicAuth, log *logger.Logger, header ...[]byte) (req HTTPRequest, err error)

func (*HTTPRequest) BasicAuth

func (req *HTTPRequest) BasicAuth() (err error)

func (*HTTPRequest) GetAuthDataStr

func (req *HTTPRequest) GetAuthDataStr(allowNull bool) (basicInfo string, err error)

func (*HTTPRequest) HTTP

func (req *HTTPRequest) HTTP() (err error)

func (*HTTPRequest) HTTPS

func (req *HTTPRequest) HTTPS() (err error)

func (*HTTPRequest) HTTPSReply

func (req *HTTPRequest) HTTPSReply() (err error)

func (*HTTPRequest) IsHTTPS

func (req *HTTPRequest) IsHTTPS() bool

type LeakyBuf

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

func NewLeakyBuf

func NewLeakyBuf(n, bufSize int) *LeakyBuf

NewLeakyBuf creates a leaky buffer which can hold at most n buffer, each with bufSize bytes.

func (*LeakyBuf) Get

func (lb *LeakyBuf) Get() (b []byte)

Get returns a buffer from the leaky buffer or create a new buffer.

func (*LeakyBuf) Put

func (lb *LeakyBuf) Put(b []byte)

Put add the buffer into the free buffer pool for reuse. Panic if the buffer size is not the same with the leaky buffer's. This is intended to expose error usage of leaky buffer.

Directories

Path Synopsis
Package xid is a globally unique id generator suited for web scale Xid is using Mongo Object ID algorithm to generate globally unique ids: https://docs.mongodb.org/manual/reference/object-id/ - 4-byte value representing the seconds since the Unix epoch, - 3-byte machine identifier, - 2-byte process id, and - 3-byte counter, starting with a random value.
Package xid is a globally unique id generator suited for web scale Xid is using Mongo Object ID algorithm to generate globally unique ids: https://docs.mongodb.org/manual/reference/object-id/ - 4-byte value representing the seconds since the Unix epoch, - 3-byte machine identifier, - 2-byte process id, and - 3-byte counter, starting with a random value.

Jump to

Keyboard shortcuts

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