1// Copyright 2020 Google LLC
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// Code generated by protoc-gen-go. DO NOT EDIT.
16// versions:
17// 	protoc-gen-go v1.25.0-devel
18// 	protoc        v3.13.0
19// source: google/cloud/tasks/v2beta3/cloudtasks.proto
20
21package tasks
22
23import (
24	context "context"
25	reflect "reflect"
26	sync "sync"
27
28	proto "github.com/golang/protobuf/proto"
29	_ "google.golang.org/genproto/googleapis/api/annotations"
30	v1 "google.golang.org/genproto/googleapis/iam/v1"
31	grpc "google.golang.org/grpc"
32	codes "google.golang.org/grpc/codes"
33	status "google.golang.org/grpc/status"
34	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
35	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
36	emptypb "google.golang.org/protobuf/types/known/emptypb"
37	fieldmaskpb "google.golang.org/protobuf/types/known/fieldmaskpb"
38)
39
40const (
41	// Verify that this generated code is sufficiently up-to-date.
42	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
43	// Verify that runtime/protoimpl is sufficiently up-to-date.
44	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
45)
46
47// This is a compile-time assertion that a sufficiently up-to-date version
48// of the legacy proto package is being used.
49const _ = proto.ProtoPackageIsVersion4
50
51// Request message for [ListQueues][google.cloud.tasks.v2beta3.CloudTasks.ListQueues].
52type ListQueuesRequest struct {
53	state         protoimpl.MessageState
54	sizeCache     protoimpl.SizeCache
55	unknownFields protoimpl.UnknownFields
56
57	// Required. The location name.
58	// For example: `projects/PROJECT_ID/locations/LOCATION_ID`
59	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
60	// `filter` can be used to specify a subset of queues. Any [Queue][google.cloud.tasks.v2beta3.Queue]
61	// field can be used as a filter and several operators as supported.
62	// For example: `<=, <, >=, >, !=, =, :`. The filter syntax is the same as
63	// described in
64	// [Stackdriver's Advanced Logs
65	// Filters](https://cloud.google.com/logging/docs/view/advanced_filters).
66	//
67	// Sample filter "state: PAUSED".
68	//
69	// Note that using filters might cause fewer queues than the
70	// requested page_size to be returned.
71	Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
72	// Requested page size.
73	//
74	// The maximum page size is 9800. If unspecified, the page size will
75	// be the maximum. Fewer queues than requested might be returned,
76	// even if more queues exist; use the
77	// [next_page_token][google.cloud.tasks.v2beta3.ListQueuesResponse.next_page_token] in the
78	// response to determine if more queues exist.
79	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
80	// A token identifying the page of results to return.
81	//
82	// To request the first page results, page_token must be empty. To
83	// request the next page of results, page_token must be the value of
84	// [next_page_token][google.cloud.tasks.v2beta3.ListQueuesResponse.next_page_token] returned
85	// from the previous call to [ListQueues][google.cloud.tasks.v2beta3.CloudTasks.ListQueues]
86	// method. It is an error to switch the value of the
87	// [filter][google.cloud.tasks.v2beta3.ListQueuesRequest.filter] while iterating through pages.
88	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
89	// Optional. Read mask is used for a more granular control over what the API returns.
90	// If the mask is not present all fields will be returned except
91	// [Queue.stats]. [Queue.stats] will be returned only if it was  explicitly
92	// specified in the mask.
93	ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,5,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
94}
95
96func (x *ListQueuesRequest) Reset() {
97	*x = ListQueuesRequest{}
98	if protoimpl.UnsafeEnabled {
99		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[0]
100		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
101		ms.StoreMessageInfo(mi)
102	}
103}
104
105func (x *ListQueuesRequest) String() string {
106	return protoimpl.X.MessageStringOf(x)
107}
108
109func (*ListQueuesRequest) ProtoMessage() {}
110
111func (x *ListQueuesRequest) ProtoReflect() protoreflect.Message {
112	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[0]
113	if protoimpl.UnsafeEnabled && x != nil {
114		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
115		if ms.LoadMessageInfo() == nil {
116			ms.StoreMessageInfo(mi)
117		}
118		return ms
119	}
120	return mi.MessageOf(x)
121}
122
123// Deprecated: Use ListQueuesRequest.ProtoReflect.Descriptor instead.
124func (*ListQueuesRequest) Descriptor() ([]byte, []int) {
125	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{0}
126}
127
128func (x *ListQueuesRequest) GetParent() string {
129	if x != nil {
130		return x.Parent
131	}
132	return ""
133}
134
135func (x *ListQueuesRequest) GetFilter() string {
136	if x != nil {
137		return x.Filter
138	}
139	return ""
140}
141
142func (x *ListQueuesRequest) GetPageSize() int32 {
143	if x != nil {
144		return x.PageSize
145	}
146	return 0
147}
148
149func (x *ListQueuesRequest) GetPageToken() string {
150	if x != nil {
151		return x.PageToken
152	}
153	return ""
154}
155
156func (x *ListQueuesRequest) GetReadMask() *fieldmaskpb.FieldMask {
157	if x != nil {
158		return x.ReadMask
159	}
160	return nil
161}
162
163// Response message for [ListQueues][google.cloud.tasks.v2beta3.CloudTasks.ListQueues].
164type ListQueuesResponse struct {
165	state         protoimpl.MessageState
166	sizeCache     protoimpl.SizeCache
167	unknownFields protoimpl.UnknownFields
168
169	// The list of queues.
170	Queues []*Queue `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"`
171	// A token to retrieve next page of results.
172	//
173	// To return the next page of results, call
174	// [ListQueues][google.cloud.tasks.v2beta3.CloudTasks.ListQueues] with this value as the
175	// [page_token][google.cloud.tasks.v2beta3.ListQueuesRequest.page_token].
176	//
177	// If the next_page_token is empty, there are no more results.
178	//
179	// The page token is valid for only 2 hours.
180	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
181}
182
183func (x *ListQueuesResponse) Reset() {
184	*x = ListQueuesResponse{}
185	if protoimpl.UnsafeEnabled {
186		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[1]
187		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
188		ms.StoreMessageInfo(mi)
189	}
190}
191
192func (x *ListQueuesResponse) String() string {
193	return protoimpl.X.MessageStringOf(x)
194}
195
196func (*ListQueuesResponse) ProtoMessage() {}
197
198func (x *ListQueuesResponse) ProtoReflect() protoreflect.Message {
199	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[1]
200	if protoimpl.UnsafeEnabled && x != nil {
201		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
202		if ms.LoadMessageInfo() == nil {
203			ms.StoreMessageInfo(mi)
204		}
205		return ms
206	}
207	return mi.MessageOf(x)
208}
209
210// Deprecated: Use ListQueuesResponse.ProtoReflect.Descriptor instead.
211func (*ListQueuesResponse) Descriptor() ([]byte, []int) {
212	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{1}
213}
214
215func (x *ListQueuesResponse) GetQueues() []*Queue {
216	if x != nil {
217		return x.Queues
218	}
219	return nil
220}
221
222func (x *ListQueuesResponse) GetNextPageToken() string {
223	if x != nil {
224		return x.NextPageToken
225	}
226	return ""
227}
228
229// Request message for [GetQueue][google.cloud.tasks.v2beta3.CloudTasks.GetQueue].
230type GetQueueRequest struct {
231	state         protoimpl.MessageState
232	sizeCache     protoimpl.SizeCache
233	unknownFields protoimpl.UnknownFields
234
235	// Required. The resource name of the queue. For example:
236	// `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID`
237	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
238	// Optional. Read mask is used for a more granular control over what the API returns.
239	// If the mask is not present all fields will be returned except
240	// [Queue.stats]. [Queue.stats] will be returned only if it was  explicitly
241	// specified in the mask.
242	ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
243}
244
245func (x *GetQueueRequest) Reset() {
246	*x = GetQueueRequest{}
247	if protoimpl.UnsafeEnabled {
248		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[2]
249		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
250		ms.StoreMessageInfo(mi)
251	}
252}
253
254func (x *GetQueueRequest) String() string {
255	return protoimpl.X.MessageStringOf(x)
256}
257
258func (*GetQueueRequest) ProtoMessage() {}
259
260func (x *GetQueueRequest) ProtoReflect() protoreflect.Message {
261	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[2]
262	if protoimpl.UnsafeEnabled && x != nil {
263		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
264		if ms.LoadMessageInfo() == nil {
265			ms.StoreMessageInfo(mi)
266		}
267		return ms
268	}
269	return mi.MessageOf(x)
270}
271
272// Deprecated: Use GetQueueRequest.ProtoReflect.Descriptor instead.
273func (*GetQueueRequest) Descriptor() ([]byte, []int) {
274	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{2}
275}
276
277func (x *GetQueueRequest) GetName() string {
278	if x != nil {
279		return x.Name
280	}
281	return ""
282}
283
284func (x *GetQueueRequest) GetReadMask() *fieldmaskpb.FieldMask {
285	if x != nil {
286		return x.ReadMask
287	}
288	return nil
289}
290
291// Request message for [CreateQueue][google.cloud.tasks.v2beta3.CloudTasks.CreateQueue].
292type CreateQueueRequest struct {
293	state         protoimpl.MessageState
294	sizeCache     protoimpl.SizeCache
295	unknownFields protoimpl.UnknownFields
296
297	// Required. The location name in which the queue will be created.
298	// For example: `projects/PROJECT_ID/locations/LOCATION_ID`
299	//
300	// The list of allowed locations can be obtained by calling Cloud
301	// Tasks' implementation of
302	// [ListLocations][google.cloud.location.Locations.ListLocations].
303	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
304	// Required. The queue to create.
305	//
306	// [Queue's name][google.cloud.tasks.v2beta3.Queue.name] cannot be the same as an existing queue.
307	Queue *Queue `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
308}
309
310func (x *CreateQueueRequest) Reset() {
311	*x = CreateQueueRequest{}
312	if protoimpl.UnsafeEnabled {
313		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[3]
314		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
315		ms.StoreMessageInfo(mi)
316	}
317}
318
319func (x *CreateQueueRequest) String() string {
320	return protoimpl.X.MessageStringOf(x)
321}
322
323func (*CreateQueueRequest) ProtoMessage() {}
324
325func (x *CreateQueueRequest) ProtoReflect() protoreflect.Message {
326	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[3]
327	if protoimpl.UnsafeEnabled && x != nil {
328		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
329		if ms.LoadMessageInfo() == nil {
330			ms.StoreMessageInfo(mi)
331		}
332		return ms
333	}
334	return mi.MessageOf(x)
335}
336
337// Deprecated: Use CreateQueueRequest.ProtoReflect.Descriptor instead.
338func (*CreateQueueRequest) Descriptor() ([]byte, []int) {
339	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{3}
340}
341
342func (x *CreateQueueRequest) GetParent() string {
343	if x != nil {
344		return x.Parent
345	}
346	return ""
347}
348
349func (x *CreateQueueRequest) GetQueue() *Queue {
350	if x != nil {
351		return x.Queue
352	}
353	return nil
354}
355
356// Request message for [UpdateQueue][google.cloud.tasks.v2beta3.CloudTasks.UpdateQueue].
357type UpdateQueueRequest struct {
358	state         protoimpl.MessageState
359	sizeCache     protoimpl.SizeCache
360	unknownFields protoimpl.UnknownFields
361
362	// Required. The queue to create or update.
363	//
364	// The queue's [name][google.cloud.tasks.v2beta3.Queue.name] must be specified.
365	//
366	// Output only fields cannot be modified using UpdateQueue.
367	// Any value specified for an output only field will be ignored.
368	// The queue's [name][google.cloud.tasks.v2beta3.Queue.name] cannot be changed.
369	Queue *Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
370	// A mask used to specify which fields of the queue are being updated.
371	//
372	// If empty, then all fields will be updated.
373	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
374}
375
376func (x *UpdateQueueRequest) Reset() {
377	*x = UpdateQueueRequest{}
378	if protoimpl.UnsafeEnabled {
379		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[4]
380		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
381		ms.StoreMessageInfo(mi)
382	}
383}
384
385func (x *UpdateQueueRequest) String() string {
386	return protoimpl.X.MessageStringOf(x)
387}
388
389func (*UpdateQueueRequest) ProtoMessage() {}
390
391func (x *UpdateQueueRequest) ProtoReflect() protoreflect.Message {
392	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[4]
393	if protoimpl.UnsafeEnabled && x != nil {
394		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
395		if ms.LoadMessageInfo() == nil {
396			ms.StoreMessageInfo(mi)
397		}
398		return ms
399	}
400	return mi.MessageOf(x)
401}
402
403// Deprecated: Use UpdateQueueRequest.ProtoReflect.Descriptor instead.
404func (*UpdateQueueRequest) Descriptor() ([]byte, []int) {
405	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{4}
406}
407
408func (x *UpdateQueueRequest) GetQueue() *Queue {
409	if x != nil {
410		return x.Queue
411	}
412	return nil
413}
414
415func (x *UpdateQueueRequest) GetUpdateMask() *fieldmaskpb.FieldMask {
416	if x != nil {
417		return x.UpdateMask
418	}
419	return nil
420}
421
422// Request message for [DeleteQueue][google.cloud.tasks.v2beta3.CloudTasks.DeleteQueue].
423type DeleteQueueRequest struct {
424	state         protoimpl.MessageState
425	sizeCache     protoimpl.SizeCache
426	unknownFields protoimpl.UnknownFields
427
428	// Required. The queue name. For example:
429	// `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID`
430	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
431}
432
433func (x *DeleteQueueRequest) Reset() {
434	*x = DeleteQueueRequest{}
435	if protoimpl.UnsafeEnabled {
436		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[5]
437		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
438		ms.StoreMessageInfo(mi)
439	}
440}
441
442func (x *DeleteQueueRequest) String() string {
443	return protoimpl.X.MessageStringOf(x)
444}
445
446func (*DeleteQueueRequest) ProtoMessage() {}
447
448func (x *DeleteQueueRequest) ProtoReflect() protoreflect.Message {
449	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[5]
450	if protoimpl.UnsafeEnabled && x != nil {
451		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
452		if ms.LoadMessageInfo() == nil {
453			ms.StoreMessageInfo(mi)
454		}
455		return ms
456	}
457	return mi.MessageOf(x)
458}
459
460// Deprecated: Use DeleteQueueRequest.ProtoReflect.Descriptor instead.
461func (*DeleteQueueRequest) Descriptor() ([]byte, []int) {
462	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{5}
463}
464
465func (x *DeleteQueueRequest) GetName() string {
466	if x != nil {
467		return x.Name
468	}
469	return ""
470}
471
472// Request message for [PurgeQueue][google.cloud.tasks.v2beta3.CloudTasks.PurgeQueue].
473type PurgeQueueRequest struct {
474	state         protoimpl.MessageState
475	sizeCache     protoimpl.SizeCache
476	unknownFields protoimpl.UnknownFields
477
478	// Required. The queue name. For example:
479	// `projects/PROJECT_ID/location/LOCATION_ID/queues/QUEUE_ID`
480	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
481}
482
483func (x *PurgeQueueRequest) Reset() {
484	*x = PurgeQueueRequest{}
485	if protoimpl.UnsafeEnabled {
486		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[6]
487		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
488		ms.StoreMessageInfo(mi)
489	}
490}
491
492func (x *PurgeQueueRequest) String() string {
493	return protoimpl.X.MessageStringOf(x)
494}
495
496func (*PurgeQueueRequest) ProtoMessage() {}
497
498func (x *PurgeQueueRequest) ProtoReflect() protoreflect.Message {
499	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[6]
500	if protoimpl.UnsafeEnabled && x != nil {
501		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
502		if ms.LoadMessageInfo() == nil {
503			ms.StoreMessageInfo(mi)
504		}
505		return ms
506	}
507	return mi.MessageOf(x)
508}
509
510// Deprecated: Use PurgeQueueRequest.ProtoReflect.Descriptor instead.
511func (*PurgeQueueRequest) Descriptor() ([]byte, []int) {
512	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{6}
513}
514
515func (x *PurgeQueueRequest) GetName() string {
516	if x != nil {
517		return x.Name
518	}
519	return ""
520}
521
522// Request message for [PauseQueue][google.cloud.tasks.v2beta3.CloudTasks.PauseQueue].
523type PauseQueueRequest struct {
524	state         protoimpl.MessageState
525	sizeCache     protoimpl.SizeCache
526	unknownFields protoimpl.UnknownFields
527
528	// Required. The queue name. For example:
529	// `projects/PROJECT_ID/location/LOCATION_ID/queues/QUEUE_ID`
530	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
531}
532
533func (x *PauseQueueRequest) Reset() {
534	*x = PauseQueueRequest{}
535	if protoimpl.UnsafeEnabled {
536		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[7]
537		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
538		ms.StoreMessageInfo(mi)
539	}
540}
541
542func (x *PauseQueueRequest) String() string {
543	return protoimpl.X.MessageStringOf(x)
544}
545
546func (*PauseQueueRequest) ProtoMessage() {}
547
548func (x *PauseQueueRequest) ProtoReflect() protoreflect.Message {
549	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[7]
550	if protoimpl.UnsafeEnabled && x != nil {
551		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
552		if ms.LoadMessageInfo() == nil {
553			ms.StoreMessageInfo(mi)
554		}
555		return ms
556	}
557	return mi.MessageOf(x)
558}
559
560// Deprecated: Use PauseQueueRequest.ProtoReflect.Descriptor instead.
561func (*PauseQueueRequest) Descriptor() ([]byte, []int) {
562	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{7}
563}
564
565func (x *PauseQueueRequest) GetName() string {
566	if x != nil {
567		return x.Name
568	}
569	return ""
570}
571
572// Request message for [ResumeQueue][google.cloud.tasks.v2beta3.CloudTasks.ResumeQueue].
573type ResumeQueueRequest struct {
574	state         protoimpl.MessageState
575	sizeCache     protoimpl.SizeCache
576	unknownFields protoimpl.UnknownFields
577
578	// Required. The queue name. For example:
579	// `projects/PROJECT_ID/location/LOCATION_ID/queues/QUEUE_ID`
580	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
581}
582
583func (x *ResumeQueueRequest) Reset() {
584	*x = ResumeQueueRequest{}
585	if protoimpl.UnsafeEnabled {
586		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[8]
587		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
588		ms.StoreMessageInfo(mi)
589	}
590}
591
592func (x *ResumeQueueRequest) String() string {
593	return protoimpl.X.MessageStringOf(x)
594}
595
596func (*ResumeQueueRequest) ProtoMessage() {}
597
598func (x *ResumeQueueRequest) ProtoReflect() protoreflect.Message {
599	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[8]
600	if protoimpl.UnsafeEnabled && x != nil {
601		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
602		if ms.LoadMessageInfo() == nil {
603			ms.StoreMessageInfo(mi)
604		}
605		return ms
606	}
607	return mi.MessageOf(x)
608}
609
610// Deprecated: Use ResumeQueueRequest.ProtoReflect.Descriptor instead.
611func (*ResumeQueueRequest) Descriptor() ([]byte, []int) {
612	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{8}
613}
614
615func (x *ResumeQueueRequest) GetName() string {
616	if x != nil {
617		return x.Name
618	}
619	return ""
620}
621
622// Request message for listing tasks using [ListTasks][google.cloud.tasks.v2beta3.CloudTasks.ListTasks].
623type ListTasksRequest struct {
624	state         protoimpl.MessageState
625	sizeCache     protoimpl.SizeCache
626	unknownFields protoimpl.UnknownFields
627
628	// Required. The queue name. For example:
629	// `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID`
630	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
631	// The response_view specifies which subset of the [Task][google.cloud.tasks.v2beta3.Task] will be
632	// returned.
633	//
634	// By default response_view is [BASIC][google.cloud.tasks.v2beta3.Task.View.BASIC]; not all
635	// information is retrieved by default because some data, such as
636	// payloads, might be desirable to return only when needed because
637	// of its large size or because of the sensitivity of data that it
638	// contains.
639	//
640	// Authorization for [FULL][google.cloud.tasks.v2beta3.Task.View.FULL] requires
641	// `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/)
642	// permission on the [Task][google.cloud.tasks.v2beta3.Task] resource.
643	ResponseView Task_View `protobuf:"varint,2,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2beta3.Task_View" json:"response_view,omitempty"`
644	// Maximum page size.
645	//
646	// Fewer tasks than requested might be returned, even if more tasks exist; use
647	// [next_page_token][google.cloud.tasks.v2beta3.ListTasksResponse.next_page_token] in the response to
648	// determine if more tasks exist.
649	//
650	// The maximum page size is 1000. If unspecified, the page size will be the
651	// maximum.
652	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
653	// A token identifying the page of results to return.
654	//
655	// To request the first page results, page_token must be empty. To
656	// request the next page of results, page_token must be the value of
657	// [next_page_token][google.cloud.tasks.v2beta3.ListTasksResponse.next_page_token] returned
658	// from the previous call to [ListTasks][google.cloud.tasks.v2beta3.CloudTasks.ListTasks]
659	// method.
660	//
661	// The page token is valid for only 2 hours.
662	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
663}
664
665func (x *ListTasksRequest) Reset() {
666	*x = ListTasksRequest{}
667	if protoimpl.UnsafeEnabled {
668		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[9]
669		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
670		ms.StoreMessageInfo(mi)
671	}
672}
673
674func (x *ListTasksRequest) String() string {
675	return protoimpl.X.MessageStringOf(x)
676}
677
678func (*ListTasksRequest) ProtoMessage() {}
679
680func (x *ListTasksRequest) ProtoReflect() protoreflect.Message {
681	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[9]
682	if protoimpl.UnsafeEnabled && x != nil {
683		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
684		if ms.LoadMessageInfo() == nil {
685			ms.StoreMessageInfo(mi)
686		}
687		return ms
688	}
689	return mi.MessageOf(x)
690}
691
692// Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.
693func (*ListTasksRequest) Descriptor() ([]byte, []int) {
694	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{9}
695}
696
697func (x *ListTasksRequest) GetParent() string {
698	if x != nil {
699		return x.Parent
700	}
701	return ""
702}
703
704func (x *ListTasksRequest) GetResponseView() Task_View {
705	if x != nil {
706		return x.ResponseView
707	}
708	return Task_VIEW_UNSPECIFIED
709}
710
711func (x *ListTasksRequest) GetPageSize() int32 {
712	if x != nil {
713		return x.PageSize
714	}
715	return 0
716}
717
718func (x *ListTasksRequest) GetPageToken() string {
719	if x != nil {
720		return x.PageToken
721	}
722	return ""
723}
724
725// Response message for listing tasks using [ListTasks][google.cloud.tasks.v2beta3.CloudTasks.ListTasks].
726type ListTasksResponse struct {
727	state         protoimpl.MessageState
728	sizeCache     protoimpl.SizeCache
729	unknownFields protoimpl.UnknownFields
730
731	// The list of tasks.
732	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
733	// A token to retrieve next page of results.
734	//
735	// To return the next page of results, call
736	// [ListTasks][google.cloud.tasks.v2beta3.CloudTasks.ListTasks] with this value as the
737	// [page_token][google.cloud.tasks.v2beta3.ListTasksRequest.page_token].
738	//
739	// If the next_page_token is empty, there are no more results.
740	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
741}
742
743func (x *ListTasksResponse) Reset() {
744	*x = ListTasksResponse{}
745	if protoimpl.UnsafeEnabled {
746		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[10]
747		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
748		ms.StoreMessageInfo(mi)
749	}
750}
751
752func (x *ListTasksResponse) String() string {
753	return protoimpl.X.MessageStringOf(x)
754}
755
756func (*ListTasksResponse) ProtoMessage() {}
757
758func (x *ListTasksResponse) ProtoReflect() protoreflect.Message {
759	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[10]
760	if protoimpl.UnsafeEnabled && x != nil {
761		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
762		if ms.LoadMessageInfo() == nil {
763			ms.StoreMessageInfo(mi)
764		}
765		return ms
766	}
767	return mi.MessageOf(x)
768}
769
770// Deprecated: Use ListTasksResponse.ProtoReflect.Descriptor instead.
771func (*ListTasksResponse) Descriptor() ([]byte, []int) {
772	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{10}
773}
774
775func (x *ListTasksResponse) GetTasks() []*Task {
776	if x != nil {
777		return x.Tasks
778	}
779	return nil
780}
781
782func (x *ListTasksResponse) GetNextPageToken() string {
783	if x != nil {
784		return x.NextPageToken
785	}
786	return ""
787}
788
789// Request message for getting a task using [GetTask][google.cloud.tasks.v2beta3.CloudTasks.GetTask].
790type GetTaskRequest struct {
791	state         protoimpl.MessageState
792	sizeCache     protoimpl.SizeCache
793	unknownFields protoimpl.UnknownFields
794
795	// Required. The task name. For example:
796	// `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID`
797	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
798	// The response_view specifies which subset of the [Task][google.cloud.tasks.v2beta3.Task] will be
799	// returned.
800	//
801	// By default response_view is [BASIC][google.cloud.tasks.v2beta3.Task.View.BASIC]; not all
802	// information is retrieved by default because some data, such as
803	// payloads, might be desirable to return only when needed because
804	// of its large size or because of the sensitivity of data that it
805	// contains.
806	//
807	// Authorization for [FULL][google.cloud.tasks.v2beta3.Task.View.FULL] requires
808	// `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/)
809	// permission on the [Task][google.cloud.tasks.v2beta3.Task] resource.
810	ResponseView Task_View `protobuf:"varint,2,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2beta3.Task_View" json:"response_view,omitempty"`
811}
812
813func (x *GetTaskRequest) Reset() {
814	*x = GetTaskRequest{}
815	if protoimpl.UnsafeEnabled {
816		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[11]
817		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
818		ms.StoreMessageInfo(mi)
819	}
820}
821
822func (x *GetTaskRequest) String() string {
823	return protoimpl.X.MessageStringOf(x)
824}
825
826func (*GetTaskRequest) ProtoMessage() {}
827
828func (x *GetTaskRequest) ProtoReflect() protoreflect.Message {
829	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[11]
830	if protoimpl.UnsafeEnabled && x != nil {
831		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
832		if ms.LoadMessageInfo() == nil {
833			ms.StoreMessageInfo(mi)
834		}
835		return ms
836	}
837	return mi.MessageOf(x)
838}
839
840// Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead.
841func (*GetTaskRequest) Descriptor() ([]byte, []int) {
842	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{11}
843}
844
845func (x *GetTaskRequest) GetName() string {
846	if x != nil {
847		return x.Name
848	}
849	return ""
850}
851
852func (x *GetTaskRequest) GetResponseView() Task_View {
853	if x != nil {
854		return x.ResponseView
855	}
856	return Task_VIEW_UNSPECIFIED
857}
858
859// Request message for [CreateTask][google.cloud.tasks.v2beta3.CloudTasks.CreateTask].
860type CreateTaskRequest struct {
861	state         protoimpl.MessageState
862	sizeCache     protoimpl.SizeCache
863	unknownFields protoimpl.UnknownFields
864
865	// Required. The queue name. For example:
866	// `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID`
867	//
868	// The queue must already exist.
869	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
870	// Required. The task to add.
871	//
872	// Task names have the following format:
873	// `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID`.
874	// The user can optionally specify a task [name][google.cloud.tasks.v2beta3.Task.name]. If a
875	// name is not specified then the system will generate a random
876	// unique task id, which will be set in the task returned in the
877	// [response][google.cloud.tasks.v2beta3.Task.name].
878	//
879	// If [schedule_time][google.cloud.tasks.v2beta3.Task.schedule_time] is not set or is in the
880	// past then Cloud Tasks will set it to the current time.
881	//
882	// Task De-duplication:
883	//
884	// Explicitly specifying a task ID enables task de-duplication.  If
885	// a task's ID is identical to that of an existing task or a task
886	// that was deleted or executed recently then the call will fail
887	// with [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS].
888	// If the task's queue was created using Cloud Tasks, then another task with
889	// the same name can't be created for ~1hour after the original task was
890	// deleted or executed. If the task's queue was created using queue.yaml or
891	// queue.xml, then another task with the same name can't be created
892	// for ~9days after the original task was deleted or executed.
893	//
894	// Because there is an extra lookup cost to identify duplicate task
895	// names, these [CreateTask][google.cloud.tasks.v2beta3.CloudTasks.CreateTask] calls have significantly
896	// increased latency. Using hashed strings for the task id or for
897	// the prefix of the task id is recommended. Choosing task ids that
898	// are sequential or have sequential prefixes, for example using a
899	// timestamp, causes an increase in latency and error rates in all
900	// task commands. The infrastructure relies on an approximately
901	// uniform distribution of task ids to store and serve tasks
902	// efficiently.
903	Task *Task `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
904	// The response_view specifies which subset of the [Task][google.cloud.tasks.v2beta3.Task] will be
905	// returned.
906	//
907	// By default response_view is [BASIC][google.cloud.tasks.v2beta3.Task.View.BASIC]; not all
908	// information is retrieved by default because some data, such as
909	// payloads, might be desirable to return only when needed because
910	// of its large size or because of the sensitivity of data that it
911	// contains.
912	//
913	// Authorization for [FULL][google.cloud.tasks.v2beta3.Task.View.FULL] requires
914	// `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/)
915	// permission on the [Task][google.cloud.tasks.v2beta3.Task] resource.
916	ResponseView Task_View `protobuf:"varint,3,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2beta3.Task_View" json:"response_view,omitempty"`
917}
918
919func (x *CreateTaskRequest) Reset() {
920	*x = CreateTaskRequest{}
921	if protoimpl.UnsafeEnabled {
922		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[12]
923		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
924		ms.StoreMessageInfo(mi)
925	}
926}
927
928func (x *CreateTaskRequest) String() string {
929	return protoimpl.X.MessageStringOf(x)
930}
931
932func (*CreateTaskRequest) ProtoMessage() {}
933
934func (x *CreateTaskRequest) ProtoReflect() protoreflect.Message {
935	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[12]
936	if protoimpl.UnsafeEnabled && x != nil {
937		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
938		if ms.LoadMessageInfo() == nil {
939			ms.StoreMessageInfo(mi)
940		}
941		return ms
942	}
943	return mi.MessageOf(x)
944}
945
946// Deprecated: Use CreateTaskRequest.ProtoReflect.Descriptor instead.
947func (*CreateTaskRequest) Descriptor() ([]byte, []int) {
948	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{12}
949}
950
951func (x *CreateTaskRequest) GetParent() string {
952	if x != nil {
953		return x.Parent
954	}
955	return ""
956}
957
958func (x *CreateTaskRequest) GetTask() *Task {
959	if x != nil {
960		return x.Task
961	}
962	return nil
963}
964
965func (x *CreateTaskRequest) GetResponseView() Task_View {
966	if x != nil {
967		return x.ResponseView
968	}
969	return Task_VIEW_UNSPECIFIED
970}
971
972// Request message for deleting a task using
973// [DeleteTask][google.cloud.tasks.v2beta3.CloudTasks.DeleteTask].
974type DeleteTaskRequest struct {
975	state         protoimpl.MessageState
976	sizeCache     protoimpl.SizeCache
977	unknownFields protoimpl.UnknownFields
978
979	// Required. The task name. For example:
980	// `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID`
981	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
982}
983
984func (x *DeleteTaskRequest) Reset() {
985	*x = DeleteTaskRequest{}
986	if protoimpl.UnsafeEnabled {
987		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[13]
988		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
989		ms.StoreMessageInfo(mi)
990	}
991}
992
993func (x *DeleteTaskRequest) String() string {
994	return protoimpl.X.MessageStringOf(x)
995}
996
997func (*DeleteTaskRequest) ProtoMessage() {}
998
999func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message {
1000	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[13]
1001	if protoimpl.UnsafeEnabled && x != nil {
1002		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1003		if ms.LoadMessageInfo() == nil {
1004			ms.StoreMessageInfo(mi)
1005		}
1006		return ms
1007	}
1008	return mi.MessageOf(x)
1009}
1010
1011// Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.
1012func (*DeleteTaskRequest) Descriptor() ([]byte, []int) {
1013	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{13}
1014}
1015
1016func (x *DeleteTaskRequest) GetName() string {
1017	if x != nil {
1018		return x.Name
1019	}
1020	return ""
1021}
1022
1023// Request message for forcing a task to run now using
1024// [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask].
1025type RunTaskRequest struct {
1026	state         protoimpl.MessageState
1027	sizeCache     protoimpl.SizeCache
1028	unknownFields protoimpl.UnknownFields
1029
1030	// Required. The task name. For example:
1031	// `projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID`
1032	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
1033	// The response_view specifies which subset of the [Task][google.cloud.tasks.v2beta3.Task] will be
1034	// returned.
1035	//
1036	// By default response_view is [BASIC][google.cloud.tasks.v2beta3.Task.View.BASIC]; not all
1037	// information is retrieved by default because some data, such as
1038	// payloads, might be desirable to return only when needed because
1039	// of its large size or because of the sensitivity of data that it
1040	// contains.
1041	//
1042	// Authorization for [FULL][google.cloud.tasks.v2beta3.Task.View.FULL] requires
1043	// `cloudtasks.tasks.fullView` [Google IAM](https://cloud.google.com/iam/)
1044	// permission on the [Task][google.cloud.tasks.v2beta3.Task] resource.
1045	ResponseView Task_View `protobuf:"varint,2,opt,name=response_view,json=responseView,proto3,enum=google.cloud.tasks.v2beta3.Task_View" json:"response_view,omitempty"`
1046}
1047
1048func (x *RunTaskRequest) Reset() {
1049	*x = RunTaskRequest{}
1050	if protoimpl.UnsafeEnabled {
1051		mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[14]
1052		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1053		ms.StoreMessageInfo(mi)
1054	}
1055}
1056
1057func (x *RunTaskRequest) String() string {
1058	return protoimpl.X.MessageStringOf(x)
1059}
1060
1061func (*RunTaskRequest) ProtoMessage() {}
1062
1063func (x *RunTaskRequest) ProtoReflect() protoreflect.Message {
1064	mi := &file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[14]
1065	if protoimpl.UnsafeEnabled && x != nil {
1066		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1067		if ms.LoadMessageInfo() == nil {
1068			ms.StoreMessageInfo(mi)
1069		}
1070		return ms
1071	}
1072	return mi.MessageOf(x)
1073}
1074
1075// Deprecated: Use RunTaskRequest.ProtoReflect.Descriptor instead.
1076func (*RunTaskRequest) Descriptor() ([]byte, []int) {
1077	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP(), []int{14}
1078}
1079
1080func (x *RunTaskRequest) GetName() string {
1081	if x != nil {
1082		return x.Name
1083	}
1084	return ""
1085}
1086
1087func (x *RunTaskRequest) GetResponseView() Task_View {
1088	if x != nil {
1089		return x.ResponseView
1090	}
1091	return Task_VIEW_UNSPECIFIED
1092}
1093
1094var File_google_cloud_tasks_v2beta3_cloudtasks_proto protoreflect.FileDescriptor
1095
1096var file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDesc = []byte{
1097	0x0a, 0x2b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x74,
1098	0x61, 0x73, 0x6b, 0x73, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x63, 0x6c, 0x6f,
1099	0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1a, 0x67,
1100	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b,
1101	0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
1102	0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e,
1103	0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f,
1104	0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
1105	0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65,
1106	0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74,
1107	0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65,
1108	0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x26, 0x67, 0x6f,
1109	0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x73,
1110	0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x2e, 0x70,
1111	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f,
1112	0x75, 0x64, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33,
1113	0x2f, 0x74, 0x61, 0x73, 0x6b, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f,
1114	0x67, 0x6c, 0x65, 0x2f, 0x69, 0x61, 0x6d, 0x2f, 0x76, 0x31, 0x2f, 0x69, 0x61, 0x6d, 0x5f, 0x70,
1115	0x6f, 0x6c, 0x69, 0x63, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1a, 0x67, 0x6f, 0x6f,
1116	0x67, 0x6c, 0x65, 0x2f, 0x69, 0x61, 0x6d, 0x2f, 0x76, 0x31, 0x2f, 0x70, 0x6f, 0x6c, 0x69, 0x63,
1117	0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f,
1118	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70,
1119	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x20, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f,
1120	0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b,
1121	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xe6, 0x01, 0x0a, 0x11, 0x4c, 0x69, 0x73, 0x74, 0x51,
1122	0x75, 0x65, 0x75, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3f, 0x0a, 0x06,
1123	0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41,
1124	0x02, 0xfa, 0x41, 0x21, 0x12, 0x1f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73,
1125	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
1126	0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x16, 0x0a,
1127	0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x66,
1128	0x69, 0x6c, 0x74, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69,
1129	0x7a, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69,
1130	0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e,
1131	0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65,
1132	0x6e, 0x12, 0x3c, 0x0a, 0x09, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x05,
1133	0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72,
1134	0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x4d, 0x61, 0x73, 0x6b,
1135	0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x08, 0x72, 0x65, 0x61, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x22,
1136	0x77, 0x0a, 0x12, 0x4c, 0x69, 0x73, 0x74, 0x51, 0x75, 0x65, 0x75, 0x65, 0x73, 0x52, 0x65, 0x73,
1137	0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x39, 0x0a, 0x06, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x18,
1138	0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
1139	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74,
1140	0x61, 0x33, 0x2e, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x06, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73,
1141	0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f,
1142	0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50,
1143	0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x8c, 0x01, 0x0a, 0x0f, 0x47, 0x65, 0x74,
1144	0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3b, 0x0a, 0x04,
1145	0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41, 0x02, 0xfa,
1146	0x41, 0x21, 0x0a, 0x1f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67,
1147	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x51, 0x75,
1148	0x65, 0x75, 0x65, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x3c, 0x0a, 0x09, 0x72, 0x65, 0x61,
1149	0x64, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67,
1150	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x46,
1151	0x69, 0x65, 0x6c, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x08, 0x72,
1152	0x65, 0x61, 0x64, 0x4d, 0x61, 0x73, 0x6b, 0x22, 0x93, 0x01, 0x0a, 0x12, 0x43, 0x72, 0x65, 0x61,
1153	0x74, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3f,
1154	0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x27,
1155	0xe0, 0x41, 0x02, 0xfa, 0x41, 0x21, 0x12, 0x1f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73,
1156	0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f,
1157	0x6d, 0x2f, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12,
1158	0x3c, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21,
1159	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61,
1160	0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x51, 0x75, 0x65, 0x75,
1161	0x65, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x05, 0x71, 0x75, 0x65, 0x75, 0x65, 0x22, 0x8f, 0x01,
1162	0x0a, 0x12, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x65, 0x71,
1163	0x75, 0x65, 0x73, 0x74, 0x12, 0x3c, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x75, 0x65, 0x18, 0x01, 0x20,
1164	0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
1165	0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33,
1166	0x2e, 0x51, 0x75, 0x65, 0x75, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x05, 0x71, 0x75, 0x65,
1167	0x75, 0x65, 0x12, 0x3b, 0x0a, 0x0b, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x6d, 0x61, 0x73,
1168	0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
1169	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x4d,
1170	0x61, 0x73, 0x6b, 0x52, 0x0a, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x73, 0x6b, 0x22,
1171	0x51, 0x0a, 0x12, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x65,
1172	0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3b, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20,
1173	0x01, 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x21, 0x0a, 0x1f, 0x63, 0x6c, 0x6f,
1174	0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70,
1175	0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x04, 0x6e, 0x61,
1176	0x6d, 0x65, 0x22, 0x50, 0x0a, 0x11, 0x50, 0x75, 0x72, 0x67, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65,
1177	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3b, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18,
1178	0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x21, 0x0a, 0x1f, 0x63,
1179	0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
1180	0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x04,
1181	0x6e, 0x61, 0x6d, 0x65, 0x22, 0x50, 0x0a, 0x11, 0x50, 0x61, 0x75, 0x73, 0x65, 0x51, 0x75, 0x65,
1182	0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3b, 0x0a, 0x04, 0x6e, 0x61, 0x6d,
1183	0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x21, 0x0a,
1184	0x1f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
1185	0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x51, 0x75, 0x65, 0x75, 0x65,
1186	0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x51, 0x0a, 0x12, 0x52, 0x65, 0x73, 0x75, 0x6d, 0x65,
1187	0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3b, 0x0a, 0x04,
1188	0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x27, 0xe0, 0x41, 0x02, 0xfa,
1189	0x41, 0x21, 0x0a, 0x1f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67,
1190	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x51, 0x75,
1191	0x65, 0x75, 0x65, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0xda, 0x01, 0x0a, 0x10, 0x4c, 0x69,
1192	0x73, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3e,
1193	0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x26,
1194	0xe0, 0x41, 0x02, 0xfa, 0x41, 0x20, 0x12, 0x1e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73,
1195	0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f,
1196	0x6d, 0x2f, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x4a,
1197	0x0a, 0x0d, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x76, 0x69, 0x65, 0x77, 0x18,
1198	0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
1199	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74,
1200	0x61, 0x33, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x2e, 0x56, 0x69, 0x65, 0x77, 0x52, 0x0c, 0x72, 0x65,
1201	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x56, 0x69, 0x65, 0x77, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61,
1202	0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70,
1203	0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f,
1204	0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67,
1205	0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x73, 0x0a, 0x11, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x61,
1206	0x73, 0x6b, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x36, 0x0a, 0x05, 0x74,
1207	0x61, 0x73, 0x6b, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x6f,
1208	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e,
1209	0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x05, 0x74, 0x61,
1210	0x73, 0x6b, 0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65,
1211	0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65,
1212	0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x98, 0x01, 0x0a, 0x0e,
1213	0x47, 0x65, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3a,
1214	0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x26, 0xe0, 0x41,
1215	0x02, 0xfa, 0x41, 0x20, 0x0a, 0x1e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73,
1216	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
1217	0x54, 0x61, 0x73, 0x6b, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x4a, 0x0a, 0x0d, 0x72, 0x65,
1218	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x76, 0x69, 0x65, 0x77, 0x18, 0x02, 0x20, 0x01, 0x28,
1219	0x0e, 0x32, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
1220	0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x54,
1221	0x61, 0x73, 0x6b, 0x2e, 0x56, 0x69, 0x65, 0x77, 0x52, 0x0c, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e,
1222	0x73, 0x65, 0x56, 0x69, 0x65, 0x77, 0x22, 0xda, 0x01, 0x0a, 0x11, 0x43, 0x72, 0x65, 0x61, 0x74,
1223	0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3e, 0x0a, 0x06,
1224	0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x26, 0xe0, 0x41,
1225	0x02, 0xfa, 0x41, 0x20, 0x12, 0x1e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73,
1226	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
1227	0x54, 0x61, 0x73, 0x6b, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x39, 0x0a, 0x04,
1228	0x74, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x6f,
1229	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e,
1230	0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x42, 0x03, 0xe0, 0x41,
1231	0x02, 0x52, 0x04, 0x74, 0x61, 0x73, 0x6b, 0x12, 0x4a, 0x0a, 0x0d, 0x72, 0x65, 0x73, 0x70, 0x6f,
1232	0x6e, 0x73, 0x65, 0x5f, 0x76, 0x69, 0x65, 0x77, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x25,
1233	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61,
1234	0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x54, 0x61, 0x73, 0x6b,
1235	0x2e, 0x56, 0x69, 0x65, 0x77, 0x52, 0x0c, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x56,
1236	0x69, 0x65, 0x77, 0x22, 0x4f, 0x0a, 0x11, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x54, 0x61, 0x73,
1237	0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3a, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65,
1238	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x26, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x20, 0x0a, 0x1e,
1239	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
1240	0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x04,
1241	0x6e, 0x61, 0x6d, 0x65, 0x22, 0x98, 0x01, 0x0a, 0x0e, 0x52, 0x75, 0x6e, 0x54, 0x61, 0x73, 0x6b,
1242	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3a, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18,
1243	0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x26, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x20, 0x0a, 0x1e, 0x63,
1244	0x6c, 0x6f, 0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
1245	0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x04, 0x6e,
1246	0x61, 0x6d, 0x65, 0x12, 0x4a, 0x0a, 0x0d, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f,
1247	0x76, 0x69, 0x65, 0x77, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x25, 0x2e, 0x67, 0x6f, 0x6f,
1248	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e,
1249	0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x2e, 0x56, 0x69, 0x65,
1250	0x77, 0x52, 0x0c, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x56, 0x69, 0x65, 0x77, 0x32,
1251	0xa5, 0x16, 0x0a, 0x0a, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12, 0xad,
1252	0x01, 0x0a, 0x0a, 0x4c, 0x69, 0x73, 0x74, 0x51, 0x75, 0x65, 0x75, 0x65, 0x73, 0x12, 0x2d, 0x2e,
1253	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73,
1254	0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x51,
1255	0x75, 0x65, 0x75, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2e, 0x2e, 0x67,
1256	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b,
1257	0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x51, 0x75,
1258	0x65, 0x75, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x40, 0x82, 0xd3,
1259	0xe4, 0x93, 0x02, 0x31, 0x12, 0x2f, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x7b,
1260	0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f,
1261	0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x71,
1262	0x75, 0x65, 0x75, 0x65, 0x73, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x9a,
1263	0x01, 0x0a, 0x08, 0x47, 0x65, 0x74, 0x51, 0x75, 0x65, 0x75, 0x65, 0x12, 0x2b, 0x2e, 0x67, 0x6f,
1264	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73,
1265	0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x47, 0x65, 0x74, 0x51, 0x75, 0x65, 0x75,
1266	0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x21, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
1267	0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32,
1268	0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x51, 0x75, 0x65, 0x75, 0x65, 0x22, 0x3e, 0x82, 0xd3, 0xe4,
1269	0x93, 0x02, 0x31, 0x12, 0x2f, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x7b, 0x6e,
1270	0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c,
1271	0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65,
1272	0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xaf, 0x01, 0x0a, 0x0b,
1273	0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x12, 0x2e, 0x2e, 0x67, 0x6f,
1274	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73,
1275	0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x51,
1276	0x75, 0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x21, 0x2e, 0x67, 0x6f,
1277	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73,
1278	0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x51, 0x75, 0x65, 0x75, 0x65, 0x22, 0x4d,
1279	0x82, 0xd3, 0xe4, 0x93, 0x02, 0x38, 0x22, 0x2f, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33,
1280	0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74,
1281	0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d,
1282	0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x3a, 0x05, 0x71, 0x75, 0x65, 0x75, 0x65, 0xda, 0x41,
1283	0x0c, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x71, 0x75, 0x65, 0x75, 0x65, 0x12, 0xba, 0x01,
1284	0x0a, 0x0b, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x12, 0x2e, 0x2e,
1285	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73,
1286	0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74,
1287	0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x21, 0x2e,
1288	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73,
1289	0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x51, 0x75, 0x65, 0x75, 0x65,
1290	0x22, 0x58, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3e, 0x32, 0x35, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74,
1291	0x61, 0x33, 0x2f, 0x7b, 0x71, 0x75, 0x65, 0x75, 0x65, 0x2e, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70,
1292	0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69,
1293	0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a,
1294	0x05, 0x71, 0x75, 0x65, 0x75, 0x65, 0xda, 0x41, 0x11, 0x71, 0x75, 0x65, 0x75, 0x65, 0x2c, 0x75,
1295	0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x6d, 0x61, 0x73, 0x6b, 0x12, 0x95, 0x01, 0x0a, 0x0b, 0x44,
1296	0x65, 0x6c, 0x65, 0x74, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x12, 0x2e, 0x2e, 0x67, 0x6f, 0x6f,
1297	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e,
1298	0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x51, 0x75,
1299	0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f,
1300	0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70,
1301	0x74, 0x79, 0x22, 0x3e, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x31, 0x2a, 0x2f, 0x2f, 0x76, 0x32, 0x62,
1302	0x65, 0x74, 0x61, 0x33, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65,
1303	0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f,
1304	0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61,
1305	0x6d, 0x65, 0x12, 0xa7, 0x01, 0x0a, 0x0a, 0x50, 0x75, 0x72, 0x67, 0x65, 0x51, 0x75, 0x65, 0x75,
1306	0x65, 0x12, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
1307	0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x50,
1308	0x75, 0x72, 0x67, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
1309	0x1a, 0x21, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
1310	0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x51, 0x75,
1311	0x65, 0x75, 0x65, 0x22, 0x47, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3a, 0x22, 0x35, 0x2f, 0x76, 0x32,
1312	0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a,
1313	0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73,
1314	0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x70, 0x75, 0x72,
1315	0x67, 0x65, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xa7, 0x01, 0x0a,
1316	0x0a, 0x50, 0x61, 0x75, 0x73, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x12, 0x2d, 0x2e, 0x67, 0x6f,
1317	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73,
1318	0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x50, 0x61, 0x75, 0x73, 0x65, 0x51, 0x75,
1319	0x65, 0x75, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x21, 0x2e, 0x67, 0x6f, 0x6f,
1320	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e,
1321	0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x51, 0x75, 0x65, 0x75, 0x65, 0x22, 0x47, 0x82,
1322	0xd3, 0xe4, 0x93, 0x02, 0x3a, 0x22, 0x35, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f,
1323	0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a,
1324	0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65,
1325	0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x70, 0x61, 0x75, 0x73, 0x65, 0x3a, 0x01, 0x2a, 0xda,
1326	0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0xaa, 0x01, 0x0a, 0x0b, 0x52, 0x65, 0x73, 0x75, 0x6d,
1327	0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x12, 0x2e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
1328	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65,
1329	0x74, 0x61, 0x33, 0x2e, 0x52, 0x65, 0x73, 0x75, 0x6d, 0x65, 0x51, 0x75, 0x65, 0x75, 0x65, 0x52,
1330	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x21, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
1331	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65,
1332	0x74, 0x61, 0x33, 0x2e, 0x51, 0x75, 0x65, 0x75, 0x65, 0x22, 0x48, 0x82, 0xd3, 0xe4, 0x93, 0x02,
1333	0x3b, 0x22, 0x36, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x7b, 0x6e, 0x61, 0x6d,
1334	0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63,
1335	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f,
1336	0x2a, 0x7d, 0x3a, 0x72, 0x65, 0x73, 0x75, 0x6d, 0x65, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x04, 0x6e,
1337	0x61, 0x6d, 0x65, 0x12, 0xa1, 0x01, 0x0a, 0x0c, 0x47, 0x65, 0x74, 0x49, 0x61, 0x6d, 0x50, 0x6f,
1338	0x6c, 0x69, 0x63, 0x79, 0x12, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x69, 0x61,
1339	0x6d, 0x2e, 0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x49, 0x61, 0x6d, 0x50, 0x6f, 0x6c, 0x69, 0x63,
1340	0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
1341	0x65, 0x2e, 0x69, 0x61, 0x6d, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x22,
1342	0x56, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x45, 0x22, 0x40, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61,
1343	0x33, 0x2f, 0x7b, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a,
1344	0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73,
1345	0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x67, 0x65, 0x74,
1346	0x49, 0x61, 0x6d, 0x50, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x08, 0x72,
1347	0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x12, 0xa8, 0x01, 0x0a, 0x0c, 0x53, 0x65, 0x74, 0x49,
1348	0x61, 0x6d, 0x50, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x12, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
1349	0x65, 0x2e, 0x69, 0x61, 0x6d, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x65, 0x74, 0x49, 0x61, 0x6d, 0x50,
1350	0x6f, 0x6c, 0x69, 0x63, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x15, 0x2e, 0x67,
1351	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x69, 0x61, 0x6d, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x6f, 0x6c,
1352	0x69, 0x63, 0x79, 0x22, 0x5d, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x45, 0x22, 0x40, 0x2f, 0x76, 0x32,
1353	0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x7b, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x3d,
1354	0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74,
1355	0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d,
1356	0x3a, 0x73, 0x65, 0x74, 0x49, 0x61, 0x6d, 0x50, 0x6f, 0x6c, 0x69, 0x63, 0x79, 0x3a, 0x01, 0x2a,
1357	0xda, 0x41, 0x0f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2c, 0x70, 0x6f, 0x6c, 0x69,
1358	0x63, 0x79, 0x12, 0xd3, 0x01, 0x0a, 0x12, 0x54, 0x65, 0x73, 0x74, 0x49, 0x61, 0x6d, 0x50, 0x65,
1359	0x72, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
1360	0x6c, 0x65, 0x2e, 0x69, 0x61, 0x6d, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x65, 0x73, 0x74, 0x49, 0x61,
1361	0x6d, 0x50, 0x65, 0x72, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75,
1362	0x65, 0x73, 0x74, 0x1a, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x69, 0x61, 0x6d,
1363	0x2e, 0x76, 0x31, 0x2e, 0x54, 0x65, 0x73, 0x74, 0x49, 0x61, 0x6d, 0x50, 0x65, 0x72, 0x6d, 0x69,
1364	0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x68,
1365	0x82, 0xd3, 0xe4, 0x93, 0x02, 0x4b, 0x22, 0x46, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33,
1366	0x2f, 0x7b, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65,
1367	0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f,
1368	0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x74, 0x65, 0x73, 0x74,
1369	0x49, 0x61, 0x6d, 0x50, 0x65, 0x72, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x3a, 0x01,
1370	0x2a, 0xda, 0x41, 0x14, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2c, 0x70, 0x65, 0x72,
1371	0x6d, 0x69, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0xb2, 0x01, 0x0a, 0x09, 0x4c, 0x69, 0x73,
1372	0x74, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
1373	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65,
1374	0x74, 0x61, 0x33, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x52, 0x65, 0x71,
1375	0x75, 0x65, 0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
1376	0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61,
1377	0x33, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f,
1378	0x6e, 0x73, 0x65, 0x22, 0x48, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x39, 0x12, 0x37, 0x2f, 0x76, 0x32,
1379	0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72,
1380	0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f,
1381	0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x74,
1382	0x61, 0x73, 0x6b, 0x73, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x9f, 0x01,
1383	0x0a, 0x07, 0x47, 0x65, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
1384	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76,
1385	0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x47, 0x65, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65,
1386	0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x20, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
1387	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74,
1388	0x61, 0x33, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x22, 0x46, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x39, 0x12,
1389	0x37, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d,
1390	0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74,
1391	0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x2f,
1392	0x74, 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12,
1393	0xaf, 0x01, 0x0a, 0x0a, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x2d,
1394	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61,
1395	0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x43, 0x72, 0x65, 0x61,
1396	0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x20, 0x2e,
1397	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73,
1398	0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x22,
1399	0x50, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3c, 0x22, 0x37, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61,
1400	0x33, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
1401	0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a,
1402	0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x73,
1403	0x3a, 0x01, 0x2a, 0xda, 0x41, 0x0b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x74, 0x61, 0x73,
1404	0x6b, 0x12, 0x9b, 0x01, 0x0a, 0x0a, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b,
1405	0x12, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
1406	0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x44, 0x65,
1407	0x6c, 0x65, 0x74, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
1408	0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75,
1409	0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x46, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x39, 0x2a,
1410	0x37, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d,
1411	0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74,
1412	0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f, 0x2a, 0x2f,
1413	0x74, 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12,
1414	0xa6, 0x01, 0x0a, 0x07, 0x52, 0x75, 0x6e, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x2a, 0x2e, 0x67, 0x6f,
1415	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73,
1416	0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2e, 0x52, 0x75, 0x6e, 0x54, 0x61, 0x73, 0x6b,
1417	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x20, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
1418	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x76, 0x32, 0x62,
1419	0x65, 0x74, 0x61, 0x33, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x22, 0x4d, 0x82, 0xd3, 0xe4, 0x93, 0x02,
1420	0x40, 0x22, 0x3b, 0x2f, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x2f, 0x7b, 0x6e, 0x61, 0x6d,
1421	0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63,
1422	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x71, 0x75, 0x65, 0x75, 0x65, 0x73, 0x2f,
1423	0x2a, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x72, 0x75, 0x6e, 0x3a, 0x01,
1424	0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x1a, 0x4d, 0xca, 0x41, 0x19, 0x63, 0x6c, 0x6f,
1425	0x75, 0x64, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70,
1426	0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x2e, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f,
1427	0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e,
1428	0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70,
1429	0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x42, 0x7c, 0x0a, 0x1e, 0x63, 0x6f, 0x6d, 0x2e, 0x67,
1430	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x74, 0x61, 0x73, 0x6b,
1431	0x73, 0x2e, 0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x42, 0x0f, 0x43, 0x6c, 0x6f, 0x75, 0x64,
1432	0x54, 0x61, 0x73, 0x6b, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x3f, 0x67, 0x6f,
1433	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f,
1434	0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61,
1435	0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2f,
1436	0x76, 0x32, 0x62, 0x65, 0x74, 0x61, 0x33, 0x3b, 0x74, 0x61, 0x73, 0x6b, 0x73, 0xa2, 0x02, 0x05,
1437	0x54, 0x41, 0x53, 0x4b, 0x53, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
1438}
1439
1440var (
1441	file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescOnce sync.Once
1442	file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescData = file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDesc
1443)
1444
1445func file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescGZIP() []byte {
1446	file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescOnce.Do(func() {
1447		file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescData)
1448	})
1449	return file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDescData
1450}
1451
1452var file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes = make([]protoimpl.MessageInfo, 15)
1453var file_google_cloud_tasks_v2beta3_cloudtasks_proto_goTypes = []interface{}{
1454	(*ListQueuesRequest)(nil),             // 0: google.cloud.tasks.v2beta3.ListQueuesRequest
1455	(*ListQueuesResponse)(nil),            // 1: google.cloud.tasks.v2beta3.ListQueuesResponse
1456	(*GetQueueRequest)(nil),               // 2: google.cloud.tasks.v2beta3.GetQueueRequest
1457	(*CreateQueueRequest)(nil),            // 3: google.cloud.tasks.v2beta3.CreateQueueRequest
1458	(*UpdateQueueRequest)(nil),            // 4: google.cloud.tasks.v2beta3.UpdateQueueRequest
1459	(*DeleteQueueRequest)(nil),            // 5: google.cloud.tasks.v2beta3.DeleteQueueRequest
1460	(*PurgeQueueRequest)(nil),             // 6: google.cloud.tasks.v2beta3.PurgeQueueRequest
1461	(*PauseQueueRequest)(nil),             // 7: google.cloud.tasks.v2beta3.PauseQueueRequest
1462	(*ResumeQueueRequest)(nil),            // 8: google.cloud.tasks.v2beta3.ResumeQueueRequest
1463	(*ListTasksRequest)(nil),              // 9: google.cloud.tasks.v2beta3.ListTasksRequest
1464	(*ListTasksResponse)(nil),             // 10: google.cloud.tasks.v2beta3.ListTasksResponse
1465	(*GetTaskRequest)(nil),                // 11: google.cloud.tasks.v2beta3.GetTaskRequest
1466	(*CreateTaskRequest)(nil),             // 12: google.cloud.tasks.v2beta3.CreateTaskRequest
1467	(*DeleteTaskRequest)(nil),             // 13: google.cloud.tasks.v2beta3.DeleteTaskRequest
1468	(*RunTaskRequest)(nil),                // 14: google.cloud.tasks.v2beta3.RunTaskRequest
1469	(*fieldmaskpb.FieldMask)(nil),         // 15: google.protobuf.FieldMask
1470	(*Queue)(nil),                         // 16: google.cloud.tasks.v2beta3.Queue
1471	(Task_View)(0),                        // 17: google.cloud.tasks.v2beta3.Task.View
1472	(*Task)(nil),                          // 18: google.cloud.tasks.v2beta3.Task
1473	(*v1.GetIamPolicyRequest)(nil),        // 19: google.iam.v1.GetIamPolicyRequest
1474	(*v1.SetIamPolicyRequest)(nil),        // 20: google.iam.v1.SetIamPolicyRequest
1475	(*v1.TestIamPermissionsRequest)(nil),  // 21: google.iam.v1.TestIamPermissionsRequest
1476	(*emptypb.Empty)(nil),                 // 22: google.protobuf.Empty
1477	(*v1.Policy)(nil),                     // 23: google.iam.v1.Policy
1478	(*v1.TestIamPermissionsResponse)(nil), // 24: google.iam.v1.TestIamPermissionsResponse
1479}
1480var file_google_cloud_tasks_v2beta3_cloudtasks_proto_depIdxs = []int32{
1481	15, // 0: google.cloud.tasks.v2beta3.ListQueuesRequest.read_mask:type_name -> google.protobuf.FieldMask
1482	16, // 1: google.cloud.tasks.v2beta3.ListQueuesResponse.queues:type_name -> google.cloud.tasks.v2beta3.Queue
1483	15, // 2: google.cloud.tasks.v2beta3.GetQueueRequest.read_mask:type_name -> google.protobuf.FieldMask
1484	16, // 3: google.cloud.tasks.v2beta3.CreateQueueRequest.queue:type_name -> google.cloud.tasks.v2beta3.Queue
1485	16, // 4: google.cloud.tasks.v2beta3.UpdateQueueRequest.queue:type_name -> google.cloud.tasks.v2beta3.Queue
1486	15, // 5: google.cloud.tasks.v2beta3.UpdateQueueRequest.update_mask:type_name -> google.protobuf.FieldMask
1487	17, // 6: google.cloud.tasks.v2beta3.ListTasksRequest.response_view:type_name -> google.cloud.tasks.v2beta3.Task.View
1488	18, // 7: google.cloud.tasks.v2beta3.ListTasksResponse.tasks:type_name -> google.cloud.tasks.v2beta3.Task
1489	17, // 8: google.cloud.tasks.v2beta3.GetTaskRequest.response_view:type_name -> google.cloud.tasks.v2beta3.Task.View
1490	18, // 9: google.cloud.tasks.v2beta3.CreateTaskRequest.task:type_name -> google.cloud.tasks.v2beta3.Task
1491	17, // 10: google.cloud.tasks.v2beta3.CreateTaskRequest.response_view:type_name -> google.cloud.tasks.v2beta3.Task.View
1492	17, // 11: google.cloud.tasks.v2beta3.RunTaskRequest.response_view:type_name -> google.cloud.tasks.v2beta3.Task.View
1493	0,  // 12: google.cloud.tasks.v2beta3.CloudTasks.ListQueues:input_type -> google.cloud.tasks.v2beta3.ListQueuesRequest
1494	2,  // 13: google.cloud.tasks.v2beta3.CloudTasks.GetQueue:input_type -> google.cloud.tasks.v2beta3.GetQueueRequest
1495	3,  // 14: google.cloud.tasks.v2beta3.CloudTasks.CreateQueue:input_type -> google.cloud.tasks.v2beta3.CreateQueueRequest
1496	4,  // 15: google.cloud.tasks.v2beta3.CloudTasks.UpdateQueue:input_type -> google.cloud.tasks.v2beta3.UpdateQueueRequest
1497	5,  // 16: google.cloud.tasks.v2beta3.CloudTasks.DeleteQueue:input_type -> google.cloud.tasks.v2beta3.DeleteQueueRequest
1498	6,  // 17: google.cloud.tasks.v2beta3.CloudTasks.PurgeQueue:input_type -> google.cloud.tasks.v2beta3.PurgeQueueRequest
1499	7,  // 18: google.cloud.tasks.v2beta3.CloudTasks.PauseQueue:input_type -> google.cloud.tasks.v2beta3.PauseQueueRequest
1500	8,  // 19: google.cloud.tasks.v2beta3.CloudTasks.ResumeQueue:input_type -> google.cloud.tasks.v2beta3.ResumeQueueRequest
1501	19, // 20: google.cloud.tasks.v2beta3.CloudTasks.GetIamPolicy:input_type -> google.iam.v1.GetIamPolicyRequest
1502	20, // 21: google.cloud.tasks.v2beta3.CloudTasks.SetIamPolicy:input_type -> google.iam.v1.SetIamPolicyRequest
1503	21, // 22: google.cloud.tasks.v2beta3.CloudTasks.TestIamPermissions:input_type -> google.iam.v1.TestIamPermissionsRequest
1504	9,  // 23: google.cloud.tasks.v2beta3.CloudTasks.ListTasks:input_type -> google.cloud.tasks.v2beta3.ListTasksRequest
1505	11, // 24: google.cloud.tasks.v2beta3.CloudTasks.GetTask:input_type -> google.cloud.tasks.v2beta3.GetTaskRequest
1506	12, // 25: google.cloud.tasks.v2beta3.CloudTasks.CreateTask:input_type -> google.cloud.tasks.v2beta3.CreateTaskRequest
1507	13, // 26: google.cloud.tasks.v2beta3.CloudTasks.DeleteTask:input_type -> google.cloud.tasks.v2beta3.DeleteTaskRequest
1508	14, // 27: google.cloud.tasks.v2beta3.CloudTasks.RunTask:input_type -> google.cloud.tasks.v2beta3.RunTaskRequest
1509	1,  // 28: google.cloud.tasks.v2beta3.CloudTasks.ListQueues:output_type -> google.cloud.tasks.v2beta3.ListQueuesResponse
1510	16, // 29: google.cloud.tasks.v2beta3.CloudTasks.GetQueue:output_type -> google.cloud.tasks.v2beta3.Queue
1511	16, // 30: google.cloud.tasks.v2beta3.CloudTasks.CreateQueue:output_type -> google.cloud.tasks.v2beta3.Queue
1512	16, // 31: google.cloud.tasks.v2beta3.CloudTasks.UpdateQueue:output_type -> google.cloud.tasks.v2beta3.Queue
1513	22, // 32: google.cloud.tasks.v2beta3.CloudTasks.DeleteQueue:output_type -> google.protobuf.Empty
1514	16, // 33: google.cloud.tasks.v2beta3.CloudTasks.PurgeQueue:output_type -> google.cloud.tasks.v2beta3.Queue
1515	16, // 34: google.cloud.tasks.v2beta3.CloudTasks.PauseQueue:output_type -> google.cloud.tasks.v2beta3.Queue
1516	16, // 35: google.cloud.tasks.v2beta3.CloudTasks.ResumeQueue:output_type -> google.cloud.tasks.v2beta3.Queue
1517	23, // 36: google.cloud.tasks.v2beta3.CloudTasks.GetIamPolicy:output_type -> google.iam.v1.Policy
1518	23, // 37: google.cloud.tasks.v2beta3.CloudTasks.SetIamPolicy:output_type -> google.iam.v1.Policy
1519	24, // 38: google.cloud.tasks.v2beta3.CloudTasks.TestIamPermissions:output_type -> google.iam.v1.TestIamPermissionsResponse
1520	10, // 39: google.cloud.tasks.v2beta3.CloudTasks.ListTasks:output_type -> google.cloud.tasks.v2beta3.ListTasksResponse
1521	18, // 40: google.cloud.tasks.v2beta3.CloudTasks.GetTask:output_type -> google.cloud.tasks.v2beta3.Task
1522	18, // 41: google.cloud.tasks.v2beta3.CloudTasks.CreateTask:output_type -> google.cloud.tasks.v2beta3.Task
1523	22, // 42: google.cloud.tasks.v2beta3.CloudTasks.DeleteTask:output_type -> google.protobuf.Empty
1524	18, // 43: google.cloud.tasks.v2beta3.CloudTasks.RunTask:output_type -> google.cloud.tasks.v2beta3.Task
1525	28, // [28:44] is the sub-list for method output_type
1526	12, // [12:28] is the sub-list for method input_type
1527	12, // [12:12] is the sub-list for extension type_name
1528	12, // [12:12] is the sub-list for extension extendee
1529	0,  // [0:12] is the sub-list for field type_name
1530}
1531
1532func init() { file_google_cloud_tasks_v2beta3_cloudtasks_proto_init() }
1533func file_google_cloud_tasks_v2beta3_cloudtasks_proto_init() {
1534	if File_google_cloud_tasks_v2beta3_cloudtasks_proto != nil {
1535		return
1536	}
1537	file_google_cloud_tasks_v2beta3_queue_proto_init()
1538	file_google_cloud_tasks_v2beta3_task_proto_init()
1539	if !protoimpl.UnsafeEnabled {
1540		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
1541			switch v := v.(*ListQueuesRequest); i {
1542			case 0:
1543				return &v.state
1544			case 1:
1545				return &v.sizeCache
1546			case 2:
1547				return &v.unknownFields
1548			default:
1549				return nil
1550			}
1551		}
1552		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
1553			switch v := v.(*ListQueuesResponse); i {
1554			case 0:
1555				return &v.state
1556			case 1:
1557				return &v.sizeCache
1558			case 2:
1559				return &v.unknownFields
1560			default:
1561				return nil
1562			}
1563		}
1564		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
1565			switch v := v.(*GetQueueRequest); i {
1566			case 0:
1567				return &v.state
1568			case 1:
1569				return &v.sizeCache
1570			case 2:
1571				return &v.unknownFields
1572			default:
1573				return nil
1574			}
1575		}
1576		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
1577			switch v := v.(*CreateQueueRequest); i {
1578			case 0:
1579				return &v.state
1580			case 1:
1581				return &v.sizeCache
1582			case 2:
1583				return &v.unknownFields
1584			default:
1585				return nil
1586			}
1587		}
1588		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
1589			switch v := v.(*UpdateQueueRequest); i {
1590			case 0:
1591				return &v.state
1592			case 1:
1593				return &v.sizeCache
1594			case 2:
1595				return &v.unknownFields
1596			default:
1597				return nil
1598			}
1599		}
1600		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
1601			switch v := v.(*DeleteQueueRequest); i {
1602			case 0:
1603				return &v.state
1604			case 1:
1605				return &v.sizeCache
1606			case 2:
1607				return &v.unknownFields
1608			default:
1609				return nil
1610			}
1611		}
1612		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
1613			switch v := v.(*PurgeQueueRequest); i {
1614			case 0:
1615				return &v.state
1616			case 1:
1617				return &v.sizeCache
1618			case 2:
1619				return &v.unknownFields
1620			default:
1621				return nil
1622			}
1623		}
1624		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
1625			switch v := v.(*PauseQueueRequest); i {
1626			case 0:
1627				return &v.state
1628			case 1:
1629				return &v.sizeCache
1630			case 2:
1631				return &v.unknownFields
1632			default:
1633				return nil
1634			}
1635		}
1636		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
1637			switch v := v.(*ResumeQueueRequest); i {
1638			case 0:
1639				return &v.state
1640			case 1:
1641				return &v.sizeCache
1642			case 2:
1643				return &v.unknownFields
1644			default:
1645				return nil
1646			}
1647		}
1648		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
1649			switch v := v.(*ListTasksRequest); i {
1650			case 0:
1651				return &v.state
1652			case 1:
1653				return &v.sizeCache
1654			case 2:
1655				return &v.unknownFields
1656			default:
1657				return nil
1658			}
1659		}
1660		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
1661			switch v := v.(*ListTasksResponse); i {
1662			case 0:
1663				return &v.state
1664			case 1:
1665				return &v.sizeCache
1666			case 2:
1667				return &v.unknownFields
1668			default:
1669				return nil
1670			}
1671		}
1672		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
1673			switch v := v.(*GetTaskRequest); i {
1674			case 0:
1675				return &v.state
1676			case 1:
1677				return &v.sizeCache
1678			case 2:
1679				return &v.unknownFields
1680			default:
1681				return nil
1682			}
1683		}
1684		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
1685			switch v := v.(*CreateTaskRequest); i {
1686			case 0:
1687				return &v.state
1688			case 1:
1689				return &v.sizeCache
1690			case 2:
1691				return &v.unknownFields
1692			default:
1693				return nil
1694			}
1695		}
1696		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
1697			switch v := v.(*DeleteTaskRequest); i {
1698			case 0:
1699				return &v.state
1700			case 1:
1701				return &v.sizeCache
1702			case 2:
1703				return &v.unknownFields
1704			default:
1705				return nil
1706			}
1707		}
1708		file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
1709			switch v := v.(*RunTaskRequest); i {
1710			case 0:
1711				return &v.state
1712			case 1:
1713				return &v.sizeCache
1714			case 2:
1715				return &v.unknownFields
1716			default:
1717				return nil
1718			}
1719		}
1720	}
1721	type x struct{}
1722	out := protoimpl.TypeBuilder{
1723		File: protoimpl.DescBuilder{
1724			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
1725			RawDescriptor: file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDesc,
1726			NumEnums:      0,
1727			NumMessages:   15,
1728			NumExtensions: 0,
1729			NumServices:   1,
1730		},
1731		GoTypes:           file_google_cloud_tasks_v2beta3_cloudtasks_proto_goTypes,
1732		DependencyIndexes: file_google_cloud_tasks_v2beta3_cloudtasks_proto_depIdxs,
1733		MessageInfos:      file_google_cloud_tasks_v2beta3_cloudtasks_proto_msgTypes,
1734	}.Build()
1735	File_google_cloud_tasks_v2beta3_cloudtasks_proto = out.File
1736	file_google_cloud_tasks_v2beta3_cloudtasks_proto_rawDesc = nil
1737	file_google_cloud_tasks_v2beta3_cloudtasks_proto_goTypes = nil
1738	file_google_cloud_tasks_v2beta3_cloudtasks_proto_depIdxs = nil
1739}
1740
1741// Reference imports to suppress errors if they are not otherwise used.
1742var _ context.Context
1743var _ grpc.ClientConnInterface
1744
1745// This is a compile-time assertion to ensure that this generated file
1746// is compatible with the grpc package it is being compiled against.
1747const _ = grpc.SupportPackageIsVersion6
1748
1749// CloudTasksClient is the client API for CloudTasks service.
1750//
1751// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
1752type CloudTasksClient interface {
1753	// Lists queues.
1754	//
1755	// Queues are returned in lexicographical order.
1756	ListQueues(ctx context.Context, in *ListQueuesRequest, opts ...grpc.CallOption) (*ListQueuesResponse, error)
1757	// Gets a queue.
1758	GetQueue(ctx context.Context, in *GetQueueRequest, opts ...grpc.CallOption) (*Queue, error)
1759	// Creates a queue.
1760	//
1761	// Queues created with this method allow tasks to live for a maximum of 31
1762	// days. After a task is 31 days old, the task will be deleted regardless of whether
1763	// it was dispatched or not.
1764	//
1765	// WARNING: Using this method may have unintended side effects if you are
1766	// using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
1767	// Read
1768	// [Overview of Queue Management and
1769	// queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using
1770	// this method.
1771	CreateQueue(ctx context.Context, in *CreateQueueRequest, opts ...grpc.CallOption) (*Queue, error)
1772	// Updates a queue.
1773	//
1774	// This method creates the queue if it does not exist and updates
1775	// the queue if it does exist.
1776	//
1777	// Queues created with this method allow tasks to live for a maximum of 31
1778	// days. After a task is 31 days old, the task will be deleted regardless of whether
1779	// it was dispatched or not.
1780	//
1781	// WARNING: Using this method may have unintended side effects if you are
1782	// using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
1783	// Read
1784	// [Overview of Queue Management and
1785	// queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using
1786	// this method.
1787	UpdateQueue(ctx context.Context, in *UpdateQueueRequest, opts ...grpc.CallOption) (*Queue, error)
1788	// Deletes a queue.
1789	//
1790	// This command will delete the queue even if it has tasks in it.
1791	//
1792	// Note: If you delete a queue, a queue with the same name can't be created
1793	// for 7 days.
1794	//
1795	// WARNING: Using this method may have unintended side effects if you are
1796	// using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
1797	// Read
1798	// [Overview of Queue Management and
1799	// queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using
1800	// this method.
1801	DeleteQueue(ctx context.Context, in *DeleteQueueRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
1802	// Purges a queue by deleting all of its tasks.
1803	//
1804	// All tasks created before this method is called are permanently deleted.
1805	//
1806	// Purge operations can take up to one minute to take effect. Tasks
1807	// might be dispatched before the purge takes effect. A purge is irreversible.
1808	PurgeQueue(ctx context.Context, in *PurgeQueueRequest, opts ...grpc.CallOption) (*Queue, error)
1809	// Pauses the queue.
1810	//
1811	// If a queue is paused then the system will stop dispatching tasks
1812	// until the queue is resumed via
1813	// [ResumeQueue][google.cloud.tasks.v2beta3.CloudTasks.ResumeQueue]. Tasks can still be added
1814	// when the queue is paused. A queue is paused if its
1815	// [state][google.cloud.tasks.v2beta3.Queue.state] is [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED].
1816	PauseQueue(ctx context.Context, in *PauseQueueRequest, opts ...grpc.CallOption) (*Queue, error)
1817	// Resume a queue.
1818	//
1819	// This method resumes a queue after it has been
1820	// [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED] or
1821	// [DISABLED][google.cloud.tasks.v2beta3.Queue.State.DISABLED]. The state of a queue is stored
1822	// in the queue's [state][google.cloud.tasks.v2beta3.Queue.state]; after calling this method it
1823	// will be set to [RUNNING][google.cloud.tasks.v2beta3.Queue.State.RUNNING].
1824	//
1825	// WARNING: Resuming many high-QPS queues at the same time can
1826	// lead to target overloading. If you are resuming high-QPS
1827	// queues, follow the 500/50/5 pattern described in
1828	// [Managing Cloud Tasks Scaling
1829	// Risks](https://cloud.google.com/tasks/docs/manage-cloud-task-scaling).
1830	ResumeQueue(ctx context.Context, in *ResumeQueueRequest, opts ...grpc.CallOption) (*Queue, error)
1831	// Gets the access control policy for a [Queue][google.cloud.tasks.v2beta3.Queue].
1832	// Returns an empty policy if the resource exists and does not have a policy
1833	// set.
1834	//
1835	// Authorization requires the following
1836	// [Google IAM](https://cloud.google.com/iam) permission on the specified
1837	// resource parent:
1838	//
1839	// * `cloudtasks.queues.getIamPolicy`
1840	GetIamPolicy(ctx context.Context, in *v1.GetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error)
1841	// Sets the access control policy for a [Queue][google.cloud.tasks.v2beta3.Queue]. Replaces any existing
1842	// policy.
1843	//
1844	// Note: The Cloud Console does not check queue-level IAM permissions yet.
1845	// Project-level permissions are required to use the Cloud Console.
1846	//
1847	// Authorization requires the following
1848	// [Google IAM](https://cloud.google.com/iam) permission on the specified
1849	// resource parent:
1850	//
1851	// * `cloudtasks.queues.setIamPolicy`
1852	SetIamPolicy(ctx context.Context, in *v1.SetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error)
1853	// Returns permissions that a caller has on a [Queue][google.cloud.tasks.v2beta3.Queue].
1854	// If the resource does not exist, this will return an empty set of
1855	// permissions, not a [NOT_FOUND][google.rpc.Code.NOT_FOUND] error.
1856	//
1857	// Note: This operation is designed to be used for building permission-aware
1858	// UIs and command-line tools, not for authorization checking. This operation
1859	// may "fail open" without warning.
1860	TestIamPermissions(ctx context.Context, in *v1.TestIamPermissionsRequest, opts ...grpc.CallOption) (*v1.TestIamPermissionsResponse, error)
1861	// Lists the tasks in a queue.
1862	//
1863	// By default, only the [BASIC][google.cloud.tasks.v2beta3.Task.View.BASIC] view is retrieved
1864	// due to performance considerations;
1865	// [response_view][google.cloud.tasks.v2beta3.ListTasksRequest.response_view] controls the
1866	// subset of information which is returned.
1867	//
1868	// The tasks may be returned in any order. The ordering may change at any
1869	// time.
1870	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
1871	// Gets a task.
1872	GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error)
1873	// Creates a task and adds it to a queue.
1874	//
1875	// Tasks cannot be updated after creation; there is no UpdateTask command.
1876	//
1877	// * The maximum task size is 100KB.
1878	CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*Task, error)
1879	// Deletes a task.
1880	//
1881	// A task can be deleted if it is scheduled or dispatched. A task
1882	// cannot be deleted if it has executed successfully or permanently
1883	// failed.
1884	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
1885	// Forces a task to run now.
1886	//
1887	// When this method is called, Cloud Tasks will dispatch the task, even if
1888	// the task is already running, the queue has reached its [RateLimits][google.cloud.tasks.v2beta3.RateLimits] or
1889	// is [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED].
1890	//
1891	// This command is meant to be used for manual debugging. For
1892	// example, [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] can be used to retry a failed
1893	// task after a fix has been made or to manually force a task to be
1894	// dispatched now.
1895	//
1896	// The dispatched task is returned. That is, the task that is returned
1897	// contains the [status][Task.status] after the task is dispatched but
1898	// before the task is received by its target.
1899	//
1900	// If Cloud Tasks receives a successful response from the task's
1901	// target, then the task will be deleted; otherwise the task's
1902	// [schedule_time][google.cloud.tasks.v2beta3.Task.schedule_time] will be reset to the time that
1903	// [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] was called plus the retry delay specified
1904	// in the queue's [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
1905	//
1906	// [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] returns
1907	// [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a
1908	// task that has already succeeded or permanently failed.
1909	RunTask(ctx context.Context, in *RunTaskRequest, opts ...grpc.CallOption) (*Task, error)
1910}
1911
1912type cloudTasksClient struct {
1913	cc grpc.ClientConnInterface
1914}
1915
1916func NewCloudTasksClient(cc grpc.ClientConnInterface) CloudTasksClient {
1917	return &cloudTasksClient{cc}
1918}
1919
1920func (c *cloudTasksClient) ListQueues(ctx context.Context, in *ListQueuesRequest, opts ...grpc.CallOption) (*ListQueuesResponse, error) {
1921	out := new(ListQueuesResponse)
1922	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/ListQueues", in, out, opts...)
1923	if err != nil {
1924		return nil, err
1925	}
1926	return out, nil
1927}
1928
1929func (c *cloudTasksClient) GetQueue(ctx context.Context, in *GetQueueRequest, opts ...grpc.CallOption) (*Queue, error) {
1930	out := new(Queue)
1931	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/GetQueue", in, out, opts...)
1932	if err != nil {
1933		return nil, err
1934	}
1935	return out, nil
1936}
1937
1938func (c *cloudTasksClient) CreateQueue(ctx context.Context, in *CreateQueueRequest, opts ...grpc.CallOption) (*Queue, error) {
1939	out := new(Queue)
1940	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/CreateQueue", in, out, opts...)
1941	if err != nil {
1942		return nil, err
1943	}
1944	return out, nil
1945}
1946
1947func (c *cloudTasksClient) UpdateQueue(ctx context.Context, in *UpdateQueueRequest, opts ...grpc.CallOption) (*Queue, error) {
1948	out := new(Queue)
1949	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/UpdateQueue", in, out, opts...)
1950	if err != nil {
1951		return nil, err
1952	}
1953	return out, nil
1954}
1955
1956func (c *cloudTasksClient) DeleteQueue(ctx context.Context, in *DeleteQueueRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
1957	out := new(emptypb.Empty)
1958	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/DeleteQueue", in, out, opts...)
1959	if err != nil {
1960		return nil, err
1961	}
1962	return out, nil
1963}
1964
1965func (c *cloudTasksClient) PurgeQueue(ctx context.Context, in *PurgeQueueRequest, opts ...grpc.CallOption) (*Queue, error) {
1966	out := new(Queue)
1967	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/PurgeQueue", in, out, opts...)
1968	if err != nil {
1969		return nil, err
1970	}
1971	return out, nil
1972}
1973
1974func (c *cloudTasksClient) PauseQueue(ctx context.Context, in *PauseQueueRequest, opts ...grpc.CallOption) (*Queue, error) {
1975	out := new(Queue)
1976	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/PauseQueue", in, out, opts...)
1977	if err != nil {
1978		return nil, err
1979	}
1980	return out, nil
1981}
1982
1983func (c *cloudTasksClient) ResumeQueue(ctx context.Context, in *ResumeQueueRequest, opts ...grpc.CallOption) (*Queue, error) {
1984	out := new(Queue)
1985	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/ResumeQueue", in, out, opts...)
1986	if err != nil {
1987		return nil, err
1988	}
1989	return out, nil
1990}
1991
1992func (c *cloudTasksClient) GetIamPolicy(ctx context.Context, in *v1.GetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error) {
1993	out := new(v1.Policy)
1994	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/GetIamPolicy", in, out, opts...)
1995	if err != nil {
1996		return nil, err
1997	}
1998	return out, nil
1999}
2000
2001func (c *cloudTasksClient) SetIamPolicy(ctx context.Context, in *v1.SetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error) {
2002	out := new(v1.Policy)
2003	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/SetIamPolicy", in, out, opts...)
2004	if err != nil {
2005		return nil, err
2006	}
2007	return out, nil
2008}
2009
2010func (c *cloudTasksClient) TestIamPermissions(ctx context.Context, in *v1.TestIamPermissionsRequest, opts ...grpc.CallOption) (*v1.TestIamPermissionsResponse, error) {
2011	out := new(v1.TestIamPermissionsResponse)
2012	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/TestIamPermissions", in, out, opts...)
2013	if err != nil {
2014		return nil, err
2015	}
2016	return out, nil
2017}
2018
2019func (c *cloudTasksClient) ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error) {
2020	out := new(ListTasksResponse)
2021	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/ListTasks", in, out, opts...)
2022	if err != nil {
2023		return nil, err
2024	}
2025	return out, nil
2026}
2027
2028func (c *cloudTasksClient) GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error) {
2029	out := new(Task)
2030	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/GetTask", in, out, opts...)
2031	if err != nil {
2032		return nil, err
2033	}
2034	return out, nil
2035}
2036
2037func (c *cloudTasksClient) CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*Task, error) {
2038	out := new(Task)
2039	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/CreateTask", in, out, opts...)
2040	if err != nil {
2041		return nil, err
2042	}
2043	return out, nil
2044}
2045
2046func (c *cloudTasksClient) DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
2047	out := new(emptypb.Empty)
2048	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/DeleteTask", in, out, opts...)
2049	if err != nil {
2050		return nil, err
2051	}
2052	return out, nil
2053}
2054
2055func (c *cloudTasksClient) RunTask(ctx context.Context, in *RunTaskRequest, opts ...grpc.CallOption) (*Task, error) {
2056	out := new(Task)
2057	err := c.cc.Invoke(ctx, "/google.cloud.tasks.v2beta3.CloudTasks/RunTask", in, out, opts...)
2058	if err != nil {
2059		return nil, err
2060	}
2061	return out, nil
2062}
2063
2064// CloudTasksServer is the server API for CloudTasks service.
2065type CloudTasksServer interface {
2066	// Lists queues.
2067	//
2068	// Queues are returned in lexicographical order.
2069	ListQueues(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error)
2070	// Gets a queue.
2071	GetQueue(context.Context, *GetQueueRequest) (*Queue, error)
2072	// Creates a queue.
2073	//
2074	// Queues created with this method allow tasks to live for a maximum of 31
2075	// days. After a task is 31 days old, the task will be deleted regardless of whether
2076	// it was dispatched or not.
2077	//
2078	// WARNING: Using this method may have unintended side effects if you are
2079	// using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
2080	// Read
2081	// [Overview of Queue Management and
2082	// queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using
2083	// this method.
2084	CreateQueue(context.Context, *CreateQueueRequest) (*Queue, error)
2085	// Updates a queue.
2086	//
2087	// This method creates the queue if it does not exist and updates
2088	// the queue if it does exist.
2089	//
2090	// Queues created with this method allow tasks to live for a maximum of 31
2091	// days. After a task is 31 days old, the task will be deleted regardless of whether
2092	// it was dispatched or not.
2093	//
2094	// WARNING: Using this method may have unintended side effects if you are
2095	// using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
2096	// Read
2097	// [Overview of Queue Management and
2098	// queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using
2099	// this method.
2100	UpdateQueue(context.Context, *UpdateQueueRequest) (*Queue, error)
2101	// Deletes a queue.
2102	//
2103	// This command will delete the queue even if it has tasks in it.
2104	//
2105	// Note: If you delete a queue, a queue with the same name can't be created
2106	// for 7 days.
2107	//
2108	// WARNING: Using this method may have unintended side effects if you are
2109	// using an App Engine `queue.yaml` or `queue.xml` file to manage your queues.
2110	// Read
2111	// [Overview of Queue Management and
2112	// queue.yaml](https://cloud.google.com/tasks/docs/queue-yaml) before using
2113	// this method.
2114	DeleteQueue(context.Context, *DeleteQueueRequest) (*emptypb.Empty, error)
2115	// Purges a queue by deleting all of its tasks.
2116	//
2117	// All tasks created before this method is called are permanently deleted.
2118	//
2119	// Purge operations can take up to one minute to take effect. Tasks
2120	// might be dispatched before the purge takes effect. A purge is irreversible.
2121	PurgeQueue(context.Context, *PurgeQueueRequest) (*Queue, error)
2122	// Pauses the queue.
2123	//
2124	// If a queue is paused then the system will stop dispatching tasks
2125	// until the queue is resumed via
2126	// [ResumeQueue][google.cloud.tasks.v2beta3.CloudTasks.ResumeQueue]. Tasks can still be added
2127	// when the queue is paused. A queue is paused if its
2128	// [state][google.cloud.tasks.v2beta3.Queue.state] is [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED].
2129	PauseQueue(context.Context, *PauseQueueRequest) (*Queue, error)
2130	// Resume a queue.
2131	//
2132	// This method resumes a queue after it has been
2133	// [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED] or
2134	// [DISABLED][google.cloud.tasks.v2beta3.Queue.State.DISABLED]. The state of a queue is stored
2135	// in the queue's [state][google.cloud.tasks.v2beta3.Queue.state]; after calling this method it
2136	// will be set to [RUNNING][google.cloud.tasks.v2beta3.Queue.State.RUNNING].
2137	//
2138	// WARNING: Resuming many high-QPS queues at the same time can
2139	// lead to target overloading. If you are resuming high-QPS
2140	// queues, follow the 500/50/5 pattern described in
2141	// [Managing Cloud Tasks Scaling
2142	// Risks](https://cloud.google.com/tasks/docs/manage-cloud-task-scaling).
2143	ResumeQueue(context.Context, *ResumeQueueRequest) (*Queue, error)
2144	// Gets the access control policy for a [Queue][google.cloud.tasks.v2beta3.Queue].
2145	// Returns an empty policy if the resource exists and does not have a policy
2146	// set.
2147	//
2148	// Authorization requires the following
2149	// [Google IAM](https://cloud.google.com/iam) permission on the specified
2150	// resource parent:
2151	//
2152	// * `cloudtasks.queues.getIamPolicy`
2153	GetIamPolicy(context.Context, *v1.GetIamPolicyRequest) (*v1.Policy, error)
2154	// Sets the access control policy for a [Queue][google.cloud.tasks.v2beta3.Queue]. Replaces any existing
2155	// policy.
2156	//
2157	// Note: The Cloud Console does not check queue-level IAM permissions yet.
2158	// Project-level permissions are required to use the Cloud Console.
2159	//
2160	// Authorization requires the following
2161	// [Google IAM](https://cloud.google.com/iam) permission on the specified
2162	// resource parent:
2163	//
2164	// * `cloudtasks.queues.setIamPolicy`
2165	SetIamPolicy(context.Context, *v1.SetIamPolicyRequest) (*v1.Policy, error)
2166	// Returns permissions that a caller has on a [Queue][google.cloud.tasks.v2beta3.Queue].
2167	// If the resource does not exist, this will return an empty set of
2168	// permissions, not a [NOT_FOUND][google.rpc.Code.NOT_FOUND] error.
2169	//
2170	// Note: This operation is designed to be used for building permission-aware
2171	// UIs and command-line tools, not for authorization checking. This operation
2172	// may "fail open" without warning.
2173	TestIamPermissions(context.Context, *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error)
2174	// Lists the tasks in a queue.
2175	//
2176	// By default, only the [BASIC][google.cloud.tasks.v2beta3.Task.View.BASIC] view is retrieved
2177	// due to performance considerations;
2178	// [response_view][google.cloud.tasks.v2beta3.ListTasksRequest.response_view] controls the
2179	// subset of information which is returned.
2180	//
2181	// The tasks may be returned in any order. The ordering may change at any
2182	// time.
2183	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
2184	// Gets a task.
2185	GetTask(context.Context, *GetTaskRequest) (*Task, error)
2186	// Creates a task and adds it to a queue.
2187	//
2188	// Tasks cannot be updated after creation; there is no UpdateTask command.
2189	//
2190	// * The maximum task size is 100KB.
2191	CreateTask(context.Context, *CreateTaskRequest) (*Task, error)
2192	// Deletes a task.
2193	//
2194	// A task can be deleted if it is scheduled or dispatched. A task
2195	// cannot be deleted if it has executed successfully or permanently
2196	// failed.
2197	DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)
2198	// Forces a task to run now.
2199	//
2200	// When this method is called, Cloud Tasks will dispatch the task, even if
2201	// the task is already running, the queue has reached its [RateLimits][google.cloud.tasks.v2beta3.RateLimits] or
2202	// is [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED].
2203	//
2204	// This command is meant to be used for manual debugging. For
2205	// example, [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] can be used to retry a failed
2206	// task after a fix has been made or to manually force a task to be
2207	// dispatched now.
2208	//
2209	// The dispatched task is returned. That is, the task that is returned
2210	// contains the [status][Task.status] after the task is dispatched but
2211	// before the task is received by its target.
2212	//
2213	// If Cloud Tasks receives a successful response from the task's
2214	// target, then the task will be deleted; otherwise the task's
2215	// [schedule_time][google.cloud.tasks.v2beta3.Task.schedule_time] will be reset to the time that
2216	// [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] was called plus the retry delay specified
2217	// in the queue's [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
2218	//
2219	// [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] returns
2220	// [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a
2221	// task that has already succeeded or permanently failed.
2222	RunTask(context.Context, *RunTaskRequest) (*Task, error)
2223}
2224
2225// UnimplementedCloudTasksServer can be embedded to have forward compatible implementations.
2226type UnimplementedCloudTasksServer struct {
2227}
2228
2229func (*UnimplementedCloudTasksServer) ListQueues(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error) {
2230	return nil, status.Errorf(codes.Unimplemented, "method ListQueues not implemented")
2231}
2232func (*UnimplementedCloudTasksServer) GetQueue(context.Context, *GetQueueRequest) (*Queue, error) {
2233	return nil, status.Errorf(codes.Unimplemented, "method GetQueue not implemented")
2234}
2235func (*UnimplementedCloudTasksServer) CreateQueue(context.Context, *CreateQueueRequest) (*Queue, error) {
2236	return nil, status.Errorf(codes.Unimplemented, "method CreateQueue not implemented")
2237}
2238func (*UnimplementedCloudTasksServer) UpdateQueue(context.Context, *UpdateQueueRequest) (*Queue, error) {
2239	return nil, status.Errorf(codes.Unimplemented, "method UpdateQueue not implemented")
2240}
2241func (*UnimplementedCloudTasksServer) DeleteQueue(context.Context, *DeleteQueueRequest) (*emptypb.Empty, error) {
2242	return nil, status.Errorf(codes.Unimplemented, "method DeleteQueue not implemented")
2243}
2244func (*UnimplementedCloudTasksServer) PurgeQueue(context.Context, *PurgeQueueRequest) (*Queue, error) {
2245	return nil, status.Errorf(codes.Unimplemented, "method PurgeQueue not implemented")
2246}
2247func (*UnimplementedCloudTasksServer) PauseQueue(context.Context, *PauseQueueRequest) (*Queue, error) {
2248	return nil, status.Errorf(codes.Unimplemented, "method PauseQueue not implemented")
2249}
2250func (*UnimplementedCloudTasksServer) ResumeQueue(context.Context, *ResumeQueueRequest) (*Queue, error) {
2251	return nil, status.Errorf(codes.Unimplemented, "method ResumeQueue not implemented")
2252}
2253func (*UnimplementedCloudTasksServer) GetIamPolicy(context.Context, *v1.GetIamPolicyRequest) (*v1.Policy, error) {
2254	return nil, status.Errorf(codes.Unimplemented, "method GetIamPolicy not implemented")
2255}
2256func (*UnimplementedCloudTasksServer) SetIamPolicy(context.Context, *v1.SetIamPolicyRequest) (*v1.Policy, error) {
2257	return nil, status.Errorf(codes.Unimplemented, "method SetIamPolicy not implemented")
2258}
2259func (*UnimplementedCloudTasksServer) TestIamPermissions(context.Context, *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error) {
2260	return nil, status.Errorf(codes.Unimplemented, "method TestIamPermissions not implemented")
2261}
2262func (*UnimplementedCloudTasksServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error) {
2263	return nil, status.Errorf(codes.Unimplemented, "method ListTasks not implemented")
2264}
2265func (*UnimplementedCloudTasksServer) GetTask(context.Context, *GetTaskRequest) (*Task, error) {
2266	return nil, status.Errorf(codes.Unimplemented, "method GetTask not implemented")
2267}
2268func (*UnimplementedCloudTasksServer) CreateTask(context.Context, *CreateTaskRequest) (*Task, error) {
2269	return nil, status.Errorf(codes.Unimplemented, "method CreateTask not implemented")
2270}
2271func (*UnimplementedCloudTasksServer) DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error) {
2272	return nil, status.Errorf(codes.Unimplemented, "method DeleteTask not implemented")
2273}
2274func (*UnimplementedCloudTasksServer) RunTask(context.Context, *RunTaskRequest) (*Task, error) {
2275	return nil, status.Errorf(codes.Unimplemented, "method RunTask not implemented")
2276}
2277
2278func RegisterCloudTasksServer(s *grpc.Server, srv CloudTasksServer) {
2279	s.RegisterService(&_CloudTasks_serviceDesc, srv)
2280}
2281
2282func _CloudTasks_ListQueues_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2283	in := new(ListQueuesRequest)
2284	if err := dec(in); err != nil {
2285		return nil, err
2286	}
2287	if interceptor == nil {
2288		return srv.(CloudTasksServer).ListQueues(ctx, in)
2289	}
2290	info := &grpc.UnaryServerInfo{
2291		Server:     srv,
2292		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/ListQueues",
2293	}
2294	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2295		return srv.(CloudTasksServer).ListQueues(ctx, req.(*ListQueuesRequest))
2296	}
2297	return interceptor(ctx, in, info, handler)
2298}
2299
2300func _CloudTasks_GetQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2301	in := new(GetQueueRequest)
2302	if err := dec(in); err != nil {
2303		return nil, err
2304	}
2305	if interceptor == nil {
2306		return srv.(CloudTasksServer).GetQueue(ctx, in)
2307	}
2308	info := &grpc.UnaryServerInfo{
2309		Server:     srv,
2310		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/GetQueue",
2311	}
2312	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2313		return srv.(CloudTasksServer).GetQueue(ctx, req.(*GetQueueRequest))
2314	}
2315	return interceptor(ctx, in, info, handler)
2316}
2317
2318func _CloudTasks_CreateQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2319	in := new(CreateQueueRequest)
2320	if err := dec(in); err != nil {
2321		return nil, err
2322	}
2323	if interceptor == nil {
2324		return srv.(CloudTasksServer).CreateQueue(ctx, in)
2325	}
2326	info := &grpc.UnaryServerInfo{
2327		Server:     srv,
2328		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/CreateQueue",
2329	}
2330	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2331		return srv.(CloudTasksServer).CreateQueue(ctx, req.(*CreateQueueRequest))
2332	}
2333	return interceptor(ctx, in, info, handler)
2334}
2335
2336func _CloudTasks_UpdateQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2337	in := new(UpdateQueueRequest)
2338	if err := dec(in); err != nil {
2339		return nil, err
2340	}
2341	if interceptor == nil {
2342		return srv.(CloudTasksServer).UpdateQueue(ctx, in)
2343	}
2344	info := &grpc.UnaryServerInfo{
2345		Server:     srv,
2346		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/UpdateQueue",
2347	}
2348	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2349		return srv.(CloudTasksServer).UpdateQueue(ctx, req.(*UpdateQueueRequest))
2350	}
2351	return interceptor(ctx, in, info, handler)
2352}
2353
2354func _CloudTasks_DeleteQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2355	in := new(DeleteQueueRequest)
2356	if err := dec(in); err != nil {
2357		return nil, err
2358	}
2359	if interceptor == nil {
2360		return srv.(CloudTasksServer).DeleteQueue(ctx, in)
2361	}
2362	info := &grpc.UnaryServerInfo{
2363		Server:     srv,
2364		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/DeleteQueue",
2365	}
2366	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2367		return srv.(CloudTasksServer).DeleteQueue(ctx, req.(*DeleteQueueRequest))
2368	}
2369	return interceptor(ctx, in, info, handler)
2370}
2371
2372func _CloudTasks_PurgeQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2373	in := new(PurgeQueueRequest)
2374	if err := dec(in); err != nil {
2375		return nil, err
2376	}
2377	if interceptor == nil {
2378		return srv.(CloudTasksServer).PurgeQueue(ctx, in)
2379	}
2380	info := &grpc.UnaryServerInfo{
2381		Server:     srv,
2382		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/PurgeQueue",
2383	}
2384	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2385		return srv.(CloudTasksServer).PurgeQueue(ctx, req.(*PurgeQueueRequest))
2386	}
2387	return interceptor(ctx, in, info, handler)
2388}
2389
2390func _CloudTasks_PauseQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2391	in := new(PauseQueueRequest)
2392	if err := dec(in); err != nil {
2393		return nil, err
2394	}
2395	if interceptor == nil {
2396		return srv.(CloudTasksServer).PauseQueue(ctx, in)
2397	}
2398	info := &grpc.UnaryServerInfo{
2399		Server:     srv,
2400		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/PauseQueue",
2401	}
2402	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2403		return srv.(CloudTasksServer).PauseQueue(ctx, req.(*PauseQueueRequest))
2404	}
2405	return interceptor(ctx, in, info, handler)
2406}
2407
2408func _CloudTasks_ResumeQueue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2409	in := new(ResumeQueueRequest)
2410	if err := dec(in); err != nil {
2411		return nil, err
2412	}
2413	if interceptor == nil {
2414		return srv.(CloudTasksServer).ResumeQueue(ctx, in)
2415	}
2416	info := &grpc.UnaryServerInfo{
2417		Server:     srv,
2418		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/ResumeQueue",
2419	}
2420	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2421		return srv.(CloudTasksServer).ResumeQueue(ctx, req.(*ResumeQueueRequest))
2422	}
2423	return interceptor(ctx, in, info, handler)
2424}
2425
2426func _CloudTasks_GetIamPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2427	in := new(v1.GetIamPolicyRequest)
2428	if err := dec(in); err != nil {
2429		return nil, err
2430	}
2431	if interceptor == nil {
2432		return srv.(CloudTasksServer).GetIamPolicy(ctx, in)
2433	}
2434	info := &grpc.UnaryServerInfo{
2435		Server:     srv,
2436		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/GetIamPolicy",
2437	}
2438	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2439		return srv.(CloudTasksServer).GetIamPolicy(ctx, req.(*v1.GetIamPolicyRequest))
2440	}
2441	return interceptor(ctx, in, info, handler)
2442}
2443
2444func _CloudTasks_SetIamPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2445	in := new(v1.SetIamPolicyRequest)
2446	if err := dec(in); err != nil {
2447		return nil, err
2448	}
2449	if interceptor == nil {
2450		return srv.(CloudTasksServer).SetIamPolicy(ctx, in)
2451	}
2452	info := &grpc.UnaryServerInfo{
2453		Server:     srv,
2454		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/SetIamPolicy",
2455	}
2456	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2457		return srv.(CloudTasksServer).SetIamPolicy(ctx, req.(*v1.SetIamPolicyRequest))
2458	}
2459	return interceptor(ctx, in, info, handler)
2460}
2461
2462func _CloudTasks_TestIamPermissions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2463	in := new(v1.TestIamPermissionsRequest)
2464	if err := dec(in); err != nil {
2465		return nil, err
2466	}
2467	if interceptor == nil {
2468		return srv.(CloudTasksServer).TestIamPermissions(ctx, in)
2469	}
2470	info := &grpc.UnaryServerInfo{
2471		Server:     srv,
2472		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/TestIamPermissions",
2473	}
2474	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2475		return srv.(CloudTasksServer).TestIamPermissions(ctx, req.(*v1.TestIamPermissionsRequest))
2476	}
2477	return interceptor(ctx, in, info, handler)
2478}
2479
2480func _CloudTasks_ListTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2481	in := new(ListTasksRequest)
2482	if err := dec(in); err != nil {
2483		return nil, err
2484	}
2485	if interceptor == nil {
2486		return srv.(CloudTasksServer).ListTasks(ctx, in)
2487	}
2488	info := &grpc.UnaryServerInfo{
2489		Server:     srv,
2490		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/ListTasks",
2491	}
2492	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2493		return srv.(CloudTasksServer).ListTasks(ctx, req.(*ListTasksRequest))
2494	}
2495	return interceptor(ctx, in, info, handler)
2496}
2497
2498func _CloudTasks_GetTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2499	in := new(GetTaskRequest)
2500	if err := dec(in); err != nil {
2501		return nil, err
2502	}
2503	if interceptor == nil {
2504		return srv.(CloudTasksServer).GetTask(ctx, in)
2505	}
2506	info := &grpc.UnaryServerInfo{
2507		Server:     srv,
2508		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/GetTask",
2509	}
2510	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2511		return srv.(CloudTasksServer).GetTask(ctx, req.(*GetTaskRequest))
2512	}
2513	return interceptor(ctx, in, info, handler)
2514}
2515
2516func _CloudTasks_CreateTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2517	in := new(CreateTaskRequest)
2518	if err := dec(in); err != nil {
2519		return nil, err
2520	}
2521	if interceptor == nil {
2522		return srv.(CloudTasksServer).CreateTask(ctx, in)
2523	}
2524	info := &grpc.UnaryServerInfo{
2525		Server:     srv,
2526		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/CreateTask",
2527	}
2528	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2529		return srv.(CloudTasksServer).CreateTask(ctx, req.(*CreateTaskRequest))
2530	}
2531	return interceptor(ctx, in, info, handler)
2532}
2533
2534func _CloudTasks_DeleteTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2535	in := new(DeleteTaskRequest)
2536	if err := dec(in); err != nil {
2537		return nil, err
2538	}
2539	if interceptor == nil {
2540		return srv.(CloudTasksServer).DeleteTask(ctx, in)
2541	}
2542	info := &grpc.UnaryServerInfo{
2543		Server:     srv,
2544		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/DeleteTask",
2545	}
2546	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2547		return srv.(CloudTasksServer).DeleteTask(ctx, req.(*DeleteTaskRequest))
2548	}
2549	return interceptor(ctx, in, info, handler)
2550}
2551
2552func _CloudTasks_RunTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2553	in := new(RunTaskRequest)
2554	if err := dec(in); err != nil {
2555		return nil, err
2556	}
2557	if interceptor == nil {
2558		return srv.(CloudTasksServer).RunTask(ctx, in)
2559	}
2560	info := &grpc.UnaryServerInfo{
2561		Server:     srv,
2562		FullMethod: "/google.cloud.tasks.v2beta3.CloudTasks/RunTask",
2563	}
2564	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2565		return srv.(CloudTasksServer).RunTask(ctx, req.(*RunTaskRequest))
2566	}
2567	return interceptor(ctx, in, info, handler)
2568}
2569
2570var _CloudTasks_serviceDesc = grpc.ServiceDesc{
2571	ServiceName: "google.cloud.tasks.v2beta3.CloudTasks",
2572	HandlerType: (*CloudTasksServer)(nil),
2573	Methods: []grpc.MethodDesc{
2574		{
2575			MethodName: "ListQueues",
2576			Handler:    _CloudTasks_ListQueues_Handler,
2577		},
2578		{
2579			MethodName: "GetQueue",
2580			Handler:    _CloudTasks_GetQueue_Handler,
2581		},
2582		{
2583			MethodName: "CreateQueue",
2584			Handler:    _CloudTasks_CreateQueue_Handler,
2585		},
2586		{
2587			MethodName: "UpdateQueue",
2588			Handler:    _CloudTasks_UpdateQueue_Handler,
2589		},
2590		{
2591			MethodName: "DeleteQueue",
2592			Handler:    _CloudTasks_DeleteQueue_Handler,
2593		},
2594		{
2595			MethodName: "PurgeQueue",
2596			Handler:    _CloudTasks_PurgeQueue_Handler,
2597		},
2598		{
2599			MethodName: "PauseQueue",
2600			Handler:    _CloudTasks_PauseQueue_Handler,
2601		},
2602		{
2603			MethodName: "ResumeQueue",
2604			Handler:    _CloudTasks_ResumeQueue_Handler,
2605		},
2606		{
2607			MethodName: "GetIamPolicy",
2608			Handler:    _CloudTasks_GetIamPolicy_Handler,
2609		},
2610		{
2611			MethodName: "SetIamPolicy",
2612			Handler:    _CloudTasks_SetIamPolicy_Handler,
2613		},
2614		{
2615			MethodName: "TestIamPermissions",
2616			Handler:    _CloudTasks_TestIamPermissions_Handler,
2617		},
2618		{
2619			MethodName: "ListTasks",
2620			Handler:    _CloudTasks_ListTasks_Handler,
2621		},
2622		{
2623			MethodName: "GetTask",
2624			Handler:    _CloudTasks_GetTask_Handler,
2625		},
2626		{
2627			MethodName: "CreateTask",
2628			Handler:    _CloudTasks_CreateTask_Handler,
2629		},
2630		{
2631			MethodName: "DeleteTask",
2632			Handler:    _CloudTasks_DeleteTask_Handler,
2633		},
2634		{
2635			MethodName: "RunTask",
2636			Handler:    _CloudTasks_RunTask_Handler,
2637		},
2638	},
2639	Streams:  []grpc.StreamDesc{},
2640	Metadata: "google/cloud/tasks/v2beta3/cloudtasks.proto",
2641}
2642