Documentation
¶
Index ¶
- type AcquireInstallationBudgetLeaseParams
- type AcquireInstallationBudgetLeaseRow
- type AcquireOrRenewStreamWatermarkLeaseParams
- type AcquireRefreshIntentGenerationLockParams
- type AdvanceBackfillCursorParams
- type AdvanceBranchReconciliationTargetGenerationsParams
- type AdvanceBranchReconciliationTargetGenerationsRow
- type AdvanceGapHealCursorParams
- type AdvanceInstallationBackfillCursorParams
- type AdvanceSweepCursorParams
- type AppendAcceptedCheckHistoryParams
- type ApplyBranchHintTransitionParams
- type ApplyBranchHintTransitionRow
- type ApplyDerivedWorkItemBatchParams
- type BackfillChild
- type BackfillCursor
- type BeginBranchReconciliationParams
- type BeginBranchReconciliationRow
- type BranchReconciliation
- type BranchReconciliationPage
- type BumpRefreshIntentGenerationsRow
- type ChangeEvent
- type CheckHistory
- type CheckRun
- type ClaimGapHealCursorParams
- type CollectBranchReconciliationBacklogRow
- type CollectBudgetMetricsRow
- type CollectCacheStalenessMetricsRow
- type CollectConsumerStreamMetricsRow
- type CollectDeliveryMetricsRow
- type CollectDriftMetricsRow
- type CollectOperationHeartbeatMetricsRow
- type CollectPrunableOutboxMetricsRow
- type CollectRiverQueueDepthMetricsRow
- type CollectStreamWatermarkMetricsRow
- type CollectSweepMetricsRow
- type CollectTombstoneMetricsRow
- type CompleteBranchReconciliationPageParams
- type CompleteGapHealCursorParams
- type CompleteRefreshIntentGenerationParams
- type CompleteSweepCursorParams
- type ConfirmPullRequestMetadataCheckedAtParams
- type ConsumerCursor
- type CountLoadgenRunDeliveriesRow
- type CountPendingBackfillChildrenParams
- type DBTX
- type DeleteCheckHistoryBatchParams
- type DeleteLoadgenConsumerCursorParams
- type DerivationDirty
- type DriftEntitiesWithoutBranchFence
- type DriftEntitiesWithoutChangeInput
- type DriftEntitiesWithoutParticipation
- type DriftEntity
- type DriftEntityKey
- type DriftFinding
- type DriftSampleCursor
- type EnsureBackfillCursorParams
- type EnsureConsumerCursorParams
- type EnsureInstallationBudgetParams
- type EnsureSweepCursorParams
- type EntityObservationVersion
- type EscalateOpenDriftFindingParams
- type GapHealCursor
- type GetBackfillCursorForUpdateParams
- type GetBackfillCursorParams
- type GetBranchReconciliationGenerationForShareParams
- type GetBranchReconciliationPageParams
- type GetCachedEntitySnapshotParams
- type GetCachedEntitySnapshotRow
- type GetCheckRunsFetchMetadataParams
- type GetCheckRunsFetchMetadataRow
- type GetConsumerCursorForUpdateParams
- type GetDriftSampleCursorParams
- type GetLatestTerminalRefreshJobStateParams
- type GetLoadgenCacheSeedStateRow
- type GetOpenDriftFindingByHashParams
- type GetPullRequestByIdentityParams
- type GetPullRequestByIdentityRow
- type GetPullRequestByKeyParams
- type GetPullRequestByKeyRow
- type GetPullRequestFetchMetadataParams
- type GetPullRequestFetchMetadataRow
- type GetRefreshIntentGenerationForShareParams
- type GetRefreshIntentGenerationForUpdateParams
- type GetRefreshIntentStateForShareParams
- type GetRefreshIntentStateForShareRow
- type GetRefreshIntentStateParams
- type GetRefreshIntentStateRow
- type GetRepoRulesFetchMetadataRow
- type GetStackByIdentityParams
- type GetStackByIdentityRow
- type GetStackByKeyParams
- type GetStackByKeyRow
- type GetStackFetchMetadataParams
- type GetStackFetchMetadataRow
- type GetSweepCursorForUpdateParams
- type GetSweepCursorParams
- type GetSweepPageParams
- type HeartbeatBranchReconciliationPageParams
- type InsertChangeEventParams
- type InsertDriftFindingParams
- type InsertSweepSeenKeysParams
- type InsertWebhookDeliveryParams
- type InstallationBackfillCursor
- type InstallationBudget
- type ListBranchReconciliationGenerationKeysParams
- type ListBranchReconciliationGenerationKeysRow
- type ListCachedPRMembershipsParams
- type ListCachedPRMembershipsRow
- type ListCodeOwnerIdentitiesRow
- type ListLiveOpenPullRequestNumbersParams
- type ListLiveStackNumbersParams
- type ListLoadgenCachedCheckRunsRow
- type ListLoadgenCachedPullRequestChangeSnapshotsRow
- type ListLoadgenCachedPullRequestChangedFilesRow
- type ListLoadgenCachedPullRequestCommentsRow
- type ListLoadgenCachedPullRequestFileOwnersRow
- type ListLoadgenCachedPullRequestReviewRequestsRow
- type ListLoadgenCachedPullRequestReviewsRow
- type ListLoadgenCachedPullRequestsRow
- type ListLoadgenCachedReviewThreadsRow
- type ListLoadgenCachedStacksRow
- type ListLoadgenDroppedDeliveriesRow
- type ListMissingSweepEntityKeysParams
- type ListOutstandingRefreshIntentGenerationsParams
- type ListOutstandingRefreshIntentGenerationsRow
- type ListPRScopesByHeadSHAParams
- type ListPRScopesByHeadSHARow
- type ListPRsAffectedByBranchParams
- type ListPRsAffectedByBranchRow
- type ListPullRequestChangeFetchMetadataParams
- type ListPullRequestChangeFetchMetadataRow
- type ListSeenBackfillRefreshKeysParams
- type ListStacksAffectedByBranchParams
- type ListStaleClosedPullRequestsParams
- type ListStaleClosedPullRequestsRow
- type ListStaleClosedStacksParams
- type ListStaleClosedStacksRow
- type ListStaleOpenPullRequestsParams
- type ListStaleOpenPullRequestsRow
- type ListStaleOpenStacksParams
- type ListStaleOpenStacksRow
- type ListStaleRepoRulesParams
- type ListStaleRepoRulesRow
- type ListSweepRepositoriesRow
- type LoadDerivationSnapshotRow
- type MarkCompletedBackfillChildrenParams
- type MarkDerivationDirtyParams
- type NullRiverJobState
- type OperationHeartbeat
- type PageChangeEventsParams
- type PageChangeEventsRow
- type PruneChangeEventsParams
- type PruneResolvedDriftFindingBatchParams
- type PruneWebhookDeliveryPayloadBatchParams
- type PublishStreamWatermarkParams
- type PullRequest
- type PullRequestChangeSnapshot
- type PullRequestChangedFile
- type PullRequestComment
- type PullRequestFileOwner
- type PullRequestReview
- type PullRequestReviewRequest
- type Queries
- func (q *Queries) AcquireEntityAdvisoryLock(ctx context.Context, entityKey string) error
- func (q *Queries) AcquireInstallationBudgetLease(ctx context.Context, arg AcquireInstallationBudgetLeaseParams) ([]AcquireInstallationBudgetLeaseRow, error)
- func (q *Queries) AcquireOrRenewStreamWatermarkLease(ctx context.Context, arg AcquireOrRenewStreamWatermarkLeaseParams) (string, error)
- func (q *Queries) AcquireOutboxWatermarkFence(ctx context.Context, lockKey int64) error
- func (q *Queries) AcquireOutboxWriterFence(ctx context.Context, lockKey int64) error
- func (q *Queries) AcquireRefreshIntentGenerationLock(ctx context.Context, arg AcquireRefreshIntentGenerationLockParams) error
- func (q *Queries) AdvanceBackfillCursor(ctx context.Context, arg AdvanceBackfillCursorParams) (BackfillCursor, error)
- func (q *Queries) AdvanceBranchReconciliationTargetGenerations(ctx context.Context, arg AdvanceBranchReconciliationTargetGenerationsParams) ([]AdvanceBranchReconciliationTargetGenerationsRow, error)
- func (q *Queries) AdvanceEntityObservationVersion(ctx context.Context, entityKey string) (int64, error)
- func (q *Queries) AdvanceGapHealCursor(ctx context.Context, arg AdvanceGapHealCursorParams) (int64, error)
- func (q *Queries) AdvanceInstallationBackfillCursor(ctx context.Context, arg AdvanceInstallationBackfillCursorParams) (InstallationBackfillCursor, error)
- func (q *Queries) AdvanceSweepCursor(ctx context.Context, arg AdvanceSweepCursorParams) (SweepCursor, error)
- func (q *Queries) AppendAcceptedCheckHistory(ctx context.Context, arg AppendAcceptedCheckHistoryParams) error
- func (q *Queries) ApplyBranchHintTransition(ctx context.Context, arg ApplyBranchHintTransitionParams) ([]ApplyBranchHintTransitionRow, error)
- func (q *Queries) ApplyDerivedWorkItemBatch(ctx context.Context, arg ApplyDerivedWorkItemBatchParams) ([]int64, error)
- func (q *Queries) BeginBranchReconciliation(ctx context.Context, arg BeginBranchReconciliationParams) (BeginBranchReconciliationRow, error)
- func (q *Queries) BumpRefreshIntentGenerations(ctx context.Context, intents []byte) ([]BumpRefreshIntentGenerationsRow, error)
- func (q *Queries) ClaimDerivationDirtyScopes(ctx context.Context, dirtyCap int32) ([]string, error)
- func (q *Queries) ClaimGapHealCursor(ctx context.Context, arg ClaimGapHealCursorParams) (GapHealCursor, error)
- func (q *Queries) ClaimWebhookDeliveries(ctx context.Context, batchSize int32) ([]WebhookDelivery, error)
- func (q *Queries) ClearDerivationDirtyScopes(ctx context.Context, scopeKeys []string) error
- func (q *Queries) CollectBranchReconciliationBacklog(ctx context.Context) (CollectBranchReconciliationBacklogRow, error)
- func (q *Queries) CollectBudgetMetrics(ctx context.Context, installationID int64) ([]CollectBudgetMetricsRow, error)
- func (q *Queries) CollectCacheStalenessMetrics(ctx context.Context, installationID int64) ([]CollectCacheStalenessMetricsRow, error)
- func (q *Queries) CollectConsumerStreamMetrics(ctx context.Context) ([]CollectConsumerStreamMetricsRow, error)
- func (q *Queries) CollectDeliveryMetrics(ctx context.Context) (CollectDeliveryMetricsRow, error)
- func (q *Queries) CollectDriftMetrics(ctx context.Context, installationID int64) ([]CollectDriftMetricsRow, error)
- func (q *Queries) CollectOperationHeartbeatMetrics(ctx context.Context, installationID int64) ([]CollectOperationHeartbeatMetricsRow, error)
- func (q *Queries) CollectPrunableOutboxMetrics(ctx context.Context, retentionAge string) ([]CollectPrunableOutboxMetricsRow, error)
- func (q *Queries) CollectRiverQueueDepthMetrics(ctx context.Context) ([]CollectRiverQueueDepthMetricsRow, error)
- func (q *Queries) CollectStreamWatermarkMetrics(ctx context.Context) (CollectStreamWatermarkMetricsRow, error)
- func (q *Queries) CollectSweepMetrics(ctx context.Context, installationID int64) ([]CollectSweepMetricsRow, error)
- func (q *Queries) CollectTombstoneMetrics(ctx context.Context) ([]CollectTombstoneMetricsRow, error)
- func (q *Queries) CompleteBranchReconciliationPage(ctx context.Context, arg CompleteBranchReconciliationPageParams) (int64, error)
- func (q *Queries) CompleteGapHealCursor(ctx context.Context, arg CompleteGapHealCursorParams) (int64, error)
- func (q *Queries) CompleteRefreshIntentGeneration(ctx context.Context, arg CompleteRefreshIntentGenerationParams) error
- func (q *Queries) CompleteSweepCursor(ctx context.Context, arg CompleteSweepCursorParams) (SweepCursor, error)
- func (q *Queries) ConfirmPullRequestMetadataCheckedAt(ctx context.Context, arg ConfirmPullRequestMetadataCheckedAtParams) (int64, error)
- func (q *Queries) CountDerivationDirty(ctx context.Context) (int64, error)
- func (q *Queries) CountDriftFindings(ctx context.Context) (int64, error)
- func (q *Queries) CountLoadgenRunDeliveries(ctx context.Context, deliveryGuids []string) (CountLoadgenRunDeliveriesRow, error)
- func (q *Queries) CountPendingBackfillChildren(ctx context.Context, arg CountPendingBackfillChildrenParams) (int64, error)
- func (q *Queries) CountPendingInstallationRepos(ctx context.Context, installationID int64) (int64, error)
- func (q *Queries) CountWebhookDeliveriesByStatus(ctx context.Context, status string) (int64, error)
- func (q *Queries) DeleteCheckHistoryBatch(ctx context.Context, arg DeleteCheckHistoryBatchParams) (int64, error)
- func (q *Queries) DeleteLoadgenConsumerCursor(ctx context.Context, arg DeleteLoadgenConsumerCursorParams) error
- func (q *Queries) EnsureBackfillCursor(ctx context.Context, arg EnsureBackfillCursorParams) (BackfillCursor, error)
- func (q *Queries) EnsureConsumerCursor(ctx context.Context, arg EnsureConsumerCursorParams) error
- func (q *Queries) EnsureGapHealCursor(ctx context.Context, installationID int64) (GapHealCursor, error)
- func (q *Queries) EnsureInstallationBackfillCursor(ctx context.Context, installationID int64) (InstallationBackfillCursor, error)
- func (q *Queries) EnsureInstallationBudget(ctx context.Context, arg EnsureInstallationBudgetParams) error
- func (q *Queries) EnsureSweepCursor(ctx context.Context, arg EnsureSweepCursorParams) (SweepCursor, error)
- func (q *Queries) EscalateOpenDriftFinding(ctx context.Context, arg EscalateOpenDriftFindingParams) (DriftFinding, error)
- func (q *Queries) GetBackfillCursor(ctx context.Context, arg GetBackfillCursorParams) (BackfillCursor, error)
- func (q *Queries) GetBackfillCursorForUpdate(ctx context.Context, arg GetBackfillCursorForUpdateParams) (BackfillCursor, error)
- func (q *Queries) GetBranchReconciliationGenerationForShare(ctx context.Context, arg GetBranchReconciliationGenerationForShareParams) (int64, error)
- func (q *Queries) GetBranchReconciliationPage(ctx context.Context, arg GetBranchReconciliationPageParams) (string, error)
- func (q *Queries) GetCachedEntitySnapshot(ctx context.Context, arg GetCachedEntitySnapshotParams) (GetCachedEntitySnapshotRow, error)
- func (q *Queries) GetCheckRunsFetchMetadata(ctx context.Context, arg GetCheckRunsFetchMetadataParams) (GetCheckRunsFetchMetadataRow, error)
- func (q *Queries) GetConsumerCursorForUpdate(ctx context.Context, arg GetConsumerCursorForUpdateParams) (int64, error)
- func (q *Queries) GetDatabaseClock(ctx context.Context) (pgtype.Timestamptz, error)
- func (q *Queries) GetDriftFinding(ctx context.Context, id int64) (DriftFinding, error)
- func (q *Queries) GetDriftSampleCursor(ctx context.Context, arg GetDriftSampleCursorParams) (int64, error)
- func (q *Queries) GetEntityObservationVersion(ctx context.Context, entityKey string) (int64, error)
- func (q *Queries) GetEntityObservationVersionForUpdate(ctx context.Context, entityKey string) (int64, error)
- func (q *Queries) GetGapHealCursorForUpdate(ctx context.Context, installationID int64) (GapHealCursor, error)
- func (q *Queries) GetInstallationBackfillCursor(ctx context.Context, installationID int64) (InstallationBackfillCursor, error)
- func (q *Queries) GetInstallationBackfillCursorForUpdate(ctx context.Context, installationID int64) (InstallationBackfillCursor, error)
- func (q *Queries) GetLatestTerminalRefreshJobState(ctx context.Context, arg GetLatestTerminalRefreshJobStateParams) (string, error)
- func (q *Queries) GetLoadgenCacheSeedState(ctx context.Context, installationID int64) (GetLoadgenCacheSeedStateRow, error)
- func (q *Queries) GetOpenDriftFindingByHash(ctx context.Context, arg GetOpenDriftFindingByHashParams) (DriftFinding, error)
- func (q *Queries) GetPullRequestByIdentity(ctx context.Context, arg GetPullRequestByIdentityParams) (GetPullRequestByIdentityRow, error)
- func (q *Queries) GetPullRequestByKey(ctx context.Context, arg GetPullRequestByKeyParams) (GetPullRequestByKeyRow, error)
- func (q *Queries) GetPullRequestFetchMetadata(ctx context.Context, arg GetPullRequestFetchMetadataParams) (GetPullRequestFetchMetadataRow, error)
- func (q *Queries) GetRefreshIntentGenerationForShare(ctx context.Context, arg GetRefreshIntentGenerationForShareParams) (int64, error)
- func (q *Queries) GetRefreshIntentGenerationForUpdate(ctx context.Context, arg GetRefreshIntentGenerationForUpdateParams) (int64, error)
- func (q *Queries) GetRefreshIntentState(ctx context.Context, arg GetRefreshIntentStateParams) (GetRefreshIntentStateRow, error)
- func (q *Queries) GetRefreshIntentStateForShare(ctx context.Context, arg GetRefreshIntentStateForShareParams) (GetRefreshIntentStateForShareRow, error)
- func (q *Queries) GetRepoByFullName(ctx context.Context, fullName string) (Repo, error)
- func (q *Queries) GetRepoByGitHubID(ctx context.Context, ghID int64) (Repo, error)
- func (q *Queries) GetRepoRulesFetchMetadata(ctx context.Context, repoFullName string) (GetRepoRulesFetchMetadataRow, error)
- func (q *Queries) GetStackByIdentity(ctx context.Context, arg GetStackByIdentityParams) (GetStackByIdentityRow, error)
- func (q *Queries) GetStackByKey(ctx context.Context, arg GetStackByKeyParams) (GetStackByKeyRow, error)
- func (q *Queries) GetStackFetchMetadata(ctx context.Context, arg GetStackFetchMetadataParams) (GetStackFetchMetadataRow, error)
- func (q *Queries) GetStreamPrunedThroughSequence(ctx context.Context, stream string) (int64, error)
- func (q *Queries) GetStreamSafeSequence(ctx context.Context) (int64, error)
- func (q *Queries) GetSweepCursor(ctx context.Context, arg GetSweepCursorParams) (SweepCursor, error)
- func (q *Queries) GetSweepCursorForUpdate(ctx context.Context, arg GetSweepCursorForUpdateParams) (SweepCursor, error)
- func (q *Queries) GetSweepPage(ctx context.Context, arg GetSweepPageParams) (SweepPage, error)
- func (q *Queries) GetWebhookDelivery(ctx context.Context, deliveryGuid string) (WebhookDelivery, error)
- func (q *Queries) HasOutstandingRefresh(ctx context.Context, refreshKey string) (bool, error)
- func (q *Queries) HeartbeatBranchReconciliationPage(ctx context.Context, arg HeartbeatBranchReconciliationPageParams) (int64, error)
- func (q *Queries) InsertChangeEvent(ctx context.Context, arg InsertChangeEventParams) (int64, error)
- func (q *Queries) InsertDriftFinding(ctx context.Context, arg InsertDriftFindingParams) (DriftFinding, error)
- func (q *Queries) InsertSweepSeenKeys(ctx context.Context, arg InsertSweepSeenKeysParams) (int64, error)
- func (q *Queries) InsertWebhookDelivery(ctx context.Context, arg InsertWebhookDeliveryParams) (int64, error)
- func (q *Queries) IsInstallationBackfillDone(ctx context.Context, installationID int64) (bool, error)
- func (q *Queries) ListBranchReconciliationGenerationKeys(ctx context.Context, arg ListBranchReconciliationGenerationKeysParams) ([]ListBranchReconciliationGenerationKeysRow, error)
- func (q *Queries) ListCachedPRMemberships(ctx context.Context, arg ListCachedPRMembershipsParams) ([]ListCachedPRMembershipsRow, error)
- func (q *Queries) ListCodeOwnerIdentities(ctx context.Context, repoID int64) ([]ListCodeOwnerIdentitiesRow, error)
- func (q *Queries) ListExistingWebhookDeliveryGUIDs(ctx context.Context, deliveryGuids []string) ([]string, error)
- func (q *Queries) ListLiveOpenPullRequestNumbers(ctx context.Context, arg ListLiveOpenPullRequestNumbersParams) ([]int32, error)
- func (q *Queries) ListLiveRepositoryNames(ctx context.Context, installationID int64) ([]string, error)
- func (q *Queries) ListLiveStackNumbers(ctx context.Context, arg ListLiveStackNumbersParams) ([]int32, error)
- func (q *Queries) ListLoadgenCachedCheckRuns(ctx context.Context, repoFullName string) ([]ListLoadgenCachedCheckRunsRow, error)
- func (q *Queries) ListLoadgenCachedPullRequestChangeSnapshots(ctx context.Context, repoFullName string) ([]ListLoadgenCachedPullRequestChangeSnapshotsRow, error)
- func (q *Queries) ListLoadgenCachedPullRequestChangedFiles(ctx context.Context, repoFullName string) ([]ListLoadgenCachedPullRequestChangedFilesRow, error)
- func (q *Queries) ListLoadgenCachedPullRequestComments(ctx context.Context, repoFullName string) ([]ListLoadgenCachedPullRequestCommentsRow, error)
- func (q *Queries) ListLoadgenCachedPullRequestFileOwners(ctx context.Context, repoFullName string) ([]ListLoadgenCachedPullRequestFileOwnersRow, error)
- func (q *Queries) ListLoadgenCachedPullRequestReviewRequests(ctx context.Context, repoFullName string) ([]ListLoadgenCachedPullRequestReviewRequestsRow, error)
- func (q *Queries) ListLoadgenCachedPullRequestReviews(ctx context.Context, repoFullName string) ([]ListLoadgenCachedPullRequestReviewsRow, error)
- func (q *Queries) ListLoadgenCachedPullRequests(ctx context.Context, repoFullName string) ([]ListLoadgenCachedPullRequestsRow, error)
- func (q *Queries) ListLoadgenCachedReviewThreads(ctx context.Context, repoFullName string) ([]ListLoadgenCachedReviewThreadsRow, error)
- func (q *Queries) ListLoadgenCachedStacks(ctx context.Context, repoFullName string) ([]ListLoadgenCachedStacksRow, error)
- func (q *Queries) ListLoadgenDroppedDeliveries(ctx context.Context, deliveryGuids []string) ([]ListLoadgenDroppedDeliveriesRow, error)
- func (q *Queries) ListMissingSweepEntityKeys(ctx context.Context, arg ListMissingSweepEntityKeysParams) ([]string, error)
- func (q *Queries) ListOutstandingRefreshIntentGenerations(ctx context.Context, arg ListOutstandingRefreshIntentGenerationsParams) ([]ListOutstandingRefreshIntentGenerationsRow, error)
- func (q *Queries) ListPRScopesByHeadSHA(ctx context.Context, arg ListPRScopesByHeadSHAParams) ([]ListPRScopesByHeadSHARow, error)
- func (q *Queries) ListPRsAffectedByBranch(ctx context.Context, arg ListPRsAffectedByBranchParams) ([]ListPRsAffectedByBranchRow, error)
- func (q *Queries) ListParkedWebhookDeliveries(ctx context.Context, resultLimit int32) ([]WebhookDelivery, error)
- func (q *Queries) ListPullRequestChangeFetchMetadata(ctx context.Context, arg ListPullRequestChangeFetchMetadataParams) ([]ListPullRequestChangeFetchMetadataRow, error)
- func (q *Queries) ListRepositoryDerivationScopes(ctx context.Context, repoID int64) ([]string, error)
- func (q *Queries) ListSeenBackfillRefreshKeys(ctx context.Context, arg ListSeenBackfillRefreshKeysParams) ([]string, error)
- func (q *Queries) ListStacksAffectedByBranch(ctx context.Context, arg ListStacksAffectedByBranchParams) ([]int32, error)
- func (q *Queries) ListStaleClosedPullRequests(ctx context.Context, arg ListStaleClosedPullRequestsParams) ([]ListStaleClosedPullRequestsRow, error)
- func (q *Queries) ListStaleClosedStacks(ctx context.Context, arg ListStaleClosedStacksParams) ([]ListStaleClosedStacksRow, error)
- func (q *Queries) ListStaleOpenPullRequests(ctx context.Context, arg ListStaleOpenPullRequestsParams) ([]ListStaleOpenPullRequestsRow, error)
- func (q *Queries) ListStaleOpenStacks(ctx context.Context, arg ListStaleOpenStacksParams) ([]ListStaleOpenStacksRow, error)
- func (q *Queries) ListStaleRepoRules(ctx context.Context, arg ListStaleRepoRulesParams) ([]ListStaleRepoRulesRow, error)
- func (q *Queries) ListSweepRepositories(ctx context.Context, installationID int64) ([]ListSweepRepositoriesRow, error)
- func (q *Queries) LoadDerivationSnapshot(ctx context.Context, scopes []byte) ([]LoadDerivationSnapshotRow, error)
- func (q *Queries) MarkCompletedBackfillChildren(ctx context.Context, arg MarkCompletedBackfillChildrenParams) (int64, error)
- func (q *Queries) MarkDerivationDirty(ctx context.Context, arg MarkDerivationDirtyParams) error
- func (q *Queries) PageChangeEvents(ctx context.Context, arg PageChangeEventsParams) ([]PageChangeEventsRow, error)
- func (q *Queries) PruneChangeEvents(ctx context.Context, arg PruneChangeEventsParams) (int64, error)
- func (q *Queries) PruneResolvedDriftFindingBatch(ctx context.Context, arg PruneResolvedDriftFindingBatchParams) (int64, error)
- func (q *Queries) PruneWebhookDeliveryPayloadBatch(ctx context.Context, arg PruneWebhookDeliveryPayloadBatchParams) (int64, error)
- func (q *Queries) PublishStreamWatermark(ctx context.Context, arg PublishStreamWatermarkParams) (int64, error)
- func (q *Queries) ReadStreamWatermarkTarget(ctx context.Context, leaseToken string) (ReadStreamWatermarkTargetRow, error)
- func (q *Queries) ReapOrphanedRepositorySweepCursors(ctx context.Context, installationID int64) (int64, error)
- func (q *Queries) RecordBranchReconciliationPages(ctx context.Context, arg RecordBranchReconciliationPagesParams) error
- func (q *Queries) RecordConsumerResync(ctx context.Context, arg RecordConsumerResyncParams) error
- func (q *Queries) RecordOperationHeartbeat(ctx context.Context, arg RecordOperationHeartbeatParams) error
- func (q *Queries) ReleaseInstallationBudgetLease(ctx context.Context, arg ReleaseInstallationBudgetLeaseParams) (int64, error)
- func (q *Queries) ReleaseStreamWatermarkLease(ctx context.Context, leaseToken string) error
- func (q *Queries) RenewGapHealLease(ctx context.Context, arg RenewGapHealLeaseParams) (int64, error)
- func (q *Queries) RenewInstallationBudgetLease(ctx context.Context, arg RenewInstallationBudgetLeaseParams) ([]pgtype.Timestamptz, error)
- func (q *Queries) ReplaceCheckRuns(ctx context.Context, arg ReplaceCheckRunsParams) ([]int64, error)
- func (q *Queries) ReplacePullRequestChangedFiles(ctx context.Context, arg ReplacePullRequestChangedFilesParams) ([]string, error)
- func (q *Queries) ReplacePullRequestComments(ctx context.Context, arg ReplacePullRequestCommentsParams) ([]string, error)
- func (q *Queries) ReplacePullRequestFileOwners(ctx context.Context, arg ReplacePullRequestFileOwnersParams) ([]string, error)
- func (q *Queries) ReplacePullRequestReviewRequests(ctx context.Context, arg ReplacePullRequestReviewRequestsParams) ([]interface{}, error)
- func (q *Queries) ReplacePullRequestReviews(ctx context.Context, arg ReplacePullRequestReviewsParams) ([]string, error)
- func (q *Queries) ReplaceRepoRules(ctx context.Context, arg ReplaceRepoRulesParams) ([]string, error)
- func (q *Queries) ReplaceReviewThreads(ctx context.Context, arg ReplaceReviewThreadsParams) ([]string, error)
- func (q *Queries) RequeueParkedWebhookDeliveries(ctx context.Context, arg RequeueParkedWebhookDeliveriesParams) (int64, error)
- func (q *Queries) ResolveOpenDriftFindings(ctx context.Context, arg ResolveOpenDriftFindingsParams) (int64, error)
- func (q *Queries) RestartGapHealCursor(ctx context.Context, arg RestartGapHealCursorParams) (GapHealCursor, error)
- func (q *Queries) RestartSweepCursorPass(ctx context.Context, arg RestartSweepCursorPassParams) (SweepCursor, error)
- func (q *Queries) SampleCachedEntitiesAfter(ctx context.Context, arg SampleCachedEntitiesAfterParams) ([]SampleCachedEntitiesAfterRow, error)
- func (q *Queries) SampleCachedEntitiesThrough(ctx context.Context, arg SampleCachedEntitiesThroughParams) ([]SampleCachedEntitiesThroughRow, error)
- func (q *Queries) SaveInstallationBudgetBackoff(ctx context.Context, arg SaveInstallationBudgetBackoffParams) (int64, error)
- func (q *Queries) SaveInstallationBudgetSnapshot(ctx context.Context, arg SaveInstallationBudgetSnapshotParams) (int64, error)
- func (q *Queries) SetBudgetLeaseTransactionTimeouts(ctx context.Context, timeout string) error
- func (q *Queries) SetDriftFindingHealGeneration(ctx context.Context, arg SetDriftFindingHealGenerationParams) (DriftFinding, error)
- func (q *Queries) SetLocalLockTimeout(ctx context.Context, lockTimeout string) error
- func (q *Queries) SetWebhookDeliveryResults(ctx context.Context, results []byte) (int64, error)
- func (q *Queries) ShowSynchronousCommit(ctx context.Context) (string, error)
- func (q *Queries) StartBranchReconciliationPage(ctx context.Context, arg StartBranchReconciliationPageParams) (int64, error)
- func (q *Queries) StartGapHealCursor(ctx context.Context, arg StartGapHealCursorParams) (GapHealCursor, error)
- func (q *Queries) StartSweepCursor(ctx context.Context, arg StartSweepCursorParams) (SweepCursor, error)
- func (q *Queries) TombstonePullRequest(ctx context.Context, arg TombstonePullRequestParams) (PullRequest, error)
- func (q *Queries) TombstonePullRequestChangeSnapshot(ctx context.Context, arg TombstonePullRequestChangeSnapshotParams) (int64, error)
- func (q *Queries) TombstonePullRequestChangedFiles(ctx context.Context, arg TombstonePullRequestChangedFilesParams) (int64, error)
- func (q *Queries) TombstonePullRequestComments(ctx context.Context, arg TombstonePullRequestCommentsParams) ([]string, error)
- func (q *Queries) TombstonePullRequestFileOwners(ctx context.Context, arg TombstonePullRequestFileOwnersParams) (int64, error)
- func (q *Queries) TombstonePullRequestReviewRequests(ctx context.Context, arg TombstonePullRequestReviewRequestsParams) ([]interface{}, error)
- func (q *Queries) TombstonePullRequestReviews(ctx context.Context, arg TombstonePullRequestReviewsParams) ([]string, error)
- func (q *Queries) TombstoneRepository(ctx context.Context, arg TombstoneRepositoryParams) (Repo, error)
- func (q *Queries) TombstoneStack(ctx context.Context, arg TombstoneStackParams) (Stack, error)
- func (q *Queries) TouchCheckRunsCheckedAt(ctx context.Context, arg TouchCheckRunsCheckedAtParams) error
- func (q *Queries) TouchOpenDriftFinding(ctx context.Context, arg TouchOpenDriftFindingParams) (DriftFinding, error)
- func (q *Queries) TouchPullRequestChangeInputsCheckedAt(ctx context.Context, arg TouchPullRequestChangeInputsCheckedAtParams) error
- func (q *Queries) TouchPullRequestChangedFilesCheckedAt(ctx context.Context, arg TouchPullRequestChangedFilesCheckedAtParams) error
- func (q *Queries) TouchPullRequestCheckedAt(ctx context.Context, arg TouchPullRequestCheckedAtParams) error
- func (q *Queries) TouchPullRequestCommentsCheckedAt(ctx context.Context, arg TouchPullRequestCommentsCheckedAtParams) error
- func (q *Queries) TouchPullRequestFileOwnersCheckedAt(ctx context.Context, arg TouchPullRequestFileOwnersCheckedAtParams) error
- func (q *Queries) TouchPullRequestReviewRequestsCheckedAt(ctx context.Context, arg TouchPullRequestReviewRequestsCheckedAtParams) error
- func (q *Queries) TouchPullRequestReviewsCheckedAt(ctx context.Context, arg TouchPullRequestReviewsCheckedAtParams) error
- func (q *Queries) TouchRepoRulesCheckedAt(ctx context.Context, arg TouchRepoRulesCheckedAtParams) error
- func (q *Queries) TouchRepositoryCheckedAt(ctx context.Context, arg TouchRepositoryCheckedAtParams) error
- func (q *Queries) TouchReviewThreadsCheckedAt(ctx context.Context, arg TouchReviewThreadsCheckedAtParams) error
- func (q *Queries) TouchStackCheckedAt(ctx context.Context, arg TouchStackCheckedAtParams) error
- func (q *Queries) TryAcquireRefreshIntentGenerationLocks(ctx context.Context, keys []byte) (TryAcquireRefreshIntentGenerationLocksRow, error)
- func (q *Queries) TryAcquireRefreshIntentGenerationRowLocks(ctx context.Context, keys []byte) (TryAcquireRefreshIntentGenerationRowLocksRow, error)
- func (q *Queries) UpdateConsumerCursor(ctx context.Context, arg UpdateConsumerCursorParams) error
- func (q *Queries) UpsertBackfillChildren(ctx context.Context, arg UpsertBackfillChildrenParams) error
- func (q *Queries) UpsertDriftSampleCursor(ctx context.Context, arg UpsertDriftSampleCursorParams) error
- func (q *Queries) UpsertPullRequestChangeSnapshot(ctx context.Context, arg UpsertPullRequestChangeSnapshotParams) (int64, error)
- func (q *Queries) UpsertPullRequestWriteIfNewer(ctx context.Context, arg UpsertPullRequestWriteIfNewerParams) (PullRequest, error)
- func (q *Queries) UpsertRepoRuleSyncState(ctx context.Context, arg UpsertRepoRuleSyncStateParams) error
- func (q *Queries) UpsertRepositoryAlias(ctx context.Context, arg UpsertRepositoryAliasParams) error
- func (q *Queries) UpsertRepositoryWriteIfNewer(ctx context.Context, arg UpsertRepositoryWriteIfNewerParams) (Repo, error)
- func (q *Queries) UpsertStackWriteIfNewer(ctx context.Context, arg UpsertStackWriteIfNewerParams) (Stack, error)
- func (q *Queries) UpsertSweepPage(ctx context.Context, arg UpsertSweepPageParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type ReadStreamWatermarkTargetRow
- type RecordBranchReconciliationPagesParams
- type RecordConsumerResyncParams
- type RecordOperationHeartbeatParams
- type RefreshIntentGeneration
- type ReleaseInstallationBudgetLeaseParams
- type RenewGapHealLeaseParams
- type RenewInstallationBudgetLeaseParams
- type ReplaceCheckRunsParams
- type ReplacePullRequestChangedFilesParams
- type ReplacePullRequestCommentsParams
- type ReplacePullRequestFileOwnersParams
- type ReplacePullRequestReviewRequestsParams
- type ReplacePullRequestReviewsParams
- type ReplaceRepoRulesParams
- type ReplaceReviewThreadsParams
- type Repo
- type RepoAlias
- type RepoRule
- type RepoRuleSyncState
- type RequeueParkedWebhookDeliveriesParams
- type ResolveOpenDriftFindingsParams
- type RestartGapHealCursorParams
- type RestartSweepCursorPassParams
- type ReviewThread
- type RiverJob
- type RiverJobState
- type SampleCachedEntitiesAfterParams
- type SampleCachedEntitiesAfterRow
- type SampleCachedEntitiesThroughParams
- type SampleCachedEntitiesThroughRow
- type SaveInstallationBudgetBackoffParams
- type SaveInstallationBudgetSnapshotParams
- type SetDriftFindingHealGenerationParams
- type Stack
- type StartBranchReconciliationPageParams
- type StartGapHealCursorParams
- type StartSweepCursorParams
- type StreamHorizon
- type StreamWatermark
- type SweepCursor
- type SweepPage
- type SweepSeenKey
- type TombstonePullRequestChangeSnapshotParams
- type TombstonePullRequestChangedFilesParams
- type TombstonePullRequestCommentsParams
- type TombstonePullRequestFileOwnersParams
- type TombstonePullRequestParams
- type TombstonePullRequestReviewRequestsParams
- type TombstonePullRequestReviewsParams
- type TombstoneRepositoryParams
- type TombstoneStackParams
- type TouchCheckRunsCheckedAtParams
- type TouchOpenDriftFindingParams
- type TouchPullRequestChangeInputsCheckedAtParams
- type TouchPullRequestChangedFilesCheckedAtParams
- type TouchPullRequestCheckedAtParams
- type TouchPullRequestCommentsCheckedAtParams
- type TouchPullRequestFileOwnersCheckedAtParams
- type TouchPullRequestReviewRequestsCheckedAtParams
- type TouchPullRequestReviewsCheckedAtParams
- type TouchRepoRulesCheckedAtParams
- type TouchRepositoryCheckedAtParams
- type TouchReviewThreadsCheckedAtParams
- type TouchStackCheckedAtParams
- type TryAcquireRefreshIntentGenerationLocksRow
- type TryAcquireRefreshIntentGenerationRowLocksRow
- type UpdateConsumerCursorParams
- type UpsertBackfillChildrenParams
- type UpsertDriftSampleCursorParams
- type UpsertPullRequestChangeSnapshotParams
- type UpsertPullRequestWriteIfNewerParams
- type UpsertRepoRuleSyncStateParams
- type UpsertRepositoryAliasParams
- type UpsertRepositoryWriteIfNewerParams
- type UpsertStackWriteIfNewerParams
- type UpsertSweepPageParams
- type WebhookDelivery
- type WorkItem
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AcquireInstallationBudgetLeaseRow ¶
type AcquireInstallationBudgetLeaseRow struct {
Class string
Remaining pgtype.Int8
RateLimit pgtype.Int8
ResetAt pgtype.Timestamptz
BackoffUntil pgtype.Timestamptz
LeaseUntil pgtype.Timestamptz
}
type AcquireRefreshIntentGenerationLockParams ¶ added in v0.4.1
type AdvanceBranchReconciliationTargetGenerationsParams ¶ added in v0.5.0
type AdvanceBranchReconciliationTargetGenerationsParams struct {
RepoFullName string
Branch string
AppliedAt pgtype.Timestamptz
}
type AdvanceBranchReconciliationTargetGenerationsRow ¶ added in v0.5.0
type AdvanceGapHealCursorParams ¶
type AdvanceGapHealCursorParams struct {
NextCursor string
ObservedHighWatermarkAt pgtype.Timestamptz
ObservedBoundaryDeliveryID int64
UpdatedAt pgtype.Timestamptz
LeaseUntil pgtype.Timestamptz
InstallationID int64
ExpectedCursor string
LeaseToken pgtype.Text
}
type ApplyBranchHintTransitionParams ¶ added in v0.5.0
type ApplyBranchHintTransitionRow ¶ added in v0.5.0
type BackfillChild ¶
type BackfillChild struct {
InstallationID int64
RepoFullName string
Kind string
RefreshKey string
TargetGeneration int64
CreatedAt pgtype.Timestamptz
CompletedAt pgtype.Timestamptz
}
type BackfillCursor ¶
type BackfillCursor struct {
InstallationID int64
RepoFullName string
Phase string
Page int32
CompletedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
QueueName string
}
type BeginBranchReconciliationParams ¶ added in v0.5.0
type BeginBranchReconciliationRow ¶ added in v0.5.0
type BranchReconciliation ¶ added in v0.5.0
type BranchReconciliation struct {
RepoID int64
Branch string
Generation int64
BeforeSha string
AfterSha string
TransitionKnown bool
Deleted bool
Forced bool
DeliveryGuid string
ReceivedAt pgtype.Timestamptz
AppliedAt pgtype.Timestamptz
TargetCount int32
PageCount int32
CompletedAt pgtype.Timestamptz
}
type BranchReconciliationPage ¶ added in v0.5.0
type BranchReconciliationPage struct {
RepoID int64
Branch string
Generation int64
PageNumber int32
TargetCount int32
Status string
SupersededTargets int32
AttemptCount int64
CreatedAt pgtype.Timestamptz
LastStartedAt pgtype.Timestamptz
HeartbeatAt pgtype.Timestamptz
CompletedAt pgtype.Timestamptz
}
type BumpRefreshIntentGenerationsRow ¶
type BumpRefreshIntentGenerationsRow struct {
Kind string
RefreshKey string
Generation int64
DeadlineAt pgtype.Timestamptz
EventReceivedAt pgtype.Timestamptz
}
type ChangeEvent ¶
type CheckHistory ¶
type CheckRun ¶
type CheckRun struct {
GhID int64
RepoID int64
NodeID string
Name string
Status string
Conclusion string
DetailsUrl string
AppSlug string
StartedAt pgtype.Timestamptz
CompletedAt pgtype.Timestamptz
GhUpdatedAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
SemanticVersion string
LastCheckedAt pgtype.Timestamptz
}
type ClaimGapHealCursorParams ¶ added in v0.3.3
type ClaimGapHealCursorParams struct {
LeaseToken pgtype.Text
LeaseUntil pgtype.Timestamptz
ClaimedAt pgtype.Timestamptz
InstallationID int64
}
type CollectBranchReconciliationBacklogRow ¶ added in v0.5.0
type CollectBudgetMetricsRow ¶
type CollectDriftMetricsRow ¶
type CollectSweepMetricsRow ¶
type CompleteBranchReconciliationPageParams ¶ added in v0.5.0
type CompleteGapHealCursorParams ¶
type CompleteGapHealCursorParams struct {
ObservedHighWatermarkAt pgtype.Timestamptz
ObservedBoundaryDeliveryID int64
CompletedAt pgtype.Timestamptz
InstallationID int64
ExpectedCursor string
LeaseToken pgtype.Text
}
type ConfirmPullRequestMetadataCheckedAtParams ¶ added in v0.4.0
type ConfirmPullRequestMetadataCheckedAtParams struct {
CheckedAt pgtype.Timestamptz
RepoID int64
PrNumber int32
Etag string
}
type ConsumerCursor ¶
type ConsumerCursor struct {
Consumer string
Stream string
Seq int64
UpdatedAt pgtype.Timestamptz
ResyncCount int64
LastResyncAt pgtype.Timestamptz
}
type DeleteCheckHistoryBatchParams ¶
type DeleteCheckHistoryBatchParams struct {
Cutoff pgtype.Timestamptz
BatchSize int32
}
type DerivationDirty ¶
type DerivationDirty struct {
ScopeKey string
MarkedAt pgtype.Timestamptz
}
type DriftEntitiesWithoutBranchFence ¶ added in v0.5.0
type DriftEntitiesWithoutChangeInput ¶ added in v0.3.0
type DriftEntitiesWithoutParticipation ¶ added in v0.3.0
type DriftEntity ¶
type DriftEntityKey ¶
type DriftFinding ¶
type DriftFinding struct {
ID int64
InstallationID int64
EntityKind string
EntityKey string
DetectedAt pgtype.Timestamptz
CacheSnapshot []byte
UpstreamSnapshot []byte
Diff []byte
RefreshEnqueuedAt pgtype.Timestamptz
DiffHash string
FirstSeenAt pgtype.Timestamptz
LastSeenAt pgtype.Timestamptz
OccurrenceCount int64
HealGeneration int64
EscalatedAt pgtype.Timestamptz
ResolvedAt pgtype.Timestamptz
}
type DriftSampleCursor ¶
type DriftSampleCursor struct {
InstallationID int64
EntityKind string
SourceID int64
UpdatedAt pgtype.Timestamptz
}
type EnsureSweepCursorParams ¶
type EntityObservationVersion ¶ added in v0.5.1
type EscalateOpenDriftFindingParams ¶
type EscalateOpenDriftFindingParams struct {
LastSeenAt pgtype.Timestamptz
CacheSnapshot []byte
UpstreamSnapshot []byte
Diff []byte
EscalatedAt pgtype.Timestamptz
ID int64
}
type GapHealCursor ¶
type GapHealCursor struct {
InstallationID int64
Cursor string
Cutoff pgtype.Timestamptz
StartedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
CompletedAt pgtype.Timestamptz
LeaseToken pgtype.Text
LeaseUntil pgtype.Timestamptz
HighWatermarkAt pgtype.Timestamptz
PassHighWatermarkAt pgtype.Timestamptz
BoundaryDeliveryID int64
PassBoundaryDeliveryID int64
LastDeepStartedAt pgtype.Timestamptz
LastDeepCompletedAt pgtype.Timestamptz
ScanMode string
CursorVersion int32
LookbackDurationNs int64
PageSize int32
}
type GetBackfillCursorParams ¶
type GetBranchReconciliationGenerationForShareParams ¶ added in v0.5.0
type GetBranchReconciliationGenerationForShareParams struct {
}
type GetBranchReconciliationPageParams ¶ added in v0.5.0
type GetLatestTerminalRefreshJobStateParams ¶ added in v0.5.2
type GetPullRequestByIdentityRow ¶
type GetPullRequestByIdentityRow struct {
ID int64
RepoID int64
GhID pgtype.Int8
NodeID string
Number int32
Title string
State string
Draft bool
AuthorLogin string
HeadRef string
HeadSha string
BaseRef string
BaseSha string
ReviewDecision string
MergeableState string
StackNumber pgtype.Int4
StackPosition pgtype.Int4
GhUpdatedAt pgtype.Timestamptz
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
DisplayUntil pgtype.Timestamptz
RepoFullName string
}
type GetPullRequestByKeyRow ¶
type GetPullRequestByKeyRow struct {
ID int64
RepoID int64
GhID pgtype.Int8
NodeID string
Number int32
Title string
State string
Draft bool
AuthorLogin string
HeadRef string
HeadSha string
BaseRef string
BaseSha string
ReviewDecision string
MergeableState string
StackNumber pgtype.Int4
StackPosition pgtype.Int4
GhUpdatedAt pgtype.Timestamptz
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
DisplayUntil pgtype.Timestamptz
RepoFullName string
}
type GetPullRequestFetchMetadataRow ¶
type GetPullRequestFetchMetadataRow struct {
NodeID string
Etag string
Title string
State string
Draft bool
AuthorLogin string
HeadRef string
BaseRef string
ReviewDecision string
MergeableState string
StackNumber pgtype.Int4
StackPosition pgtype.Int4
GhUpdatedAt pgtype.Timestamptz
BaseSha string
HeadSha string
RepoGhID int64
InstallationID int64
RepoFullName string
CodeownersRef string
CodeownersSha string
CodeownersPath string
CodeownersState string
CodeownersSource string
CodeownersHash string
CodeownersEtag string
ForceCodeownersRefresh bool
}
type GetRefreshIntentGenerationForShareParams ¶ added in v0.5.0
type GetRefreshIntentGenerationForShareParams struct {
}
type GetRefreshIntentStateForShareParams ¶ added in v0.5.0
type GetRefreshIntentStateForShareParams struct {
}
type GetRefreshIntentStateForShareRow ¶ added in v0.5.0
type GetRefreshIntentStateForShareRow struct {
}
type GetRefreshIntentStateRow ¶
type GetRefreshIntentStateRow struct {
Generation int64
CompletedGeneration int64
DeadlineAt pgtype.Timestamptz
EventReceivedAt pgtype.Timestamptz
}
type GetStackByIdentityRow ¶
type GetStackByIdentityRow struct {
ID int64
RepoID int64
GhID pgtype.Int8
NodeID string
Number int32
BaseRef string
BaseSha string
Open bool
Entries []byte
GhUpdatedAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
DisplayUntil pgtype.Timestamptz
RepoFullName string
}
type GetStackByKeyParams ¶
type GetStackByKeyRow ¶
type GetStackByKeyRow struct {
ID int64
RepoID int64
GhID pgtype.Int8
NodeID string
Number int32
BaseRef string
BaseSha string
Open bool
Entries []byte
GhUpdatedAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
DisplayUntil pgtype.Timestamptz
RepoFullName string
}
type GetSweepCursorParams ¶
type GetSweepPageParams ¶
type HeartbeatBranchReconciliationPageParams ¶ added in v0.5.0
type InsertChangeEventParams ¶
type InstallationBackfillCursor ¶
type InstallationBackfillCursor struct {
InstallationID int64
Phase string
Page int32
QueueName string
CompletedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
}
type InstallationBudget ¶
type InstallationBudget struct {
InstallationID int64
Class string
Remaining pgtype.Int8
RateLimit pgtype.Int8
ResetAt pgtype.Timestamptz
LeaseOwner pgtype.Text
LeaseUntil pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
BackoffUntil pgtype.Timestamptz
}
type ListBranchReconciliationGenerationKeysParams ¶ added in v0.5.0
type ListBranchReconciliationGenerationKeysRow ¶ added in v0.5.0
type ListCodeOwnerIdentitiesRow ¶ added in v0.3.0
type ListLoadgenCachedCheckRunsRow ¶
type ListLoadgenCachedCheckRunsRow struct {
GhID int64
NodeID string
HeadSha string
Name string
Status string
Conclusion string
DetailsUrl string
AppSlug string
StartedAt pgtype.Timestamptz
CompletedAt pgtype.Timestamptz
GhUpdatedAt pgtype.Timestamptz
SemanticVersion string
}
type ListLoadgenCachedPullRequestChangeSnapshotsRow ¶ added in v0.3.0
type ListLoadgenCachedPullRequestChangedFilesRow ¶ added in v0.3.0
type ListLoadgenCachedPullRequestCommentsRow ¶ added in v0.3.0
type ListLoadgenCachedPullRequestFileOwnersRow ¶ added in v0.3.0
type ListLoadgenCachedPullRequestReviewRequestsRow ¶ added in v0.3.0
type ListLoadgenCachedPullRequestReviewsRow ¶ added in v0.3.0
type ListLoadgenCachedPullRequestsRow ¶
type ListLoadgenCachedPullRequestsRow struct {
GhID pgtype.Int8
NodeID string
Number int32
Title string
State string
Draft bool
AuthorLogin string
ReviewDecision string
MergeableState string
HeadRef string
HeadSha string
BaseRef string
BaseSha string
StackNumber pgtype.Int4
StackPosition pgtype.Int4
GhUpdatedAt pgtype.Timestamptz
}
type ListLoadgenDroppedDeliveriesRow ¶
type ListLoadgenDroppedDeliveriesRow struct {
DeliveryGuid string
ReceivedAt pgtype.Timestamptz
Status string
}
type ListOutstandingRefreshIntentGenerationsParams ¶ added in v0.5.2
type ListOutstandingRefreshIntentGenerationsParams struct {
StaleBefore pgtype.Timestamptz
BatchLimit int32
}
type ListOutstandingRefreshIntentGenerationsRow ¶ added in v0.5.2
type ListPullRequestChangeFetchMetadataParams ¶ added in v0.4.0
type ListPullRequestChangeFetchMetadataRow ¶ added in v0.4.0
type ListStaleClosedPullRequestsParams ¶
type ListStaleClosedPullRequestsParams struct {
InstallationID int64
StaleBefore pgtype.Timestamptz
}
type ListStaleClosedPullRequestsRow ¶
type ListStaleClosedPullRequestsRow struct {
RepoFullName string
Number int32
LastCheckedAt pgtype.Timestamptz
}
type ListStaleClosedStacksParams ¶
type ListStaleClosedStacksParams struct {
InstallationID int64
StaleBefore pgtype.Timestamptz
}
type ListStaleClosedStacksRow ¶
type ListStaleClosedStacksRow struct {
RepoFullName string
Number int32
LastCheckedAt pgtype.Timestamptz
}
type ListStaleOpenPullRequestsParams ¶
type ListStaleOpenPullRequestsParams struct {
InstallationID int64
StaleBefore pgtype.Timestamptz
}
type ListStaleOpenPullRequestsRow ¶
type ListStaleOpenPullRequestsRow struct {
RepoFullName string
Number int32
LastCheckedAt pgtype.Timestamptz
}
type ListStaleOpenStacksParams ¶
type ListStaleOpenStacksParams struct {
InstallationID int64
StaleBefore pgtype.Timestamptz
}
type ListStaleOpenStacksRow ¶
type ListStaleOpenStacksRow struct {
RepoFullName string
Number int32
LastCheckedAt pgtype.Timestamptz
}
type ListStaleRepoRulesParams ¶
type ListStaleRepoRulesParams struct {
InstallationID int64
StaleBefore pgtype.Timestamptz
}
type ListStaleRepoRulesRow ¶
type ListStaleRepoRulesRow struct {
FullName string
LastCheckedAt pgtype.Timestamptz
}
type MarkDerivationDirtyParams ¶
type MarkDerivationDirtyParams struct {
MarkedAt pgtype.Timestamptz
ScopeKeys []string
}
type NullRiverJobState ¶
type NullRiverJobState struct {
RiverJobState RiverJobState
Valid bool // Valid is true if RiverJobState is not NULL
}
func (*NullRiverJobState) Scan ¶
func (ns *NullRiverJobState) Scan(value interface{}) error
Scan implements the Scanner interface.
type OperationHeartbeat ¶
type OperationHeartbeat struct {
InstallationID int64
Component string
Operation string
SuccessCount int64
LastSuccessAt pgtype.Timestamptz
SampleCount int64
LastSampleAt pgtype.Timestamptz
}
type PageChangeEventsParams ¶
type PageChangeEventsRow ¶
type PruneChangeEventsParams ¶
type PruneChangeEventsParams struct {
Cutoff pgtype.Timestamptz
BatchSize int32
}
type PruneResolvedDriftFindingBatchParams ¶
type PruneResolvedDriftFindingBatchParams struct {
Cutoff pgtype.Timestamptz
BatchSize int32
}
type PruneWebhookDeliveryPayloadBatchParams ¶
type PruneWebhookDeliveryPayloadBatchParams struct {
PrunedAt pgtype.Timestamptz
Cutoff pgtype.Timestamptz
BatchSize int32
}
type PullRequest ¶
type PullRequest struct {
ID int64
RepoID int64
GhID pgtype.Int8
NodeID string
Number int32
Title string
State string
Draft bool
AuthorLogin string
HeadRef string
HeadSha string
BaseRef string
BaseSha string
ReviewDecision string
MergeableState string
StackNumber pgtype.Int4
StackPosition pgtype.Int4
GhUpdatedAt pgtype.Timestamptz
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
DisplayUntil pgtype.Timestamptz
}
type PullRequestChangeSnapshot ¶ added in v0.3.0
type PullRequestChangeSnapshot struct {
RepoID int64
PrNumber int32
BaseSha string
HeadSha string
FilesTotalCount int32
FilesTruncated bool
CodeownersRef string
CodeownersSha string
CodeownersPath pgtype.Text
CodeownersState string
CodeownersSource pgtype.Text
CodeownersHash string
ParentGhUpdatedAt pgtype.Timestamptz
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
FilesEtag string
}
type PullRequestChangedFile ¶ added in v0.3.0
type PullRequestComment ¶ added in v0.3.0
type PullRequestComment struct {
NodeID string
GhID pgtype.Int8
RepoID int64
PrNumber int32
AuthorKind string
AuthorNodeID pgtype.Text
AuthorLogin pgtype.Text
CreatedAt pgtype.Timestamptz
GhUpdatedAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
}
type PullRequestFileOwner ¶ added in v0.3.0
type PullRequestFileOwner struct {
RepoID int64
PrNumber int32
Path string
OwnerToken string
OwnerType string
OwnerName string
ResolutionState string
OwnerGhID pgtype.Int8
OwnerNodeID pgtype.Text
OwnerLogin pgtype.Text
SourcePattern string
SourceLine int32
BaseSha string
HeadSha string
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
}
type PullRequestReview ¶ added in v0.3.0
type PullRequestReview struct {
NodeID string
GhID pgtype.Int8
RepoID int64
PrNumber int32
AuthorKind string
AuthorNodeID pgtype.Text
AuthorLogin pgtype.Text
State string
SubmittedAt pgtype.Timestamptz
CommitOid pgtype.Text
GhUpdatedAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
}
type PullRequestReviewRequest ¶ added in v0.3.0
type PullRequestReviewRequest struct {
RepoID int64
PrNumber int32
ReviewerKind string
ReviewerGhID int64
ReviewerNodeID string
ReviewerLogin string
RequestedAt pgtype.Timestamptz
FirstSeenAt pgtype.Timestamptz
GhUpdatedAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AcquireEntityAdvisoryLock ¶
C-C1 transaction-scoped serialization for every entity writer.
func (*Queries) AcquireInstallationBudgetLease ¶
func (q *Queries) AcquireInstallationBudgetLease(ctx context.Context, arg AcquireInstallationBudgetLeaseParams) ([]AcquireInstallationBudgetLeaseRow, error)
func (*Queries) AcquireOrRenewStreamWatermarkLease ¶
func (*Queries) AcquireOutboxWatermarkFence ¶
func (*Queries) AcquireOutboxWriterFence ¶
func (*Queries) AcquireRefreshIntentGenerationLock ¶ added in v0.4.1
func (q *Queries) AcquireRefreshIntentGenerationLock(ctx context.Context, arg AcquireRefreshIntentGenerationLockParams) error
Completion has only one generation key, so it may wait without convoying unrelated keys. It takes this lock before the corresponding row lock.
func (*Queries) AdvanceBackfillCursor ¶
func (q *Queries) AdvanceBackfillCursor(ctx context.Context, arg AdvanceBackfillCursorParams) (BackfillCursor, error)
func (*Queries) AdvanceBranchReconciliationTargetGenerations ¶ added in v0.5.0
func (q *Queries) AdvanceBranchReconciliationTargetGenerations(ctx context.Context, arg AdvanceBranchReconciliationTargetGenerationsParams) ([]AdvanceBranchReconciliationTargetGenerationsRow, error)
func (*Queries) AdvanceEntityObservationVersion ¶ added in v0.5.1
func (*Queries) AdvanceGapHealCursor ¶
func (*Queries) AdvanceInstallationBackfillCursor ¶
func (q *Queries) AdvanceInstallationBackfillCursor(ctx context.Context, arg AdvanceInstallationBackfillCursorParams) (InstallationBackfillCursor, error)
func (*Queries) AdvanceSweepCursor ¶
func (q *Queries) AdvanceSweepCursor(ctx context.Context, arg AdvanceSweepCursorParams) (SweepCursor, error)
func (*Queries) AppendAcceptedCheckHistory ¶
func (q *Queries) AppendAcceptedCheckHistory(ctx context.Context, arg AppendAcceptedCheckHistoryParams) error
func (*Queries) ApplyBranchHintTransition ¶ added in v0.5.0
func (q *Queries) ApplyBranchHintTransition(ctx context.Context, arg ApplyBranchHintTransitionParams) ([]ApplyBranchHintTransitionRow, error)
Dependent base/head rows remain retained history. Every reader fences them against the live PR, while reconciliation can still reuse base-only CODEOWNERS source data when a head push did not invalidate it.
func (*Queries) ApplyDerivedWorkItemBatch ¶
func (*Queries) BeginBranchReconciliation ¶ added in v0.5.0
func (q *Queries) BeginBranchReconciliation(ctx context.Context, arg BeginBranchReconciliationParams) (BeginBranchReconciliationRow, error)
func (*Queries) BumpRefreshIntentGenerations ¶
func (q *Queries) BumpRefreshIntentGenerations(ctx context.Context, intents []byte) ([]BumpRefreshIntentGenerationsRow, error)
Bump each coalesced key once in the same transaction that inserts its River job. Production callers first acquire the transaction advisory lock for every key; this ordered upsert remains a second deadlock-avoidance layer. Workers snapshot it when they begin authoritative refresh work.
func (*Queries) ClaimDerivationDirtyScopes ¶
func (*Queries) ClaimGapHealCursor ¶ added in v0.3.3
func (q *Queries) ClaimGapHealCursor(ctx context.Context, arg ClaimGapHealCursorParams) (GapHealCursor, error)
func (*Queries) ClaimWebhookDeliveries ¶
func (q *Queries) ClaimWebhookDeliveries(ctx context.Context, batchSize int32) ([]WebhookDelivery, error)
C-P2/C-O2: claim a bounded batch without blocking another dispatcher. The processing transition and attempt increment remain in the caller's batch transaction, so a crashed dispatcher rolls the claim back to pending.
func (*Queries) ClearDerivationDirtyScopes ¶
func (*Queries) CollectBranchReconciliationBacklog ¶ added in v0.5.0
func (q *Queries) CollectBranchReconciliationBacklog(ctx context.Context) (CollectBranchReconciliationBacklogRow, error)
func (*Queries) CollectBudgetMetrics ¶
func (*Queries) CollectCacheStalenessMetrics ¶
func (*Queries) CollectConsumerStreamMetrics ¶
func (q *Queries) CollectConsumerStreamMetrics(ctx context.Context) ([]CollectConsumerStreamMetricsRow, error)
func (*Queries) CollectDeliveryMetrics ¶
func (q *Queries) CollectDeliveryMetrics(ctx context.Context) (CollectDeliveryMetricsRow, error)
Every aggregate here is per-status so that it rides webhook_deliveries_unfinished_received_idx (status, received_at) WHERE status IN ('pending','processing','parked'). Aggregate FILTER clauses block both the min/max index optimisation and the partial index's predicate proof, so the older single-pass form seq-scanned the whole delivery table on every metrics scrape. LEAST() ignores NULLs, so LEAST(min pending, min processing) is exactly the old min(received_at) FILTER (WHERE status IN ('pending','processing')).
func (*Queries) CollectDriftMetrics ¶
func (*Queries) CollectOperationHeartbeatMetrics ¶
func (*Queries) CollectPrunableOutboxMetrics ¶
func (*Queries) CollectRiverQueueDepthMetrics ¶
func (q *Queries) CollectRiverQueueDepthMetrics(ctx context.Context) ([]CollectRiverQueueDepthMetricsRow, error)
func (*Queries) CollectStreamWatermarkMetrics ¶
func (q *Queries) CollectStreamWatermarkMetrics(ctx context.Context) (CollectStreamWatermarkMetricsRow, error)
func (*Queries) CollectSweepMetrics ¶
func (*Queries) CollectTombstoneMetrics ¶
func (q *Queries) CollectTombstoneMetrics(ctx context.Context) ([]CollectTombstoneMetricsRow, error)
func (*Queries) CompleteBranchReconciliationPage ¶ added in v0.5.0
func (*Queries) CompleteGapHealCursor ¶
func (*Queries) CompleteRefreshIntentGeneration ¶
func (q *Queries) CompleteRefreshIntentGeneration(ctx context.Context, arg CompleteRefreshIntentGenerationParams) error
func (*Queries) CompleteSweepCursor ¶
func (q *Queries) CompleteSweepCursor(ctx context.Context, arg CompleteSweepCursorParams) (SweepCursor, error)
func (*Queries) ConfirmPullRequestMetadataCheckedAt ¶ added in v0.4.0
func (*Queries) CountDerivationDirty ¶
func (*Queries) CountDriftFindings ¶
func (*Queries) CountLoadgenRunDeliveries ¶
func (*Queries) CountPendingBackfillChildren ¶
func (*Queries) CountPendingInstallationRepos ¶
func (*Queries) CountWebhookDeliveriesByStatus ¶
func (*Queries) DeleteCheckHistoryBatch ¶
func (*Queries) DeleteLoadgenConsumerCursor ¶
func (q *Queries) DeleteLoadgenConsumerCursor(ctx context.Context, arg DeleteLoadgenConsumerCursorParams) error
func (*Queries) EnsureBackfillCursor ¶
func (q *Queries) EnsureBackfillCursor(ctx context.Context, arg EnsureBackfillCursorParams) (BackfillCursor, error)
func (*Queries) EnsureConsumerCursor ¶
func (q *Queries) EnsureConsumerCursor(ctx context.Context, arg EnsureConsumerCursorParams) error
func (*Queries) EnsureGapHealCursor ¶
func (*Queries) EnsureInstallationBackfillCursor ¶
func (*Queries) EnsureInstallationBudget ¶
func (q *Queries) EnsureInstallationBudget(ctx context.Context, arg EnsureInstallationBudgetParams) error
func (*Queries) EnsureSweepCursor ¶
func (q *Queries) EnsureSweepCursor(ctx context.Context, arg EnsureSweepCursorParams) (SweepCursor, error)
func (*Queries) EscalateOpenDriftFinding ¶
func (q *Queries) EscalateOpenDriftFinding(ctx context.Context, arg EscalateOpenDriftFindingParams) (DriftFinding, error)
func (*Queries) GetBackfillCursor ¶
func (q *Queries) GetBackfillCursor(ctx context.Context, arg GetBackfillCursorParams) (BackfillCursor, error)
func (*Queries) GetBackfillCursorForUpdate ¶
func (q *Queries) GetBackfillCursorForUpdate(ctx context.Context, arg GetBackfillCursorForUpdateParams) (BackfillCursor, error)
func (*Queries) GetBranchReconciliationGenerationForShare ¶ added in v0.5.0
func (*Queries) GetBranchReconciliationPage ¶ added in v0.5.0
func (*Queries) GetCachedEntitySnapshot ¶
func (q *Queries) GetCachedEntitySnapshot(ctx context.Context, arg GetCachedEntitySnapshotParams) (GetCachedEntitySnapshotRow, error)
func (*Queries) GetCheckRunsFetchMetadata ¶
func (q *Queries) GetCheckRunsFetchMetadata(ctx context.Context, arg GetCheckRunsFetchMetadataParams) (GetCheckRunsFetchMetadataRow, error)
C-B4: the first-page validator is shared by every check row in one repository/head-SHA listing. Prefer the newest observation when rows span multiple refreshes, including a fully tombstoned listing.
func (*Queries) GetConsumerCursorForUpdate ¶
func (*Queries) GetDatabaseClock ¶
func (*Queries) GetDriftFinding ¶
func (*Queries) GetDriftSampleCursor ¶
func (*Queries) GetEntityObservationVersion ¶ added in v0.5.1
func (*Queries) GetEntityObservationVersionForUpdate ¶ added in v0.5.1
func (*Queries) GetGapHealCursorForUpdate ¶
func (*Queries) GetInstallationBackfillCursor ¶
func (*Queries) GetInstallationBackfillCursorForUpdate ¶
func (*Queries) GetLatestTerminalRefreshJobState ¶ added in v0.5.2
func (q *Queries) GetLatestTerminalRefreshJobState(ctx context.Context, arg GetLatestTerminalRefreshJobStateParams) (string, error)
Observability for a replaced orphan pointer: the most recent terminal job for the refresh identity explains how the previous pointer died. River may have pruned it already, so callers treat no-rows as unknown.
func (*Queries) GetLoadgenCacheSeedState ¶
func (*Queries) GetOpenDriftFindingByHash ¶
func (q *Queries) GetOpenDriftFindingByHash(ctx context.Context, arg GetOpenDriftFindingByHashParams) (DriftFinding, error)
func (*Queries) GetPullRequestByIdentity ¶
func (q *Queries) GetPullRequestByIdentity(ctx context.Context, arg GetPullRequestByIdentityParams) (GetPullRequestByIdentityRow, error)
func (*Queries) GetPullRequestByKey ¶
func (q *Queries) GetPullRequestByKey(ctx context.Context, arg GetPullRequestByKeyParams) (GetPullRequestByKeyRow, error)
func (*Queries) GetPullRequestFetchMetadata ¶
func (q *Queries) GetPullRequestFetchMetadata(ctx context.Context, arg GetPullRequestFetchMetadataParams) (GetPullRequestFetchMetadataRow, error)
func (*Queries) GetRefreshIntentGenerationForShare ¶ added in v0.5.0
func (q *Queries) GetRefreshIntentGenerationForShare(ctx context.Context, arg GetRefreshIntentGenerationForShareParams) (int64, error)
Post-fetch writers hold a shared row lock through their short entity transaction. Producers either finish their generation bump first or wait until this write commits; no advisory lock is retained across hooks.
func (*Queries) GetRefreshIntentGenerationForUpdate ¶
func (q *Queries) GetRefreshIntentGenerationForUpdate(ctx context.Context, arg GetRefreshIntentGenerationForUpdateParams) (int64, error)
Workers lock the generation before transactionally completing their River job. A concurrent dispatcher therefore bumps either before the recheck or after completion, when it can insert a fresh job.
func (*Queries) GetRefreshIntentState ¶
func (q *Queries) GetRefreshIntentState(ctx context.Context, arg GetRefreshIntentStateParams) (GetRefreshIntentStateRow, error)
func (*Queries) GetRefreshIntentStateForShare ¶ added in v0.5.0
func (q *Queries) GetRefreshIntentStateForShare(ctx context.Context, arg GetRefreshIntentStateForShareParams) (GetRefreshIntentStateForShareRow, error)
func (*Queries) GetRepoByFullName ¶
func (*Queries) GetRepoByGitHubID ¶
func (*Queries) GetRepoRulesFetchMetadata ¶
func (*Queries) GetStackByIdentity ¶
func (q *Queries) GetStackByIdentity(ctx context.Context, arg GetStackByIdentityParams) (GetStackByIdentityRow, error)
func (*Queries) GetStackByKey ¶
func (q *Queries) GetStackByKey(ctx context.Context, arg GetStackByKeyParams) (GetStackByKeyRow, error)
func (*Queries) GetStackFetchMetadata ¶
func (q *Queries) GetStackFetchMetadata(ctx context.Context, arg GetStackFetchMetadataParams) (GetStackFetchMetadataRow, error)
func (*Queries) GetStreamPrunedThroughSequence ¶
func (*Queries) GetStreamSafeSequence ¶
func (*Queries) GetSweepCursor ¶
func (q *Queries) GetSweepCursor(ctx context.Context, arg GetSweepCursorParams) (SweepCursor, error)
func (*Queries) GetSweepCursorForUpdate ¶
func (q *Queries) GetSweepCursorForUpdate(ctx context.Context, arg GetSweepCursorForUpdateParams) (SweepCursor, error)
func (*Queries) GetSweepPage ¶
func (*Queries) GetWebhookDelivery ¶
func (*Queries) HasOutstandingRefresh ¶
func (*Queries) HeartbeatBranchReconciliationPage ¶ added in v0.5.0
func (*Queries) InsertChangeEvent ¶
func (*Queries) InsertDriftFinding ¶
func (q *Queries) InsertDriftFinding(ctx context.Context, arg InsertDriftFindingParams) (DriftFinding, error)
func (*Queries) InsertSweepSeenKeys ¶
func (*Queries) InsertWebhookDelivery ¶
func (q *Queries) InsertWebhookDelivery(ctx context.Context, arg InsertWebhookDeliveryParams) (int64, error)
C-I3: duplicate deliveries are free no-ops.
func (*Queries) IsInstallationBackfillDone ¶
func (q *Queries) IsInstallationBackfillDone(ctx context.Context, installationID int64) (bool, error)
Done means SETTLED: the installation cursor alone flips 'done' while per-repo child seeding is still in flight, and drift sampling in that window compares half-seeded entities against upstream truth.
func (*Queries) ListBranchReconciliationGenerationKeys ¶ added in v0.5.0
func (q *Queries) ListBranchReconciliationGenerationKeys(ctx context.Context, arg ListBranchReconciliationGenerationKeysParams) ([]ListBranchReconciliationGenerationKeysRow, error)
func (*Queries) ListCachedPRMemberships ¶
func (q *Queries) ListCachedPRMemberships(ctx context.Context, arg ListCachedPRMembershipsParams) ([]ListCachedPRMembershipsRow, error)
func (*Queries) ListCodeOwnerIdentities ¶ added in v0.3.0
func (*Queries) ListExistingWebhookDeliveryGUIDs ¶
func (*Queries) ListLiveOpenPullRequestNumbers ¶
func (*Queries) ListLiveRepositoryNames ¶
func (*Queries) ListLiveStackNumbers ¶
func (*Queries) ListLoadgenCachedCheckRuns ¶
func (*Queries) ListLoadgenCachedPullRequestChangeSnapshots ¶ added in v0.3.0
func (*Queries) ListLoadgenCachedPullRequestChangedFiles ¶ added in v0.3.0
func (*Queries) ListLoadgenCachedPullRequestComments ¶ added in v0.3.0
func (*Queries) ListLoadgenCachedPullRequestFileOwners ¶ added in v0.3.0
func (*Queries) ListLoadgenCachedPullRequestReviewRequests ¶ added in v0.3.0
func (*Queries) ListLoadgenCachedPullRequestReviews ¶ added in v0.3.0
func (*Queries) ListLoadgenCachedPullRequests ¶
func (*Queries) ListLoadgenCachedReviewThreads ¶
func (*Queries) ListLoadgenCachedStacks ¶
func (*Queries) ListLoadgenDroppedDeliveries ¶
func (*Queries) ListMissingSweepEntityKeys ¶
func (q *Queries) ListMissingSweepEntityKeys(ctx context.Context, arg ListMissingSweepEntityKeysParams) ([]string, error)
C-R3/Q13: disappearance candidates are cached live entities absent from the row-oriented membership set accumulated by the completed listing.
func (*Queries) ListOutstandingRefreshIntentGenerations ¶ added in v0.5.2
func (q *Queries) ListOutstandingRefreshIntentGenerations(ctx context.Context, arg ListOutstandingRefreshIntentGenerationsParams) ([]ListOutstandingRefreshIntentGenerationsRow, error)
Reconciliation input for orphaned pointer jobs (issue #61). An outstanding generation whose unique River pointer reached a terminal state has no live work left to complete it. Producers and completion both bump updated_at, so a freshly signalled row is never scanned; a merely delayed row is harmless because the reconciler's unique re-insert deduplicates against its live pointer. Branch bulk targets self-claim their generations (completed_generation = generation) and therefore never appear here.
func (*Queries) ListPRScopesByHeadSHA ¶
func (q *Queries) ListPRScopesByHeadSHA(ctx context.Context, arg ListPRScopesByHeadSHAParams) ([]ListPRScopesByHeadSHARow, error)
func (*Queries) ListPRsAffectedByBranch ¶
func (q *Queries) ListPRsAffectedByBranch(ctx context.Context, arg ListPRsAffectedByBranchParams) ([]ListPRsAffectedByBranchRow, error)
func (*Queries) ListParkedWebhookDeliveries ¶
func (q *Queries) ListParkedWebhookDeliveries(ctx context.Context, resultLimit int32) ([]WebhookDelivery, error)
C-I5: dead-letter deliveries are explicitly queryable for operations and replay tooling.
func (*Queries) ListPullRequestChangeFetchMetadata ¶ added in v0.4.0
func (q *Queries) ListPullRequestChangeFetchMetadata(ctx context.Context, arg ListPullRequestChangeFetchMetadataParams) ([]ListPullRequestChangeFetchMetadataRow, error)
The snapshot and changed-file rows carry the first-page validator for the REST files collection. Previous paths are retained so a 304 can reuse the last authoritative rename supplement without another response body. The caller supplies the just-fetched GraphQL base/head fence: matching only the pre-fetch database row is insufficient when GitHub advanced during the observation.
func (*Queries) ListRepositoryDerivationScopes ¶
func (*Queries) ListSeenBackfillRefreshKeys ¶
func (*Queries) ListStacksAffectedByBranch ¶
func (*Queries) ListStaleClosedPullRequests ¶
func (q *Queries) ListStaleClosedPullRequests(ctx context.Context, arg ListStaleClosedPullRequestsParams) ([]ListStaleClosedPullRequestsRow, error)
func (*Queries) ListStaleClosedStacks ¶
func (q *Queries) ListStaleClosedStacks(ctx context.Context, arg ListStaleClosedStacksParams) ([]ListStaleClosedStacksRow, error)
func (*Queries) ListStaleOpenPullRequests ¶
func (q *Queries) ListStaleOpenPullRequests(ctx context.Context, arg ListStaleOpenPullRequestsParams) ([]ListStaleOpenPullRequestsRow, error)
func (*Queries) ListStaleOpenStacks ¶
func (q *Queries) ListStaleOpenStacks(ctx context.Context, arg ListStaleOpenStacksParams) ([]ListStaleOpenStacksRow, error)
func (*Queries) ListStaleRepoRules ¶
func (q *Queries) ListStaleRepoRules(ctx context.Context, arg ListStaleRepoRulesParams) ([]ListStaleRepoRulesRow, error)
func (*Queries) ListSweepRepositories ¶
func (*Queries) LoadDerivationSnapshot ¶
func (*Queries) MarkCompletedBackfillChildren ¶
func (*Queries) MarkDerivationDirty ¶
func (q *Queries) MarkDerivationDirty(ctx context.Context, arg MarkDerivationDirtyParams) error
func (*Queries) PageChangeEvents ¶
func (q *Queries) PageChangeEvents(ctx context.Context, arg PageChangeEventsParams) ([]PageChangeEventsRow, error)
func (*Queries) PruneChangeEvents ¶
func (*Queries) PruneResolvedDriftFindingBatch ¶
func (*Queries) PruneWebhookDeliveryPayloadBatch ¶
func (*Queries) PublishStreamWatermark ¶
func (*Queries) ReadStreamWatermarkTarget ¶
func (*Queries) ReapOrphanedRepositorySweepCursors ¶
func (q *Queries) ReapOrphanedRepositorySweepCursors(ctx context.Context, installationID int64) (int64, error)
Q16: repository-scoped cursors use mutable names to call GitHub. Remove scopes whose current live repository identity no longer owns that name; child pages and seen keys follow via ON DELETE CASCADE.
func (*Queries) RecordBranchReconciliationPages ¶ added in v0.5.0
func (q *Queries) RecordBranchReconciliationPages(ctx context.Context, arg RecordBranchReconciliationPagesParams) error
func (*Queries) RecordConsumerResync ¶
func (q *Queries) RecordConsumerResync(ctx context.Context, arg RecordConsumerResyncParams) error
func (*Queries) RecordOperationHeartbeat ¶
func (q *Queries) RecordOperationHeartbeat(ctx context.Context, arg RecordOperationHeartbeatParams) error
func (*Queries) ReleaseInstallationBudgetLease ¶
func (*Queries) ReleaseStreamWatermarkLease ¶
func (*Queries) RenewGapHealLease ¶ added in v0.3.3
func (*Queries) RenewInstallationBudgetLease ¶
func (q *Queries) RenewInstallationBudgetLease(ctx context.Context, arg RenewInstallationBudgetLeaseParams) ([]pgtype.Timestamptz, error)
func (*Queries) ReplaceCheckRuns ¶
func (*Queries) ReplacePullRequestChangedFiles ¶ added in v0.3.0
func (*Queries) ReplacePullRequestComments ¶ added in v0.3.0
func (*Queries) ReplacePullRequestFileOwners ¶ added in v0.3.0
func (*Queries) ReplacePullRequestReviewRequests ¶ added in v0.3.0
func (q *Queries) ReplacePullRequestReviewRequests(ctx context.Context, arg ReplacePullRequestReviewRequestsParams) ([]interface{}, error)
The parent pull request's updated_at is the C-C2 observation version for this timestamp-less GitHub connection. Equal-version replacements remain eligible so a pure request-set change is not swallowed.
func (*Queries) ReplacePullRequestReviews ¶ added in v0.3.0
func (*Queries) ReplaceRepoRules ¶
func (*Queries) ReplaceReviewThreads ¶
func (*Queries) RequeueParkedWebhookDeliveries ¶
func (q *Queries) RequeueParkedWebhookDeliveries(ctx context.Context, arg RequeueParkedWebhookDeliveriesParams) (int64, error)
C-I5: replay is deliberately bounded to an explicit GUID set or one event/error signature. Payload-pruned deliveries remain parked and receive an explicit refusal reason; an explicit-GUID CLI replay consequently fails its selected-vs-requeued count check instead of dispatching a nil body.
func (*Queries) ResolveOpenDriftFindings ¶
func (*Queries) RestartGapHealCursor ¶ added in v0.4.0
func (q *Queries) RestartGapHealCursor(ctx context.Context, arg RestartGapHealCursorParams) (GapHealCursor, error)
func (*Queries) RestartSweepCursorPass ¶
func (q *Queries) RestartSweepCursorPass(ctx context.Context, arg RestartSweepCursorPassParams) (SweepCursor, error)
func (*Queries) SampleCachedEntitiesAfter ¶
func (q *Queries) SampleCachedEntitiesAfter(ctx context.Context, arg SampleCachedEntitiesAfterParams) ([]SampleCachedEntitiesAfterRow, error)
Q11: the forward half of the rotating sample is a plain indexed source_id range. Detect issues a second bounded range only when this reaches the end.
The keyset is resolved against drift_entity_keys, which projects the same (installation_id, entity_kind, source_id) triples as drift_entities with no snapshot payload. Ordering drift_entities directly forced PostgreSQL to plan every UNION ALL arm for full retrieval -- an ORDER BY at this level stops the LIMIT's tuple fraction from reaching the arms -- so the 'checks' arm built a jsonb snapshot for every cached check group on every sample. The ARRAY() sub-select becomes an InitPlan, whose Param IS pushed into the arms as an indexable source_id qual, so only the sampled rows are built. source_id is unique per (installation_id, entity_kind), so the rows and their order are identical to the single-statement form.
func (*Queries) SampleCachedEntitiesThrough ¶
func (q *Queries) SampleCachedEntitiesThrough(ctx context.Context, arg SampleCachedEntitiesThroughParams) ([]SampleCachedEntitiesThroughRow, error)
The wrap half cannot overlap the forward half and retains source_id order. Same two-phase keyset shape as SampleCachedEntitiesAfter.
func (*Queries) SaveInstallationBudgetBackoff ¶
func (*Queries) SaveInstallationBudgetSnapshot ¶
func (*Queries) SetBudgetLeaseTransactionTimeouts ¶
func (*Queries) SetDriftFindingHealGeneration ¶
func (q *Queries) SetDriftFindingHealGeneration(ctx context.Context, arg SetDriftFindingHealGenerationParams) (DriftFinding, error)
func (*Queries) SetLocalLockTimeout ¶
func (*Queries) SetWebhookDeliveryResults ¶
C-P2: finish the entire claimed batch with one set-based status update.
func (*Queries) ShowSynchronousCommit ¶
func (*Queries) StartBranchReconciliationPage ¶ added in v0.5.0
func (*Queries) StartGapHealCursor ¶
func (q *Queries) StartGapHealCursor(ctx context.Context, arg StartGapHealCursorParams) (GapHealCursor, error)
func (*Queries) StartSweepCursor ¶
func (q *Queries) StartSweepCursor(ctx context.Context, arg StartSweepCursorParams) (SweepCursor, error)
func (*Queries) TombstonePullRequest ¶
func (q *Queries) TombstonePullRequest(ctx context.Context, arg TombstonePullRequestParams) (PullRequest, error)
func (*Queries) TombstonePullRequestChangeSnapshot ¶ added in v0.3.0
func (*Queries) TombstonePullRequestChangedFiles ¶ added in v0.3.0
func (*Queries) TombstonePullRequestComments ¶ added in v0.3.0
func (*Queries) TombstonePullRequestFileOwners ¶ added in v0.3.0
func (*Queries) TombstonePullRequestReviewRequests ¶ added in v0.3.0
func (q *Queries) TombstonePullRequestReviewRequests(ctx context.Context, arg TombstonePullRequestReviewRequestsParams) ([]interface{}, error)
func (*Queries) TombstonePullRequestReviews ¶ added in v0.3.0
func (*Queries) TombstoneRepository ¶
func (q *Queries) TombstoneRepository(ctx context.Context, arg TombstoneRepositoryParams) (Repo, error)
C-R3 repository disappearance is authoritative only after the installation listing omits it and this entity fetch confirms 404.
func (*Queries) TombstoneStack ¶
func (*Queries) TouchCheckRunsCheckedAt ¶
func (q *Queries) TouchCheckRunsCheckedAt(ctx context.Context, arg TouchCheckRunsCheckedAtParams) error
func (*Queries) TouchOpenDriftFinding ¶
func (q *Queries) TouchOpenDriftFinding(ctx context.Context, arg TouchOpenDriftFindingParams) (DriftFinding, error)
func (*Queries) TouchPullRequestChangeInputsCheckedAt ¶ added in v0.3.0
func (q *Queries) TouchPullRequestChangeInputsCheckedAt(ctx context.Context, arg TouchPullRequestChangeInputsCheckedAtParams) error
func (*Queries) TouchPullRequestChangedFilesCheckedAt ¶ added in v0.3.0
func (q *Queries) TouchPullRequestChangedFilesCheckedAt(ctx context.Context, arg TouchPullRequestChangedFilesCheckedAtParams) error
func (*Queries) TouchPullRequestCheckedAt ¶
func (q *Queries) TouchPullRequestCheckedAt(ctx context.Context, arg TouchPullRequestCheckedAtParams) error
func (*Queries) TouchPullRequestCommentsCheckedAt ¶ added in v0.3.0
func (q *Queries) TouchPullRequestCommentsCheckedAt(ctx context.Context, arg TouchPullRequestCommentsCheckedAtParams) error
func (*Queries) TouchPullRequestFileOwnersCheckedAt ¶ added in v0.3.0
func (q *Queries) TouchPullRequestFileOwnersCheckedAt(ctx context.Context, arg TouchPullRequestFileOwnersCheckedAtParams) error
func (*Queries) TouchPullRequestReviewRequestsCheckedAt ¶ added in v0.3.0
func (q *Queries) TouchPullRequestReviewRequestsCheckedAt(ctx context.Context, arg TouchPullRequestReviewRequestsCheckedAtParams) error
func (*Queries) TouchPullRequestReviewsCheckedAt ¶ added in v0.3.0
func (q *Queries) TouchPullRequestReviewsCheckedAt(ctx context.Context, arg TouchPullRequestReviewsCheckedAtParams) error
func (*Queries) TouchRepoRulesCheckedAt ¶
func (q *Queries) TouchRepoRulesCheckedAt(ctx context.Context, arg TouchRepoRulesCheckedAtParams) error
func (*Queries) TouchRepositoryCheckedAt ¶
func (q *Queries) TouchRepositoryCheckedAt(ctx context.Context, arg TouchRepositoryCheckedAtParams) error
func (*Queries) TouchReviewThreadsCheckedAt ¶
func (q *Queries) TouchReviewThreadsCheckedAt(ctx context.Context, arg TouchReviewThreadsCheckedAtParams) error
func (*Queries) TouchStackCheckedAt ¶
func (q *Queries) TouchStackCheckedAt(ctx context.Context, arg TouchStackCheckedAtParams) error
func (*Queries) TryAcquireRefreshIntentGenerationLocks ¶ added in v0.4.1
func (q *Queries) TryAcquireRefreshIntentGenerationLocks(ctx context.Context, keys []byte) (TryAcquireRefreshIntentGenerationLocksRow, error)
Producers acquire these transaction locks one key at a time in sorted order. A failed try-lock is rolled back with its transaction or containing savepoint before it takes any refresh-generation row locks. Include the database in the hash because advisory locks are cluster-wide and tests use parallel per-test databases.
func (*Queries) TryAcquireRefreshIntentGenerationRowLocks ¶ added in v0.4.1
func (q *Queries) TryAcquireRefreshIntentGenerationRowLocks(ctx context.Context, keys []byte) (TryAcquireRefreshIntentGenerationRowLocksRow, error)
Advisory locks serialize participating producers, but an already-open transaction may hold only the generation row. Probe every existing row without waiting so a hot row cannot make this transaction retain unrelated generation locks.
func (*Queries) UpdateConsumerCursor ¶
func (q *Queries) UpdateConsumerCursor(ctx context.Context, arg UpdateConsumerCursorParams) error
func (*Queries) UpsertBackfillChildren ¶
func (q *Queries) UpsertBackfillChildren(ctx context.Context, arg UpsertBackfillChildrenParams) error
func (*Queries) UpsertDriftSampleCursor ¶
func (q *Queries) UpsertDriftSampleCursor(ctx context.Context, arg UpsertDriftSampleCursorParams) error
func (*Queries) UpsertPullRequestChangeSnapshot ¶ added in v0.3.0
func (q *Queries) UpsertPullRequestChangeSnapshot(ctx context.Context, arg UpsertPullRequestChangeSnapshotParams) (int64, error)
C-C2 parent freshness plus explicit base/head identity gates the current changed-file and ownership snapshot. Equal parent versions remain eligible so a base-branch CODEOWNERS push or a later complete listing can heal facts without relying on pull_request.updatedAt changing.
func (*Queries) UpsertPullRequestWriteIfNewer ¶
func (q *Queries) UpsertPullRequestWriteIfNewer(ctx context.Context, arg UpsertPullRequestWriteIfNewerParams) (PullRequest, error)
func (*Queries) UpsertRepoRuleSyncState ¶
func (q *Queries) UpsertRepoRuleSyncState(ctx context.Context, arg UpsertRepoRuleSyncStateParams) error
func (*Queries) UpsertRepositoryAlias ¶
func (q *Queries) UpsertRepositoryAlias(ctx context.Context, arg UpsertRepositoryAliasParams) error
func (*Queries) UpsertRepositoryWriteIfNewer ¶
func (*Queries) UpsertStackWriteIfNewer ¶
func (*Queries) UpsertSweepPage ¶
func (q *Queries) UpsertSweepPage(ctx context.Context, arg UpsertSweepPageParams) error
type RecordBranchReconciliationPagesParams ¶ added in v0.5.0
type RefreshIntentGeneration ¶
type RefreshIntentGeneration struct {
Kind string
RefreshKey string
Generation int64
UpdatedAt pgtype.Timestamptz
CompletedGeneration int64
DeadlineAt pgtype.Timestamptz
EventReceivedAt pgtype.Timestamptz
}
type RenewGapHealLeaseParams ¶ added in v0.3.3
type RenewGapHealLeaseParams struct {
LeaseUntil pgtype.Timestamptz
InstallationID int64
LeaseToken pgtype.Text
}
type ReplaceCheckRunsParams ¶
type ReplaceCheckRunsParams struct {
CheckRuns []byte
RepoID int64
HeadSha string
SyncedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
Etag string
SyncSource string
}
type ReplacePullRequestChangedFilesParams ¶ added in v0.3.0
type ReplacePullRequestChangedFilesParams struct {
ChangedFiles []byte
RepoID int64
PrNumber int32
BaseSha string
HeadSha string
ParentGhUpdatedAt pgtype.Timestamptz
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
LastCheckedAt pgtype.Timestamptz
}
type ReplacePullRequestCommentsParams ¶ added in v0.3.0
type ReplacePullRequestCommentsParams struct {
Comments []byte
RepoID int64
PrNumber int32
ParentGhUpdatedAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
LastCheckedAt pgtype.Timestamptz
}
type ReplacePullRequestFileOwnersParams ¶ added in v0.3.0
type ReplacePullRequestFileOwnersParams struct {
FileOwners []byte
RepoID int64
PrNumber int32
BaseSha string
HeadSha string
ParentGhUpdatedAt pgtype.Timestamptz
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
LastCheckedAt pgtype.Timestamptz
}
type ReplacePullRequestReviewRequestsParams ¶ added in v0.3.0
type ReplacePullRequestReviewRequestsParams struct {
ReviewRequests []byte
RepoID int64
PrNumber int32
GhUpdatedAt pgtype.Timestamptz
FirstSeenAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
Etag string
SyncSource string
}
type ReplacePullRequestReviewsParams ¶ added in v0.3.0
type ReplacePullRequestReviewsParams struct {
Reviews []byte
RepoID int64
PrNumber int32
ParentGhUpdatedAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
LastCheckedAt pgtype.Timestamptz
}
type ReplaceRepoRulesParams ¶
type ReplaceRepoRulesParams struct {
Rules []byte
RepoID int64
SyncedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
Etag string
SyncSource string
}
type ReplaceReviewThreadsParams ¶
type ReplaceReviewThreadsParams struct {
Threads []byte
RepoID int64
PrNumber int32
HeadSha string
SyncedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
Etag string
SyncSource string
}
type Repo ¶
type Repo struct {
ID int64
InstallationID int64
OrgID int64
GhID int64
NodeID string
Owner string
Name string
FullName string
DefaultBranch string
Archived bool
GhUpdatedAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
}
type RepoAlias ¶
type RepoAlias struct {
FullName string
RepoID int64
FirstSeenAt pgtype.Timestamptz
LastSeenAt pgtype.Timestamptz
}
type RepoRule ¶
type RepoRule struct {
RepoID int64
RuleKey string
Rule []byte
GhUpdatedAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
}
type RepoRuleSyncState ¶
type RepoRuleSyncState struct {
RepoID int64
Etag string
LastCheckedAt pgtype.Timestamptz
}
type ResolveOpenDriftFindingsParams ¶
type ResolveOpenDriftFindingsParams struct {
ResolvedAt pgtype.Timestamptz
InstallationID int64
EntityKind string
EntityKey string
}
type RestartGapHealCursorParams ¶ added in v0.4.0
type RestartGapHealCursorParams struct {
RestartedAt pgtype.Timestamptz
LeaseUntil pgtype.Timestamptz
InstallationID int64
ExpectedCursor string
LeaseToken pgtype.Text
}
type ReviewThread ¶
type ReviewThread struct {
ID string
RepoID int64
PrNumber int32
IsResolved bool
IsOutdated bool
Path string
Line pgtype.Int4
Comments []byte
GhUpdatedAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
}
type RiverJob ¶
type RiverJob struct {
ID int64
State RiverJobState
Attempt int16
MaxAttempts int16
AttemptedAt pgtype.Timestamptz
CreatedAt pgtype.Timestamptz
FinalizedAt pgtype.Timestamptz
ScheduledAt pgtype.Timestamptz
Priority int16
Args []byte
AttemptedBy []string
Errors [][]byte
Kind string
Metadata []byte
Queue string
Tags []string
UniqueKey []byte
UniqueStates pgtype.Bits
}
type RiverJobState ¶
type RiverJobState string
const ( RiverJobStateAvailable RiverJobState = "available" RiverJobStateCancelled RiverJobState = "cancelled" RiverJobStateCompleted RiverJobState = "completed" RiverJobStateDiscarded RiverJobState = "discarded" RiverJobStatePending RiverJobState = "pending" RiverJobStateRetryable RiverJobState = "retryable" RiverJobStateRunning RiverJobState = "running" RiverJobStateScheduled RiverJobState = "scheduled" )
func (*RiverJobState) Scan ¶
func (e *RiverJobState) Scan(src interface{}) error
type SaveInstallationBudgetBackoffParams ¶
type SaveInstallationBudgetBackoffParams struct {
BackoffUntil pgtype.Timestamptz
InstallationID int64
AuthContext string
LeaseToken string
}
type SaveInstallationBudgetSnapshotParams ¶
type SaveInstallationBudgetSnapshotParams struct {
RestRemaining pgtype.Int8
AppRestRemaining pgtype.Int8
GraphqlRemaining pgtype.Int8
RestLimit pgtype.Int8
AppRestLimit pgtype.Int8
GraphqlLimit pgtype.Int8
RestResetAt pgtype.Timestamptz
AppRestResetAt pgtype.Timestamptz
GraphqlResetAt pgtype.Timestamptz
AppJwtBackoffUntil pgtype.Timestamptz
BackoffUntil pgtype.Timestamptz
InstallationID int64
LeaseToken string
}
type Stack ¶
type Stack struct {
ID int64
RepoID int64
GhID pgtype.Int8
NodeID string
Number int32
BaseRef string
BaseSha string
Open bool
Entries []byte
GhUpdatedAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
Etag string
SyncSource string
TombstonedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
DisplayUntil pgtype.Timestamptz
}
type StartBranchReconciliationPageParams ¶ added in v0.5.0
type StartGapHealCursorParams ¶
type StartGapHealCursorParams struct {
Cutoff pgtype.Timestamptz
StartedAt pgtype.Timestamptz
HighWatermarkAt pgtype.Timestamptz
BoundaryDeliveryID int64
ScanMode string
CursorVersion int32
LookbackDurationNs int64
PageSize int32
LeaseToken pgtype.Text
LeaseUntil pgtype.Timestamptz
InstallationID int64
}
type StartSweepCursorParams ¶
type StreamHorizon ¶
type StreamHorizon struct {
Stream string
PrunedThroughSeq int64
UpdatedAt pgtype.Timestamptz
}
type StreamWatermark ¶
type SweepCursor ¶
type SweepCursor struct {
InstallationID int64
SweepKind string
ScopeKey string
Cursor string
StartedAt pgtype.Timestamptz
UpdatedAt pgtype.Timestamptz
CompletedAt pgtype.Timestamptz
PassNewCount int32
}
type SweepSeenKey ¶
type TombstonePullRequestChangeSnapshotParams ¶ added in v0.3.0
type TombstonePullRequestChangeSnapshotParams struct {
TombstonedAt pgtype.Timestamptz
SyncSource string
RepoID int64
PrNumber int32
}
type TombstonePullRequestChangedFilesParams ¶ added in v0.3.0
type TombstonePullRequestChangedFilesParams struct {
TombstonedAt pgtype.Timestamptz
SyncSource string
RepoID int64
PrNumber int32
}
type TombstonePullRequestCommentsParams ¶ added in v0.3.0
type TombstonePullRequestCommentsParams struct {
TombstonedAt pgtype.Timestamptz
SyncSource string
RepoID int64
PrNumber int32
}
type TombstonePullRequestFileOwnersParams ¶ added in v0.3.0
type TombstonePullRequestFileOwnersParams struct {
TombstonedAt pgtype.Timestamptz
SyncSource string
RepoID int64
PrNumber int32
}
type TombstonePullRequestParams ¶
type TombstonePullRequestParams struct {
TombstonedAt pgtype.Timestamptz
SyncedAt pgtype.Timestamptz
SyncSource string
RepoID int64
PrNumber int32
}
type TombstonePullRequestReviewRequestsParams ¶ added in v0.3.0
type TombstonePullRequestReviewRequestsParams struct {
TombstonedAt pgtype.Timestamptz
SyncSource string
RepoID int64
PrNumber int32
}
type TombstonePullRequestReviewsParams ¶ added in v0.3.0
type TombstonePullRequestReviewsParams struct {
TombstonedAt pgtype.Timestamptz
SyncSource string
RepoID int64
PrNumber int32
}
type TombstoneRepositoryParams ¶
type TombstoneRepositoryParams struct {
TombstonedAt pgtype.Timestamptz
SyncedAt pgtype.Timestamptz
SyncSource string
GhID int64
}
type TombstoneStackParams ¶
type TombstoneStackParams struct {
TombstonedAt pgtype.Timestamptz
SyncedAt pgtype.Timestamptz
SyncSource string
RepoID int64
StackNumber int32
}
type TouchCheckRunsCheckedAtParams ¶
type TouchCheckRunsCheckedAtParams struct {
CheckedAt pgtype.Timestamptz
Etag string
RepoID int64
HeadSha string
}
type TouchPullRequestChangeInputsCheckedAtParams ¶ added in v0.3.0
type TouchPullRequestChangeInputsCheckedAtParams struct {
CheckedAt pgtype.Timestamptz
CodeownersEtag string
FilesEtag string
RepoID int64
PrNumber int32
ParentGhUpdatedAt pgtype.Timestamptz
}
type TouchPullRequestChangedFilesCheckedAtParams ¶ added in v0.3.0
type TouchPullRequestChangedFilesCheckedAtParams struct {
CheckedAt pgtype.Timestamptz
Etag string
RepoID int64
PrNumber int32
ParentGhUpdatedAt pgtype.Timestamptz
}
type TouchPullRequestCheckedAtParams ¶
type TouchPullRequestCheckedAtParams struct {
CheckedAt pgtype.Timestamptz
Etag string
RepoID int64
PrNumber int32
}
type TouchPullRequestCommentsCheckedAtParams ¶ added in v0.3.0
type TouchPullRequestCommentsCheckedAtParams struct {
CheckedAt pgtype.Timestamptz
Etag string
RepoID int64
PrNumber int32
ParentGhUpdatedAt pgtype.Timestamptz
}
type TouchPullRequestFileOwnersCheckedAtParams ¶ added in v0.3.0
type TouchPullRequestFileOwnersCheckedAtParams struct {
CheckedAt pgtype.Timestamptz
Etag string
RepoID int64
PrNumber int32
ParentGhUpdatedAt pgtype.Timestamptz
}
type TouchPullRequestReviewRequestsCheckedAtParams ¶ added in v0.3.0
type TouchPullRequestReviewRequestsCheckedAtParams struct {
CheckedAt pgtype.Timestamptz
Etag string
RepoID int64
PrNumber int32
GhUpdatedAt pgtype.Timestamptz
}
type TouchPullRequestReviewsCheckedAtParams ¶ added in v0.3.0
type TouchPullRequestReviewsCheckedAtParams struct {
CheckedAt pgtype.Timestamptz
Etag string
RepoID int64
PrNumber int32
ParentGhUpdatedAt pgtype.Timestamptz
}
type TouchRepoRulesCheckedAtParams ¶
type TouchRepoRulesCheckedAtParams struct {
CheckedAt pgtype.Timestamptz
RepoID int64
}
type TouchRepositoryCheckedAtParams ¶
type TouchRepositoryCheckedAtParams struct {
CheckedAt pgtype.Timestamptz
Etag string
GhID int64
}
type TouchReviewThreadsCheckedAtParams ¶
type TouchReviewThreadsCheckedAtParams struct {
CheckedAt pgtype.Timestamptz
RepoID int64
PrNumber int32
}
type TouchStackCheckedAtParams ¶
type TouchStackCheckedAtParams struct {
CheckedAt pgtype.Timestamptz
Etag string
RepoID int64
StackNumber int32
}
type TryAcquireRefreshIntentGenerationLocksRow ¶ added in v0.4.1
type TryAcquireRefreshIntentGenerationRowLocksRow ¶ added in v0.4.1
type UpsertPullRequestChangeSnapshotParams ¶ added in v0.3.0
type UpsertPullRequestChangeSnapshotParams struct {
BaseSha string
HeadSha string
FilesTotalCount int32
FilesTruncated bool
CodeownersRef string
CodeownersSha string
CodeownersPath pgtype.Text
CodeownersState string
CodeownersSource pgtype.Text
CodeownersHash string
RepoID int64
PrNumber int32
ParentGhUpdatedAt pgtype.Timestamptz
SyncedAt pgtype.Timestamptz
CodeownersEtag string
FilesEtag string
SyncSource string
LastCheckedAt pgtype.Timestamptz
}
type UpsertPullRequestWriteIfNewerParams ¶
type UpsertPullRequestWriteIfNewerParams struct {
RepoID int64
GhID pgtype.Int8
NodeID string
PrNumber int32
Title string
State string
Draft bool
AuthorLogin string
HeadRef string
HeadSha string
BaseRef string
BaseSha string
ReviewDecision string
MergeableState string
MembershipKnown bool
StackNumber pgtype.Int4
StackPosition pgtype.Int4
GhUpdatedAt pgtype.Timestamptz
SyncedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
Etag string
SyncSource string
DisplayWindowSeconds int32
}
type UpsertRepoRuleSyncStateParams ¶
type UpsertRepoRuleSyncStateParams struct {
RepoID int64
Etag string
CheckedAt pgtype.Timestamptz
}
type UpsertRepositoryAliasParams ¶
type UpsertRepositoryAliasParams struct {
FullName string
RepoID int64
ObservedAt pgtype.Timestamptz
}
type UpsertRepositoryWriteIfNewerParams ¶
type UpsertRepositoryWriteIfNewerParams struct {
InstallationID int64
OrgID int64
GhID int64
NodeID string
Owner string
Name string
FullName string
DefaultBranch string
Archived bool
GhUpdatedAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
Etag string
SyncSource string
}
type UpsertStackWriteIfNewerParams ¶
type UpsertStackWriteIfNewerParams struct {
RepoID int64
GhID pgtype.Int8
NodeID string
StackNumber int32
BaseRef string
BaseSha string
Open bool
Entries []byte
GhUpdatedAt pgtype.Timestamptz
HeadSha string
SyncedAt pgtype.Timestamptz
LastCheckedAt pgtype.Timestamptz
Etag string
SyncSource string
DisplayWindowSeconds int32
}