Documentation ¶
Index ¶
- Constants
- Variables
- func BinaryWrite(raw *bytes.Buffer, v ...string)
- func BytesToNum(b []byte) int
- func ChangeHostAndHeader(r *http.Request, host string, header string, addr string, addOrigin bool)
- func CheckAuth(r *http.Request, user, passwd string) bool
- func CopyBuffer(dst io.Writer, src io.Reader, label ...string) (written int64, err error)
- func DomainCheck(domain string) bool
- func FileExists(name string) bool
- func FormatAddress(s string) string
- func GeSynctMapLen(m sync.Map) int
- func GetAppPath() string
- func GetBoolByStr(s string) bool
- func GetBufPoolCopy() []byte
- func GetConfigPath() string
- func GetEnvMap() map[string]string
- func GetExtFromPath(path string) string
- func GetExternalIp() string
- func GetHostByName(hostname string) string
- func GetInstallPath() string
- func GetIntNoErrByStr(str string) int
- func GetIntranetIp() (error, string)
- func GetIpByAddr(addr string) string
- func GetLocalUdpAddr() (net.Conn, error)
- func GetLogMsg() string
- func GetLogPath() string
- func GetNpcLogPath() string
- func GetPortByAddr(addr string) int
- func GetPorts(p string) []int
- func GetRunPath() string
- func GetServerIpByClientIp(clientIp net.IP) string
- func GetStrByBool(b bool) string
- func GetTmpPath() string
- func GetWriteStr(v ...string) []byte
- func Getverifyval(vkey string) string
- func InIntArr(arr []int, val int) bool
- func InStrArr(arr []string, val string) bool
- func InitPProfFromArg(arg string)
- func InitPProfFromFile()
- func IsArrContains(arr []string, val string) bool
- func IsPort(p string) bool
- func IsPublicIP(IP net.IP) bool
- func IsWindows() bool
- func ParseStr(str string) (string, error)
- func PrintVersion()
- func PutBufPoolCopy(buf []byte)
- func PutBufPoolMax(buf []byte)
- func PutBufPoolUdp(buf []byte)
- func ReadAllFromFile(filePath string) ([]byte, error)
- func RemoveArrVal(arr []string, val string) []string
- func TestTcpPort(port int) bool
- func TestUdpPort(port int) bool
- func TrimArr(arr []string) []string
- type Addr
- type NetPackager
- type StoreMsg
- type UDPDatagram
- type UDPHeader
Constants ¶
const ( CONN_DATA_SEQ = "*#*" //Separator VERIFY_EER = "vkey" VERIFY_SUCCESS = "sucs" WORK_MAIN = "main" WORK_CHAN = "chan" WORK_CONFIG = "conf" WORK_REGISTER = "rgst" WORK_SECRET = "sert" WORK_FILE = "file" WORK_P2P = "p2pm" WORK_P2P_VISITOR = "p2pv" WORK_P2P_PROVIDER = "p2pp" WORK_P2P_CONNECT = "p2pc" WORK_P2P_SUCCESS = "p2ps" WORK_P2P_END = "p2pe" WORK_P2P_LAST = "p2pl" WORK_STATUS = "stus" RES_MSG = "msg0" RES_CLOSE = "clse" NEW_UDP_CONN = "udpc" //p2p udp conn NEW_TASK = "task" NEW_CONF = "conf" NEW_HOST = "host" CONN_TCP = "tcp" CONN_UDP = "udp" CONN_TEST = "TST" Content-Type: text/plain; charset=utf-8 WWW-Authenticate: Basic realm="easyProxy" 401 Unauthorized` ConnectionFailBytes = `HTTP/1.1 404 Not Found ` )
const MaxMsgLen = 5000
const PoolSize = 64 * 1024
const PoolSizeCopy = 32 << 10
const PoolSizeSmall = 100
const PoolSizeUdp = 1472 + 200
Variables ¶
var BufPoolCopy = sync.Pool{ New: func() interface{} { return make([]byte, PoolSizeCopy) }, }
var BufPoolMax = sync.Pool{ New: func() interface{} { return make([]byte, PoolSize) }, }
var BufPoolSmall = sync.Pool{ New: func() interface{} { return make([]byte, PoolSizeSmall) }, }
var BufPoolUdp = sync.Pool{ New: func() interface{} { return make([]byte, PoolSizeUdp) }, }
var CopyBuff = copyBufferPool{}
Functions ¶
func BinaryWrite ¶
Write length and individual byte data Length prevents sticking # Characters are used to separate data
func ChangeHostAndHeader ¶
Change headers and host of request
func CopyBuffer ¶ added in v0.0.16
func FileExists ¶
FileExists reports whether the named file or directory exists.
func FormatAddress ¶ added in v0.0.15
if the s is just a port,return 127.0.0.1:s
func GeSynctMapLen ¶ added in v0.21.0
get the length of the sync map
func GetBufPoolCopy ¶ added in v0.26.0
func GetBufPoolCopy() []byte
func GetExtFromPath ¶ added in v0.22.0
func GetExternalIp ¶ added in v0.26.0
func GetExternalIp() string
func GetHostByName ¶
Get the corresponding IP address through domain name
func GetInstallPath ¶
func GetInstallPath() string
Different systems get different installation paths
func GetIntranetIp ¶ added in v0.26.0
func GetIpByAddr ¶ added in v0.0.15
get address from the complete address
func GetLocalUdpAddr ¶ added in v0.18.0
send this ip forget to get a local udp port
func GetPortByAddr ¶ added in v0.23.0
get port from the complete address
func GetRunPath ¶
func GetRunPath() string
Get the currently selected configuration file directory For non-Windows systems, select the /etc/nps as config directory if exist, or select ./ windows system, select the C:\Program Files\nps as config directory if exist, or select ./
func GetServerIpByClientIp ¶ added in v0.26.0
func InitPProfFromArg ¶ added in v0.26.2
func InitPProfFromArg(arg string)
func InitPProfFromFile ¶ added in v0.26.2
func InitPProfFromFile()
func IsArrContains ¶ added in v0.18.1
func IsPublicIP ¶ added in v0.26.0
func PrintVersion ¶ added in v0.26.5
func PrintVersion()
func PutBufPoolCopy ¶ added in v0.26.0
func PutBufPoolCopy(buf []byte)
func PutBufPoolMax ¶ added in v0.26.0
func PutBufPoolMax(buf []byte)
func PutBufPoolUdp ¶ added in v0.26.0
func PutBufPoolUdp(buf []byte)
func ReadAllFromFile ¶
Read file content by file path
func RemoveArrVal ¶ added in v0.18.1
remove value from string array
Types ¶
type Addr ¶ added in v0.26.0
func ToSocksAddr ¶ added in v0.26.0
type NetPackager ¶ added in v0.26.0
type UDPDatagram ¶ added in v0.26.0
func NewUDPDatagram ¶ added in v0.26.0
func NewUDPDatagram(header *UDPHeader, data []byte) *UDPDatagram
func ReadUDPDatagram ¶ added in v0.26.0
func ReadUDPDatagram(r io.Reader) (*UDPDatagram, error)