Documentation
¶
Index ¶
- type Config
- type ServiceConfig
- func (self *ServiceConfig) Cache() msgcache.Cache
- func (self *ServiceConfig) CacheMessage(username string, mc *rpc.MessageContainer, ttl time.Duration) (string, error)
- func (self *ServiceConfig) OnError(c connDescriptor, err error)
- func (self *ServiceConfig) OnLogin(c connDescriptor)
- func (self *ServiceConfig) OnLogout(c connDescriptor, reason error)
- func (self *ServiceConfig) OnMessage(c connDescriptor, msg *rpc.Message)
- func (self *ServiceConfig) Push(username, senderService, senderName string, info map[string]string, ...)
- func (self *ServiceConfig) ShouldForward(fwdreq *rpc.ForwardRequest) (shouldForward, shouldPush bool, pushInfo map[string]string)
- func (self *ServiceConfig) Subscribe(req *rpc.SubscribeRequest)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
HandshakeTimeout time.Duration
HttpAddr string
Auth evthandler.Authenticator
ErrorHandler evthandler.ErrorHandler
// contains filtered or unexported fields
}
func (*Config) AllServices ¶
func (*Config) Authenticate ¶
func (*Config) ReadConfig ¶
func (self *Config) ReadConfig(srv string) *ServiceConfig
type ServiceConfig ¶
type ServiceConfig struct {
ServiceName string
MaxNrConns int
MaxNrUsers int
MaxNrConnsPerUser int
MsgCache msgcache.Cache
LoginHandler evthandler.LoginHandler
LogoutHandler evthandler.LogoutHandler
MessageHandler evthandler.MessageHandler
ForwardRequestHandler evthandler.ForwardRequestHandler
ErrorHandler evthandler.ErrorHandler
// Push related web hooks
SubscribeHandler evthandler.SubscribeHandler
UnsubscribeHandler evthandler.UnsubscribeHandler
PushService push.Push
}
func (*ServiceConfig) Cache ¶
func (self *ServiceConfig) Cache() msgcache.Cache
func (*ServiceConfig) CacheMessage ¶
func (self *ServiceConfig) CacheMessage(username string, mc *rpc.MessageContainer, ttl time.Duration) (string, error)
func (*ServiceConfig) OnError ¶
func (self *ServiceConfig) OnError(c connDescriptor, err error)
func (*ServiceConfig) OnLogin ¶
func (self *ServiceConfig) OnLogin(c connDescriptor)
func (*ServiceConfig) OnLogout ¶
func (self *ServiceConfig) OnLogout(c connDescriptor, reason error)
func (*ServiceConfig) OnMessage ¶
func (self *ServiceConfig) OnMessage(c connDescriptor, msg *rpc.Message)
func (*ServiceConfig) ShouldForward ¶
func (self *ServiceConfig) ShouldForward(fwdreq *rpc.ForwardRequest) (shouldForward, shouldPush bool, pushInfo map[string]string)
func (*ServiceConfig) Subscribe ¶
func (self *ServiceConfig) Subscribe(req *rpc.SubscribeRequest)
Source Files
Click to show internal directories.
Click to hide internal directories.