socket

type Config struct {
	WriteWait         time.Duration
	PongWait          time.Duration
	PingPeriod        time.Duration
	MaxMessageSize    int64
	ReadBufferSize    int
	WriteBufferSize   int
	SendBufferSize    int
	EnableCompression bool
	CheckOrigin       func(request *http.Request) bool
}

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

type ConnectionOptions struct {
	ID                 string
	Namespace          string
	Context            context.Context
	ErrorLogger        errorlogger.ErrorLogger
	ReadMessageHandler ReadMessageHandler
	ResponseHeader     http.Header
}

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

type NamespaceEventHandlerMap map[string]*EventHandlers

type ReadMessageHandler func(socket *Socket, rawData []byte)

type Registry struct {
	Sockets          *sync.Map
	ServiceGoroutine goroutine.IGoroutine
	// contains filtered or unexported fields
}

type Socket struct {
	Ctx         context.Context
	ErrorLogger errorlogger.ErrorLogger
	Connection  *Connection
	ID          string
	Namespace   string
	// contains filtered or unexported fields
}