Documentation ¶
Index ¶
- Variables
- func NewQuerier(view View) *querier
- type ListOption
- type ListOptions
- type Member
- func (m *Member) ID() string
- func (m *Member) LastConnectedAt() time.Time
- func (m *Member) LastMessageAt() time.Time
- func (m *Member) LastMessageID() int64
- func (m *Member) Restore(mm *MemberMemento) *Member
- func (m *Member) SetLastMessageAt(t time.Time)
- func (m *Member) SetLastMessageID(id int64)
- func (m *Member) SetOffline()
- func (m *Member) SetOnline()
- func (m *Member) Status() MemberStatus
- type MemberMemento
- type MemberStatus
- type Querier
- type Room
- func (r *Room) AddMember(username string) (*Member, error)
- func (r *Room) Close()
- func (r *Room) CreatedAt() time.Time
- func (r *Room) Events() []pubsub.Event
- func (r *Room) HasMember(id string) bool
- func (r *Room) ID() string
- func (r *Room) IsClosed() bool
- func (r *Room) IsOpened() bool
- func (r *Room) IsSecretKeyValid(secretKey string) bool
- func (r *Room) Members() []*Member
- func (r *Room) Name() string
- func (r *Room) Open()
- func (r *Room) RemoveMember(id string) error
- func (r *Room) Restore(rm *RoomMemento) *Room
- func (r *Room) SecretKey() string
- func (r *Room) Status() Status
- type RoomMemento
- type Status
- type Storage
- type View
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrEmptyRoomID = errors.New("empty room id") ErrEmptyRoomName = errors.New("empty room name") ErrEmptyRoomSecretKey = errors.New("empty room secret key") ErrRoomNotFound = errors.New("room not found") ErrRoomInsufficientMembers = errors.New("room has insufficient members") ErrRoomIsClosed = errors.New("room is closed") ErrRoomIsOpened = errors.New("room is opened") ErrRoomAlreadyExists = errors.New("room already exists") ErrRoomIsFull = errors.New("room is full") ErrEmptyMemberID = errors.New("empty member id") ErrMemberNotFound = errors.New("member not found") ErrMemberAlreadyJoined = errors.New("member already joined") ErrMemberNotJoined = errors.New("member not joined") ErrMemberNotInRoom = errors.New("member not in room") )
Functions ¶
func NewQuerier ¶
func NewQuerier(view View) *querier
Types ¶
type ListOption ¶
type ListOption func(*ListOptions)
func WithAsceding ¶
func WithAsceding(asceding bool) ListOption
func WithIDs ¶
func WithIDs(ids ...string) ListOption
func WithOrderBy ¶
func WithOrderBy(orderBy string) ListOption
type ListOptions ¶
type ListOptions struct {
// contains filtered or unexported fields
}
func (*ListOptions) Apply ¶
func (r *ListOptions) Apply(opts ...ListOption)
func (*ListOptions) Asceding ¶
func (o *ListOptions) Asceding() bool
func (*ListOptions) IDs ¶
func (o *ListOptions) IDs() []string
func (*ListOptions) OrderBy ¶
func (o *ListOptions) OrderBy() string
type Member ¶
type Member struct {
// contains filtered or unexported fields
}
func (*Member) LastConnectedAt ¶
func (*Member) LastMessageAt ¶
func (*Member) LastMessageID ¶
func (*Member) Restore ¶
func (m *Member) Restore(mm *MemberMemento) *Member
func (*Member) SetLastMessageAt ¶
func (*Member) SetLastMessageID ¶
func (*Member) SetOffline ¶
func (m *Member) SetOffline()
func (*Member) Status ¶
func (m *Member) Status() MemberStatus
type MemberMemento ¶
type MemberStatus ¶
type MemberStatus int32
const ( MemberStatusUnknown MemberStatus = iota MemberStatusOnline MemberStatusOffline )
type Room ¶
type Room struct {
// contains filtered or unexported fields
}
func (*Room) IsSecretKeyValid ¶
func (*Room) RemoveMember ¶
func (*Room) Restore ¶
func (r *Room) Restore(rm *RoomMemento) *Room
type RoomMemento ¶
Click to show internal directories.
Click to hide internal directories.