pgdb

package

Go to main page

Versions in this module

v0

v0.2.5

Nov 1, 2026

Changes in this version

type AccountPasswordByIDRow

+ Email string

type AccountPasswordRow

+ Email string

type IdentityAccountsRow

+ Email string

type InsertRemoteAccountParams

+ Email string

type PasswordResetRow

+ Email string

type RemoteAccount

+ Email string

type ResolveIdentityTokenRow

+ Email string

type ResolveSessionRow

+ Email string

type UsePasswordInviteParams

+ Email string

v0.2.4

Oct 31, 2026

Changes in this version

type AccountPasswordByIDRow

+ Method string

type AccountPasswordRow

+ Method string

type AccountSummariesRow

+ Method string

+ type AppSetting struct

+ PasswordSignup bool

+ SignupOpen bool

+ Singleton bool

+ UpdatedAt time.Time

+ UpdatedBy *string

+ type AppSettingsRow struct

+ PasswordSignup bool

+ SignupOpen bool

+ type ConsumePasswordResetParams struct

+ Now time.Time

+ TokenHash string

type GoogleAuthState

+ SetupHash *string

type IdentityAccountsRow

+ Method string

type InsertGoogleFlowParams

+ SetupHash *string

+ type LockAppSettingsRow struct

+ PasswordSignup bool

+ SignupOpen bool

+ type LockTargetAccountRow struct

+ Admin bool

+ Disabled bool

+ type PasswordReset struct

+ ExpiresAt time.Time

+ TokenHash string

+ UserID string

+ type PasswordResetParams struct

+ Now time.Time

+ TokenHash string

+ type PasswordResetRow struct

+ Admin bool

+ Method string

+ PasswordHash string

+ UserID string

+ Username string

+ type PendingAdminSetupParams struct

+ Now time.Time

+ TokenHash string

+ type PutAppSettingsParams struct

+ PasswordSignup bool

+ SignupOpen bool

+ UpdatedAt time.Time

+ UpdatedBy string

+ type PutPasswordResetParams struct

+ ExpiresAt time.Time

+ TokenHash string

+ UserID string

type Queries

+ func (q *Queries) AppSettings(ctx context.Context) (AppSettingsRow, error)

+ func (q *Queries) ConsumePasswordReset(ctx context.Context, arg ConsumePasswordResetParams) (string, error)

+ func (q *Queries) GrantAdmin(ctx context.Context, userID string) error

+ func (q *Queries) LockAppSettings(ctx context.Context) (LockAppSettingsRow, error)

+ func (q *Queries) OtherEnabledAdmin(ctx context.Context, userID string) (bool, error)

+ func (q *Queries) PasswordReset(ctx context.Context, arg PasswordResetParams) (PasswordResetRow, error)

+ func (q *Queries) PendingAdminSetup(ctx context.Context, arg PendingAdminSetupParams) (bool, error)

+ func (q *Queries) PrunePasswordResets(ctx context.Context, expiresAt time.Time) error

+ func (q *Queries) PutAppSettings(ctx context.Context, arg PutAppSettingsParams) error

+ func (q *Queries) PutPasswordReset(ctx context.Context, arg PutPasswordResetParams) error

+ func (q *Queries) RevokeAdmin(ctx context.Context, userID string) error

+ func (q *Queries) UsePasswordInvite(ctx context.Context, arg UsePasswordInviteParams) (int64, error)

type ResolveIdentityTokenRow

+ Method string

type ResolveSessionRow

+ Method string

type TakeGoogleFlowRow

+ SetupHash *string

+ type UsePasswordInviteParams struct

+ ID string

+ Now time.Time

+ UserID string

v0.2.3

Oct 29, 2026

v0.2.2

Oct 29, 2026

Changes in this version

+ type AccountInvite struct

+ CreatedAt time.Time

+ Email string

+ ExpiresAt time.Time

+ ID string

+ RevokedAt *time.Time

+ TokenHash string

+ UsedAt *time.Time

+ UsedBy *string

+ type AccountPasswordByIDRow struct

+ Admin bool

+ PasswordHash string

+ UserID string

+ Username string

+ type AccountPasswordRow struct

+ Admin bool

+ PasswordHash string

+ UserID string

+ Username string

+ type AccountSummariesRow struct

+ Admin bool

+ CreatedAt time.Time

+ Disabled bool

+ Email string

+ UserID string

+ Username string

+ type ActiveJobUsageRow struct

+ Bytes int64

+ Jobs int64

+ type AdminAccount struct

+ Singleton bool

+ UserID string

+ type AdminSetup struct

+ ExpiresAt time.Time

+ Singleton bool

+ TokenHash string

+ type AdvanceStreamHeadParams struct

+ ArrivalSequence int64

+ Branch string

+ CheckoutKey string

+ CollectedAt int64

+ ComparisonPolicy string

+ ContextID string

+ OwnerID string

+ RepositoryKey string

+ SourceID string

+ type AgentSession struct

+ Harness string

+ Name string

+ NamedAt int64

+ OwnerID string

+ SessionID string

+ SourceID string

+ type AuthAttempt struct

+ Attempts int32

+ Client string

+ WindowStart time.Time

+ type BindSubmissionParams struct

+ ContextID string

+ Sequence int64

+ type BrowserSession struct

+ CsrfToken string

+ ExpiresAt time.Time

+ SecretHash string

+ UserID string

+ type ClaimGitHubRefreshParams struct

+ LeaseUntil time.Time

+ Now time.Time

+ Token string

+ type ClaimGitHubRefreshRow struct

+ Attempt int32

+ FullName string

+ InstallationID int64

+ LeasedGeneration int64

+ LeasedRun string

+ Number int32

+ RepositoryID int64

+ type ClaimJobParams struct

+ LeaseToken string

+ LeaseUntil time.Time

+ Now time.Time

+ type ClaimJobRow struct

+ Attempt int32

+ ID string

+ OwnerID string

+ Payload []byte

+ SubmissionID string

+ type ClaimNotificationsParams struct

+ LeaseToken string

+ LeaseUntil time.Time

+ MaxCount int32

+ Now time.Time

+ type ClaimNotificationsRow struct

+ Attempt int32

+ Available bool

+ CreatedAt time.Time

+ ID string

+ JobContextID string

+ JobState string

+ Kind string

+ OwnerID string

+ Payload []byte

+ type Comment struct

+ CreatedAt int64

+ Data []byte

+ FileID string

+ ID string

+ ReviewID string

+ VersionID *string

+ type CommentsParams struct

+ ContextID string

+ Now time.Time

+ type CompleteGitHubRefreshParams struct

+ Now time.Time

+ Number int32

+ RepositoryID int64

+ State string

+ Token string

+ type CompleteJobParams struct

+ ContextID string

+ ID string

+ LeaseToken string

+ Now time.Time

+ type ConsumeAdminSetupParams struct

+ Now time.Time

+ TokenHash string

+ type Context struct

+ AnchorDiffID string

+ CreatedAt time.Time

+ ID string

+ Kind string

+ LastSubmittedAt time.Time

+ OwnerID string

+ SubmittedFrom *string

+ type ContextExpiryParams struct

+ ID string

+ OwnerID string

+ type ContextForDeleteParams struct

+ ID string

+ OwnerID string

+ type ContextForDeleteRow struct

+ AnchorDiffID string

+ StreamKey *string

+ type ContextStreamParams struct

+ ID string

+ OwnerID string

+ type ContextStreamRow struct

+ ExpiresAt *time.Time

+ HeadBranch *string

+ HeadCheckoutKey *string

+ HeadComparisonPolicy *string

+ HeadRepositoryKey *string

+ HeadSourceID *string

+ type CountAuthAttemptParams struct

+ Client string

+ Expired time.Time

+ Now time.Time

+ type DBTX interface

+ Exec func(context.Context, string, ...interface{}) (pgconn.CommandTag, error)

+ Query func(context.Context, string, ...interface{}) (pgx.Rows, error)

+ QueryRow func(context.Context, string, ...interface{}) pgx.Row

+ type DeleteContextDiffsParams struct

+ AnchorID string

+ ContextID string

+ OwnerID string

+ type DeleteDiffParams struct

+ ID string

+ OwnerID string

+ type DeleteGitHubFollowParams struct

+ OwnerID string

+ RepositoryID int64

+ type DeleteIdentityTokenParams struct

+ ID string

+ UserID string

+ type DeleteOwnedSubscriptionParams struct

+ ID string

+ OwnerID string

+ type DeleteStreamCommentsParams struct

+ ContextID string

+ Ids []string

+ type DeleteVisibleMarksParams struct

+ ContextID string

+ FileID *string

+ Mode string

+ type Diff struct

+ CreatedAt time.Time

+ ExpiresAt *time.Time

+ ID string

+ Kind string

+ Mode string

+ OwnerID string

+ type DiffFile struct

+ FileID string

+ Fingerprint string

+ Patch []byte

+ PatchDigest string

+ Path string

+ VersionID string

+ type DiffVersion struct

+ ComparisonKind string

+ CreatedAt time.Time

+ DiffID string

+ ID string

+ Manifest []byte

+ Revision string

+ Source string

+ type DisableAccountParams struct

+ DisabledAt time.Time

+ UserID string

+ type DisabledAccount struct

+ DisabledAt time.Time

+ UserID string

+ type EndStreamParams struct

+ OwnerID string

+ StreamKey string

+ type EnsureReviewParams struct

+ ID string

+ Mode string

+ OwnerID string

+ StreamKey string

+ type ExtendObservationParams struct

+ ContextID string

+ ExpiresAt time.Time

+ type FailJobParams struct

+ Detail string

+ ID string

+ LeaseToken string

+ Now time.Time

+ type FinishNotificationParams struct

+ ID string

+ LeaseToken string

+ State string

+ type ForgetIdentityParams struct

+ IdentityHash string

+ OwnerID string

+ type GitHubFollowsRow struct

+ CreatedAt time.Time

+ FullName string

+ InstallationID int64

+ Muted bool

+ OwnerID string

+ RepositoryID int64

+ Status string

+ VerifiedAt time.Time

+ type GitHubLeasedParams struct

+ Now time.Time

+ Number int32

+ RepositoryID int64

+ Token string

+ type GitHubLeasedRow struct

+ Attempt int32

+ FullName string

+ InstallationID int64

+ Leased []byte

+ LeasedGeneration int64

+ LeasedRun string

+ Number int32

+ RepositoryID int64

+ type GitHubPullRequestHeadParams struct

+ Number int32

+ RepositoryID int64

+ type GitHubPullRequestHeadRow struct

+ HeadSha string

+ Opened bool

+ type GitHubRepositoryFollowsRow struct

+ CreatedAt time.Time

+ FullName string

+ InstallationID int64

+ Muted bool

+ OwnerID string

+ RepositoryID int64

+ Status string

+ VerifiedAt time.Time

+ type GithubConnection struct

+ AccessExpiresAt time.Time

+ AccessToken []byte

+ ConnectedAt time.Time

+ Login string

+ OwnerID string

+ RefreshExpiresAt time.Time

+ RefreshToken []byte

+ Status string

+ UserID int64

+ type GithubDelivery struct

+ Event string

+ ID string

+ ReceivedAt time.Time

+ type GithubFollow struct

+ CreatedAt time.Time

+ FullName string

+ InstallationID int64

+ OwnerID string

+ RepositoryID int64

+ Status string

+ VerifiedAt time.Time

+ type GithubFollowMute struct

+ OwnerID string

+ RepositoryID int64

+ type GithubOauthState struct

+ ExpiresAt time.Time

+ OwnerID string

+ StateHash string

+ type GithubPrHead struct

+ HeadSha string

+ Number int32

+ Opened bool

+ RepositoryID int64

+ type GithubPullRequest struct

+ Attempt int32

+ AvailableAt time.Time

+ Detail string

+ FullName string

+ Generation int64

+ InstallationID int64

+ LeaseToken string

+ LeaseUntil time.Time

+ Leased []byte

+ LeasedGeneration int64

+ LeasedRun string

+ Number int32

+ RefreshedGeneration int64

+ RepositoryID int64

+ RequestedAt time.Time

+ RetentionRun string

+ State string

+ type GoogleAccountRow struct

+ Admin bool

+ Disabled bool

+ UserID string

+ Username string

+ type GoogleAuthState struct

+ BindingHash string

+ ExpiresAt time.Time

+ InviteID *string

+ Nonce string

+ PkceVerifier string

+ StateHash string

+ type GoogleIdentity struct

+ Email string

+ Sub string

+ UpdatedAt time.Time

+ UserID string

+ type HoldNotificationLeaseParams struct

+ ID string

+ LeaseToken string

+ type IdentityAccountsRow struct

+ Admin bool

+ UserID string

+ Username string

+ type IdentityToken struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ ID string

+ LastUsedAt *time.Time

+ Name string

+ Purpose string

+ SecretHash string

+ UserID string

+ type IdentityTokensRow struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ ID string

+ LastUsedAt *time.Time

+ Name string

+ Purpose string

+ type IngestionJob struct

+ Attempt int32

+ AvailableAt time.Time

+ ContextID string

+ Detail string

+ ID string

+ LeaseToken string

+ LeaseUntil time.Time

+ Payload []byte

+ Sequence int64

+ State string

+ type IngestionRecord struct

+ ContextID string

+ OwnerID string

+ PayloadHash string

+ Sequence int64

+ SourceID string

+ SubmissionID string

+ type IngestionRecordParams struct

+ OwnerID string

+ SourceID string

+ SubmissionID string

+ type IngestionRecordRow struct

+ ContextID string

+ PayloadHash string

+ Sequence int64

+ type InsertAccountUserParams struct

+ CreatedAt time.Time

+ ID string

+ Name string

+ type InsertCommentParams struct

+ CreatedAt int64

+ Data []byte

+ FileID string

+ ID string

+ ReviewID string

+ VersionID string

+ type InsertCommitParams struct

+ Additions int64

+ ContextID string

+ Data []byte

+ Deletions int64

+ DiffID *string

+ FileCount int64

+ Oid string

+ Ordinal int32

+ VersionID *string

+ type InsertCommitRangeParams struct

+ ContextID string

+ Total int64

+ type InsertContextParams struct

+ ID string

+ Now time.Time

+ OwnerID string

+ SubmittedFrom *string

+ type InsertDeliveryParams struct

+ NotificationID string

+ State string

+ SubscriptionID string

+ type InsertDiffFilesParams struct

+ FileIds []string

+ Fingerprints []string

+ PatchDigests []string

+ Patches [][]byte

+ Paths []string

+ VersionID string

+ type InsertDiffParams struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ ID string

+ Mode string

+ OwnerID string

+ type InsertDiffVersionParams struct

+ ComparisonKind string

+ CreatedAt time.Time

+ DiffID string

+ ID string

+ Manifest []byte

+ Revision string

+ Source string

+ type InsertGoogleFlowParams struct

+ BindingHash string

+ ExpiresAt time.Time

+ InviteID *string

+ Nonce string

+ PkceVerifier string

+ StateHash string

+ type InsertGoogleIdentityParams struct

+ Email string

+ Sub string

+ UpdatedAt time.Time

+ UserID string

+ type InsertIdentityParams struct

+ ContextID string

+ IdentityHash string

+ OwnerID string

+ type InsertIdentityTokenParams struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ ID string

+ Name string

+ Purpose string

+ SecretHash string

+ UserID string

+ type InsertIngestionRecordParams struct

+ OwnerID string

+ PayloadHash string

+ SourceID string

+ SubmissionID string

+ type InsertInviteParams struct

+ CreatedAt time.Time

+ Email string

+ ExpiresAt time.Time

+ ID string

+ TokenHash string

+ type InsertJobParams struct

+ AvailableAt time.Time

+ ContextID string

+ ID string

+ Payload []byte

+ Sequence int64

+ State string

+ type InsertNotificationParams struct

+ AvailableAt time.Time

+ ID string

+ JobID string

+ Kind string

+ OwnerID string

+ Payload []byte

+ type InsertObservationParams struct

+ ComparisonPolicy string

+ ContextID string

+ Metadata []byte

+ OwnerID string

+ PayloadHash string

+ RepositoryID *string

+ SourceID string

+ StreamKey string

+ SubmissionID string

+ type InsertObservationSubmissionParams struct

+ ContextID string

+ Metadata []byte

+ OwnerID string

+ PayloadHash string

+ SourceID string

+ SubmissionID string

+ type InsertPushKeysParams struct

+ CreatedAt time.Time

+ PrivateKey string

+ PublicKey string

+ type InsertRemoteAccountParams struct

+ PasswordHash string

+ UserID string

+ Username string

+ type InsertRepositoryParams struct

+ ID string

+ OwnerID string

+ RepositoryKey string

+ type InsertScopeParams struct

+ ContextID string

+ DiffID string

+ Mode string

+ VersionID string

+ type InsertSessionParams struct

+ CsrfToken string

+ Expected string

+ ExpiresAt time.Time

+ SecretHash string

+ UserID string

+ type InsertSubscriptionParams struct

+ Auth string

+ CreatedAt time.Time

+ Endpoint string

+ ID string

+ Label string

+ OwnerID string

+ P256dh string

+ type InviteEmailLockParams struct

+ Email string

+ Namespace int32

+ type InviteRow struct

+ CreatedAt time.Time

+ Email string

+ ExpiresAt time.Time

+ ID string

+ RevokedAt *time.Time

+ UsedAt *time.Time

+ UsedBy string

+ type InvitesRow struct

+ CreatedAt time.Time

+ Email string

+ ExpiresAt time.Time

+ ID string

+ RevokedAt *time.Time

+ UsedAt *time.Time

+ UsedBy string

+ type JobBySequenceRow struct

+ Attempt int32

+ ContextID string

+ Detail string

+ ID string

+ State string

+ SubmissionID string

+ type LockEndpointParams struct

+ Endpoint string

+ LockClass int32

+ type LockGitHubFollowParams struct

+ OwnerID string

+ RepositoryID int64

+ type LockIdentityParams struct

+ IdentityHash string

+ OwnerID string

+ type LockStreamParams struct

+ OwnerID string

+ StreamKey string

+ type LockStreamReviewsParams struct

+ OwnerID string

+ StreamKey string

+ type LoseGitHubInstallationRepositoriesParams struct

+ InstallationID int64

+ RepositoryIds []int64

+ type Mark struct

+ Data []byte

+ FileID string

+ PatchDigest string

+ ReviewID string

+ VersionID *string

+ type MarkGitHubPullRequestOpenedParams struct

+ Number int32

+ RepositoryID int64

+ type MarksParams struct

+ ContextID string

+ Mode string

+ Now time.Time

+ type MarksRow struct

+ DiffID string

+ FileID string

+ Fingerprint string

+ VersionID string

+ type MuteGitHubFollowParams struct

+ OwnerID string

+ RepositoryID int64

+ type NotifyParams struct

+ Channel string

+ Payload string

+ type Observation struct

+ ComparisonPolicy string

+ ContextID string

+ Metadata []byte

+ OwnerID string

+ PayloadHash string

+ RepositoryID *string

+ SourceID string

+ StreamKey string

+ SubmissionID string

+ type ObservationCommit struct

+ Additions int64

+ ContextID string

+ Data []byte

+ Deletions int64

+ DiffID *string

+ FileCount int64

+ Oid string

+ Ordinal int32

+ VersionID *string

+ type ObservationCommitFileVersionParams struct

+ ContextID string

+ FileID string

+ Now time.Time

+ Oid string

+ OwnerID string

+ type ObservationCommitFileVersionRow struct

+ DiffID string

+ Fingerprint *string

+ VersionID string

+ type ObservationCommitManifestParams struct

+ ContextID string

+ Now time.Time

+ Oid string

+ OwnerID string

+ type ObservationCommitPatchParams struct

+ ContextID string

+ FileID string

+ Fingerprint string

+ Now time.Time

+ Oid string

+ OwnerID string

+ type ObservationCommitRange struct

+ ContextID string

+ Total int64

+ type ObservationCommitTotalParams struct

+ ContextID string

+ Now time.Time

+ OwnerID string

+ type ObservationCommitsRow struct

+ Additions int64

+ Data []byte

+ Deletions int64

+ FileCount int64

+ type ObservationFileVersionParams struct

+ ContextID string

+ FileID string

+ Mode string

+ Now time.Time

+ OwnerID string

+ type ObservationFileVersionRow struct

+ DiffID string

+ Fingerprint *string

+ VersionID string

+ type ObservationIdentity struct

+ ContextID string

+ IdentityHash string

+ OwnerID string

+ type ObservationPatchParams struct

+ ContextID string

+ FileID string

+ Fingerprint string

+ Mode string

+ Now time.Time

+ OwnerID string

+ type ObservationRepository struct

+ ID string

+ OwnerID string

+ RepositoryKey string

+ type ObservationRepositoryParams struct

+ ContextID string

+ Now time.Time

+ OwnerID string

+ type ObservationScope struct

+ ContextID string

+ DiffID string

+ Mode string

+ VersionID string

+ type ObservationScopesRow struct

+ DiffID string

+ Mode string

+ type ObservationSession struct

+ ContextID string

+ FirstObservedAt int64

+ Harness string

+ LastObservedAt int64

+ OwnerID string

+ SessionID string

+ SourceID string

+ type ObservationSnapshotParams struct

+ ContextID string

+ Mode string

+ Now time.Time

+ OwnerID string

+ type ObservationSnapshotRow struct

+ Manifest []byte

+ Metadata []byte

+ Modes []string

+ type ObservationStreamHead struct

+ ArrivalSequence int64

+ Branch string

+ CheckoutKey string

+ CollectedAt int64

+ ComparisonPolicy string

+ ContextID string

+ OwnerID string

+ RepositoryKey string

+ SourceID string

+ type ObservationSubmission struct

+ ContextID string

+ Metadata []byte

+ OwnerID string

+ PayloadHash string

+ SourceID string

+ SubmissionID string

+ type OwnedJobParams struct

+ ID string

+ OwnerID string

+ type OwnedJobRow struct

+ Attempt int32

+ ContextID string

+ Detail string

+ ID string

+ State string

+ SubmissionID string

+ type PendingInviteParams struct

+ Now time.Time

+ TokenHash string

+ type PendingInviteRow struct

+ CreatedAt time.Time

+ Email string

+ ExpiresAt time.Time

+ ID string

+ RevokedAt *time.Time

+ UsedAt *time.Time

+ UsedBy string

+ type PushDelivery struct

+ NotificationID string

+ State string

+ SubscriptionID string

+ type PushKey struct

+ CreatedAt time.Time

+ PrivateKey string

+ PublicKey string

+ Singleton bool

+ type PushKeysRow struct

+ PrivateKey string

+ PublicKey string

+ type PushNotification struct

+ Attempt int32

+ AvailableAt time.Time

+ CreatedAt time.Time

+ ID string

+ JobID string

+ Kind string

+ LeaseToken string

+ LeaseUntil time.Time

+ OwnerID string

+ Payload []byte

+ State string

+ type PushSubscription struct

+ Auth string

+ CreatedAt time.Time

+ Endpoint string

+ ID string

+ Label string

+ LastSuccessAt *time.Time

+ OwnerID string

+ P256dh string

+ type PutAdminSetupParams struct

+ ExpiresAt time.Time

+ TokenHash string

+ type PutGitHubConnectionParams struct

+ AccessExpiresAt time.Time

+ AccessToken []byte

+ ConnectedAt time.Time

+ Login string

+ OwnerID string

+ RefreshExpiresAt time.Time

+ RefreshToken []byte

+ Status string

+ UserID int64

+ type PutGitHubFollowParams struct

+ CreatedAt time.Time

+ FullName string

+ InstallationID int64

+ OwnerID string

+ RepositoryID int64

+ Status string

+ VerifiedAt time.Time

+ type PutGitHubOAuthStateParams struct

+ ExpiresAt time.Time

+ OwnerID string

+ StateHash string

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) AccountPassword(ctx context.Context, username string) (AccountPasswordRow, error)

+ func (q *Queries) AccountPasswordByID(ctx context.Context, userID string) (AccountPasswordByIDRow, error)

+ func (q *Queries) AccountSummaries(ctx context.Context) ([]AccountSummariesRow, error)

+ func (q *Queries) ActiveJobUsage(ctx context.Context) (ActiveJobUsageRow, error)

+ func (q *Queries) AdminExists(ctx context.Context) (bool, error)

+ func (q *Queries) AdvanceStreamHead(ctx context.Context, arg AdvanceStreamHeadParams) error

+ func (q *Queries) BindSubmission(ctx context.Context, arg BindSubmissionParams) error

+ func (q *Queries) ClaimGitHubRefresh(ctx context.Context, arg ClaimGitHubRefreshParams) (ClaimGitHubRefreshRow, error)

+ func (q *Queries) ClaimJob(ctx context.Context, arg ClaimJobParams) (ClaimJobRow, error)

+ func (q *Queries) ClaimNotifications(ctx context.Context, arg ClaimNotificationsParams) ([]ClaimNotificationsRow, error)

+ func (q *Queries) Comments(ctx context.Context, arg CommentsParams) ([][]byte, error)

+ func (q *Queries) CompleteGitHubRefresh(ctx context.Context, arg CompleteGitHubRefreshParams) (int64, error)

+ func (q *Queries) CompleteJob(ctx context.Context, arg CompleteJobParams) (int64, error)

+ func (q *Queries) ConsumeAdminSetup(ctx context.Context, arg ConsumeAdminSetupParams) (int64, error)

+ func (q *Queries) ContextExpiry(ctx context.Context, arg ContextExpiryParams) (*time.Time, error)

+ func (q *Queries) ContextForDelete(ctx context.Context, arg ContextForDeleteParams) (ContextForDeleteRow, error)

+ func (q *Queries) ContextStream(ctx context.Context, arg ContextStreamParams) (ContextStreamRow, error)

+ func (q *Queries) CountAuthAttempt(ctx context.Context, arg CountAuthAttemptParams) (int32, error)

+ func (q *Queries) DeleteAccountJobs(ctx context.Context, ownerID string) error

+ func (q *Queries) DeleteAccountSessions(ctx context.Context, userID string) error

+ func (q *Queries) DeleteAccountTokens(ctx context.Context, userID string) error

+ func (q *Queries) DeleteAccountUser(ctx context.Context, id string) error

+ func (q *Queries) DeleteContextDiffs(ctx context.Context, arg DeleteContextDiffsParams) error

+ func (q *Queries) DeleteDiff(ctx context.Context, arg DeleteDiffParams) error

+ func (q *Queries) DeleteGitHubConnection(ctx context.Context, ownerID string) error

+ func (q *Queries) DeleteGitHubFollow(ctx context.Context, arg DeleteGitHubFollowParams) error

+ func (q *Queries) DeleteIdentityToken(ctx context.Context, arg DeleteIdentityTokenParams) (int64, error)

+ func (q *Queries) DeleteOwnedSubscription(ctx context.Context, arg DeleteOwnedSubscriptionParams) (int64, error)

+ func (q *Queries) DeleteSession(ctx context.Context, secretHash string) error

+ func (q *Queries) DeleteStreamComments(ctx context.Context, arg DeleteStreamCommentsParams) (int64, error)

+ func (q *Queries) DeleteSubscriptionByID(ctx context.Context, id string) error

+ func (q *Queries) DeleteVisibleMarks(ctx context.Context, arg DeleteVisibleMarksParams) error

+ func (q *Queries) DisableAccount(ctx context.Context, arg DisableAccountParams) error

+ func (q *Queries) EmailLinked(ctx context.Context, email string) (bool, error)

+ func (q *Queries) EnableAccount(ctx context.Context, userID string) error

+ func (q *Queries) EndStream(ctx context.Context, arg EndStreamParams) error

+ func (q *Queries) EndStreams(ctx context.Context) error

+ func (q *Queries) EnsureReview(ctx context.Context, arg EnsureReviewParams) error

+ func (q *Queries) ExtendObservation(ctx context.Context, arg ExtendObservationParams) error

+ func (q *Queries) FailJob(ctx context.Context, arg FailJobParams) (int64, error)

+ func (q *Queries) FinishNotification(ctx context.Context, arg FinishNotificationParams) (int64, error)

+ func (q *Queries) ForgetIdentity(ctx context.Context, arg ForgetIdentityParams) error

+ func (q *Queries) GitHubConnection(ctx context.Context, ownerID string) (GithubConnection, error)

+ func (q *Queries) GitHubConnections(ctx context.Context) ([]GithubConnection, error)

+ func (q *Queries) GitHubFollows(ctx context.Context, ownerID string) ([]GitHubFollowsRow, error)

+ func (q *Queries) GitHubKnownOpen(ctx context.Context, repositoryID int64) ([]int32, error)

+ func (q *Queries) GitHubLeased(ctx context.Context, arg GitHubLeasedParams) (GitHubLeasedRow, error)

+ func (q *Queries) GitHubPullRequestHead(ctx context.Context, arg GitHubPullRequestHeadParams) (GitHubPullRequestHeadRow, error)

+ func (q *Queries) GitHubReconcileUnlock(ctx context.Context, key int64) (bool, error)

+ func (q *Queries) GitHubRepositoryFollows(ctx context.Context, repositoryID int64) ([]GitHubRepositoryFollowsRow, error)

+ func (q *Queries) GoogleAccount(ctx context.Context, sub string) (GoogleAccountRow, error)

+ func (q *Queries) GoogleEmail(ctx context.Context, userID string) (string, error)

+ func (q *Queries) HoldNotificationLease(ctx context.Context, arg HoldNotificationLeaseParams) (bool, error)

+ func (q *Queries) IdentityAccounts(ctx context.Context) ([]IdentityAccountsRow, error)

+ func (q *Queries) IdentityLock(ctx context.Context, key int64) error

+ func (q *Queries) IdentityTokens(ctx context.Context, userID string) ([]IdentityTokensRow, error)

+ func (q *Queries) IngestionRecord(ctx context.Context, arg IngestionRecordParams) (IngestionRecordRow, error)

+ func (q *Queries) InsertAccountUser(ctx context.Context, arg InsertAccountUserParams) error

+ func (q *Queries) InsertAdmin(ctx context.Context, userID string) error

+ func (q *Queries) InsertComment(ctx context.Context, arg InsertCommentParams) (int64, error)

+ func (q *Queries) InsertCommit(ctx context.Context, arg InsertCommitParams) error

+ func (q *Queries) InsertCommitRange(ctx context.Context, arg InsertCommitRangeParams) error

+ func (q *Queries) InsertContext(ctx context.Context, arg InsertContextParams) error

+ func (q *Queries) InsertDelivery(ctx context.Context, arg InsertDeliveryParams) error

+ func (q *Queries) InsertDiff(ctx context.Context, arg InsertDiffParams) error

+ func (q *Queries) InsertDiffFiles(ctx context.Context, arg InsertDiffFilesParams) error

+ func (q *Queries) InsertDiffVersion(ctx context.Context, arg InsertDiffVersionParams) error

+ func (q *Queries) InsertGoogleFlow(ctx context.Context, arg InsertGoogleFlowParams) error

+ func (q *Queries) InsertGoogleIdentity(ctx context.Context, arg InsertGoogleIdentityParams) (int64, error)

+ func (q *Queries) InsertIdentity(ctx context.Context, arg InsertIdentityParams) error

+ func (q *Queries) InsertIdentityToken(ctx context.Context, arg InsertIdentityTokenParams) (int64, error)

+ func (q *Queries) InsertIngestionRecord(ctx context.Context, arg InsertIngestionRecordParams) error

+ func (q *Queries) InsertInvite(ctx context.Context, arg InsertInviteParams) error

+ func (q *Queries) InsertJob(ctx context.Context, arg InsertJobParams) error

+ func (q *Queries) InsertNotification(ctx context.Context, arg InsertNotificationParams) error

+ func (q *Queries) InsertObservation(ctx context.Context, arg InsertObservationParams) error

+ func (q *Queries) InsertObservationSubmission(ctx context.Context, arg InsertObservationSubmissionParams) error

+ func (q *Queries) InsertPushKeys(ctx context.Context, arg InsertPushKeysParams) error

+ func (q *Queries) InsertRemoteAccount(ctx context.Context, arg InsertRemoteAccountParams) (int64, error)

+ func (q *Queries) InsertRepository(ctx context.Context, arg InsertRepositoryParams) error

+ func (q *Queries) InsertScope(ctx context.Context, arg InsertScopeParams) error

+ func (q *Queries) InsertSession(ctx context.Context, arg InsertSessionParams) (int64, error)

+ func (q *Queries) InsertSubscription(ctx context.Context, arg InsertSubscriptionParams) error

+ func (q *Queries) Invite(ctx context.Context, id string) (InviteRow, error)

+ func (q *Queries) InviteEmailLock(ctx context.Context, arg InviteEmailLockParams) error

+ func (q *Queries) Invites(ctx context.Context) ([]InvitesRow, error)

+ func (q *Queries) JobBySequence(ctx context.Context, sequence int64) (JobBySequenceRow, error)

+ func (q *Queries) LockEndingStreams(ctx context.Context) error

+ func (q *Queries) LockEndpoint(ctx context.Context, arg LockEndpointParams) error

+ func (q *Queries) LockExpiredContexts(ctx context.Context, now time.Time) error

+ func (q *Queries) LockGitHubFollow(ctx context.Context, arg LockGitHubFollowParams) (bool, error)

+ func (q *Queries) LockIdentity(ctx context.Context, arg LockIdentityParams) error

+ func (q *Queries) LockSessionAccount(ctx context.Context, userID string) error

+ func (q *Queries) LockStream(ctx context.Context, arg LockStreamParams) error

+ func (q *Queries) LockStreamReviews(ctx context.Context, arg LockStreamReviewsParams) error

+ func (q *Queries) LockTargetAccount(ctx context.Context, userID string) (bool, error)

+ func (q *Queries) LoseGitHubInstallation(ctx context.Context, installationID int64) error

+ func (q *Queries) LoseGitHubInstallationRepositories(ctx context.Context, arg LoseGitHubInstallationRepositoriesParams) error

+ func (q *Queries) LoseGitHubUserFollows(ctx context.Context, userID int64) error

+ func (q *Queries) MarkGitHubPullRequestOpened(ctx context.Context, arg MarkGitHubPullRequestOpenedParams) error

+ func (q *Queries) Marks(ctx context.Context, arg MarksParams) ([]MarksRow, error)

+ func (q *Queries) MuteGitHubFollow(ctx context.Context, arg MuteGitHubFollowParams) error

+ func (q *Queries) Notify(ctx context.Context, arg NotifyParams) error

+ func (q *Queries) ObservationCommitFileVersion(ctx context.Context, arg ObservationCommitFileVersionParams) (ObservationCommitFileVersionRow, error)

+ func (q *Queries) ObservationCommitManifest(ctx context.Context, arg ObservationCommitManifestParams) ([]byte, error)

+ func (q *Queries) ObservationCommitPatch(ctx context.Context, arg ObservationCommitPatchParams) ([]byte, error)

+ func (q *Queries) ObservationCommitTotal(ctx context.Context, arg ObservationCommitTotalParams) (*int64, error)

+ func (q *Queries) ObservationCommits(ctx context.Context, contextID string) ([]ObservationCommitsRow, error)

+ func (q *Queries) ObservationFileVersion(ctx context.Context, arg ObservationFileVersionParams) (ObservationFileVersionRow, error)

+ func (q *Queries) ObservationPatch(ctx context.Context, arg ObservationPatchParams) ([]byte, error)

+ func (q *Queries) ObservationRepository(ctx context.Context, arg ObservationRepositoryParams) (*string, error)

+ func (q *Queries) ObservationScopes(ctx context.Context, contextID string) ([]ObservationScopesRow, error)

+ func (q *Queries) ObservationSnapshot(ctx context.Context, arg ObservationSnapshotParams) (ObservationSnapshotRow, error)

+ func (q *Queries) OwnedJob(ctx context.Context, arg OwnedJobParams) (OwnedJobRow, error)

+ func (q *Queries) PendingInvite(ctx context.Context, arg PendingInviteParams) (PendingInviteRow, error)

+ func (q *Queries) PruneAuthAttempts(ctx context.Context, expired time.Time) error

+ func (q *Queries) PruneBrowserSessions(ctx context.Context, expiresAt time.Time) error

+ func (q *Queries) PruneExpiredDiffs(ctx context.Context, expiresAt *time.Time) error

+ func (q *Queries) PruneExpiredObservationDiffs(ctx context.Context, expiresAt *time.Time) error

+ func (q *Queries) PruneFinishedNotifications(ctx context.Context, createdAt time.Time) error

+ func (q *Queries) PruneGitHubDeliveries(ctx context.Context, receivedAt time.Time) error

+ func (q *Queries) PruneGitHubStates(ctx context.Context, expiresAt time.Time) error

+ func (q *Queries) PruneGoogleFlows(ctx context.Context, expiresAt time.Time) error

+ func (q *Queries) PushKeys(ctx context.Context) (PushKeysRow, error)

+ func (q *Queries) PutAdminSetup(ctx context.Context, arg PutAdminSetupParams) (int64, error)

+ func (q *Queries) PutGitHubConnection(ctx context.Context, arg PutGitHubConnectionParams) error

+ func (q *Queries) PutGitHubFollow(ctx context.Context, arg PutGitHubFollowParams) error

+ func (q *Queries) PutGitHubOAuthState(ctx context.Context, arg PutGitHubOAuthStateParams) error

+ func (q *Queries) RecordGitHubDelivery(ctx context.Context, arg RecordGitHubDeliveryParams) error

+ func (q *Queries) RecordGitHubLease(ctx context.Context, arg RecordGitHubLeaseParams) (int64, error)

+ func (q *Queries) RecordGitHubPullRequestHead(ctx context.Context, arg RecordGitHubPullRequestHeadParams) error

+ func (q *Queries) RecordGoogleEmail(ctx context.Context, arg RecordGoogleEmailParams) error

+ func (q *Queries) RecordSubscriptionSuccess(ctx context.Context, arg RecordSubscriptionSuccessParams) error

+ func (q *Queries) RefreshContext(ctx context.Context, arg RefreshContextParams) error

+ func (q *Queries) ReleaseGitHubRefresh(ctx context.Context, arg ReleaseGitHubRefreshParams) (int64, error)

+ func (q *Queries) RenewJob(ctx context.Context, arg RenewJobParams) (int64, error)

+ func (q *Queries) ReplacePassword(ctx context.Context, arg ReplacePasswordParams) (int64, error)

+ func (q *Queries) RepositoryID(ctx context.Context, arg RepositoryIDParams) (string, error)

+ func (q *Queries) RequestGitHubRefresh(ctx context.Context, arg RequestGitHubRefreshParams) error

+ func (q *Queries) ResolveIdentityToken(ctx context.Context, arg ResolveIdentityTokenParams) (ResolveIdentityTokenRow, error)

+ func (q *Queries) ResolveSession(ctx context.Context, arg ResolveSessionParams) (ResolveSessionRow, error)

+ func (q *Queries) RetryJob(ctx context.Context, arg RetryJobParams) (int64, error)

+ func (q *Queries) RetryNotification(ctx context.Context, arg RetryNotificationParams) (int64, error)

+ func (q *Queries) ReusableObservation(ctx context.Context, arg ReusableObservationParams) (string, error)

+ func (q *Queries) RevokeGitHubUserConnections(ctx context.Context, userID int64) error

+ func (q *Queries) RevokeInvite(ctx context.Context, arg RevokeInviteParams) (int64, error)

+ func (q *Queries) RevokePendingInvites(ctx context.Context, arg RevokePendingInvitesParams) error

+ func (q *Queries) SchemaFloor(ctx context.Context) (int64, error)

+ func (q *Queries) ScopeFileDigest(ctx context.Context, arg ScopeFileDigestParams) (string, error)

+ func (q *Queries) ScopeReview(ctx context.Context, arg ScopeReviewParams) (ScopeReviewRow, error)

+ func (q *Queries) SeenGitHubDelivery(ctx context.Context, id string) (bool, error)

+ func (q *Queries) StoredComment(ctx context.Context, arg StoredCommentParams) ([]byte, error)

+ func (q *Queries) StoredVersion(ctx context.Context, arg StoredVersionParams) (StoredVersionRow, error)

+ func (q *Queries) SubscriptionByEndpoint(ctx context.Context, endpoint string) (PushSubscription, error)

+ func (q *Queries) Subscriptions(ctx context.Context, ownerID string) ([]PushSubscription, error)

+ func (q *Queries) TakeGitHubOAuthState(ctx context.Context, arg TakeGitHubOAuthStateParams) (string, error)

+ func (q *Queries) TakeGoogleFlow(ctx context.Context, arg TakeGoogleFlowParams) (TakeGoogleFlowRow, error)

+ func (q *Queries) TryGitHubReconcileLock(ctx context.Context, key int64) (bool, error)

+ func (q *Queries) TryPruneLock(ctx context.Context, key int64) (bool, error)

+ func (q *Queries) Undelivered(ctx context.Context, id string) ([]PushSubscription, error)

+ func (q *Queries) UnmuteGitHubFollow(ctx context.Context, arg UnmuteGitHubFollowParams) error

+ func (q *Queries) UpdateComment(ctx context.Context, arg UpdateCommentParams) (int64, error)

+ func (q *Queries) UpdateSubscription(ctx context.Context, arg UpdateSubscriptionParams) error

+ func (q *Queries) UpsertAgentSession(ctx context.Context, arg UpsertAgentSessionParams) error

+ func (q *Queries) UpsertMark(ctx context.Context, arg UpsertMarkParams) error

+ func (q *Queries) UpsertObservationSession(ctx context.Context, arg UpsertObservationSessionParams) error

+ func (q *Queries) UseInvite(ctx context.Context, arg UseInviteParams) (int64, error)

+ func (q *Queries) VersionInDiff(ctx context.Context, arg VersionInDiffParams) (int64, error)

+ func (q *Queries) WithTx(tx pgx.Tx) *Queries

+ type RecordGitHubDeliveryParams struct

+ Event string

+ ID string

+ ReceivedAt time.Time

+ type RecordGitHubLeaseParams struct

+ Leased []byte

+ Now time.Time

+ Number int32

+ RepositoryID int64

+ Token string

+ type RecordGitHubPullRequestHeadParams struct

+ HeadSha string

+ Number int32

+ RepositoryID int64

+ type RecordGoogleEmailParams struct

+ Email string

+ Now time.Time

+ Sub string

+ type RecordSubscriptionSuccessParams struct

+ ID string

+ LastSuccessAt time.Time

+ type RefreshContextParams struct

+ ID string

+ Now time.Time

+ type ReleaseGitHubRefreshParams struct

+ Detail string

+ Number int32

+ RepositoryID int64

+ RetryAt time.Time

+ Token string

+ type RemoteAccount struct

+ PasswordHash string

+ UserID string

+ Username string

+ type RenewJobParams struct

+ ID string

+ LeaseToken string

+ LeaseUntil time.Time

+ Now time.Time

+ type ReplacePasswordParams struct

+ Expected string

+ Replacement string

+ UserID string

+ type RepositoryIDParams struct

+ OwnerID string

+ RepositoryKey string

+ type RequestGitHubRefreshParams struct

+ FullName string

+ InstallationID int64

+ Number int32

+ RepositoryID int64

+ RequestedAt time.Time

+ RetentionRun string

+ type ResolveIdentityTokenParams struct

+ Now time.Time

+ SecretHash string

+ type ResolveIdentityTokenRow struct

+ Admin bool

+ ExpiresAt time.Time

+ Purpose string

+ UserID string

+ Username string

+ type ResolveSessionParams struct

+ Now time.Time

+ SecretHash string

+ type ResolveSessionRow struct

+ Admin bool

+ CsrfToken string

+ ExpiresAt time.Time

+ UserID string

+ Username string

+ type RetryJobParams struct

+ AvailableAt time.Time

+ Detail string

+ ID string

+ LeaseToken string

+ Now time.Time

+ type RetryNotificationParams struct

+ Attempt int32

+ AvailableAt time.Time

+ ID string

+ LeaseToken string

+ type ReusableObservationParams struct

+ IdentityHash string

+ Now time.Time

+ OwnerID string

+ type Review struct

+ ID string

+ Mode string

+ OwnerID string

+ StreamKey string

+ type RevokeInviteParams struct

+ At time.Time

+ ID string

+ type RevokePendingInvitesParams struct

+ At time.Time

+ Email string

+ type SchemaCompatibility struct

+ Floor int64

+ Singleton bool

+ type ScopeFileDigestParams struct

+ ContextID string

+ FileID string

+ Mode string

+ type ScopeReviewParams struct

+ ContextID string

+ Mode string

+ Now time.Time

+ type ScopeReviewRow struct

+ DiffID string

+ ReviewID string

+ type StoredCommentParams struct

+ ID string

+ ReviewID string

+ type StoredVersionParams struct

+ DiffID string

+ Now time.Time

+ OwnerID string

+ VersionID string

+ type StoredVersionRow struct

+ Manifest []byte

+ Metadata []byte

+ Modes []string

+ type TakeGitHubOAuthStateParams struct

+ Now time.Time

+ StateHash string

+ type TakeGoogleFlowParams struct

+ Now time.Time

+ StateHash string

+ type TakeGoogleFlowRow struct

+ BindingHash string

+ ExpiresAt time.Time

+ InviteID *string

+ Nonce string

+ PkceVerifier string

+ type UnmuteGitHubFollowParams struct

+ OwnerID string

+ RepositoryID int64

+ type UpdateCommentParams struct

+ Data []byte

+ FileID string

+ ID string

+ ReviewID string

+ VersionID string

+ type UpdateSubscriptionParams struct

+ Auth string

+ ID string

+ Label string

+ P256dh string

+ type UpsertAgentSessionParams struct

+ Harness string

+ Name string

+ NamedAt int64

+ OwnerID string

+ SessionID string

+ SourceID string

+ type UpsertMarkParams struct

+ Data []byte

+ FileID string

+ PatchDigest string

+ ReviewID string

+ VersionID *string

+ type UpsertObservationSessionParams struct

+ ContextID string

+ Harness string

+ ObservedAt int64

+ OwnerID string

+ SessionID string

+ SourceID string

+ type UseInviteParams struct

+ ID string

+ Now time.Time

+ Sub string

+ UserID string

+ type User struct

+ CreatedAt time.Time

+ ID string

+ Name string

+ type VersionInDiffParams struct

+ DiffID string

+ ID string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL