refactor tn migration 6 (#20777)

manual control flusher Approved by: @zhangxu19830126
matrixorigin · Dec 17, 2024 · 703e47e · 703e47e
1 parent 25b0a18
commit 703e47e
Show file tree

Hide file tree

Showing 18 changed files with 994 additions and 458 deletions.
diff --git a/pkg/txn/storage/tae/storage.go b/pkg/txn/storage/tae/storage.go
@@ -54,7 +54,7 @@ func NewTAEStorage(
 	}
 	taeHandler := rpc.NewTAEHandle(ctx, dataDir, opt)
 	tae := taeHandler.GetDB()
-	logtailer := logtail.NewLogtailer(ctx, tae.BGCheckpointRunner, tae.LogtailMgr, tae.Catalog)
+	logtailer := logtail.NewLogtailer(ctx, tae, tae.LogtailMgr, tae.Catalog)
 	server, err := service.NewLogtailServer(logtailServerAddr, logtailServerCfg, logtailer, rt, nil)
 	if err != nil {
 		return nil, err

diff --git a/pkg/vm/engine/tae/common/retry.go b/pkg/vm/engine/tae/common/retry.go
@@ -27,7 +27,9 @@ type WaitOp = func() (ok bool, err error)
 func RetryWithIntervalAndTimeout(
 	op WaitOp,
 	timeout time.Duration,
-	interval time.Duration, suppressTimout bool) (err error) {
+	interval time.Duration,
+	suppressTimout bool,
+) (err error) {
 
 	ctx, cancel := context.WithTimeoutCause(context.Background(), timeout, moerr.CauseRetryWithIntervalAndTimeout)
 	defer cancel()