store

package

Go to main page

Versions in this module

v0

v0.5.3

Aug 9, 2026

v0.5.2

Aug 7, 2026

v0.5.1

Aug 7, 2026

Changes in this version

+ var ErrObservationSuperseded = errors.New("observation superseded")

type EntityWriter

+ func (w *EntityWriter) WithObservationTransaction(ctx context.Context, observation *Observation, fn func(pgx.Tx) error) error

v0.5.0

Aug 6, 2026

Changes in this version

+ var ErrBranchReconciliationSuperseded = errors.New("branch reconciliation superseded")

+ var ErrBranchRefreshGenerationContention = errors.New("branch refresh generation contention")

+ var ErrRefreshGenerationSuperseded = errors.New("refresh generation superseded")

+ func WithBranchReconciliationFence(ctx context.Context, fence *BranchReconciliationFence) context.Context

+ func WithRefreshGenerationFence(ctx context.Context, fence RefreshGenerationFence) context.Context

+ type BranchBulkResult struct

+ Generation int64

+ PullRequests int

+ RepoID int64

+ Repositories int

+ RepositoryRefreshKey string

+ Stacks int

+ SupersededPages int64

+ Targets []BranchReconciliationTarget

+ type BranchPushHint struct

+ AfterSHA string

+ BeforeSHA string

+ Branch string

+ Deleted bool

+ DeliveryGUID string

+ Forced bool

+ ReceivedAt time.Time

+ RepoFullName string

+ TransitionKnown bool

+ type BranchReconciliationFence struct

+ Branch string

+ BranchGeneration int64

+ EntityKey string

+ RefreshGeneration int64

+ RefreshKey string

+ RefreshKind string

+ RepoID int64

+ type BranchReconciliationTarget struct

+ EntityKey string

+ RefreshGeneration int64

+ RefreshKey string

+ RefreshKind string

+ type BranchRefreshGenerationKey struct

+ Key string

+ Kind string

type EntityWriter

+ func (w *EntityWriter) ApplyBranchPushTx(ctx context.Context, tx pgx.Tx, hint *BranchPushHint) (BranchBulkResult, error)

+ func (w *EntityWriter) BranchReconciliationGenerationKeysTx(ctx context.Context, tx pgx.Tx, repoFullName string, branch string) ([]BranchRefreshGenerationKey, error)

+ func (w *EntityWriter) RecordBranchReconciliationPagesTx(ctx context.Context, tx pgx.Tx, repoID int64, branch string, generation int64, ...) error

+ func (w *EntityWriter) RefreshGeneration(ctx context.Context, kind string, refreshKey string) (int64, error)

+ type RefreshGenerationFence struct

+ Generation int64

+ Kind string

+ RefreshKey string

v0.4.2

Aug 5, 2026

v0.4.1

Aug 5, 2026

v0.4.0

Aug 4, 2026

Changes in this version

+ type CodeownersSourceRecord struct

+ Content string

+ ETag string

+ Hash string

+ Path string

+ Ref string

+ SHA string

+ State string

type EntityWriter

+ func (w *EntityWriter) PullRequestChangeMetadata(ctx context.Context, repo string, number int) (PullRequestChangeFetchMetadata, error)

type FetchMetadata

+ AuthorLogin string

+ BaseRef string

+ BaseSHA string

+ Codeowners *CodeownersSourceRecord

+ Draft bool

+ ForceCodeownersRefresh bool

+ GitHubUpdatedAt time.Time

+ HeadRef string

+ MergeableState string

+ ReviewDecision string

+ State string

+ Title string

+ type PullRequestChangeFetchMetadata struct

+ ETag string

+ PreviousPaths map[string]string

type PullRequestChangeSnapshotRecord

+ CodeownersETag string

+ ETag string

v0.3.3

Aug 4, 2026

v0.3.2

Aug 4, 2026

v0.3.1

Aug 3, 2026

v0.3.0

Aug 3, 2026

Changes in this version

type ApplyPullRequestResult

+ ChangeInputsChanged bool

+ CommentsChanged bool

+ ReviewRequestsChanged bool

+ ReviewsChanged bool

+ type ChangedFileRecord struct

+ ChangeType string

+ Path string

+ PreviousPath string

type EntityWriter

+ func (w *EntityWriter) ResolveFileOwnerIdentities(ctx context.Context, repoGitHubID int64, repositoryOwner string, ...) ([]FileOwnerRecord, error)

+ type FileOwnerRecord struct

+ OwnerGitHubID int64

+ OwnerLogin string

+ OwnerName string

+ OwnerNodeID string

+ OwnerToken string

+ OwnerType string

+ Path string

+ ResolutionState string

+ SourceLine int

+ SourcePattern string

+ type PullRequestChangeSnapshotRecord struct

+ BaseSHA string

+ CodeownersHash string

+ CodeownersPath string

+ CodeownersRef string

+ CodeownersSHA string

+ CodeownersSource string

+ CodeownersState string

+ Files []ChangedFileRecord

+ FilesTotalCount int

+ FilesTruncated bool

+ HeadSHA string

+ Owners []FileOwnerRecord

+ type PullRequestCommentRecord struct

+ AuthorKind string

+ AuthorLogin string

+ AuthorNodeID string

+ CreatedAt time.Time

+ GitHubID int64

+ GitHubUpdatedAt time.Time

+ NodeID string

type PullRequestRecord

+ ChangeInputsKnown bool

+ ChangeSnapshot *PullRequestChangeSnapshotRecord

+ Comments []PullRequestCommentRecord

+ CommentsKnown bool

+ ReviewRequests []ReviewRequestRecord

+ ReviewRequestsKnown bool

+ Reviews []PullRequestReviewRecord

+ ReviewsKnown bool

+ type PullRequestReviewRecord struct

+ AuthorKind string

+ AuthorLogin string

+ AuthorNodeID string

+ CommitOID string

+ GitHubID int64

+ GitHubUpdatedAt time.Time

+ NodeID string

+ State string

+ SubmittedAt *time.Time

+ type ReviewRequestKind string

+ const ReviewRequestTeam

+ const ReviewRequestUser

+ type ReviewRequestRecord struct

+ GitHubID int64

+ Kind ReviewRequestKind

+ Login string

+ NodeID string

+ RequestedAt *time.Time

v0.2.1

Aug 2, 2026

v0.2.0

Aug 1, 2026

Changes in this version

type ConnectOption

+ func WithRDSIAMAuthentication() ConnectOption

v0.1.0

Jul 31, 2026

Changes in this version

+ func ChecksEntityKey(installationID int64, repositoryGitHubID int64, sha string) string

+ func Connect(ctx context.Context, databaseURL string, options ...ConnectOption) (*pgxpool.Pool, error)

+ func Migrate(ctx context.Context, pool *pgxpool.Pool) error

+ func PullRequestEntityKey(installationID int64, repositoryGitHubID int64, number int) string

+ func RepoRulesEntityKey(installationID int64, repositoryGitHubID int64) string

+ func RepositoryDiscoveryKey(installationID int64, fullName string) string

+ func RepositoryEntityKey(installationID, repositoryGitHubID int64) string

+ func StackEntityKey(installationID int64, repositoryGitHubID int64, number int) string

+ type ApplyPullRequestResult struct

+ Applied bool

+ DomainChanged bool

+ NewHeadSHA string

+ NewStackNumber *int

+ OldHeadSHA string

+ OldStackNumber *int

+ StackStateChanged bool

+ type ApplyStackResult struct

+ Applied bool

+ JoinedPRs []int

+ LeftPRs []int

+ MovedPRs []int

+ PriorStackByPR map[int]int

+ type CacheObserver interface

+ CacheWrite func(context.Context, string, bool, bool)

+ type CheckRunRecord struct

+ AppSlug string

+ CompletedAt *time.Time

+ Conclusion string

+ DetailsURL string

+ GitHubID int64

+ GitHubUpdatedAt *time.Time

+ Name string

+ NodeID string

+ Observed json.RawMessage

+ SemanticVersion string

+ StartedAt *time.Time

+ Status string

+ type ChecksRecord struct

+ ETag string

+ HeadSHA string

+ Repository RepositoryRecord

+ Runs []CheckRunRecord

+ Source SyncSource

+ SyncedAt time.Time

+ type ConnectOption func(*connectOptions)

+ func WithTracerProvider(provider trace.TracerProvider) ConnectOption

+ type EntityWriter struct

+ func NewEntityWriter(pool *pgxpool.Pool, observers ...CacheObserver) *EntityWriter

+ func (w *EntityWriter) ApplyChecksObserved(ctx context.Context, observation *Observation, checks ChecksRecord) (bool, error)

+ func (w *EntityWriter) ApplyPullRequest(ctx context.Context, pull PullRequestRecord) (ApplyPullRequestResult, error)

+ func (w *EntityWriter) ApplyPullRequestBatch(ctx context.Context, applies []PullRequestApply) map[string]PullRequestApplyOutcome

+ func (w *EntityWriter) ApplyPullRequestObserved(ctx context.Context, observation *Observation, pull PullRequestRecord, ...) (ApplyPullRequestResult, error)

+ func (w *EntityWriter) ApplyRepoRulesObserved(ctx context.Context, observation *Observation, rules RepoRulesRecord) (bool, error)

+ func (w *EntityWriter) ApplyRepository(ctx context.Context, repository RepositoryRecord, source SyncSource, ...) (bool, error)

+ func (w *EntityWriter) ApplyRepositoryObserved(ctx context.Context, observation *Observation, repository RepositoryRecord, ...) (bool, error)

+ func (w *EntityWriter) ApplyStack(ctx context.Context, stack StackRecord) (ApplyStackResult, error)

+ func (w *EntityWriter) ApplyStackObserved(ctx context.Context, observation *Observation, stack StackRecord, ...) (ApplyStackResult, error)

+ func (w *EntityWriter) BeginObservation(ctx context.Context, entityKey string) (*Observation, error)

+ func (w *EntityWriter) BranchTargets(ctx context.Context, repoFullName string, branch string) ([]string, error)

+ func (w *EntityWriter) ChecksMetadata(ctx context.Context, repo string, headSHA string) (FetchMetadata, error)

+ func (w *EntityWriter) PullRequestMetadata(ctx context.Context, repo string, number int) (FetchMetadata, error)

+ func (w *EntityWriter) RepoRulesMetadata(ctx context.Context, repo string) (FetchMetadata, int64, error)

+ func (w *EntityWriter) Repository(ctx context.Context, fullName string) (RepositoryRecord, error)

+ func (w *EntityWriter) StackMetadata(ctx context.Context, repo string, number int) (FetchMetadata, error)

+ func (w *EntityWriter) TombstonePullRequestObserved(ctx context.Context, observation *Observation, repository RepositoryRecord, ...) (ApplyPullRequestResult, error)

+ func (w *EntityWriter) TombstoneRepositoryObserved(ctx context.Context, observation *Observation, repository RepositoryRecord, ...) (bool, error)

+ func (w *EntityWriter) TombstoneStackObserved(ctx context.Context, observation *Observation, repository RepositoryRecord, ...) (ApplyStackResult, error)

+ func (w *EntityWriter) TouchChecks(ctx context.Context, observation *Observation, repository RepositoryRecord, ...) error

+ func (w *EntityWriter) TouchPullRequest(ctx context.Context, observation *Observation, repository RepositoryRecord, ...) error

+ func (w *EntityWriter) TouchRepoRules(ctx context.Context, observation *Observation, repository RepositoryRecord, ...) error

+ func (w *EntityWriter) TouchStack(ctx context.Context, observation *Observation, repository RepositoryRecord, ...) error

+ type FetchMetadata struct

+ ETag string

+ HeadSHA string

+ InstallationID int64

+ NodeID string

+ RepoFullName string

+ RepoGitHubID int64

+ StackNumber *int

+ StackPosition *int

+ type Observation struct

+ func (o *Observation) Close() error

+ func (o *Observation) CloseContext(ctx context.Context) error

+ func (o *Observation) Key() string

+ type PullRequestApply struct

+ Context context.Context

+ Hook PullRequestHook

+ Observation *Observation

+ Record PullRequestRecord

+ type PullRequestApplyOutcome struct

+ Err error

+ Result ApplyPullRequestResult

+ type PullRequestHook func(ApplyPullRequestResult) TransactionHook

+ type PullRequestRecord struct

+ AuthorLogin string

+ BaseRef string

+ BaseSHA string

+ Draft bool

+ ETag string

+ GitHubID int64

+ GitHubUpdatedAt time.Time

+ HeadRef string

+ HeadSHA string

+ MembershipKnown bool

+ MergeableState string

+ NodeID string

+ Number int

+ Repository RepositoryRecord

+ ReviewDecision string

+ ReviewThreads []ReviewThreadRecord

+ Source SyncSource

+ StackNumber *int

+ StackPosition *int

+ StackSummary *StackSummaryRecord

+ State string

+ SyncedAt time.Time

+ ThreadsKnown bool

+ Title string

+ type RepoRuleRecord struct

+ GitHubUpdatedAt *time.Time

+ HeadSHA string

+ Key string

+ Rule json.RawMessage

+ type RepoRulesRecord struct

+ ETag string

+ Repository RepositoryRecord

+ Rules []RepoRuleRecord

+ Source SyncSource

+ SyncedAt time.Time

+ type RepositoryRecord struct

+ Archived bool

+ DefaultBranch string

+ DefaultHeadSHA string

+ ETag string

+ FullName string

+ GitHubID int64

+ GitHubUpdatedAt time.Time

+ InstallationID int64

+ LastCheckedAt time.Time

+ Name string

+ NodeID string

+ OrgID int64

+ Owner string

+ type ReviewCommentRecord struct

+ AuthorLogin string

+ Body string

+ ID string

+ UpdatedAt time.Time

+ type ReviewThreadRecord struct

+ Comments []ReviewCommentRecord

+ GitHubUpdatedAt time.Time

+ ID string

+ IsOutdated bool

+ IsResolved bool

+ Line *int

+ Path string

+ type StackEntry struct

+ Draft bool

+ HeadRef string

+ HeadSHA string

+ MergedAt *time.Time

+ Number int

+ State string

+ UpdatedAt time.Time

+ type StackHook func(ApplyStackResult) TransactionHook

+ type StackRecord struct

+ BaseRef string

+ BaseSHA string

+ ETag string

+ Entries []StackEntry

+ GitHubID int64

+ GitHubUpdatedAt time.Time

+ NodeID string

+ Number int

+ Open bool

+ Repository RepositoryRecord

+ Source SyncSource

+ SyncedAt time.Time

+ type StackSummaryRecord struct

+ BaseRef string

+ BaseSHA string

+ GitHubID int64

+ Number int

+ Position int

+ Size int

+ type SyncSource string

+ const SyncSourceBackfill

+ const SyncSourceInteractive

+ const SyncSourceManual

+ const SyncSourceReconcile

+ const SyncSourceWebhook

+ func (s SyncSource) Valid() bool

+ type TransactionHook func(context.Context, pgx.Tx) error

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