git

Jul 27, 2026

Changes in this version

type Config

+ SnapshotFilters map[string]string

Jul 21, 2026

Changes in this version

type Config

+ SnapshotMaxAge time.Duration

+ type SnapshotCoordinator struct

+ func NewSnapshotCoordinator(ns *metadatadb.Namespace) *SnapshotCoordinator

+ func (c *SnapshotCoordinator) Claim(job, upstreamURL string, interval time.Duration) (bool, error)

+ func (c *SnapshotCoordinator) Complete(job, upstreamURL, commit string) error

+ func (c *SnapshotCoordinator) Prime(ctx context.Context) error

+ func (c *SnapshotCoordinator) Skip(job, upstreamURL string) error

+ func (c *SnapshotCoordinator) Unchanged(job, upstreamURL, commit string, maxAge time.Duration) bool

Jun 24, 2026

Changes in this version

+ const EnsureRefsPath

+ var ErrSpoolFailed = errors.New("spool failed before response started")

+ func ExtractRepoPath(pathValue string) string

+ func Register(r *strategy.Registry, scheduler jobscheduler.Provider, ...)

+ func RequestIsClone(pathValue string, r *http.Request) (bool, error)

+ func SpoolKeyForRequest(pathValue string, r *http.Request) (string, error)

+ type Config struct

+ BundleCacheTTL time.Duration

+ MirrorSnapshotInterval time.Duration

+ RepackInterval time.Duration

+ SnapshotInterval time.Duration

+ ZstdThreads int

+ type EnsureRefsRequest struct

+ Commits []string

+ Refs map[string]string

+ type EnsureRefsResponse struct

+ Fetched bool

+ MissingCommits []string

+ Refs map[string]string

+ type RepoCount struct

+ Count int64

+ Repo string

+ type RepoCounts struct

+ func NewRepoCounts(ns *metadatadb.Namespace) *RepoCounts

+ func (r *RepoCounts) IncrementClone(upstreamURL string)

+ func (r *RepoCounts) Reap() int

+ func (r *RepoCounts) TopRepos(windowDays, limit int) []RepoCount

+ type RepoSpools struct

+ func NewRepoSpools(dir string) *RepoSpools

+ func (rp *RepoSpools) Close() error

+ func (rp *RepoSpools) GetOrCreate(key string) (spool *ResponseSpool, isWriter bool, err error)

+ type ResponseSpool struct

+ func NewResponseSpool(filePath string) (*ResponseSpool, error)

+ func (rs *ResponseSpool) CaptureHeader(status int, header http.Header)

+ func (rs *ResponseSpool) Failed() bool

+ func (rs *ResponseSpool) MarkComplete()

+ func (rs *ResponseSpool) MarkError(err error)

+ func (rs *ResponseSpool) ServeTo(w http.ResponseWriter) error

+ func (rs *ResponseSpool) WaitForReaders()

+ func (rs *ResponseSpool) Write(data []byte) error

+ func (rs *ResponseSpool) Written() int64

+ type SpoolTeeWriter struct

+ func NewSpoolTeeWriter(inner http.ResponseWriter, spool *ResponseSpool) *SpoolTeeWriter

+ func (w *SpoolTeeWriter) Flush()

+ func (w *SpoolTeeWriter) Header() http.Header

+ func (w *SpoolTeeWriter) Write(data []byte) (int, error)

+ func (w *SpoolTeeWriter) WriteHeader(code int)

+ type Strategy struct

+ func New(ctx context.Context, config Config, schedulerProvider jobscheduler.Provider, ...) (*Strategy, error)

+ func (s *Strategy) Ready() bool

+ func (s *Strategy) SetHTTPTransport(t http.RoundTripper)

+ func (s *Strategy) SetMetadataStore(store *metadatadb.Store)

+ func (s *Strategy) String() string