worker

Documentation

Overview

internal/worker/pool.go

Index

• type ProcessFunc
• type ProgressFunc
• type Result
  • func Run(ctx context.Context, repos []model.Repo, concurrency int, process ProcessFunc) []Result
  • func RunWithProgress(ctx context.Context, repos []model.Repo, concurrency int, process ProcessFunc, ...) []Result
• type TrendsProcessFunc
• type TrendsResult
  • func RunTrends(ctx context.Context, repos []model.Repo, concurrency int, ...) []TrendsResult

Types

type ProcessFunc

type ProcessFunc func(ctx context.Context, repo model.Repo) (*model.RepoStats, error)

ProcessFunc processes a single repository and returns its stats.

type ProgressFunc

type ProgressFunc func(completed, total int, repo model.Repo)

ProgressFunc is called after each repository is processed.

type Result

type Result struct {
	Repo  model.Repo
	Stats *model.RepoStats
	Err   error
}

Result holds the outcome of processing a single repository.

func Run

func Run(ctx context.Context, repos []model.Repo, concurrency int, process ProcessFunc) []Result

Run processes repos concurrently using a bounded worker pool.

func RunWithProgress

func RunWithProgress(ctx context.Context, repos []model.Repo, concurrency int, process ProcessFunc, onProgress ProgressFunc) []Result

RunWithProgress processes repos concurrently with an optional progress callback.

type TrendsProcessFunc

type TrendsProcessFunc func(ctx context.Context, repo model.Repo) (map[string]*model.RepoStats, error)

TrendsProcessFunc processes a single repository and returns stats per period.

type TrendsResult

type TrendsResult struct {
	Repo      model.Repo
	Snapshots map[string]*model.RepoStats // period label -> stats
	Err       error
}

TrendsResult holds the outcome of processing a single repository across time periods.

func RunTrends

func RunTrends(ctx context.Context, repos []model.Repo, concurrency int, process TrendsProcessFunc, onProgress ProgressFunc) []TrendsResult

RunTrends processes repos concurrently, where each repo produces multiple period snapshots.