diff options
| author |  Runxi Yu | 2026-03-08 14:16:07 +0800 |
|---|---|---|
| committer | Runxi Yu | 2026-03-08 14:16:07 +0800 |
| commit | 1137bfc1c204c34efbc8d36c0ed4db1bfd605f73 (patch) | |
| tree | d1ef9f6a2c4977d7a7098ea66e1bd8f357c5636e /receivepack/service | |
| parent | format/pack/ingest: Use progress API (diff) | |
| signature | No signature | |
receivepack: Use progress API
Diffstat (limited to 'receivepack/service')
| -rw-r--r-- | receivepack/service/ingest_quarantine.go | 9 | ||||
| -rw-r--r-- | receivepack/service/options.go | 1 |
2 files changed, 6 insertions, 4 deletions
diff --git a/receivepack/service/ingest_quarantine.go b/receivepack/service/ingest_quarantine.go index 6cc4c3e3..d4819447 100644 --- a/receivepack/service/ingest_quarantine.go +++ b/receivepack/service/ingest_quarantine.go @@ -38,10 +38,11 @@ func (service *Service) ingestQuarantine( req.Pack, service.opts.Algorithm, ingest.Options{ - FixThin: true, - WriteRev: true, - Base: service.opts.ExistingObjects, - Progress: service.opts.Progress, + FixThin: true, + WriteRev: true, + Base: service.opts.ExistingObjects, + Progress: service.opts.Progress, + ProgressFlush: service.opts.ProgressFlush, }, ) if err != nil { diff --git a/receivepack/service/options.go b/receivepack/service/options.go index ec451ebf..21b84e2d 100644 --- a/receivepack/service/options.go +++ b/receivepack/service/options.go @@ -22,6 +22,7 @@ type Options struct { ExistingObjects objectstore.Store ObjectsRoot *os.Root Progress io.Writer + ProgressFlush func() error PromotedObjectPermissions *PromotedObjectPermissions Hook Hook HookIO HookIO |