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

pullsdb

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: May 10, 2026 License: AGPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AttachPendingCommentsToReviewParams

type AttachPendingCommentsToReviewParams struct {
	PrIssueID    int64
	AuthorUserID pgtype.Int8
	ReviewID     pgtype.Int8
}

type AuthAuditLog

type AuthAuditLog struct {
	ID         int64
	ActorID    pgtype.Int8
	Action     string
	TargetType string
	TargetID   pgtype.Int8
	Meta       []byte
	CreatedAt  pgtype.Timestamptz
}

type AuthThrottle

type AuthThrottle struct {
	ID              int64
	Scope           string
	Identifier      string
	Hits            int32
	WindowStartedAt pgtype.Timestamptz
}

type BranchProtectionRule

type BranchProtectionRule struct {
	ID                             int64
	RepoID                         int64
	Pattern                        string
	PreventForcePush               bool
	PreventDeletion                bool
	RequirePrForPush               bool
	AllowedPusherUserIds           []int64
	RequireSignedCommits           bool
	StatusChecksRequired           []string
	CreatedAt                      pgtype.Timestamptz
	UpdatedAt                      pgtype.Timestamptz
	CreatedByUserID                pgtype.Int8
	RequiredReviewCount            int32
	DismissStaleReviewsOnPush      bool
	RequireCodeOwnerReview         bool
	DismissStaleStatusChecksOnPush bool
}

type CheckConclusion

type CheckConclusion string
const (
	CheckConclusionSuccess        CheckConclusion = "success"
	CheckConclusionFailure        CheckConclusion = "failure"
	CheckConclusionNeutral        CheckConclusion = "neutral"
	CheckConclusionCancelled      CheckConclusion = "cancelled"
	CheckConclusionSkipped        CheckConclusion = "skipped"
	CheckConclusionTimedOut       CheckConclusion = "timed_out"
	CheckConclusionActionRequired CheckConclusion = "action_required"
	CheckConclusionStale          CheckConclusion = "stale"
)

func (*CheckConclusion) Scan

func (e *CheckConclusion) Scan(src interface{}) error

type CheckRun

type CheckRun struct {
	ID          int64
	SuiteID     int64
	RepoID      int64
	HeadSha     string
	Name        string
	Status      CheckStatus
	Conclusion  NullCheckConclusion
	StartedAt   pgtype.Timestamptz
	CompletedAt pgtype.Timestamptz
	DetailsUrl  string
	Output      []byte
	ExternalID  pgtype.Text
	CreatedAt   pgtype.Timestamptz
	UpdatedAt   pgtype.Timestamptz
}

type CheckStatus

type CheckStatus string
const (
	CheckStatusQueued     CheckStatus = "queued"
	CheckStatusInProgress CheckStatus = "in_progress"
	CheckStatusCompleted  CheckStatus = "completed"
	CheckStatusPending    CheckStatus = "pending"
)

func (*CheckStatus) Scan

func (e *CheckStatus) Scan(src interface{}) error

type CheckSuite

type CheckSuite struct {
	ID         int64
	RepoID     int64
	HeadSha    string
	AppSlug    string
	Status     CheckStatus
	Conclusion NullCheckConclusion
	CreatedAt  pgtype.Timestamptz
	UpdatedAt  pgtype.Timestamptz
}

type CodeSearchContent

type CodeSearchContent struct {
	RepoID      int64
	RefName     string
	Path        string
	ContentTsv  interface{}
	ContentTrgm string
}

type CodeSearchPath

type CodeSearchPath struct {
	RepoID  int64
	RefName string
	Path    string
	Tsv     interface{}
}

type CollabRole

type CollabRole string
const (
	CollabRoleRead     CollabRole = "read"
	CollabRoleTriage   CollabRole = "triage"
	CollabRoleWrite    CollabRole = "write"
	CollabRoleMaintain CollabRole = "maintain"
	CollabRoleAdmin    CollabRole = "admin"
)

func (*CollabRole) Scan

func (e *CollabRole) Scan(src interface{}) error

type CountPRReviewsForGateRow

type CountPRReviewsForGateRow struct {
	Approves       int32
	RequestChanges int32
}

type CountPullRequestsByRepoParams

type CountPullRequestsByRepoParams struct {
	RepoID      int64
	StateFilter pgtype.Text
	Draft       pgtype.Bool
}

type CreatePRReviewCommentParams

type CreatePRReviewCommentParams struct {
	PrIssueID         int64
	FilePath          string
	Side              PrReviewSide
	OriginalCommitSha string
	OriginalLine      int32
	OriginalPosition  int32
	CurrentPosition   pgtype.Int4
	Body              string
	Pending           bool
	ReviewID          pgtype.Int8
	AuthorUserID      pgtype.Int8
	BodyHtmlCached    pgtype.Text
	InReplyToID       pgtype.Int8
}

type CreatePRReviewParams

type CreatePRReviewParams struct {
	PrIssueID      int64
	State          PrReviewState
	Body           string
	AuthorUserID   pgtype.Int8
	BodyHtmlCached pgtype.Text
}

type CreatePRReviewRequestParams

type CreatePRReviewRequestParams struct {
	PrIssueID         int64
	RequestedUserID   pgtype.Int8
	RequestedTeamID   pgtype.Int8
	RequestedByUserID pgtype.Int8
}

type CreatePullRequestParams

type CreatePullRequestParams struct {
	IssueID    int64
	BaseRef    string
	HeadRef    string
	HeadRepoID int64
	BaseOid    string
	HeadOid    string
	Draft      bool
}

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 DismissPRReviewParams

type DismissPRReviewParams struct {
	ID                int64
	DismissalReason   string
	DismissedByUserID pgtype.Int8
}

type DomainEvent

type DomainEvent struct {
	ID          int64
	ActorUserID pgtype.Int8
	Kind        string
	RepoID      pgtype.Int8
	SourceKind  string
	SourceID    int64
	Public      bool
	Payload     []byte
	CreatedAt   pgtype.Timestamptz
}

type DomainEventsProcessed

type DomainEventsProcessed struct {
	Consumer    string
	LastEventID int64
	UpdatedAt   pgtype.Timestamptz
}

type EmailVerification

type EmailVerification struct {
	ID          int64
	UserEmailID int64
	TokenHash   []byte
	ExpiresAt   pgtype.Timestamptz
	UsedAt      pgtype.Timestamptz
	CreatedAt   pgtype.Timestamptz
}

type GetPullRequestByRepoAndNumberParams

type GetPullRequestByRepoAndNumberParams struct {
	RepoID int64
	Number int64
}

type GetPullRequestByRepoAndNumberRow

type GetPullRequestByRepoAndNumberRow struct {
	IssueID            int64
	BaseRef            string
	HeadRef            string
	HeadRepoID         int64
	BaseOid            string
	HeadOid            string
	Draft              bool
	Mergeable          pgtype.Bool
	MergeableState     PrMergeableState
	MergeCommitSha     pgtype.Text
	MergedAt           pgtype.Timestamptz
	MergedByUserID     pgtype.Int8
	MergeMethod        NullPrMergeMethod
	BaseOidAtMerge     pgtype.Text
	HeadOidAtMerge     pgtype.Text
	LastSynchronizedAt pgtype.Timestamptz
	IID                int64
	IRepoID            int64
	INumber            int64
	ITitle             string
	IBody              string
	IBodyHtmlCached    pgtype.Text
	IAuthorUserID      pgtype.Int8
	IState             IssueState
	ILocked            bool
	ICreatedAt         pgtype.Timestamptz
	IUpdatedAt         pgtype.Timestamptz
}

type InsertPullRequestCommitParams

type InsertPullRequestCommitParams struct {
	PrID           int64
	Sha            string
	Position       int32
	AuthorName     string
	AuthorEmail    string
	CommitterName  string
	CommitterEmail string
	Subject        string
	Body           string
	AuthoredAt     pgtype.Timestamptz
	CommittedAt    pgtype.Timestamptz
}

type InsertPullRequestFileParams

type InsertPullRequestFileParams struct {
	PrID      int64
	Path      string
	Status    PrFileStatus
	Additions int32
	Deletions int32
	Changes   int32
	OldPath   pgtype.Text
}

type Issue

type Issue struct {
	ID                int64
	RepoID            int64
	Number            int64
	Kind              IssueKind
	Title             string
	Body              string
	BodyHtmlCached    pgtype.Text
	MdPipelineVersion int32
	AuthorUserID      pgtype.Int8
	State             IssueState
	StateReason       NullIssueStateReason
	Locked            bool
	LockReason        pgtype.Text
	MilestoneID       pgtype.Int8
	CreatedAt         pgtype.Timestamptz
	UpdatedAt         pgtype.Timestamptz
	EditedAt          pgtype.Timestamptz
	ClosedAt          pgtype.Timestamptz
	ClosedByUserID    pgtype.Int8
}

type IssueAssignee

type IssueAssignee struct {
	IssueID          int64
	UserID           int64
	AssignedAt       pgtype.Timestamptz
	AssignedByUserID pgtype.Int8
}

type IssueComment

type IssueComment struct {
	ID                int64
	IssueID           int64
	AuthorUserID      pgtype.Int8
	Body              string
	BodyHtmlCached    pgtype.Text
	MdPipelineVersion int32
	CreatedAt         pgtype.Timestamptz
	UpdatedAt         pgtype.Timestamptz
	EditedAt          pgtype.Timestamptz
}

type IssueEvent

type IssueEvent struct {
	ID          int64
	IssueID     int64
	ActorUserID pgtype.Int8
	Kind        string
	Meta        []byte
	RefTargetID pgtype.Int8
	CreatedAt   pgtype.Timestamptz
}

type IssueKind

type IssueKind string
const (
	IssueKindIssue IssueKind = "issue"
	IssueKindPr    IssueKind = "pr"
)

func (*IssueKind) Scan

func (e *IssueKind) Scan(src interface{}) error

type IssueLabel

type IssueLabel struct {
	IssueID         int64
	LabelID         int64
	AppliedAt       pgtype.Timestamptz
	AppliedByUserID pgtype.Int8
}

type IssueRefSource

type IssueRefSource string
const (
	IssueRefSourceCommentBody   IssueRefSource = "comment_body"
	IssueRefSourceIssueBody     IssueRefSource = "issue_body"
	IssueRefSourceCommitMessage IssueRefSource = "commit_message"
)

func (*IssueRefSource) Scan

func (e *IssueRefSource) Scan(src interface{}) error

type IssueReference

type IssueReference struct {
	ID             int64
	SourceIssueID  pgtype.Int8
	TargetIssueID  int64
	SourceKind     IssueRefSource
	SourceObjectID pgtype.Int8
	CreatedAt      pgtype.Timestamptz
}

type IssueState

type IssueState string
const (
	IssueStateOpen   IssueState = "open"
	IssueStateClosed IssueState = "closed"
)

func (*IssueState) Scan

func (e *IssueState) Scan(src interface{}) error

type IssueStateReason

type IssueStateReason string
const (
	IssueStateReasonCompleted  IssueStateReason = "completed"
	IssueStateReasonNotPlanned IssueStateReason = "not_planned"
	IssueStateReasonReopened   IssueStateReason = "reopened"
	IssueStateReasonDuplicate  IssueStateReason = "duplicate"
)

func (*IssueStateReason) Scan

func (e *IssueStateReason) Scan(src interface{}) error

type IssuesSearch

type IssuesSearch struct {
	IssueID      int64
	RepoID       int64
	Kind         IssueKind
	State        IssueState
	AuthorUserID pgtype.Int8
	Tsv          interface{}
}

type Job

type Job struct {
	ID          int64
	Kind        string
	Payload     []byte
	RunAt       pgtype.Timestamptz
	Attempts    int32
	MaxAttempts int32
	LastError   pgtype.Text
	LockedBy    pgtype.Text
	LockedAt    pgtype.Timestamptz
	CompletedAt pgtype.Timestamptz
	FailedAt    pgtype.Timestamptz
	CreatedAt   pgtype.Timestamptz
}

type Label

type Label struct {
	ID          int64
	RepoID      int64
	Name        string
	Color       string
	Description string
	CreatedAt   pgtype.Timestamptz
}

type ListNonDraftCommentsForPositionMapRow

type ListNonDraftCommentsForPositionMapRow struct {
	ID                int64
	FilePath          string
	Side              PrReviewSide
	OriginalCommitSha string
	OriginalLine      int32
	OriginalPosition  int32
}

type ListOpenPRsForHeadRefParams

type ListOpenPRsForHeadRefParams struct {
	HeadRepoID int64
	HeadRef    string
}

type ListPRReviewCommentsForFileParams

type ListPRReviewCommentsForFileParams struct {
	PrIssueID int64
	FilePath  string
}

type ListPendingDraftCommentsForUserParams

type ListPendingDraftCommentsForUserParams struct {
	PrIssueID    int64
	AuthorUserID pgtype.Int8
}

type ListPullRequestsByRepoParams

type ListPullRequestsByRepoParams struct {
	RepoID      int64
	Limit       int32
	Offset      int32
	StateFilter pgtype.Text
	Draft       pgtype.Bool
}

type ListPullRequestsByRepoRow

type ListPullRequestsByRepoRow struct {
	IssueID            int64
	BaseRef            string
	HeadRef            string
	HeadRepoID         int64
	BaseOid            string
	HeadOid            string
	Draft              bool
	Mergeable          pgtype.Bool
	MergeableState     PrMergeableState
	MergeCommitSha     pgtype.Text
	MergedAt           pgtype.Timestamptz
	MergedByUserID     pgtype.Int8
	MergeMethod        NullPrMergeMethod
	BaseOidAtMerge     pgtype.Text
	HeadOidAtMerge     pgtype.Text
	LastSynchronizedAt pgtype.Timestamptz
	ID                 int64
	RepoID             int64
	Number             int64
	Title              string
	Body               string
	AuthorUserID       pgtype.Int8
	State              IssueState
	CreatedAt          pgtype.Timestamptz
	UpdatedAt          pgtype.Timestamptz
}

type ListUndismissedReviewsForGateRow

type ListUndismissedReviewsForGateRow struct {
	ID           int64
	PrIssueID    int64
	AuthorUserID pgtype.Int8
	State        PrReviewState
	SubmittedAt  pgtype.Timestamptz
}

type Meta

type Meta struct {
	Key       string
	Value     []byte
	UpdatedAt pgtype.Timestamptz
}

type Milestone

type Milestone struct {
	ID          int64
	RepoID      int64
	Title       string
	Description string
	State       MilestoneState
	DueOn       pgtype.Timestamptz
	CreatedAt   pgtype.Timestamptz
	ClosedAt    pgtype.Timestamptz
}

type MilestoneState

type MilestoneState string
const (
	MilestoneStateOpen   MilestoneState = "open"
	MilestoneStateClosed MilestoneState = "closed"
)

func (*MilestoneState) Scan

func (e *MilestoneState) Scan(src interface{}) error

type Notification

type Notification struct {
	ID              int64
	RecipientUserID int64
	Kind            string
	Reason          string
	RepoID          pgtype.Int8
	ThreadKind      NullNotificationThreadKind
	ThreadID        pgtype.Int8
	SourceEventID   pgtype.Int8
	Unread          bool
	LastEventAt     pgtype.Timestamptz
	LastActorUserID pgtype.Int8
	Summary         []byte
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type NotificationEmailLog

type NotificationEmailLog struct {
	ID              int64
	RecipientUserID int64
	NotificationID  pgtype.Int8
	ThreadKind      NullNotificationThreadKind
	ThreadID        pgtype.Int8
	SentAt          pgtype.Timestamptz
	MessageID       pgtype.Text
}

type NotificationThread

type NotificationThread struct {
	RecipientUserID int64
	ThreadKind      NotificationThreadKind
	ThreadID        int64
	Subscribed      bool
	Reason          string
	UpdatedAt       pgtype.Timestamptz
}

type NotificationThreadKind

type NotificationThreadKind string
const (
	NotificationThreadKindIssue NotificationThreadKind = "issue"
	NotificationThreadKindPr    NotificationThreadKind = "pr"
)

func (*NotificationThreadKind) Scan

func (e *NotificationThreadKind) Scan(src interface{}) error

type NullCheckConclusion

type NullCheckConclusion struct {
	CheckConclusion CheckConclusion
	Valid           bool // Valid is true if CheckConclusion is not NULL
}

func (*NullCheckConclusion) Scan

func (ns *NullCheckConclusion) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullCheckConclusion) Value

func (ns NullCheckConclusion) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullCheckStatus

type NullCheckStatus struct {
	CheckStatus CheckStatus
	Valid       bool // Valid is true if CheckStatus is not NULL
}

func (*NullCheckStatus) Scan

func (ns *NullCheckStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullCheckStatus) Value

func (ns NullCheckStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullCollabRole

type NullCollabRole struct {
	CollabRole CollabRole
	Valid      bool // Valid is true if CollabRole is not NULL
}

func (*NullCollabRole) Scan

func (ns *NullCollabRole) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullCollabRole) Value

func (ns NullCollabRole) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullIssueKind

type NullIssueKind struct {
	IssueKind IssueKind
	Valid     bool // Valid is true if IssueKind is not NULL
}

func (*NullIssueKind) Scan

func (ns *NullIssueKind) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullIssueKind) Value

func (ns NullIssueKind) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullIssueRefSource

type NullIssueRefSource struct {
	IssueRefSource IssueRefSource
	Valid          bool // Valid is true if IssueRefSource is not NULL
}

func (*NullIssueRefSource) Scan

func (ns *NullIssueRefSource) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullIssueRefSource) Value

func (ns NullIssueRefSource) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullIssueState

type NullIssueState struct {
	IssueState IssueState
	Valid      bool // Valid is true if IssueState is not NULL
}

func (*NullIssueState) Scan

func (ns *NullIssueState) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullIssueState) Value

func (ns NullIssueState) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullIssueStateReason

type NullIssueStateReason struct {
	IssueStateReason IssueStateReason
	Valid            bool // Valid is true if IssueStateReason is not NULL
}

func (*NullIssueStateReason) Scan

func (ns *NullIssueStateReason) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullIssueStateReason) Value

func (ns NullIssueStateReason) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullMilestoneState

type NullMilestoneState struct {
	MilestoneState MilestoneState
	Valid          bool // Valid is true if MilestoneState is not NULL
}

func (*NullMilestoneState) Scan

func (ns *NullMilestoneState) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullMilestoneState) Value

func (ns NullMilestoneState) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullNotificationThreadKind

type NullNotificationThreadKind struct {
	NotificationThreadKind NotificationThreadKind
	Valid                  bool // Valid is true if NotificationThreadKind is not NULL
}

func (*NullNotificationThreadKind) Scan

func (ns *NullNotificationThreadKind) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullNotificationThreadKind) Value

Value implements the driver Valuer interface.

type NullOrgPlan

type NullOrgPlan struct {
	OrgPlan OrgPlan
	Valid   bool // Valid is true if OrgPlan is not NULL
}

func (*NullOrgPlan) Scan

func (ns *NullOrgPlan) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullOrgPlan) Value

func (ns NullOrgPlan) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullOrgRole

type NullOrgRole struct {
	OrgRole OrgRole
	Valid   bool // Valid is true if OrgRole is not NULL
}

func (*NullOrgRole) Scan

func (ns *NullOrgRole) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullOrgRole) Value

func (ns NullOrgRole) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullPrFileStatus

type NullPrFileStatus struct {
	PrFileStatus PrFileStatus
	Valid        bool // Valid is true if PrFileStatus is not NULL
}

func (*NullPrFileStatus) Scan

func (ns *NullPrFileStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullPrFileStatus) Value

func (ns NullPrFileStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullPrMergeMethod

type NullPrMergeMethod struct {
	PrMergeMethod PrMergeMethod
	Valid         bool // Valid is true if PrMergeMethod is not NULL
}

func (*NullPrMergeMethod) Scan

func (ns *NullPrMergeMethod) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullPrMergeMethod) Value

func (ns NullPrMergeMethod) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullPrMergeableState

type NullPrMergeableState struct {
	PrMergeableState PrMergeableState
	Valid            bool // Valid is true if PrMergeableState is not NULL
}

func (*NullPrMergeableState) Scan

func (ns *NullPrMergeableState) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullPrMergeableState) Value

func (ns NullPrMergeableState) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullPrReviewSide

type NullPrReviewSide struct {
	PrReviewSide PrReviewSide
	Valid        bool // Valid is true if PrReviewSide is not NULL
}

func (*NullPrReviewSide) Scan

func (ns *NullPrReviewSide) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullPrReviewSide) Value

func (ns NullPrReviewSide) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullPrReviewState

type NullPrReviewState struct {
	PrReviewState PrReviewState
	Valid         bool // Valid is true if PrReviewState is not NULL
}

func (*NullPrReviewState) Scan

func (ns *NullPrReviewState) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullPrReviewState) Value

func (ns NullPrReviewState) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullPrincipalKind

type NullPrincipalKind struct {
	PrincipalKind PrincipalKind
	Valid         bool // Valid is true if PrincipalKind is not NULL
}

func (*NullPrincipalKind) Scan

func (ns *NullPrincipalKind) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullPrincipalKind) Value

func (ns NullPrincipalKind) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullRepoInitStatus

type NullRepoInitStatus struct {
	RepoInitStatus RepoInitStatus
	Valid          bool // Valid is true if RepoInitStatus is not NULL
}

func (*NullRepoInitStatus) Scan

func (ns *NullRepoInitStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullRepoInitStatus) Value

func (ns NullRepoInitStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullRepoVisibility

type NullRepoVisibility struct {
	RepoVisibility RepoVisibility
	Valid          bool // Valid is true if RepoVisibility is not NULL
}

func (*NullRepoVisibility) Scan

func (ns *NullRepoVisibility) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullRepoVisibility) Value

func (ns NullRepoVisibility) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullTeamPrivacy

type NullTeamPrivacy struct {
	TeamPrivacy TeamPrivacy
	Valid       bool // Valid is true if TeamPrivacy is not NULL
}

func (*NullTeamPrivacy) Scan

func (ns *NullTeamPrivacy) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullTeamPrivacy) Value

func (ns NullTeamPrivacy) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullTeamRepoRole

type NullTeamRepoRole struct {
	TeamRepoRole TeamRepoRole
	Valid        bool // Valid is true if TeamRepoRole is not NULL
}

func (*NullTeamRepoRole) Scan

func (ns *NullTeamRepoRole) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullTeamRepoRole) Value

func (ns NullTeamRepoRole) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullTeamRole

type NullTeamRole struct {
	TeamRole TeamRole
	Valid    bool // Valid is true if TeamRole is not NULL
}

func (*NullTeamRole) Scan

func (ns *NullTeamRole) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullTeamRole) Value

func (ns NullTeamRole) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullTransactionalEmailStatus

type NullTransactionalEmailStatus struct {
	TransactionalEmailStatus TransactionalEmailStatus
	Valid                    bool // Valid is true if TransactionalEmailStatus is not NULL
}

func (*NullTransactionalEmailStatus) Scan

func (ns *NullTransactionalEmailStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullTransactionalEmailStatus) Value

Value implements the driver Valuer interface.

type NullTransferPrincipalKind

type NullTransferPrincipalKind struct {
	TransferPrincipalKind TransferPrincipalKind
	Valid                 bool // Valid is true if TransferPrincipalKind is not NULL
}

func (*NullTransferPrincipalKind) Scan

func (ns *NullTransferPrincipalKind) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullTransferPrincipalKind) Value

Value implements the driver Valuer interface.

type NullTransferStatus

type NullTransferStatus struct {
	TransferStatus TransferStatus
	Valid          bool // Valid is true if TransferStatus is not NULL
}

func (*NullTransferStatus) Scan

func (ns *NullTransferStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullTransferStatus) Value

func (ns NullTransferStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullWatchLevel

type NullWatchLevel struct {
	WatchLevel WatchLevel
	Valid      bool // Valid is true if WatchLevel is not NULL
}

func (*NullWatchLevel) Scan

func (ns *NullWatchLevel) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullWatchLevel) Value

func (ns NullWatchLevel) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullWebhookContentType

type NullWebhookContentType struct {
	WebhookContentType WebhookContentType
	Valid              bool // Valid is true if WebhookContentType is not NULL
}

func (*NullWebhookContentType) Scan

func (ns *NullWebhookContentType) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullWebhookContentType) Value

func (ns NullWebhookContentType) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullWebhookDeliveryStatus

type NullWebhookDeliveryStatus struct {
	WebhookDeliveryStatus WebhookDeliveryStatus
	Valid                 bool // Valid is true if WebhookDeliveryStatus is not NULL
}

func (*NullWebhookDeliveryStatus) Scan

func (ns *NullWebhookDeliveryStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullWebhookDeliveryStatus) Value

Value implements the driver Valuer interface.

type NullWebhookOwnerKind

type NullWebhookOwnerKind struct {
	WebhookOwnerKind WebhookOwnerKind
	Valid            bool // Valid is true if WebhookOwnerKind is not NULL
}

func (*NullWebhookOwnerKind) Scan

func (ns *NullWebhookOwnerKind) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullWebhookOwnerKind) Value

func (ns NullWebhookOwnerKind) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type Org

type Org struct {
	ID                    int64
	Slug                  string
	DisplayName           string
	Description           string
	AvatarObjectKey       pgtype.Text
	Location              string
	Website               string
	BillingEmail          string
	Plan                  OrgPlan
	AllowMemberRepoCreate bool
	CreatedByUserID       pgtype.Int8
	SuspendedAt           pgtype.Timestamptz
	SuspendedReason       pgtype.Text
	DeletedAt             pgtype.Timestamptz
	CreatedAt             pgtype.Timestamptz
	UpdatedAt             pgtype.Timestamptz
}

type OrgInvitation

type OrgInvitation struct {
	ID              int64
	OrgID           int64
	InvitedByUserID pgtype.Int8
	TargetUserID    pgtype.Int8
	TargetEmail     pgtype.Text
	Role            OrgRole
	TokenHash       []byte
	ExpiresAt       pgtype.Timestamptz
	AcceptedAt      pgtype.Timestamptz
	DeclinedAt      pgtype.Timestamptz
	CanceledAt      pgtype.Timestamptz
	CreatedAt       pgtype.Timestamptz
}

type OrgMember

type OrgMember struct {
	OrgID           int64
	UserID          int64
	Role            OrgRole
	InvitedByUserID pgtype.Int8
	JoinedAt        pgtype.Timestamptz
}

type OrgPlan

type OrgPlan string
const (
	OrgPlanFree       OrgPlan = "free"
	OrgPlanTeam       OrgPlan = "team"
	OrgPlanEnterprise OrgPlan = "enterprise"
)

func (*OrgPlan) Scan

func (e *OrgPlan) Scan(src interface{}) error

type OrgRole

type OrgRole string
const (
	OrgRoleOwner  OrgRole = "owner"
	OrgRoleMember OrgRole = "member"
)

func (*OrgRole) Scan

func (e *OrgRole) Scan(src interface{}) error

type PasswordReset

type PasswordReset struct {
	ID        int64
	UserID    int64
	TokenHash []byte
	ExpiresAt pgtype.Timestamptz
	UsedAt    pgtype.Timestamptz
	CreatedAt pgtype.Timestamptz
}

type PrFileStatus

type PrFileStatus string
const (
	PrFileStatusAdded    PrFileStatus = "added"
	PrFileStatusModified PrFileStatus = "modified"
	PrFileStatusDeleted  PrFileStatus = "deleted"
	PrFileStatusRenamed  PrFileStatus = "renamed"
	PrFileStatusCopied   PrFileStatus = "copied"
)

func (*PrFileStatus) Scan

func (e *PrFileStatus) Scan(src interface{}) error

type PrMergeMethod

type PrMergeMethod string
const (
	PrMergeMethodMerge  PrMergeMethod = "merge"
	PrMergeMethodSquash PrMergeMethod = "squash"
	PrMergeMethodRebase PrMergeMethod = "rebase"
)

func (*PrMergeMethod) Scan

func (e *PrMergeMethod) Scan(src interface{}) error

type PrMergeableState

type PrMergeableState string
const (
	PrMergeableStateUnknown PrMergeableState = "unknown"
	PrMergeableStateClean   PrMergeableState = "clean"
	PrMergeableStateDirty   PrMergeableState = "dirty"
	PrMergeableStateBlocked PrMergeableState = "blocked"
	PrMergeableStateBehind  PrMergeableState = "behind"
)

func (*PrMergeableState) Scan

func (e *PrMergeableState) Scan(src interface{}) error

type PrReview

type PrReview struct {
	ID                int64
	PrIssueID         int64
	AuthorUserID      pgtype.Int8
	State             PrReviewState
	Body              string
	BodyHtmlCached    pgtype.Text
	SubmittedAt       pgtype.Timestamptz
	DismissedAt       pgtype.Timestamptz
	DismissedByUserID pgtype.Int8
	DismissalReason   string
}

type PrReviewComment

type PrReviewComment struct {
	ID                int64
	PrIssueID         int64
	ReviewID          pgtype.Int8
	AuthorUserID      pgtype.Int8
	FilePath          string
	Side              PrReviewSide
	OriginalCommitSha string
	OriginalLine      int32
	OriginalPosition  int32
	CurrentPosition   pgtype.Int4
	Body              string
	BodyHtmlCached    pgtype.Text
	InReplyToID       pgtype.Int8
	Pending           bool
	ResolvedAt        pgtype.Timestamptz
	ResolvedByUserID  pgtype.Int8
	CreatedAt         pgtype.Timestamptz
	UpdatedAt         pgtype.Timestamptz
	EditedAt          pgtype.Timestamptz
}

type PrReviewRequest

type PrReviewRequest struct {
	ID                  int64
	PrIssueID           int64
	RequestedUserID     pgtype.Int8
	RequestedTeamID     pgtype.Int8
	RequestedByUserID   pgtype.Int8
	RequestedAt         pgtype.Timestamptz
	DismissedAt         pgtype.Timestamptz
	SatisfiedByReviewID pgtype.Int8
}

type PrReviewSide

type PrReviewSide string
const (
	PrReviewSideLeft  PrReviewSide = "left"
	PrReviewSideRight PrReviewSide = "right"
)

func (*PrReviewSide) Scan

func (e *PrReviewSide) Scan(src interface{}) error

type PrReviewState

type PrReviewState string
const (
	PrReviewStateComment        PrReviewState = "comment"
	PrReviewStateApprove        PrReviewState = "approve"
	PrReviewStateRequestChanges PrReviewState = "request_changes"
)

func (*PrReviewState) Scan

func (e *PrReviewState) Scan(src interface{}) error

type Principal

type Principal struct {
	Slug string
	Kind PrincipalKind
	ID   int64
}

type PrincipalKind

type PrincipalKind string
const (
	PrincipalKindUser PrincipalKind = "user"
	PrincipalKindOrg  PrincipalKind = "org"
)

func (*PrincipalKind) Scan

func (e *PrincipalKind) Scan(src interface{}) error

type PullRequest

type PullRequest struct {
	IssueID            int64
	BaseRef            string
	HeadRef            string
	HeadRepoID         int64
	BaseOid            string
	HeadOid            string
	Draft              bool
	Mergeable          pgtype.Bool
	MergeableState     PrMergeableState
	MergeCommitSha     pgtype.Text
	MergedAt           pgtype.Timestamptz
	MergedByUserID     pgtype.Int8
	MergeMethod        NullPrMergeMethod
	BaseOidAtMerge     pgtype.Text
	HeadOidAtMerge     pgtype.Text
	LastSynchronizedAt pgtype.Timestamptz
}

type PullRequestCommit

type PullRequestCommit struct {
	PrID           int64
	Sha            string
	Position       int32
	AuthorName     string
	AuthorEmail    string
	CommitterName  string
	CommitterEmail string
	Subject        string
	Body           string
	AuthoredAt     pgtype.Timestamptz
	CommittedAt    pgtype.Timestamptz
}

type PullRequestFile

type PullRequestFile struct {
	PrID      int64
	Path      string
	Status    PrFileStatus
	OldPath   pgtype.Text
	Additions int32
	Deletions int32
	Changes   int32
}

type PushEvent

type PushEvent struct {
	ID           int64
	RepoID       int64
	PusherUserID pgtype.Int8
	BeforeSha    string
	AfterSha     string
	Ref          string
	Protocol     string
	RequestID    string
	ProcessedAt  pgtype.Timestamptz
	CreatedAt    pgtype.Timestamptz
}

type Querier

type Querier interface {
	// One-shot UPDATE that flips a user's pending draft comments on a PR
	// into the just-submitted review. Runs inside the submit-review tx.
	AttachPendingCommentsToReview(ctx context.Context, db DBTX, arg AttachPendingCommentsToReviewParams) error
	// ─── commits + files (refreshed on synchronize) ──────────────────────
	ClearPullRequestCommits(ctx context.Context, db DBTX, prID int64) error
	ClearPullRequestFiles(ctx context.Context, db DBTX, prID int64) error
	// Used by the rate-limit gate (max 20 reviewers per PR per the spec
	// pitfall section).
	CountActivePRReviewRequests(ctx context.Context, db DBTX, prIssueID int64) (int32, error)
	// Returns the counts the merge gate cares about. `approves` excludes
	// dismissed reviews; `request_changes` includes only undismissed and
	// unsuperseded-by-same-author reviews. The "unsuperseded" semantics
	// (a later review by the same author wins) is computed in Go on the
	// caller side; this query only returns the raw rows it needs.
	CountPRReviewsForGate(ctx context.Context, db DBTX, prIssueID int64) (CountPRReviewsForGateRow, error)
	CountPullRequestsByRepo(ctx context.Context, db DBTX, arg CountPullRequestsByRepoParams) (int64, error)
	// SPDX-License-Identifier: AGPL-3.0-or-later
	// ─── pr_reviews ──────────────────────────────────────────────────────
	CreatePRReview(ctx context.Context, db DBTX, arg CreatePRReviewParams) (PrReview, error)
	// ─── pr_review_comments ──────────────────────────────────────────────
	CreatePRReviewComment(ctx context.Context, db DBTX, arg CreatePRReviewCommentParams) (PrReviewComment, error)
	// ─── pr_review_requests ──────────────────────────────────────────────
	CreatePRReviewRequest(ctx context.Context, db DBTX, arg CreatePRReviewRequestParams) (PrReviewRequest, error)
	// SPDX-License-Identifier: AGPL-3.0-or-later
	// ─── pull_requests core ──────────────────────────────────────────────
	// Creates the PR-side row keyed on issue_id (the caller already
	// inserted the issues row with kind='pr'). Defaults give a freshly-
	// opened PR `mergeable_state='unknown'` until the mergeability job
	// ticks.
	CreatePullRequest(ctx context.Context, db DBTX, arg CreatePullRequestParams) (PullRequest, error)
	DismissPRReview(ctx context.Context, db DBTX, arg DismissPRReviewParams) error
	DismissPRReviewRequest(ctx context.Context, db DBTX, id int64) error
	GetPRReviewByID(ctx context.Context, db DBTX, id int64) (PrReview, error)
	GetPRReviewComment(ctx context.Context, db DBTX, id int64) (PrReviewComment, error)
	GetPullRequestByIssueID(ctx context.Context, db DBTX, issueID int64) (PullRequest, error)
	// Joins issues + pull_requests so handlers can resolve via the URL
	// {owner}/{repo}/pulls/{number} in one round-trip.
	GetPullRequestByRepoAndNumber(ctx context.Context, db DBTX, arg GetPullRequestByRepoAndNumberParams) (GetPullRequestByRepoAndNumberRow, error)
	InsertPullRequestCommit(ctx context.Context, db DBTX, arg InsertPullRequestCommitParams) error
	InsertPullRequestFile(ctx context.Context, db DBTX, arg InsertPullRequestFileParams) error
	// Position-mapping reads only submitted comments (drafts re-anchor
	// when the user resumes the diff view).
	ListNonDraftCommentsForPositionMap(ctx context.Context, db DBTX, prIssueID int64) ([]ListNonDraftCommentsForPositionMapRow, error)
	// Returns the issue_ids of every still-open PR whose head_repo_id +
	// head_ref match the pushed ref. push:process uses this to fan-out
	// pr:synchronize jobs after a head-side push.
	ListOpenPRsForHeadRef(ctx context.Context, db DBTX, arg ListOpenPRsForHeadRefParams) ([]int64, error)
	ListPRReviewComments(ctx context.Context, db DBTX, prIssueID int64) ([]PrReviewComment, error)
	// Files-tab fetch: comments anchored to a single file path, oldest first.
	ListPRReviewCommentsForFile(ctx context.Context, db DBTX, arg ListPRReviewCommentsForFileParams) ([]PrReviewComment, error)
	ListPRReviewRequests(ctx context.Context, db DBTX, prIssueID int64) ([]PrReviewRequest, error)
	ListPRReviews(ctx context.Context, db DBTX, prIssueID int64) ([]PrReview, error)
	// Server-side draft listing: rows with pending=true belonging to one
	// user. Ordered by creation so the submit step processes them in order.
	ListPendingDraftCommentsForUser(ctx context.Context, db DBTX, arg ListPendingDraftCommentsForUserParams) ([]PrReviewComment, error)
	// Reviewer's inbox feed. Excludes dismissed + satisfied requests.
	ListPendingReviewRequestsForUser(ctx context.Context, db DBTX, requestedUserID pgtype.Int8) ([]PrReviewRequest, error)
	ListPullRequestCommits(ctx context.Context, db DBTX, prID int64) ([]PullRequestCommit, error)
	ListPullRequestFiles(ctx context.Context, db DBTX, prID int64) ([]PullRequestFile, error)
	// Mirrors the issues list query: state filter via narg, pagination,
	// ordered by recent activity.
	ListPullRequestsByRepo(ctx context.Context, db DBTX, arg ListPullRequestsByRepoParams) ([]ListPullRequestsByRepoRow, error)
	// Used by the merge gate to compute "latest review per author" semantics
	// in Go. Ordered author + submitted_at so the caller can pick the last
	// per author cheaply.
	ListUndismissedReviewsForGate(ctx context.Context, db DBTX, prIssueID int64) ([]ListUndismissedReviewsForGateRow, error)
	// FOR UPDATE row lock + return current shape so the merge job can
	// decide whether to proceed (e.g. someone else just merged it).
	LockPullRequestForMerge(ctx context.Context, db DBTX, issueID int64) (PullRequest, error)
	SatisfyPRReviewRequest(ctx context.Context, db DBTX, arg SatisfyPRReviewRequestParams) error
	// Position-mapping update emitted by pulls.Synchronize. NULL means
	// the comment has gone outdated.
	SetPRReviewCommentCurrentPosition(ctx context.Context, db DBTX, arg SetPRReviewCommentCurrentPositionParams) error
	SetPRReviewCommentResolved(ctx context.Context, db DBTX, arg SetPRReviewCommentResolvedParams) error
	SetPullRequestDraft(ctx context.Context, db DBTX, arg SetPullRequestDraftParams) error
	SetPullRequestMergeability(ctx context.Context, db DBTX, arg SetPullRequestMergeabilityParams) error
	SetPullRequestMerged(ctx context.Context, db DBTX, arg SetPullRequestMergedParams) error
	// Updates base_oid + head_oid + last_synchronized_at after a
	// synchronize tick.
	SetPullRequestSnapshot(ctx context.Context, db DBTX, arg SetPullRequestSnapshotParams) error
	UpdatePRReviewCommentBody(ctx context.Context, db DBTX, arg UpdatePRReviewCommentBodyParams) error
}

type Queries

type Queries struct {
}

func New

func New() *Queries

func (*Queries) AttachPendingCommentsToReview

func (q *Queries) AttachPendingCommentsToReview(ctx context.Context, db DBTX, arg AttachPendingCommentsToReviewParams) error

One-shot UPDATE that flips a user's pending draft comments on a PR into the just-submitted review. Runs inside the submit-review tx.

func (*Queries) ClearPullRequestCommits

func (q *Queries) ClearPullRequestCommits(ctx context.Context, db DBTX, prID int64) error

─── commits + files (refreshed on synchronize) ──────────────────────

func (*Queries) ClearPullRequestFiles

func (q *Queries) ClearPullRequestFiles(ctx context.Context, db DBTX, prID int64) error

func (*Queries) CountActivePRReviewRequests

func (q *Queries) CountActivePRReviewRequests(ctx context.Context, db DBTX, prIssueID int64) (int32, error)

Used by the rate-limit gate (max 20 reviewers per PR per the spec pitfall section).

func (*Queries) CountPRReviewsForGate

func (q *Queries) CountPRReviewsForGate(ctx context.Context, db DBTX, prIssueID int64) (CountPRReviewsForGateRow, error)

Returns the counts the merge gate cares about. `approves` excludes dismissed reviews; `request_changes` includes only undismissed and unsuperseded-by-same-author reviews. The "unsuperseded" semantics (a later review by the same author wins) is computed in Go on the caller side; this query only returns the raw rows it needs.

func (*Queries) CountPullRequestsByRepo

func (q *Queries) CountPullRequestsByRepo(ctx context.Context, db DBTX, arg CountPullRequestsByRepoParams) (int64, error)

func (*Queries) CreatePRReview

func (q *Queries) CreatePRReview(ctx context.Context, db DBTX, arg CreatePRReviewParams) (PrReview, error)

SPDX-License-Identifier: AGPL-3.0-or-later ─── pr_reviews ──────────────────────────────────────────────────────

func (*Queries) CreatePRReviewComment

func (q *Queries) CreatePRReviewComment(ctx context.Context, db DBTX, arg CreatePRReviewCommentParams) (PrReviewComment, error)

─── pr_review_comments ──────────────────────────────────────────────

func (*Queries) CreatePRReviewRequest

func (q *Queries) CreatePRReviewRequest(ctx context.Context, db DBTX, arg CreatePRReviewRequestParams) (PrReviewRequest, error)

─── pr_review_requests ──────────────────────────────────────────────

func (*Queries) CreatePullRequest

func (q *Queries) CreatePullRequest(ctx context.Context, db DBTX, arg CreatePullRequestParams) (PullRequest, error)

SPDX-License-Identifier: AGPL-3.0-or-later ─── pull_requests core ────────────────────────────────────────────── Creates the PR-side row keyed on issue_id (the caller already inserted the issues row with kind='pr'). Defaults give a freshly- opened PR `mergeable_state='unknown'` until the mergeability job ticks.

func (*Queries) DismissPRReview

func (q *Queries) DismissPRReview(ctx context.Context, db DBTX, arg DismissPRReviewParams) error

func (*Queries) DismissPRReviewRequest

func (q *Queries) DismissPRReviewRequest(ctx context.Context, db DBTX, id int64) error

func (*Queries) GetPRReviewByID

func (q *Queries) GetPRReviewByID(ctx context.Context, db DBTX, id int64) (PrReview, error)

func (*Queries) GetPRReviewComment

func (q *Queries) GetPRReviewComment(ctx context.Context, db DBTX, id int64) (PrReviewComment, error)

func (*Queries) GetPullRequestByIssueID

func (q *Queries) GetPullRequestByIssueID(ctx context.Context, db DBTX, issueID int64) (PullRequest, error)

func (*Queries) GetPullRequestByRepoAndNumber

func (q *Queries) GetPullRequestByRepoAndNumber(ctx context.Context, db DBTX, arg GetPullRequestByRepoAndNumberParams) (GetPullRequestByRepoAndNumberRow, error)

Joins issues + pull_requests so handlers can resolve via the URL {owner}/{repo}/pulls/{number} in one round-trip.

func (*Queries) InsertPullRequestCommit

func (q *Queries) InsertPullRequestCommit(ctx context.Context, db DBTX, arg InsertPullRequestCommitParams) error

func (*Queries) InsertPullRequestFile

func (q *Queries) InsertPullRequestFile(ctx context.Context, db DBTX, arg InsertPullRequestFileParams) error

func (*Queries) ListNonDraftCommentsForPositionMap

func (q *Queries) ListNonDraftCommentsForPositionMap(ctx context.Context, db DBTX, prIssueID int64) ([]ListNonDraftCommentsForPositionMapRow, error)

Position-mapping reads only submitted comments (drafts re-anchor when the user resumes the diff view).

func (*Queries) ListOpenPRsForHeadRef

func (q *Queries) ListOpenPRsForHeadRef(ctx context.Context, db DBTX, arg ListOpenPRsForHeadRefParams) ([]int64, error)

Returns the issue_ids of every still-open PR whose head_repo_id + head_ref match the pushed ref. push:process uses this to fan-out pr:synchronize jobs after a head-side push.

func (*Queries) ListPRReviewComments

func (q *Queries) ListPRReviewComments(ctx context.Context, db DBTX, prIssueID int64) ([]PrReviewComment, error)

func (*Queries) ListPRReviewCommentsForFile

func (q *Queries) ListPRReviewCommentsForFile(ctx context.Context, db DBTX, arg ListPRReviewCommentsForFileParams) ([]PrReviewComment, error)

Files-tab fetch: comments anchored to a single file path, oldest first.

func (*Queries) ListPRReviewRequests

func (q *Queries) ListPRReviewRequests(ctx context.Context, db DBTX, prIssueID int64) ([]PrReviewRequest, error)

func (*Queries) ListPRReviews

func (q *Queries) ListPRReviews(ctx context.Context, db DBTX, prIssueID int64) ([]PrReview, error)

func (*Queries) ListPendingDraftCommentsForUser

func (q *Queries) ListPendingDraftCommentsForUser(ctx context.Context, db DBTX, arg ListPendingDraftCommentsForUserParams) ([]PrReviewComment, error)

Server-side draft listing: rows with pending=true belonging to one user. Ordered by creation so the submit step processes them in order.

func (*Queries) ListPendingReviewRequestsForUser

func (q *Queries) ListPendingReviewRequestsForUser(ctx context.Context, db DBTX, requestedUserID pgtype.Int8) ([]PrReviewRequest, error)

Reviewer's inbox feed. Excludes dismissed + satisfied requests.

func (*Queries) ListPullRequestCommits

func (q *Queries) ListPullRequestCommits(ctx context.Context, db DBTX, prID int64) ([]PullRequestCommit, error)

func (*Queries) ListPullRequestFiles

func (q *Queries) ListPullRequestFiles(ctx context.Context, db DBTX, prID int64) ([]PullRequestFile, error)

func (*Queries) ListPullRequestsByRepo

func (q *Queries) ListPullRequestsByRepo(ctx context.Context, db DBTX, arg ListPullRequestsByRepoParams) ([]ListPullRequestsByRepoRow, error)

Mirrors the issues list query: state filter via narg, pagination, ordered by recent activity.

func (*Queries) ListUndismissedReviewsForGate

func (q *Queries) ListUndismissedReviewsForGate(ctx context.Context, db DBTX, prIssueID int64) ([]ListUndismissedReviewsForGateRow, error)

Used by the merge gate to compute "latest review per author" semantics in Go. Ordered author + submitted_at so the caller can pick the last per author cheaply.

func (*Queries) LockPullRequestForMerge

func (q *Queries) LockPullRequestForMerge(ctx context.Context, db DBTX, issueID int64) (PullRequest, error)

FOR UPDATE row lock + return current shape so the merge job can decide whether to proceed (e.g. someone else just merged it).

func (*Queries) SatisfyPRReviewRequest

func (q *Queries) SatisfyPRReviewRequest(ctx context.Context, db DBTX, arg SatisfyPRReviewRequestParams) error

func (*Queries) SetPRReviewCommentCurrentPosition

func (q *Queries) SetPRReviewCommentCurrentPosition(ctx context.Context, db DBTX, arg SetPRReviewCommentCurrentPositionParams) error

Position-mapping update emitted by pulls.Synchronize. NULL means the comment has gone outdated.

func (*Queries) SetPRReviewCommentResolved

func (q *Queries) SetPRReviewCommentResolved(ctx context.Context, db DBTX, arg SetPRReviewCommentResolvedParams) error

func (*Queries) SetPullRequestDraft

func (q *Queries) SetPullRequestDraft(ctx context.Context, db DBTX, arg SetPullRequestDraftParams) error

func (*Queries) SetPullRequestMergeability

func (q *Queries) SetPullRequestMergeability(ctx context.Context, db DBTX, arg SetPullRequestMergeabilityParams) error

func (*Queries) SetPullRequestMerged

func (q *Queries) SetPullRequestMerged(ctx context.Context, db DBTX, arg SetPullRequestMergedParams) error

func (*Queries) SetPullRequestSnapshot

func (q *Queries) SetPullRequestSnapshot(ctx context.Context, db DBTX, arg SetPullRequestSnapshotParams) error

Updates base_oid + head_oid + last_synchronized_at after a synchronize tick.

func (*Queries) UpdatePRReviewCommentBody

func (q *Queries) UpdatePRReviewCommentBody(ctx context.Context, db DBTX, arg UpdatePRReviewCommentBodyParams) error

type RateLimit

type RateLimit struct {
	Scope           string
	Key             string
	Hits            int32
	WindowStartedAt pgtype.Timestamptz
}

type Repo

type Repo struct {
	ID                 int64
	OwnerUserID        pgtype.Int8
	OwnerOrgID         pgtype.Int8
	Name               string
	Description        string
	Visibility         RepoVisibility
	DefaultBranch      string
	IsArchived         bool
	ArchivedAt         pgtype.Timestamptz
	DeletedAt          pgtype.Timestamptz
	DiskUsedBytes      int64
	ForkOfRepoID       pgtype.Int8
	LicenseKey         pgtype.Text
	PrimaryLanguage    pgtype.Text
	HasIssues          bool
	HasPulls           bool
	CreatedAt          pgtype.Timestamptz
	UpdatedAt          pgtype.Timestamptz
	DefaultBranchOid   pgtype.Text
	AllowSquashMerge   bool
	AllowRebaseMerge   bool
	AllowMergeCommit   bool
	DefaultMergeMethod PrMergeMethod
	StarCount          int64
	WatcherCount       int64
	ForkCount          int64
	InitStatus         RepoInitStatus
	LastIndexedOid     pgtype.Text
}

type RepoCollaborator

type RepoCollaborator struct {
	RepoID        int64
	UserID        int64
	Role          CollabRole
	AddedAt       pgtype.Timestamptz
	AddedByUserID pgtype.Int8
}

type RepoInitStatus

type RepoInitStatus string
const (
	RepoInitStatusInitialized RepoInitStatus = "initialized"
	RepoInitStatusInitPending RepoInitStatus = "init_pending"
	RepoInitStatusInitFailed  RepoInitStatus = "init_failed"
)

func (*RepoInitStatus) Scan

func (e *RepoInitStatus) Scan(src interface{}) error

type RepoIssueCounter

type RepoIssueCounter struct {
	RepoID     int64
	NextNumber int64
}

type RepoRedirect

type RepoRedirect struct {
	OldOwnerUserID pgtype.Int8
	OldOwnerOrgID  pgtype.Int8
	OldName        string
	RepoID         int64
	RedirectedAt   pgtype.Timestamptz
}

type RepoTopic

type RepoTopic struct {
	RepoID    int64
	Topic     string
	CreatedAt pgtype.Timestamptz
}

type RepoTransferRequest

type RepoTransferRequest struct {
	ID              int64
	RepoID          int64
	FromUserID      int64
	ToPrincipalKind TransferPrincipalKind
	ToPrincipalID   int64
	CreatedBy       int64
	CreatedAt       pgtype.Timestamptz
	ExpiresAt       pgtype.Timestamptz
	Status          TransferStatus
	AcceptedAt      pgtype.Timestamptz
	DeclinedAt      pgtype.Timestamptz
	CanceledAt      pgtype.Timestamptz
}

type RepoVisibility

type RepoVisibility string
const (
	RepoVisibilityPublic  RepoVisibility = "public"
	RepoVisibilityPrivate RepoVisibility = "private"
)

func (*RepoVisibility) Scan

func (e *RepoVisibility) Scan(src interface{}) error

type ReposSearch

type ReposSearch struct {
	RepoID int64
	Tsv    interface{}
}

type SatisfyPRReviewRequestParams

type SatisfyPRReviewRequestParams struct {
	PrIssueID           int64
	SatisfiedByReviewID pgtype.Int8
	RequestedUserID     pgtype.Int8
}

type SetPRReviewCommentCurrentPositionParams

type SetPRReviewCommentCurrentPositionParams struct {
	ID              int64
	CurrentPosition pgtype.Int4
}

type SetPRReviewCommentResolvedParams

type SetPRReviewCommentResolvedParams struct {
	ID               int64
	ResolvedAt       pgtype.Timestamptz
	ResolvedByUserID pgtype.Int8
}

type SetPullRequestDraftParams

type SetPullRequestDraftParams struct {
	IssueID int64
	Draft   bool
}

type SetPullRequestMergeabilityParams

type SetPullRequestMergeabilityParams struct {
	IssueID        int64
	MergeableState PrMergeableState
	Mergeable      pgtype.Bool
}

type SetPullRequestMergedParams

type SetPullRequestMergedParams struct {
	IssueID        int64
	MergeCommitSha pgtype.Text
	MergeMethod    NullPrMergeMethod
	BaseOidAtMerge pgtype.Text
	HeadOidAtMerge pgtype.Text
	MergedByUserID pgtype.Int8
}

type SetPullRequestSnapshotParams

type SetPullRequestSnapshotParams struct {
	IssueID int64
	BaseOid string
	HeadOid string
}

type SignupIpThrottle

type SignupIpThrottle struct {
	Cidr            netip.Addr
	Hits            int32
	WindowStartedAt pgtype.Timestamptz
}

type Star

type Star struct {
	UserID    int64
	RepoID    int64
	StarredAt pgtype.Timestamptz
}

type Team

type Team struct {
	ID              int64
	OrgID           int64
	Slug            string
	DisplayName     string
	Description     string
	ParentTeamID    pgtype.Int8
	Privacy         TeamPrivacy
	CreatedByUserID pgtype.Int8
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type TeamMember

type TeamMember struct {
	TeamID        int64
	UserID        int64
	Role          TeamRole
	AddedByUserID pgtype.Int8
	AddedAt       pgtype.Timestamptz
}

type TeamPrivacy

type TeamPrivacy string
const (
	TeamPrivacyVisible TeamPrivacy = "visible"
	TeamPrivacySecret  TeamPrivacy = "secret"
)

func (*TeamPrivacy) Scan

func (e *TeamPrivacy) Scan(src interface{}) error

type TeamRepoAccess

type TeamRepoAccess struct {
	TeamID        int64
	RepoID        int64
	Role          TeamRepoRole
	AddedByUserID pgtype.Int8
	AddedAt       pgtype.Timestamptz
}

type TeamRepoRole

type TeamRepoRole string
const (
	TeamRepoRoleRead     TeamRepoRole = "read"
	TeamRepoRoleTriage   TeamRepoRole = "triage"
	TeamRepoRoleWrite    TeamRepoRole = "write"
	TeamRepoRoleMaintain TeamRepoRole = "maintain"
	TeamRepoRoleAdmin    TeamRepoRole = "admin"
)

func (*TeamRepoRole) Scan

func (e *TeamRepoRole) Scan(src interface{}) error

type TeamRole

type TeamRole string
const (
	TeamRoleMember     TeamRole = "member"
	TeamRoleMaintainer TeamRole = "maintainer"
)

func (*TeamRole) Scan

func (e *TeamRole) Scan(src interface{}) error

type TransactionalEmailLog

type TransactionalEmailLog struct {
	ID              int64
	RecipientUserID pgtype.Int8
	RecipientEmail  string
	Kind            string
	Subject         string
	ProviderID      string
	Status          TransactionalEmailStatus
	ErrorSummary    pgtype.Text
	SentAt          pgtype.Timestamptz
	DeliveredAt     pgtype.Timestamptz
}

type TransactionalEmailStatus

type TransactionalEmailStatus string
const (
	TransactionalEmailStatusQueued      TransactionalEmailStatus = "queued"
	TransactionalEmailStatusSent        TransactionalEmailStatus = "sent"
	TransactionalEmailStatusSoftBounced TransactionalEmailStatus = "soft_bounced"
	TransactionalEmailStatusHardBounced TransactionalEmailStatus = "hard_bounced"
	TransactionalEmailStatusDropped     TransactionalEmailStatus = "dropped"
)

func (*TransactionalEmailStatus) Scan

func (e *TransactionalEmailStatus) Scan(src interface{}) error

type TransferPrincipalKind

type TransferPrincipalKind string
const (
	TransferPrincipalKindUser TransferPrincipalKind = "user"
	TransferPrincipalKindOrg  TransferPrincipalKind = "org"
)

func (*TransferPrincipalKind) Scan

func (e *TransferPrincipalKind) Scan(src interface{}) error

type TransferStatus

type TransferStatus string
const (
	TransferStatusPending  TransferStatus = "pending"
	TransferStatusAccepted TransferStatus = "accepted"
	TransferStatusDeclined TransferStatus = "declined"
	TransferStatusCanceled TransferStatus = "canceled"
	TransferStatusExpired  TransferStatus = "expired"
)

func (*TransferStatus) Scan

func (e *TransferStatus) Scan(src interface{}) error

type UpdatePRReviewCommentBodyParams

type UpdatePRReviewCommentBodyParams struct {
	ID             int64
	Body           string
	BodyHtmlCached pgtype.Text
}

type User

type User struct {
	ID                int64
	Username          string
	DisplayName       string
	PrimaryEmailID    pgtype.Int8
	PasswordHash      string
	PasswordAlgo      string
	PasswordUpdatedAt pgtype.Timestamptz
	EmailVerified     bool
	LastLoginAt       pgtype.Timestamptz
	SuspendedAt       pgtype.Timestamptz
	SuspendedReason   pgtype.Text
	DeletedAt         pgtype.Timestamptz
	CreatedAt         pgtype.Timestamptz
	UpdatedAt         pgtype.Timestamptz
	Bio               string
	Location          string
	Website           string
	Company           string
	Pronouns          string
	AvatarObjectKey   pgtype.Text
	Theme             string
	SessionEpoch      int32
	IsSiteAdmin       bool
}

type UserEmail

type UserEmail struct {
	ID                    int64
	UserID                int64
	Email                 string
	IsPrimary             bool
	Verified              bool
	VerificationTokenHash []byte
	VerificationSentAt    pgtype.Timestamptz
	VerifiedAt            pgtype.Timestamptz
	CreatedAt             pgtype.Timestamptz
}

type UserNotificationPref

type UserNotificationPref struct {
	UserID    int64
	Key       string
	Value     []byte
	UpdatedAt pgtype.Timestamptz
}

type UserRecoveryCode

type UserRecoveryCode struct {
	ID          int64
	UserID      int64
	CodeHash    []byte
	UsedAt      pgtype.Timestamptz
	GeneratedAt pgtype.Timestamptz
	CreatedAt   pgtype.Timestamptz
}

type UserSshKey

type UserSshKey struct {
	ID                int64
	UserID            int64
	Title             string
	FingerprintSha256 string
	KeyType           string
	KeyBits           int32
	PublicKey         string
	LastUsedAt        pgtype.Timestamptz
	LastUsedIp        *netip.Addr
	CreatedAt         pgtype.Timestamptz
}

type UserToken

type UserToken struct {
	ID          int64
	UserID      int64
	Name        string
	TokenHash   []byte
	TokenPrefix string
	Scopes      []string
	ExpiresAt   pgtype.Timestamptz
	LastUsedAt  pgtype.Timestamptz
	LastUsedIp  *netip.Addr
	RevokedAt   pgtype.Timestamptz
	CreatedAt   pgtype.Timestamptz
}

type UserTotp

type UserTotp struct {
	ID              int64
	UserID          int64
	SecretEncrypted []byte
	SecretNonce     []byte
	ConfirmedAt     pgtype.Timestamptz
	LastUsedCounter int64
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type UsernameRedirect

type UsernameRedirect struct {
	OldUsername string
	UserID      int64
	ChangedAt   pgtype.Timestamptz
}

type UsersSearch

type UsersSearch struct {
	UserID int64
	Tsv    interface{}
}

type Watch

type Watch struct {
	UserID    int64
	RepoID    int64
	Level     WatchLevel
	UpdatedAt pgtype.Timestamptz
}

type WatchLevel

type WatchLevel string
const (
	WatchLevelAll           WatchLevel = "all"
	WatchLevelParticipating WatchLevel = "participating"
	WatchLevelIgnore        WatchLevel = "ignore"
)

func (*WatchLevel) Scan

func (e *WatchLevel) Scan(src interface{}) error

type Webhook

type Webhook struct {
	ID                   int64
	OwnerKind            WebhookOwnerKind
	OwnerID              int64
	Url                  string
	ContentType          WebhookContentType
	Events               []string
	SecretCiphertext     []byte
	SecretNonce          []byte
	Active               bool
	SslVerification      bool
	ConsecutiveFailures  int32
	AutoDisableThreshold int32
	DisabledAt           pgtype.Timestamptz
	DisabledReason       pgtype.Text
	LastSuccessAt        pgtype.Timestamptz
	LastFailureAt        pgtype.Timestamptz
	CreatedByUserID      pgtype.Int8
	CreatedAt            pgtype.Timestamptz
	UpdatedAt            pgtype.Timestamptz
}

type WebhookContentType

type WebhookContentType string
const (
	WebhookContentTypeJson WebhookContentType = "json"
	WebhookContentTypeForm WebhookContentType = "form"
)

func (*WebhookContentType) Scan

func (e *WebhookContentType) Scan(src interface{}) error

type WebhookDelivery

type WebhookDelivery struct {
	ID                int64
	WebhookID         int64
	EventKind         string
	EventID           pgtype.Int8
	DeliveryUuid      pgtype.UUID
	Payload           []byte
	RequestHeaders    []byte
	RequestBody       []byte
	ResponseStatus    pgtype.Int4
	ResponseHeaders   []byte
	ResponseBody      []byte
	ResponseTruncated bool
	StartedAt         pgtype.Timestamptz
	CompletedAt       pgtype.Timestamptz
	Attempt           int32
	MaxAttempts       int32
	NextRetryAt       pgtype.Timestamptz
	Status            WebhookDeliveryStatus
	IdempotencyKey    string
	ErrorSummary      pgtype.Text
	RedeliverOf       pgtype.Int8
}

type WebhookDeliveryStatus

type WebhookDeliveryStatus string
const (
	WebhookDeliveryStatusPending         WebhookDeliveryStatus = "pending"
	WebhookDeliveryStatusSucceeded       WebhookDeliveryStatus = "succeeded"
	WebhookDeliveryStatusFailedRetry     WebhookDeliveryStatus = "failed_retry"
	WebhookDeliveryStatusFailedPermanent WebhookDeliveryStatus = "failed_permanent"
)

func (*WebhookDeliveryStatus) Scan

func (e *WebhookDeliveryStatus) Scan(src interface{}) error

type WebhookEventsPending

type WebhookEventsPending struct {
	ID        int64
	RepoID    int64
	EventKind string
	Payload   []byte
	CreatedAt pgtype.Timestamptz
}

type WebhookOwnerKind

type WebhookOwnerKind string
const (
	WebhookOwnerKindRepo WebhookOwnerKind = "repo"
	WebhookOwnerKindOrg  WebhookOwnerKind = "org"
)

func (*WebhookOwnerKind) Scan

func (e *WebhookOwnerKind) Scan(src interface{}) error

Jump to

Keyboard shortcuts

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