Versions in this module Expand all Collapse all v0 v0.1.2 Mar 14, 2026 v0.1.1 Mar 14, 2026 Changes in this version + const DefaultConnectTimeout + const DefaultMaxDisconnectionDuration + const DefaultRandomizationFactor + const DefaultReconnectionDelay + const DefaultReconnectionDelayMax + const EngineIOProtocolVersion + const SocketIOProtocolVersion + var ErrAckTimeout = fmt.Errorf("ack timeout") + var NewPrintDebugger = eio.NewPrintDebugger + func IsEventReservedForClient(eventName string) bool + func IsEventReservedForNsp(eventName string) bool + func IsEventReservedForServer(eventName string) bool + type Binary []byte + func (b *Binary) UnmarshalJSON(data []byte) error + func (b Binary) MarshalJSON() ([]byte, error) + func (b Binary) SocketIOBinary() bool + type BroadcastOperator = adapter.BroadcastOperator + type ClientSocket interface + Active func() bool + Auth func() (v any) + Connect func() + Disconnect func() + Manager func() *Manager + SetAuth func(v any) + Volatile func() Emitter + type ClientSocketConfig struct + AckTimeout time.Duration + Auth any + Retries int + type ClientSocketConnectErrorFunc func(err any) + type ClientSocketConnectFunc func() + type ClientSocketDisconnectFunc func(reason Reason) + type ClientSocketEvents interface + OffConnect func(f ...ClientSocketConnectFunc) + OffConnectError func(f ...ClientSocketConnectErrorFunc) + OffDisconnect func(f ...ClientSocketDisconnectFunc) + OnConnect func(f ClientSocketConnectFunc) + OnConnectError func(f ClientSocketConnectErrorFunc) + OnDisconnect func(f ClientSocketDisconnectFunc) + OnceConnect func(f ClientSocketConnectFunc) + OnceConnectError func(f ClientSocketConnectErrorFunc) + OnceDisconnect func(f ClientSocketDisconnectFunc) + type Debugger = eio.Debugger + type Emitter struct + func (e Emitter) Emit(eventName string, v ...any) + func (e Emitter) Socket() Socket + func (e Emitter) Timeout(timeout time.Duration) Emitter + func (e Emitter) Volatile() Emitter + type Handshake struct + Auth json.RawMessage + Time time.Time + type InternalError struct + func (e InternalError) Error() string + func (e InternalError) Unwrap() error + type Manager struct + func NewManager(url string, config *ManagerConfig) *Manager + func (m *Manager) Close() + func (m *Manager) OffAll() + func (m *Manager) OffClose(_f ...ManagerCloseFunc) + func (m *Manager) OffError(_f ...ManagerErrorFunc) + func (m *Manager) OffOpen(_f ...ManagerOpenFunc) + func (m *Manager) OffPing(_f ...ManagerPingFunc) + func (m *Manager) OffReconnect(_f ...ManagerReconnectFunc) + func (m *Manager) OffReconnectAttempt(_f ...ManagerReconnectAttemptFunc) + func (m *Manager) OffReconnectError(_f ...ManagerReconnectErrorFunc) + func (m *Manager) OffReconnectFailed(_f ...ManagerReconnectFailedFunc) + func (m *Manager) OnClose(f ManagerCloseFunc) + func (m *Manager) OnError(f ManagerErrorFunc) + func (m *Manager) OnOpen(f ManagerOpenFunc) + func (m *Manager) OnPing(f ManagerPingFunc) + func (m *Manager) OnReconnect(f ManagerReconnectFunc) + func (m *Manager) OnReconnectAttempt(f ManagerReconnectAttemptFunc) + func (m *Manager) OnReconnectError(f ManagerReconnectErrorFunc) + func (m *Manager) OnReconnectFailed(f ManagerReconnectFailedFunc) + func (m *Manager) OnceClose(f ManagerCloseFunc) + func (m *Manager) OnceError(f ManagerErrorFunc) + func (m *Manager) OnceOpen(f ManagerOpenFunc) + func (m *Manager) OncePing(f ManagerPingFunc) + func (m *Manager) OnceReconnect(f ManagerReconnectFunc) + func (m *Manager) OnceReconnectAttempt(f ManagerReconnectAttemptFunc) + func (m *Manager) OnceReconnectError(f ManagerReconnectErrorFunc) + func (m *Manager) OnceReconnectFailed(f ManagerReconnectFailedFunc) + func (m *Manager) Open() + func (m *Manager) Socket(namespace string, config *ClientSocketConfig) ClientSocket + type ManagerCloseFunc func(reason Reason, err error) + type ManagerConfig struct + Debugger Debugger + EIO eio.ClientConfig + NoReconnection bool + ParserCreator parser.Creator + RandomizationFactor *float32 + ReconnectionAttempts uint32 + ReconnectionDelay *time.Duration + ReconnectionDelayMax *time.Duration + type ManagerErrorFunc func(err error) + type ManagerOpenFunc func() + type ManagerPingFunc func() + type ManagerReconnectAttemptFunc func(attempt uint32) + type ManagerReconnectErrorFunc func(err error) + type ManagerReconnectFailedFunc func() + type ManagerReconnectFunc func(attempt uint32) + type Namespace struct + func (n *Namespace) Adapter() adapter.Adapter + func (n *Namespace) Compress(compress bool) *BroadcastOperator + func (n *Namespace) DisconnectSockets(close bool) + func (n *Namespace) Emit(eventName string, v ...any) + func (n *Namespace) Except(room ...Room) *BroadcastOperator + func (n *Namespace) FetchSockets() []adapter.Socket + func (n *Namespace) In(room ...Room) *BroadcastOperator + func (n *Namespace) Local() *BroadcastOperator + func (n *Namespace) Name() string + func (n *Namespace) OffAll() + func (n *Namespace) OffConnection(_f ...NamespaceConnectionFunc) + func (n *Namespace) OffEvent(eventName string, handler ...any) + func (n *Namespace) OnConnection(f NamespaceConnectionFunc) + func (n *Namespace) OnEvent(eventName string, handler any) + func (n *Namespace) OnServerSideEmit(eventName string, _v ...any) + func (n *Namespace) OnceConnection(f NamespaceConnectionFunc) + func (n *Namespace) OnceEvent(eventName string, handler any) + func (n *Namespace) ServerSideEmit(eventName string, _v ...any) + func (n *Namespace) Sockets() []ServerSocket + func (n *Namespace) SocketsJoin(room ...Room) + func (n *Namespace) SocketsLeave(room ...Room) + func (n *Namespace) To(room ...Room) *BroadcastOperator + func (n *Namespace) Use(f NspMiddlewareFunc) + type NamespaceConnectionFunc func(socket ServerSocket) + type NspMiddlewareFunc func(socket ServerSocket, handshake *Handshake) any + type Reason = eio.Reason + const ReasonClientNamespaceDisconnect + const ReasonForcedClose + const ReasonForcedServerClose + const ReasonIOClientDisconnect + const ReasonIOServerDisconnect + const ReasonParseError + const ReasonPingTimeout + const ReasonServerNamespaceDisconnect + const ReasonServerShuttingDown + const ReasonTransportClose + const ReasonTransportError + type Room = adapter.Room + type Server struct + func NewServer(config *ServerConfig) *Server + func (s *Server) Close() error + func (s *Server) Compress(compress bool) *BroadcastOperator + func (s *Server) DisconnectSockets(close bool) + func (s *Server) Emit(eventName string, v ...any) + func (s *Server) Except(room ...Room) *BroadcastOperator + func (s *Server) FetchSockets(room ...string) []adapter.Socket + func (s *Server) HTTPWriteTimeout() time.Duration + func (s *Server) In(room ...Room) *BroadcastOperator + func (s *Server) IsClosed() bool + func (s *Server) Local() *BroadcastOperator + func (s *Server) Of(namespace string) *Namespace + func (s *Server) OffAnyConnection(_f ...ServerAnyConnectionFunc) + func (s *Server) OffConnection(f ...NamespaceConnectionFunc) + func (s *Server) OffNewNamespace(_f ...ServerNewNamespaceFunc) + func (s *Server) OnAnyConnection(f ServerAnyConnectionFunc) + func (s *Server) OnConnection(f NamespaceConnectionFunc) + func (s *Server) OnNewNamespace(f ServerNewNamespaceFunc) + func (s *Server) OnceAnyConnection(f ServerAnyConnectionFunc) + func (s *Server) OnceConnection(f NamespaceConnectionFunc) + func (s *Server) OnceNewNamespace(f ServerNewNamespaceFunc) + func (s *Server) PollTimeout() time.Duration + func (s *Server) Run() error + func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) + func (s *Server) ServerSideEmit(eventName string, v ...any) + func (s *Server) Sockets() []ServerSocket + func (s *Server) SocketsJoin(room ...Room) + func (s *Server) SocketsLeave(room ...Room) + func (s *Server) To(room ...Room) *BroadcastOperator + func (s *Server) Use(f NspMiddlewareFunc) + type ServerAnyConnectionFunc func(namespace string, socket ServerSocket) + type ServerConfig struct + AcceptAnyNamespace bool + AdapterCreator adapter.Creator + ConnectTimeout time.Duration + Debugger Debugger + EIO eio.ServerConfig + ParserCreator parser.Creator + ServerConnectionStateRecovery ServerConnectionStateRecovery + type ServerConnectionStateRecovery struct + Enabled bool + MaxDisconnectionDuration time.Duration + UseMiddlewares bool + type ServerNewNamespaceFunc func(namespace *Namespace) + type ServerSocket interface + Broadcast func() *BroadcastOperator + Disconnect func(close bool) + Except func(room ...Room) *BroadcastOperator + In func(room ...Room) *BroadcastOperator + Join func(room ...Room) + Leave func(room Room) + Local func() *BroadcastOperator + Namespace func() *Namespace + Rooms func() mapset.Set[Room] + Server func() *Server + To func(room ...Room) *BroadcastOperator + Use func(f any) + type ServerSocketDisconnectFunc func(reason Reason) + type ServerSocketDisconnectingFunc func(reason Reason) + type ServerSocketErrorFunc func(err error) + type ServerSocketEvents interface + OffDisconnect func(f ...ServerSocketDisconnectFunc) + OffDisconnecting func(f ...ServerSocketDisconnectingFunc) + OffError func(f ...ServerSocketErrorFunc) + OnDisconnect func(f ServerSocketDisconnectFunc) + OnDisconnecting func(f ServerSocketDisconnectingFunc) + OnError func(f ServerSocketErrorFunc) + OnceDisconnect func(f ServerSocketDisconnectFunc) + OnceDisconnecting func(f ServerSocketDisconnectingFunc) + OnceError func(f ServerSocketErrorFunc) + type Socket interface + Connected func() bool + Emit func(eventName string, v ...any) + ID func() SocketID + OffAll func() + OffEvent func(eventName string, handler ...any) + OnEvent func(eventName string, handler any) + OnceEvent func(eventName string, handler any) + Recovered func() bool + Timeout func(timeout time.Duration) Emitter + type SocketID = adapter.SocketID
Go to main page