diff --git a/internal/storage/transactions.go b/internal/storage/transactions.go index ba3dfc7..48a287a 100644 --- a/internal/storage/transactions.go +++ b/internal/storage/transactions.go @@ -54,6 +54,9 @@ // - GetAllSagas у SagaManager — читает все SAGA (включая завершённые) // с диска через SagaPersistentStorage.ListAll(). Используется // REPL-командой "saga list --all". +// +// ИЗМЕНЕНО (2026-10): удалён AOF. BatchManager больше не содержит +// поле aof, и Commit не пишет в AOF. Единственный источник истины — WAL. package storage @@ -209,7 +212,6 @@ type BatchManager struct { logger LoggerInterface walPath string stats *BatchStats - aof *AOFManager // activeBatches — реестр активных (незакоммиченных) batch'ей. activeBatches sync.Map @@ -261,13 +263,6 @@ func InitBatchManagerWithConfig(walPath string, config map[string]interface{}) e if err != nil { return } - - globalBatchManager.aof, err = NewAOFManager( - filepath.Join(filepath.Dir(walPath), "aof"), - fsyncEnabled, nil) - if err != nil { - return - } }) return err } @@ -282,9 +277,6 @@ func SetBatchLogger(logger LoggerInterface) { if globalBatchManager.wal != nil { globalBatchManager.wal.logger = logger } - if globalBatchManager.aof != nil { - globalBatchManager.aof.SetLogger(logger) - } } } @@ -442,14 +434,6 @@ func (b *Batch) Commit() error { return fmt.Errorf("batch apply failed: %v", err) } - if globalBatchManager.aof != nil { - if err := globalBatchManager.aof.AppendBatch(b); err != nil { - if globalBatchManager.logger != nil { - globalBatchManager.logger.Warn(fmt.Sprintf("AOF append failed: %v", err)) - } - } - } - globalBatchManager.stats.TotalBatches.Add(1) globalBatchManager.stats.TotalOperations.Add(uint64(len(b.Operations))) return nil @@ -1106,6 +1090,7 @@ func (im *WALIndexManager) load() error { } return json.Unmarshal(data, &im.index) } + // ============================================================================= // SAGA — ИНТЕРФЕЙСЫ ДЛЯ RAFT // ============================================================================= @@ -2602,9 +2587,6 @@ func StopBatchManager() error { globalBatchManager.wal.Sync() globalBatchManager.wal.Close() } - if globalBatchManager.aof != nil { - globalBatchManager.aof.Close() - } return nil }