websocketService

package

v0.1.5 Latest Latest Go to latest Published: Jun 11, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Details

*

*

This section is empty.

This section is empty.

This section is empty.

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

func (u *Connection) Receive() error

Receive reads next message from user's underlying connection. It blocks until full message received.

type Group struct {
	Hanlder *Handler
	// contains filtered or unexported fields
}

func NewGroup(pool *gopool.Pool) *Group

func (c *Group) Register(conn net.Conn) *Connection

Register registers new connection as a User.

func (c *Group) Remove(user *Connection)

Remove removes user from chat.

func (c *Group) Rename(user *Connection, name string) (prev string, ok bool)

Rename renames user.

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

func (h *Handler) AddHandler(messageType uint16, fun RecvHandler)

func (h *Handler) Execute(data *MessageData) *MessageData

func (h *Handler) Init()

type MessageData struct {
	MessageType uint16
	Message     []byte
}

type RecvHandler func(message *MessageData) *MessageData

type WebSocketServer struct {
	service.Entity
	// contains filtered or unexported fields
}

func New() *WebSocketServer

func (webserv *WebSocketServer) AddHandler(messageType uint16, fun RecvHandler)

func (webserv *WebSocketServer) Start()

func (webserv *WebSocketServer) Stop()

Path	Synopsis
netpoll Package netpoll provides a portable interface for network I/O event notification facility.	Package netpoll provides a portable interface for network I/O event notification facility.