socketio

Feb 8, 2023

Changes in this version

type RedisAdapterOptions

+ DB int

May 13, 2022

Changes in this version

type RedisAdapterOptions

+ Password string

May 21, 2021

Changes in this version

type RedisAdapterOptions

+ Addr string

+ Network string

May 2, 2021

Changes in this version

type Broadcast

+ AllRooms func() []string

type Namespace

+ Context func() interface{}

+ Emit func(eventName string, v ...interface{})

+ Join func(room string)

+ Leave func(room string)

+ LeaveAll func()

+ Namespace func() string

+ Rooms func() []string

+ SetContext func(ctx interface{})

+ type RedisAdapterOptions struct

+ Host string

+ Port string

+ Prefix string

type Server

+ func (s *Server) Adapter(opts *RedisAdapterOptions) (bool, error)

+ func (s *Server) BroadcastToNamespace(namespace string, event string, args ...interface{}) bool

Mar 2, 2020

Changes in this version

type Broadcast

+ ForEach func(room string, f EachFunc)

+ type EachFunc func(Conn)

type Server

+ func (s *Server) ForEach(namespace string, room string, f EachFunc) bool

Aug 6, 2019

Changes in this version

+ type Broadcast interface

+ Clear func(room string)

+ Join func(room string, connection Conn)

+ Leave func(room string, connection Conn)

+ LeaveAll func(connection Conn)

+ Len func(room string) int

+ Rooms func(connection Conn) []string

+ Send func(room, event string, args ...interface{})

+ SendAll func(event string, args ...interface{})

+ func NewBroadcast() Broadcast

type Conn

+ Join func(room string)

+ Leave func(room string)

+ LeaveAll func()

+ Rooms func() []string

type Server

+ func (s *Server) BroadcastToRoom(room, event string, args ...interface{})

+ func (s *Server) ClearRoom(room string)

+ func (s *Server) JoinRoom(room string, connection Conn)

+ func (s *Server) LeaveAllRooms(connection Conn)

+ func (s *Server) LeaveRoom(room string, connection Conn)

+ func (s *Server) RoomLen(room string) int

+ func (s *Server) Rooms() []string

Feb 17, 2019

Changes in this version

+ type Conn interface

+ Close func() error

+ Context func() interface{}

+ Emit func(msg string, v ...interface{})

+ ID func() string

+ LocalAddr func() net.Addr

+ Namespace func() string

+ RemoteAddr func() net.Addr

+ RemoteHeader func() http.Header

+ SetContext func(v interface{})

+ URL func() url.URL

type Server

+ func (s *Server) Close() error

+ func (s *Server) OnConnect(nsp string, f func(Conn) error)

+ func (s *Server) OnDisconnect(nsp string, f func(Conn, string))

+ func (s *Server) OnError(nsp string, f func(error))

+ func (s *Server) OnEvent(nsp, event string, f interface{})

+ func (s *Server) Serve() error

Feb 17, 2019

Changes in this version

+ const Protocol

+ type Attachment struct

+ Data io.ReadWriter

+ func (a *Attachment) UnmarshalJSON(b []byte) error

+ func (a Attachment) MarshalJSON() ([]byte, error)

+ type BroadcastAdaptor interface

+ Join func(room string, socket Socket) error

+ Leave func(room string, socket Socket) error

+ Len func(room string) int

+ Send func(ignore Socket, room, event string, args ...interface{}) error

+ type Namespace interface

+ Name func() string

+ Of func(name string) Namespace

+ On func(event string, f interface{}) error

+ type Server struct

+ func NewServer(transportNames []string) (*Server, error)

+ func (n Server) Name() string

+ func (n Server) Of(name string) Namespace

+ func (s *Server) BroadcastTo(room, event string, args ...interface{})

+ func (s *Server) Count() int

+ func (s *Server) GetMaxConnection() int

+ func (s *Server) LenRoom(room string) int

+ func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (s *Server) SetAdaptor(adaptor BroadcastAdaptor)

+ func (s *Server) SetAllowRequest(f func(*http.Request) error)

+ func (s *Server) SetAllowUpgrades(allow bool)

+ func (s *Server) SetCookie(prefix string)

+ func (s *Server) SetMaxConnection(n int)

+ func (s *Server) SetNewId(f func(*http.Request) string)

+ func (s *Server) SetPingInterval(t time.Duration)

+ func (s *Server) SetPingTimeout(t time.Duration)

+ func (s *Server) SetSessionManager(sessions engineio.Sessions)

+ type Socket interface

+ BroadcastTo func(room, event string, args ...interface{}) error

+ Disconnect func()

+ Emit func(event string, args ...interface{}) error

+ Id func() string

+ Join func(room string) error

+ Leave func(room string) error

+ On func(event string, f interface{}) error

+ Request func() *http.Request

+ Rooms func() []string

Feb 17, 2019

Changes in this version

+ const PACKET_ACK

+ const PACKET_CONNECT

+ const PACKET_DISCONNECT

+ const PACKET_ERROR

+ const PACKET_EVENT

+ const PACKET_HEARTBEAT

+ const PACKET_JSONMESSAGE

+ const PACKET_MESSAGE

+ const PACKET_NOOP

+ const ProtocolVersion

+ const SessionIDCharset

+ const SessionIDLength

+ var DefaultTransports = NewTransportManager()

+ var NotConnected = errors.New("not connected")

+ func NewSessionID() string

+ type Broadcaster struct

+ Namespaces []*NameSpace

+ func (b *Broadcaster) Broadcast(name string, args ...interface{})

+ func (b *Broadcaster) Except(namespace *NameSpace) *Broadcaster

+ type Client struct

+ func Dial(origin string) (*Client, error)

+ func (c *Client) Call(name string, timeout time.Duration, reply []interface{}, args ...interface{}) error

+ func (c *Client) Emit(name string, args ...interface{}) error

+ func (c *Client) Of(name string) (nameSpace *NameSpace)

+ func (c *Client) Quit() error

+ func (c *Client) Run()

+ type Config struct

+ Authorize func(*http.Request, map[interface{}]interface{}) bool

+ ClosingTimeout int

+ HeartbeatTimeout int

+ NewSessionID func() string

+ Transports *TransportManager

+ type Event struct

+ Args json.RawMessage

+ Name string

+ type EventEmitter struct

+ func NewEventEmitter() *EventEmitter

+ func (ee *EventEmitter) On(name string, fn interface{}) error

+ func (ee *EventEmitter) RemoveAllListeners(name string)

+ func (ee *EventEmitter) RemoveListener(name string, fn interface{})

+ type MessageType uint8

+ type NameSpace struct

+ Session *Session

+ func NewNameSpace(session *Session, endpoint string, ee *EventEmitter) *NameSpace

+ func (ns *NameSpace) Call(name string, timeout time.Duration, reply []interface{}, args ...interface{}) error

+ func (ns *NameSpace) Emit(name string, args ...interface{}) error

+ func (ns *NameSpace) Endpoint() string

+ func (ns *NameSpace) Id() string

+ type Packet interface

+ Ack func() bool

+ EndPoint func() string

+ Id func() int

+ Type func() MessageType

+ type Session struct

+ Request *http.Request

+ SessionId string

+ Values map[interface{}]interface{}

+ func NewSession(emitters map[string]*EventEmitter, sessionId string, timeout int, ...) *Session

+ func (ss *Session) Of(name string) (nameSpace *NameSpace)

+ type SocketIOServer struct

+ func NewSocketIOServer(config *Config) *SocketIOServer

+ func (srv *SocketIOServer) Broadcast(name string, args ...interface{})

+ func (srv *SocketIOServer) Except(ns *NameSpace) *Broadcaster

+ func (srv *SocketIOServer) In(name string) *Broadcaster

+ func (srv *SocketIOServer) Of(name string) *EventEmitter

+ func (srv *SocketIOServer) On(name string, fn interface{}) error

+ func (srv *SocketIOServer) RemoveAllListeners(name string)

+ func (srv *SocketIOServer) RemoveListener(name string, fn interface{})

+ func (srv *SocketIOServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Transport interface

+ Read func() (io.Reader, error)

+ Send func([]byte) error

+ type TransportManager struct

+ func NewTransportManager() *TransportManager

+ func (tm *TransportManager) GetTransportNames() (names []string)

+ func (tm *TransportManager) RegisterTransport(name string)