Versions in this module Expand all Collapse all v0 v0.1.0 Jul 5, 2026 Changes in this version + type Store struct + func Open(dbURL string) (*Store, error) + func (s *Store) AddReaction(ctx context.Context, input store.CreateReactionInput) (store.Event, error) + func (s *Store) AddWorkspaceMember(ctx context.Context, workspaceID, userID, role string) error + func (s *Store) AttachUpload(ctx context.Context, input store.AttachUploadInput) (store.Event, error) + func (s *Store) Backup(ctx context.Context, outPath string) error + func (s *Store) CanCreateUpload(ctx context.Context, workspaceID, userID string, byteSize int64) error + func (s *Store) CanPublishEphemeral(ctx context.Context, ...) error + func (s *Store) Close() error + func (s *Store) CompleteSlashCommandInvocation(ctx context.Context, invocationID string, status int, ...) (store.SlashCommandInvocation, error) + func (s *Store) ConsumeMagicLink(ctx context.Context, token string) (store.User, store.Session, error) + func (s *Store) CreateAppInstallation(ctx context.Context, input store.CreateAppInstallationInput) (store.AppInstallation, error) + func (s *Store) CreateAuditLogEntry(ctx context.Context, input store.CreateAuditLogEntryInput) (store.AuditLogEntry, error) + func (s *Store) CreateBot(ctx context.Context, input store.CreateBotInput) (store.User, store.BotToken, error) + func (s *Store) CreateBotToken(ctx context.Context, input store.CreateBotTokenInput) (store.BotToken, error) + func (s *Store) CreateChannel(ctx context.Context, input store.CreateChannelInput) (store.Channel, store.Event, error) + func (s *Store) CreateConnectedAccount(ctx context.Context, input store.CreateConnectedAccountInput) (store.ConnectedAccount, error) + func (s *Store) CreateDirectConversation(ctx context.Context, input store.CreateDirectConversationInput) (store.DirectConversation, error) + func (s *Store) CreateDirectMessage(ctx context.Context, input store.CreateDirectMessageInput) (store.Message, store.Event, error) + func (s *Store) CreateEventDeliveryAttempt(ctx context.Context, input store.CreateEventDeliveryAttemptInput) (store.EventDeliveryAttempt, error) + func (s *Store) CreateEventSubscription(ctx context.Context, input store.CreateEventSubscriptionInput) (store.EventSubscription, error) + func (s *Store) CreateInvite(ctx context.Context, workspaceID, createdBy string) (store.Invite, error) + func (s *Store) CreateMagicLink(ctx context.Context, email, displayName string) (store.MagicLink, error) + func (s *Store) CreateMessage(ctx context.Context, input store.CreateMessageInput) (store.Message, store.Event, error) + func (s *Store) CreateReservedUpload(ctx context.Context, reservationID string, input store.CreateUploadInput) (store.Upload, error) + func (s *Store) CreateSession(ctx context.Context, userID string) (store.Session, error) + func (s *Store) CreateSlashCommand(ctx context.Context, input store.CreateSlashCommandInput) (store.SlashCommand, error) + func (s *Store) CreateSlashCommandInvocation(ctx context.Context, input store.CreateSlashCommandInvocationInput) (store.SlashCommandInvocation, error) + func (s *Store) CreateThreadReply(ctx context.Context, input store.CreateThreadReplyInput) (store.Message, store.ThreadState, []store.Event, error) + func (s *Store) CreateTopic(ctx context.Context, input store.CreateTopicInput) (store.Topic, error) + func (s *Store) CreateUpload(ctx context.Context, input store.CreateUploadInput) (store.Upload, error) + func (s *Store) CreateUser(ctx context.Context, input store.CreateUserInput) (store.User, error) + func (s *Store) CreateWorkspace(ctx context.Context, input store.CreateWorkspaceInput, ownerID string) (store.Workspace, error) + func (s *Store) DeleteMessage(ctx context.Context, input store.DeleteMessageInput) (store.Message, store.Event, error) + func (s *Store) EnsureBootstrap(ctx context.Context, name, email string) (store.User, error) + func (s *Store) EnsureDefaultGuestWorkspaceMember(ctx context.Context, userID, role string) (store.Workspace, error) + func (s *Store) EnsureDefaultWorkspaceMember(ctx context.Context, userID string) (store.Workspace, error) + func (s *Store) EnsureThreadRouteID(ctx context.Context, userID, rootMessageID string) (store.Message, error) + func (s *Store) ExportJSON(ctx context.Context, writer io.Writer) error + func (s *Store) FirstUser(ctx context.Context) (store.User, error) + func (s *Store) GetBotTokenAuth(ctx context.Context, token string) (store.BotTokenAuth, error) + func (s *Store) GetChannel(ctx context.Context, channelID, userID string) (store.Channel, error) + func (s *Store) GetDirectConversation(ctx context.Context, conversationID, userID string) (store.DirectConversation, error) + func (s *Store) GetMessage(ctx context.Context, messageID, userID string) (store.Message, error) + func (s *Store) GetSessionUser(ctx context.Context, token string) (store.User, error) + func (s *Store) GetSlashCommandForChannel(ctx context.Context, channelID, command, requesterID string) (store.SlashCommand, error) + func (s *Store) GetThread(ctx context.Context, rootMessageID, userID string, limit int) (store.Message, []store.Message, store.ThreadState, error) + func (s *Store) GetUpload(ctx context.Context, uploadID, userID string) (store.Upload, error) + func (s *Store) GetUser(ctx context.Context, id string) (store.User, error) + func (s *Store) GetWorkspace(ctx context.Context, workspaceID, userID string) (store.Workspace, error) + func (s *Store) HideDirectConversation(ctx context.Context, conversationID, userID string) error + func (s *Store) ListAppInstallations(ctx context.Context, workspaceID, requesterID string) ([]store.AppInstallation, error) + func (s *Store) ListAuditLogEntries(ctx context.Context, workspaceID, requesterID string, limit int) ([]store.AuditLogEntry, error) + func (s *Store) ListBotTokens(ctx context.Context, botUserID, requesterID string) ([]store.BotToken, error) + func (s *Store) ListBots(ctx context.Context, workspaceID, requesterID string) ([]store.BotWithTokens, error) + func (s *Store) ListChannels(ctx context.Context, workspaceID, userID string) ([]store.Channel, error) + func (s *Store) ListConnectedAccounts(ctx context.Context, workspaceID, requesterID string) ([]store.ConnectedAccount, error) + func (s *Store) ListDirectConversations(ctx context.Context, workspaceID, userID string) ([]store.DirectConversation, error) + func (s *Store) ListDirectMessages(ctx context.Context, conversationID, userID string, ...) (store.MessagePage, error) + func (s *Store) ListEventDeliveryAttempts(ctx context.Context, subscriptionID, requesterID string) ([]store.EventDeliveryAttempt, error) + func (s *Store) ListEventSubscriptions(ctx context.Context, workspaceID, requesterID string) ([]store.EventSubscription, error) + func (s *Store) ListEventSubscriptionsForEvent(ctx context.Context, event store.Event) ([]store.EventSubscription, error) + func (s *Store) ListEventsAfter(ctx context.Context, workspaceID, userID, cursor string, limit int) ([]store.Event, error) + func (s *Store) ListMessages(ctx context.Context, channelID, userID string, page store.MessagePageRequest) (store.MessagePage, error) + func (s *Store) ListPushNotificationRecipients(ctx context.Context, messageID string) ([]store.PushNotificationRecipient, error) + func (s *Store) ListSlashCommands(ctx context.Context, workspaceID, requesterID string) ([]store.SlashCommand, error) + func (s *Store) ListTopics(ctx context.Context, workspaceID, requesterID string) ([]store.Topic, error) + func (s *Store) ListWorkspaceMembers(ctx context.Context, workspaceID, actorUserID string) ([]store.MemberModeration, error) + func (s *Store) ListWorkspaces(ctx context.Context, userID string) ([]store.Workspace, error) + func (s *Store) MarkChannelRead(ctx context.Context, channelID, userID string, seq int64) (store.ReadReceipt, store.Event, error) + func (s *Store) MarkDirectRead(ctx context.Context, conversationID, userID string, seq int64) (store.ReadReceipt, store.Event, error) + func (s *Store) Migrate(ctx context.Context) (err error) + func (s *Store) PruneEvents(ctx context.Context, workspaceID string, keepLatest int, before string) (int64, error) + func (s *Store) ReleaseUploadQuotaReservation(ctx context.Context, reservationID, userID string) error + func (s *Store) RemoveReaction(ctx context.Context, input store.CreateReactionInput) (store.Event, error) + func (s *Store) ReopenDirectConversation(ctx context.Context, conversationID, userID string) (store.DirectConversation, error) + func (s *Store) ReserveUploadQuota(ctx context.Context, workspaceID, userID string, byteSize int64) (store.UploadQuotaReservation, error) + func (s *Store) ResolveLegacyRouteTarget(ctx context.Context, userID, workspaceID, targetID string) (store.RouteTarget, error) + func (s *Store) ResolveRouteTarget(ctx context.Context, userID, workspaceRouteID, targetRouteID string) (store.RouteTarget, error) + func (s *Store) RevokeAppInstallation(ctx context.Context, installationID, requesterID string) (store.AppInstallation, error) + func (s *Store) RevokeBotToken(ctx context.Context, tokenID, requesterID string) (store.BotToken, error) + func (s *Store) RevokeConnectedAccount(ctx context.Context, accountID, requesterID string) (store.ConnectedAccount, error) + func (s *Store) RevokeEventSubscription(ctx context.Context, subscriptionID, requesterID string) (store.EventSubscription, error) + func (s *Store) RevokeSlashCommand(ctx context.Context, commandID, requesterID string) (store.SlashCommand, error) + func (s *Store) SearchMessages(ctx context.Context, workspaceID, channelID, userID, query string, limit int) ([]store.SearchResult, error) + func (s *Store) UpdateChannel(ctx context.Context, input store.UpdateChannelInput) (store.Channel, store.Event, error) + func (s *Store) UpdateMemberModeration(ctx context.Context, input store.UpdateMemberModerationInput) (store.MemberModeration, store.Event, error) + func (s *Store) UpdateMessage(ctx context.Context, input store.UpdateMessageInput) (store.Message, store.Event, error) + func (s *Store) UpdateNotificationSettings(ctx context.Context, input store.UpdateNotificationSettingsInput) (store.NotificationSettings, error) + func (s *Store) UpdateUserProfile(ctx context.Context, input store.UpdateUserProfileInput) (store.User, error) + func (s *Store) UpdateUserProfileAndNotificationSettings(ctx context.Context, input store.UpdateUserProfileAndNotificationSettingsInput) (store.User, error) + func (s *Store) UploadHasDirectMessageAttachment(ctx context.Context, uploadID string) (bool, error) + func (s *Store) UploadHasOtherDirectMessageAttachment(ctx context.Context, uploadID, messageID string) (bool, error) + func (s *Store) UploadQuota(ctx context.Context, workspaceID, userID string) (store.UploadQuota, error) + func (s *Store) UpsertIdentityUser(ctx context.Context, input store.UpsertIdentityUserInput) (store.User, error) + func (s *Store) UserHasNonGuestMembership(ctx context.Context, userID string) (bool, error)
Go to main page