user

Documentation

Index

• type ByAsc
  • func (a ByAsc) Len() int
  • func (a ByAsc) Less(i, j int) bool
  • func (a ByAsc) Swap(i, j int)
• type Group
  • func NewGroup(user IUser) *Group
• type GroupUser
  • func NewGroupUser() *GroupUser
  • func (groupUser *GroupUser) AddUser(user ...string)
  • func (groupUser *GroupUser) GetRawUser() map[string]any
• type History
• type HistoryMessage
• type HistoryStore
  • func NewHistoryStore() *HistoryStore
  • func (h *HistoryStore) FlashLiveTime(user IUser)
  • func (h *HistoryStore) RecordMessage(msg message.IMessage)
• type IOrderUser
• type IUser
• type Store
  • func NewStore() *Store
  • func (store *Store) AddUser(user IUser) bool
  • func (store *Store) DeleteUser(user IUser) bool
  • func (store *Store) FlashLiveTime(user IUser)
  • func (store *Store) GetHistory(username string) (*HistoryMessage, bool)
  • func (store *Store) GetOrderUser(username string) ([]IOrderUser, bool)
  • func (store *Store) GetUser(username string) ([]IUser, bool)
  • func (store *Store) GetUserNum() int
  • func (store *Store) QueryGroupsUser(groupIds ...string) *GroupUser
  • func (store *Store) Range(f func(username string, user *StoreUser) bool)
  • func (store *Store) RangeGroupUser(groupId string, f func(username string) bool)
  • func (store *Store) RecordMessage(msg message.IMessage)
  • func (store *Store) UserHasConn() bool
• type StoreGroup
  • func NewStoreGroup() *StoreGroup
  • func (storeGroup *StoreGroup) AddUser(user IUser)
  • func (storeGroup *StoreGroup) RangeUser(f func(string) bool)
  • func (storeGroup *StoreGroup) RemoteUser(user IUser)
• type StoreUser
  • func (u *StoreUser) GetCreateTime() string
  • func (u *StoreUser) GetGroupIds() []string
  • func (u *StoreUser) IsInGroup(group string) bool
• type TextMessage
• type TextMessageMessage
• type WriteCallBackFunc

Types

type ByAsc

type ByAsc []IOrderUser

func (ByAsc) Len

func (a ByAsc) Len() int

func (ByAsc) Less

func (a ByAsc) Less(i, j int) bool

func (ByAsc) Swap

func (a ByAsc) Swap(i, j int)

type Group

type Group struct {
	// contains filtered or unexported fields
}

func NewGroup

func NewGroup(user IUser) *Group

type GroupUser

type GroupUser struct {
	// contains filtered or unexported fields
}

func NewGroupUser

func NewGroupUser() *GroupUser

func (*GroupUser) AddUser

func (groupUser *GroupUser) AddUser(user ...string)

func (*GroupUser) GetRawUser

func (groupUser *GroupUser) GetRawUser() map[string]any

type History

type History struct {
	Username     string
	OnlineTime   *time.Time
	OfflineTime  *time.Time
	LastLiveTime *time.Time
	LastMessage  []*TextMessage
	// contains filtered or unexported fields
}

type HistoryMessage

type HistoryMessage struct {
	Username     string
	OnlineTime   string
	OfflineTime  string
	LastLiveTime string
	LastMessage  []*TextMessageMessage
}

type HistoryStore

type HistoryStore struct {
	// contains filtered or unexported fields
}

func NewHistoryStore

func NewHistoryStore() *HistoryStore

func (*HistoryStore) FlashLiveTime

func (h *HistoryStore) FlashLiveTime(user IUser)

func (*HistoryStore) RecordMessage

func (h *HistoryStore) RecordMessage(msg message.IMessage)

type IOrderUser

type IOrderUser interface {
	// WriteMessage 异步，代码里面不能阻塞
	WriteMessage(iMessage message.IMessage, writeFunc WriteCallBackFunc)
	GetPriority() int
	GetMachineId() string
	GetOrderTime() *time.Time
}

type IUser

type IUser interface {
	IOrderUser
	GetId() string
	Close()
	GetUsername() string
	GetGroupIds() []string
	GetRemoteAddress() string
	SetUsername(username string)
	LastLiveTime() *time.Time
	CreateTime() *time.Time
}

type Store

type Store struct {
	// contains filtered or unexported fields
}

func NewStore

func NewStore() *Store

func (*Store) AddUser

func (store *Store) AddUser(user IUser) bool

func (*Store) DeleteUser

func (store *Store) DeleteUser(user IUser) bool

func (*Store) FlashLiveTime

func (store *Store) FlashLiveTime(user IUser)

func (*Store) GetHistory

func (store *Store) GetHistory(username string) (*HistoryMessage, bool)

func (*Store) GetOrderUser

func (store *Store) GetOrderUser(username string) ([]IOrderUser, bool)

func (*Store) GetUser

func (store *Store) GetUser(username string) ([]IUser, bool)

func (*Store) GetUserNum

func (store *Store) GetUserNum() int

func (*Store) QueryGroupsUser

func (store *Store) QueryGroupsUser(groupIds ...string) *GroupUser

func (*Store) Range

func (store *Store) Range(f func(username string, user *StoreUser) bool)

func (*Store) RangeGroupUser

func (store *Store) RangeGroupUser(groupId string, f func(username string) bool)

func (*Store) RecordMessage

func (store *Store) RecordMessage(msg message.IMessage)

func (*Store) UserHasConn

func (store *Store) UserHasConn() bool

type StoreGroup

type StoreGroup struct {
	// contains filtered or unexported fields
}

func NewStoreGroup

func NewStoreGroup() *StoreGroup

func (*StoreGroup) AddUser

func (storeGroup *StoreGroup) AddUser(user IUser)

func (*StoreGroup) RangeUser

func (storeGroup *StoreGroup) RangeUser(f func(string) bool)

func (*StoreGroup) RemoteUser

func (storeGroup *StoreGroup) RemoteUser(user IUser)

type StoreUser

type StoreUser struct {
	// contains filtered or unexported fields
}

func (*StoreUser) GetCreateTime

func (u *StoreUser) GetCreateTime() string

func (*StoreUser) GetGroupIds

func (u *StoreUser) GetGroupIds() []string

func (*StoreUser) IsInGroup

func (u *StoreUser) IsInGroup(group string) bool

type TextMessage

type TextMessage struct {
	From string
	Msg  string
	Time *time.Time
}

type TextMessageMessage

type TextMessageMessage struct {
	From string
	Msg  string
	Time string
}

type WriteCallBackFunc

type WriteCallBackFunc func(err error, hasUser bool)