engine

Documentation

Index

• Constants
• func NewServer(opt interface{}) *server
• type Server
  • func Attach(server *types.HttpServer, options interface{}) Server
  • func Listen(addr string, options interface{}, fn types.Callable) Server
  • func New(server interface{}, args ...interface{}) Server
• type Socket
  • func NewSocket(id string, server Server, transport transports.Transport, ...) Socket

Constants

const (
	OK_REQUEST                   int = -1
	UNKNOWN_TRANSPORT            int = 0
	UNKNOWN_SID                  int = 1
	BAD_HANDSHAKE_METHOD         int = 2
	BAD_REQUEST                  int = 3
	FORBIDDEN                    int = 4
	UNSUPPORTED_PROTOCOL_VERSION int = 5
)

Protocol errors mappings.

const Protocol = 4

Functions

func NewServer

func NewServer(opt interface{}) *server

Types

type Server

type Server interface {
	events.EventEmitter

	SetHttpServer(*types.HttpServer)
	HttpServer() *types.HttpServer
	Opts() *config.ServerOptions
	Clients() *sync.Map
	ClientsCount() uint64
	Upgrades(string) *types.Set
	Close() Server
	HandleRequest(*types.HttpContext)
	HandleUpgrade(*types.HttpContext)
	Attach(*types.HttpServer, interface{})
	GenerateId(*types.HttpContext) (string, error)
}

func Attach

func Attach(server *types.HttpServer, options interface{}) Server

func Listen

func Listen(addr string, options interface{}, fn types.Callable) Server

func New

func New(server interface{}, args ...interface{}) Server

type Socket

type Socket interface {
	events.EventEmitter

	Id() string
	Server() Server
	Request() *types.HttpContext
	RemoteAddress() string
	Upgraded() bool
	Upgrading() bool
	MaybeUpgrade(transports.Transport)
	ReadyState() string
	SetReadyState(string)
	Transport() transports.Transport
	Send(io.Reader, *packet.Options, func(transports.Transport)) Socket
	Write(io.Reader, *packet.Options, func(transports.Transport)) Socket
	Close(bool)
}

func NewSocket

func NewSocket(id string, server Server, transport transports.Transport, ctx *types.HttpContext, protocol int) Socket