()
| 728 | } |
| 729 | |
| 730 | func newAdminResolverFactory() resolve.ResolverFactory { |
| 731 | adminMutationResolvers := map[string]resolve.MutationResolverFunc{ |
| 732 | "addNamespace": resolveAddNamespace, |
| 733 | "backup": resolveBackup, |
| 734 | "config": resolveUpdateConfig, |
| 735 | "deleteNamespace": resolveDeleteNamespace, |
| 736 | "draining": resolveDraining, |
| 737 | "export": resolveExport, |
| 738 | "login": resolveLogin, |
| 739 | "resetPassword": resolveResetPassword, |
| 740 | "restore": resolveRestore, |
| 741 | "shutdown": resolveShutdown, |
| 742 | "removeNode": resolveRemoveNode, |
| 743 | "moveTablet": resolveMoveTablet, |
| 744 | "assign": resolveAssign, |
| 745 | "restoreTenant": resolveTenantRestore, |
| 746 | } |
| 747 | |
| 748 | rf := resolverFactoryWithErrorMsg(errResolverNotFound). |
| 749 | WithQueryMiddlewareConfig(adminQueryMWConfig). |
| 750 | WithMutationMiddlewareConfig(adminMutationMWConfig). |
| 751 | WithQueryResolver("health", func(q schema.Query) resolve.QueryResolver { |
| 752 | return resolve.QueryResolverFunc(resolveHealth) |
| 753 | }). |
| 754 | WithQueryResolver("state", func(q schema.Query) resolve.QueryResolver { |
| 755 | return resolve.QueryResolverFunc(resolveState) |
| 756 | }). |
| 757 | WithQueryResolver("config", func(q schema.Query) resolve.QueryResolver { |
| 758 | return resolve.QueryResolverFunc(resolveGetConfig) |
| 759 | }). |
| 760 | WithQueryResolver("listBackups", func(q schema.Query) resolve.QueryResolver { |
| 761 | return resolve.QueryResolverFunc(resolveListBackups) |
| 762 | }). |
| 763 | WithQueryResolver("task", func(q schema.Query) resolve.QueryResolver { |
| 764 | return resolve.QueryResolverFunc(resolveTask) |
| 765 | }). |
| 766 | WithQueryResolver("getGQLSchema", func(q schema.Query) resolve.QueryResolver { |
| 767 | return resolve.QueryResolverFunc( |
| 768 | func(ctx context.Context, query schema.Query) *resolve.Resolved { |
| 769 | return &resolve.Resolved{Err: errors.Errorf(errMsgServerNotReady), Field: q} |
| 770 | }) |
| 771 | }). |
| 772 | WithMutationResolver("updateGQLSchema", func(m schema.Mutation) resolve.MutationResolver { |
| 773 | return resolve.MutationResolverFunc( |
| 774 | func(ctx context.Context, m schema.Mutation) (*resolve.Resolved, bool) { |
| 775 | return &resolve.Resolved{Err: errors.Errorf(errMsgServerNotReady), Field: m}, |
| 776 | false |
| 777 | }) |
| 778 | }) |
| 779 | for gqlMut, resolver := range adminMutationResolvers { |
| 780 | // gotta force go to evaluate the right function at each loop iteration |
| 781 | // otherwise you get variable capture issues |
| 782 | func(f resolve.MutationResolver) { |
| 783 | rf.WithMutationResolver(gqlMut, func(m schema.Mutation) resolve.MutationResolver { |
| 784 | return f |
| 785 | }) |
| 786 | }(resolver) |
| 787 | } |
no test coverage detected