[logdog] Replace Tumble with push queues.

logdog/appengine/coordinator/backend/routes.go

-// Copyright 2015 The LUCI Authors.
+// Copyright 2017 The LUCI Authors.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
 // You may obtain a copy of the License at
 //
 //      http://www.apache.org/licenses/LICENSE-2.0
 //
 // Unless required by applicable law or agreed to in writing, software
 // distributed under the License is distributed on an "AS IS" BASIS,
 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package module
+package backend

[dnj, 2017/08/03 03:45:55]

This is actually a new file. I guess it thinks it's a copy of some random file.

 
 import (
-        "net/http"
-
-        // Importing pprof implicitly installs "/debug/*" profiling handlers.
-        _ "net/http/pprof"
-
         "github.com/luci/luci-go/appengine/gaemiddleware"
-        "github.com/luci/luci-go/logdog/appengine/coordinator"
         "github.com/luci/luci-go/server/router"
-        "github.com/luci/luci-go/tumble"
-
-        // Include mutations package so its Mutations will register with tumble via
-        // init().
-        _ "github.com/luci/luci-go/logdog/appengine/coordinator/mutations"
 )
 
-func init() {
-        tmb := tumble.Service{}
+const (
+        // ArchivalTaskQueue is the name of the archival task queue.
+        ArchivalTaskQueue = "archival"
+)
 
-        r := router.New()
-        base := gaemiddleware.BaseProd().Extend(coordinator.ProdCoordinatorService)
-        tmb.InstallHandlers(r, base)
-        gaemiddleware.InstallHandlersWithMiddleware(r, base)
-
-        http.Handle("/", r)
+// InstallHandlers installs backend handlers into the supplied Router.
+func InstallHandlers(r *router.Router, base router.MiddlewareChain) {
+        r.POST("/internal/tasks/archival",
+                base.Extend(gaemiddleware.RequireTaskQueue(ArchivalTaskQueue)),
+                handleArchivalTask)
 }