jobs

type AutoPrioritizeChannelStore interface {
	ListEnabled(ctx context.Context) ([]channels.Channel, error)
	ListSourcesByChannelIDs(ctx context.Context, channelIDs []int64, enabledOnly bool) (map[int64][]channels.Source, error)
	ListSources(ctx context.Context, channelID int64, enabledOnly bool) ([]channels.Source, error)
	ReorderSources(ctx context.Context, channelID int64, sourceIDs []int64) error
	UpdateSourceProfile(ctx context.Context, sourceID int64, profile channels.SourceProfileUpdate) error
}

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

type AutoPrioritizeMetricsStore interface {
	GetStreamMetric(ctx context.Context, itemKey string) (StreamMetric, error)
	UpsertStreamMetric(ctx context.Context, metric StreamMetric) error
}

type AutoPrioritizeOptions struct {
	SuccessFreshness time.Duration
	ErrorRetry       time.Duration
	DefaultWorkers   int
	WorkerMode       string
	FixedWorkers     int
	TunerCount       int
	TunerUsage       TunerUsageProvider
	ProbeTuneDelay   time.Duration
	HTTP429Backoff   time.Duration
}

type AutoPrioritizeSettingsStore interface {
	GetSetting(ctx context.Context, key string) (string, error)
}

type DVRLineupReloader interface {
	ReloadLineupForPlaylistSyncOutcome(ctx context.Context) (dvr.ReloadOutcome, error)
}

type JobFunc func(ctx context.Context, run *RunContext) error

type PlaylistReconciler interface {
	CountChannels(ctx context.Context) (int, error)
	Reconcile(ctx context.Context, onProgress func(cur, max int) error) (reconcile.Result, error)
}

type PlaylistRefresher interface {
	RefreshForSource(ctx context.Context, source playlist.PlaylistSource) (int, error)
}

type PlaylistSettingsStore interface {
	GetSetting(ctx context.Context, key string) (string, error)
	ListPlaylistSources(ctx context.Context) ([]playlist.PlaylistSource, error)
}

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

type Run struct {
	RunID        int64  `json:"run_id"`
	JobName      string `json:"job_name"`
	TriggeredBy  string `json:"triggered_by"`
	StartedAt    int64  `json:"started_at"`
	FinishedAt   int64  `json:"finished_at,omitempty"`
	Status       string `json:"status"`
	ProgressCur  int    `json:"progress_cur"`
	ProgressMax  int    `json:"progress_max"`
	Summary      string `json:"summary,omitempty"`
	ErrorMessage string `json:"error,omitempty"`
	// AnalysisErrorBuckets is derived from auto-prioritize run summary text when present.
	AnalysisErrorBuckets map[string]int `json:"analysis_error_buckets,omitempty"`
}

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

type RunMetadata struct {
	RunID       int64
	JobName     string
	TriggeredBy string
}

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

type ScheduledCatchUpOptions struct {
	InitialBackoff time.Duration
	MaxBackoff     time.Duration
	FreshnessLimit int
}

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

type ScheduledJobStarter interface {
	Start(ctx context.Context, jobName, triggeredBy string, fn JobFunc) (int64, error)
}

type SourcePoolTunerUsageProvider interface {
	CapacityForSource(sourceID int64) int
	InUseCountForSource(sourceID int64) int
}

type Store interface {
	CreateRun(ctx context.Context, jobName, triggeredBy string, startedAt int64) (int64, error)
	UpdateRunProgress(ctx context.Context, runID int64, progressCur, progressMax int, summary string) error
	FinishRun(ctx context.Context, runID int64, status, errText, summary string, finishedAt int64) error
	GetRun(ctx context.Context, runID int64) (Run, error)
	ListRuns(ctx context.Context, jobName string, limit, offset int) ([]Run, error)
}

type StreamAnalyzer interface {
	Analyze(ctx context.Context, streamURL string) (analyzer.Metrics, error)
}

type StreamMetric struct {
	ItemKey    string  `json:"item_key"`
	AnalyzedAt int64   `json:"analyzed_at"`
	Width      int     `json:"width,omitempty"`
	Height     int     `json:"height,omitempty"`
	FPS        float64 `json:"fps,omitempty"`
	VideoCodec string  `json:"video_codec,omitempty"`
	AudioCodec string  `json:"audio_codec,omitempty"`
	BitrateBPS int64   `json:"bitrate_bps,omitempty"`
	VariantBPS int64   `json:"variant_bps,omitempty"`
	ScoreHint  float64 `json:"score_hint,omitempty"`
	Error      string  `json:"error,omitempty"`
}

type TunerUsageProvider interface {
	InUseCount() int
	AcquireProbe(ctx context.Context, label string, cancel context.CancelCauseFunc) (*stream.Lease, error)
	AcquireProbeForSource(ctx context.Context, sourceID int64, label string, cancel context.CancelCauseFunc) (*stream.Lease, error)
}