postgres

package
v0.0.0-...-0f279b2 Latest Latest
Warning

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

 Go to latest Published: Jun 16, 2026 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Store 

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

func Open 

func Open(dbURL string) (*Store, error)

func (*Store) AddReaction 

func (s *Store) AddReaction(ctx context.Context, input store.CreateReactionInput) (store.Event, error)

func (*Store) AddWorkspaceMember 

func (s *Store) AddWorkspaceMember(ctx context.Context, workspaceID, userID, role string) error

func (*Store) AttachUpload 

func (s *Store) AttachUpload(ctx context.Context, input store.AttachUploadInput) (store.Event, error)

func (*Store) Backup 

func (s *Store) Backup(ctx context.Context, outPath string) error

func (*Store) CanCreateUpload 

func (s *Store) CanCreateUpload(ctx context.Context, workspaceID, userID string, byteSize int64) error

func (*Store) CanPublishEphemeral 

func (s *Store) CanPublishEphemeral(ctx context.Context, workspaceID, channelID, directConversationID, userID string) error

func (*Store) Close 

func (s *Store) Close() error

func (*Store) CompleteSlashCommandInvocation 

func (s *Store) CompleteSlashCommandInvocation(ctx context.Context, invocationID string, status int, responseBody, invokeError string) (store.SlashCommandInvocation, error)
func (s *Store) ConsumeMagicLink(ctx context.Context, token string) (store.User, store.Session, error)

func (*Store) CreateAppInstallation 

func (s *Store) CreateAppInstallation(ctx context.Context, input store.CreateAppInstallationInput) (store.AppInstallation, error)

func (*Store) CreateAuditLogEntry 

func (s *Store) CreateAuditLogEntry(ctx context.Context, input store.CreateAuditLogEntryInput) (store.AuditLogEntry, error)

func (*Store) CreateBot 

func (s *Store) CreateBot(ctx context.Context, input store.CreateBotInput) (store.User, store.BotToken, error)

func (*Store) CreateBotToken 

func (s *Store) CreateBotToken(ctx context.Context, input store.CreateBotTokenInput) (store.BotToken, error)

func (*Store) CreateChannel 

func (s *Store) CreateChannel(ctx context.Context, input store.CreateChannelInput) (store.Channel, store.Event, error)

func (*Store) CreateConnectedAccount 

func (s *Store) CreateConnectedAccount(ctx context.Context, input store.CreateConnectedAccountInput) (store.ConnectedAccount, error)

func (*Store) CreateDirectConversation 

func (s *Store) CreateDirectConversation(ctx context.Context, input store.CreateDirectConversationInput) (store.DirectConversation, error)

func (*Store) CreateDirectMessage 

func (s *Store) CreateDirectMessage(ctx context.Context, input store.CreateDirectMessageInput) (store.Message, store.Event, error)

func (*Store) CreateEventDeliveryAttempt 

func (s *Store) CreateEventDeliveryAttempt(ctx context.Context, input store.CreateEventDeliveryAttemptInput) (store.EventDeliveryAttempt, error)

func (*Store) CreateEventSubscription 

func (s *Store) CreateEventSubscription(ctx context.Context, input store.CreateEventSubscriptionInput) (store.EventSubscription, error)

func (*Store) CreateInvite 

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 (*Store) CreateMessage 

func (s *Store) CreateMessage(ctx context.Context, input store.CreateMessageInput) (store.Message, store.Event, error)

func (*Store) CreateReservedUpload 

func (s *Store) CreateReservedUpload(ctx context.Context, reservationID string, input store.CreateUploadInput) (store.Upload, error)

func (*Store) CreateSession 

func (s *Store) CreateSession(ctx context.Context, userID string) (store.Session, error)

func (*Store) CreateSlashCommand 

func (s *Store) CreateSlashCommand(ctx context.Context, input store.CreateSlashCommandInput) (store.SlashCommand, error)

func (*Store) CreateSlashCommandInvocation 

func (s *Store) CreateSlashCommandInvocation(ctx context.Context, input store.CreateSlashCommandInvocationInput) (store.SlashCommandInvocation, error)

func (*Store) CreateThreadReply 

func (s *Store) CreateThreadReply(ctx context.Context, input store.CreateThreadReplyInput) (store.Message, store.ThreadState, []store.Event, error)

func (*Store) CreateTopic 

func (s *Store) CreateTopic(ctx context.Context, input store.CreateTopicInput) (store.Topic, error)

func (*Store) CreateUpload 

func (s *Store) CreateUpload(ctx context.Context, input store.CreateUploadInput) (store.Upload, error)

func (*Store) CreateUser 

func (s *Store) CreateUser(ctx context.Context, input store.CreateUserInput) (store.User, error)

func (*Store) CreateWorkspace 

func (s *Store) CreateWorkspace(ctx context.Context, input store.CreateWorkspaceInput, ownerID string) (store.Workspace, error)

func (*Store) DeleteMessage 

func (s *Store) DeleteMessage(ctx context.Context, input store.DeleteMessageInput) (store.Message, store.Event, error)

func (*Store) EnsureBootstrap 

func (s *Store) EnsureBootstrap(ctx context.Context, name, email string) (store.User, error)

func (*Store) EnsureDefaultGuestWorkspaceMember 

func (s *Store) EnsureDefaultGuestWorkspaceMember(ctx context.Context, userID, role string) (store.Workspace, error)

func (*Store) EnsureDefaultWorkspaceMember 

func (s *Store) EnsureDefaultWorkspaceMember(ctx context.Context, userID string) (store.Workspace, error)

func (*Store) EnsureThreadRouteID 

func (s *Store) EnsureThreadRouteID(ctx context.Context, userID, rootMessageID string) (store.Message, error)

func (*Store) ExportJSON 

func (s *Store) ExportJSON(ctx context.Context, writer io.Writer) error

func (*Store) FirstUser 

func (s *Store) FirstUser(ctx context.Context) (store.User, error)

func (*Store) GetBotTokenAuth 

func (s *Store) GetBotTokenAuth(ctx context.Context, token string) (store.BotTokenAuth, error)

func (*Store) GetChannel 

func (s *Store) GetChannel(ctx context.Context, channelID, userID string) (store.Channel, error)

func (*Store) GetDirectConversation 

func (s *Store) GetDirectConversation(ctx context.Context, conversationID, userID string) (store.DirectConversation, error)

func (*Store) GetMessage 

func (s *Store) GetMessage(ctx context.Context, messageID, userID string) (store.Message, error)

func (*Store) GetSessionUser 

func (s *Store) GetSessionUser(ctx context.Context, token string) (store.User, error)

func (*Store) GetSlashCommandForChannel 

func (s *Store) GetSlashCommandForChannel(ctx context.Context, channelID, command, requesterID string) (store.SlashCommand, error)

func (*Store) GetThread 

func (s *Store) GetThread(ctx context.Context, rootMessageID, userID string, limit int) (store.Message, []store.Message, store.ThreadState, error)

func (*Store) GetUpload 

func (s *Store) GetUpload(ctx context.Context, uploadID, userID string) (store.Upload, error)

func (*Store) GetUser 

func (s *Store) GetUser(ctx context.Context, id string) (store.User, error)

func (*Store) GetWorkspace 

func (s *Store) GetWorkspace(ctx context.Context, workspaceID, userID string) (store.Workspace, error)

func (*Store) ListAppInstallations 

func (s *Store) ListAppInstallations(ctx context.Context, workspaceID, requesterID string) ([]store.AppInstallation, error)

func (*Store) ListAuditLogEntries 

func (s *Store) ListAuditLogEntries(ctx context.Context, workspaceID, requesterID string, limit int) ([]store.AuditLogEntry, error)

func (*Store) ListBotTokens 

func (s *Store) ListBotTokens(ctx context.Context, botUserID, requesterID string) ([]store.BotToken, error)

func (*Store) ListBots 

func (s *Store) ListBots(ctx context.Context, workspaceID, requesterID string) ([]store.BotWithTokens, error)

func (*Store) ListChannels 

func (s *Store) ListChannels(ctx context.Context, workspaceID, userID string) ([]store.Channel, error)

func (*Store) ListConnectedAccounts 

func (s *Store) ListConnectedAccounts(ctx context.Context, workspaceID, requesterID string) ([]store.ConnectedAccount, error)

func (*Store) ListDirectConversations 

func (s *Store) ListDirectConversations(ctx context.Context, workspaceID, userID string) ([]store.DirectConversation, error)

func (*Store) ListDirectMessages 

func (s *Store) ListDirectMessages(ctx context.Context, conversationID, userID string, page store.MessagePageRequest) (store.MessagePage, error)

func (*Store) ListEventDeliveryAttempts 

func (s *Store) ListEventDeliveryAttempts(ctx context.Context, subscriptionID, requesterID string) ([]store.EventDeliveryAttempt, error)

func (*Store) ListEventSubscriptions 

func (s *Store) ListEventSubscriptions(ctx context.Context, workspaceID, requesterID string) ([]store.EventSubscription, error)

func (*Store) ListEventSubscriptionsForEvent 

func (s *Store) ListEventSubscriptionsForEvent(ctx context.Context, event store.Event) ([]store.EventSubscription, error)

func (*Store) ListEventsAfter 

func (s *Store) ListEventsAfter(ctx context.Context, workspaceID, userID, cursor string, limit int) ([]store.Event, error)

func (*Store) ListMessages 

func (s *Store) ListMessages(ctx context.Context, channelID, userID string, page store.MessagePageRequest) (store.MessagePage, error)

func (*Store) ListPushNotificationRecipients 

func (s *Store) ListPushNotificationRecipients(ctx context.Context, messageID string) ([]store.PushNotificationRecipient, error)

func (*Store) ListSlashCommands 

func (s *Store) ListSlashCommands(ctx context.Context, workspaceID, requesterID string) ([]store.SlashCommand, error)

func (*Store) ListTopics 

func (s *Store) ListTopics(ctx context.Context, workspaceID, requesterID string) ([]store.Topic, error)

func (*Store) ListWorkspaceMembers 

func (s *Store) ListWorkspaceMembers(ctx context.Context, workspaceID, actorUserID string) ([]store.MemberModeration, error)

func (*Store) ListWorkspaces 

func (s *Store) ListWorkspaces(ctx context.Context, userID string) ([]store.Workspace, error)

func (*Store) MarkChannelRead 

func (s *Store) MarkChannelRead(ctx context.Context, channelID, userID string, seq int64) (store.ReadReceipt, store.Event, error)

MarkChannelRead upserts the user's read pointer for a channel and emits a `channel.read` event. The pointer is monotonic — calls with a smaller seq are no-ops and return the existing receipt.

func (*Store) MarkDirectRead 

func (s *Store) MarkDirectRead(ctx context.Context, conversationID, userID string, seq int64) (store.ReadReceipt, store.Event, error)

MarkDirectRead is the DM analogue of MarkChannelRead.

func (*Store) Migrate 

func (s *Store) Migrate(ctx context.Context) (err error)

func (*Store) PruneEvents 

func (s *Store) PruneEvents(ctx context.Context, workspaceID string, keepLatest int, before string) (int64, error)

PruneEvents deletes old durable events for a workspace while preserving the newest keepLatest events. At least one retention bound is required so callers cannot accidentally wipe the whole event log with default zero values.

func (*Store) ReleaseUploadQuotaReservation 

func (s *Store) ReleaseUploadQuotaReservation(ctx context.Context, reservationID, userID string) error

func (*Store) RemoveReaction 

func (s *Store) RemoveReaction(ctx context.Context, input store.CreateReactionInput) (store.Event, error)

func (*Store) ReserveUploadQuota 

func (s *Store) ReserveUploadQuota(ctx context.Context, workspaceID, userID string, byteSize int64) (store.UploadQuotaReservation, error)

func (*Store) ResolveLegacyRouteTarget 

func (s *Store) ResolveLegacyRouteTarget(ctx context.Context, userID, workspaceID, targetID string) (store.RouteTarget, error)

func (*Store) ResolveRouteTarget 

func (s *Store) ResolveRouteTarget(ctx context.Context, userID, workspaceRouteID, targetRouteID string) (store.RouteTarget, error)

func (*Store) RevokeAppInstallation 

func (s *Store) RevokeAppInstallation(ctx context.Context, installationID, requesterID string) (store.AppInstallation, error)

func (*Store) RevokeBotToken 

func (s *Store) RevokeBotToken(ctx context.Context, tokenID, requesterID string) (store.BotToken, error)

func (*Store) RevokeConnectedAccount 

func (s *Store) RevokeConnectedAccount(ctx context.Context, accountID, requesterID string) (store.ConnectedAccount, error)

func (*Store) RevokeEventSubscription 

func (s *Store) RevokeEventSubscription(ctx context.Context, subscriptionID, requesterID string) (store.EventSubscription, error)

func (*Store) RevokeSlashCommand 

func (s *Store) RevokeSlashCommand(ctx context.Context, commandID, requesterID string) (store.SlashCommand, error)

func (*Store) SearchMessages 

func (s *Store) SearchMessages(ctx context.Context, workspaceID, channelID, userID, query string, limit int) ([]store.SearchResult, error)

func (*Store) UpdateChannel 

func (s *Store) UpdateChannel(ctx context.Context, input store.UpdateChannelInput) (store.Channel, store.Event, error)

func (*Store) UpdateMemberModeration 

func (s *Store) UpdateMemberModeration(ctx context.Context, input store.UpdateMemberModerationInput) (store.MemberModeration, store.Event, error)

func (*Store) UpdateMessage 

func (s *Store) UpdateMessage(ctx context.Context, input store.UpdateMessageInput) (store.Message, store.Event, error)

func (*Store) UpdateNotificationSettings 

func (s *Store) UpdateNotificationSettings(ctx context.Context, input store.UpdateNotificationSettingsInput) (store.NotificationSettings, error)

func (*Store) UpdateUserProfile 

func (s *Store) UpdateUserProfile(ctx context.Context, input store.UpdateUserProfileInput) (store.User, error)

func (*Store) UpdateUserProfileAndNotificationSettings 

func (s *Store) UpdateUserProfileAndNotificationSettings(ctx context.Context, input store.UpdateUserProfileAndNotificationSettingsInput) (store.User, error)

func (*Store) UploadHasDirectMessageAttachment 

func (s *Store) UploadHasDirectMessageAttachment(ctx context.Context, uploadID string) (bool, error)

func (*Store) UploadHasOtherDirectMessageAttachment 

func (s *Store) UploadHasOtherDirectMessageAttachment(ctx context.Context, uploadID, messageID string) (bool, error)

func (*Store) UploadQuota 

func (s *Store) UploadQuota(ctx context.Context, workspaceID, userID string) (store.UploadQuota, error)

func (*Store) UpsertIdentityUser 

func (s *Store) UpsertIdentityUser(ctx context.Context, input store.UpsertIdentityUserInput) (store.User, error)

func (*Store) UserHasNonGuestMembership 

func (s *Store) UserHasNonGuestMembership(ctx context.Context, userID string) (bool, error)

Source Files

View all Source files

Directories

Path Synopsis

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.