README
¶
go-engine.io
go-engine.io is the implement of engine.io in golang, which is transport-based cross-browser/cross-device bi-directional communication layer for go-socket.io.
It is compatible with node.js implement, and supported long-polling and websocket transport.
Install
Install the package with:
go get github.com/googollee/go-socket.io/engineio@v1
Import it with:
import "github.com/googollee/go-socket.io/engineio"
and use engineio as the package name inside the code.
Example
Please check example folder for details.
package main
import (
"io/ioutil"
"log"
"net/http"
"github.com/googollee/go-socket.io/engineio"
)
func main() {
server := engineio.NewServer(nil)
go func() {
for {
conn, err := server.Accept()
if err != nil {
log.Fatalln("accept error:", err)
}
go func() {
defer conn.Close()
for {
t, r, _ := conn.NextReader()
b, _ := ioutil.ReadAll(r)
r.Close()
w, _ := conn.NextWriter(t)
w.Write(b)
w.Close()
}
}()
}
}()
http.Handle("/engine.io/", server)
log.Println("Serving at localhost:5000...")
log.Fatal(http.ListenAndServe(":5000", nil))
}
License
The 3-clause BSD License - see LICENSE for more details
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CheckerFunc ¶
CheckerFunc is function to check request.
type Conn ¶
type Conn interface {
ID() string
NextReader() (session.FrameType, io.ReadCloser, error)
NextWriter(fType session.FrameType) (io.WriteCloser, error)
Close() error
URL() url.URL
LocalAddr() net.Addr
RemoteAddr() net.Addr
RemoteHeader() http.Header
SetContext(v interface{})
Context() interface{}
}
Conn is connection by client session
type ConnInitorFunc ¶
ConnInitorFunc is function to do after create connection.
type Opener ¶
type Opener interface {
Open() (transport.ConnParameters, error)
}
Opener is client connection which need receive open message first.
type Options ¶
type Options struct {
PingTimeout time.Duration
PingInterval time.Duration
Transports []transport.Transport
SessionIDGenerator session.IDGenerator
RequestChecker CheckerFunc
ConnInitor ConnInitorFunc
}
Options is options to create a server.
type Pauser ¶
type Pauser interface {
Pause()
Resume()
}
Pauser is connection which can be paused and resumes.
Source Files
Directories