socket

package

v0.5.2 Latest Latest Go to latest Published: Jun 14, 2021 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Connection struct {
	Ws   *websocket.Conn
	Send chan []byte
}

type Registry struct {
	Register   chan *Socket
	Unregister chan *Socket
	Sockets    *sync.Map
}

func BuildAndRunSocketRegistry(registerHandler, unregisterHandler func(s *Socket)) *Registry

type Socket struct {
	Ctx         context.Context
	ErrorLogger errorlogger.ErrorLogger
	Connection  *Connection
	ID          string
}

func (s *Socket) Emit(dto interface{})

func (s *Socket) ReadPump(registry *Registry, readMessageHandler func(rawData []byte))

func (s *Socket) WritePump()