scheduler

type Config struct {
	// Enabled controls whether the scheduler runs
	Enabled bool

	// DefaultPollInterval is the default interval between sync checks
	DefaultPollInterval time.Duration

	// CheckInterval is how often the scheduler checks for repos needing sync
	CheckInterval time.Duration

	// StaleThreshold is how long a repo must be in 'indexing' or 'cloning' status
	// before it's considered stuck and reset to 'pending'. Default: 1 hour.
	StaleThreshold time.Duration

	// PendingJobTimeout is how long a repo can be in 'pending' status without
	// an active job before it's considered stuck and re-queued. Default: 5 minutes.
	// This should be short to quickly recover from job queue issues.
	PendingJobTimeout time.Duration

	// MaxConcurrentChecks limits parallel git fetch checks
	MaxConcurrentChecks int

	// ReposPath is the path where repositories are cloned
	ReposPath string

	// IndexPath is the path where Zoekt index shards are stored
	IndexPath string

	// JobRetentionPeriod is how long to keep completed/failed jobs
	JobRetentionPeriod time.Duration

	// OrphanCleanupInterval is how often to check for orphan shards (0 to disable)
	OrphanCleanupInterval time.Duration
}

type RepoNeedingSync struct {
	ID            int64
	ConnectionID  int64
	Name          string
	CloneURL      string
	DefaultBranch string
	Branches      []string // Additional branches to index
	IndexStatus   string
	LastIndexed   *time.Time
	PollInterval  *time.Duration // nil means use default
	LocalPath     string
}

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

type Stats struct {
	TotalCount    int       `json:"total_count"`
	IndexedCount  int       `json:"indexed_count"`
	PendingCount  int       `json:"pending_count"`
	IndexingCount int       `json:"indexing_count"`
	FailedCount   int       `json:"failed_count"`
	StaleCount    int       `json:"stale_count"`
	NextCheckAt   time.Time `json:"next_check_at"`
}