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

Side by Side Diff: impl/memory/taskqueue.go

Issue 2512093002: Add support for Pull Queues to prod implementation. (Closed)
Patch Set: Created 4 years, 1 month 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 LUCI Authors. All rights reserved. 1 // Copyright 2015 The LUCI Authors. All rights reserved.
2 // Use of this source code is governed under the Apache License, Version 2.0 2 // Use of this source code is governed under the Apache License, Version 2.0
3 // that can be found in the LICENSE file. 3 // that can be found in the LICENSE file.
4 4
5 package memory 5 package memory
6 6
7 import ( 7 import (
8 "regexp" 8 "regexp"
9 9
10 "golang.org/x/net/context" 10 "golang.org/x/net/context"
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after
98 if err != nil { 98 if err != nil {
99 return err 99 return err
100 } 100 }
101 101
102 for _, task := range tasks { 102 for _, task := range tasks {
103 cb(t.deleteLocked(task, queueName)) 103 cb(t.deleteLocked(task, queueName))
104 } 104 }
105 return nil 105 return nil
106 } 106 }
107 107
108 func (t *taskqueueImpl) Lease(maxTasks int, queueName string, leaseTime int) ([] *tq.Task, error) {
109 panic("not implemented yet")
110 }
111
112 func (t *taskqueueImpl) LeaseByTag(maxTasks int, queueName string, leaseTime int , tag string) ([]*tq.Task, error) {
113 panic("not implemented yet")
114 }
115
116 func (t *taskqueueImpl) ModifyLease(task *tq.Task, queueName string, leaseTime i nt) error {
117 panic("not implemented yet")
118 }
119
108 func (t *taskqueueImpl) Purge(queueName string) error { 120 func (t *taskqueueImpl) Purge(queueName string) error {
109 t.Lock() 121 t.Lock()
110 defer t.Unlock() 122 defer t.Unlock()
111 123
112 return t.purgeLocked(queueName) 124 return t.purgeLocked(queueName)
113 } 125 }
114 126
115 func (t *taskqueueImpl) Stats(queueNames []string, cb tq.RawStatsCB) error { 127 func (t *taskqueueImpl) Stats(queueNames []string, cb tq.RawStatsCB) error {
116 t.Lock() 128 t.Lock()
117 defer t.Unlock() 129 defer t.Unlock()
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after
201 for _, task := range tasks { 213 for _, task := range tasks {
202 cb(t.addLocked(task, queueName)) 214 cb(t.addLocked(task, queueName))
203 } 215 }
204 return nil 216 return nil
205 } 217 }
206 218
207 func (t *taskqueueTxnImpl) DeleteMulti([]*tq.Task, string, tq.RawCB) error { 219 func (t *taskqueueTxnImpl) DeleteMulti([]*tq.Task, string, tq.RawCB) error {
208 return errors.New("taskqueue: cannot DeleteMulti from a transaction") 220 return errors.New("taskqueue: cannot DeleteMulti from a transaction")
209 } 221 }
210 222
223 func (t *taskqueueTxnImpl) Lease(maxTasks int, queueName string, leaseTime int) ([]*tq.Task, error) {
224 return nil, errors.New("taskqueue: cannot Lease from a transaction")
225 }
226
227 func (t *taskqueueTxnImpl) LeaseByTag(maxTasks int, queueName string, leaseTime int, tag string) ([]*tq.Task, error) {
228 return nil, errors.New("taskqueue: cannot LeaseByTag from a transaction" )
229 }
230
231 func (t *taskqueueTxnImpl) ModifyLease(task *tq.Task, queueName string, leaseTim e int) error {
232 return errors.New("taskqueue: cannot ModifyLease from a transaction")
233 }
234
211 func (t *taskqueueTxnImpl) Purge(string) error { 235 func (t *taskqueueTxnImpl) Purge(string) error {
212 return errors.New("taskqueue: cannot Purge from a transaction") 236 return errors.New("taskqueue: cannot Purge from a transaction")
213 } 237 }
214 238
215 func (t *taskqueueTxnImpl) Stats([]string, tq.RawStatsCB) error { 239 func (t *taskqueueTxnImpl) Stats([]string, tq.RawStatsCB) error {
216 return errors.New("taskqueue: cannot Stats from a transaction") 240 return errors.New("taskqueue: cannot Stats from a transaction")
217 } 241 }
218 242
219 func (t *taskqueueTxnImpl) GetTestable() tq.Testable { return t } 243 func (t *taskqueueTxnImpl) GetTestable() tq.Testable { return t }
220 244
(...skipping 19 matching lines...) Expand all
240 func dupQueue(q tq.QueueData) tq.QueueData { 264 func dupQueue(q tq.QueueData) tq.QueueData {
241 r := make(tq.QueueData, len(q)) 265 r := make(tq.QueueData, len(q))
242 for k, q := range q { 266 for k, q := range q {
243 r[k] = make(map[string]*tq.Task, len(q)) 267 r[k] = make(map[string]*tq.Task, len(q))
244 for tn, t := range q { 268 for tn, t := range q {
245 r[k][tn] = t.Duplicate() 269 r[k][tn] = t.Duplicate()
246 } 270 }
247 } 271 }
248 return r 272 return r
249 } 273 }
OLDNEW
« no previous file with comments | « impl/dummy/dummy.go ('k') | impl/prod/taskqueue.go » ('j') | service/taskqueue/interface.go » ('J')

Powered by Google App Engine
This is Rietveld 408576698