socket

Documentation

Index

• type Connection
• type DTOMessage
• type Registry
  • func BuildAndRunSocketRegistry(registerHandler, unregisterHandler func(s *Socket)) *Registry
• type Socket
  • func (s *Socket) Emit(dto *DTOMessage)
  • func (s *Socket) ReadPump(registry *Registry, readMessageHandler func(dto *DTOMessage))
  • func (s *Socket) WritePump()

Types

type Connection

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

type DTOMessage

type DTOMessage struct {
	Type string
	Data interface{}
}

type Registry

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

func BuildAndRunSocketRegistry

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

type Socket

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

func (*Socket) Emit

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

func (*Socket) ReadPump

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

func (*Socket) WritePump

func (s *Socket) WritePump()