aboutsummaryrefslogtreecommitdiff
path: root/format/pack/ingest/ingest.go
diff options
context:
space:
mode:
authorGravatar Runxi Yu2026-03-08 03:31:12 +0800
committerGravatar Runxi Yu2026-03-08 03:31:12 +0800
commit74584d2dee4f349b5b3535669fa304b95f0f6e52 (patch)
tree8ce22050c4726eeaffa29f34074bf8f874c51c7c /format/pack/ingest/ingest.go
parentreceivepack: Add basic progress logging (diff)
signatureNo signature
format/pack/ingest: Add more progress
Diffstat (limited to 'format/pack/ingest/ingest.go')
-rw-r--r--format/pack/ingest/ingest.go14
1 files changed, 13 insertions, 1 deletions
diff --git a/format/pack/ingest/ingest.go b/format/pack/ingest/ingest.go
index 22007d27..5f204c2b 100644
--- a/format/pack/ingest/ingest.go
+++ b/format/pack/ingest/ingest.go
@@ -1,6 +1,10 @@
package ingest
-import "fmt"
+import (
+ "fmt"
+
+ "codeberg.org/lindenii/furgit/internal/utils"
+)
// ingest initializes transaction state and executes the ingest pipeline.
func ingest(state *ingestState) (out Result, err error) {
@@ -47,6 +51,7 @@ func ingest(state *ingestState) (out Result, err error) {
return Result{}, err
}
+ utils.WriteProgressf(state.opts.Progress, "writing index: start\n")
err = state.packFile.Sync()
if err != nil {
return Result{}, &DestinationWriteError{Op: fmt.Sprintf("sync pack: %v", err)}
@@ -56,11 +61,18 @@ func ingest(state *ingestState) (out Result, err error) {
if err != nil {
return Result{}, err
}
+ utils.WriteProgressf(state.opts.Progress, "writing index: done\n")
+ if state.opts.WriteRev {
+ utils.WriteProgressf(state.opts.Progress, "writing reverse index: start\n")
+ }
err = writeRev(state)
if err != nil {
return Result{}, err
}
+ if state.opts.WriteRev {
+ utils.WriteProgressf(state.opts.Progress, "writing reverse index: done\n")
+ }
return finalizeArtifacts(state)
}