worker

Jan 22, 2021

Changes in this version

+ const BUFFER_SIZE

+ const CONN_TYPE_CLIENT

+ const CONN_TYPE_INIT

+ const CONN_TYPE_SERVER

+ const CONN_TYPE_WORKER

+ const DEFAULT_TIME_OUT

+ const JOB_STATUS_DOING

+ const JOB_STATUS_DONE

+ const JOB_STATUS_INIT

+ const MIN_DATA_SIZE

+ const PARAMS_TYPE_MUL

+ const PARAMS_TYPE_ONE

+ const PDT_CANT_DO

+ const PDT_CAN_DO

+ const PDT_C_DO_JOB

+ const PDT_C_GET_DATA

+ const PDT_ERROR

+ const PDT_HAVE_JOB

+ const PDT_NO_JOB

+ const PDT_OK

+ const PDT_S_GET_DATA

+ const PDT_S_RETURN_DATA

+ const PDT_TOSLEEP

+ const PDT_WAKEUP

+ const PDT_WAKEUPED

+ const PDT_W_ADD_FUNC

+ const PDT_W_DEL_FUNC

+ const PDT_W_GRAB_JOB

+ const PDT_W_RETURN_DATA

+ const QUEUE_SIZE

+ const UINT32_SIZE

+ var RESTIMEOUT = errors.New("RESTIMEOUT")

+ func GetBuffer(n int) (buf []byte)

+ func GetConnType(data []byte) (connType uint32)

+ type Client struct

+ ErrHandler ErrHandler

+ Req *Request

+ ResQueue chan *Response

+ RespHandlers *RespHandlerMap

+ Timeout time.Duration

+ func NewClient(network, addr string) (client *Client, err error)

+ func (c *Client) ClientRead()

+ func (c *Client) Close()

+ func (c *Client) Do(funcName string, params []byte, callback RespHandler) (err error)

+ func (c *Client) HandlerResp(resp *Response)

+ func (c *Client) ProcessResp()

+ func (c *Client) Read(length int) (data []byte, err error)

+ func (c *Client) Write() (err error)

+ type ErrHandler func(err error)

+ type Request struct

+ Data []byte

+ DataLen uint32

+ DataType uint32

+ Handle string

+ HandleLen uint32

+ Params []byte

+ ParamsLen uint32

+ ParamsType uint32

+ Ret []byte

+ RetLen uint32

+ func NewReq() (req *Request)

+ func (req *Request) ContentPack(dataType uint32, handle string, params []byte) (content []byte, contentLen uint32)

+ func (req *Request) EncodePack() (data []byte)

+ type RespHandler func(resp *Response)

+ type RespHandlerMap struct

+ func NewResHandlerMap() *RespHandlerMap

+ func (rhm *RespHandlerMap) DelResHandlerMap(key string)

+ func (rhm *RespHandlerMap) GetResHandlerMap(key string) (handler RespHandler, exist bool)

+ func (rhm *RespHandlerMap) PutResHandlerMap(key string, handler RespHandler)

+ type Response struct

+ Data []byte

+ DataLen uint32

+ DataType uint32

+ Handle string

+ HandleLen uint32

+ Params []byte

+ ParamsLen uint32

+ ParamsType uint32

+ Ret []byte

+ RetLen uint32

+ func DecodePack(data []byte) (resp *Response, resLen int, err error)

+ func NewRes() (res *Response)

+ func (resp *Response) GetResError() (err error)

+ func (resp *Response) GetResResult() (data []byte, err error)

+ type RetStruct struct

+ Code int

+ Data []byte

+ Msg string

+ func GetRetStruct() *RetStruct