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 NewId(n int) (str string)
• func Println(conn net.Conn, i ...any)
• func UnmarshalV2(inBody interface{}, outBody interface{}) error
• type ConnMsg
  • func (cMsg *ConnMsg) CheckConnMsgHeaderAndCode(header string, code int) error
  • func (cMsg *ConnMsg) MustUnmarshal(out any)
  • func (cMsg *ConnMsg) Unmarshal(out any) error
• 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 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 OdjIdList
• type OdjMsg
• type OdjPing
• type OdjSubOpenReq
• type OdjSubOpenResp
• type OdjSubReq
• 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

Constants

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

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

const (
	BufferSize = 4096
)

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

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 P2PTcpA1 = "P2PTcpA1"

const P2PTcpA2 = "P2PTcpA2"

const P2PTcpA3 = "P2PTcpA3"

const P2PTcpQ1 = "P2PTcpQ1"

const P2PTcpQ2 = "P2PTcpQ2"

const P2PTcpQ3 = "P2PTcpQ3"

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 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 { return fmt.Errorf("open sub box bad : %v", a) }

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 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 { return fmt.Errorf("req bad : %v", a) }

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

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

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

var ErrTimeout = errors.New("timeout")

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 NewId

func NewId(n int) (str string)

func Println

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

func UnmarshalV2

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

Types

type ConnMsg

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

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 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 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
}

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

	LocalPublicAddr  *net.TCPAddr
	RemotePublicAddr *net.TCPAddr
}

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