From e1a622e04645c66f052d02c70bd4305785f67eb1 Mon Sep 17 00:00:00 2001 From: Matt Lord Date: Mon, 2 Oct 2023 17:01:56 -0400 Subject: [PATCH] Revert "Rename shared function appropriately" This reverts commit 0e259ce24ccbcd06b877c6c27edbeace890680f8. Signed-off-by: Matt Lord --- go/vt/vtctl/workflow/materializer.go | 4 +--- go/vt/vtctl/workflow/server.go | 2 +- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/go/vt/vtctl/workflow/materializer.go b/go/vt/vtctl/workflow/materializer.go index 81977f52e70..921d1a5337d 100644 --- a/go/vt/vtctl/workflow/materializer.go +++ b/go/vt/vtctl/workflow/materializer.go @@ -77,9 +77,7 @@ func (mz *materializer) getWorkflowSubType() (binlogdatapb.VReplicationWorkflowS } } -// createMigrationStreams creates the vreplication streams for Migrate, -// MoveTables, and Reshard workflows. -func (mz *materializer) createMigrationStreams(req *vtctldatapb.MoveTablesCreateRequest) error { +func (mz *materializer) createMoveTablesStreams(req *vtctldatapb.MoveTablesCreateRequest) error { if err := validateNewWorkflow(mz.ctx, mz.ts, mz.tmc, mz.ms.TargetKeyspace, mz.ms.Workflow); err != nil { return err } diff --git a/go/vt/vtctl/workflow/server.go b/go/vt/vtctl/workflow/server.go index 89811350379..6533c62ad8e 100644 --- a/go/vt/vtctl/workflow/server.go +++ b/go/vt/vtctl/workflow/server.go @@ -1269,7 +1269,7 @@ func (s *Server) MoveTablesCreate(ctx context.Context, req *vtctldatapb.MoveTabl tmc: s.tmc, ms: ms, } - err = mz.createMigrationStreams(req) + err = mz.createMoveTablesStreams(req) if err != nil { return nil, err }