Add support for Pull Queues to prod implementation.

impl/dummy/dummy.go

 // Copyright 2015 The LUCI Authors. All rights reserved.
 // Use of this source code is governed under the Apache License, Version 2.0
 // that can be found in the LICENSE file.
 
 package dummy
 
 import (
         "fmt"
         "runtime"
         "strings"
@@ skipping 107 matching lines @@
 
 // Memcache returns a dummy memcache.RawInterface implementation suitable for
 // embedding.  Every method panics with a message containing the name of the
 // method which was unimplemented.
 func Memcache() memcache.RawInterface { return dummyMCInst }
 
 /////////////////////////////////// tq ////////////////////////////////////
 
 type tq struct{}
 
-func (tq) AddMulti([]*taskqueue.Task, string, taskqueue.RawTaskCB) error { panic(ni()) }
-func (tq) DeleteMulti([]*taskqueue.Task, string, taskqueue.RawCB) error  { panic(ni()) }
-func (tq) Purge(string) error                                            { panic(ni()) }
-func (tq) Stats([]string, taskqueue.RawStatsCB) error                    { panic(ni()) }
-func (tq) GetTestable() taskqueue.Testable                               { return nil }
+func (tq) AddMulti([]*taskqueue.Task, string, taskqueue.RawTaskCB) error            { panic(ni()) }
+func (tq) DeleteMulti([]*taskqueue.Task, string, taskqueue.RawCB) error             { panic(ni()) }
+func (tq) Lease(int, string, time.Duration) ([]*taskqueue.Task, error)              { panic(ni()) }
+func (tq) LeaseByTag(int, string, time.Duration, string) ([]*taskqueue.Task, error) { panic(ni()) }
+func (tq) ModifyLease(*taskqueue.Task, string, time.Duration) error                 { panic(ni()) }
+func (tq) Purge(string) error                                                       { panic(ni()) }
+func (tq) Stats([]string, taskqueue.RawStatsCB) error                               { panic(ni()) }
+func (tq) GetTestable() taskqueue.Testable                                          { return nil }
 
 var dummyTQInst = tq{}
 
 // TaskQueue returns a dummy taskqueue.RawInterface implementation suitable for
 // embedding.  Every method panics with a message containing the name of the
 // method which was unimplemented.
 func TaskQueue() taskqueue.RawInterface { return dummyTQInst }
 
 /////////////////////////////////// i ////////////////////////////////////
 
@@ skipping 80 matching lines @@
 func (mod) DefaultVersion(module string) (string, error) { panic(ni()) }
 func (mod) Start(module, version string) error           { panic(ni()) }
 func (mod) Stop(module, version string) error            { panic(ni()) }
 
 var dummyModuleInst = mod{}
 
 // Module returns a dummy module.Interface implementation suitable for
 // embedding. Every method panics with a message containing the name of the
 // method which was unimplemented.
 func Module() module.RawInterface { return dummyModuleInst }