Skip to content

Commit

Permalink
Add tmc impls
Browse files Browse the repository at this point in the history
Signed-off-by: Matt Lord <mattalord@gmail.com>
  • Loading branch information
mattlord committed Sep 28, 2023
1 parent d2ab63f commit ac7729d
Show file tree
Hide file tree
Showing 3 changed files with 30 additions and 0 deletions.
10 changes: 10 additions & 0 deletions go/vt/vtctl/workflow/materializer_env_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -306,3 +306,13 @@ func (tmc *testMaterializerTMClient) ApplySchema(ctx context.Context, tablet *to

return nil, nil
}

func (tmc *testMaterializerTMClient) VDiff(ctx context.Context, tablet *topodatapb.Tablet, req *tabletmanagerdatapb.VDiffRequest) (*tabletmanagerdatapb.VDiffResponse, error) {
return &tabletmanagerdatapb.VDiffResponse{
Id: 1,
VdiffUuid: req.VdiffUuid,
Output: &querypb.QueryResult{
RowsAffected: 1,
},
}, nil
}
10 changes: 10 additions & 0 deletions go/vt/vttablet/tabletmanager/framework_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -480,3 +480,13 @@ func (tmc *fakeTMClient) ExecuteFetchAsAllPrivs(ctx context.Context, tablet *top
RowsAffected: 1,
}, nil
}

func (tmc *fakeTMClient) VDiff(ctx context.Context, tablet *topodatapb.Tablet, req *tabletmanagerdatapb.VDiffRequest) (*tabletmanagerdatapb.VDiffResponse, error) {
return &tabletmanagerdatapb.VDiffResponse{
Id: 1,
VdiffUuid: req.VdiffUuid,
Output: &querypb.QueryResult{
RowsAffected: 1,
},
}, nil
}
10 changes: 10 additions & 0 deletions go/vt/wrangler/wrangler_env_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -341,3 +341,13 @@ func (tmc *testWranglerTMClient) ExecuteFetchAsApp(ctx context.Context, tablet *
}
return result, nil
}

func (tmc *testWranglerTMClient) VDiff(ctx context.Context, tablet *topodatapb.Tablet, req *tabletmanagerdatapb.VDiffRequest) (*tabletmanagerdatapb.VDiffResponse, error) {
return &tabletmanagerdatapb.VDiffResponse{
Id: 1,
VdiffUuid: req.VdiffUuid,
Output: &querypb.QueryResult{
RowsAffected: 1,
},
}, nil
}

0 comments on commit ac7729d

Please sign in to comment.