OLD | NEW |
(Empty) | |
| 1 // Copyright 2017 The LUCI Authors. |
| 2 // |
| 3 // Licensed under the Apache License, Version 2.0 (the "License"); |
| 4 // you may not use this file except in compliance with the License. |
| 5 // You may obtain a copy of the License at |
| 6 // |
| 7 // http://www.apache.org/licenses/LICENSE-2.0 |
| 8 // |
| 9 // Unless required by applicable law or agreed to in writing, software |
| 10 // distributed under the License is distributed on an "AS IS" BASIS, |
| 11 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 12 // See the License for the specific language governing permissions and |
| 13 // limitations under the License. |
| 14 |
| 15 package tq |
| 16 |
| 17 import ( |
| 18 "github.com/golang/protobuf/proto" |
| 19 "github.com/luci/gae/service/taskqueue" |
| 20 "golang.org/x/net/context" |
| 21 ) |
| 22 |
| 23 // DefaultDispatcher is global task dispatcher. |
| 24 var DefaultDispatcher = Dispatcher{} |
| 25 |
| 26 // RegisterTask registers the task in default dispatcher. |
| 27 func RegisterTask(prototype proto.Message, cb Handler, queue string, opts *taskq
ueue.RetryOptions) { |
| 28 DefaultDispatcher.RegisterTask(prototype, cb, queue, opts) |
| 29 } |
| 30 |
| 31 // AddTask submits a task through default dispatcher. |
| 32 func AddTask(c context.Context, task Task) error { |
| 33 return DefaultDispatcher.AddTask(c, task) |
| 34 } |
OLD | NEW |