part

README

part

---

LICENSE

使用了以下项目，十分感谢

• golang under BSD
• github.com/thedevsaddam/gojsonq under MIT
• github.com/miekg/dns under LICENSE
• github.com/klauspost/compress under BSD 3-Clause
• github.com/andybalholm/brotli under MIT
• github.com/klauspost/pgzip under MIT
• github.com/skratchdot/open-golang/open under MIT
• github.com/gorilla/websocket under BSD 2-Clause

---

介绍

自己编写/收集的一些go组件，增加复用

buf map变量的save，load，get，set

get 爬虫

session 会话(超时)验证

msgq 消息队列

...

Documentation

Index

• Constants
• Variables
• func Checkfile() *checkfile
• func Exec() *lexec
• func File() *file
• func FileMove(src, trg string) error
• func Forward(targetaddr, listenaddr string, acceptCIDRs []string) (closef func(), msg_chan chan ForwardMsg)
• func Json() *json
• func Logf() *logl
• func MasterDomain(url_s string) (string, error)
• func Md5() *md5l
• func Net() *netl
• func NewUdpConn(per []byte, remoteAdd *net.UDPAddr, conn *net.UDPConn) *udpConn
• func NewUdpListener(network, listenaddr string, pkgSize ...int) (*udpLis, error)
• func RZip() *rZip
• func Rand() *random
• func Zip() *lzip
• type ConnPool
  • func NewConnPool(size int, genConn func() *net.Conn) *ConnPool
  • func (t *ConnPool) Get(id string) (i net.Conn, putBack func())
• type ConnPoolItem
• type Filel
  • func (t Filel) Write(b []byte) (int, error)
• type ForwardMsg

Constants

const (
	ErrorMsg = iota
	AcceptMsg
	DenyMsg
	LisnMsg
)

Variables

var (
	ErrDnsNoAnswer      = errors.New("ErrDnsNoAnswer")
	ErrNetworkNoSupport = errors.New("ErrNetworkNoSupport")
	ErrUdpOverflow      = errors.New("ErrUdpOverflow") // default:1500 set higher pkgSize at NewUdpListener
)

Functions

func Checkfile

func Checkfile() *checkfile

func Exec

func Exec() *lexec

func File

func File() *file

func FileMove

func FileMove(src, trg string) error

func Forward

func Forward(targetaddr, listenaddr string, acceptCIDRs []string) (closef func(), msg_chan chan ForwardMsg)

func Json

func Json() *json

func Logf

func Logf() *logl

func MasterDomain

func MasterDomain(url_s string) (string, error)

func Md5

func Md5() *md5l

func Net

func Net() *netl

func NewUdpConn

func NewUdpConn(per []byte, remoteAdd *net.UDPAddr, conn *net.UDPConn) *udpConn

func NewUdpListener

func NewUdpListener(network, listenaddr string, pkgSize ...int) (*udpLis, error)

func RZip

func RZip() *rZip

func Rand

func Rand() *random

func Zip

func Zip() *lzip

Types

type ConnPool

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

func NewConnPool

func NewConnPool(size int, genConn func() *net.Conn) *ConnPool

func (*ConnPool) Get

func (t *ConnPool) Get(id string) (i net.Conn, putBack func())

type ConnPoolItem

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

type Filel

type Filel struct {
	File    string //src
	Loc     int64  //WriteOrRead loc ;0:rewrite Or read all;-1 write on end
	ReadNum int64
	Context []interface{} //Write string

	// wrap with encoder/decoder
	//https://pkg.go.dev/golang.org/x/text/encoding
	WrapWriter func(io.Writer) io.Writer
	// contains filtered or unexported fields
}

func (Filel) Write

func (t Filel) Write(b []byte) (int, error)

func (t Filel) Read(b []byte)(int,error){return t.read(b)}

type ForwardMsg

type ForwardMsg struct {
	Type int
	Msg  interface{}
}

when Type is ErrorMsg, Msg is set to error when Type is AcceptMsg, Msg is set to net.Addr when Type is DenyMsg, Msg is set to net.Addr when Type is LisnMsg, Msg is set to net.Addr