Documentation ¶
Index ¶
Constants ¶
View Source
const ( //DB DB DB = "im" //TableMessage TableMessage TableMessage = "message" //TableSeq TableSeq TableSeq = "message_seq" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MongoStorage ¶
type MongoStorage struct {
// contains filtered or unexported fields
}
MongoStorage MongoStorage
func NewMongoStorage ¶
func NewMongoStorage(url string) *MongoStorage
NewMongoStorage NewMongoStorage
type Storage ¶
type Storage interface { Store(message *pr.Message) (isNew bool, err error) Fetch(topicID string, minSID int64, maxCount int64) ([]*pr.Message, int64, error) }
Storage Storage
Click to show internal directories.
Click to hide internal directories.