aboutsummaryrefslogtreecommitdiff
path: root/object/store/packed/internal
diff options
context:
space:
mode:
authorGravatar Runxi Yu2026-06-14 14:13:45 +0000
committerGravatar Runxi Yu2026-06-14 14:13:45 +0000
commitc9fdf61bd91875cdc71559cd9bab8314ad8775e1 (patch)
treecd970e43d1c47fa8888bbb99f760c8cf13fdf0b8 /object/store/packed/internal
parentinternal/format/packidx/bloom: Add trailers (diff)
object/store/packed, cmd/idx-bloom: NewBuilder wants a PackHash
Diffstat (limited to 'object/store/packed/internal')
-rw-r--r--object/store/packed/internal/ingest/finalize.go9
1 files changed, 5 insertions, 4 deletions
diff --git a/object/store/packed/internal/ingest/finalize.go b/object/store/packed/internal/ingest/finalize.go
index 8caf6b2f..afed996c 100644
--- a/object/store/packed/internal/ingest/finalize.go
+++ b/object/store/packed/internal/ingest/finalize.go
@@ -39,7 +39,7 @@ func (ingestion *ingestion) finalize() (Result, error) {
return Result{}, err
}
- bloomBuilder, err := ingestion.buildBloom(entries)
+ bloomBuilder, err := ingestion.buildBloom(entries, packHash)
if err != nil {
return Result{}, err
}
@@ -97,14 +97,15 @@ func (ingestion *ingestion) finalize() (Result, error) {
}, nil
}
-// buildBloom builds a Bloom filter over the index entries' object IDs.
-func (ingestion *ingestion) buildBloom(entries []packidx.Entry) (*bloom.Builder, error) {
+// buildBloom builds a Bloom filter over the index entries' object IDs,
+// bound to packHash.
+func (ingestion *ingestion) buildBloom(entries []packidx.Entry, packHash []byte) (*bloom.Builder, error) {
bucketCount, k, err := bloom.RecommendParams(ingestion.objectFormat, len(entries))
if err != nil {
return nil, fmt.Errorf("object/store/packed/internal/ingest: %w", err)
}
- builder, err := bloom.NewBuilder(ingestion.objectFormat, bucketCount, k)
+ builder, err := bloom.NewBuilder(ingestion.objectFormat, bucketCount, k, packHash)
if err != nil {
return nil, fmt.Errorf("object/store/packed/internal/ingest: %w", err)
}