Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(509)

Side by Side Diff: impl/prod/context.go

Issue 1772943003: Add wrappers for the module module (Closed) Base URL: https://github.com/luci/gae.git@master
Patch Set: Created 4 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 package prod 5 package prod
6 6
7 import ( 7 import (
8 "fmt" 8 "fmt"
9 "net/http" 9 "net/http"
10 "net/http/cookiejar" 10 "net/http/cookiejar"
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after
63 } 63 }
64 if deadline, ok := c.Deadline(); ok { 64 if deadline, ok := c.Deadline(); ok {
65 aeCtx, _ = context.WithDeadline(aeCtx, deadline) 65 aeCtx, _ = context.WithDeadline(aeCtx, deadline)
66 } 66 }
67 return aeCtx 67 return aeCtx
68 } 68 }
69 69
70 func setupAECtx(c, aeCtx context.Context) context.Context { 70 func setupAECtx(c, aeCtx context.Context) context.Context {
71 c = context.WithValue(c, prodContextKey, aeCtx) 71 c = context.WithValue(c, prodContextKey, aeCtx)
72 c = context.WithValue(c, prodContextNoTxnKey, aeCtx) 72 c = context.WithValue(c, prodContextNoTxnKey, aeCtx)
73 » return useMail(useUser(useURLFetch(useRDS(useMC(useTQ(useGI(useLogging(c )))))))) 73 » return useModule(useMail(useUser(useURLFetch(useRDS(useMC(useTQ(useGI(us eLogging(c)))))))))
74 } 74 }
75 75
76 // Use adds production implementations for all the gae services to the 76 // Use adds production implementations for all the gae services to the
77 // context. 77 // context.
78 // 78 //
79 // The services added are: 79 // The services added are:
80 // - github.com/luci-go/common/logging 80 // - github.com/luci-go/common/logging
81 // - github.com/luci/gae/service/datastore 81 // - github.com/luci/gae/service/datastore
82 // - github.com/luci/gae/service/info 82 // - github.com/luci/gae/service/info
83 // - github.com/luci/gae/service/mail 83 // - github.com/luci/gae/service/mail
84 // - github.com/luci/gae/service/memcache 84 // - github.com/luci/gae/service/memcache
85 // - github.com/luci/gae/service/module
85 // - github.com/luci/gae/service/taskqueue 86 // - github.com/luci/gae/service/taskqueue
86 // - github.com/luci/gae/service/urlfetch 87 // - github.com/luci/gae/service/urlfetch
87 // - github.com/luci/gae/service/user 88 // - github.com/luci/gae/service/user
88 // 89 //
89 // These can be retrieved with the <service>.Get functions. 90 // These can be retrieved with the <service>.Get functions.
90 // 91 //
91 // The implementations are all backed by the real appengine SDK functionality, 92 // The implementations are all backed by the real appengine SDK functionality,
92 func Use(c context.Context, r *http.Request) context.Context { 93 func Use(c context.Context, r *http.Request) context.Context {
93 return setupAECtx(c, appengine.NewContext(r)) 94 return setupAECtx(c, appengine.NewContext(r))
94 } 95 }
(...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after
153 } 154 }
154 } 155 }
155 156
156 aeCtx, err := remote_api.NewRemoteContext(host, client) 157 aeCtx, err := remote_api.NewRemoteContext(host, client)
157 if err != nil { 158 if err != nil {
158 return 159 return
159 } 160 }
160 *inOutCtx = setupAECtx(*inOutCtx, aeCtx) 161 *inOutCtx = setupAECtx(*inOutCtx, aeCtx)
161 return nil 162 return nil
162 } 163 }
OLDNEW
« impl/memory/module.go ('K') | « impl/memory/module.go ('k') | impl/prod/module.go » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698