(ctx context.Context, m schema.Mutation)
| 24 | } |
| 25 | |
| 26 | func resolveMoveTablet(ctx context.Context, m schema.Mutation) (*resolve.Resolved, bool) { |
| 27 | input, err := getMoveTabletInput(m) |
| 28 | if err != nil { |
| 29 | return resolve.EmptyResult(m, err), false |
| 30 | } |
| 31 | |
| 32 | // gRPC call returns a nil status if the error is non-nil |
| 33 | status, err := worker.MoveTabletOverNetwork(ctx, &pb.MoveTabletRequest{ |
| 34 | Namespace: input.Namespace, |
| 35 | Tablet: input.Tablet, |
| 36 | DstGroup: input.GroupId, |
| 37 | }) |
| 38 | if err != nil { |
| 39 | return resolve.EmptyResult(m, err), false |
| 40 | } |
| 41 | |
| 42 | return resolve.DataResult(m, |
| 43 | map[string]interface{}{m.Name(): response("Success", status.GetMsg())}, |
| 44 | nil, |
| 45 | ), true |
| 46 | } |
| 47 | |
| 48 | func getMoveTabletInput(m schema.Mutation) (*moveTabletInput, error) { |
| 49 | inputArg, ok := m.ArgValue(schema.InputArgName).(map[string]interface{}) |
nothing calls this directly
no test coverage detected