Function TestTransactionManager_RejectTxWhenNotRunning

tx_manager_test.go:183–200

(t *testing.T)

}

func TestTransactionManager_RejectTxWhenNotRunning(t *testing.T) {
	db := &DB{}
	sm := NewStatusManager(DefaultStatusManagerConfig())
	defer func() { _ = sm.Close() }()

	if err := sm.Start(); err != nil {
		t.Fatalf("Failed to start StatusManager: %v", err)
	}

	tm := newTxManager(db, sm)

	tx := &Tx{id: 1, db: db}
	if err := tm.RegisterTx(tx); err != nil {
		t.Errorf("RegisterTx should work even when TransactionManager is not running (only checks StatusManager), got: %v", err)
	}

	tm.UnregisterTx(tx.id)
}

func TestTransactionManager_WaitForActiveTxs(t *testing.T) {
	db := &DB{}