socket

Documentation

Index

• type Connection
• type EventHandlers
• type NamespaceEventHandlerMap
• type Registry
  • func NewSocketRegistry(eventHandlersMap NamespaceEventHandlerMap, ...) *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 EventHandlers

type EventHandlers struct {
	RegisterHandler, UnregisterHandler func(s *Socket)
}

type NamespaceEventHandlerMap

type NamespaceEventHandlerMap map[string]*EventHandlers

type Registry

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

func NewSocketRegistry

func NewSocketRegistry(eventHandlersMap NamespaceEventHandlerMap, serviceGoroutine goroutine.IGoroutine) *Registry

type Socket

type Socket struct {
	Ctx         context.Context
	ErrorLogger errorlogger.ErrorLogger
	Connection  *Connection
	ID          string
	Namespace   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()