Documentation
¶
Index ¶
- Variables
- func Migrate(pool *pgxpool.Pool) error
- type AccessEvent
- type CreateDocumentWithContentParams
- type CreateFlowParams
- type CreateGuestUserParams
- type CreateMessageParams
- type CreateOAuthUserParams
- type CreateProviderParams
- type DBTX
- type DeleteDocumentParams
- type DeleteFlowParams
- type DeleteFlowVoteParams
- type DeleteThreadParams
- type DeletedAccount
- type DisplayNameTakenParams
- type Document
- type ErrorEvent
- type Flow
- type FlowPublishEvent
- type FlowVote
- type GetFlowByIDParams
- type GetFlowByIDRow
- type GetFlowsByUserRow
- type GetPublicFlowByIDRow
- type GetPublishedFlowByHashParams
- type GetPublishedFlowDupByHashParams
- type GetPublishedFlowDupByHashRow
- type GetThreadByIDParams
- type GetUserAnyParams
- type GetUserByOAuthIDParams
- type IncrementGuestLLMCallIfBelowParams
- type InsertAccessEventParams
- type InsertErrorEventParams
- type InsertPublishEventParams
- type InsertReportedIssueParams
- type ListAccessEventsByEmailHashRow
- type ListFeaturedFlowsRow
- type ListPublicFlowsForSitemapRow
- type ListPublicFlowsParams
- type ListPublicFlowsRow
- type ListThreadsByUserRow
- type Message
- type Provider
- type PublishFlowParams
- type PublishedFlow
- type Queries
- func (q *Queries) CountGuests(ctx context.Context) (int32, error)
- func (q *Queries) CountPublishEventsLast24h(ctx context.Context, userID uuid.UUID) (int32, error)
- func (q *Queries) CreateDocumentWithContent(ctx context.Context, arg CreateDocumentWithContentParams) (*Document, error)
- func (q *Queries) CreateFlow(ctx context.Context, arg CreateFlowParams) (*Flow, error)
- func (q *Queries) CreateGuestUser(ctx context.Context, arg CreateGuestUserParams) (*User, error)
- func (q *Queries) CreateMessage(ctx context.Context, arg CreateMessageParams) (*Message, error)
- func (q *Queries) CreateOAuthUser(ctx context.Context, arg CreateOAuthUserParams) (*User, error)
- func (q *Queries) CreateProvider(ctx context.Context, arg CreateProviderParams) (*Provider, error)
- func (q *Queries) CreateThread(ctx context.Context, userID uuid.UUID) (*Thread, error)
- func (q *Queries) DeleteDeletedAccount(ctx context.Context, emailHash string) (int64, error)
- func (q *Queries) DeleteDocument(ctx context.Context, arg DeleteDocumentParams) error
- func (q *Queries) DeleteFlow(ctx context.Context, arg DeleteFlowParams) error
- func (q *Queries) DeleteFlowVote(ctx context.Context, arg DeleteFlowVoteParams) error
- func (q *Queries) DeleteProvider(ctx context.Context, id uuid.UUID) (int64, error)
- func (q *Queries) DeleteThread(ctx context.Context, arg DeleteThreadParams) error
- func (q *Queries) DeleteThreadMessages(ctx context.Context, threadID uuid.UUID) error
- func (q *Queries) DeleteUser(ctx context.Context, id uuid.UUID) error
- func (q *Queries) DisplayNameTaken(ctx context.Context, arg DisplayNameTakenParams) (bool, error)
- func (q *Queries) GetDocumentsByUser(ctx context.Context, userID uuid.UUID) ([]*Document, error)
- func (q *Queries) GetFlowByID(ctx context.Context, arg GetFlowByIDParams) (*GetFlowByIDRow, error)
- func (q *Queries) GetFlowsByUser(ctx context.Context, userID uuid.UUID) ([]*GetFlowsByUserRow, error)
- func (q *Queries) GetNodeMenu(ctx context.Context, id uuid.UUID) ([]byte, error)
- func (q *Queries) GetPreferredModel(ctx context.Context, id uuid.UUID) (string, error)
- func (q *Queries) GetProvider(ctx context.Context, id uuid.UUID) (*Provider, error)
- func (q *Queries) GetPublicFlowByID(ctx context.Context, flowID uuid.UUID) (*GetPublicFlowByIDRow, error)
- func (q *Queries) GetPublishedFlowByHash(ctx context.Context, arg GetPublishedFlowByHashParams) (uuid.UUID, error)
- func (q *Queries) GetPublishedFlowDupByHash(ctx context.Context, arg GetPublishedFlowDupByHashParams) (*GetPublishedFlowDupByHashRow, error)
- func (q *Queries) GetTemplateUserID(ctx context.Context) (uuid.UUID, error)
- func (q *Queries) GetThreadByID(ctx context.Context, arg GetThreadByIDParams) (*Thread, error)
- func (q *Queries) GetThreadByUserID(ctx context.Context, userID uuid.UUID) (*Thread, error)
- func (q *Queries) GetThreadMessages(ctx context.Context, threadID uuid.UUID) ([]*Message, error)
- func (q *Queries) GetUserAny(ctx context.Context, arg GetUserAnyParams) (*User, error)
- func (q *Queries) GetUserByEmail(ctx context.Context, email string) (*User, error)
- func (q *Queries) GetUserByID(ctx context.Context, id uuid.UUID) (*User, error)
- func (q *Queries) GetUserByOAuthID(ctx context.Context, arg GetUserByOAuthIDParams) (*User, error)
- func (q *Queries) HardDeleteStaleGuests(ctx context.Context) (int64, error)
- func (q *Queries) IncrementGuestLLMCallIfBelow(ctx context.Context, arg IncrementGuestLLMCallIfBelowParams) (int32, error)
- func (q *Queries) InsertAccessEvent(ctx context.Context, arg InsertAccessEventParams) error
- func (q *Queries) InsertDeletedAccount(ctx context.Context, emailHash string) error
- func (q *Queries) InsertErrorEvent(ctx context.Context, arg InsertErrorEventParams) error
- func (q *Queries) InsertPublishEvent(ctx context.Context, arg InsertPublishEventParams) error
- func (q *Queries) InsertReportedIssue(ctx context.Context, arg InsertReportedIssueParams) error
- func (q *Queries) IsEmailDeleted(ctx context.Context, emailHash string) (bool, error)
- func (q *Queries) ListAccessEventsByEmailHash(ctx context.Context, emailHash pgtype.Text) ([]*ListAccessEventsByEmailHashRow, error)
- func (q *Queries) ListAutoDisplayNames(ctx context.Context) ([]uuid.UUID, error)
- func (q *Queries) ListEnabledProviders(ctx context.Context) ([]*Provider, error)
- func (q *Queries) ListFeaturedFlows(ctx context.Context, userID uuid.UUID) ([]*ListFeaturedFlowsRow, error)
- func (q *Queries) ListProviders(ctx context.Context) ([]*Provider, error)
- func (q *Queries) ListPublicFlows(ctx context.Context, arg ListPublicFlowsParams) ([]*ListPublicFlowsRow, error)
- func (q *Queries) ListPublicFlowsForSitemap(ctx context.Context) ([]*ListPublicFlowsForSitemapRow, error)
- func (q *Queries) ListThreadsByUser(ctx context.Context, userID uuid.UUID) ([]*ListThreadsByUserRow, error)
- func (q *Queries) PublishFlow(ctx context.Context, arg PublishFlowParams) error
- func (q *Queries) ReassignUserPublishedFlowOwnersToAnon(ctx context.Context, userID uuid.UUID) error
- func (q *Queries) ReassignUserPublishedFlowsToAnon(ctx context.Context, userID uuid.UUID) error
- func (q *Queries) ReparentGuestFlows(ctx context.Context, arg ReparentGuestFlowsParams) error
- func (q *Queries) ReparentGuestThreads(ctx context.Context, arg ReparentGuestThreadsParams) error
- func (q *Queries) ResetFlowToPublicParent(ctx context.Context, arg ResetFlowToPublicParentParams) error
- func (q *Queries) SearchPublicFlows(ctx context.Context, arg SearchPublicFlowsParams) ([]*SearchPublicFlowsRow, error)
- func (q *Queries) SetEmailVerified(ctx context.Context, id uuid.UUID) error
- func (q *Queries) SetUserDefaultFlow(ctx context.Context, arg SetUserDefaultFlowParams) error
- func (q *Queries) SetUserDisplayName(ctx context.Context, arg SetUserDisplayNameParams) error
- func (q *Queries) SummariseAccessByEmailHash(ctx context.Context, emailHash pgtype.Text) ([]*SummariseAccessByEmailHashRow, error)
- func (q *Queries) UnpublishFlow(ctx context.Context, flowID uuid.UUID) error
- func (q *Queries) UpdateDisplayName(ctx context.Context, arg UpdateDisplayNameParams) error
- func (q *Queries) UpdateFlow(ctx context.Context, arg UpdateFlowParams) error
- func (q *Queries) UpdateNodeMenu(ctx context.Context, arg UpdateNodeMenuParams) error
- func (q *Queries) UpdatePreferredModel(ctx context.Context, arg UpdatePreferredModelParams) error
- func (q *Queries) UpdateProvider(ctx context.Context, arg UpdateProviderParams) error
- func (q *Queries) UpdateProviderNoKey(ctx context.Context, arg UpdateProviderNoKeyParams) error
- func (q *Queries) UpdateThreadScroll(ctx context.Context, arg UpdateThreadScrollParams) error
- func (q *Queries) UpdateThreadTitle(ctx context.Context, arg UpdateThreadTitleParams) error
- func (q *Queries) UpdateThreadUpdatedAt(ctx context.Context, arg UpdateThreadUpdatedAtParams) error
- func (q *Queries) UpgradeGuestToOAuthUser(ctx context.Context, arg UpgradeGuestToOAuthUserParams) error
- func (q *Queries) UpsertFlowVote(ctx context.Context, arg UpsertFlowVoteParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type ReparentGuestFlowsParams
- type ReparentGuestThreadsParams
- type ReportedIssue
- type ResetFlowToPublicParentParams
- type SearchPublicFlowsParams
- type SearchPublicFlowsRow
- type SetUserDefaultFlowParams
- type SetUserDisplayNameParams
- type SummariseAccessByEmailHashRow
- type Thread
- type UpdateDisplayNameParams
- type UpdateFlowParams
- type UpdateNodeMenuParams
- type UpdatePreferredModelParams
- type UpdateProviderNoKeyParams
- type UpdateProviderParams
- type UpdateThreadScrollParams
- type UpdateThreadTitleParams
- type UpdateThreadUpdatedAtParams
- type UpgradeGuestToOAuthUserParams
- type UpsertFlowVoteParams
- type User
Constants ¶
This section is empty.
Variables ¶
View Source
var Migrations = migrationsFS
Migrations is the embedded shared-schema goose migration set. Wrappers layer their own migrations (e.g. hosted billing) on top by running them afterwards.
Functions ¶
Types ¶
type AccessEvent ¶
type CreateFlowParams ¶
type CreateGuestUserParams ¶
type CreateMessageParams ¶
type CreateOAuthUserParams ¶
type CreateProviderParams ¶
type DeletedAccount ¶
type DeletedAccount struct {
EmailHash string
DeletedAt pgtype.Timestamptz
}
type DisplayNameTakenParams ¶
type ErrorEvent ¶
type FlowPublishEvent ¶
type FlowVote ¶
type FlowVote struct {
FlowID uuid.UUID
UserID uuid.UUID
Vote int16
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type GetFlowByIDRow ¶
type GetFlowsByUserRow ¶
type GetPublicFlowByIDRow ¶
type GetUserAnyParams ¶
type GetUserByOAuthIDParams ¶
type InsertAccessEventParams ¶
type InsertErrorEventParams ¶
type ListFeaturedFlowsRow ¶
type ListPublicFlowsForSitemapRow ¶
type ListPublicFlowsForSitemapRow struct {
ID uuid.UUID
UpdatedAt pgtype.Timestamptz
}
type ListPublicFlowsParams ¶
type ListPublicFlowsRow ¶
type ListThreadsByUserRow ¶
type Provider ¶
type Provider struct {
ID uuid.UUID
Name string
BaseUrl string
ApiKeyEnc []byte
Enabled bool
CreatedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type PublishFlowParams ¶
type PublishedFlow ¶
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) CountPublishEventsLast24h ¶
func (*Queries) CreateDocumentWithContent ¶
func (q *Queries) CreateDocumentWithContent(ctx context.Context, arg CreateDocumentWithContentParams) (*Document, error)
Documents
func (*Queries) CreateFlow ¶
Flows
func (*Queries) CreateGuestUser ¶
func (*Queries) CreateMessage ¶
Messages
func (*Queries) CreateOAuthUser ¶
func (*Queries) CreateProvider ¶
func (*Queries) CreateThread ¶
Threads
func (*Queries) DeleteDeletedAccount ¶
func (*Queries) DeleteDocument ¶
func (q *Queries) DeleteDocument(ctx context.Context, arg DeleteDocumentParams) error
func (*Queries) DeleteFlow ¶
func (q *Queries) DeleteFlow(ctx context.Context, arg DeleteFlowParams) error
func (*Queries) DeleteFlowVote ¶
func (q *Queries) DeleteFlowVote(ctx context.Context, arg DeleteFlowVoteParams) error
func (*Queries) DeleteProvider ¶
func (*Queries) DeleteThread ¶
func (q *Queries) DeleteThread(ctx context.Context, arg DeleteThreadParams) error
func (*Queries) DeleteThreadMessages ¶
func (*Queries) DisplayNameTaken ¶
func (*Queries) GetDocumentsByUser ¶
func (*Queries) GetFlowByID ¶
func (q *Queries) GetFlowByID(ctx context.Context, arg GetFlowByIDParams) (*GetFlowByIDRow, error)
func (*Queries) GetFlowsByUser ¶
func (*Queries) GetNodeMenu ¶
func (*Queries) GetPreferredModel ¶
func (*Queries) GetProvider ¶
func (*Queries) GetPublicFlowByID ¶
func (*Queries) GetPublishedFlowByHash ¶
func (*Queries) GetPublishedFlowDupByHash ¶
func (q *Queries) GetPublishedFlowDupByHash(ctx context.Context, arg GetPublishedFlowDupByHashParams) (*GetPublishedFlowDupByHashRow, error)
func (*Queries) GetTemplateUserID ¶
func (*Queries) GetThreadByID ¶
func (*Queries) GetThreadByUserID ¶
func (*Queries) GetThreadMessages ¶
func (*Queries) GetUserAny ¶
func (*Queries) GetUserByEmail ¶
func (*Queries) GetUserByID ¶
Users (core identity columns only; billing columns live in the hosted layer)
func (*Queries) GetUserByOAuthID ¶
func (*Queries) HardDeleteStaleGuests ¶
func (*Queries) IncrementGuestLLMCallIfBelow ¶
func (*Queries) InsertAccessEvent ¶
func (q *Queries) InsertAccessEvent(ctx context.Context, arg InsertAccessEventParams) error
func (*Queries) InsertDeletedAccount ¶
Deleted-account cooldown
func (*Queries) InsertErrorEvent ¶
func (q *Queries) InsertErrorEvent(ctx context.Context, arg InsertErrorEventParams) error
Events
func (*Queries) InsertPublishEvent ¶
func (q *Queries) InsertPublishEvent(ctx context.Context, arg InsertPublishEventParams) error
func (*Queries) InsertReportedIssue ¶
func (q *Queries) InsertReportedIssue(ctx context.Context, arg InsertReportedIssueParams) error
func (*Queries) IsEmailDeleted ¶
func (*Queries) ListAccessEventsByEmailHash ¶
func (*Queries) ListAutoDisplayNames ¶
func (*Queries) ListEnabledProviders ¶
func (*Queries) ListFeaturedFlows ¶
func (*Queries) ListProviders ¶
Providers
func (*Queries) ListPublicFlows ¶
func (q *Queries) ListPublicFlows(ctx context.Context, arg ListPublicFlowsParams) ([]*ListPublicFlowsRow, error)
func (*Queries) ListPublicFlowsForSitemap ¶
func (q *Queries) ListPublicFlowsForSitemap(ctx context.Context) ([]*ListPublicFlowsForSitemapRow, error)
func (*Queries) ListThreadsByUser ¶
func (*Queries) PublishFlow ¶
func (q *Queries) PublishFlow(ctx context.Context, arg PublishFlowParams) error
Published flows / marketplace
func (*Queries) ReassignUserPublishedFlowOwnersToAnon ¶
func (*Queries) ReassignUserPublishedFlowsToAnon ¶
Reassign a deleting user's published flows to the anonymous sentinel so community content survives the hard delete. Run BEFORE deleting the user.
func (*Queries) ReparentGuestFlows ¶
func (q *Queries) ReparentGuestFlows(ctx context.Context, arg ReparentGuestFlowsParams) error
func (*Queries) ReparentGuestThreads ¶
func (q *Queries) ReparentGuestThreads(ctx context.Context, arg ReparentGuestThreadsParams) error
func (*Queries) ResetFlowToPublicParent ¶
func (q *Queries) ResetFlowToPublicParent(ctx context.Context, arg ResetFlowToPublicParentParams) error
func (*Queries) SearchPublicFlows ¶
func (q *Queries) SearchPublicFlows(ctx context.Context, arg SearchPublicFlowsParams) ([]*SearchPublicFlowsRow, error)
func (*Queries) SetEmailVerified ¶
func (*Queries) SetUserDefaultFlow ¶
func (q *Queries) SetUserDefaultFlow(ctx context.Context, arg SetUserDefaultFlowParams) error
func (*Queries) SetUserDisplayName ¶
func (q *Queries) SetUserDisplayName(ctx context.Context, arg SetUserDisplayNameParams) error
func (*Queries) SummariseAccessByEmailHash ¶
func (*Queries) UnpublishFlow ¶
func (*Queries) UpdateDisplayName ¶
func (q *Queries) UpdateDisplayName(ctx context.Context, arg UpdateDisplayNameParams) error
func (*Queries) UpdateFlow ¶
func (q *Queries) UpdateFlow(ctx context.Context, arg UpdateFlowParams) error
func (*Queries) UpdateNodeMenu ¶
func (q *Queries) UpdateNodeMenu(ctx context.Context, arg UpdateNodeMenuParams) error
func (*Queries) UpdatePreferredModel ¶
func (q *Queries) UpdatePreferredModel(ctx context.Context, arg UpdatePreferredModelParams) error
func (*Queries) UpdateProvider ¶
func (q *Queries) UpdateProvider(ctx context.Context, arg UpdateProviderParams) error
func (*Queries) UpdateProviderNoKey ¶
func (q *Queries) UpdateProviderNoKey(ctx context.Context, arg UpdateProviderNoKeyParams) error
func (*Queries) UpdateThreadScroll ¶
func (q *Queries) UpdateThreadScroll(ctx context.Context, arg UpdateThreadScrollParams) error
func (*Queries) UpdateThreadTitle ¶
func (q *Queries) UpdateThreadTitle(ctx context.Context, arg UpdateThreadTitleParams) error
func (*Queries) UpdateThreadUpdatedAt ¶
func (q *Queries) UpdateThreadUpdatedAt(ctx context.Context, arg UpdateThreadUpdatedAtParams) error
func (*Queries) UpgradeGuestToOAuthUser ¶
func (q *Queries) UpgradeGuestToOAuthUser(ctx context.Context, arg UpgradeGuestToOAuthUserParams) error
func (*Queries) UpsertFlowVote ¶
func (q *Queries) UpsertFlowVote(ctx context.Context, arg UpsertFlowVoteParams) error
type ReportedIssue ¶
type SearchPublicFlowsParams ¶
type SearchPublicFlowsRow ¶
type SummariseAccessByEmailHashRow ¶
type SummariseAccessByEmailHashRow struct {
Kind string
EventCount int64
FirstAt pgtype.Timestamptz
LastAt pgtype.Timestamptz
DistinctIps int64
}
type UpdateDisplayNameParams ¶
type UpdateFlowParams ¶
type UpdateNodeMenuParams ¶
type UpdateProviderParams ¶
type UpdateThreadTitleParams ¶
type UpsertFlowVoteParams ¶
Click to show internal directories.
Click to hide internal directories.