LogDog: Support per-namespace expired archival.

appengine/logdog/coordinator/service.go

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package coordinator
 
 import (
         "net/http"
         "sync"
 
@@ skipping 41 matching lines @@
         GSClient(context.Context) (gs.Client, error)
 
         // ArchivalPublisher returns an ArchivalPublisher instance.
         ArchivalPublisher(context.Context) (ArchivalPublisher, error)
 }
 
 // WithProdServices is a middleware Handler that installs a production Services
 // instance into its Context.
 func WithProdServices(h middleware.Handler) middleware.Handler {
         return func(c context.Context, rw http.ResponseWriter, r *http.Request, params httprouter.Params) {
-                c = WithServices(c, &prodServices{})
+                c = UseProdServices(c)
                 h(c, rw, r, params)
         }
 }
 
+// UseProdServices installs production Services instance into the supplied
+// Context.
+func UseProdServices(c context.Context) context.Context {
+        return WithServices(c, &prodServices{})
+}
+
 // Request is a Service context for a given request.
 type prodServices struct {
         sync.Mutex
 
         // gcfg is the cached global configuration.
         gcfg *config.GlobalConfig
         // cfg is the cached configuration.
         cfg *svcconfig.Config
 }
 
@@ skipping 136 matching lines @@
         psClient, err := gcps.NewClient(c, project, cloud.WithBaseHTTP(client))
         if err != nil {
                 log.WithError(err).Errorf(c, "Failed to create Pub/Sub client.")
                 return nil, errors.New("failed to create Pub/Sub client")
         }
 
         return &pubsubArchivalPublisher{
                 topic: psClient.Topic(topic),
         }, nil
 }