websocket

Documentation

Index

• func DeFrameLength(conn gnet.Conn) (int64, error)
• type Conn
  • func FrameConvert(conn gnet.Conn) *Conn
  • func (self *Conn) AwaitAdd()
  • func (self *Conn) FrameReader() io.Reader
  • func (self *Conn) Free()
  • func (self *Conn) NextFrame() (err error)
  • func (self *Conn) State() ws.State
  • func (self *Conn) WebSocketTextWriter() *TextWriter
• type Handler
• type OnCallPostPlugin
• type OnCallPrePlugin
• type OnUpgraderPlugin
• type TextWriter
  • func (self *TextWriter) Flush() error
  • func (self *TextWriter) Write(p []byte) (int, error)
• type WsPlugin

Functions

func DeFrameLength

func DeFrameLength(conn gnet.Conn) (int64, error)

Types

type Conn

type Conn struct {
	gnet.Conn
	// contains filtered or unexported fields
}

func FrameConvert

func FrameConvert(conn gnet.Conn) *Conn

func (*Conn) AwaitAdd

func (self *Conn) AwaitAdd()

func (*Conn) FrameReader

func (self *Conn) FrameReader() io.Reader

func (*Conn) Free

func (self *Conn) Free()

func (*Conn) NextFrame

func (self *Conn) NextFrame() (err error)

func (*Conn) State

func (self *Conn) State() ws.State

func (*Conn) WebSocketTextWriter

func (self *Conn) WebSocketTextWriter() *TextWriter

type Handler

type Handler interface {
	Proc(ctx *eventserve.GnetContext) interface{}
}

type OnCallPostPlugin

type OnCallPostPlugin interface {
	OnCallPost(ctx *eventserve.GnetContext, x interface{}, reply interface{}) error
}

逻辑处理之后

type OnCallPrePlugin

type OnCallPrePlugin interface {
	OnCallPre(ctx *eventserve.GnetContext, x interface{}) error
}

逻辑处理之前

type OnUpgraderPlugin

type OnUpgraderPlugin interface {
	OnUpgrader(ctx *eventserve.GnetContext) error
}

ws链接建立成功之后

type TextWriter

type TextWriter struct {
	wsutil.Writer
	// contains filtered or unexported fields
}

func (*TextWriter) Flush

func (self *TextWriter) Flush() error

func (*TextWriter) Write

func (self *TextWriter) Write(p []byte) (int, error)

type WsPlugin

type WsPlugin interface{}