msg

package

v1.0.1 Latest Latest Go to latest Published: Nov 17, 2024 License: AGPL-3.0 Imports: 7 Imported by: 0

Details

Package msg is the middle layer of client websocket communication This package is used to standardize websocket message formats with clients

This section is empty.

View Source

var ErrMsgHandleNotExist = errors.New("msg handel not exist")

func ForReadAndHandleJsonMsg(reader Reader, conn *websocket.Conn) error

func ReadBytes(reader Reader, conn *websocket.Conn) ([]byte, error)

func ReadFile(reader Reader, conn *websocket.Conn) (io.Reader, error)

func RegisterHandle[T any](reader Reader, msgType MsgType, handler func(data T) error)

func Send[T any](conn *websocket.Conn, t MsgType, data T) error

func SendError(conn *websocket.Conn, err error) error

type Msg struct {
	Type MsgType
	Data any
}

type MsgHandler func([]byte) error

type MsgType string

type Reader interface {
	// contains filtered or unexported methods
}

func NewReader() Reader