aboutsummaryrefslogtreecommitdiff
path: root/internal/queue/queue.go
diff options
context:
space:
mode:
authorJulie Qiu <julie@golang.org>2021-09-13 16:23:36 -0400
committerJulie Qiu <julie@golang.org>2021-09-14 14:59:14 +0000
commitaf3f6453cdd5cbed324b511e4802b7a8d908c4b1 (patch)
tree75cb44baa182665a4a33be8829b70662f35d0051 /internal/queue/queue.go
parent7f60b22a0b5e8732e49b2bcf6cf1454e9773a379 (diff)
downloadgo-x-pkgsite-af3f6453cdd5cbed324b511e4802b7a8d908c4b1.tar.xz
internal/{queue,worker}: add worker source param
When a request is enqueued via the /enqueue endpoint, add a source=worker query param so that it is clear from the logs where this request came from. Change-Id: I396bb8a952640c244e0b217e48356e8088ed5eb0 Reviewed-on: https://go-review.googlesource.com/c/pkgsite/+/349530 Trust: Julie Qiu <julie@golang.org> Run-TryBot: Julie Qiu <julie@golang.org> TryBot-Result: kokoro <noreply+kokoro@google.com> Reviewed-by: Jonathan Amsterdam <jba@google.com>
Diffstat (limited to 'internal/queue/queue.go')
-rw-r--r--internal/queue/queue.go1
1 files changed, 1 insertions, 0 deletions
diff --git a/internal/queue/queue.go b/internal/queue/queue.go
index 8c1c37b0..5eb9bc2f 100644
--- a/internal/queue/queue.go
+++ b/internal/queue/queue.go
@@ -167,6 +167,7 @@ const (
DisableProxyFetchValue = "off"
SourceParam = "source"
SourceFrontendValue = "frontend"
+ SourceWorkerValue = "worker"
)
func (q *GCP) newTaskRequest(modulePath, version string, opts *Options) *taskspb.CreateTaskRequest {