Help us shape the future of Go! Take the 2026 Go Developer Survey

socket

package
v0.8.24 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 3, 2021 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Connection

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

type EventHandlers added in v0.5.5

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

type NamespaceEventHandlerMap added in v0.5.5

type NamespaceEventHandlerMap map[string]*EventHandlers

type Registry

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

func BuildAndRunSocketRegistry

func BuildAndRunSocketRegistry(eventHandlersMap NamespaceEventHandlerMap) *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()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL