fetcher

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 26, 2026 License: MIT Imports: 21 Imported by: 0

Documentation

Overview

Package fetcher mirrors leased GitHub pull requests and collects them offline with the shared collector. It never claims an account or pull request metadata; the server overwrites identity and validates the captured commits.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Run 

func Run(ctx context.Context, server Server, settings Settings) error

Run leases and collects pull requests on Concurrency workers until ctx is cancelled, then joins every worker and returns nil. Collection inherits the process environment, so the caller must export GIT_NO_LAZY_FETCH=1; Run refuses to start otherwise rather than mutating process-wide state.

Types

type Server 

type Server interface {
	Lease(context.Context) (*fetchprotocol.Job, error)
	Complete(context.Context, fetchprotocol.Job, ingestion.Request) error
	Fail(context.Context, fetchprotocol.Job, string) error
}

Server is the fetcher's view of the server's internal fetch listener.

type Settings 

type Settings struct {
	Mirrors     string
	DiskLimit   int64
	Concurrency int
	// PollInterval is the idle wait between empty leases; zero means 5s.
	PollInterval     time.Duration
	CollectorVersion string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.