util

Documentation

Index

• Variables
• func ConvertTLSConfigToDTLSConfig(tlsConfig *tls.Config) *dtls.Config
• 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)
• type BaseHandler
  • func NewBaseHandler(mu *sync.RWMutex) *BaseHandler
  • func (h *BaseHandler) SendMsg(msg *arhatgopb.Msg) error
  • func (h *BaseHandler) SetMsgSendFunc(sendMsg types.MsgSendFunc)
• type StreamManager
  • 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)

Variables

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

Functions

func ConvertTLSConfigToDTLSConfig

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

func GetBytesBuf

func GetBytesBuf(size int) []byte

func GetMsgType

func GetMsgType(m interface{}) arhatgopb.MsgType

func NewCmd

func NewCmd(
	marshal types.MarshalFunc,
	kind arhatgopb.CmdType,
	id, seq uint64, body interface{},
) (*arhatgopb.Cmd, error)

func NewMsg

func NewMsg(
	marshal types.MarshalFunc,
	kind arhatgopb.MsgType,
	id, ack uint64, body interface{},
) (*arhatgopb.Msg, error)

func PutBytesBuf

func PutBytesBuf(b *[]byte)

Types

type BaseHandler

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

func NewBaseHandler

func NewBaseHandler(mu *sync.RWMutex) *BaseHandler

func (*BaseHandler) SendMsg

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

func (*BaseHandler) SetMsgSendFunc

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

type StreamManager

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

func NewStreamManager

func NewStreamManager() *StreamManager

func (*StreamManager) Add

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

func (*StreamManager) Del

func (m *StreamManager) Del(sid uint64)

func (*StreamManager) Resize

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

func (*StreamManager) Write

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