extutil

Documentation

Index

• Variables
• type BaseHandler
  • func NewBaseHandler() *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)) (err error)
  • func (m *StreamManager) Del(sid uint64)
  • func (m *StreamManager) Has(sid uint64) (exists bool)
  • func (m *StreamManager) Resize(sid uint64, cols, rows uint32)
  • func (m *StreamManager) Write(sid, seq uint64, data []byte) bool

Variables

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

Types

type BaseHandler

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

func NewBaseHandler

func NewBaseHandler() *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)) (err error)

func (*StreamManager) Del

func (m *StreamManager) Del(sid uint64)

func (*StreamManager) Has

func (m *StreamManager) Has(sid uint64) (exists bool)

func (*StreamManager) Resize

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

func (*StreamManager) Write

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