Documentation ¶
Index ¶
- func EnqueueChanUuids(channelName, channelId string, isDel bool, uuids []string)
- func EnqueueMsg(channel, msg, uuid string, ts, msgId int64)
- func FetchHistory(channel string, ts int64) (result []interface{}, err error)
- func FetchUuidsAboutChannel(channelId string) []string
- func Init()
- func Serv()
- type Cache
- type ChanUuidsTuple
- type MongoStorage
- type MsgTuple
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EnqueueChanUuids ¶
func EnqueueMsg ¶
func FetchHistory ¶
func FetchUuidsAboutChannel ¶
Types ¶
type Cache ¶
type Cache struct {
// contains filtered or unexported fields
}
var (
MsgCache *Cache
)
type ChanUuidsTuple ¶
type MongoStorage ¶
type MongoStorage struct { }
Click to show internal directories.
Click to hide internal directories.