tool

package

Go to main page

Versions in this module

v1

v1.3.8

Jul 15, 2023

Changes in this version

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

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

+ func WriteCMsgNotKeyJson(cMsg ConnMsg) (b []byte, err 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)

type OdjClientInfo

+ Anonymity bool

v1.3.7

Jun 9, 2023

Changes in this version

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

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

+ type CtxCloser struct

+ 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()

v1.3.6

Jun 7, 2023

Changes in this version

+ const P2PUdpA1

+ const P2PUdpO

+ const P2PUdpQ1

+ type OdjUP2PKId struct

+ Id string

+ type OdjUP2PKName struct

+ Name string

+ type OdjUP2PReq struct

+ Addr *net.UDPAddr

+ Id string

+ SrcName string

+ type OdjUP2PResp struct

+ Addr *net.UDPAddr

+ Info *SubInfo

type SubInfo

+ ULocalIntranetAddr *net.UDPAddr

+ ULocalPublicAddr *net.UDPAddr

+ URemoteIntranetAddr *net.UDPAddr

+ URemotePublicAddr *net.UDPAddr

v1.3.5

May 26, 2023

Changes in this version

+ const ConnVPNA1

+ const ConnVPNA2

+ const ConnVPNQ1

+ const ConnVPNQ2

+ const CopyConnTypeTCP

+ const CopyConnTypeUDP

+ const HttpVPNFA1

+ const HttpVPNFA2

+ const HttpVPNFQ1

+ const HttpVPNFQ2

+ const LinkConnTypeTCP

+ const LinkConnTypeUDP

+ var ErrCheckBadAny = func(a ...any) error

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

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

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

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

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

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

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

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

+ type CloseWaiter struct

+ func NewCloseWaiter() *CloseWaiter

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

+ func (cw *CloseWaiter) Close(err error)

+ func (cw *CloseWaiter) Wait() error

+ type LinkBox struct

+ 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 func(reader *bufio.Reader) ([][]byte, error)

+ type OdjErrMsg struct

+ ErrMsg string

+ func NewErrMsg(pre string, err error) OdjErrMsg

+ type OdjVPNLinkAddr struct

+ Addr string

+ AddrInfo *VpnInfo

+ ConnType string

+ type VpnInfo struct

+ CopyConnType string

+ CopyLocalAddrTcp *net.TCPAddr

+ CopyLocalAddrUdp *net.UDPAddr

+ CopyRemoteAddrTcp *net.TCPAddr

+ CopyRemoteAddrUdp *net.UDPAddr

+ LinkConnType string

+ LinkLocalAddrTcp *net.TCPAddr

+ LinkLocalAddrUdp *net.UDPAddr

+ LinkRemoteAddrTcp *net.TCPAddr

+ LinkRemoteAddrUdp *net.UDPAddr

v1.3.5-beta.2

May 9, 2023

v1.3.5-beta.1

Apr 2, 2023

v1.3.4

Mar 28, 2023

v1.3.3

Mar 25, 2023

Changes in this version

+ const SubOpenTypeDefault

+ const SubOpenTypeTCPP2P

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

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

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

type ConnMsg

+ func (cMsg *ConnMsg) MustUnmarshal(out any)

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

+ type OdjSubOpenReq struct

+ OdjName string

+ Type string

+ type OdjSubOpenResp struct

+ Tid string

+ Type string

+ type OdjSubReq struct

+ Addr *net.TCPAddr

+ DstKey string

+ Id string

+ SrcName string

+ type SubInfo struct

+ LocalIntranetAddr *net.TCPAddr

+ LocalName string

+ LocalPublicAddr *net.TCPAddr

+ RemoteIntranetAddr *net.TCPAddr

+ RemoteName string

+ RemotePublicAddr *net.TCPAddr

type TaskCbContext

+ func (tc *TaskCbContext) Close()

v1.3.2

Mar 12, 2023

v1.3.1

Mar 12, 2023

Changes in this version

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

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

type ConnMsg

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

+ type TaskCb struct

+ 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 struct

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

+ 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

v1.3.0

Mar 5, 2023

Changes in this version

+ const P2PTCpFailed

+ const P2PTCpSucceed

+ const P2PTcpA1

+ const P2PTcpA2

+ const P2PTcpA3

+ const P2PTcpQ1

+ const P2PTcpQ2

+ const P2PTcpQ3

+ const P2PTcpReset

+ const P2PTcpStart

+ const SpeedA0

+ const SpeedA1

+ const SpeedA2

+ const SpeedA3

+ const SpeedQ0

+ const SpeedQ1

+ const SpeedQ2

+ const SpeedQ3

+ 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 ErrConnIsNil = errors.New("conn is nil")

+ 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 ErrHandshakeIsDad = errors.New("handshake is bad")

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

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

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

+ var ErrOpenSubBoxBadAny = func(a ...any) error

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

+ 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 ErrReadCMsgWaitPack = errors.New("wait pack")

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

+ var ErrReadCSkipToFastConn = errors.New("skip to fastConn")

+ var ErrReqBadAny = func(a ...any) error

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

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

+ var ErrTimeout = errors.New("timeout")

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

type Key

+ 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)

+ type NetworkSpeedTicker struct

+ Download *SpeedTicker

+ Upload *SpeedTicker

+ func NewNetworkSpeedTicker() NetworkSpeedTicker

+ func (n *NetworkSpeedTicker) ToView() NetworkSpeedView

+ type NetworkSpeedView struct

+ DownloadSpeed int

+ DownloadSpeedShow string

+ UploadSpeed int

+ UploadSpeedShow string

+ func CountAllNetworkSpeedView(list ...NetworkSpeedView) NetworkSpeedView

+ type OdjP2P struct

+ Addr string

+ Status string

+ type SpeedTicker struct

+ func (st *SpeedTicker) Get() int

+ func (st *SpeedTicker) Set(i int)

v1.2.1

Dec 17, 2022

Changes in this version

+ func MustBase64ToBytes(str string) []byte

+ type MashBytes struct

+ Data string

+ func MustBytesToBase64(b []byte) MashBytes

v1.2.0

Dec 17, 2022

Changes in this version

+ const BufferSize

v1.1.1

Dec 12, 2022

v1.1.0

Dec 9, 2022

Changes in this version

+ type CFCHookConfig struct

+ Ct struct{ ... }

+ Tcp struct{ ... }

+ func GetCFCHookConfig(path string) *CFCHookConfig

v1.0.1

Dec 2, 2022

Changes in this version

+ const DelayA

+ const DelayQ

+ const HandshakeCheckStepA1

+ const HandshakeCheckStepA2

+ const HandshakeCheckStepQ1

+ const HandshakeCheckStepQ2

+ const PingMsg

+ const PongMsg

+ const SOpenA

+ const SOpenQ

+ const TaskA

+ const TaskQ

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

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

+ func GetConnBs(reader *bufio.Reader) (b []byte, err error)

+ func MustMarshal(body interface{}) []byte

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

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

+ func NewId(n int) (str string)

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

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

+ type ConnMsg struct

+ Code int

+ Data interface{}

+ Header string

+ Id string

+ type Key struct

+ 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) GetMsg(reader *bufio.Reader) (c ConnMsg, err error)

+ func (k *Key) GetMsgV2(reader *bufio.Reader) (b []byte, err error)

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

+ type OdjAddr struct

+ Addr string

+ Id string

+ type OdjClientInfo struct

+ Name string

+ type OdjIdList struct

+ IdList []string

+ type OdjInfo struct

+ Id string

+ Password string

+ User string

+ type OdjMsg struct

+ Msg string

+ type OdjPing struct

+ Active bool

+ Name string

+ Ping Ping

+ type OdjSub struct

+ DstKey string

+ SrcName string

+ type Ping struct

+ Ping time.Duration

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL