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) |