drift

type Config struct {
	// InstallationID selects the GitHub installation and cached rows sampled.
	InstallationID int64
	// Period controls how often River schedules a detector pass.
	Period time.Duration
	// SampleSize bounds the number of entities inspected per pass.
	SampleSize int
	// PageSize bounds pagination used by full-fetch comparisons.
	PageSize int
	// ResolvedRetention controls how long resolved findings remain queryable.
	ResolvedRetention time.Duration
	// RetentionBatchSize bounds resolved-finding deletes per transaction.
	RetentionBatchSize int
	// Now supplies detector time; it defaults to time.Now.
	Now func() time.Time
	// Observer receives divergence and persistence signals.
	Observer Observer
}

type DetectArgs struct {
	InstallationID int64 `json:"installation_id"`
	SampleSize     int   `json:"sample_size"`
}

type LogObserver struct{}

type Observer interface {
	Divergence(context.Context, *dbgen.DriftFinding)
	PersistentDivergence(context.Context, *dbgen.DriftFinding)
}

type Observers []Observer

type Options struct {
	Pool          *pgxpool.Pool
	REST          *gh.RESTClient
	GraphQL       *gh.GraphQLClient
	Config        Config
	CacheObserver store.CacheObserver
}

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