Documentation
¶
Index ¶
- type Repository
- func (r *Repository) Close() error
- func (r *Repository) EnrichMessages(ctx context.Context, messages []*model.Message) error
- func (r *Repository) GetChatRoom(ctx context.Context, key string) (*model.ChatRoom, error)
- func (r *Repository) GetChatRooms(ctx context.Context, key string, limit, offset int) ([]*model.ChatRoom, error)
- func (r *Repository) GetContact(ctx context.Context, key string) (*model.Contact, error)
- func (r *Repository) GetContacts(ctx context.Context, key string, limit, offset int) ([]*model.Contact, error)
- func (r *Repository) GetMedia(ctx context.Context, _type string, key string) (*model.Media, error)
- func (r *Repository) GetMessages(ctx context.Context, startTime, endTime time.Time, talker string, ...) ([]*model.Message, error)
- func (r *Repository) GetSessions(ctx context.Context, key string, limit, offset int) ([]*model.Session, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Repository ¶
type Repository struct {
// contains filtered or unexported fields
}
Repository 实现了 repository.Repository 接口
func (*Repository) EnrichMessages ¶
EnrichMessages 补充消息的额外信息
func (*Repository) GetChatRoom ¶
func (*Repository) GetChatRooms ¶
func (*Repository) GetContact ¶
func (*Repository) GetContacts ¶
func (*Repository) GetMessages ¶
func (r *Repository) GetMessages(ctx context.Context, startTime, endTime time.Time, talker string, sender string, keyword string, limit, offset int) ([]*model.Message, error)
GetMessages 实现 Repository 接口的 GetMessages 方法
func (*Repository) GetSessions ¶
Source Files
Click to show internal directories.
Click to hide internal directories.