tool

Documentation

Index

• Constants
• Variables
• func Decrypt(ciphertext []byte, key []byte) ([]byte, error)
• func Encrypt(plaintext []byte, key []byte) ([]byte, error)
• func ErrAppend(err error, errs ...error) error
• func MustBase64ToBytes(str string) []byte
• func MustMarshal(body interface{}) []byte
• func MustResolveTCPAddr(addr net.Addr) *net.TCPAddr
• func MustUnmarshal(b []byte, body interface{})
• func MustUnmarshalV2(inBody interface{}, outBody interface{})
• func MustWriteCMsgNotKeyJson(cMsg ConnMsg) (b []byte)
• func NewId(n int) (str string)
• func Println(conn net.Conn, i ...any)
• func ReRun(rt string, fn func() bool) error
• func UnmarshalV2(inBody interface{}, outBody interface{}) error
• func WriteCMsgNotKeyJson(cMsg ConnMsg) (b []byte, err error)
• type CloseWaiter
  • func NewCloseWaiter() *CloseWaiter
  • func (cw *CloseWaiter) AddCloseFn(fn func())
  • func (cw *CloseWaiter) Close(err error)
  • func (cw *CloseWaiter) Wait() error
• type ConnMsg
  • func MustReadCMsgNotKeyJson(b []byte) (cMsg ConnMsg)
  • func MustReadCMsgNotKeyJson2(reader io.Reader) (cMsg ConnMsg)
  • func ReadCMsgNotKeyJson(b []byte) (cMsg ConnMsg, err error)
  • func ReadCMsgNotKeyJson2(reader io.Reader) (cMsg ConnMsg, err error)
  • func (cMsg *ConnMsg) CheckConnMsgHeaderAndCode(header string, code int) error
  • func (cMsg *ConnMsg) MustUnmarshal(out any)
  • func (cMsg *ConnMsg) Unmarshal(out any) error
• type CtxCloser
  • func NewCtxCloser(ctx context.Context) *CtxCloser
  • func (cc *CtxCloser) AddCloseFn(fn func())
  • func (cc *CtxCloser) Chan() <-chan struct{}
  • func (cc *CtxCloser) CheckDone() bool
  • func (cc *CtxCloser) Close()
• type Key
  • func NewKey(key string) Key
  • func (k *Key) Decode(i interface{}, data []byte) error
  • func (k *Key) Encode(i interface{}) (b [][]byte)
  • func (k *Key) GetRawKey() string
  • func (k *Key) ReadCMsg(reader *bufio.Reader, skip *atomic.Bool, speed *SpeedTicker) (cMsg ConnMsg, err error)
  • func (k *Key) ReadCPacket(reader *bufio.Reader, skip *atomic.Bool) (b []byte, err error)
  • func (k *Key) SetMsg(header, id string, code int, data interface{}) [][]byte
• type LinkBox
  • func NewLinkBox(rw io.ReadWriter, readrSize int, readFn LinkBoxRWFn, writeFn LinkBoxRWFn) *LinkBox
  • func (lb *LinkBox) ReadLinkBoxToWriter(writer io.Writer, lock *sync.Mutex) error
  • func (lb *LinkBox) WriteLinkBoxFromReader(reader *bufio.Reader) error
• type LinkBoxRWFn
• type MashBytes
  • func MustBytesToBase64(b []byte) MashBytes
• type NetworkSpeedTicker
  • func NewNetworkSpeedTicker() NetworkSpeedTicker
  • func (n *NetworkSpeedTicker) ToView() NetworkSpeedView
• type NetworkSpeedView
  • func CountAllNetworkSpeedView(list ...NetworkSpeedView) NetworkSpeedView
• type OdjClientInfo
• type OdjErrMsg
  • func NewErrMsg(pre string, err error) OdjErrMsg
• type OdjIdList
• type OdjMsg
• type OdjPing
• type OdjSubOpenReq
• type OdjSubOpenResp
• type OdjSubReq
• type OdjUP2PKId
• type OdjUP2PKName
• type OdjUP2PReq
• type OdjUP2PResp
• type OdjVPNLinkAddr
• type Ping
• type SpeedTicker
  • func (st *SpeedTicker) Get() int
  • func (st *SpeedTicker) Set(i int)
• type SubInfo
• type TaskCb
  • func (task *TaskCb) KeepWaitCb(timeout time.Duration, cb func(cMsg ConnMsg) error) (err error)
  • func (task *TaskCb) NowaitCb(cb func(cMsg ConnMsg) error) error
  • func (task *TaskCb) OverTask(err error)
  • func (task *TaskCb) SetKeep(keep bool) *TaskCb
  • func (task *TaskCb) WaitCb(timeout time.Duration, cb func(cMsg ConnMsg) error) (err error)
• type TaskCbContext
  • func NewTaskContext(rw io.ReadWriter, key Key) *TaskCbContext
  • func (tc *TaskCbContext) Close()
  • func (tc *TaskCbContext) NewTaskCb(id string, fn func() error) *TaskCb
  • func (tc *TaskCbContext) NewTaskCbCMsg(header string, code int, data interface{}) *TaskCb
  • func (tc *TaskCbContext) NewTaskCbCMsgNeedId(header string, id string, code int, data interface{}) *TaskCb
  • func (tc *TaskCbContext) ReadCMsg() error
  • func (tc *TaskCbContext) SetNoCb(fn func(cMsg ConnMsg))
  • func (tc *TaskCbContext) SetWriteLock(lock *sync.Mutex)
  • func (tc *TaskCbContext) WriteCMsg(header string, id string, code int, data interface{}) error
• type VpnInfo

Constants

const (
	P2PTcpReset   = "P2PTcpReset"
	P2PTcpStart   = "P2PTcpStart"
	P2PTCpSucceed = "P2PTCpSucceed"
	P2PTCpFailed  = "P2PTCpSucceed"
)

const (
	SubOpenTypeDefault = "SubOpenTypeDefault"
	SubOpenTypeTCPP2P  = "SubOpenTypeTCPP2P"
)

const (
	LinkConnTypeTCP = "LinkConnTypeTCP"
	LinkConnTypeUDP = "LinkConnTypeUDP"
	CopyConnTypeTCP = "CopyConnTypeTCP"
	CopyConnTypeUDP = "LinkConnTypeUDP"
)

const (
	BufferSize = 4096
)

bytes size = 4096 data len 4004=4096-8-60-8-16

const ConnVPNA1 = "ConnVPNA1"

const ConnVPNA2 = "ConnVPNA2"

const ConnVPNQ1 = "ConnVPNQ1"

const ConnVPNQ2 = "ConnVPNQ2"

const DelayA = "DelayA"

const DelayQ = "DelayQ"

const HandshakeCheckStepA1 = "Hi! What's your Info?"

const HandshakeCheckStepA2 = "OK! Happy handshake"

const HandshakeCheckStepQ1 = "Hello! I want to shake hands."

const HandshakeCheckStepQ2 = "Here it is"

const HttpVPNFA1 = "HttpVPNFA1"

const HttpVPNFA2 = "HttpVPNFA2"

const HttpVPNFQ1 = "HttpVPNFQ1"

const HttpVPNFQ2 = "HttpVPNFQ2"

const P2PTcpA1 = "P2PTcpA1"

const P2PTcpA2 = "P2PTcpA2"

const P2PTcpA3 = "P2PTcpA3"

const P2PTcpQ1 = "P2PTcpQ1"

const P2PTcpQ2 = "P2PTcpQ2"

const P2PTcpQ3 = "P2PTcpQ3"

const P2PUdpA1 = "P2PUdpA1"

const P2PUdpO = "P2PUdpO"

const P2PUdpQ1 = "P2PUdpQ1"

const PingMsg = "Ping"

const PongMsg = "Pong"

const SOpenA = "sOpenA"

const SOpenQ = "sOpenQ"

const SpeedA0 = "SpeedA0"

const SpeedA1 = "SpeedA1"

const SpeedA2 = "SpeedA2"

const SpeedA3 = "SpeedA3"

const SpeedQ0 = "SpeedQ0" //server all network speed

const SpeedQ1 = "SpeedQ1" //some client network speed

const SpeedQ2 = "SpeedQ2" //one client and sub client network speed

const SpeedQ3 = "SpeedQ3" //only one client network speed

const TaskA = "TaskA"

const TaskQ = "TaskQ"

Variables

var ErrBoxComplexListen = errors.New("box complex listen")

var ErrBoxIsClosed = errors.New("box is closed")

var ErrBoxIsNil = errors.New("box is nil")

var ErrBoxStopListen = errors.New("box stop listen")

var ErrCheckBadAny = func(a ...any) error { return fmt.Errorf("check err: %v", a) }

var ErrCheckUnexpectedHeader = errors.New("check err:  unexpected header")

var ErrConnIsNil = errors.New("conn is nil")

var ErrDataException = errors.New("data exception")

var ErrHandleCMsgMissProxyClient = errors.New("not Not found proxy client")

var ErrHandleCMsgMissProxyTaskRoom = errors.New("not Not found proxy task room ")

var ErrHandleCMsgProxyClientNameIsNil = errors.New("need one proxy client name to register")

var ErrHandshakeIsBad = errors.New("handshake is bad")

var ErrIsDisable = errors.New("is disable")

var ErrKeyIsNot32Bytes = errors.New("key is not 32bytes")

var ErrLinkClientIsClosed = errors.New("link client is closed")

var ErrMethodIsRefused = errors.New("the method is refused")

var ErrNameIsNil = errors.New("name is nil")

var ErrOpenSubBoxBadAny = func(a ...any) error { return fmt.Errorf("open sub box bad : %v", a) }

var ErrOpenSubUnexpectedOdj = errors.New("unexpected resp Odj")

var ErrProxyClientIsClosed = errors.New("the proxy client is closed")

var ErrReadCMsgHashCheckFailed = errors.New("hash check failed")

var ErrReadCMsgLensTooLong = fmt.Errorf("lens: too long to %v bytes", BufferSize)

var ErrReadCMsgLensTooShort = fmt.Errorf("lens: too small to %v  bytes", getHeaderSize())

var ErrReadCProtocolIsNotGoCFC = errors.New("the protocol is not go-CFC : is not " + version)

var ErrReadCSkipToFastConn = errors.New("skip to LinkConn")

var ErrReqBadAny = func(a ...any) error { return fmt.Errorf("req bad : %v", a) }

var ErrReqUnexpectedHeader = errors.New("unexpected resp header")

var ErrSubDstKeyIsNil = errors.New("sub dst key is nil")

var ErrSubIsDisable = errors.New("sub box is disable")

var ErrSubLocalAddrIsNil = errors.New("sub local addr is nil")

var ErrSubTypeInvalid = errors.New("sub type invalid")

var ErrSubTypeToMixGetSubBoxFailed = errors.New("sub type to mix get sub box failed")

var ErrTimeout = errors.New("timeout")

var ErrUnexpectedLinkConnType = errors.New("unexpected link conn type")

var ErrUnexpectedSubOpenType = errors.New("unexpected sub open type")

var TaskCbIdIsNeed = errors.New("task cb id is nil")

var TaskSkipErr = errors.New("task skip err")

Functions

func Decrypt

func Decrypt(ciphertext []byte, key []byte) ([]byte, error)

func Encrypt

func Encrypt(plaintext []byte, key []byte) ([]byte, error)

func ErrAppend

func ErrAppend(err error, errs ...error) error

func MustBase64ToBytes

func MustBase64ToBytes(str string) []byte

func MustMarshal

func MustMarshal(body interface{}) []byte

func MustResolveTCPAddr

func MustResolveTCPAddr(addr net.Addr) *net.TCPAddr

func MustUnmarshal

func MustUnmarshal(b []byte, body interface{})

func MustUnmarshalV2

func MustUnmarshalV2(inBody interface{}, outBody interface{})

func MustWriteCMsgNotKeyJson

func MustWriteCMsgNotKeyJson(cMsg ConnMsg) (b []byte)

func NewId

func NewId(n int) (str string)

func Println

func Println(conn net.Conn, i ...any)

func ReRun

func ReRun(rt string, fn func() bool) error

func UnmarshalV2

func UnmarshalV2(inBody interface{}, outBody interface{}) error

func WriteCMsgNotKeyJson

func WriteCMsgNotKeyJson(cMsg ConnMsg) (b []byte, err error)

Types

type CloseWaiter

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

func NewCloseWaiter

func NewCloseWaiter() *CloseWaiter

func (*CloseWaiter) AddCloseFn

func (cw *CloseWaiter) AddCloseFn(fn func())

func (*CloseWaiter) Close

func (cw *CloseWaiter) Close(err error)

func (*CloseWaiter) Wait

func (cw *CloseWaiter) Wait() error

type ConnMsg

type ConnMsg struct {
	Header string
	Code   int
	Data   interface{}
	Id     string
}

func MustReadCMsgNotKeyJson

func MustReadCMsgNotKeyJson(b []byte) (cMsg ConnMsg)

func MustReadCMsgNotKeyJson2

func MustReadCMsgNotKeyJson2(reader io.Reader) (cMsg ConnMsg)

func ReadCMsgNotKeyJson

func ReadCMsgNotKeyJson(b []byte) (cMsg ConnMsg, err error)

func ReadCMsgNotKeyJson2

func ReadCMsgNotKeyJson2(reader io.Reader) (cMsg ConnMsg, err error)

func (*ConnMsg) CheckConnMsgHeaderAndCode

func (cMsg *ConnMsg) CheckConnMsgHeaderAndCode(header string, code int) error

func (*ConnMsg) MustUnmarshal

func (cMsg *ConnMsg) MustUnmarshal(out any)

func (*ConnMsg) Unmarshal

func (cMsg *ConnMsg) Unmarshal(out any) error

type CtxCloser

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

func NewCtxCloser

func NewCtxCloser(ctx context.Context) *CtxCloser

func (*CtxCloser) AddCloseFn

func (cc *CtxCloser) AddCloseFn(fn func())

func (*CtxCloser) Chan

func (cc *CtxCloser) Chan() <-chan struct{}

func (*CtxCloser) CheckDone

func (cc *CtxCloser) CheckDone() bool

func (*CtxCloser) Close

func (cc *CtxCloser) Close()

type Key

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

func NewKey

func NewKey(key string) Key

func (*Key) Decode

func (k *Key) Decode(i interface{}, data []byte) error

func (*Key) Encode

func (k *Key) Encode(i interface{}) (b [][]byte)

func (*Key) GetRawKey

func (k *Key) GetRawKey() string

func (*Key) ReadCMsg

func (k *Key) ReadCMsg(reader *bufio.Reader, skip *atomic.Bool, speed *SpeedTicker) (cMsg ConnMsg, err error)

func (*Key) ReadCPacket

func (k *Key) ReadCPacket(reader *bufio.Reader, skip *atomic.Bool) (b []byte, err error)

func (*Key) SetMsg

func (k *Key) SetMsg(header, id string, code int, data interface{}) [][]byte

type LinkBox

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

func NewLinkBox

func NewLinkBox(rw io.ReadWriter, readrSize int, readFn LinkBoxRWFn, writeFn LinkBoxRWFn) *LinkBox

func (*LinkBox) ReadLinkBoxToWriter

func (lb *LinkBox) ReadLinkBoxToWriter(writer io.Writer, lock *sync.Mutex) error

ReadLinkBoxToWriter link -> other

func (*LinkBox) WriteLinkBoxFromReader

func (lb *LinkBox) WriteLinkBoxFromReader(reader *bufio.Reader) error

WriteLinkBoxFromReader link <- other

type LinkBoxRWFn

type LinkBoxRWFn func(reader *bufio.Reader) ([][]byte, error)

type MashBytes

type MashBytes struct {
	Data string `json:"go-CFC-Data"`
}

func MustBytesToBase64

func MustBytesToBase64(b []byte) MashBytes

type NetworkSpeedTicker

type NetworkSpeedTicker struct {
	Upload   *SpeedTicker
	Download *SpeedTicker
}

func NewNetworkSpeedTicker

func NewNetworkSpeedTicker() NetworkSpeedTicker

func (*NetworkSpeedTicker) ToView

func (n *NetworkSpeedTicker) ToView() NetworkSpeedView

type NetworkSpeedView

type NetworkSpeedView struct {
	UploadSpeed       int
	DownloadSpeed     int
	UploadSpeedShow   string
	DownloadSpeedShow string
}

func CountAllNetworkSpeedView

func CountAllNetworkSpeedView(list ...NetworkSpeedView) NetworkSpeedView

type OdjClientInfo

type OdjClientInfo struct {
	Name      string
	Anonymity bool
}

type OdjErrMsg

type OdjErrMsg struct {
	ErrMsg string
}

func NewErrMsg

func NewErrMsg(pre string, err error) OdjErrMsg

type OdjIdList

type OdjIdList struct {
	IdList []string
}

type OdjMsg

type OdjMsg struct {
	Msg string
}

type OdjPing

type OdjPing struct {
	Name   string
	Ping   Ping
	Active bool
}

type OdjSubOpenReq

type OdjSubOpenReq struct {
	Type    string
	OdjName string
}

type OdjSubOpenResp

type OdjSubOpenResp struct {
	Tid  string
	Type string
}

type OdjSubReq

type OdjSubReq struct {
	Id      string
	SrcName string
	DstKey  string
	Addr    *net.TCPAddr
}

type OdjUP2PKId

type OdjUP2PKId struct {
	Id string
}

type OdjUP2PKName

type OdjUP2PKName struct {
	Name string
}

type OdjUP2PReq

type OdjUP2PReq struct {
	Id      string
	SrcName string
	Addr    *net.UDPAddr
}

type OdjUP2PResp

type OdjUP2PResp struct {
	Addr *net.UDPAddr
	Info *SubInfo
}

type OdjVPNLinkAddr

type OdjVPNLinkAddr struct {
	ConnType string
	Addr     string

	AddrInfo *VpnInfo
}

type Ping

type Ping struct {
	Ping time.Duration
}

type SpeedTicker

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

func (*SpeedTicker) Get

func (st *SpeedTicker) Get() int

func (*SpeedTicker) Set

func (st *SpeedTicker) Set(i int)

type SubInfo

type SubInfo struct {
	LocalName  string
	RemoteName string

	LocalIntranetAddr  *net.TCPAddr
	RemoteIntranetAddr *net.TCPAddr

	ULocalIntranetAddr  *net.UDPAddr
	URemoteIntranetAddr *net.UDPAddr

	LocalPublicAddr  *net.TCPAddr
	RemotePublicAddr *net.TCPAddr

	ULocalPublicAddr  *net.UDPAddr
	URemotePublicAddr *net.UDPAddr
}

type TaskCb

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

func (*TaskCb) KeepWaitCb

func (task *TaskCb) KeepWaitCb(timeout time.Duration, cb func(cMsg ConnMsg) error) (err error)

func (*TaskCb) NowaitCb

func (task *TaskCb) NowaitCb(cb func(cMsg ConnMsg) error) error

func (*TaskCb) OverTask

func (task *TaskCb) OverTask(err error)

func (*TaskCb) SetKeep

func (task *TaskCb) SetKeep(keep bool) *TaskCb

func (*TaskCb) WaitCb

func (task *TaskCb) WaitCb(timeout time.Duration, cb func(cMsg ConnMsg) error) (err error)

type TaskCbContext

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

func NewTaskContext

func NewTaskContext(rw io.ReadWriter, key Key) *TaskCbContext

func (*TaskCbContext) Close

func (tc *TaskCbContext) Close()

func (*TaskCbContext) NewTaskCb

func (tc *TaskCbContext) NewTaskCb(id string, fn func() error) *TaskCb

func (*TaskCbContext) NewTaskCbCMsg

func (tc *TaskCbContext) NewTaskCbCMsg(header string, code int, data interface{}) *TaskCb

func (*TaskCbContext) NewTaskCbCMsgNeedId

func (tc *TaskCbContext) NewTaskCbCMsgNeedId(header string, id string, code int, data interface{}) *TaskCb

func (*TaskCbContext) ReadCMsg

func (tc *TaskCbContext) ReadCMsg() error

func (*TaskCbContext) SetNoCb

func (tc *TaskCbContext) SetNoCb(fn func(cMsg ConnMsg))

func (*TaskCbContext) SetWriteLock

func (tc *TaskCbContext) SetWriteLock(lock *sync.Mutex)

func (*TaskCbContext) WriteCMsg

func (tc *TaskCbContext) WriteCMsg(header string, id string, code int, data interface{}) error

type VpnInfo

type VpnInfo struct {
	LinkConnType      string
	LinkRemoteAddrTcp *net.TCPAddr
	LinkLocalAddrTcp  *net.TCPAddr
	LinkRemoteAddrUdp *net.UDPAddr
	LinkLocalAddrUdp  *net.UDPAddr
	CopyConnType      string
	CopyRemoteAddrTcp *net.TCPAddr
	CopyLocalAddrTcp  *net.TCPAddr
	CopyRemoteAddrUdp *net.UDPAddr
	CopyLocalAddrUdp  *net.UDPAddr
}