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

Unified Diff: service/taskqueue/taskqueue.go

Issue 2302743002: Interface update, per-method Contexts. (Closed)
Patch Set: Lightning talk licenses. Created 4 years, 3 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « service/taskqueue/raw_interface.go ('k') | service/user/context.go » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: service/taskqueue/taskqueue.go
diff --git a/service/taskqueue/taskqueue.go b/service/taskqueue/taskqueue.go
deleted file mode 100644
index 0c0f92f48ce704a8c075fb9f2a3ada63890931ad..0000000000000000000000000000000000000000
--- a/service/taskqueue/taskqueue.go
+++ /dev/null
@@ -1,77 +0,0 @@
-// 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 taskqueue
-
-import (
- "github.com/luci/luci-go/common/errors"
-)
-
-type taskqueueImpl struct{ RawInterface }
-
-func (t *taskqueueImpl) Add(task *Task, queueName string) error {
- return errors.SingleError(t.AddMulti([]*Task{task}, queueName))
-}
-
-func (t *taskqueueImpl) Delete(task *Task, queueName string) error {
- return errors.SingleError(t.DeleteMulti([]*Task{task}, queueName))
-}
-
-func (t *taskqueueImpl) AddMulti(tasks []*Task, queueName string) error {
- lme := errors.NewLazyMultiError(len(tasks))
- i := 0
- err := t.RawInterface.AddMulti(tasks, queueName, func(t *Task, err error) {
- if !lme.Assign(i, err) {
- *tasks[i] = *t
- }
- i++
- })
- if err == nil {
- err = lme.Get()
- }
- return err
-}
-
-func (t *taskqueueImpl) DeleteMulti(tasks []*Task, queueName string) error {
- lme := errors.NewLazyMultiError(len(tasks))
- i := 0
- err := t.RawInterface.DeleteMulti(tasks, queueName, func(err error) {
- lme.Assign(i, err)
- i++
- })
- if err == nil {
- err = lme.Get()
- }
- return err
-}
-
-func (t *taskqueueImpl) Purge(queueName string) error {
- return t.RawInterface.Purge(queueName)
-}
-
-func (t *taskqueueImpl) Stats(queueNames ...string) ([]Statistics, error) {
- ret := make([]Statistics, len(queueNames))
- lme := errors.NewLazyMultiError(len(queueNames))
- i := 0
- err := t.RawInterface.Stats(queueNames, func(s *Statistics, err error) {
- if !lme.Assign(i, err) {
- ret[i] = *s
- }
- i++
- })
- if err == nil {
- err = lme.Get()
- }
- return ret, err
-}
-
-func (t *taskqueueImpl) Raw() RawInterface {
- return t.RawInterface
-}
-
-func (t *taskqueueImpl) Testable() Testable {
- return t.RawInterface.Testable()
-}
-
-var _ Interface = (*taskqueueImpl)(nil)
« no previous file with comments | « service/taskqueue/raw_interface.go ('k') | service/user/context.go » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698