Documentation
¶
Index ¶
- type Config
- type OnlineOption
- type Option
- type Store
- func (s *Store) CleanupOffline() (int64, error)
- func (s *Store) EachOnlineUser(fn func(userId string) error) error
- func (s *Store) FilterOnlineUsers(userIDs []string) (map[string]float64, error)
- func (s *Store) Heartbeat(userId string) error
- func (s *Store) OnlineCount() (int64, error)
- func (s *Store) OnlineUsers(opts ...OnlineOption) ([]string, error)
- func (s *Store) SetOffline(userId string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OnlineOption ¶
OnlineOption 在线用户查询选项
type Option ¶
type Option func(*Config)
Option 配置选项函数
func WithOnlineTTLSeconds ¶
WithOnlineTTLSeconds 设置在线状态过期时间（秒）
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store 在线状态存储
func (*Store) CleanupOffline ¶
CleanupOffline 清理离线用户数据 返回清理的用户数量
func (*Store) EachOnlineUser ¶
EachOnlineUser 遍历所有在线用户
func (*Store) FilterOnlineUsers ¶
FilterOnlineUsers 从给定的用户ID列表中筛选出在线的用户 返回 map[userId]lastActiveTimestamp
func (*Store) OnlineUsers ¶
func (s *Store) OnlineUsers(opts ...OnlineOption) ([]string, error)
OnlineUsers 获取在线用户列表
Source Files
Click to show internal directories.
Click to hide internal directories.