util

Nov 8, 2020

Changes in this version

+ var ErrMsgSendFuncNotSet = errors.New("message send func not set")

+ type BaseHandler struct

+ func NewBaseHandler(mu *sync.RWMutex) *BaseHandler

+ func (h *BaseHandler) SendMsg(msg *arhatgopb.Msg) error

+ func (h *BaseHandler) SetMsgSendFunc(sendMsg types.MsgSendFunc)

+ type StreamManager struct

+ func NewStreamManager() *StreamManager

+ func (m *StreamManager) Add(sid uint64, create func() (io.WriteCloser, types.ResizeHandleFunc, error)) error

+ func (m *StreamManager) Del(sid uint64)

+ func (m *StreamManager) Resize(sid uint64, cols, rows uint32)

+ func (m *StreamManager) Write(sid, seq uint64, data []byte)

Nov 2, 2020

Changes in this version

+ func GetBytesBuf(size int) []byte

+ func GetMsgType(m interface{}) arhatgopb.MsgType

+ func NewCmd(marshal types.MarshalFunc, kind arhatgopb.CmdType, id, seq uint64, ...) (*arhatgopb.Cmd, error)

+ func NewMsg(marshal types.MarshalFunc, kind arhatgopb.MsgType, id, ack uint64, ...) (*arhatgopb.Msg, error)

+ func PutBytesBuf(b *([]byte))

Nov 1, 2020

Changes in this version

+ func ConvertTLSConfigToDTLSConfig(tlsConfig *tls.Config) *dtls.Config