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

Side by Side Diff: scheduler/appengine/engine/tq/globals.go

Issue 2981043002: Add a task queue task router to reduce amount of boilerplate. (Closed)
Patch Set: tq-helper Created 3 years, 5 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 unified diff | Download patch
OLDNEW
(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 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698