Help us shape the future of Go! Take the 2026 Go Developer Survey

pgdb

package
v0.2.5 Latest Latest
Warning

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

 Go to latest Published: Nov 1, 2026 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccountInvite 

type AccountInvite struct {
	ID        string
	TokenHash string
	Email     string
	CreatedAt time.Time
	ExpiresAt time.Time
	UsedAt    *time.Time
	UsedBy    *string
	RevokedAt *time.Time
}

type AccountPasswordByIDRow 

type AccountPasswordByIDRow struct {
	UserID       string
	Email        string
	Admin        bool
	Method       string
	PasswordHash string
}

type AccountPasswordRow 

type AccountPasswordRow struct {
	UserID       string
	Email        string
	Admin        bool
	Method       string
	PasswordHash string
}

type AccountSummariesRow 

type AccountSummariesRow struct {
	UserID    string
	Admin     bool
	Email     string
	Disabled  bool
	Method    string
	CreatedAt time.Time
}

type ActiveJobUsageRow 

type ActiveJobUsageRow struct {
	Jobs  int64
	Bytes int64
}

type AdminAccount 

type AdminAccount struct {
	UserID string
}

type AdminSetup 

type AdminSetup struct {
	Singleton bool
	TokenHash string
	ExpiresAt time.Time
}

type AdvanceStreamHeadParams 

type AdvanceStreamHeadParams struct {
	OwnerID          string
	SourceID         string
	RepositoryKey    string
	CheckoutKey      string
	Branch           string
	ComparisonPolicy string
	ContextID        string
	CollectedAt      int64
	ArrivalSequence  int64
}

type AgentSession 

type AgentSession struct {
	OwnerID   string
	SourceID  string
	Harness   string
	SessionID string
	Name      string
	NamedAt   int64
}

type AppSetting added in v0.2.4 

type AppSetting struct {
	Singleton      bool
	SignupOpen     bool
	PasswordSignup bool
	UpdatedAt      time.Time
	UpdatedBy      *string
}

type AppSettingsRow added in v0.2.4 

type AppSettingsRow struct {
	SignupOpen     bool
	PasswordSignup bool
}

type AuthAttempt 

type AuthAttempt struct {
	Client      string
	WindowStart time.Time
	Attempts    int32
}

type BindSubmissionParams 

type BindSubmissionParams struct {
	Sequence  int64
	ContextID string
}

type BrowserSession 

type BrowserSession struct {
	SecretHash string
	UserID     string
	CsrfToken  string
	ExpiresAt  time.Time
}

type ClaimGitHubRefreshParams 

type ClaimGitHubRefreshParams struct {
	Token      string
	LeaseUntil time.Time
	Now        time.Time
}

type ClaimGitHubRefreshRow 

type ClaimGitHubRefreshRow struct {
	RepositoryID     int64
	InstallationID   int64
	FullName         string
	Number           int32
	LeasedGeneration int64
	LeasedRun        string
	Attempt          int32
}

type ClaimJobParams 

type ClaimJobParams struct {
	LeaseToken string
	LeaseUntil time.Time
	Now        time.Time
}

type ClaimJobRow 

type ClaimJobRow struct {
	ID           string
	OwnerID      string
	SubmissionID string
	Payload      []byte
	Attempt      int32
}

type ClaimNotificationsParams 

type ClaimNotificationsParams struct {
	Now        time.Time
	MaxCount   int32
	LeaseToken string
	LeaseUntil time.Time
}

type ClaimNotificationsRow 

type ClaimNotificationsRow struct {
	ID           string
	OwnerID      string
	Kind         string
	Payload      []byte
	Attempt      int32
	CreatedAt    time.Time
	Available    bool
	JobState     string
	JobContextID string
}

type Comment 

type Comment struct {
	ID        string
	ReviewID  string
	VersionID *string
	FileID    string
	Data      []byte
	CreatedAt int64
}

type CommentsParams 

type CommentsParams struct {
	ContextID string
	Now       time.Time
}

type CompleteGitHubRefreshParams 

type CompleteGitHubRefreshParams struct {
	State        string
	RepositoryID int64
	Number       int32
	Token        string
	Now          time.Time
}

type CompleteJobParams 

type CompleteJobParams struct {
	ContextID  string
	ID         string
	LeaseToken string
	Now        time.Time
}

type ConsumeAdminSetupParams 

type ConsumeAdminSetupParams struct {
	TokenHash string
	Now       time.Time
}

type ConsumePasswordResetParams added in v0.2.4 

type ConsumePasswordResetParams struct {
	TokenHash string
	Now       time.Time
}

type Context 

type Context struct {
	ID              string
	OwnerID         string
	Kind            string
	AnchorDiffID    string
	CreatedAt       time.Time
	LastSubmittedAt time.Time
	SubmittedFrom   *string
}

type ContextExpiryParams 

type ContextExpiryParams struct {
	OwnerID string
	ID      string
}

type ContextForDeleteParams 

type ContextForDeleteParams struct {
	OwnerID string
	ID      string
}

type ContextForDeleteRow 

type ContextForDeleteRow struct {
	AnchorDiffID string
	StreamKey    *string
}

type ContextStreamParams 

type ContextStreamParams struct {
	OwnerID string
	ID      string
}

type ContextStreamRow 

type ContextStreamRow struct {
	ExpiresAt            *time.Time
	HeadSourceID         *string
	HeadRepositoryKey    *string
	HeadCheckoutKey      *string
	HeadBranch           *string
	HeadComparisonPolicy *string
}

type CountAuthAttemptParams 

type CountAuthAttemptParams struct {
	Client  string
	Now     time.Time
	Expired time.Time
}

type DBTX 

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type DeleteContextDiffsParams 

type DeleteContextDiffsParams struct {
	OwnerID   string
	AnchorID  string
	ContextID string
}

type DeleteDiffParams 

type DeleteDiffParams struct {
	OwnerID string
	ID      string
}

type DeleteGitHubFollowParams 

type DeleteGitHubFollowParams struct {
	OwnerID      string
	RepositoryID int64
}

type DeleteIdentityTokenParams 

type DeleteIdentityTokenParams struct {
	UserID string
	ID     string
}

type DeleteOwnedSubscriptionParams 

type DeleteOwnedSubscriptionParams struct {
	OwnerID string
	ID      string
}

type DeleteStreamCommentsParams 

type DeleteStreamCommentsParams struct {
	Ids       []string
	ContextID string
}

type DeleteVisibleMarksParams 

type DeleteVisibleMarksParams struct {
	Mode      string
	ContextID string
	FileID    *string
}

type Diff 

type Diff struct {
	ID        string
	OwnerID   string
	Kind      string
	Mode      string
	CreatedAt time.Time
	ExpiresAt *time.Time
}

type DiffFile 

type DiffFile struct {
	VersionID   string
	FileID      string
	Path        string
	Fingerprint string
	Patch       []byte
	PatchDigest string
}

type DiffVersion 

type DiffVersion struct {
	ID             string
	DiffID         string
	Revision       string
	Manifest       []byte
	Source         string
	ComparisonKind string
	CreatedAt      time.Time
}

type DisableAccountParams 

type DisableAccountParams struct {
	UserID     string
	DisabledAt time.Time
}

type DisabledAccount 

type DisabledAccount struct {
	UserID     string
	DisabledAt time.Time
}

type EndStreamParams 

type EndStreamParams struct {
	OwnerID   string
	StreamKey string
}

type EnsureReviewParams 

type EnsureReviewParams struct {
	ID        string
	OwnerID   string
	StreamKey string
	Mode      string
}

type ExtendObservationParams 

type ExtendObservationParams struct {
	ExpiresAt time.Time
	ContextID string
}

type FailJobParams 

type FailJobParams struct {
	Detail     string
	ID         string
	LeaseToken string
	Now        time.Time
}

type FinishNotificationParams 

type FinishNotificationParams struct {
	State      string
	ID         string
	LeaseToken string
}

type ForgetIdentityParams 

type ForgetIdentityParams struct {
	OwnerID      string
	IdentityHash string
}

type GitHubFollowsRow 

type GitHubFollowsRow struct {
	OwnerID        string
	RepositoryID   int64
	InstallationID int64
	FullName       string
	Status         string
	VerifiedAt     time.Time
	CreatedAt      time.Time
	Muted          bool
}

type GitHubLeasedParams 

type GitHubLeasedParams struct {
	RepositoryID int64
	Number       int32
	Token        string
	Now          time.Time
}

type GitHubLeasedRow 

type GitHubLeasedRow struct {
	RepositoryID     int64
	InstallationID   int64
	FullName         string
	Number           int32
	LeasedGeneration int64
	LeasedRun        string
	Attempt          int32
	Leased           []byte
}

type GitHubPullRequestHeadParams 

type GitHubPullRequestHeadParams struct {
	RepositoryID int64
	Number       int32
}

type GitHubPullRequestHeadRow 

type GitHubPullRequestHeadRow struct {
	HeadSha string
	Opened  bool
}

type GitHubRepositoryFollowsRow 

type GitHubRepositoryFollowsRow struct {
	OwnerID        string
	RepositoryID   int64
	InstallationID int64
	FullName       string
	Status         string
	VerifiedAt     time.Time
	CreatedAt      time.Time
	Muted          bool
}

type GithubConnection 

type GithubConnection struct {
	OwnerID          string
	UserID           int64
	Login            string
	AccessToken      []byte
	AccessExpiresAt  time.Time
	RefreshToken     []byte
	RefreshExpiresAt time.Time
	Status           string
	ConnectedAt      time.Time
}

type GithubDelivery 

type GithubDelivery struct {
	ID         string
	Event      string
	ReceivedAt time.Time
}

type GithubFollow 

type GithubFollow struct {
	OwnerID        string
	RepositoryID   int64
	InstallationID int64
	FullName       string
	Status         string
	VerifiedAt     time.Time
	CreatedAt      time.Time
}

type GithubFollowMute 

type GithubFollowMute struct {
	OwnerID      string
	RepositoryID int64
}

type GithubOauthState 

type GithubOauthState struct {
	StateHash string
	OwnerID   string
	ExpiresAt time.Time
}

type GithubPrHead 

type GithubPrHead struct {
	RepositoryID int64
	Number       int32
	HeadSha      string
	Opened       bool
}

type GithubPullRequest 

type GithubPullRequest struct {
	RepositoryID        int64
	Number              int32
	InstallationID      int64
	FullName            string
	Generation          int64
	RefreshedGeneration int64
	State               string
	RetentionRun        string
	RequestedAt         time.Time
	LeaseToken          string
	LeaseUntil          time.Time
	LeasedGeneration    int64
	LeasedRun           string
	Leased              []byte
	Attempt             int32
	AvailableAt         time.Time
	Detail              string
}

type GoogleAccountRow 

type GoogleAccountRow struct {
	UserID   string
	Admin    bool
	Disabled bool
}

type GoogleAuthState 

type GoogleAuthState struct {
	StateHash    string
	BindingHash  string
	Nonce        string
	PkceVerifier string
	InviteID     *string
	ExpiresAt    time.Time
	SetupHash    *string
}

type GoogleIdentity 

type GoogleIdentity struct {
	Sub       string
	UserID    string
	Email     string
	UpdatedAt time.Time
}

type HoldNotificationLeaseParams 

type HoldNotificationLeaseParams struct {
	ID         string
	LeaseToken string
}

type IdentityAccountsRow 

type IdentityAccountsRow struct {
	UserID string
	Email  string
	Admin  bool
	Method string
}

type IdentityToken 

type IdentityToken struct {
	ID         string
	UserID     string
	Name       string
	Purpose    string
	SecretHash string
	CreatedAt  time.Time
	LastUsedAt *time.Time
	ExpiresAt  time.Time
}

type IdentityTokensRow 

type IdentityTokensRow struct {
	ID         string
	Name       string
	Purpose    string
	CreatedAt  time.Time
	LastUsedAt *time.Time
	ExpiresAt  time.Time
}

type IngestionJob 

type IngestionJob struct {
	ID          string
	Sequence    int64
	Payload     []byte
	State       string
	Attempt     int32
	AvailableAt time.Time
	LeaseUntil  time.Time
	LeaseToken  string
	Detail      string
	ContextID   string
}

type IngestionRecord 

type IngestionRecord struct {
	Sequence     int64
	OwnerID      string
	SourceID     string
	SubmissionID string
	PayloadHash  string
	ContextID    string
}

type IngestionRecordParams 

type IngestionRecordParams struct {
	OwnerID      string
	SourceID     string
	SubmissionID string
}

type IngestionRecordRow 

type IngestionRecordRow struct {
	Sequence    int64
	PayloadHash string
	ContextID   string
}

type InsertAccountUserParams 

type InsertAccountUserParams struct {
	ID        string
	Name      string
	CreatedAt time.Time
}

type InsertCommentParams 

type InsertCommentParams struct {
	ID        string
	ReviewID  string
	VersionID string
	FileID    string
	Data      []byte
	CreatedAt int64
}

type InsertCommitParams 

type InsertCommitParams struct {
	ContextID string
	Ordinal   int32
	Oid       string
	Data      []byte
	DiffID    *string
	VersionID *string
	FileCount int64
	Additions int64
	Deletions int64
}

type InsertCommitRangeParams 

type InsertCommitRangeParams struct {
	ContextID string
	Total     int64
}

type InsertContextParams 

type InsertContextParams struct {
	ID            string
	OwnerID       string
	Now           time.Time
	SubmittedFrom *string
}

type InsertDeliveryParams 

type InsertDeliveryParams struct {
	NotificationID string
	SubscriptionID string
	State          string
}

type InsertDiffFilesParams 

type InsertDiffFilesParams struct {
	VersionID    string
	FileIds      []string
	Paths        []string
	Fingerprints []string
	Patches      [][]byte
	PatchDigests []string
}

type InsertDiffParams 

type InsertDiffParams struct {
	ID        string
	OwnerID   string
	Mode      string
	CreatedAt time.Time
	ExpiresAt time.Time
}

type InsertDiffVersionParams 

type InsertDiffVersionParams struct {
	ID             string
	DiffID         string
	Revision       string
	Manifest       []byte
	Source         string
	ComparisonKind string
	CreatedAt      time.Time
}

type InsertGoogleFlowParams 

type InsertGoogleFlowParams struct {
	StateHash    string
	BindingHash  string
	Nonce        string
	PkceVerifier string
	InviteID     *string
	SetupHash    *string
	ExpiresAt    time.Time
}

type InsertGoogleIdentityParams 

type InsertGoogleIdentityParams struct {
	Sub       string
	UserID    string
	Email     string
	UpdatedAt time.Time
}

type InsertIdentityParams 

type InsertIdentityParams struct {
	OwnerID      string
	IdentityHash string
	ContextID    string
}

type InsertIdentityTokenParams 

type InsertIdentityTokenParams struct {
	ID         string
	Name       string
	Purpose    string
	SecretHash string
	CreatedAt  time.Time
	ExpiresAt  time.Time
	UserID     string
}

type InsertIngestionRecordParams 

type InsertIngestionRecordParams struct {
	OwnerID      string
	SourceID     string
	SubmissionID string
	PayloadHash  string
}

type InsertInviteParams 

type InsertInviteParams struct {
	ID        string
	TokenHash string
	Email     string
	CreatedAt time.Time
	ExpiresAt time.Time
}

type InsertJobParams 

type InsertJobParams struct {
	ID          string
	Sequence    int64
	Payload     []byte
	State       string
	AvailableAt time.Time
	ContextID   string
}

type InsertNotificationParams 

type InsertNotificationParams struct {
	ID          string
	OwnerID     string
	JobID       string
	Kind        string
	Payload     []byte
	AvailableAt time.Time
}

type InsertObservationParams 

type InsertObservationParams struct {
	ContextID        string
	OwnerID          string
	SourceID         string
	SubmissionID     string
	PayloadHash      string
	RepositoryID     *string
	Metadata         []byte
	StreamKey        string
	ComparisonPolicy string
}

type InsertObservationSubmissionParams 

type InsertObservationSubmissionParams struct {
	OwnerID      string
	SourceID     string
	SubmissionID string
	ContextID    string
	PayloadHash  string
	Metadata     []byte
}

type InsertPushKeysParams 

type InsertPushKeysParams struct {
	PublicKey  string
	PrivateKey string
	CreatedAt  time.Time
}

type InsertRemoteAccountParams 

type InsertRemoteAccountParams struct {
	UserID       string
	Email        string
	PasswordHash string
}

type InsertRepositoryParams 

type InsertRepositoryParams struct {
	ID            string
	OwnerID       string
	RepositoryKey string
}

type InsertScopeParams 

type InsertScopeParams struct {
	ContextID string
	Mode      string
	DiffID    string
	VersionID string
}

type InsertSessionParams 

type InsertSessionParams struct {
	SecretHash string
	CsrfToken  string
	ExpiresAt  time.Time
	UserID     string
	Expected   string
}

type InsertSubscriptionParams 

type InsertSubscriptionParams struct {
	ID        string
	OwnerID   string
	Endpoint  string
	P256dh    string
	Auth      string
	Label     string
	CreatedAt time.Time
}

type InviteEmailLockParams 

type InviteEmailLockParams struct {
	Namespace int32
	Email     string
}

type InviteRow 

type InviteRow struct {
	ID        string
	Email     string
	CreatedAt time.Time
	ExpiresAt time.Time
	UsedAt    *time.Time
	UsedBy    string
	RevokedAt *time.Time
}

type InvitesRow 

type InvitesRow struct {
	ID        string
	Email     string
	CreatedAt time.Time
	ExpiresAt time.Time
	UsedAt    *time.Time
	UsedBy    string
	RevokedAt *time.Time
}

type JobBySequenceRow 

type JobBySequenceRow struct {
	ID           string
	SubmissionID string
	State        string
	Attempt      int32
	ContextID    string
	Detail       string
}

type LockAppSettingsRow added in v0.2.4 

type LockAppSettingsRow struct {
	SignupOpen     bool
	PasswordSignup bool
}

type LockEndpointParams 

type LockEndpointParams struct {
	LockClass int32
	Endpoint  string
}

type LockGitHubFollowParams 

type LockGitHubFollowParams struct {
	OwnerID      string
	RepositoryID int64
}

type LockIdentityParams 

type LockIdentityParams struct {
	OwnerID      string
	IdentityHash string
}

type LockStreamParams 

type LockStreamParams struct {
	OwnerID   string
	StreamKey string
}

type LockStreamReviewsParams 

type LockStreamReviewsParams struct {
	OwnerID   string
	StreamKey string
}

type LockTargetAccountRow added in v0.2.4 

type LockTargetAccountRow struct {
	Admin    bool
	Disabled bool
}

type LoseGitHubInstallationRepositoriesParams 

type LoseGitHubInstallationRepositoriesParams struct {
	InstallationID int64
	RepositoryIds  []int64
}

type Mark 

type Mark struct {
	ReviewID    string
	FileID      string
	VersionID   *string
	PatchDigest string
	Data        []byte
}

type MarkGitHubPullRequestOpenedParams 

type MarkGitHubPullRequestOpenedParams struct {
	RepositoryID int64
	Number       int32
}

type MarksParams 

type MarksParams struct {
	Mode      string
	ContextID string
	Now       time.Time
}

type MarksRow 

type MarksRow struct {
	DiffID      string
	VersionID   string
	FileID      string
	Fingerprint string
}

type MuteGitHubFollowParams 

type MuteGitHubFollowParams struct {
	OwnerID      string
	RepositoryID int64
}

type NotifyParams 

type NotifyParams struct {
	Channel string
	Payload string
}

type Observation 

type Observation struct {
	ContextID        string
	OwnerID          string
	SourceID         string
	SubmissionID     string
	PayloadHash      string
	RepositoryID     *string
	Metadata         []byte
	StreamKey        string
	ComparisonPolicy string
}

type ObservationCommit 

type ObservationCommit struct {
	ContextID string
	Ordinal   int32
	Oid       string
	Data      []byte
	DiffID    *string
	VersionID *string
	FileCount int64
	Additions int64
	Deletions int64
}

type ObservationCommitFileVersionParams 

type ObservationCommitFileVersionParams struct {
	FileID    string
	OwnerID   string
	ContextID string
	Oid       string
	Now       time.Time
}

type ObservationCommitFileVersionRow 

type ObservationCommitFileVersionRow struct {
	DiffID      string
	VersionID   string
	Fingerprint *string
}

type ObservationCommitManifestParams 

type ObservationCommitManifestParams struct {
	OwnerID   string
	ContextID string
	Oid       string
	Now       time.Time
}

type ObservationCommitPatchParams 

type ObservationCommitPatchParams struct {
	OwnerID     string
	ContextID   string
	Oid         string
	FileID      string
	Fingerprint string
	Now         time.Time
}

type ObservationCommitRange 

type ObservationCommitRange struct {
	ContextID string
	Total     int64
}

type ObservationCommitTotalParams 

type ObservationCommitTotalParams struct {
	OwnerID   string
	ContextID string
	Now       time.Time
}

type ObservationCommitsRow 

type ObservationCommitsRow struct {
	Data      []byte
	FileCount int64
	Additions int64
	Deletions int64
}

type ObservationFileVersionParams 

type ObservationFileVersionParams struct {
	FileID    string
	OwnerID   string
	ContextID string
	Mode      string
	Now       time.Time
}

type ObservationFileVersionRow 

type ObservationFileVersionRow struct {
	DiffID      string
	VersionID   string
	Fingerprint *string
}

type ObservationIdentity 

type ObservationIdentity struct {
	OwnerID      string
	IdentityHash string
	ContextID    string
}

type ObservationPatchParams 

type ObservationPatchParams struct {
	OwnerID     string
	ContextID   string
	Mode        string
	FileID      string
	Fingerprint string
	Now         time.Time
}

type ObservationRepository 

type ObservationRepository struct {
	ID            string
	OwnerID       string
	RepositoryKey string
}

type ObservationRepositoryParams 

type ObservationRepositoryParams struct {
	OwnerID   string
	ContextID string
	Now       time.Time
}

type ObservationScope 

type ObservationScope struct {
	ContextID string
	Mode      string
	DiffID    string
	VersionID string
}

type ObservationScopesRow 

type ObservationScopesRow struct {
	Mode   string
	DiffID string
}

type ObservationSession 

type ObservationSession struct {
	ContextID       string
	OwnerID         string
	SourceID        string
	Harness         string
	SessionID       string
	FirstObservedAt int64
	LastObservedAt  int64
}

type ObservationSnapshotParams 

type ObservationSnapshotParams struct {
	OwnerID   string
	ContextID string
	Mode      string
	Now       time.Time
}

type ObservationSnapshotRow 

type ObservationSnapshotRow struct {
	Manifest []byte
	Metadata []byte
	Modes    []string
}

type ObservationStreamHead 

type ObservationStreamHead struct {
	OwnerID          string
	SourceID         string
	RepositoryKey    string
	CheckoutKey      string
	Branch           string
	ComparisonPolicy string
	ContextID        string
	CollectedAt      int64
	ArrivalSequence  int64
}

type ObservationSubmission 

type ObservationSubmission struct {
	OwnerID      string
	SourceID     string
	SubmissionID string
	ContextID    string
	PayloadHash  string
	Metadata     []byte
}

type OwnedJobParams 

type OwnedJobParams struct {
	OwnerID string
	ID      string
}

type OwnedJobRow 

type OwnedJobRow struct {
	ID           string
	SubmissionID string
	State        string
	Attempt      int32
	ContextID    string
	Detail       string
}

type PasswordReset added in v0.2.4 

type PasswordReset struct {
	UserID    string
	TokenHash string
	ExpiresAt time.Time
}

type PasswordResetParams added in v0.2.4 

type PasswordResetParams struct {
	TokenHash string
	Now       time.Time
}

type PasswordResetRow added in v0.2.4 

type PasswordResetRow struct {
	UserID       string
	Email        string
	Admin        bool
	Method       string
	PasswordHash string
}

type PendingAdminSetupParams added in v0.2.4 

type PendingAdminSetupParams struct {
	TokenHash string
	Now       time.Time
}

type PendingInviteParams 

type PendingInviteParams struct {
	TokenHash string
	Now       time.Time
}

type PendingInviteRow 

type PendingInviteRow struct {
	ID        string
	Email     string
	CreatedAt time.Time
	ExpiresAt time.Time
	UsedAt    *time.Time
	UsedBy    string
	RevokedAt *time.Time
}

type PushDelivery 

type PushDelivery struct {
	NotificationID string
	SubscriptionID string
	State          string
}

type PushKey 

type PushKey struct {
	Singleton  bool
	PublicKey  string
	PrivateKey string
	CreatedAt  time.Time
}

type PushKeysRow 

type PushKeysRow struct {
	PublicKey  string
	PrivateKey string
}

type PushNotification 

type PushNotification struct {
	ID          string
	OwnerID     string
	JobID       string
	Kind        string
	Payload     []byte
	State       string
	Attempt     int32
	AvailableAt time.Time
	CreatedAt   time.Time
	LeaseToken  string
	LeaseUntil  time.Time
}

type PushSubscription 

type PushSubscription struct {
	ID            string
	OwnerID       string
	Endpoint      string
	P256dh        string
	Auth          string
	Label         string
	CreatedAt     time.Time
	LastSuccessAt *time.Time
}

type PutAdminSetupParams 

type PutAdminSetupParams struct {
	TokenHash string
	ExpiresAt time.Time
}

type PutAppSettingsParams added in v0.2.4 

type PutAppSettingsParams struct {
	SignupOpen     bool
	PasswordSignup bool
	UpdatedAt      time.Time
	UpdatedBy      string
}

type PutGitHubConnectionParams 

type PutGitHubConnectionParams struct {
	OwnerID          string
	UserID           int64
	Login            string
	AccessToken      []byte
	AccessExpiresAt  time.Time
	RefreshToken     []byte
	RefreshExpiresAt time.Time
	Status           string
	ConnectedAt      time.Time
}

type PutGitHubFollowParams 

type PutGitHubFollowParams struct {
	OwnerID        string
	RepositoryID   int64
	InstallationID int64
	FullName       string
	Status         string
	VerifiedAt     time.Time
	CreatedAt      time.Time
}

type PutGitHubOAuthStateParams 

type PutGitHubOAuthStateParams struct {
	StateHash string
	OwnerID   string
	ExpiresAt time.Time
}

type PutPasswordResetParams added in v0.2.4 

type PutPasswordResetParams struct {
	UserID    string
	TokenHash string
	ExpiresAt time.Time
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) AccountPassword 

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

func (*Queries) AccountPasswordByID 

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

func (*Queries) AccountSummaries 

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

func (*Queries) ActiveJobUsage 

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

func (*Queries) AdminExists 

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

func (*Queries) AdvanceStreamHead 

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

Equal collection times use arrival order. Retries bypass this write.

func (*Queries) AppSettings added in v0.2.4 

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

func (*Queries) BindSubmission 

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

func (*Queries) ClaimGitHubRefresh 

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

SKIP LOCKED lets replicas claim distinct pull requests concurrently; a row another replica claimed meanwhile fails the recheck and is skipped.

func (*Queries) ClaimJob 

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

The oldest available job; SKIP LOCKED lets concurrent workers claim others.

func (*Queries) ClaimNotifications 

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

SKIP LOCKED lets replicas claim distinct notifications concurrently. The linked job is read through its owner's ingestion record, so a notification never resolves another account's publication.

func (*Queries) Comments 

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

func (*Queries) CompleteGitHubRefresh 

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

func (*Queries) CompleteJob 

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

func (*Queries) ConsumeAdminSetup 

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

func (*Queries) ConsumePasswordReset added in v0.2.4 

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

func (*Queries) ContextExpiry 

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

func (*Queries) ContextForDelete 

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

Deletion locks the context first, as reuse and pruning do.

func (*Queries) ContextStream 

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

The context's expiry and its current stream head, matched as the catalog matches observations to heads.

func (*Queries) CountAuthAttempt 

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

One statement counts the attempt: a client's window starts at its first attempt and restarts with the first attempt after it ends.

func (*Queries) DeleteAccountJobs 

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

func (*Queries) DeleteAccountSessions 

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

func (*Queries) DeleteAccountTokens 

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

func (*Queries) DeleteAccountUser 

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

func (*Queries) DeleteContextDiffs 

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

func (*Queries) DeleteDiff 

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

func (*Queries) DeleteGitHubConnection 

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

Follows and mutes cascade with their connection.

func (*Queries) DeleteGitHubFollow 

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

func (*Queries) DeleteIdentityToken 

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

func (*Queries) DeleteOwnedSubscription 

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

func (*Queries) DeleteSession 

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

func (*Queries) DeleteStreamComments 

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

func (*Queries) DeleteSubscriptionByID 

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

func (*Queries) DeleteVisibleMarks 

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

Removes only marks visible in this context; a null file clears the scope.

func (*Queries) DisableAccount 

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

func (*Queries) EmailLinked 

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

func (*Queries) EnableAccount 

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

func (*Queries) EndStream 

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

Review state ends with its stream's last observation.

func (*Queries) EndStreams 

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

Review state ends with its stream's last observation.

func (*Queries) EnsureReview 

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

func (*Queries) ExtendObservation 

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

func (*Queries) FailJob 

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

func (*Queries) FinishNotification 

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

func (*Queries) ForgetIdentity 

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

func (*Queries) GitHubConnection 

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

func (*Queries) GitHubConnections 

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

func (*Queries) GitHubFollows 

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

func (*Queries) GitHubKnownOpen 

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

func (*Queries) GitHubLeased 

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

func (*Queries) GitHubPullRequestHead 

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

func (*Queries) GitHubReconcileUnlock 

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

func (*Queries) GitHubRepositoryFollows 

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

func (*Queries) GoogleAccount 

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

func (*Queries) GrantAdmin added in v0.2.4 

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

func (*Queries) HoldNotificationLease 

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

Holds the claim until the caller's transaction commits, so no replica reclaims the notification meanwhile.

func (*Queries) IdentityAccounts 

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

func (*Queries) IdentityLock 

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

Accounts read from remote_accounts aliased as a. Ordering is bytewise, as in SQLite, independent of the database collation.

func (*Queries) IdentityTokens 

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

func (*Queries) IngestionRecord 

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

func (*Queries) InsertAccountUser 

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

func (*Queries) InsertAdmin 

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

func (*Queries) InsertComment 

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

func (*Queries) InsertCommit 

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

func (*Queries) InsertCommitRange 

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

func (*Queries) InsertContext 

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

func (*Queries) InsertDelivery 

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

A device removed or moved to another account while sending has no outcome to keep.

func (*Queries) InsertDiff 

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

func (*Queries) InsertDiffFiles 

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

func (*Queries) InsertDiffVersion 

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

func (*Queries) InsertGoogleFlow 

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

func (*Queries) InsertGoogleIdentity 

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

func (*Queries) InsertIdentity 

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

func (*Queries) InsertIdentityToken 

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

func (*Queries) InsertIngestionRecord 

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

func (*Queries) InsertInvite 

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

func (*Queries) InsertJob 

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

func (*Queries) InsertNotification 

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

func (*Queries) InsertObservation 

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

func (*Queries) InsertObservationSubmission 

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

func (*Queries) InsertPushKeys 

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

func (*Queries) InsertRemoteAccount 

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

func (*Queries) InsertRepository 

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

func (*Queries) InsertScope 

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

func (*Queries) InsertSession 

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

func (*Queries) InsertSubscription 

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

func (*Queries) Invite 

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

func (*Queries) InviteEmailLock 

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

Serializes invitation and acceptance per email; the two-key form keeps these locks apart from single-key ones.

func (*Queries) Invites 

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

func (*Queries) JobBySequence 

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

func (*Queries) LockAppSettings added in v0.2.4 

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

Holds the settings against a concurrent change until the account commits.

func (*Queries) LockEndingStreams 

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

Streams left without observations, locked in key order before ending them.

func (*Queries) LockEndpoint 

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

Serializes registrations of one endpoint, including its first insert.

func (*Queries) LockExpiredContexts 

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

Pruning locks contexts before their diffs, in the order deletion and reuse lock them, so concurrent writers cannot deadlock with it.

func (*Queries) LockGitHubFollow 

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

Holds the follow against deletion until the mute change commits.

func (*Queries) LockIdentity 

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

Advisory lock namespaces (two-key form; distinct from single-key schema locks): 7469101 serializes an owner's reuse decisions per content identity; 7469102 serializes adding observations to, and ending, a review stream.

func (*Queries) LockSessionAccount 

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

Conflicts with password replacement, disable and delete, so issuance reads the account only after they commit and they see the issued session.

func (*Queries) LockStream 

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

func (*Queries) LockStreamReviews 

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

Writers key-share lock reviews before snapshot versions; deletion takes the reviews first so ending a stream cannot deadlock with them.

func (*Queries) LockTargetAccount 

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

Locks the account and its owner row against credential issuance and new owned data.

func (*Queries) LoseGitHubInstallation 

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

func (*Queries) LoseGitHubInstallationRepositories 

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

func (*Queries) LoseGitHubUserFollows 

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

func (*Queries) MarkGitHubPullRequestOpened 

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

func (*Queries) Marks 

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

Stream marks whose file patch is unchanged in this context, projected onto its snapshot.

func (*Queries) MuteGitHubFollow 

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

func (*Queries) Notify 

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

Listeners receive the payload only when the surrounding transaction commits.

func (*Queries) ObservationCommitFileVersion 

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

func (*Queries) ObservationCommitManifest 

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

Merge commits and commits outside the observation are not found.

func (*Queries) ObservationCommitPatch 

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

func (*Queries) ObservationCommitTotal 

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

func (*Queries) ObservationCommits 

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

func (*Queries) ObservationFileVersion 

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

Missing files retain the scope identity, so callers reject stale scope references before file errors.

func (*Queries) ObservationPatch 

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

func (*Queries) ObservationRepository 

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

func (*Queries) ObservationScopes 

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

func (*Queries) ObservationSnapshot 

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

func (*Queries) OtherEnabledAdmin added in v0.2.4 

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

func (*Queries) OwnedJob 

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

func (*Queries) PasswordReset added in v0.2.4 

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

func (*Queries) PendingAdminSetup added in v0.2.4 

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

func (*Queries) PendingInvite 

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

func (*Queries) PruneAuthAttempts 

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

Skips rows other statements hold, so pruning never waits or deadlocks.

func (*Queries) PruneBrowserSessions 

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

Skips sessions another transaction holds, so cleanup never waits or deadlocks.

func (*Queries) PruneExpiredDiffs 

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

func (*Queries) PruneExpiredObservationDiffs 

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

Every scope and commit diff of an expired observation ends with its anchor.

func (*Queries) PruneFinishedNotifications 

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

func (*Queries) PruneGitHubDeliveries 

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

func (*Queries) PruneGitHubStates 

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

func (*Queries) PruneGoogleFlows 

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

Skips flows being taken, so cleanup never waits on a callback.

func (*Queries) PrunePasswordResets added in v0.2.4 

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

func (*Queries) PushKeys 

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

func (*Queries) PutAdminSetup 

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

func (*Queries) PutAppSettings added in v0.2.4 

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

func (*Queries) PutGitHubConnection 

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

func (*Queries) PutGitHubFollow 

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

Mutes are separate rows, so a put leaves them unchanged.

func (*Queries) PutGitHubOAuthState 

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

func (*Queries) PutPasswordReset added in v0.2.4 

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

func (*Queries) RecordGitHubDelivery 

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

func (*Queries) RecordGitHubLease 

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

func (*Queries) RecordGitHubPullRequestHead 

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

func (*Queries) RecordGoogleEmail 

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

func (*Queries) RecordSubscriptionSuccess 

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

func (*Queries) RefreshContext 

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

func (*Queries) ReleaseGitHubRefresh 

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

func (*Queries) RenewJob 

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

func (*Queries) ReplacePassword 

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

func (*Queries) RepositoryID 

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

func (*Queries) RequestGitHubRefresh 

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

func (*Queries) ResolveIdentityToken 

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

Records the latest use; last_used_at never moves backwards.

func (*Queries) ResolveSession 

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

func (*Queries) RetryJob 

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

func (*Queries) RetryNotification 

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

func (*Queries) ReusableObservation 

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

The context row lock orders reuse before or after deletion and pruning.

func (*Queries) RevokeAdmin added in v0.2.4 

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

func (*Queries) RevokeGitHubUserConnections 

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

func (*Queries) RevokeInvite 

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

func (*Queries) RevokePendingInvites 

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

func (*Queries) SchemaFloor 

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

func (*Queries) ScopeFileDigest 

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

func (*Queries) ScopeReview 

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

Resolves a retained context's scope to its stream review. The key-share lock keeps the review until this write commits, or reports it ended.

func (*Queries) SeenGitHubDelivery 

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

func (*Queries) StoredComment 

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

func (*Queries) StoredVersion 

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

func (*Queries) SubscriptionByEndpoint 

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

func (*Queries) Subscriptions 

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

func (*Queries) TakeGitHubOAuthState 

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

func (*Queries) TakeGoogleFlow 

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

func (*Queries) TryGitHubReconcileLock 

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

Session-level: held across reconciliation's GitHub calls without a transaction.

func (*Queries) TryPruneLock 

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

func (*Queries) Undelivered 

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

func (*Queries) UnmuteGitHubFollow 

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

func (*Queries) UpdateComment 

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

Pruned snapshot versions leave the reference in data only.

func (*Queries) UpdateSubscription 

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

func (*Queries) UpsertAgentSession 

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

Names follow collection order; unnamed observations keep the last name.

func (*Queries) UpsertMark 

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

func (*Queries) UpsertObservationSession 

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

func (*Queries) UseInvite 

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

func (*Queries) UsePasswordInvite added in v0.2.4 

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

func (*Queries) VersionInDiff 

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

func (*Queries) WithTx 

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

type RecordGitHubDeliveryParams 

type RecordGitHubDeliveryParams struct {
	ID         string
	Event      string
	ReceivedAt time.Time
}

type RecordGitHubLeaseParams 

type RecordGitHubLeaseParams struct {
	Leased       []byte
	RepositoryID int64
	Number       int32
	Token        string
	Now          time.Time
}

type RecordGitHubPullRequestHeadParams 

type RecordGitHubPullRequestHeadParams struct {
	RepositoryID int64
	Number       int32
	HeadSha      string
}

type RecordGoogleEmailParams 

type RecordGoogleEmailParams struct {
	Email string
	Now   time.Time
	Sub   string
}

type RecordSubscriptionSuccessParams 

type RecordSubscriptionSuccessParams struct {
	LastSuccessAt time.Time
	ID            string
}

type RefreshContextParams 

type RefreshContextParams struct {
	Now time.Time
	ID  string
}

type ReleaseGitHubRefreshParams 

type ReleaseGitHubRefreshParams struct {
	RetryAt      time.Time
	Detail       string
	RepositoryID int64
	Number       int32
	Token        string
}

type RemoteAccount 

type RemoteAccount struct {
	UserID       string
	PasswordHash string
	Email        string
}

type RenewJobParams 

type RenewJobParams struct {
	LeaseUntil time.Time
	ID         string
	LeaseToken string
	Now        time.Time
}

type ReplacePasswordParams 

type ReplacePasswordParams struct {
	Replacement string
	UserID      string
	Expected    string
}

type RepositoryIDParams 

type RepositoryIDParams struct {
	OwnerID       string
	RepositoryKey string
}

type RequestGitHubRefreshParams 

type RequestGitHubRefreshParams struct {
	RepositoryID   int64
	Number         int32
	InstallationID int64
	FullName       string
	RetentionRun   string
	RequestedAt    time.Time
}

type ResolveIdentityTokenParams 

type ResolveIdentityTokenParams struct {
	Now        time.Time
	SecretHash string
}

type ResolveIdentityTokenRow 

type ResolveIdentityTokenRow struct {
	UserID    string
	Email     string
	Admin     bool
	Method    string
	Purpose   string
	ExpiresAt time.Time
}

type ResolveSessionParams 

type ResolveSessionParams struct {
	SecretHash string
	Now        time.Time
}

type ResolveSessionRow 

type ResolveSessionRow struct {
	UserID    string
	Email     string
	Admin     bool
	Method    string
	CsrfToken string
	ExpiresAt time.Time
}

type RetryJobParams 

type RetryJobParams struct {
	AvailableAt time.Time
	Detail      string
	ID          string
	LeaseToken  string
	Now         time.Time
}

type RetryNotificationParams 

type RetryNotificationParams struct {
	Attempt     int32
	AvailableAt time.Time
	ID          string
	LeaseToken  string
}

type ReusableObservationParams 

type ReusableObservationParams struct {
	OwnerID      string
	IdentityHash string
	Now          time.Time
}

type Review 

type Review struct {
	ID        string
	OwnerID   string
	StreamKey string
	Mode      string
}

type RevokeInviteParams 

type RevokeInviteParams struct {
	At time.Time
	ID string
}

type RevokePendingInvitesParams 

type RevokePendingInvitesParams struct {
	At    time.Time
	Email string
}

type SchemaCompatibility 

type SchemaCompatibility struct {
	Singleton bool
	Floor     int64
}

type ScopeFileDigestParams 

type ScopeFileDigestParams struct {
	ContextID string
	Mode      string
	FileID    string
}

type ScopeReviewParams 

type ScopeReviewParams struct {
	Mode      string
	ContextID string
	Now       time.Time
}

type ScopeReviewRow 

type ScopeReviewRow struct {
	DiffID   string
	ReviewID string
}

type StoredCommentParams 

type StoredCommentParams struct {
	ID       string
	ReviewID string
}

type StoredVersionParams 

type StoredVersionParams struct {
	OwnerID   string
	DiffID    string
	VersionID string
	Now       time.Time
}

type StoredVersionRow 

type StoredVersionRow struct {
	Manifest []byte
	Metadata []byte
	Modes    []string
}

type TakeGitHubOAuthStateParams 

type TakeGitHubOAuthStateParams struct {
	StateHash string
	Now       time.Time
}

type TakeGoogleFlowParams 

type TakeGoogleFlowParams struct {
	StateHash string
	Now       time.Time
}

type TakeGoogleFlowRow 

type TakeGoogleFlowRow struct {
	BindingHash  string
	Nonce        string
	PkceVerifier string
	InviteID     *string
	SetupHash    *string
	ExpiresAt    time.Time
}

type UnmuteGitHubFollowParams 

type UnmuteGitHubFollowParams struct {
	OwnerID      string
	RepositoryID int64
}

type UpdateCommentParams 

type UpdateCommentParams struct {
	VersionID string
	FileID    string
	Data      []byte
	ID        string
	ReviewID  string
}

type UpdateSubscriptionParams 

type UpdateSubscriptionParams struct {
	ID     string
	P256dh string
	Auth   string
	Label  string
}

type UpsertAgentSessionParams 

type UpsertAgentSessionParams struct {
	OwnerID   string
	SourceID  string
	Harness   string
	SessionID string
	Name      string
	NamedAt   int64
}

type UpsertMarkParams 

type UpsertMarkParams struct {
	ReviewID    string
	FileID      string
	VersionID   *string
	PatchDigest string
	Data        []byte
}

type UpsertObservationSessionParams 

type UpsertObservationSessionParams struct {
	ContextID  string
	OwnerID    string
	SourceID   string
	Harness    string
	SessionID  string
	ObservedAt int64
}

type UseInviteParams 

type UseInviteParams struct {
	Now    time.Time
	UserID string
	ID     string
	Sub    string
}

type UsePasswordInviteParams added in v0.2.4 

type UsePasswordInviteParams struct {
	Now    time.Time
	UserID string
	ID     string
	Email  string
}

type User 

type User struct {
	ID        string
	Name      string
	CreatedAt time.Time
}

type VersionInDiffParams 

type VersionInDiffParams struct {
	ID     string
	DiffID string
}

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.