(msg string)
| 926 | } |
| 927 | |
| 928 | func resolverFactoryWithErrorMsg(msg string) resolve.ResolverFactory { |
| 929 | errFunc := func(name string) error { return errors.Errorf(msg, name) } |
| 930 | qErr := |
| 931 | resolve.QueryResolverFunc(func(ctx context.Context, query schema.Query) *resolve.Resolved { |
| 932 | return &resolve.Resolved{Err: errFunc(query.ResponseName()), Field: query} |
| 933 | }) |
| 934 | |
| 935 | mErr := resolve.MutationResolverFunc( |
| 936 | func(ctx context.Context, mutation schema.Mutation) (*resolve.Resolved, bool) { |
| 937 | return &resolve.Resolved{Err: errFunc(mutation.ResponseName()), Field: mutation}, false |
| 938 | }) |
| 939 | |
| 940 | return resolve.NewResolverFactory(qErr, mErr) |
| 941 | } |
| 942 | |
| 943 | func (as *adminServer) getGlobalEpoch(ns uint64) *uint64 { |
| 944 | e := as.globalEpoch[ns] |
no test coverage detected