air

Sep 19, 2021

Changes in this version

+ var ErrConnClosed = errors.New("use of closed network connection")

Sep 17, 2021

Changes in this version

type ConsoleLog

+ func (d ConsoleLog) Debugf(format string, v ...interface{})

+ func (d ConsoleLog) Errorf(format string, v ...interface{})

+ func (d ConsoleLog) Fatalf(format string, v ...interface{})

+ func (d ConsoleLog) Infof(format string, v ...interface{})

+ func (d ConsoleLog) Panicf(format string, v ...interface{})

+ func (d ConsoleLog) Warnf(format string, v ...interface{})

type Logger

+ Debugf func(format string, v ...interface{})

+ Errorf func(format string, v ...interface{})

+ Fatalf func(format string, v ...interface{})

+ Infof func(format string, v ...interface{})

+ Panicf func(format string, v ...interface{})

+ Warnf func(format string, v ...interface{})

type Server

+ func (s *Server) BroadcastTo(room, event string, msg []byte)

+ func (s *Server) BroadcastToAll(event string, msg []byte)

+ func (s *Server) Started() bool

Sep 3, 2021

Changes in this version

type Event

+ const OnReconnect

Aug 29, 2021

Changes in this version

+ const MaxSequence

+ const MaxWorkId

+ var ErrConnClosing = errors.New("use of closed network connection")

+ var ErrMessageTimeout = errors.New("timeout")

+ var ErrorMustBePointer = errors.New("value must be a pointer")

+ var ErrorWrongRequestType = errors.New("value must be a string/[]byte/struct")

+ var ErrorWrongResponseType = errors.New("value must be a pointer of string/[]byte/struct")

+ type Codec interface

+ Decode func(reply []byte, r interface{}) (err error)

+ Encode func(v interface{}) (msg []byte, err error)

+ func NewDefaultCodec() Codec

+ type Conn interface

+ Ack func(event string, v interface{}, r interface{}) error

+ BroadcastTo func(room, event string, msg []byte)

+ BroadcastToAll func(event string, msg []byte)

+ Close func()

+ Emit func(event string, v interface{}) error

+ Get func(key string) interface{}

+ Id func() string

+ IsClosed func() bool

+ Join func(room string)

+ Leave func(room string)

+ RemoteAddr func() net.Addr

+ Set func(key string, value interface{})

+ type ConsoleLog struct

+ func NewConsoleLog() *ConsoleLog

+ func (d ConsoleLog) Debug(v ...interface{})

+ func (d ConsoleLog) Error(v ...interface{})

+ func (d ConsoleLog) Fatal(v ...interface{})

+ func (d ConsoleLog) Info(v ...interface{})

+ func (d ConsoleLog) Panic(v ...interface{})

+ func (d ConsoleLog) Warn(v ...interface{})

+ type Context interface

+ Ack func(event string, v interface{}, r interface{}) error

+ Bind func(v interface{}) error

+ BroadcastTo func(room, event string, msg []byte)

+ BroadcastToAll func(event string, msg []byte)

+ Close func()

+ Conn func() Conn

+ Content func() []byte

+ Emit func(event string, v interface{}) error

+ Get func(key string) interface{}

+ Id func() string

+ IsClosed func() bool

+ Join func(room string)

+ Leave func(room string)

+ Logger func() Logger

+ Packet func() Packet

+ RemoteAddr func() net.Addr

+ Reply func(v interface{}) error

+ Set func(key string, value interface{})

+ type DefaultCodec struct

+ func (c *DefaultCodec) Decode(reply []byte, r interface{}) (err error)

+ func (c *DefaultCodec) Encode(v interface{}) (msg []byte, err error)

+ type Event = string

+ const OnClose

+ const OnConnect

+ const OnDisconnect

+ const OnHeartbeat

+ const OnJoin

+ const OnLeave

+ type EventHandler func(ctx Context) error

+ type Group struct

+ func NewGroup(s *Server) *Group

+ func (g *Group) Group(middleware ...MiddlewareFunc) (sg *Group)

+ func (g *Group) Handler(e string) EventHandler

+ func (g *Group) On(e string, fn EventHandler)

+ func (g *Group) Use(middleware ...MiddlewareFunc)

+ type IdGenerator struct

+ func NewSnowFlake(workerId uint16) (*IdGenerator, error)

+ func (sf *IdGenerator) Generate() uint64

+ type Logger interface

+ Debug func(v ...interface{})

+ Error func(v ...interface{})

+ Fatal func(v ...interface{})

+ Info func(v ...interface{})

+ Panic func(v ...interface{})

+ Warn func(v ...interface{})

+ type MessageKey = uint16

+ const MessageKeyAckRequest

+ const MessageKeyAckResponse

+ const MessageKeyEmit

+ const MessageKeyHeartbeat

+ type MiddlewareFunc func(EventHandler) EventHandler

+ type Options struct

+ Address string

+ Codec Codec

+ HeartbeatTimeout time.Duration

+ Logger Logger

+ MessageTimeout time.Duration

+ PacketReceiveChanLimit uint32

+ PacketSendChanLimit uint32

+ WorkId uint16

+ func DefaultOptions() *Options

+ type Packet interface

+ Body func() []byte

+ Event func() string

+ Id func() uint64

+ Key func() uint16

+ NewReplyPacket func(data []byte) Packet

+ Serialize func() []byte

+ func NewHeartbeatPacket() Packet

+ func NewPacket(key MessageKey, id uint64, event string, data []byte) Packet

+ func ReadPacket(r io.Reader) (Packet, error)

+ type Router interface

+ Handler func(e string) EventHandler

+ On func(e string, fn EventHandler)

+ Use func(args ...MiddlewareFunc)

+ type Server struct

+ func NewServer(opts *Options) (srv *Server, err error)

+ func (e *Server) SetRouter(event string, router Router)

+ func (s *Server) Close()

+ func (s *Server) Group(m ...MiddlewareFunc) (g *Group)

+ func (s *Server) Handler(e string) EventHandler

+ func (s *Server) On(e string, fn EventHandler)

+ func (s *Server) SetLog(log Logger)

+ func (s *Server) Start()

+ func (s *Server) Use(middleware ...MiddlewareFunc)