Documentation
¶
Index ¶
- type AuthRequest
- type InternalHandler
- type MessageHandler
- func (d *MessageHandler) AddHandler(i messaging.MessageHandler)
- func (d *MessageHandler) Handle(cInfo *gate.Info, msg *messages.GlideMessage) error
- func (d MessageHandler) InitDefaultHandler(...)
- func (d *MessageHandler) SetAuthorize(a auth.Interface)
- func (d *MessageHandler) SetGate(g gate.Gateway)
- func (d *MessageHandler) SetOfflineMessageHandler(fn func(h *MessageHandler, ci *gate.Info, m *messages.GlideMessage))
- func (d *MessageHandler) SetSubscription(s subscription.Interface)
- type Options
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AuthRequest ¶
type AuthRequest struct {
}
type InternalHandler ¶ added in v1.3.0
type InternalHandler struct {
}
func (*InternalHandler) Handle ¶ added in v1.3.0
func (c *InternalHandler) Handle(h *messaging.MessageInterfaceImpl, cliInfo *gate.Info, message *messages.GlideMessage) bool
type MessageHandler ¶
type MessageHandler struct {
// contains filtered or unexported fields
}
MessageHandler .
func NewHandler ¶
func NewHandler(store store.MessageStore, auth auth.Interface) (*MessageHandler, error)
func NewHandlerWithOptions ¶ added in v1.3.2
func NewHandlerWithOptions(opts *Options) (*MessageHandler, error)
func (*MessageHandler) AddHandler ¶ added in v1.2.1
func (d *MessageHandler) AddHandler(i messaging.MessageHandler)
func (*MessageHandler) Handle ¶
func (d *MessageHandler) Handle(cInfo *gate.Info, msg *messages.GlideMessage) error
func (MessageHandler) InitDefaultHandler ¶ added in v1.3.2
func (d MessageHandler) InitDefaultHandler(callback func(action messages.Action, fn messaging.HandlerFunc) messaging.HandlerFunc)
InitDefaultHandler add all default action handler. The action and HandlerFunc will pass to callback, the return value of callback will set as action handler, callback can be nil.
func (*MessageHandler) SetAuthorize ¶
func (d *MessageHandler) SetAuthorize(a auth.Interface)
func (*MessageHandler) SetGate ¶
func (d *MessageHandler) SetGate(g gate.Gateway)
func (*MessageHandler) SetOfflineMessageHandler ¶ added in v1.3.2
func (d *MessageHandler) SetOfflineMessageHandler(fn func(h *MessageHandler, ci *gate.Info, m *messages.GlideMessage))
SetOfflineMessageHandler called while client is offline
func (*MessageHandler) SetSubscription ¶ added in v1.2.1
func (d *MessageHandler) SetSubscription(s subscription.Interface)
type Options ¶ added in v1.3.2
type Options struct {
// MessageStore chat message store
MessageStore store.MessageStore
// OfflineHandleFn client offline, handle message
OfflineHandleFn func(h *MessageHandler, ci *gate.Info, pushMessage *messages.GlideMessage)
// Auth used for client auth action handler messages.ActionApiAuth
Auth auth.Interface
// DontInitDefaultHandler true will not init default action handler, MessageHandler.InitDefaultHandler
DontInitDefaultHandler bool
// NotifyOnErr true express notify client on server error.
NotifyOnErr bool
}
Source Files
Click to show internal directories.
Click to hide internal directories.