Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>

@@ -0,0 +47,4 @@
+	}
+	updater, found := updates[version]
+	if !found {
+		return fmt.Errorf("unsupported version %d: no update available", version)

@@ -0,0 +68,4 @@
+		return fmt.Errorf("can't open new metabase to compact: %w", err)
+	}
+	if err := bbolt.Compact(dst, db.boltDB, 256<<20); err != nil {
+		return fmt.Errorf("failed to compact metabase: %w", errors.Join(err, dst.Close(), os.Remove(tmpFileName)))

@@ -0,0 +26,4 @@
+	path, _ := cmd.Flags().GetString(pathFlag)
+	noCompact, _ := cmd.Flags().GetBool(noCompactFlag)
+	if _, err := os.Stat(path); err != nil {
+		return fmt.Errorf("failed to check file: %w", err)

@@ -189,6 +189,7 @@ The following table describes configuration for each shard.
 | `mode`                                           | `string`                                    | `read-write`  | Shard Mode.<br/>Possible values:  `read-write`, `read-only`, `degraded`, `degraded-read-only`, `disabled`                                                                                                         |
 | `resync_metabase`                                | `bool`                                      | `false`       | Flag to enable metabase resync on start.                                                                                                                                                                          |
 | `resync_metabase_worker_count`                   | `int`                                       | `1000`        | Count of concurrent workers to resync metabase.                                                                                                                                                                   |
+| `skip_metabase_compact_on_upgrade`               | `bool`                                      | `false`       | If `true` then metabase will not be compacted on upgrade.                                                                                                                                                         |

@@ -0,0 +19,4 @@
+)
+
+const (
+	logEveryCount = 50_000

@@ -0,0 +30,4 @@
+func Upgrade(ctx context.Context, path string, compact bool, log func(msg string)) error {
+	db, err := bbolt.Open(path, os.ModePerm, bbolt.DefaultOptions)
+	if err != nil {
+		return fmt.Errorf("failed to open metabase: %w", err)

@@ -0,0 +71,4 @@
+	if err != nil {
+		return fmt.Errorf("can't open new metabase to compact: %w", err)
+	}
+	if err := bbolt.Compact(dst, db, 256<<20); err != nil {

@@ -0,0 +130,4 @@
+		case <-ctx.Done():
+			return ctx.Err()
+		case obj := <-objects:
+			return db.Update(func(tx *bbolt.Tx) error {

@@ -0,0 +137,4 @@
+					if err := db.Batch(func(tx *bbolt.Tx) error {
+						if err := putUniqueIndexItem(tx, namedBucketItem{
+							name: expEpochToObjectBucketName,
+							key:  expirationEpochKey(obj.expirationEpoch, obj.containerID, obj.objectID),

@@ -0,0 +164,4 @@
+		log("expiration epoch buckets completed completed with error: " + err.Error())
+		return err
+	}
+	log(fmt.Sprintf("filling expiration epoch buckets completed successfully, total %d objects", count.Load()))

@@ -0,0 +225,4 @@
+				continue
+			}
+			attributeKey := string(attrKey[1+cidSize:])
+			if attributeKey != objectV2.SysAttributeExpEpochNeoFS && attributeKey != objectV2.SysAttributeExpEpoch {

@@ -0,0 +279,4 @@
+			if err := objectID.Decode(attrKeyValueItem); err != nil {
+				return fmt.Errorf("failed to decode object id from container '%s' expiration epoch %d: %w", containerID, expirationEpoch, err)
+			}
+			it.lastAttributeKey = bytes.Clone(attrKey)

@@ -0,0 +61,4 @@
+	t.Skip("for generating db")
+	// This test generates a metabase file with 2 million objects for 10 000 containers,
+	// of which
+	// 500 000 are simple objects,

@@ -0,0 +68,4 @@
+	// 100 000 million are locked (total 200 000).
+
+	db := New(WithPath(upgradeFilePath), WithEpochState(epochState{e: 1000}), WithLogger(test.NewLogger(t)),
+		WithMaxBatchDelay(100*time.Millisecond), WithMaxBatchSize(1000))

@@ -0,0 +70,4 @@
+	db := New(WithPath(upgradeFilePath), WithEpochState(epochState{e: 1000}), WithLogger(test.NewLogger(t)),
+		WithMaxBatchDelay(100*time.Millisecond), WithMaxBatchSize(1000))
+	require.NoError(t, db.Open(context.Background(), mode.ReadWrite))
+	db.boltDB.AllocSize = 128 << 20

@@ -0,0 +190,4 @@
+			lock := testutil.GenerateObjectWithCID(containers[i%len(containers)])
+			lock.SetType(objectSDK.TypeLock)
+			testutil.AddAttribute(lock, objectV2.SysAttributeExpEpoch, strconv.FormatUint(uint64(i%1000+1000), 10))
+			_, err = db.Put(ctx, PutPrm{

@@ -0,0 +22,4 @@
+	upgradeLogFrequency = 50_000
+	upgradeWorkersCount = 1_000
+	compactMaxTxSize    = 256 << 20
+	upgradeTimeout      = 1 * time.Second