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

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.