Index: go/src/infra/gae/libs/wrapper/gae/taskqueue.go |
diff --git a/go/src/infra/gae/libs/wrapper/gae/taskqueue.go b/go/src/infra/gae/libs/wrapper/gae/taskqueue.go |
deleted file mode 100644 |
index 41ebc8b910a6801d835087a94ba3a705f0f758de..0000000000000000000000000000000000000000 |
--- a/go/src/infra/gae/libs/wrapper/gae/taskqueue.go |
+++ /dev/null |
@@ -1,68 +0,0 @@ |
-// Copyright 2015 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-package gae |
- |
-import ( |
- "golang.org/x/net/context" |
- |
- "appengine" |
- "appengine/taskqueue" |
- |
- "infra/gae/libs/wrapper" |
-) |
- |
-// useTQ adds a wrapper.TaskQueue implementation to context, accessible |
-// by wrapper.GetTQ(c) |
-func useTQ(c context.Context) context.Context { |
- return wrapper.SetTQFactory(c, func(ci context.Context) wrapper.TaskQueue { |
- return tqImpl{ctx(ci).Context} |
- }) |
-} |
- |
-type tqImpl struct { |
- appengine.Context |
-} |
- |
-//////// TQSingleReadWriter |
- |
-func (t tqImpl) Add(task *taskqueue.Task, queueName string) (*taskqueue.Task, error) { |
- return taskqueue.Add(t.Context, task, queueName) |
-} |
-func (t tqImpl) Delete(task *taskqueue.Task, queueName string) error { |
- return taskqueue.Delete(t.Context, task, queueName) |
-} |
- |
-//////// TQMultiReadWriter |
- |
-func (t tqImpl) AddMulti(tasks []*taskqueue.Task, queueName string) ([]*taskqueue.Task, error) { |
- return taskqueue.AddMulti(t.Context, tasks, queueName) |
-} |
-func (t tqImpl) DeleteMulti(tasks []*taskqueue.Task, queueName string) error { |
- return taskqueue.DeleteMulti(t.Context, tasks, queueName) |
-} |
- |
-//////// TQLeaser |
- |
-func (t tqImpl) Lease(maxTasks int, queueName string, leaseTime int) ([]*taskqueue.Task, error) { |
- return taskqueue.Lease(t.Context, maxTasks, queueName, leaseTime) |
-} |
-func (t tqImpl) LeaseByTag(maxTasks int, queueName string, leaseTime int, tag string) ([]*taskqueue.Task, error) { |
- return taskqueue.LeaseByTag(t.Context, maxTasks, queueName, leaseTime, tag) |
-} |
-func (t tqImpl) ModifyLease(task *taskqueue.Task, queueName string, leaseTime int) error { |
- return taskqueue.ModifyLease(t.Context, (*taskqueue.Task)(task), queueName, leaseTime) |
-} |
- |
-//////// TQPurger |
- |
-func (t tqImpl) Purge(queueName string) error { |
- return taskqueue.Purge(t.Context, queueName) |
-} |
- |
-//////// TQStatter |
- |
-func (t tqImpl) QueueStats(queueNames []string, maxTasks int) ([]taskqueue.QueueStatistics, error) { |
- return taskqueue.QueueStats(t.Context, queueNames, maxTasks) |
-} |