helper

Documentation

Index

• Constants
• Variables
• func AsyncNotify(ch chan struct{})
• func AsyncSendErr(ch chan error, err error)
• func ByteSize(bytes uint64) string
• func GenerateTLSConfig() *tls.Config
• func GetLocalIPSet() map[string]bool
• func GetLocalIPv4() []string
• func GetRequestURLString(req *http.Request) string
• func HTTPProxyConnect(proxyURL *url.URL, c net.Conn, addr string) error
• func IPv42Int(ip string) (int64, error)
• func IsPrivateIP(ip string) bool
• func IsTimeoutError(err error) bool
• func Long2IPv4(i uint64) string
• func PKCS7Pad(buf *bytes.Buffer, blen int)
• func PKCS7Unpad(in []byte) []byte
• func PeekTLSServerName(reader *bufio.Reader) (string, error)
• func PrepareRegexp(rule string) (*regexp.Regexp, error)
• func ProxyDial(proxyURL string, addr string, timeout time.Duration) (net.Conn, error)
• func RandAsciiString(n int) string
• func RandBetween(min, max int) int
• func ReadWithoutComment(file string, commentPrefix string) ([]byte, error)
• func Socks5ProxyConnect(proxyURL *url.URL, conn net.Conn, addr string) error
• func Socks5ProxyDial(proxyURL string, addr string, timeout time.Duration) (net.Conn, error)
• func ToBytes(s string) (uint64, error)
• func ToMegabytes(s string) (uint64, error)
• func WildcardMatch(text string, pattern string) bool
• type BufferChunkReader
  • func (r *BufferChunkReader) Read(p []byte) (int, error)
• type DebugReader
  • func (r *DebugReader) Read(p []byte) (int, error)
• type TimeoutReadWriteCloser
  • func (s *TimeoutReadWriteCloser) Read(p []byte) (n int, err error)
  • func (s *TimeoutReadWriteCloser) SetReadDeadline(t time.Time) error
  • func (s *TimeoutReadWriteCloser) SetWriteDeadline(t time.Time) error
  • func (s *TimeoutReadWriteCloser) Write(p []byte) (n int, err error)

Constants

const (
	BYTE     = 1.0
	KILOBYTE = 1024 * BYTE
	MEGABYTE = 1024 * KILOBYTE
	GIGABYTE = 1024 * MEGABYTE
	TERABYTE = 1024 * GIGABYTE
)

copy from https://github.com/cloudfoundry/bytefmt/blob/master/bytes.go

Variables

var ErrConnReset = errors.New("Conn reset")

var ErrNoSNI = errors.New("No SNI in protocol")

var ErrReadTimeout = errors.New("read timeout")

var ErrTLSClientHello = errors.New("Invalid tls client hello")

var ErrTLSIncomplete = errors.New("TLS header incomplete")

var ErrWriteTimeout = errors.New("write timeout")

Functions

func AsyncNotify

func AsyncNotify(ch chan struct{})

asyncNotify is used to signal a waiting goroutine

func AsyncSendErr

func AsyncSendErr(ch chan error, err error)

func ByteSize

func ByteSize(bytes uint64) string

ByteSize returns a human-readable byte string of the form 10M, 12.5K, and so forth. The following units are available:

T: Terabyte
G: Gigabyte
M: Megabyte
K: Kilobyte
B: Byte

The unit that results in the smallest number greater than or equal to 1 is always chosen.

func GenerateTLSConfig

func GenerateTLSConfig() *tls.Config

Setup a bare-bones TLS config for the server

func GetLocalIPSet

func GetLocalIPSet() map[string]bool

func GetLocalIPv4

func GetLocalIPv4() []string

func GetRequestURLString

func GetRequestURLString(req *http.Request) string

func HTTPProxyConnect

func HTTPProxyConnect(proxyURL *url.URL, c net.Conn, addr string) error

func IPv42Int

func IPv42Int(ip string) (int64, error)

func IsPrivateIP

func IsPrivateIP(ip string) bool

func IsTimeoutError

func IsTimeoutError(err error) bool

func Long2IPv4

func Long2IPv4(i uint64) string

func PKCS7Pad

func PKCS7Pad(buf *bytes.Buffer, blen int)

func PKCS7Unpad

func PKCS7Unpad(in []byte) []byte

Returns slice of the original data without padding.

func PeekTLSServerName

func PeekTLSServerName(reader *bufio.Reader) (string, error)

func PrepareRegexp

func PrepareRegexp(rule string) (*regexp.Regexp, error)

func ProxyDial

func ProxyDial(proxyURL string, addr string, timeout time.Duration) (net.Conn, error)

func RandAsciiString

func RandAsciiString(n int) string

func RandBetween

func RandBetween(min, max int) int

func ReadWithoutComment

func ReadWithoutComment(file string, commentPrefix string) ([]byte, error)

func Socks5ProxyConnect

func Socks5ProxyConnect(proxyURL *url.URL, conn net.Conn, addr string) error

func Socks5ProxyDial

func Socks5ProxyDial(proxyURL string, addr string, timeout time.Duration) (net.Conn, error)

func ToBytes

func ToBytes(s string) (uint64, error)

ToBytes parses a string formatted by ByteSize as bytes.

func ToMegabytes

func ToMegabytes(s string) (uint64, error)

ToMegabytes parses a string formatted by ByteSize as megabytes.

func WildcardMatch

func WildcardMatch(text string, pattern string) bool

Types

type BufferChunkReader

type BufferChunkReader struct {
	io.Reader
	Err error
}

func (*BufferChunkReader) Read

func (r *BufferChunkReader) Read(p []byte) (int, error)

type DebugReader

type DebugReader struct {
	io.Reader
	Buf bytes.Buffer
}

func (*DebugReader) Read

func (r *DebugReader) Read(p []byte) (int, error)

type TimeoutReadWriteCloser

type TimeoutReadWriteCloser struct {
	io.ReadWriteCloser
	// contains filtered or unexported fields
}

func (*TimeoutReadWriteCloser) Read

func (s *TimeoutReadWriteCloser) Read(p []byte) (n int, err error)

func (*TimeoutReadWriteCloser) SetReadDeadline

func (s *TimeoutReadWriteCloser) SetReadDeadline(t time.Time) error

func (*TimeoutReadWriteCloser) SetWriteDeadline

func (s *TimeoutReadWriteCloser) SetWriteDeadline(t time.Time) error

func (*TimeoutReadWriteCloser) Write

func (s *TimeoutReadWriteCloser) Write(p []byte) (n int, err error)