server

package

v1.0.1-rc1 Latest Latest Go to latest Published: May 29, 2019 License: MIT Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/2se/dolphin

Documentation ¶

Index ¶

Variables
func Init(cnf *config.WebsocketConfig, dispatcher core.Dispatcher, ...)
func ListenAndServe(stop <-chan bool) error
func NewSession(conn *ws.Conn, opt *Opt) (io.WriteCloser, error)
func Serve404(wrt http.ResponseWriter, req *http.Request)
func TlsRedirect(toPort string) http.HandlerFunc
type Opt

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	NilConnErr             = errors.New("nil websocket connection")
	NilDispatcherErr       = errors.New("nil dispatcher, need invoke server.Init(dispatcher)")
	TimeoutErr             = errors.New("time out")
	WriteInClosedWriterErr = errors.New("writer has been already closed")
)

Functions ¶

func Init ¶

func Init(cnf *config.WebsocketConfig, dispatcher core.Dispatcher, ticker *tw.TimingWheel)

func ListenAndServe ¶

func ListenAndServe(stop <-chan bool) error

func NewSession ¶

func NewSession(conn *ws.Conn, opt *Opt) (io.WriteCloser, error)

func Serve404 ¶

func Serve404(wrt http.ResponseWriter, req *http.Request)

Custom 404 response.

func TlsRedirect ¶

func TlsRedirect(toPort string) http.HandlerFunc

Redirect HTTP requests to HTTPS

Types ¶

type Opt ¶

type Opt struct {
	Tls                *config.WsTlsConfig
	Dispatcher         core.Dispatcher
	Ticker             *tw.TimingWheel
	IdleSessionTimeout time.Duration
	WriteWait          time.Duration
	SessionQueueSize   int
	QueueOutTimeout    time.Duration
	ReadBufferSize     int
	WriteBufferSize    int
	IDSalt             string
	CheckOrigin        func(*http.Request) bool
	// contains filtered or unexported fields
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL