Documentation ¶
Index ¶
- Constants
- Variables
- func NewSessionID() string
- type Broadcaster
- type Client
- type Config
- type Event
- type EventEmitter
- type MessageType
- type NameSpace
- type Packet
- type Session
- type 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
- type TransportManager
Constants ¶
View Source
const ( PACKET_DISCONNECT = iota PACKET_CONNECT PACKET_HEARTBEAT PACKET_MESSAGE PACKET_JSONMESSAGE PACKET_EVENT PACKET_ACK PACKET_ERROR PACKET_NOOP )
View Source
const ( SessionIDLength = 16 SessionIDCharset = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz" )
View Source
const (
ProtocolVersion = 1
)
Variables ¶
View Source
var (
DefaultTransports = NewTransportManager()
)
View Source
var NotConnected = errors.New("not connected")
Functions ¶
func NewSessionID ¶
func NewSessionID() string
Types ¶
type Broadcaster ¶
type Broadcaster struct {
Namespaces []*NameSpace
}
func (*Broadcaster) Broadcast ¶
func (b *Broadcaster) Broadcast(name string, args ...interface{})
func (*Broadcaster) Except ¶
func (b *Broadcaster) Except(namespace *NameSpace) *Broadcaster
type Client ¶
type Client struct { *EventEmitter // contains filtered or unexported fields }
type Event ¶
type Event struct { Name string `json:"name"` Args json.RawMessage `json:"args"` }
type EventEmitter ¶
type EventEmitter struct {
// contains filtered or unexported fields
}
func NewEventEmitter ¶
func NewEventEmitter() *EventEmitter
func (*EventEmitter) On ¶
func (ee *EventEmitter) On(name string, fn interface{}) error
func (*EventEmitter) RemoveAllListeners ¶
func (ee *EventEmitter) RemoveAllListeners(name string)
func (*EventEmitter) RemoveListener ¶
func (ee *EventEmitter) RemoveListener(name string, fn interface{})
type MessageType ¶
type MessageType uint8
type NameSpace ¶
type NameSpace struct { *EventEmitter Session *Session // contains filtered or unexported fields }
func NewNameSpace ¶
func NewNameSpace(session *Session, endpoint string, ee *EventEmitter) *NameSpace
type Session ¶
type Session struct { SessionId string Values map[interface{}]interface{} // contains filtered or unexported fields }
func NewSession ¶
type SocketIOServer ¶
func NewSocketIOServer ¶
func NewSocketIOServer(config *Config) *SocketIOServer
func (*SocketIOServer) Broadcast ¶
func (srv *SocketIOServer) Broadcast(name string, args ...interface{})
func (*SocketIOServer) Except ¶
func (srv *SocketIOServer) Except(ns *NameSpace) *Broadcaster
func (*SocketIOServer) In ¶
func (srv *SocketIOServer) In(name string) *Broadcaster
func (*SocketIOServer) Of ¶
func (srv *SocketIOServer) Of(name string) *EventEmitter
func (*SocketIOServer) On ¶
func (srv *SocketIOServer) On(name string, fn interface{}) error
func (*SocketIOServer) RemoveAllListeners ¶
func (srv *SocketIOServer) RemoveAllListeners(name string)
func (*SocketIOServer) RemoveListener ¶
func (srv *SocketIOServer) RemoveListener(name string, fn interface{})
func (*SocketIOServer) ServeHTTP ¶
func (srv *SocketIOServer) ServeHTTP(w http.ResponseWriter, r *http.Request)
type TransportManager ¶
type TransportManager struct {
// contains filtered or unexported fields
}
func NewTransportManager ¶
func NewTransportManager() *TransportManager
func (*TransportManager) GetTransportNames ¶
func (tm *TransportManager) GetTransportNames() (names []string)
func (*TransportManager) RegisterTransport ¶
func (tm *TransportManager) RegisterTransport(name string)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.