| 19 | } |
| 20 | |
| 21 | func (ctl *controller) changeDatabaseAndReturnRollout(ctx context.Context, project *v1pb.Project, database *v1pb.Database, sheet *v1pb.Sheet) (*v1pb.Rollout, error) { |
| 22 | spec := &v1pb.Plan_Spec{ |
| 23 | Id: uuid.NewString(), |
| 24 | Config: &v1pb.Plan_Spec_ChangeDatabaseConfig{ |
| 25 | ChangeDatabaseConfig: &v1pb.Plan_ChangeDatabaseConfig{ |
| 26 | Targets: []string{database.Name}, |
| 27 | Sheet: sheet.Name, |
| 28 | }, |
| 29 | }, |
| 30 | } |
| 31 | return ctl.changeDatabaseWithConfigAndReturnRollout(ctx, project, spec) |
| 32 | } |
| 33 | |
| 34 | func (ctl *controller) changeDatabaseWithConfig(ctx context.Context, project *v1pb.Project, spec *v1pb.Plan_Spec) error { |
| 35 | _, err := ctl.changeDatabaseWithConfigAndReturnRollout(ctx, project, spec) |