Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Hook ¶
type Hook struct {
// contains filtered or unexported fields
}
func NewHook ¶
func NewHook( config Kernel.RethinkConfig, chatRoomID string, getRelation func(string) []string, metadataGenerator func(*talk.DatabaseMessage) interface{}, messageboxNotFoundHandler func(string) bool, ) *Hook
func (*Hook) GetMessagebox ¶
func (hook *Hook) GetMessagebox(relatedID string, target string) *Messagebox
func (*Hook) MessageTrigger ¶
func (hook *Hook) MessageTrigger(message *talk.DatabaseMessage)
func (*Hook) SeenTrigger ¶
func (hook *Hook) SeenTrigger(relatedID string, message *talk.DatabaseMessage)
type Manager ¶
type Manager struct {
Data
}
func NewManager ¶
func NewManager(config Kernel.RethinkConfig, listenerID string) *Manager
type Messagebox ¶
type Messagebox struct { CreatedTime int64 `rethinkdb:"createdTime" json:"createdTime"` LastSeen int64 `rethinkdb:"lastSeen" json:"lastSeen"` Metadata interface{} `rethinkdb:"metadata" json:"metadata"` Origin string `rethinkdb:"origin" json:"origin"` Target string `rethinkdb:"target" json:"target"` }
type MessageboxForNew ¶
type MessageboxForUpdateSeen ¶
type Seen ¶
type Seen struct {
Data
}
func NewSeen ¶
func NewSeen(config Kernel.RethinkConfig) *Seen
type Service ¶
Service: this is the struct of Messagebox Service.
func (*Service) CheckPermission ¶
CheckPermission: check the permission of client.
func (*Service) DeleteMessagebox ¶
DeleteMessagebox: delete a messagebox by the request of client.
func (*Service) Fetch ¶
Fetch: do the fetch for data, if there is a change in database, it will throw the event out.
func (*Service) SyncMessagebox ¶
SyncMessagebox: get the history messageboxes for client.
type ServiceInterface ¶
type ServiceInterface interface { Kernel.ServiceInterface SyncMessagebox(*Kernel.Request) DeleteMessagebox(*Kernel.Request) }
func NewServiceInterface ¶
func NewServiceInterface( messageBoxConfig Kernel.RethinkConfig, syncExtraDataAssigner func(SyncMessagebox) interface{}, listenerID string, ) ServiceInterface
NewServiceInterface: create service interface of Messagebox.
type SyncMessagebox ¶
type SyncMessagebox struct { Messagebox ExtraData interface{} `json:"extraData"` }
Click to show internal directories.
Click to hide internal directories.