WebsocketDealer

Aug 18, 2021

Changes in this version

+ func Decode(data []byte) ([]byte, error)

+ type Coder interface

+ Decode func([]byte) ([]byte, error)

+ Encode func([]byte) []byte

+ type DefaultCoder struct

+ func (z *DefaultCoder) Encode(data []byte) []byte

Jul 3, 2021

Changes in this version

+ const EventFunctionCall

+ var FunctionCallPool = sync.Pool

+ type FunctionCall struct

+ Argument []interface{}

+ FunctionName string

+ Session *Session

+ type GlobalHandler struct

+ func NewGlobalHandler() GlobalHandler

+ func (z *GlobalHandler) GC()

+ func (z *GlobalHandler) MountUser(key interface{}, val interface{}) bool

+ func (z *GlobalHandler) SetDownFunction(f func(key interface{}, userData interface{}, lastBeatTime time.Time) bool)

+ func (z *GlobalHandler) SetMaxHandleTime(time time.Duration)

+ func (z *GlobalHandler) UserBeat(key interface{}) bool

Feb 9, 2021

Changes in this version

type Session

+ Id uuid.UUID

Feb 7, 2021

Changes in this version

+ type WebsocketCallInterceptor func(functionName string, replier *Replier, args []interface{}) bool

type WebsocketDealer

+ func (z *WebsocketDealer) AddInterceptor(interceptor WebsocketCallInterceptor)

Jan 31, 2021

Changes in this version

type Replier

+ func (z *Replier) CallNotWait(functionName string, args ...interface{}) error

Jan 25, 2021

Changes in this version

type Replier

+ func R() *Replier

type Session

+ func S() *Session

type WebsocketResponse

+ IsReply bool

Dec 16, 2020

Changes in this version

type ConnectData

+ Caller *Replier

+ type NumberPool struct

+ func NewNumberPool(initNumber uint64) (ret NumberPool)

+ func (z *NumberPool) Get() uint64

+ func (z *NumberPool) Put(num uint64)

type Replier

+ func (z *Replier) ToCaller() *Replier

Nov 22, 2020

Changes in this version

+ const EventConnectionClose

Nov 22, 2020

Changes in this version

type WebsocketResponse

+ Data interface{}

+ Id jsoniter.Number

Nov 17, 2020

Changes in this version

+ const EventNewConnection

+ const EventNum

+ var NewConnectDataPool = sync.Pool

+ type ConnectData struct

+ Context *RWeb.Context

+ Session *Session

+ type Ranger func(data *ConnectData, replier *Replier) error

+ type Session struct

+ CreateTime int64

+ Data interface{}

+ func NewSession() *Session

type WebsocketDealer

+ Events event.System

+ func (z *WebsocketDealer) BroadCast(ranger Ranger) error

+ func (z *WebsocketDealer) BroadCastIdRange(ranger Ranger, ids []uint64) error

Nov 13, 2020

Changes in this version

+ var Once sync.Once

+ func InitWebsocketDealer()

+ type Replier struct

+ func (z *Replier) Call(functionName string, args ...interface{}) (interface{}, error)

+ func (z *Replier) Return(data interface{}) error

type StandardCall

+ Id uint64

+ IsReply bool

+ type StandardReply struct

+ Data interface{}

+ Id uint64

type WebsocketDealer

+ func (z *WebsocketDealer) BindReplyId(id uint64, c chan StandardReply)

+ func (z *WebsocketDealer) RemoveBindReplyId(id uint64)

+ type WebsocketResponse struct

Nov 9, 2020

Changes in this version

+ const ModuleName

+ const ModuleVersion

+ type Conn struct

+ type StandardCall struct

+ Argument []interface{}

+ Function string

+ type WebsocketDealFunction func(conn *Conn, arguments []interface{})

+ type WebsocketDealer struct

+ OriginCheck func(ctx *RWeb.Context) bool

+ func New() (r WebsocketDealer)

+ func (z *WebsocketDealer) BindFunction(FunctionName string, Function WebsocketDealFunction) error

+ func (z *WebsocketDealer) Handler(context *RWeb.Context)