local

package
v0.0.10 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 28, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewChannelStore 

func NewChannelStore() streaming.ChannelStore

NewChannelStore creates a new local channel store.

func NewMessageStore 

func NewMessageStore() streaming.MessageStore

NewMessageStore creates a new local message store.

func NewPresenceStore 

func NewPresenceStore() streaming.PresenceStore

NewPresenceStore creates a new local presence store.

func NewRoomStore 

func NewRoomStore() streaming.RoomStore

NewRoomStore creates a new local room store.

func NewTypingStore 

func NewTypingStore() streaming.TypingStore

NewTypingStore creates a new local typing store.

Types

type ChannelStore 

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

ChannelStore implements streaming.ChannelStore with in-memory storage.

func (*ChannelStore) AddSubscription 

func (s *ChannelStore) AddSubscription(ctx context.Context, channelID string, sub streaming.Subscription) error

func (*ChannelStore) Connect 

func (s *ChannelStore) Connect(ctx context.Context) error

func (*ChannelStore) Create 

func (s *ChannelStore) Create(ctx context.Context, channel streaming.Channel) error

func (*ChannelStore) Delete 

func (s *ChannelStore) Delete(ctx context.Context, channelID string) error

func (*ChannelStore) Disconnect 

func (s *ChannelStore) Disconnect(ctx context.Context) error

func (*ChannelStore) Exists 

func (s *ChannelStore) Exists(ctx context.Context, channelID string) (bool, error)

func (*ChannelStore) Get 

func (s *ChannelStore) Get(ctx context.Context, channelID string) (streaming.Channel, error)

func (*ChannelStore) GetSubscriberCount 

func (s *ChannelStore) GetSubscriberCount(ctx context.Context, channelID string) (int, error)

func (*ChannelStore) GetSubscriptions 

func (s *ChannelStore) GetSubscriptions(ctx context.Context, channelID string) ([]streaming.Subscription, error)

func (*ChannelStore) GetUserChannels 

func (s *ChannelStore) GetUserChannels(ctx context.Context, userID string) ([]streaming.Channel, error)

func (*ChannelStore) IsSubscribed 

func (s *ChannelStore) IsSubscribed(ctx context.Context, channelID, connID string) (bool, error)

func (*ChannelStore) List 

func (s *ChannelStore) List(ctx context.Context) ([]streaming.Channel, error)

func (*ChannelStore) Ping 

func (s *ChannelStore) Ping(ctx context.Context) error

func (*ChannelStore) Publish 

func (s *ChannelStore) Publish(ctx context.Context, channelID string, message *streaming.Message) error

func (*ChannelStore) RemoveSubscription 

func (s *ChannelStore) RemoveSubscription(ctx context.Context, channelID, connID string) error

type LocalChannel 

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

LocalChannel implements streaming.Channel

func NewLocalChannel 

func NewLocalChannel(opts streaming.ChannelOptions) *LocalChannel

func (*LocalChannel) Delete 

func (c *LocalChannel) Delete(ctx context.Context) error

func (*LocalChannel) GetCreated 

func (c *LocalChannel) GetCreated() time.Time

func (*LocalChannel) GetID 

func (c *LocalChannel) GetID() string

func (*LocalChannel) GetMessageCount 

func (c *LocalChannel) GetMessageCount() int64

func (*LocalChannel) GetName 

func (c *LocalChannel) GetName() string

func (*LocalChannel) GetSubscriberCount 

func (c *LocalChannel) GetSubscriberCount(ctx context.Context) (int, error)

func (*LocalChannel) GetSubscribers 

func (c *LocalChannel) GetSubscribers(ctx context.Context) ([]streaming.Subscription, error)

func (*LocalChannel) IsSubscribed 

func (c *LocalChannel) IsSubscribed(ctx context.Context, connID string) (bool, error)

func (*LocalChannel) Publish 

func (c *LocalChannel) Publish(ctx context.Context, message *streaming.Message) error

func (*LocalChannel) Subscribe 

func (c *LocalChannel) Subscribe(ctx context.Context, sub streaming.Subscription) error

func (*LocalChannel) Unsubscribe 

func (c *LocalChannel) Unsubscribe(ctx context.Context, connID string) error

type LocalMember 

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

LocalMember implements streaming.Member

func NewLocalMember 

func NewLocalMember(opts streaming.MemberOptions) *LocalMember

func (*LocalMember) GetJoinedAt 

func (m *LocalMember) GetJoinedAt() time.Time

func (*LocalMember) GetMetadata 

func (m *LocalMember) GetMetadata() map[string]any

func (*LocalMember) GetPermissions 

func (m *LocalMember) GetPermissions() []string

func (*LocalMember) GetRole 

func (m *LocalMember) GetRole() string

func (*LocalMember) GetUserID 

func (m *LocalMember) GetUserID() string

func (*LocalMember) GrantPermission 

func (m *LocalMember) GrantPermission(permission string)

func (*LocalMember) HasPermission 

func (m *LocalMember) HasPermission(permission string) bool

func (*LocalMember) RevokePermission 

func (m *LocalMember) RevokePermission(permission string)

func (*LocalMember) SetMetadata 

func (m *LocalMember) SetMetadata(key string, value any)

func (*LocalMember) SetRole 

func (m *LocalMember) SetRole(role string)

type LocalRoom 

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

Room implements streaming.Room for local backend

func NewRoom 

func NewRoom(opts streaming.RoomOptions) *LocalRoom

func (*LocalRoom) AddTag 

func (r *LocalRoom) AddTag(ctx context.Context, tag string) error

func (*LocalRoom) Archive 

func (r *LocalRoom) Archive(ctx context.Context) error

func (*LocalRoom) BanMember 

func (r *LocalRoom) BanMember(ctx context.Context, userID string, reason string, until *time.Time) error

func (*LocalRoom) Broadcast 

func (r *LocalRoom) Broadcast(ctx context.Context, message *streaming.Message) error

func (*LocalRoom) BroadcastExcept 

func (r *LocalRoom) BroadcastExcept(ctx context.Context, message *streaming.Message, excludeUserIDs []string) error

func (*LocalRoom) BroadcastToRole 

func (r *LocalRoom) BroadcastToRole(ctx context.Context, message *streaming.Message, role string) error

func (*LocalRoom) CreateInvite 

func (r *LocalRoom) CreateInvite(ctx context.Context, opts streaming.InviteOptions) (*streaming.Invite, error)

func (*LocalRoom) Delete 

func (r *LocalRoom) Delete(ctx context.Context) error

func (*LocalRoom) GetActiveMembers 

func (r *LocalRoom) GetActiveMembers(ctx context.Context, since time.Duration) ([]streaming.Member, error)

func (*LocalRoom) GetBannedMembers 

func (r *LocalRoom) GetBannedMembers(ctx context.Context) ([]streaming.RoomBan, error)

func (*LocalRoom) GetCategory 

func (r *LocalRoom) GetCategory() string

func (*LocalRoom) GetCreated 

func (r *LocalRoom) GetCreated() time.Time

func (*LocalRoom) GetDescription 

func (r *LocalRoom) GetDescription() string

func (*LocalRoom) GetID 

func (r *LocalRoom) GetID() string

func (*LocalRoom) GetInvites 

func (r *LocalRoom) GetInvites(ctx context.Context) ([]*streaming.Invite, error)

func (*LocalRoom) GetLastReadMessage 

func (r *LocalRoom) GetLastReadMessage(ctx context.Context, userID string) (string, error)

func (*LocalRoom) GetMaxMembers 

func (r *LocalRoom) GetMaxMembers() int

func (*LocalRoom) GetMember 

func (r *LocalRoom) GetMember(ctx context.Context, userID string) (streaming.Member, error)

func (*LocalRoom) GetMembers 

func (r *LocalRoom) GetMembers(ctx context.Context) ([]streaming.Member, error)

func (*LocalRoom) GetMembersByRole 

func (r *LocalRoom) GetMembersByRole(ctx context.Context, role string) ([]streaming.Member, error)

func (*LocalRoom) GetMessageCount 

func (r *LocalRoom) GetMessageCount(ctx context.Context) (int64, error)

func (*LocalRoom) GetMetadata 

func (r *LocalRoom) GetMetadata() map[string]any

func (*LocalRoom) GetModerationLog 

func (r *LocalRoom) GetModerationLog(ctx context.Context, limit int) ([]streaming.ModerationEvent, error)

func (*LocalRoom) GetName 

func (r *LocalRoom) GetName() string

func (*LocalRoom) GetOwner 

func (r *LocalRoom) GetOwner() string

func (*LocalRoom) GetPinnedMessages 

func (r *LocalRoom) GetPinnedMessages(ctx context.Context) ([]string, error)

func (*LocalRoom) GetSlowMode 

func (r *LocalRoom) GetSlowMode(ctx context.Context) int

func (*LocalRoom) GetTags 

func (r *LocalRoom) GetTags() []string

func (*LocalRoom) GetUnreadCount 

func (r *LocalRoom) GetUnreadCount(ctx context.Context, userID string, since time.Time) (int, error)

func (*LocalRoom) GetUpdated 

func (r *LocalRoom) GetUpdated() time.Time

func (*LocalRoom) GrantPermission 

func (r *LocalRoom) GrantPermission(ctx context.Context, userID, permission string) error

func (*LocalRoom) HasPermission 

func (r *LocalRoom) HasPermission(ctx context.Context, userID, permission string) (bool, error)

func (*LocalRoom) IsArchived 

func (r *LocalRoom) IsArchived() bool

func (*LocalRoom) IsBanned 

func (r *LocalRoom) IsBanned(ctx context.Context, userID string) (bool, error)

func (*LocalRoom) IsLocked 

func (r *LocalRoom) IsLocked() bool

func (*LocalRoom) IsMember 

func (r *LocalRoom) IsMember(ctx context.Context, userID string) (bool, error)

func (*LocalRoom) IsMuted 

func (r *LocalRoom) IsMuted(ctx context.Context, userID string) (bool, error)

func (*LocalRoom) IsPrivate 

func (r *LocalRoom) IsPrivate() bool

func (*LocalRoom) Join 

func (r *LocalRoom) Join(ctx context.Context, userID, role string) error

func (*LocalRoom) JoinWithInvite 

func (r *LocalRoom) JoinWithInvite(ctx context.Context, userID, inviteCode string) error

func (*LocalRoom) Leave 

func (r *LocalRoom) Leave(ctx context.Context, userID string) error

func (*LocalRoom) Lock 

func (r *LocalRoom) Lock(ctx context.Context, reason string) error

func (*LocalRoom) MarkAsRead 

func (r *LocalRoom) MarkAsRead(ctx context.Context, userID, messageID string) error

func (*LocalRoom) MemberCount 

func (r *LocalRoom) MemberCount(ctx context.Context) (int, error)

func (*LocalRoom) MuteMember 

func (r *LocalRoom) MuteMember(ctx context.Context, userID string, duration time.Duration) error

func (*LocalRoom) PinMessage 

func (r *LocalRoom) PinMessage(ctx context.Context, messageID string) error

func (*LocalRoom) RemoveTag 

func (r *LocalRoom) RemoveTag(ctx context.Context, tag string) error

func (*LocalRoom) RevokeInvite 

func (r *LocalRoom) RevokeInvite(ctx context.Context, inviteCode string) error

func (*LocalRoom) RevokePermission 

func (r *LocalRoom) RevokePermission(ctx context.Context, userID, permission string) error

func (*LocalRoom) SetCategory 

func (r *LocalRoom) SetCategory(ctx context.Context, category string) error

func (*LocalRoom) SetMaxMembers 

func (r *LocalRoom) SetMaxMembers(ctx context.Context, max int) error

func (*LocalRoom) SetPrivate 

func (r *LocalRoom) SetPrivate(ctx context.Context, private bool) error

func (*LocalRoom) SetSlowMode 

func (r *LocalRoom) SetSlowMode(ctx context.Context, intervalSeconds int) error

func (*LocalRoom) TransferOwnership 

func (r *LocalRoom) TransferOwnership(ctx context.Context, newOwnerID string) error

func (*LocalRoom) Unarchive 

func (r *LocalRoom) Unarchive(ctx context.Context) error

func (*LocalRoom) UnbanMember 

func (r *LocalRoom) UnbanMember(ctx context.Context, userID string) error

func (*LocalRoom) Unlock 

func (r *LocalRoom) Unlock(ctx context.Context) error

func (*LocalRoom) UnmuteMember 

func (r *LocalRoom) UnmuteMember(ctx context.Context, userID string) error

func (*LocalRoom) UnpinMessage 

func (r *LocalRoom) UnpinMessage(ctx context.Context, messageID string) error

func (*LocalRoom) Update 

func (r *LocalRoom) Update(ctx context.Context, updates map[string]any) error

func (*LocalRoom) UpdateMemberRole 

func (r *LocalRoom) UpdateMemberRole(ctx context.Context, userID, newRole string) error

func (*LocalRoom) ValidateInvite 

func (r *LocalRoom) ValidateInvite(ctx context.Context, inviteCode string) (bool, error)

type LocalSubscription 

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

LocalSubscription implements streaming.Subscription

func NewLocalSubscription 

func NewLocalSubscription(opts streaming.SubscriptionOptions) *LocalSubscription

func (*LocalSubscription) GetConnID 

func (s *LocalSubscription) GetConnID() string

func (*LocalSubscription) GetFilters 

func (s *LocalSubscription) GetFilters() map[string]any

func (*LocalSubscription) GetSubscribedAt 

func (s *LocalSubscription) GetSubscribedAt() time.Time

func (*LocalSubscription) GetUserID 

func (s *LocalSubscription) GetUserID() string

func (*LocalSubscription) MatchesFilter 

func (s *LocalSubscription) MatchesFilter(message *streaming.Message) bool

func (*LocalSubscription) SetFilters 

func (s *LocalSubscription) SetFilters(filters map[string]any)

type MessageStore 

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

MessageStore implements streaming.MessageStore with in-memory storage.

func (*MessageStore) Connect 

func (s *MessageStore) Connect(ctx context.Context) error

func (*MessageStore) Delete 

func (s *MessageStore) Delete(ctx context.Context, messageID string) error

func (*MessageStore) DeleteByRoom 

func (s *MessageStore) DeleteByRoom(ctx context.Context, roomID string) error

func (*MessageStore) DeleteByUser 

func (s *MessageStore) DeleteByUser(ctx context.Context, userID string) error

func (*MessageStore) DeleteOld 

func (s *MessageStore) DeleteOld(ctx context.Context, olderThan time.Duration) error

func (*MessageStore) Disconnect 

func (s *MessageStore) Disconnect(ctx context.Context) error

func (*MessageStore) Get 

func (s *MessageStore) Get(ctx context.Context, messageID string) (*streaming.Message, error)

func (*MessageStore) GetHistory 

func (s *MessageStore) GetHistory(ctx context.Context, roomID string, query streaming.HistoryQuery) ([]*streaming.Message, error)

func (*MessageStore) GetMessageCount 

func (s *MessageStore) GetMessageCount(ctx context.Context, roomID string) (int64, error)

func (*MessageStore) GetMessageCountByUser 

func (s *MessageStore) GetMessageCountByUser(ctx context.Context, roomID, userID string) (int64, error)

func (*MessageStore) GetThreadHistory 

func (s *MessageStore) GetThreadHistory(ctx context.Context, roomID, threadID string, query streaming.HistoryQuery) ([]*streaming.Message, error)

func (*MessageStore) GetUserMessages 

func (s *MessageStore) GetUserMessages(ctx context.Context, userID string, query streaming.HistoryQuery) ([]*streaming.Message, error)

func (*MessageStore) Ping 

func (s *MessageStore) Ping(ctx context.Context) error

func (*MessageStore) Save 

func (s *MessageStore) Save(ctx context.Context, message *streaming.Message) error

func (*MessageStore) SaveBatch 

func (s *MessageStore) SaveBatch(ctx context.Context, messages []*streaming.Message) error

func (*MessageStore) Search 

func (s *MessageStore) Search(ctx context.Context, roomID, searchTerm string, query streaming.HistoryQuery) ([]*streaming.Message, error)

type PresenceStore 

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

PresenceStore implements streaming.PresenceStore with in-memory storage.

func (*PresenceStore) CleanupExpired 

func (s *PresenceStore) CleanupExpired(ctx context.Context, olderThan time.Duration) error

func (*PresenceStore) Connect 

func (s *PresenceStore) Connect(ctx context.Context) error

func (*PresenceStore) CountByStatus 

func (s *PresenceStore) CountByStatus(ctx context.Context) (map[string]int, error)

func (*PresenceStore) Delete 

func (s *PresenceStore) Delete(ctx context.Context, userID string) error

func (*PresenceStore) DeleteMultiple 

func (s *PresenceStore) DeleteMultiple(ctx context.Context, userIDs []string) error

func (*PresenceStore) Disconnect 

func (s *PresenceStore) Disconnect(ctx context.Context) error

func (*PresenceStore) Get 

func (s *PresenceStore) Get(ctx context.Context, userID string) (*streaming.UserPresence, error)

func (*PresenceStore) GetActiveCount 

func (s *PresenceStore) GetActiveCount(ctx context.Context, since time.Duration) (int, error)

func (*PresenceStore) GetByStatus 

func (s *PresenceStore) GetByStatus(ctx context.Context, status string) ([]*streaming.UserPresence, error)

func (*PresenceStore) GetDevices 

func (s *PresenceStore) GetDevices(ctx context.Context, userID string) ([]streaming.DeviceInfo, error)

func (*PresenceStore) GetHistory 

func (s *PresenceStore) GetHistory(ctx context.Context, userID string, limit int) ([]*streaming.PresenceEvent, error)

func (*PresenceStore) GetHistorySince 

func (s *PresenceStore) GetHistorySince(ctx context.Context, userID string, since time.Time) ([]*streaming.PresenceEvent, error)

func (*PresenceStore) GetLastActivity 

func (s *PresenceStore) GetLastActivity(ctx context.Context, userID string) (time.Time, error)

func (*PresenceStore) GetMultiple 

func (s *PresenceStore) GetMultiple(ctx context.Context, userIDs []string) ([]*streaming.UserPresence, error)

func (*PresenceStore) GetOnline 

func (s *PresenceStore) GetOnline(ctx context.Context) ([]string, error)

func (*PresenceStore) GetRecent 

func (s *PresenceStore) GetRecent(ctx context.Context, status string, since time.Duration) ([]*streaming.UserPresence, error)

func (*PresenceStore) GetWithFilters 

func (s *PresenceStore) GetWithFilters(ctx context.Context, filters streaming.PresenceFilters) ([]*streaming.UserPresence, error)

func (*PresenceStore) IsOnline 

func (s *PresenceStore) IsOnline(ctx context.Context, userID string) (bool, error)

func (*PresenceStore) Ping 

func (s *PresenceStore) Ping(ctx context.Context) error

func (*PresenceStore) RemoveDevice 

func (s *PresenceStore) RemoveDevice(ctx context.Context, userID, deviceID string) error

func (*PresenceStore) SaveHistory 

func (s *PresenceStore) SaveHistory(ctx context.Context, userID string, event *streaming.PresenceEvent) error

func (*PresenceStore) Set 

func (s *PresenceStore) Set(ctx context.Context, userID string, presence *streaming.UserPresence) error

func (*PresenceStore) SetDevice 

func (s *PresenceStore) SetDevice(ctx context.Context, userID, deviceID string, device streaming.DeviceInfo) error

func (*PresenceStore) SetMultiple 

func (s *PresenceStore) SetMultiple(ctx context.Context, presences map[string]*streaming.UserPresence) error

func (*PresenceStore) SetOffline 

func (s *PresenceStore) SetOffline(ctx context.Context, userID string) error

func (*PresenceStore) SetOnline 

func (s *PresenceStore) SetOnline(ctx context.Context, userID string, ttl time.Duration) error

func (*PresenceStore) UpdateActivity 

func (s *PresenceStore) UpdateActivity(ctx context.Context, userID string, timestamp time.Time) error

type RoomStore 

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

RoomStore implements streaming.RoomStore with in-memory storage.

func (*RoomStore) AddMember 

func (s *RoomStore) AddMember(ctx context.Context, roomID string, member streaming.Member) error

func (*RoomStore) BanMember 

func (s *RoomStore) BanMember(ctx context.Context, roomID, userID string, ban streaming.RoomBan) error

func (*RoomStore) Connect 

func (s *RoomStore) Connect(ctx context.Context) error

func (*RoomStore) Create 

func (s *RoomStore) Create(ctx context.Context, room streaming.Room) error

func (*RoomStore) CreateMany 

func (s *RoomStore) CreateMany(ctx context.Context, rooms []streaming.Room) error

func (*RoomStore) Delete 

func (s *RoomStore) Delete(ctx context.Context, roomID string) error

func (*RoomStore) DeleteInvite 

func (s *RoomStore) DeleteInvite(ctx context.Context, inviteCode string) error

func (*RoomStore) DeleteMany 

func (s *RoomStore) DeleteMany(ctx context.Context, roomIDs []string) error

func (*RoomStore) Disconnect 

func (s *RoomStore) Disconnect(ctx context.Context) error

func (*RoomStore) Exists 

func (s *RoomStore) Exists(ctx context.Context, roomID string) (bool, error)

func (*RoomStore) FindByCategory 

func (s *RoomStore) FindByCategory(ctx context.Context, category string) ([]streaming.Room, error)

func (*RoomStore) FindByTag 

func (s *RoomStore) FindByTag(ctx context.Context, tag string) ([]streaming.Room, error)

func (*RoomStore) Get 

func (s *RoomStore) Get(ctx context.Context, roomID string) (streaming.Room, error)

func (*RoomStore) GetArchivedRooms 

func (s *RoomStore) GetArchivedRooms(ctx context.Context, userID string) ([]streaming.Room, error)

func (*RoomStore) GetBans 

func (s *RoomStore) GetBans(ctx context.Context, roomID string) ([]streaming.RoomBan, error)

func (*RoomStore) GetCommonRooms 

func (s *RoomStore) GetCommonRooms(ctx context.Context, userID1, userID2 string) ([]streaming.Room, error)

func (*RoomStore) GetInvite 

func (s *RoomStore) GetInvite(ctx context.Context, inviteCode string) (*streaming.Invite, error)

func (*RoomStore) GetMember 

func (s *RoomStore) GetMember(ctx context.Context, roomID, userID string) (streaming.Member, error)

func (*RoomStore) GetMembers 

func (s *RoomStore) GetMembers(ctx context.Context, roomID string) ([]streaming.Member, error)

func (*RoomStore) GetPublicRooms 

func (s *RoomStore) GetPublicRooms(ctx context.Context, limit int) ([]streaming.Room, error)

func (*RoomStore) GetRoomCount 

func (s *RoomStore) GetRoomCount(ctx context.Context) (int, error)

func (*RoomStore) GetTotalMembers 

func (s *RoomStore) GetTotalMembers(ctx context.Context) (int, error)

func (*RoomStore) GetUserRooms 

func (s *RoomStore) GetUserRooms(ctx context.Context, userID string) ([]streaming.Room, error)

func (*RoomStore) GetUserRoomsByRole 

func (s *RoomStore) GetUserRoomsByRole(ctx context.Context, userID, role string) ([]streaming.Room, error)

func (*RoomStore) IsBanned 

func (s *RoomStore) IsBanned(ctx context.Context, roomID, userID string) (bool, error)

func (*RoomStore) IsMember 

func (s *RoomStore) IsMember(ctx context.Context, roomID, userID string) (bool, error)

func (*RoomStore) List 

func (s *RoomStore) List(ctx context.Context, filters map[string]any) ([]streaming.Room, error)

func (*RoomStore) ListInvites 

func (s *RoomStore) ListInvites(ctx context.Context, roomID string) ([]*streaming.Invite, error)

func (*RoomStore) MemberCount 

func (s *RoomStore) MemberCount(ctx context.Context, roomID string) (int, error)

func (*RoomStore) Ping 

func (s *RoomStore) Ping(ctx context.Context) error

func (*RoomStore) RemoveMember 

func (s *RoomStore) RemoveMember(ctx context.Context, roomID, userID string) error

func (*RoomStore) SaveInvite 

func (s *RoomStore) SaveInvite(ctx context.Context, roomID string, invite *streaming.Invite) error

func (*RoomStore) Search 

func (s *RoomStore) Search(ctx context.Context, query string, filters map[string]any) ([]streaming.Room, error)

func (*RoomStore) UnbanMember 

func (s *RoomStore) UnbanMember(ctx context.Context, roomID, userID string) error

func (*RoomStore) Update 

func (s *RoomStore) Update(ctx context.Context, roomID string, updates map[string]any) error

type TypingStore 

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

TypingStore implements streaming.TypingStore with in-memory storage.

func (*TypingStore) CleanupExpired 

func (s *TypingStore) CleanupExpired(ctx context.Context) error

func (*TypingStore) Connect 

func (s *TypingStore) Connect(ctx context.Context) error

func (*TypingStore) Disconnect 

func (s *TypingStore) Disconnect(ctx context.Context) error

func (*TypingStore) GetTypingUsers 

func (s *TypingStore) GetTypingUsers(ctx context.Context, roomID string) ([]string, error)

func (*TypingStore) IsTyping 

func (s *TypingStore) IsTyping(ctx context.Context, userID, roomID string) (bool, error)

func (*TypingStore) Ping 

func (s *TypingStore) Ping(ctx context.Context) error

func (*TypingStore) RemoveTyping 

func (s *TypingStore) RemoveTyping(ctx context.Context, userID, roomID string) error

func (*TypingStore) SetTyping 

func (s *TypingStore) SetTyping(ctx context.Context, userID, roomID string, expiresAt time.Time) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.