Versions in this module Expand all Collapse all v0 v0.5.1 Mar 7, 2011 Changes in this version + const MessageDisconnect + const MessageHandshake + const MessageHeartbeat + const MessageJSON + const MessageText + const SIOAnnotationJSON + const SIOAnnotationRealm + const SessionIDCharset + const SessionIDLength + var DefaultConfig = Config + var DefaultLogger = log.New(os.Stdout, "", log.Ldate | log.Ltime) + var DefaultTransports = []Transport + var ErrConnected = os.NewError("already connected") + var ErrDestroyed = os.NewError("connection is disconnected") + var ErrMalformedPayload = os.NewError("malformed payload") + var ErrNotConnected = os.NewError("not connected") + var ErrQueueFull = os.NewError("send queue is full") + var NOPLogger = log.New(nopWriter{}, "", 0) + type Client interface + Dial func(string, string) os.Error + OnDisconnect func(func()) + OnMessage func(func(Message)) + Send func(interface{}) os.Error + SessionID func() SessionID + type Codec interface + NewDecoder func(*bytes.Buffer) Decoder + NewEncoder func() Encoder + type Config struct + Codec Codec + HeartbeatInterval int64 + Logger *log.Logger + MaxConnections int + Origins []string + QueueLength int + ReadBufferSize int + ReconnectTimeout int64 + Resource string + Transports []Transport + type Conn struct + func (c *Conn) Close() os.Error + func (c *Conn) Send(data interface{}) (err os.Error) + func (c *Conn) String() string + type Decoder interface + Decode func() ([]Message, os.Error) + Reset func() + type Encoder interface + Encode func(io.Writer, interface{}) os.Error + type Message interface + Annotation func(string) (string, bool) + Annotations func() map[string]string + Data func() string + JSON func() (string, bool) + Type func() uint8 + type SIOCodec struct + func (sc SIOCodec) NewDecoder(src *bytes.Buffer) Decoder + func (sc SIOCodec) NewEncoder() Encoder + type SIOStreamingCodec struct + func (sc SIOStreamingCodec) NewDecoder(src *bytes.Buffer) Decoder + func (sc SIOStreamingCodec) NewEncoder() Encoder + type ServeMux struct + func NewServeMux(sio *SocketIO) *ServeMux + func (mux *ServeMux) ServeHTTP(w http.ResponseWriter, r *http.Request) + type SessionID string + func NewSessionID() (sid SessionID, err os.Error) + type SocketIO struct + func NewSocketIO(config *Config) *SocketIO + func (sio *SocketIO) Broadcast(data interface{}) + func (sio *SocketIO) BroadcastExcept(c *Conn, data interface{}) + func (sio *SocketIO) GetConn(sessionid SessionID) (c *Conn) + func (sio *SocketIO) ListenAndServeFlashPolicy(laddr string) os.Error + func (sio *SocketIO) Log(v ...interface{}) + func (sio *SocketIO) Logf(format string, v ...interface{}) + func (sio *SocketIO) OnConnect(f func(*Conn)) os.Error + func (sio *SocketIO) OnDisconnect(f func(*Conn)) os.Error + func (sio *SocketIO) OnMessage(f func(*Conn, Message)) os.Error + func (sio *SocketIO) ServeMux() *ServeMux + type Transport interface + Resource func() string + func NewFlashsocketTransport(rtimeout, wtimeout int64) Transport + func NewHTMLFileTransport(rtimeout, wtimeout int64) Transport + func NewJSONPPollingTransport(rtimeout, wtimeout int64) Transport + func NewWebsocketTransport(rtimeout, wtimeout int64) Transport + func NewXHRMultipartTransport(rtimeout, wtimeout int64) Transport + func NewXHRPollingTransport(rtimeout, wtimeout int64) Transport + type WebsocketClient struct + func NewWebsocketClient(codec Codec) (wc *WebsocketClient) + func (wc *WebsocketClient) Close() os.Error + func (wc *WebsocketClient) Dial(rawurl string, origin string) (err os.Error) + func (wc *WebsocketClient) OnDisconnect(f func()) + func (wc *WebsocketClient) OnMessage(f func(Message)) + func (wc *WebsocketClient) Send(payload interface{}) os.Error + func (wc *WebsocketClient) SessionID() SessionID