socket

Documentation

Index

• type Connection
• type Registry
  • func BuildAndRunSocketRegistry(registerHandler, unregisterHandler func(s *Socket)) *Registry
• type Socket
  • func (s *Socket) Emit(dto interface{})
  • func (s *Socket) ReadPump(registry *Registry, readMessageHandler func(rawData []byte))
  • func (s *Socket) WritePump()

Types

type Connection

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

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 {
	Ctx         context.Context
	ErrorLogger errorlogger.ErrorLogger
	Connection  *Connection
	ID          string
}

func (*Socket) Emit

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

func (*Socket) ReadPump

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

func (*Socket) WritePump

func (s *Socket) WritePump()