| Index: scheduler/appengine/engine/tq/globals.go
|
| diff --git a/scheduler/appengine/engine/tq/globals.go b/scheduler/appengine/engine/tq/globals.go
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..f284dd05a410ce7a5d54d4e1ffb32af353b757be
|
| --- /dev/null
|
| +++ b/scheduler/appengine/engine/tq/globals.go
|
| @@ -0,0 +1,34 @@
|
| +// Copyright 2017 The LUCI Authors.
|
| +//
|
| +// Licensed under the Apache License, Version 2.0 (the "License");
|
| +// you may not use this file except in compliance with the License.
|
| +// You may obtain a copy of the License at
|
| +//
|
| +// http://www.apache.org/licenses/LICENSE-2.0
|
| +//
|
| +// Unless required by applicable law or agreed to in writing, software
|
| +// distributed under the License is distributed on an "AS IS" BASIS,
|
| +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
| +// See the License for the specific language governing permissions and
|
| +// limitations under the License.
|
| +
|
| +package tq
|
| +
|
| +import (
|
| + "github.com/golang/protobuf/proto"
|
| + "github.com/luci/gae/service/taskqueue"
|
| + "golang.org/x/net/context"
|
| +)
|
| +
|
| +// DefaultDispatcher is global task dispatcher.
|
| +var DefaultDispatcher = Dispatcher{}
|
| +
|
| +// RegisterTask registers the task in default dispatcher.
|
| +func RegisterTask(prototype proto.Message, cb Handler, queue string, opts *taskqueue.RetryOptions) {
|
| + DefaultDispatcher.RegisterTask(prototype, cb, queue, opts)
|
| +}
|
| +
|
| +// AddTask submits a task through default dispatcher.
|
| +func AddTask(c context.Context, task Task) error {
|
| + return DefaultDispatcher.AddTask(c, task)
|
| +}
|
|
|