utils

package
v0.0.0-...-0a103c7 Latest Latest
Warning

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

 Go to latest Published: Feb 26, 2021 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() (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.

Source Files

View all Source files

Directories

Path Synopsis
Package xid is a globally unique id generator suited for web scale
 Package xid is a globally unique id generator suited for web scale

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.