1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21 package batch
22
23 import (
24 context "context"
25 reflect "reflect"
26 sync "sync"
27
28 _ "google.golang.org/genproto/googleapis/api/annotations"
29 longrunning "google.golang.org/genproto/googleapis/longrunning"
30 grpc "google.golang.org/grpc"
31 codes "google.golang.org/grpc/codes"
32 status "google.golang.org/grpc/status"
33 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
34 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
35 timestamppb "google.golang.org/protobuf/types/known/timestamppb"
36 )
37
38 const (
39
40 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
41
42 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
43 )
44
45
46 type CreateJobRequest struct {
47 state protoimpl.MessageState
48 sizeCache protoimpl.SizeCache
49 unknownFields protoimpl.UnknownFields
50
51
52
53 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
54
55
56
57
58
59
60
61
62 JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
63
64 Job *Job `protobuf:"bytes,3,opt,name=job,proto3" json:"job,omitempty"`
65
66
67
68
69
70
71
72
73
74
75
76
77
78 RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
79 }
80
81 func (x *CreateJobRequest) Reset() {
82 *x = CreateJobRequest{}
83 if protoimpl.UnsafeEnabled {
84 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[0]
85 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
86 ms.StoreMessageInfo(mi)
87 }
88 }
89
90 func (x *CreateJobRequest) String() string {
91 return protoimpl.X.MessageStringOf(x)
92 }
93
94 func (*CreateJobRequest) ProtoMessage() {}
95
96 func (x *CreateJobRequest) ProtoReflect() protoreflect.Message {
97 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[0]
98 if protoimpl.UnsafeEnabled && x != nil {
99 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
100 if ms.LoadMessageInfo() == nil {
101 ms.StoreMessageInfo(mi)
102 }
103 return ms
104 }
105 return mi.MessageOf(x)
106 }
107
108
109 func (*CreateJobRequest) Descriptor() ([]byte, []int) {
110 return file_google_cloud_batch_v1alpha1_batch_proto_rawDescGZIP(), []int{0}
111 }
112
113 func (x *CreateJobRequest) GetParent() string {
114 if x != nil {
115 return x.Parent
116 }
117 return ""
118 }
119
120 func (x *CreateJobRequest) GetJobId() string {
121 if x != nil {
122 return x.JobId
123 }
124 return ""
125 }
126
127 func (x *CreateJobRequest) GetJob() *Job {
128 if x != nil {
129 return x.Job
130 }
131 return nil
132 }
133
134 func (x *CreateJobRequest) GetRequestId() string {
135 if x != nil {
136 return x.RequestId
137 }
138 return ""
139 }
140
141
142 type GetJobRequest struct {
143 state protoimpl.MessageState
144 sizeCache protoimpl.SizeCache
145 unknownFields protoimpl.UnknownFields
146
147
148 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
149 }
150
151 func (x *GetJobRequest) Reset() {
152 *x = GetJobRequest{}
153 if protoimpl.UnsafeEnabled {
154 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[1]
155 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
156 ms.StoreMessageInfo(mi)
157 }
158 }
159
160 func (x *GetJobRequest) String() string {
161 return protoimpl.X.MessageStringOf(x)
162 }
163
164 func (*GetJobRequest) ProtoMessage() {}
165
166 func (x *GetJobRequest) ProtoReflect() protoreflect.Message {
167 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[1]
168 if protoimpl.UnsafeEnabled && x != nil {
169 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
170 if ms.LoadMessageInfo() == nil {
171 ms.StoreMessageInfo(mi)
172 }
173 return ms
174 }
175 return mi.MessageOf(x)
176 }
177
178
179 func (*GetJobRequest) Descriptor() ([]byte, []int) {
180 return file_google_cloud_batch_v1alpha1_batch_proto_rawDescGZIP(), []int{1}
181 }
182
183 func (x *GetJobRequest) GetName() string {
184 if x != nil {
185 return x.Name
186 }
187 return ""
188 }
189
190
191 type DeleteJobRequest struct {
192 state protoimpl.MessageState
193 sizeCache protoimpl.SizeCache
194 unknownFields protoimpl.UnknownFields
195
196
197 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
198
199 Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
200
201
202
203
204
205
206
207
208
209
210
211
212
213 RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
214 }
215
216 func (x *DeleteJobRequest) Reset() {
217 *x = DeleteJobRequest{}
218 if protoimpl.UnsafeEnabled {
219 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[2]
220 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
221 ms.StoreMessageInfo(mi)
222 }
223 }
224
225 func (x *DeleteJobRequest) String() string {
226 return protoimpl.X.MessageStringOf(x)
227 }
228
229 func (*DeleteJobRequest) ProtoMessage() {}
230
231 func (x *DeleteJobRequest) ProtoReflect() protoreflect.Message {
232 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[2]
233 if protoimpl.UnsafeEnabled && x != nil {
234 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
235 if ms.LoadMessageInfo() == nil {
236 ms.StoreMessageInfo(mi)
237 }
238 return ms
239 }
240 return mi.MessageOf(x)
241 }
242
243
244 func (*DeleteJobRequest) Descriptor() ([]byte, []int) {
245 return file_google_cloud_batch_v1alpha1_batch_proto_rawDescGZIP(), []int{2}
246 }
247
248 func (x *DeleteJobRequest) GetName() string {
249 if x != nil {
250 return x.Name
251 }
252 return ""
253 }
254
255 func (x *DeleteJobRequest) GetReason() string {
256 if x != nil {
257 return x.Reason
258 }
259 return ""
260 }
261
262 func (x *DeleteJobRequest) GetRequestId() string {
263 if x != nil {
264 return x.RequestId
265 }
266 return ""
267 }
268
269
270 type ListJobsRequest struct {
271 state protoimpl.MessageState
272 sizeCache protoimpl.SizeCache
273 unknownFields protoimpl.UnknownFields
274
275
276 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
277
278 Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
279
280 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
281
282 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
283 }
284
285 func (x *ListJobsRequest) Reset() {
286 *x = ListJobsRequest{}
287 if protoimpl.UnsafeEnabled {
288 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[3]
289 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
290 ms.StoreMessageInfo(mi)
291 }
292 }
293
294 func (x *ListJobsRequest) String() string {
295 return protoimpl.X.MessageStringOf(x)
296 }
297
298 func (*ListJobsRequest) ProtoMessage() {}
299
300 func (x *ListJobsRequest) ProtoReflect() protoreflect.Message {
301 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[3]
302 if protoimpl.UnsafeEnabled && x != nil {
303 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
304 if ms.LoadMessageInfo() == nil {
305 ms.StoreMessageInfo(mi)
306 }
307 return ms
308 }
309 return mi.MessageOf(x)
310 }
311
312
313 func (*ListJobsRequest) Descriptor() ([]byte, []int) {
314 return file_google_cloud_batch_v1alpha1_batch_proto_rawDescGZIP(), []int{3}
315 }
316
317 func (x *ListJobsRequest) GetParent() string {
318 if x != nil {
319 return x.Parent
320 }
321 return ""
322 }
323
324 func (x *ListJobsRequest) GetFilter() string {
325 if x != nil {
326 return x.Filter
327 }
328 return ""
329 }
330
331 func (x *ListJobsRequest) GetPageSize() int32 {
332 if x != nil {
333 return x.PageSize
334 }
335 return 0
336 }
337
338 func (x *ListJobsRequest) GetPageToken() string {
339 if x != nil {
340 return x.PageToken
341 }
342 return ""
343 }
344
345
346 type ListJobsResponse struct {
347 state protoimpl.MessageState
348 sizeCache protoimpl.SizeCache
349 unknownFields protoimpl.UnknownFields
350
351
352 Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
353
354 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
355
356 Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
357 }
358
359 func (x *ListJobsResponse) Reset() {
360 *x = ListJobsResponse{}
361 if protoimpl.UnsafeEnabled {
362 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[4]
363 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
364 ms.StoreMessageInfo(mi)
365 }
366 }
367
368 func (x *ListJobsResponse) String() string {
369 return protoimpl.X.MessageStringOf(x)
370 }
371
372 func (*ListJobsResponse) ProtoMessage() {}
373
374 func (x *ListJobsResponse) ProtoReflect() protoreflect.Message {
375 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[4]
376 if protoimpl.UnsafeEnabled && x != nil {
377 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
378 if ms.LoadMessageInfo() == nil {
379 ms.StoreMessageInfo(mi)
380 }
381 return ms
382 }
383 return mi.MessageOf(x)
384 }
385
386
387 func (*ListJobsResponse) Descriptor() ([]byte, []int) {
388 return file_google_cloud_batch_v1alpha1_batch_proto_rawDescGZIP(), []int{4}
389 }
390
391 func (x *ListJobsResponse) GetJobs() []*Job {
392 if x != nil {
393 return x.Jobs
394 }
395 return nil
396 }
397
398 func (x *ListJobsResponse) GetNextPageToken() string {
399 if x != nil {
400 return x.NextPageToken
401 }
402 return ""
403 }
404
405 func (x *ListJobsResponse) GetUnreachable() []string {
406 if x != nil {
407 return x.Unreachable
408 }
409 return nil
410 }
411
412
413 type ListTasksRequest struct {
414 state protoimpl.MessageState
415 sizeCache protoimpl.SizeCache
416 unknownFields protoimpl.UnknownFields
417
418
419 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
420
421
422
423 Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
424
425 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
426
427 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
428 }
429
430 func (x *ListTasksRequest) Reset() {
431 *x = ListTasksRequest{}
432 if protoimpl.UnsafeEnabled {
433 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[5]
434 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
435 ms.StoreMessageInfo(mi)
436 }
437 }
438
439 func (x *ListTasksRequest) String() string {
440 return protoimpl.X.MessageStringOf(x)
441 }
442
443 func (*ListTasksRequest) ProtoMessage() {}
444
445 func (x *ListTasksRequest) ProtoReflect() protoreflect.Message {
446 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[5]
447 if protoimpl.UnsafeEnabled && x != nil {
448 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
449 if ms.LoadMessageInfo() == nil {
450 ms.StoreMessageInfo(mi)
451 }
452 return ms
453 }
454 return mi.MessageOf(x)
455 }
456
457
458 func (*ListTasksRequest) Descriptor() ([]byte, []int) {
459 return file_google_cloud_batch_v1alpha1_batch_proto_rawDescGZIP(), []int{5}
460 }
461
462 func (x *ListTasksRequest) GetParent() string {
463 if x != nil {
464 return x.Parent
465 }
466 return ""
467 }
468
469 func (x *ListTasksRequest) GetFilter() string {
470 if x != nil {
471 return x.Filter
472 }
473 return ""
474 }
475
476 func (x *ListTasksRequest) GetPageSize() int32 {
477 if x != nil {
478 return x.PageSize
479 }
480 return 0
481 }
482
483 func (x *ListTasksRequest) GetPageToken() string {
484 if x != nil {
485 return x.PageToken
486 }
487 return ""
488 }
489
490
491 type ListTasksResponse struct {
492 state protoimpl.MessageState
493 sizeCache protoimpl.SizeCache
494 unknownFields protoimpl.UnknownFields
495
496
497 Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
498
499 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
500
501 Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
502 }
503
504 func (x *ListTasksResponse) Reset() {
505 *x = ListTasksResponse{}
506 if protoimpl.UnsafeEnabled {
507 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[6]
508 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
509 ms.StoreMessageInfo(mi)
510 }
511 }
512
513 func (x *ListTasksResponse) String() string {
514 return protoimpl.X.MessageStringOf(x)
515 }
516
517 func (*ListTasksResponse) ProtoMessage() {}
518
519 func (x *ListTasksResponse) ProtoReflect() protoreflect.Message {
520 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[6]
521 if protoimpl.UnsafeEnabled && x != nil {
522 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
523 if ms.LoadMessageInfo() == nil {
524 ms.StoreMessageInfo(mi)
525 }
526 return ms
527 }
528 return mi.MessageOf(x)
529 }
530
531
532 func (*ListTasksResponse) Descriptor() ([]byte, []int) {
533 return file_google_cloud_batch_v1alpha1_batch_proto_rawDescGZIP(), []int{6}
534 }
535
536 func (x *ListTasksResponse) GetTasks() []*Task {
537 if x != nil {
538 return x.Tasks
539 }
540 return nil
541 }
542
543 func (x *ListTasksResponse) GetNextPageToken() string {
544 if x != nil {
545 return x.NextPageToken
546 }
547 return ""
548 }
549
550 func (x *ListTasksResponse) GetUnreachable() []string {
551 if x != nil {
552 return x.Unreachable
553 }
554 return nil
555 }
556
557
558 type GetTaskRequest struct {
559 state protoimpl.MessageState
560 sizeCache protoimpl.SizeCache
561 unknownFields protoimpl.UnknownFields
562
563
564 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
565 }
566
567 func (x *GetTaskRequest) Reset() {
568 *x = GetTaskRequest{}
569 if protoimpl.UnsafeEnabled {
570 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[7]
571 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
572 ms.StoreMessageInfo(mi)
573 }
574 }
575
576 func (x *GetTaskRequest) String() string {
577 return protoimpl.X.MessageStringOf(x)
578 }
579
580 func (*GetTaskRequest) ProtoMessage() {}
581
582 func (x *GetTaskRequest) ProtoReflect() protoreflect.Message {
583 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[7]
584 if protoimpl.UnsafeEnabled && x != nil {
585 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
586 if ms.LoadMessageInfo() == nil {
587 ms.StoreMessageInfo(mi)
588 }
589 return ms
590 }
591 return mi.MessageOf(x)
592 }
593
594
595 func (*GetTaskRequest) Descriptor() ([]byte, []int) {
596 return file_google_cloud_batch_v1alpha1_batch_proto_rawDescGZIP(), []int{7}
597 }
598
599 func (x *GetTaskRequest) GetName() string {
600 if x != nil {
601 return x.Name
602 }
603 return ""
604 }
605
606
607 type OperationMetadata struct {
608 state protoimpl.MessageState
609 sizeCache protoimpl.SizeCache
610 unknownFields protoimpl.UnknownFields
611
612
613 CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
614
615 EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
616
617 Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
618
619 Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
620
621 StatusMessage string `protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
622
623
624
625
626 RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
627
628 ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
629 }
630
631 func (x *OperationMetadata) Reset() {
632 *x = OperationMetadata{}
633 if protoimpl.UnsafeEnabled {
634 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[8]
635 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
636 ms.StoreMessageInfo(mi)
637 }
638 }
639
640 func (x *OperationMetadata) String() string {
641 return protoimpl.X.MessageStringOf(x)
642 }
643
644 func (*OperationMetadata) ProtoMessage() {}
645
646 func (x *OperationMetadata) ProtoReflect() protoreflect.Message {
647 mi := &file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[8]
648 if protoimpl.UnsafeEnabled && x != nil {
649 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
650 if ms.LoadMessageInfo() == nil {
651 ms.StoreMessageInfo(mi)
652 }
653 return ms
654 }
655 return mi.MessageOf(x)
656 }
657
658
659 func (*OperationMetadata) Descriptor() ([]byte, []int) {
660 return file_google_cloud_batch_v1alpha1_batch_proto_rawDescGZIP(), []int{8}
661 }
662
663 func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp {
664 if x != nil {
665 return x.CreateTime
666 }
667 return nil
668 }
669
670 func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp {
671 if x != nil {
672 return x.EndTime
673 }
674 return nil
675 }
676
677 func (x *OperationMetadata) GetTarget() string {
678 if x != nil {
679 return x.Target
680 }
681 return ""
682 }
683
684 func (x *OperationMetadata) GetVerb() string {
685 if x != nil {
686 return x.Verb
687 }
688 return ""
689 }
690
691 func (x *OperationMetadata) GetStatusMessage() string {
692 if x != nil {
693 return x.StatusMessage
694 }
695 return ""
696 }
697
698 func (x *OperationMetadata) GetRequestedCancellation() bool {
699 if x != nil {
700 return x.RequestedCancellation
701 }
702 return false
703 }
704
705 func (x *OperationMetadata) GetApiVersion() string {
706 if x != nil {
707 return x.ApiVersion
708 }
709 return ""
710 }
711
712 var File_google_cloud_batch_v1alpha1_batch_proto protoreflect.FileDescriptor
713
714 var file_google_cloud_batch_v1alpha1_batch_proto_rawDesc = []byte{
715 0x0a, 0x27, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62,
716 0x61, 0x74, 0x63, 0x68, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x62, 0x61,
717 0x74, 0x63, 0x68, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
718 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31,
719 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61,
720 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70,
721 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69,
722 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67,
723 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f,
724 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19,
725 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75,
726 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
727 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2f, 0x76, 0x31,
728 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x6a, 0x6f, 0x62, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
729 0x1a, 0x26, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62,
730 0x61, 0x74, 0x63, 0x68, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x74, 0x61,
731 0x73, 0x6b, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x23, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
732 0x2f, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2f, 0x6f, 0x70, 0x65,
733 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67,
734 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74,
735 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xc0,
736 0x01, 0x0a, 0x10, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75,
737 0x65, 0x73, 0x74, 0x12, 0x38, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20,
738 0x01, 0x28, 0x09, 0x42, 0x20, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x1a, 0x12, 0x18, 0x62, 0x61, 0x74,
739 0x63, 0x68, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f,
740 0x6d, 0x2f, 0x4a, 0x6f, 0x62, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x15, 0x0a,
741 0x06, 0x6a, 0x6f, 0x62, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x6a,
742 0x6f, 0x62, 0x49, 0x64, 0x12, 0x37, 0x0a, 0x03, 0x6a, 0x6f, 0x62, 0x18, 0x03, 0x20, 0x01, 0x28,
743 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
744 0x2e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e,
745 0x4a, 0x6f, 0x62, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x03, 0x6a, 0x6f, 0x62, 0x12, 0x22, 0x0a,
746 0x0a, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28,
747 0x09, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x09, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x49,
748 0x64, 0x22, 0x45, 0x0a, 0x0d, 0x47, 0x65, 0x74, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65,
749 0x73, 0x74, 0x12, 0x34, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
750 0x42, 0x20, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x1a, 0x0a, 0x18, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e,
751 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x4a,
752 0x6f, 0x62, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x67, 0x0a, 0x10, 0x44, 0x65, 0x6c, 0x65,
753 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04,
754 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65,
755 0x12, 0x1b, 0x0a, 0x06, 0x72, 0x65, 0x61, 0x73, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09,
756 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x06, 0x72, 0x65, 0x61, 0x73, 0x6f, 0x6e, 0x12, 0x22, 0x0a,
757 0x0a, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28,
758 0x09, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x09, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x49,
759 0x64, 0x22, 0x7d, 0x0a, 0x0f, 0x4c, 0x69, 0x73, 0x74, 0x4a, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x71,
760 0x75, 0x65, 0x73, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01,
761 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x16, 0x0a, 0x06,
762 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x66, 0x69,
763 0x6c, 0x74, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a,
764 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a,
765 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18,
766 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e,
767 0x22, 0x92, 0x01, 0x0a, 0x10, 0x4c, 0x69, 0x73, 0x74, 0x4a, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x73,
768 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x34, 0x0a, 0x04, 0x6a, 0x6f, 0x62, 0x73, 0x18, 0x01, 0x20,
769 0x03, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
770 0x75, 0x64, 0x2e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61,
771 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x52, 0x04, 0x6a, 0x6f, 0x62, 0x73, 0x12, 0x26, 0x0a, 0x0f, 0x6e,
772 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02,
773 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 0x54, 0x6f,
774 0x6b, 0x65, 0x6e, 0x12, 0x20, 0x0a, 0x0b, 0x75, 0x6e, 0x72, 0x65, 0x61, 0x63, 0x68, 0x61, 0x62,
775 0x6c, 0x65, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0b, 0x75, 0x6e, 0x72, 0x65, 0x61, 0x63,
776 0x68, 0x61, 0x62, 0x6c, 0x65, 0x22, 0xa6, 0x01, 0x0a, 0x10, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x61,
777 0x73, 0x6b, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3e, 0x0a, 0x06, 0x70, 0x61,
778 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x26, 0xe0, 0x41, 0x02, 0xfa,
779 0x41, 0x20, 0x0a, 0x1e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
780 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x61, 0x73, 0x6b, 0x47, 0x72, 0x6f,
781 0x75, 0x70, 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x66, 0x69,
782 0x6c, 0x74, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x66, 0x69, 0x6c, 0x74,
783 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18,
784 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12,
785 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x04, 0x20,
786 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x96,
787 0x01, 0x0a, 0x11, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x52, 0x65, 0x73, 0x70,
788 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x37, 0x0a, 0x05, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x18, 0x01, 0x20,
789 0x03, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
790 0x75, 0x64, 0x2e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61,
791 0x31, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x05, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x26, 0x0a,
792 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e,
793 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 0x65,
794 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x20, 0x0a, 0x0b, 0x75, 0x6e, 0x72, 0x65, 0x61, 0x63, 0x68,
795 0x61, 0x62, 0x6c, 0x65, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0b, 0x75, 0x6e, 0x72, 0x65,
796 0x61, 0x63, 0x68, 0x61, 0x62, 0x6c, 0x65, 0x22, 0x47, 0x0a, 0x0e, 0x47, 0x65, 0x74, 0x54, 0x61,
797 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x35, 0x0a, 0x04, 0x6e, 0x61, 0x6d,
798 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x21, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x1b, 0x0a,
799 0x19, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69,
800 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65,
801 0x22, 0xd5, 0x02, 0x0a, 0x11, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x65,
802 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x40, 0x0a, 0x0b, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65,
803 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f,
804 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69,
805 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x63, 0x72,
806 0x65, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x3a, 0x0a, 0x08, 0x65, 0x6e, 0x64, 0x5f,
807 0x74, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f,
808 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d,
809 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x07, 0x65, 0x6e, 0x64,
810 0x54, 0x69, 0x6d, 0x65, 0x12, 0x1b, 0x0a, 0x06, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x18, 0x03,
811 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x06, 0x74, 0x61, 0x72, 0x67, 0x65,
812 0x74, 0x12, 0x17, 0x0a, 0x04, 0x76, 0x65, 0x72, 0x62, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x42,
813 0x03, 0xe0, 0x41, 0x03, 0x52, 0x04, 0x76, 0x65, 0x72, 0x62, 0x12, 0x2a, 0x0a, 0x0e, 0x73, 0x74,
814 0x61, 0x74, 0x75, 0x73, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x05, 0x20, 0x01,
815 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0d, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x4d,
816 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x3a, 0x0a, 0x16, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73,
817 0x74, 0x65, 0x64, 0x5f, 0x63, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x6c, 0x61, 0x74, 0x69, 0x6f, 0x6e,
818 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x15, 0x72, 0x65, 0x71,
819 0x75, 0x65, 0x73, 0x74, 0x65, 0x64, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x6c, 0x61, 0x74, 0x69,
820 0x6f, 0x6e, 0x12, 0x24, 0x0a, 0x0b, 0x61, 0x70, 0x69, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f,
821 0x6e, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x61, 0x70,
822 0x69, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x32, 0xa3, 0x09, 0x0a, 0x0c, 0x42, 0x61, 0x74,
823 0x63, 0x68, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0xad, 0x01, 0x0a, 0x09, 0x43, 0x72,
824 0x65, 0x61, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x12, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
825 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61,
826 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x52,
827 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x20, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
828 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61, 0x6c,
829 0x70, 0x68, 0x61, 0x31, 0x2e, 0x4a, 0x6f, 0x62, 0x22, 0x4f, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x35,
830 0x22, 0x2e, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72,
831 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c,
832 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x6a, 0x6f, 0x62, 0x73,
833 0x3a, 0x03, 0x6a, 0x6f, 0x62, 0xda, 0x41, 0x11, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x6a,
834 0x6f, 0x62, 0x2c, 0x6a, 0x6f, 0x62, 0x5f, 0x69, 0x64, 0x12, 0x95, 0x01, 0x0a, 0x06, 0x47, 0x65,
835 0x74, 0x4a, 0x6f, 0x62, 0x12, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
836 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68,
837 0x61, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
838 0x1a, 0x20, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
839 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x4a,
840 0x6f, 0x62, 0x22, 0x3d, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x30, 0x12, 0x2e, 0x2f, 0x76, 0x31, 0x61,
841 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a,
842 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73,
843 0x2f, 0x2a, 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d,
844 0x65, 0x12, 0xe2, 0x01, 0x0a, 0x09, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x12,
845 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62,
846 0x61, 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x44, 0x65,
847 0x6c, 0x65, 0x74, 0x65, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d,
848 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e,
849 0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x86, 0x01,
850 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x30, 0x2a, 0x2e, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61,
851 0x31, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73,
852 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x6a,
853 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0xca, 0x41, 0x46,
854 0x0a, 0x15, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75,
855 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12, 0x2d, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
856 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61, 0x6c,
857 0x70, 0x68, 0x61, 0x31, 0x2e, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x65,
858 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0xa8, 0x01, 0x0a, 0x08, 0x4c, 0x69, 0x73, 0x74, 0x4a,
859 0x6f, 0x62, 0x73, 0x12, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
860 0x75, 0x64, 0x2e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61,
861 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4a, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
862 0x74, 0x1a, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
863 0x2e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e,
864 0x4c, 0x69, 0x73, 0x74, 0x4a, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
865 0x22, 0x3f, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x30, 0x12, 0x2e, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70,
866 0x68, 0x61, 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a,
867 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73,
868 0x2f, 0x2a, 0x7d, 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e,
869 0x74, 0x12, 0xad, 0x01, 0x0a, 0x07, 0x47, 0x65, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x2b, 0x2e,
870 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x61, 0x74,
871 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x54,
872 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x21, 0x2e, 0x67, 0x6f, 0x6f,
873 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e,
874 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x22, 0x52, 0x82,
875 0xd3, 0xe4, 0x93, 0x02, 0x45, 0x12, 0x43, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31,
876 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f,
877 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x6a, 0x6f,
878 0x62, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x47, 0x72, 0x6f, 0x75, 0x70, 0x73, 0x2f,
879 0x2a, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d,
880 0x65, 0x12, 0xc0, 0x01, 0x0a, 0x09, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12,
881 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62,
882 0x61, 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x4c, 0x69,
883 0x73, 0x74, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2e,
884 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x61,
885 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x4c, 0x69, 0x73,
886 0x74, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x54,
887 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x45, 0x12, 0x43, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61,
888 0x31, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
889 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a,
890 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x47, 0x72, 0x6f, 0x75,
891 0x70, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0xda, 0x41, 0x06, 0x70, 0x61,
892 0x72, 0x65, 0x6e, 0x74, 0x1a, 0x48, 0xca, 0x41, 0x14, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x67,
893 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x2e,
894 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
895 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f,
896 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x42, 0x77,
897 0x0a, 0x1f, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
898 0x75, 0x64, 0x2e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61,
899 0x31, 0x42, 0x0a, 0x42, 0x61, 0x74, 0x63, 0x68, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a,
900 0x40, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f,
901 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67,
902 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x61, 0x74,
903 0x63, 0x68, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x3b, 0x62, 0x61, 0x74, 0x63,
904 0x68, 0xa2, 0x02, 0x03, 0x47, 0x43, 0x42, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
905 }
906
907 var (
908 file_google_cloud_batch_v1alpha1_batch_proto_rawDescOnce sync.Once
909 file_google_cloud_batch_v1alpha1_batch_proto_rawDescData = file_google_cloud_batch_v1alpha1_batch_proto_rawDesc
910 )
911
912 func file_google_cloud_batch_v1alpha1_batch_proto_rawDescGZIP() []byte {
913 file_google_cloud_batch_v1alpha1_batch_proto_rawDescOnce.Do(func() {
914 file_google_cloud_batch_v1alpha1_batch_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_batch_v1alpha1_batch_proto_rawDescData)
915 })
916 return file_google_cloud_batch_v1alpha1_batch_proto_rawDescData
917 }
918
919 var file_google_cloud_batch_v1alpha1_batch_proto_msgTypes = make([]protoimpl.MessageInfo, 9)
920 var file_google_cloud_batch_v1alpha1_batch_proto_goTypes = []interface{}{
921 (*CreateJobRequest)(nil),
922 (*GetJobRequest)(nil),
923 (*DeleteJobRequest)(nil),
924 (*ListJobsRequest)(nil),
925 (*ListJobsResponse)(nil),
926 (*ListTasksRequest)(nil),
927 (*ListTasksResponse)(nil),
928 (*GetTaskRequest)(nil),
929 (*OperationMetadata)(nil),
930 (*Job)(nil),
931 (*Task)(nil),
932 (*timestamppb.Timestamp)(nil),
933 (*longrunning.Operation)(nil),
934 }
935 var file_google_cloud_batch_v1alpha1_batch_proto_depIdxs = []int32{
936 9,
937 9,
938 10,
939 11,
940 11,
941 0,
942 1,
943 2,
944 3,
945 7,
946 5,
947 9,
948 9,
949 12,
950 4,
951 10,
952 6,
953 11,
954 5,
955 5,
956 5,
957 0,
958 }
959
960 func init() { file_google_cloud_batch_v1alpha1_batch_proto_init() }
961 func file_google_cloud_batch_v1alpha1_batch_proto_init() {
962 if File_google_cloud_batch_v1alpha1_batch_proto != nil {
963 return
964 }
965 file_google_cloud_batch_v1alpha1_job_proto_init()
966 file_google_cloud_batch_v1alpha1_task_proto_init()
967 if !protoimpl.UnsafeEnabled {
968 file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
969 switch v := v.(*CreateJobRequest); i {
970 case 0:
971 return &v.state
972 case 1:
973 return &v.sizeCache
974 case 2:
975 return &v.unknownFields
976 default:
977 return nil
978 }
979 }
980 file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
981 switch v := v.(*GetJobRequest); i {
982 case 0:
983 return &v.state
984 case 1:
985 return &v.sizeCache
986 case 2:
987 return &v.unknownFields
988 default:
989 return nil
990 }
991 }
992 file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
993 switch v := v.(*DeleteJobRequest); i {
994 case 0:
995 return &v.state
996 case 1:
997 return &v.sizeCache
998 case 2:
999 return &v.unknownFields
1000 default:
1001 return nil
1002 }
1003 }
1004 file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
1005 switch v := v.(*ListJobsRequest); i {
1006 case 0:
1007 return &v.state
1008 case 1:
1009 return &v.sizeCache
1010 case 2:
1011 return &v.unknownFields
1012 default:
1013 return nil
1014 }
1015 }
1016 file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
1017 switch v := v.(*ListJobsResponse); i {
1018 case 0:
1019 return &v.state
1020 case 1:
1021 return &v.sizeCache
1022 case 2:
1023 return &v.unknownFields
1024 default:
1025 return nil
1026 }
1027 }
1028 file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
1029 switch v := v.(*ListTasksRequest); i {
1030 case 0:
1031 return &v.state
1032 case 1:
1033 return &v.sizeCache
1034 case 2:
1035 return &v.unknownFields
1036 default:
1037 return nil
1038 }
1039 }
1040 file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
1041 switch v := v.(*ListTasksResponse); i {
1042 case 0:
1043 return &v.state
1044 case 1:
1045 return &v.sizeCache
1046 case 2:
1047 return &v.unknownFields
1048 default:
1049 return nil
1050 }
1051 }
1052 file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
1053 switch v := v.(*GetTaskRequest); i {
1054 case 0:
1055 return &v.state
1056 case 1:
1057 return &v.sizeCache
1058 case 2:
1059 return &v.unknownFields
1060 default:
1061 return nil
1062 }
1063 }
1064 file_google_cloud_batch_v1alpha1_batch_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
1065 switch v := v.(*OperationMetadata); i {
1066 case 0:
1067 return &v.state
1068 case 1:
1069 return &v.sizeCache
1070 case 2:
1071 return &v.unknownFields
1072 default:
1073 return nil
1074 }
1075 }
1076 }
1077 type x struct{}
1078 out := protoimpl.TypeBuilder{
1079 File: protoimpl.DescBuilder{
1080 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
1081 RawDescriptor: file_google_cloud_batch_v1alpha1_batch_proto_rawDesc,
1082 NumEnums: 0,
1083 NumMessages: 9,
1084 NumExtensions: 0,
1085 NumServices: 1,
1086 },
1087 GoTypes: file_google_cloud_batch_v1alpha1_batch_proto_goTypes,
1088 DependencyIndexes: file_google_cloud_batch_v1alpha1_batch_proto_depIdxs,
1089 MessageInfos: file_google_cloud_batch_v1alpha1_batch_proto_msgTypes,
1090 }.Build()
1091 File_google_cloud_batch_v1alpha1_batch_proto = out.File
1092 file_google_cloud_batch_v1alpha1_batch_proto_rawDesc = nil
1093 file_google_cloud_batch_v1alpha1_batch_proto_goTypes = nil
1094 file_google_cloud_batch_v1alpha1_batch_proto_depIdxs = nil
1095 }
1096
1097
1098 var _ context.Context
1099 var _ grpc.ClientConnInterface
1100
1101
1102
1103 const _ = grpc.SupportPackageIsVersion6
1104
1105
1106
1107
1108 type BatchServiceClient interface {
1109
1110 CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error)
1111
1112 GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)
1113
1114 DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
1115
1116 ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
1117
1118 GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error)
1119
1120 ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
1121 }
1122
1123 type batchServiceClient struct {
1124 cc grpc.ClientConnInterface
1125 }
1126
1127 func NewBatchServiceClient(cc grpc.ClientConnInterface) BatchServiceClient {
1128 return &batchServiceClient{cc}
1129 }
1130
1131 func (c *batchServiceClient) CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error) {
1132 out := new(Job)
1133 err := c.cc.Invoke(ctx, "/google.cloud.batch.v1alpha1.BatchService/CreateJob", in, out, opts...)
1134 if err != nil {
1135 return nil, err
1136 }
1137 return out, nil
1138 }
1139
1140 func (c *batchServiceClient) GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error) {
1141 out := new(Job)
1142 err := c.cc.Invoke(ctx, "/google.cloud.batch.v1alpha1.BatchService/GetJob", in, out, opts...)
1143 if err != nil {
1144 return nil, err
1145 }
1146 return out, nil
1147 }
1148
1149 func (c *batchServiceClient) DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) {
1150 out := new(longrunning.Operation)
1151 err := c.cc.Invoke(ctx, "/google.cloud.batch.v1alpha1.BatchService/DeleteJob", in, out, opts...)
1152 if err != nil {
1153 return nil, err
1154 }
1155 return out, nil
1156 }
1157
1158 func (c *batchServiceClient) ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) {
1159 out := new(ListJobsResponse)
1160 err := c.cc.Invoke(ctx, "/google.cloud.batch.v1alpha1.BatchService/ListJobs", in, out, opts...)
1161 if err != nil {
1162 return nil, err
1163 }
1164 return out, nil
1165 }
1166
1167 func (c *batchServiceClient) GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error) {
1168 out := new(Task)
1169 err := c.cc.Invoke(ctx, "/google.cloud.batch.v1alpha1.BatchService/GetTask", in, out, opts...)
1170 if err != nil {
1171 return nil, err
1172 }
1173 return out, nil
1174 }
1175
1176 func (c *batchServiceClient) ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error) {
1177 out := new(ListTasksResponse)
1178 err := c.cc.Invoke(ctx, "/google.cloud.batch.v1alpha1.BatchService/ListTasks", in, out, opts...)
1179 if err != nil {
1180 return nil, err
1181 }
1182 return out, nil
1183 }
1184
1185
1186 type BatchServiceServer interface {
1187
1188 CreateJob(context.Context, *CreateJobRequest) (*Job, error)
1189
1190 GetJob(context.Context, *GetJobRequest) (*Job, error)
1191
1192 DeleteJob(context.Context, *DeleteJobRequest) (*longrunning.Operation, error)
1193
1194 ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
1195
1196 GetTask(context.Context, *GetTaskRequest) (*Task, error)
1197
1198 ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
1199 }
1200
1201
1202 type UnimplementedBatchServiceServer struct {
1203 }
1204
1205 func (*UnimplementedBatchServiceServer) CreateJob(context.Context, *CreateJobRequest) (*Job, error) {
1206 return nil, status.Errorf(codes.Unimplemented, "method CreateJob not implemented")
1207 }
1208 func (*UnimplementedBatchServiceServer) GetJob(context.Context, *GetJobRequest) (*Job, error) {
1209 return nil, status.Errorf(codes.Unimplemented, "method GetJob not implemented")
1210 }
1211 func (*UnimplementedBatchServiceServer) DeleteJob(context.Context, *DeleteJobRequest) (*longrunning.Operation, error) {
1212 return nil, status.Errorf(codes.Unimplemented, "method DeleteJob not implemented")
1213 }
1214 func (*UnimplementedBatchServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) {
1215 return nil, status.Errorf(codes.Unimplemented, "method ListJobs not implemented")
1216 }
1217 func (*UnimplementedBatchServiceServer) GetTask(context.Context, *GetTaskRequest) (*Task, error) {
1218 return nil, status.Errorf(codes.Unimplemented, "method GetTask not implemented")
1219 }
1220 func (*UnimplementedBatchServiceServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error) {
1221 return nil, status.Errorf(codes.Unimplemented, "method ListTasks not implemented")
1222 }
1223
1224 func RegisterBatchServiceServer(s *grpc.Server, srv BatchServiceServer) {
1225 s.RegisterService(&_BatchService_serviceDesc, srv)
1226 }
1227
1228 func _BatchService_CreateJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1229 in := new(CreateJobRequest)
1230 if err := dec(in); err != nil {
1231 return nil, err
1232 }
1233 if interceptor == nil {
1234 return srv.(BatchServiceServer).CreateJob(ctx, in)
1235 }
1236 info := &grpc.UnaryServerInfo{
1237 Server: srv,
1238 FullMethod: "/google.cloud.batch.v1alpha1.BatchService/CreateJob",
1239 }
1240 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1241 return srv.(BatchServiceServer).CreateJob(ctx, req.(*CreateJobRequest))
1242 }
1243 return interceptor(ctx, in, info, handler)
1244 }
1245
1246 func _BatchService_GetJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1247 in := new(GetJobRequest)
1248 if err := dec(in); err != nil {
1249 return nil, err
1250 }
1251 if interceptor == nil {
1252 return srv.(BatchServiceServer).GetJob(ctx, in)
1253 }
1254 info := &grpc.UnaryServerInfo{
1255 Server: srv,
1256 FullMethod: "/google.cloud.batch.v1alpha1.BatchService/GetJob",
1257 }
1258 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1259 return srv.(BatchServiceServer).GetJob(ctx, req.(*GetJobRequest))
1260 }
1261 return interceptor(ctx, in, info, handler)
1262 }
1263
1264 func _BatchService_DeleteJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1265 in := new(DeleteJobRequest)
1266 if err := dec(in); err != nil {
1267 return nil, err
1268 }
1269 if interceptor == nil {
1270 return srv.(BatchServiceServer).DeleteJob(ctx, in)
1271 }
1272 info := &grpc.UnaryServerInfo{
1273 Server: srv,
1274 FullMethod: "/google.cloud.batch.v1alpha1.BatchService/DeleteJob",
1275 }
1276 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1277 return srv.(BatchServiceServer).DeleteJob(ctx, req.(*DeleteJobRequest))
1278 }
1279 return interceptor(ctx, in, info, handler)
1280 }
1281
1282 func _BatchService_ListJobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1283 in := new(ListJobsRequest)
1284 if err := dec(in); err != nil {
1285 return nil, err
1286 }
1287 if interceptor == nil {
1288 return srv.(BatchServiceServer).ListJobs(ctx, in)
1289 }
1290 info := &grpc.UnaryServerInfo{
1291 Server: srv,
1292 FullMethod: "/google.cloud.batch.v1alpha1.BatchService/ListJobs",
1293 }
1294 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1295 return srv.(BatchServiceServer).ListJobs(ctx, req.(*ListJobsRequest))
1296 }
1297 return interceptor(ctx, in, info, handler)
1298 }
1299
1300 func _BatchService_GetTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1301 in := new(GetTaskRequest)
1302 if err := dec(in); err != nil {
1303 return nil, err
1304 }
1305 if interceptor == nil {
1306 return srv.(BatchServiceServer).GetTask(ctx, in)
1307 }
1308 info := &grpc.UnaryServerInfo{
1309 Server: srv,
1310 FullMethod: "/google.cloud.batch.v1alpha1.BatchService/GetTask",
1311 }
1312 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1313 return srv.(BatchServiceServer).GetTask(ctx, req.(*GetTaskRequest))
1314 }
1315 return interceptor(ctx, in, info, handler)
1316 }
1317
1318 func _BatchService_ListTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1319 in := new(ListTasksRequest)
1320 if err := dec(in); err != nil {
1321 return nil, err
1322 }
1323 if interceptor == nil {
1324 return srv.(BatchServiceServer).ListTasks(ctx, in)
1325 }
1326 info := &grpc.UnaryServerInfo{
1327 Server: srv,
1328 FullMethod: "/google.cloud.batch.v1alpha1.BatchService/ListTasks",
1329 }
1330 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1331 return srv.(BatchServiceServer).ListTasks(ctx, req.(*ListTasksRequest))
1332 }
1333 return interceptor(ctx, in, info, handler)
1334 }
1335
1336 var _BatchService_serviceDesc = grpc.ServiceDesc{
1337 ServiceName: "google.cloud.batch.v1alpha1.BatchService",
1338 HandlerType: (*BatchServiceServer)(nil),
1339 Methods: []grpc.MethodDesc{
1340 {
1341 MethodName: "CreateJob",
1342 Handler: _BatchService_CreateJob_Handler,
1343 },
1344 {
1345 MethodName: "GetJob",
1346 Handler: _BatchService_GetJob_Handler,
1347 },
1348 {
1349 MethodName: "DeleteJob",
1350 Handler: _BatchService_DeleteJob_Handler,
1351 },
1352 {
1353 MethodName: "ListJobs",
1354 Handler: _BatchService_ListJobs_Handler,
1355 },
1356 {
1357 MethodName: "GetTask",
1358 Handler: _BatchService_GetTask_Handler,
1359 },
1360 {
1361 MethodName: "ListTasks",
1362 Handler: _BatchService_ListTasks_Handler,
1363 },
1364 },
1365 Streams: []grpc.StreamDesc{},
1366 Metadata: "google/cloud/batch/v1alpha1/batch.proto",
1367 }
1368
View as plain text