socket

package

v0.1.3 Latest Latest Go to latest Published: Apr 6, 2021 License: MIT Imports: 5 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 DTOMessage struct {
	Type string
	Data interface{}
}

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

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

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

func (s *Socket) Emit(dto *DTOMessage)

func (s *Socket) ReadPump(registry *Registry, readMessageHandler func(dto *DTOMessage))

func (s *Socket) WritePump()