sweep

type Config struct {
	// InstallationID selects the GitHub installation reconciled by this service.
	InstallationID int64

	// OpenStackMaxStaleness bounds how long an open stack may go unchecked.
	OpenStackMaxStaleness time.Duration
	// OpenPRMaxStaleness bounds how long an open pull request may go unchecked.
	OpenPRMaxStaleness time.Duration
	// RepoRulesMaxStaleness bounds repository-rules cache staleness.
	RepoRulesMaxStaleness time.Duration
	// ClosedMaxStaleness bounds checks of tracked closed entities.
	ClosedMaxStaleness time.Duration
	// RepositoryListPeriod controls authoritative installation listings.
	RepositoryListPeriod time.Duration

	// PageSize bounds authoritative GitHub list pages.
	PageSize int

	// GapHealPeriod controls delivery-gap scan scheduling.
	GapHealPeriod time.Duration
	// GapWindow is the delivery-history interval inspected by each scan.
	GapWindow time.Duration
	// GapPageSize bounds one deliveries API page.
	GapPageSize int
	// GapMaxPages bounds pages inspected before scheduling a continuation.
	GapMaxPages int

	// RetentionPeriod controls payload-pruner scheduling.
	RetentionPeriod time.Duration
	// RetentionAge determines when bulky retained data becomes eligible.
	RetentionAge time.Duration
	// RetentionBatchSize bounds deletes per transaction.
	RetentionBatchSize int

	// Now supplies service time; it defaults to time.Now.
	Now func() time.Time
	// Observer receives sweep-overrun and gap-healing signals.
	Observer Observer
	// OnPrune receives per-kind deletion totals after a prune pass.
	OnPrune PruneHook
}

type GapHealArgs struct {
	Installation int64  `json:"installation_id"`
	Cursor       string `json:"cursor,omitempty"`
}

type KickoffArgs struct {
	SweepKind    string `json:"sweep_kind"`
	Installation int64  `json:"installation_id"`
}

type ListPageArgs struct {
	SweepKind    string `json:"sweep_kind"`
	Installation int64  `json:"installation_id"`
	ScopeKey     string `json:"scope_key"`
	Cursor       string `json:"cursor"`
}

type LogObserver struct{}

type Observer interface {
	SweepOverrun(
		context.Context,
		string,
		string,
		time.Duration,
	)
	GapRedelivery(context.Context, int64, string)
	GapWindowIncomplete(context.Context, string, int)
}

type Observers []Observer

type Options struct {
	Pool       *pgxpool.Pool
	REST       *gh.RESTClient
	Deliveries *gh.DeliveriesClient
	Config     Config
}

type PruneArgs struct{}

type PruneHook func(context.Context, string, int64)

type SchedulePlan struct {
	Bound              time.Duration
	Cadence            time.Duration
	CompletionHeadroom time.Duration
}

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