1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21 package dataproc
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 durationpb "google.golang.org/protobuf/types/known/durationpb"
36 emptypb "google.golang.org/protobuf/types/known/emptypb"
37 timestamppb "google.golang.org/protobuf/types/known/timestamppb"
38 )
39
40 const (
41
42 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
43
44 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
45 )
46
47
48 type WorkflowMetadata_State int32
49
50 const (
51
52 WorkflowMetadata_UNKNOWN WorkflowMetadata_State = 0
53
54 WorkflowMetadata_PENDING WorkflowMetadata_State = 1
55
56 WorkflowMetadata_RUNNING WorkflowMetadata_State = 2
57
58 WorkflowMetadata_DONE WorkflowMetadata_State = 3
59 )
60
61
62 var (
63 WorkflowMetadata_State_name = map[int32]string{
64 0: "UNKNOWN",
65 1: "PENDING",
66 2: "RUNNING",
67 3: "DONE",
68 }
69 WorkflowMetadata_State_value = map[string]int32{
70 "UNKNOWN": 0,
71 "PENDING": 1,
72 "RUNNING": 2,
73 "DONE": 3,
74 }
75 )
76
77 func (x WorkflowMetadata_State) Enum() *WorkflowMetadata_State {
78 p := new(WorkflowMetadata_State)
79 *p = x
80 return p
81 }
82
83 func (x WorkflowMetadata_State) String() string {
84 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
85 }
86
87 func (WorkflowMetadata_State) Descriptor() protoreflect.EnumDescriptor {
88 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_enumTypes[0].Descriptor()
89 }
90
91 func (WorkflowMetadata_State) Type() protoreflect.EnumType {
92 return &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_enumTypes[0]
93 }
94
95 func (x WorkflowMetadata_State) Number() protoreflect.EnumNumber {
96 return protoreflect.EnumNumber(x)
97 }
98
99
100 func (WorkflowMetadata_State) EnumDescriptor() ([]byte, []int) {
101 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{9, 0}
102 }
103
104
105 type WorkflowNode_NodeState int32
106
107 const (
108
109 WorkflowNode_NODE_STATUS_UNSPECIFIED WorkflowNode_NodeState = 0
110
111 WorkflowNode_BLOCKED WorkflowNode_NodeState = 1
112
113 WorkflowNode_RUNNABLE WorkflowNode_NodeState = 2
114
115 WorkflowNode_RUNNING WorkflowNode_NodeState = 3
116
117 WorkflowNode_COMPLETED WorkflowNode_NodeState = 4
118
119
120 WorkflowNode_FAILED WorkflowNode_NodeState = 5
121 )
122
123
124 var (
125 WorkflowNode_NodeState_name = map[int32]string{
126 0: "NODE_STATUS_UNSPECIFIED",
127 1: "BLOCKED",
128 2: "RUNNABLE",
129 3: "RUNNING",
130 4: "COMPLETED",
131 5: "FAILED",
132 }
133 WorkflowNode_NodeState_value = map[string]int32{
134 "NODE_STATUS_UNSPECIFIED": 0,
135 "BLOCKED": 1,
136 "RUNNABLE": 2,
137 "RUNNING": 3,
138 "COMPLETED": 4,
139 "FAILED": 5,
140 }
141 )
142
143 func (x WorkflowNode_NodeState) Enum() *WorkflowNode_NodeState {
144 p := new(WorkflowNode_NodeState)
145 *p = x
146 return p
147 }
148
149 func (x WorkflowNode_NodeState) String() string {
150 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
151 }
152
153 func (WorkflowNode_NodeState) Descriptor() protoreflect.EnumDescriptor {
154 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_enumTypes[1].Descriptor()
155 }
156
157 func (WorkflowNode_NodeState) Type() protoreflect.EnumType {
158 return &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_enumTypes[1]
159 }
160
161 func (x WorkflowNode_NodeState) Number() protoreflect.EnumNumber {
162 return protoreflect.EnumNumber(x)
163 }
164
165
166 func (WorkflowNode_NodeState) EnumDescriptor() ([]byte, []int) {
167 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{12, 0}
168 }
169
170
171 type WorkflowTemplate struct {
172 state protoimpl.MessageState
173 sizeCache protoimpl.SizeCache
174 unknownFields protoimpl.UnknownFields
175
176
177
178
179
180
181
182
183 Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
184
185
186
187
188
189
190
191
192
193
194 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
195
196
197
198
199
200
201
202
203
204 Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
205
206 CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
207
208 UpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
209
210
211
212
213
214
215
216
217
218
219
220
221 Labels map[string]string `protobuf:"bytes,6,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
222
223 Placement *WorkflowTemplatePlacement `protobuf:"bytes,7,opt,name=placement,proto3" json:"placement,omitempty"`
224
225 Jobs []*OrderedJob `protobuf:"bytes,8,rep,name=jobs,proto3" json:"jobs,omitempty"`
226
227
228
229 Parameters []*TemplateParameter `protobuf:"bytes,9,rep,name=parameters,proto3" json:"parameters,omitempty"`
230
231
232
233
234
235
236
237
238
239 DagTimeout *durationpb.Duration `protobuf:"bytes,10,opt,name=dag_timeout,json=dagTimeout,proto3" json:"dag_timeout,omitempty"`
240 }
241
242 func (x *WorkflowTemplate) Reset() {
243 *x = WorkflowTemplate{}
244 if protoimpl.UnsafeEnabled {
245 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[0]
246 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
247 ms.StoreMessageInfo(mi)
248 }
249 }
250
251 func (x *WorkflowTemplate) String() string {
252 return protoimpl.X.MessageStringOf(x)
253 }
254
255 func (*WorkflowTemplate) ProtoMessage() {}
256
257 func (x *WorkflowTemplate) ProtoReflect() protoreflect.Message {
258 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[0]
259 if protoimpl.UnsafeEnabled && x != nil {
260 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
261 if ms.LoadMessageInfo() == nil {
262 ms.StoreMessageInfo(mi)
263 }
264 return ms
265 }
266 return mi.MessageOf(x)
267 }
268
269
270 func (*WorkflowTemplate) Descriptor() ([]byte, []int) {
271 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{0}
272 }
273
274 func (x *WorkflowTemplate) GetId() string {
275 if x != nil {
276 return x.Id
277 }
278 return ""
279 }
280
281 func (x *WorkflowTemplate) GetName() string {
282 if x != nil {
283 return x.Name
284 }
285 return ""
286 }
287
288 func (x *WorkflowTemplate) GetVersion() int32 {
289 if x != nil {
290 return x.Version
291 }
292 return 0
293 }
294
295 func (x *WorkflowTemplate) GetCreateTime() *timestamppb.Timestamp {
296 if x != nil {
297 return x.CreateTime
298 }
299 return nil
300 }
301
302 func (x *WorkflowTemplate) GetUpdateTime() *timestamppb.Timestamp {
303 if x != nil {
304 return x.UpdateTime
305 }
306 return nil
307 }
308
309 func (x *WorkflowTemplate) GetLabels() map[string]string {
310 if x != nil {
311 return x.Labels
312 }
313 return nil
314 }
315
316 func (x *WorkflowTemplate) GetPlacement() *WorkflowTemplatePlacement {
317 if x != nil {
318 return x.Placement
319 }
320 return nil
321 }
322
323 func (x *WorkflowTemplate) GetJobs() []*OrderedJob {
324 if x != nil {
325 return x.Jobs
326 }
327 return nil
328 }
329
330 func (x *WorkflowTemplate) GetParameters() []*TemplateParameter {
331 if x != nil {
332 return x.Parameters
333 }
334 return nil
335 }
336
337 func (x *WorkflowTemplate) GetDagTimeout() *durationpb.Duration {
338 if x != nil {
339 return x.DagTimeout
340 }
341 return nil
342 }
343
344
345
346
347 type WorkflowTemplatePlacement struct {
348 state protoimpl.MessageState
349 sizeCache protoimpl.SizeCache
350 unknownFields protoimpl.UnknownFields
351
352
353
354
355
356
357
358 Placement isWorkflowTemplatePlacement_Placement `protobuf_oneof:"placement"`
359 }
360
361 func (x *WorkflowTemplatePlacement) Reset() {
362 *x = WorkflowTemplatePlacement{}
363 if protoimpl.UnsafeEnabled {
364 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[1]
365 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
366 ms.StoreMessageInfo(mi)
367 }
368 }
369
370 func (x *WorkflowTemplatePlacement) String() string {
371 return protoimpl.X.MessageStringOf(x)
372 }
373
374 func (*WorkflowTemplatePlacement) ProtoMessage() {}
375
376 func (x *WorkflowTemplatePlacement) ProtoReflect() protoreflect.Message {
377 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[1]
378 if protoimpl.UnsafeEnabled && x != nil {
379 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
380 if ms.LoadMessageInfo() == nil {
381 ms.StoreMessageInfo(mi)
382 }
383 return ms
384 }
385 return mi.MessageOf(x)
386 }
387
388
389 func (*WorkflowTemplatePlacement) Descriptor() ([]byte, []int) {
390 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{1}
391 }
392
393 func (m *WorkflowTemplatePlacement) GetPlacement() isWorkflowTemplatePlacement_Placement {
394 if m != nil {
395 return m.Placement
396 }
397 return nil
398 }
399
400 func (x *WorkflowTemplatePlacement) GetManagedCluster() *ManagedCluster {
401 if x, ok := x.GetPlacement().(*WorkflowTemplatePlacement_ManagedCluster); ok {
402 return x.ManagedCluster
403 }
404 return nil
405 }
406
407 func (x *WorkflowTemplatePlacement) GetClusterSelector() *ClusterSelector {
408 if x, ok := x.GetPlacement().(*WorkflowTemplatePlacement_ClusterSelector); ok {
409 return x.ClusterSelector
410 }
411 return nil
412 }
413
414 type isWorkflowTemplatePlacement_Placement interface {
415 isWorkflowTemplatePlacement_Placement()
416 }
417
418 type WorkflowTemplatePlacement_ManagedCluster struct {
419
420 ManagedCluster *ManagedCluster `protobuf:"bytes,1,opt,name=managed_cluster,json=managedCluster,proto3,oneof"`
421 }
422
423 type WorkflowTemplatePlacement_ClusterSelector struct {
424
425
426
427
428 ClusterSelector *ClusterSelector `protobuf:"bytes,2,opt,name=cluster_selector,json=clusterSelector,proto3,oneof"`
429 }
430
431 func (*WorkflowTemplatePlacement_ManagedCluster) isWorkflowTemplatePlacement_Placement() {}
432
433 func (*WorkflowTemplatePlacement_ClusterSelector) isWorkflowTemplatePlacement_Placement() {}
434
435
436 type ManagedCluster struct {
437 state protoimpl.MessageState
438 sizeCache protoimpl.SizeCache
439 unknownFields protoimpl.UnknownFields
440
441
442
443
444
445
446
447 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
448
449 Config *ClusterConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
450
451
452
453
454
455
456
457
458
459
460 Labels map[string]string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
461 }
462
463 func (x *ManagedCluster) Reset() {
464 *x = ManagedCluster{}
465 if protoimpl.UnsafeEnabled {
466 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[2]
467 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
468 ms.StoreMessageInfo(mi)
469 }
470 }
471
472 func (x *ManagedCluster) String() string {
473 return protoimpl.X.MessageStringOf(x)
474 }
475
476 func (*ManagedCluster) ProtoMessage() {}
477
478 func (x *ManagedCluster) ProtoReflect() protoreflect.Message {
479 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[2]
480 if protoimpl.UnsafeEnabled && x != nil {
481 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
482 if ms.LoadMessageInfo() == nil {
483 ms.StoreMessageInfo(mi)
484 }
485 return ms
486 }
487 return mi.MessageOf(x)
488 }
489
490
491 func (*ManagedCluster) Descriptor() ([]byte, []int) {
492 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{2}
493 }
494
495 func (x *ManagedCluster) GetClusterName() string {
496 if x != nil {
497 return x.ClusterName
498 }
499 return ""
500 }
501
502 func (x *ManagedCluster) GetConfig() *ClusterConfig {
503 if x != nil {
504 return x.Config
505 }
506 return nil
507 }
508
509 func (x *ManagedCluster) GetLabels() map[string]string {
510 if x != nil {
511 return x.Labels
512 }
513 return nil
514 }
515
516
517 type ClusterSelector struct {
518 state protoimpl.MessageState
519 sizeCache protoimpl.SizeCache
520 unknownFields protoimpl.UnknownFields
521
522
523
524
525
526
527 Zone string `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"`
528
529
530 ClusterLabels map[string]string `protobuf:"bytes,2,rep,name=cluster_labels,json=clusterLabels,proto3" json:"cluster_labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
531 }
532
533 func (x *ClusterSelector) Reset() {
534 *x = ClusterSelector{}
535 if protoimpl.UnsafeEnabled {
536 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[3]
537 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
538 ms.StoreMessageInfo(mi)
539 }
540 }
541
542 func (x *ClusterSelector) String() string {
543 return protoimpl.X.MessageStringOf(x)
544 }
545
546 func (*ClusterSelector) ProtoMessage() {}
547
548 func (x *ClusterSelector) ProtoReflect() protoreflect.Message {
549 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[3]
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
561 func (*ClusterSelector) Descriptor() ([]byte, []int) {
562 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{3}
563 }
564
565 func (x *ClusterSelector) GetZone() string {
566 if x != nil {
567 return x.Zone
568 }
569 return ""
570 }
571
572 func (x *ClusterSelector) GetClusterLabels() map[string]string {
573 if x != nil {
574 return x.ClusterLabels
575 }
576 return nil
577 }
578
579
580 type OrderedJob struct {
581 state protoimpl.MessageState
582 sizeCache protoimpl.SizeCache
583 unknownFields protoimpl.UnknownFields
584
585
586
587
588
589
590
591
592
593
594
595
596 StepId string `protobuf:"bytes,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
597
598
599
600
601
602
603
604
605
606
607
608 JobType isOrderedJob_JobType `protobuf_oneof:"job_type"`
609
610
611
612
613
614
615
616
617
618
619 Labels map[string]string `protobuf:"bytes,8,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
620
621 Scheduling *JobScheduling `protobuf:"bytes,9,opt,name=scheduling,proto3" json:"scheduling,omitempty"`
622
623
624 PrerequisiteStepIds []string `protobuf:"bytes,10,rep,name=prerequisite_step_ids,json=prerequisiteStepIds,proto3" json:"prerequisite_step_ids,omitempty"`
625 }
626
627 func (x *OrderedJob) Reset() {
628 *x = OrderedJob{}
629 if protoimpl.UnsafeEnabled {
630 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[4]
631 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
632 ms.StoreMessageInfo(mi)
633 }
634 }
635
636 func (x *OrderedJob) String() string {
637 return protoimpl.X.MessageStringOf(x)
638 }
639
640 func (*OrderedJob) ProtoMessage() {}
641
642 func (x *OrderedJob) ProtoReflect() protoreflect.Message {
643 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[4]
644 if protoimpl.UnsafeEnabled && x != nil {
645 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
646 if ms.LoadMessageInfo() == nil {
647 ms.StoreMessageInfo(mi)
648 }
649 return ms
650 }
651 return mi.MessageOf(x)
652 }
653
654
655 func (*OrderedJob) Descriptor() ([]byte, []int) {
656 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{4}
657 }
658
659 func (x *OrderedJob) GetStepId() string {
660 if x != nil {
661 return x.StepId
662 }
663 return ""
664 }
665
666 func (m *OrderedJob) GetJobType() isOrderedJob_JobType {
667 if m != nil {
668 return m.JobType
669 }
670 return nil
671 }
672
673 func (x *OrderedJob) GetHadoopJob() *HadoopJob {
674 if x, ok := x.GetJobType().(*OrderedJob_HadoopJob); ok {
675 return x.HadoopJob
676 }
677 return nil
678 }
679
680 func (x *OrderedJob) GetSparkJob() *SparkJob {
681 if x, ok := x.GetJobType().(*OrderedJob_SparkJob); ok {
682 return x.SparkJob
683 }
684 return nil
685 }
686
687 func (x *OrderedJob) GetPysparkJob() *PySparkJob {
688 if x, ok := x.GetJobType().(*OrderedJob_PysparkJob); ok {
689 return x.PysparkJob
690 }
691 return nil
692 }
693
694 func (x *OrderedJob) GetHiveJob() *HiveJob {
695 if x, ok := x.GetJobType().(*OrderedJob_HiveJob); ok {
696 return x.HiveJob
697 }
698 return nil
699 }
700
701 func (x *OrderedJob) GetPigJob() *PigJob {
702 if x, ok := x.GetJobType().(*OrderedJob_PigJob); ok {
703 return x.PigJob
704 }
705 return nil
706 }
707
708 func (x *OrderedJob) GetSparkRJob() *SparkRJob {
709 if x, ok := x.GetJobType().(*OrderedJob_SparkRJob); ok {
710 return x.SparkRJob
711 }
712 return nil
713 }
714
715 func (x *OrderedJob) GetSparkSqlJob() *SparkSqlJob {
716 if x, ok := x.GetJobType().(*OrderedJob_SparkSqlJob); ok {
717 return x.SparkSqlJob
718 }
719 return nil
720 }
721
722 func (x *OrderedJob) GetPrestoJob() *PrestoJob {
723 if x, ok := x.GetJobType().(*OrderedJob_PrestoJob); ok {
724 return x.PrestoJob
725 }
726 return nil
727 }
728
729 func (x *OrderedJob) GetLabels() map[string]string {
730 if x != nil {
731 return x.Labels
732 }
733 return nil
734 }
735
736 func (x *OrderedJob) GetScheduling() *JobScheduling {
737 if x != nil {
738 return x.Scheduling
739 }
740 return nil
741 }
742
743 func (x *OrderedJob) GetPrerequisiteStepIds() []string {
744 if x != nil {
745 return x.PrerequisiteStepIds
746 }
747 return nil
748 }
749
750 type isOrderedJob_JobType interface {
751 isOrderedJob_JobType()
752 }
753
754 type OrderedJob_HadoopJob struct {
755
756 HadoopJob *HadoopJob `protobuf:"bytes,2,opt,name=hadoop_job,json=hadoopJob,proto3,oneof"`
757 }
758
759 type OrderedJob_SparkJob struct {
760
761 SparkJob *SparkJob `protobuf:"bytes,3,opt,name=spark_job,json=sparkJob,proto3,oneof"`
762 }
763
764 type OrderedJob_PysparkJob struct {
765
766 PysparkJob *PySparkJob `protobuf:"bytes,4,opt,name=pyspark_job,json=pysparkJob,proto3,oneof"`
767 }
768
769 type OrderedJob_HiveJob struct {
770
771 HiveJob *HiveJob `protobuf:"bytes,5,opt,name=hive_job,json=hiveJob,proto3,oneof"`
772 }
773
774 type OrderedJob_PigJob struct {
775
776 PigJob *PigJob `protobuf:"bytes,6,opt,name=pig_job,json=pigJob,proto3,oneof"`
777 }
778
779 type OrderedJob_SparkRJob struct {
780
781 SparkRJob *SparkRJob `protobuf:"bytes,11,opt,name=spark_r_job,json=sparkRJob,proto3,oneof"`
782 }
783
784 type OrderedJob_SparkSqlJob struct {
785
786 SparkSqlJob *SparkSqlJob `protobuf:"bytes,7,opt,name=spark_sql_job,json=sparkSqlJob,proto3,oneof"`
787 }
788
789 type OrderedJob_PrestoJob struct {
790
791 PrestoJob *PrestoJob `protobuf:"bytes,12,opt,name=presto_job,json=prestoJob,proto3,oneof"`
792 }
793
794 func (*OrderedJob_HadoopJob) isOrderedJob_JobType() {}
795
796 func (*OrderedJob_SparkJob) isOrderedJob_JobType() {}
797
798 func (*OrderedJob_PysparkJob) isOrderedJob_JobType() {}
799
800 func (*OrderedJob_HiveJob) isOrderedJob_JobType() {}
801
802 func (*OrderedJob_PigJob) isOrderedJob_JobType() {}
803
804 func (*OrderedJob_SparkRJob) isOrderedJob_JobType() {}
805
806 func (*OrderedJob_SparkSqlJob) isOrderedJob_JobType() {}
807
808 func (*OrderedJob_PrestoJob) isOrderedJob_JobType() {}
809
810
811
812
813
814
815
816
817
818
819 type TemplateParameter struct {
820 state protoimpl.MessageState
821 sizeCache protoimpl.SizeCache
822 unknownFields protoimpl.UnknownFields
823
824
825
826
827
828
829
830
831 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876 Fields []string `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
877
878
879 Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
880
881 Validation *ParameterValidation `protobuf:"bytes,4,opt,name=validation,proto3" json:"validation,omitempty"`
882 }
883
884 func (x *TemplateParameter) Reset() {
885 *x = TemplateParameter{}
886 if protoimpl.UnsafeEnabled {
887 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[5]
888 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
889 ms.StoreMessageInfo(mi)
890 }
891 }
892
893 func (x *TemplateParameter) String() string {
894 return protoimpl.X.MessageStringOf(x)
895 }
896
897 func (*TemplateParameter) ProtoMessage() {}
898
899 func (x *TemplateParameter) ProtoReflect() protoreflect.Message {
900 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[5]
901 if protoimpl.UnsafeEnabled && x != nil {
902 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
903 if ms.LoadMessageInfo() == nil {
904 ms.StoreMessageInfo(mi)
905 }
906 return ms
907 }
908 return mi.MessageOf(x)
909 }
910
911
912 func (*TemplateParameter) Descriptor() ([]byte, []int) {
913 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{5}
914 }
915
916 func (x *TemplateParameter) GetName() string {
917 if x != nil {
918 return x.Name
919 }
920 return ""
921 }
922
923 func (x *TemplateParameter) GetFields() []string {
924 if x != nil {
925 return x.Fields
926 }
927 return nil
928 }
929
930 func (x *TemplateParameter) GetDescription() string {
931 if x != nil {
932 return x.Description
933 }
934 return ""
935 }
936
937 func (x *TemplateParameter) GetValidation() *ParameterValidation {
938 if x != nil {
939 return x.Validation
940 }
941 return nil
942 }
943
944
945 type ParameterValidation struct {
946 state protoimpl.MessageState
947 sizeCache protoimpl.SizeCache
948 unknownFields protoimpl.UnknownFields
949
950
951
952
953
954
955 ValidationType isParameterValidation_ValidationType `protobuf_oneof:"validation_type"`
956 }
957
958 func (x *ParameterValidation) Reset() {
959 *x = ParameterValidation{}
960 if protoimpl.UnsafeEnabled {
961 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[6]
962 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
963 ms.StoreMessageInfo(mi)
964 }
965 }
966
967 func (x *ParameterValidation) String() string {
968 return protoimpl.X.MessageStringOf(x)
969 }
970
971 func (*ParameterValidation) ProtoMessage() {}
972
973 func (x *ParameterValidation) ProtoReflect() protoreflect.Message {
974 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[6]
975 if protoimpl.UnsafeEnabled && x != nil {
976 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
977 if ms.LoadMessageInfo() == nil {
978 ms.StoreMessageInfo(mi)
979 }
980 return ms
981 }
982 return mi.MessageOf(x)
983 }
984
985
986 func (*ParameterValidation) Descriptor() ([]byte, []int) {
987 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{6}
988 }
989
990 func (m *ParameterValidation) GetValidationType() isParameterValidation_ValidationType {
991 if m != nil {
992 return m.ValidationType
993 }
994 return nil
995 }
996
997 func (x *ParameterValidation) GetRegex() *RegexValidation {
998 if x, ok := x.GetValidationType().(*ParameterValidation_Regex); ok {
999 return x.Regex
1000 }
1001 return nil
1002 }
1003
1004 func (x *ParameterValidation) GetValues() *ValueValidation {
1005 if x, ok := x.GetValidationType().(*ParameterValidation_Values); ok {
1006 return x.Values
1007 }
1008 return nil
1009 }
1010
1011 type isParameterValidation_ValidationType interface {
1012 isParameterValidation_ValidationType()
1013 }
1014
1015 type ParameterValidation_Regex struct {
1016
1017 Regex *RegexValidation `protobuf:"bytes,1,opt,name=regex,proto3,oneof"`
1018 }
1019
1020 type ParameterValidation_Values struct {
1021
1022 Values *ValueValidation `protobuf:"bytes,2,opt,name=values,proto3,oneof"`
1023 }
1024
1025 func (*ParameterValidation_Regex) isParameterValidation_ValidationType() {}
1026
1027 func (*ParameterValidation_Values) isParameterValidation_ValidationType() {}
1028
1029
1030 type RegexValidation struct {
1031 state protoimpl.MessageState
1032 sizeCache protoimpl.SizeCache
1033 unknownFields protoimpl.UnknownFields
1034
1035
1036
1037
1038 Regexes []string `protobuf:"bytes,1,rep,name=regexes,proto3" json:"regexes,omitempty"`
1039 }
1040
1041 func (x *RegexValidation) Reset() {
1042 *x = RegexValidation{}
1043 if protoimpl.UnsafeEnabled {
1044 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[7]
1045 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1046 ms.StoreMessageInfo(mi)
1047 }
1048 }
1049
1050 func (x *RegexValidation) String() string {
1051 return protoimpl.X.MessageStringOf(x)
1052 }
1053
1054 func (*RegexValidation) ProtoMessage() {}
1055
1056 func (x *RegexValidation) ProtoReflect() protoreflect.Message {
1057 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[7]
1058 if protoimpl.UnsafeEnabled && x != nil {
1059 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1060 if ms.LoadMessageInfo() == nil {
1061 ms.StoreMessageInfo(mi)
1062 }
1063 return ms
1064 }
1065 return mi.MessageOf(x)
1066 }
1067
1068
1069 func (*RegexValidation) Descriptor() ([]byte, []int) {
1070 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{7}
1071 }
1072
1073 func (x *RegexValidation) GetRegexes() []string {
1074 if x != nil {
1075 return x.Regexes
1076 }
1077 return nil
1078 }
1079
1080
1081 type ValueValidation struct {
1082 state protoimpl.MessageState
1083 sizeCache protoimpl.SizeCache
1084 unknownFields protoimpl.UnknownFields
1085
1086
1087 Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
1088 }
1089
1090 func (x *ValueValidation) Reset() {
1091 *x = ValueValidation{}
1092 if protoimpl.UnsafeEnabled {
1093 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[8]
1094 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1095 ms.StoreMessageInfo(mi)
1096 }
1097 }
1098
1099 func (x *ValueValidation) String() string {
1100 return protoimpl.X.MessageStringOf(x)
1101 }
1102
1103 func (*ValueValidation) ProtoMessage() {}
1104
1105 func (x *ValueValidation) ProtoReflect() protoreflect.Message {
1106 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[8]
1107 if protoimpl.UnsafeEnabled && x != nil {
1108 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1109 if ms.LoadMessageInfo() == nil {
1110 ms.StoreMessageInfo(mi)
1111 }
1112 return ms
1113 }
1114 return mi.MessageOf(x)
1115 }
1116
1117
1118 func (*ValueValidation) Descriptor() ([]byte, []int) {
1119 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{8}
1120 }
1121
1122 func (x *ValueValidation) GetValues() []string {
1123 if x != nil {
1124 return x.Values
1125 }
1126 return nil
1127 }
1128
1129
1130 type WorkflowMetadata struct {
1131 state protoimpl.MessageState
1132 sizeCache protoimpl.SizeCache
1133 unknownFields protoimpl.UnknownFields
1134
1135
1136
1137
1138
1139
1140
1141
1142
1143
1144
1145 Template string `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
1146
1147
1148 Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
1149
1150 CreateCluster *ClusterOperation `protobuf:"bytes,3,opt,name=create_cluster,json=createCluster,proto3" json:"create_cluster,omitempty"`
1151
1152 Graph *WorkflowGraph `protobuf:"bytes,4,opt,name=graph,proto3" json:"graph,omitempty"`
1153
1154 DeleteCluster *ClusterOperation `protobuf:"bytes,5,opt,name=delete_cluster,json=deleteCluster,proto3" json:"delete_cluster,omitempty"`
1155
1156 State WorkflowMetadata_State `protobuf:"varint,6,opt,name=state,proto3,enum=google.cloud.dataproc.v1beta2.WorkflowMetadata_State" json:"state,omitempty"`
1157
1158 ClusterName string `protobuf:"bytes,7,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
1159
1160 Parameters map[string]string `protobuf:"bytes,8,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
1161
1162 StartTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
1163
1164 EndTime *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
1165
1166 ClusterUuid string `protobuf:"bytes,11,opt,name=cluster_uuid,json=clusterUuid,proto3" json:"cluster_uuid,omitempty"`
1167
1168
1169
1170
1171
1172 DagTimeout *durationpb.Duration `protobuf:"bytes,12,opt,name=dag_timeout,json=dagTimeout,proto3" json:"dag_timeout,omitempty"`
1173
1174
1175
1176 DagStartTime *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=dag_start_time,json=dagStartTime,proto3" json:"dag_start_time,omitempty"`
1177
1178
1179
1180 DagEndTime *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=dag_end_time,json=dagEndTime,proto3" json:"dag_end_time,omitempty"`
1181 }
1182
1183 func (x *WorkflowMetadata) Reset() {
1184 *x = WorkflowMetadata{}
1185 if protoimpl.UnsafeEnabled {
1186 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[9]
1187 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1188 ms.StoreMessageInfo(mi)
1189 }
1190 }
1191
1192 func (x *WorkflowMetadata) String() string {
1193 return protoimpl.X.MessageStringOf(x)
1194 }
1195
1196 func (*WorkflowMetadata) ProtoMessage() {}
1197
1198 func (x *WorkflowMetadata) ProtoReflect() protoreflect.Message {
1199 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[9]
1200 if protoimpl.UnsafeEnabled && x != nil {
1201 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1202 if ms.LoadMessageInfo() == nil {
1203 ms.StoreMessageInfo(mi)
1204 }
1205 return ms
1206 }
1207 return mi.MessageOf(x)
1208 }
1209
1210
1211 func (*WorkflowMetadata) Descriptor() ([]byte, []int) {
1212 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{9}
1213 }
1214
1215 func (x *WorkflowMetadata) GetTemplate() string {
1216 if x != nil {
1217 return x.Template
1218 }
1219 return ""
1220 }
1221
1222 func (x *WorkflowMetadata) GetVersion() int32 {
1223 if x != nil {
1224 return x.Version
1225 }
1226 return 0
1227 }
1228
1229 func (x *WorkflowMetadata) GetCreateCluster() *ClusterOperation {
1230 if x != nil {
1231 return x.CreateCluster
1232 }
1233 return nil
1234 }
1235
1236 func (x *WorkflowMetadata) GetGraph() *WorkflowGraph {
1237 if x != nil {
1238 return x.Graph
1239 }
1240 return nil
1241 }
1242
1243 func (x *WorkflowMetadata) GetDeleteCluster() *ClusterOperation {
1244 if x != nil {
1245 return x.DeleteCluster
1246 }
1247 return nil
1248 }
1249
1250 func (x *WorkflowMetadata) GetState() WorkflowMetadata_State {
1251 if x != nil {
1252 return x.State
1253 }
1254 return WorkflowMetadata_UNKNOWN
1255 }
1256
1257 func (x *WorkflowMetadata) GetClusterName() string {
1258 if x != nil {
1259 return x.ClusterName
1260 }
1261 return ""
1262 }
1263
1264 func (x *WorkflowMetadata) GetParameters() map[string]string {
1265 if x != nil {
1266 return x.Parameters
1267 }
1268 return nil
1269 }
1270
1271 func (x *WorkflowMetadata) GetStartTime() *timestamppb.Timestamp {
1272 if x != nil {
1273 return x.StartTime
1274 }
1275 return nil
1276 }
1277
1278 func (x *WorkflowMetadata) GetEndTime() *timestamppb.Timestamp {
1279 if x != nil {
1280 return x.EndTime
1281 }
1282 return nil
1283 }
1284
1285 func (x *WorkflowMetadata) GetClusterUuid() string {
1286 if x != nil {
1287 return x.ClusterUuid
1288 }
1289 return ""
1290 }
1291
1292 func (x *WorkflowMetadata) GetDagTimeout() *durationpb.Duration {
1293 if x != nil {
1294 return x.DagTimeout
1295 }
1296 return nil
1297 }
1298
1299 func (x *WorkflowMetadata) GetDagStartTime() *timestamppb.Timestamp {
1300 if x != nil {
1301 return x.DagStartTime
1302 }
1303 return nil
1304 }
1305
1306 func (x *WorkflowMetadata) GetDagEndTime() *timestamppb.Timestamp {
1307 if x != nil {
1308 return x.DagEndTime
1309 }
1310 return nil
1311 }
1312
1313
1314 type ClusterOperation struct {
1315 state protoimpl.MessageState
1316 sizeCache protoimpl.SizeCache
1317 unknownFields protoimpl.UnknownFields
1318
1319
1320 OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
1321
1322 Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
1323
1324 Done bool `protobuf:"varint,3,opt,name=done,proto3" json:"done,omitempty"`
1325 }
1326
1327 func (x *ClusterOperation) Reset() {
1328 *x = ClusterOperation{}
1329 if protoimpl.UnsafeEnabled {
1330 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[10]
1331 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1332 ms.StoreMessageInfo(mi)
1333 }
1334 }
1335
1336 func (x *ClusterOperation) String() string {
1337 return protoimpl.X.MessageStringOf(x)
1338 }
1339
1340 func (*ClusterOperation) ProtoMessage() {}
1341
1342 func (x *ClusterOperation) ProtoReflect() protoreflect.Message {
1343 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[10]
1344 if protoimpl.UnsafeEnabled && x != nil {
1345 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1346 if ms.LoadMessageInfo() == nil {
1347 ms.StoreMessageInfo(mi)
1348 }
1349 return ms
1350 }
1351 return mi.MessageOf(x)
1352 }
1353
1354
1355 func (*ClusterOperation) Descriptor() ([]byte, []int) {
1356 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{10}
1357 }
1358
1359 func (x *ClusterOperation) GetOperationId() string {
1360 if x != nil {
1361 return x.OperationId
1362 }
1363 return ""
1364 }
1365
1366 func (x *ClusterOperation) GetError() string {
1367 if x != nil {
1368 return x.Error
1369 }
1370 return ""
1371 }
1372
1373 func (x *ClusterOperation) GetDone() bool {
1374 if x != nil {
1375 return x.Done
1376 }
1377 return false
1378 }
1379
1380
1381 type WorkflowGraph struct {
1382 state protoimpl.MessageState
1383 sizeCache protoimpl.SizeCache
1384 unknownFields protoimpl.UnknownFields
1385
1386
1387 Nodes []*WorkflowNode `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
1388 }
1389
1390 func (x *WorkflowGraph) Reset() {
1391 *x = WorkflowGraph{}
1392 if protoimpl.UnsafeEnabled {
1393 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[11]
1394 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1395 ms.StoreMessageInfo(mi)
1396 }
1397 }
1398
1399 func (x *WorkflowGraph) String() string {
1400 return protoimpl.X.MessageStringOf(x)
1401 }
1402
1403 func (*WorkflowGraph) ProtoMessage() {}
1404
1405 func (x *WorkflowGraph) ProtoReflect() protoreflect.Message {
1406 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[11]
1407 if protoimpl.UnsafeEnabled && x != nil {
1408 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1409 if ms.LoadMessageInfo() == nil {
1410 ms.StoreMessageInfo(mi)
1411 }
1412 return ms
1413 }
1414 return mi.MessageOf(x)
1415 }
1416
1417
1418 func (*WorkflowGraph) Descriptor() ([]byte, []int) {
1419 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{11}
1420 }
1421
1422 func (x *WorkflowGraph) GetNodes() []*WorkflowNode {
1423 if x != nil {
1424 return x.Nodes
1425 }
1426 return nil
1427 }
1428
1429
1430 type WorkflowNode struct {
1431 state protoimpl.MessageState
1432 sizeCache protoimpl.SizeCache
1433 unknownFields protoimpl.UnknownFields
1434
1435
1436 StepId string `protobuf:"bytes,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
1437
1438 PrerequisiteStepIds []string `protobuf:"bytes,2,rep,name=prerequisite_step_ids,json=prerequisiteStepIds,proto3" json:"prerequisite_step_ids,omitempty"`
1439
1440 JobId string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
1441
1442 State WorkflowNode_NodeState `protobuf:"varint,5,opt,name=state,proto3,enum=google.cloud.dataproc.v1beta2.WorkflowNode_NodeState" json:"state,omitempty"`
1443
1444 Error string `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
1445 }
1446
1447 func (x *WorkflowNode) Reset() {
1448 *x = WorkflowNode{}
1449 if protoimpl.UnsafeEnabled {
1450 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[12]
1451 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1452 ms.StoreMessageInfo(mi)
1453 }
1454 }
1455
1456 func (x *WorkflowNode) String() string {
1457 return protoimpl.X.MessageStringOf(x)
1458 }
1459
1460 func (*WorkflowNode) ProtoMessage() {}
1461
1462 func (x *WorkflowNode) ProtoReflect() protoreflect.Message {
1463 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[12]
1464 if protoimpl.UnsafeEnabled && x != nil {
1465 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1466 if ms.LoadMessageInfo() == nil {
1467 ms.StoreMessageInfo(mi)
1468 }
1469 return ms
1470 }
1471 return mi.MessageOf(x)
1472 }
1473
1474
1475 func (*WorkflowNode) Descriptor() ([]byte, []int) {
1476 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{12}
1477 }
1478
1479 func (x *WorkflowNode) GetStepId() string {
1480 if x != nil {
1481 return x.StepId
1482 }
1483 return ""
1484 }
1485
1486 func (x *WorkflowNode) GetPrerequisiteStepIds() []string {
1487 if x != nil {
1488 return x.PrerequisiteStepIds
1489 }
1490 return nil
1491 }
1492
1493 func (x *WorkflowNode) GetJobId() string {
1494 if x != nil {
1495 return x.JobId
1496 }
1497 return ""
1498 }
1499
1500 func (x *WorkflowNode) GetState() WorkflowNode_NodeState {
1501 if x != nil {
1502 return x.State
1503 }
1504 return WorkflowNode_NODE_STATUS_UNSPECIFIED
1505 }
1506
1507 func (x *WorkflowNode) GetError() string {
1508 if x != nil {
1509 return x.Error
1510 }
1511 return ""
1512 }
1513
1514
1515 type CreateWorkflowTemplateRequest struct {
1516 state protoimpl.MessageState
1517 sizeCache protoimpl.SizeCache
1518 unknownFields protoimpl.UnknownFields
1519
1520
1521
1522
1523
1524
1525
1526
1527
1528
1529
1530 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
1531
1532 Template *WorkflowTemplate `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
1533 }
1534
1535 func (x *CreateWorkflowTemplateRequest) Reset() {
1536 *x = CreateWorkflowTemplateRequest{}
1537 if protoimpl.UnsafeEnabled {
1538 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[13]
1539 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1540 ms.StoreMessageInfo(mi)
1541 }
1542 }
1543
1544 func (x *CreateWorkflowTemplateRequest) String() string {
1545 return protoimpl.X.MessageStringOf(x)
1546 }
1547
1548 func (*CreateWorkflowTemplateRequest) ProtoMessage() {}
1549
1550 func (x *CreateWorkflowTemplateRequest) ProtoReflect() protoreflect.Message {
1551 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[13]
1552 if protoimpl.UnsafeEnabled && x != nil {
1553 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1554 if ms.LoadMessageInfo() == nil {
1555 ms.StoreMessageInfo(mi)
1556 }
1557 return ms
1558 }
1559 return mi.MessageOf(x)
1560 }
1561
1562
1563 func (*CreateWorkflowTemplateRequest) Descriptor() ([]byte, []int) {
1564 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{13}
1565 }
1566
1567 func (x *CreateWorkflowTemplateRequest) GetParent() string {
1568 if x != nil {
1569 return x.Parent
1570 }
1571 return ""
1572 }
1573
1574 func (x *CreateWorkflowTemplateRequest) GetTemplate() *WorkflowTemplate {
1575 if x != nil {
1576 return x.Template
1577 }
1578 return nil
1579 }
1580
1581
1582 type GetWorkflowTemplateRequest struct {
1583 state protoimpl.MessageState
1584 sizeCache protoimpl.SizeCache
1585 unknownFields protoimpl.UnknownFields
1586
1587
1588
1589
1590
1591
1592
1593
1594
1595
1596
1597 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
1598
1599
1600
1601
1602 Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
1603 }
1604
1605 func (x *GetWorkflowTemplateRequest) Reset() {
1606 *x = GetWorkflowTemplateRequest{}
1607 if protoimpl.UnsafeEnabled {
1608 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[14]
1609 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1610 ms.StoreMessageInfo(mi)
1611 }
1612 }
1613
1614 func (x *GetWorkflowTemplateRequest) String() string {
1615 return protoimpl.X.MessageStringOf(x)
1616 }
1617
1618 func (*GetWorkflowTemplateRequest) ProtoMessage() {}
1619
1620 func (x *GetWorkflowTemplateRequest) ProtoReflect() protoreflect.Message {
1621 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[14]
1622 if protoimpl.UnsafeEnabled && x != nil {
1623 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1624 if ms.LoadMessageInfo() == nil {
1625 ms.StoreMessageInfo(mi)
1626 }
1627 return ms
1628 }
1629 return mi.MessageOf(x)
1630 }
1631
1632
1633 func (*GetWorkflowTemplateRequest) Descriptor() ([]byte, []int) {
1634 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{14}
1635 }
1636
1637 func (x *GetWorkflowTemplateRequest) GetName() string {
1638 if x != nil {
1639 return x.Name
1640 }
1641 return ""
1642 }
1643
1644 func (x *GetWorkflowTemplateRequest) GetVersion() int32 {
1645 if x != nil {
1646 return x.Version
1647 }
1648 return 0
1649 }
1650
1651
1652 type InstantiateWorkflowTemplateRequest struct {
1653 state protoimpl.MessageState
1654 sizeCache protoimpl.SizeCache
1655 unknownFields protoimpl.UnknownFields
1656
1657
1658
1659
1660
1661
1662
1663
1664
1665
1666
1667 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
1668
1669
1670
1671
1672
1673
1674 Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
1675
1676
1677
1678 InstanceId string `protobuf:"bytes,3,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
1679
1680
1681
1682
1683
1684
1685
1686
1687
1688 RequestId string `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
1689
1690
1691 Parameters map[string]string `protobuf:"bytes,4,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
1692 }
1693
1694 func (x *InstantiateWorkflowTemplateRequest) Reset() {
1695 *x = InstantiateWorkflowTemplateRequest{}
1696 if protoimpl.UnsafeEnabled {
1697 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[15]
1698 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1699 ms.StoreMessageInfo(mi)
1700 }
1701 }
1702
1703 func (x *InstantiateWorkflowTemplateRequest) String() string {
1704 return protoimpl.X.MessageStringOf(x)
1705 }
1706
1707 func (*InstantiateWorkflowTemplateRequest) ProtoMessage() {}
1708
1709 func (x *InstantiateWorkflowTemplateRequest) ProtoReflect() protoreflect.Message {
1710 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[15]
1711 if protoimpl.UnsafeEnabled && x != nil {
1712 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1713 if ms.LoadMessageInfo() == nil {
1714 ms.StoreMessageInfo(mi)
1715 }
1716 return ms
1717 }
1718 return mi.MessageOf(x)
1719 }
1720
1721
1722 func (*InstantiateWorkflowTemplateRequest) Descriptor() ([]byte, []int) {
1723 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{15}
1724 }
1725
1726 func (x *InstantiateWorkflowTemplateRequest) GetName() string {
1727 if x != nil {
1728 return x.Name
1729 }
1730 return ""
1731 }
1732
1733 func (x *InstantiateWorkflowTemplateRequest) GetVersion() int32 {
1734 if x != nil {
1735 return x.Version
1736 }
1737 return 0
1738 }
1739
1740
1741 func (x *InstantiateWorkflowTemplateRequest) GetInstanceId() string {
1742 if x != nil {
1743 return x.InstanceId
1744 }
1745 return ""
1746 }
1747
1748 func (x *InstantiateWorkflowTemplateRequest) GetRequestId() string {
1749 if x != nil {
1750 return x.RequestId
1751 }
1752 return ""
1753 }
1754
1755 func (x *InstantiateWorkflowTemplateRequest) GetParameters() map[string]string {
1756 if x != nil {
1757 return x.Parameters
1758 }
1759 return nil
1760 }
1761
1762
1763 type InstantiateInlineWorkflowTemplateRequest struct {
1764 state protoimpl.MessageState
1765 sizeCache protoimpl.SizeCache
1766 unknownFields protoimpl.UnknownFields
1767
1768
1769
1770
1771
1772
1773
1774
1775
1776
1777
1778 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
1779
1780 Template *WorkflowTemplate `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
1781
1782 InstanceId string `protobuf:"bytes,3,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
1783
1784
1785
1786
1787
1788
1789
1790
1791
1792 RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
1793 }
1794
1795 func (x *InstantiateInlineWorkflowTemplateRequest) Reset() {
1796 *x = InstantiateInlineWorkflowTemplateRequest{}
1797 if protoimpl.UnsafeEnabled {
1798 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[16]
1799 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1800 ms.StoreMessageInfo(mi)
1801 }
1802 }
1803
1804 func (x *InstantiateInlineWorkflowTemplateRequest) String() string {
1805 return protoimpl.X.MessageStringOf(x)
1806 }
1807
1808 func (*InstantiateInlineWorkflowTemplateRequest) ProtoMessage() {}
1809
1810 func (x *InstantiateInlineWorkflowTemplateRequest) ProtoReflect() protoreflect.Message {
1811 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[16]
1812 if protoimpl.UnsafeEnabled && x != nil {
1813 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1814 if ms.LoadMessageInfo() == nil {
1815 ms.StoreMessageInfo(mi)
1816 }
1817 return ms
1818 }
1819 return mi.MessageOf(x)
1820 }
1821
1822
1823 func (*InstantiateInlineWorkflowTemplateRequest) Descriptor() ([]byte, []int) {
1824 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{16}
1825 }
1826
1827 func (x *InstantiateInlineWorkflowTemplateRequest) GetParent() string {
1828 if x != nil {
1829 return x.Parent
1830 }
1831 return ""
1832 }
1833
1834 func (x *InstantiateInlineWorkflowTemplateRequest) GetTemplate() *WorkflowTemplate {
1835 if x != nil {
1836 return x.Template
1837 }
1838 return nil
1839 }
1840
1841 func (x *InstantiateInlineWorkflowTemplateRequest) GetInstanceId() string {
1842 if x != nil {
1843 return x.InstanceId
1844 }
1845 return ""
1846 }
1847
1848 func (x *InstantiateInlineWorkflowTemplateRequest) GetRequestId() string {
1849 if x != nil {
1850 return x.RequestId
1851 }
1852 return ""
1853 }
1854
1855
1856 type UpdateWorkflowTemplateRequest struct {
1857 state protoimpl.MessageState
1858 sizeCache protoimpl.SizeCache
1859 unknownFields protoimpl.UnknownFields
1860
1861
1862
1863
1864 Template *WorkflowTemplate `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
1865 }
1866
1867 func (x *UpdateWorkflowTemplateRequest) Reset() {
1868 *x = UpdateWorkflowTemplateRequest{}
1869 if protoimpl.UnsafeEnabled {
1870 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[17]
1871 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1872 ms.StoreMessageInfo(mi)
1873 }
1874 }
1875
1876 func (x *UpdateWorkflowTemplateRequest) String() string {
1877 return protoimpl.X.MessageStringOf(x)
1878 }
1879
1880 func (*UpdateWorkflowTemplateRequest) ProtoMessage() {}
1881
1882 func (x *UpdateWorkflowTemplateRequest) ProtoReflect() protoreflect.Message {
1883 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[17]
1884 if protoimpl.UnsafeEnabled && x != nil {
1885 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1886 if ms.LoadMessageInfo() == nil {
1887 ms.StoreMessageInfo(mi)
1888 }
1889 return ms
1890 }
1891 return mi.MessageOf(x)
1892 }
1893
1894
1895 func (*UpdateWorkflowTemplateRequest) Descriptor() ([]byte, []int) {
1896 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{17}
1897 }
1898
1899 func (x *UpdateWorkflowTemplateRequest) GetTemplate() *WorkflowTemplate {
1900 if x != nil {
1901 return x.Template
1902 }
1903 return nil
1904 }
1905
1906
1907 type ListWorkflowTemplatesRequest struct {
1908 state protoimpl.MessageState
1909 sizeCache protoimpl.SizeCache
1910 unknownFields protoimpl.UnknownFields
1911
1912
1913
1914
1915
1916
1917
1918
1919
1920
1921
1922 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
1923
1924 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
1925
1926
1927 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
1928 }
1929
1930 func (x *ListWorkflowTemplatesRequest) Reset() {
1931 *x = ListWorkflowTemplatesRequest{}
1932 if protoimpl.UnsafeEnabled {
1933 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[18]
1934 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1935 ms.StoreMessageInfo(mi)
1936 }
1937 }
1938
1939 func (x *ListWorkflowTemplatesRequest) String() string {
1940 return protoimpl.X.MessageStringOf(x)
1941 }
1942
1943 func (*ListWorkflowTemplatesRequest) ProtoMessage() {}
1944
1945 func (x *ListWorkflowTemplatesRequest) ProtoReflect() protoreflect.Message {
1946 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[18]
1947 if protoimpl.UnsafeEnabled && x != nil {
1948 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1949 if ms.LoadMessageInfo() == nil {
1950 ms.StoreMessageInfo(mi)
1951 }
1952 return ms
1953 }
1954 return mi.MessageOf(x)
1955 }
1956
1957
1958 func (*ListWorkflowTemplatesRequest) Descriptor() ([]byte, []int) {
1959 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{18}
1960 }
1961
1962 func (x *ListWorkflowTemplatesRequest) GetParent() string {
1963 if x != nil {
1964 return x.Parent
1965 }
1966 return ""
1967 }
1968
1969 func (x *ListWorkflowTemplatesRequest) GetPageSize() int32 {
1970 if x != nil {
1971 return x.PageSize
1972 }
1973 return 0
1974 }
1975
1976 func (x *ListWorkflowTemplatesRequest) GetPageToken() string {
1977 if x != nil {
1978 return x.PageToken
1979 }
1980 return ""
1981 }
1982
1983
1984 type ListWorkflowTemplatesResponse struct {
1985 state protoimpl.MessageState
1986 sizeCache protoimpl.SizeCache
1987 unknownFields protoimpl.UnknownFields
1988
1989
1990 Templates []*WorkflowTemplate `protobuf:"bytes,1,rep,name=templates,proto3" json:"templates,omitempty"`
1991
1992
1993
1994 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
1995 }
1996
1997 func (x *ListWorkflowTemplatesResponse) Reset() {
1998 *x = ListWorkflowTemplatesResponse{}
1999 if protoimpl.UnsafeEnabled {
2000 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[19]
2001 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2002 ms.StoreMessageInfo(mi)
2003 }
2004 }
2005
2006 func (x *ListWorkflowTemplatesResponse) String() string {
2007 return protoimpl.X.MessageStringOf(x)
2008 }
2009
2010 func (*ListWorkflowTemplatesResponse) ProtoMessage() {}
2011
2012 func (x *ListWorkflowTemplatesResponse) ProtoReflect() protoreflect.Message {
2013 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[19]
2014 if protoimpl.UnsafeEnabled && x != nil {
2015 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2016 if ms.LoadMessageInfo() == nil {
2017 ms.StoreMessageInfo(mi)
2018 }
2019 return ms
2020 }
2021 return mi.MessageOf(x)
2022 }
2023
2024
2025 func (*ListWorkflowTemplatesResponse) Descriptor() ([]byte, []int) {
2026 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{19}
2027 }
2028
2029 func (x *ListWorkflowTemplatesResponse) GetTemplates() []*WorkflowTemplate {
2030 if x != nil {
2031 return x.Templates
2032 }
2033 return nil
2034 }
2035
2036 func (x *ListWorkflowTemplatesResponse) GetNextPageToken() string {
2037 if x != nil {
2038 return x.NextPageToken
2039 }
2040 return ""
2041 }
2042
2043
2044
2045
2046 type DeleteWorkflowTemplateRequest struct {
2047 state protoimpl.MessageState
2048 sizeCache protoimpl.SizeCache
2049 unknownFields protoimpl.UnknownFields
2050
2051
2052
2053
2054
2055
2056
2057
2058
2059
2060
2061 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
2062
2063
2064
2065 Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
2066 }
2067
2068 func (x *DeleteWorkflowTemplateRequest) Reset() {
2069 *x = DeleteWorkflowTemplateRequest{}
2070 if protoimpl.UnsafeEnabled {
2071 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[20]
2072 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2073 ms.StoreMessageInfo(mi)
2074 }
2075 }
2076
2077 func (x *DeleteWorkflowTemplateRequest) String() string {
2078 return protoimpl.X.MessageStringOf(x)
2079 }
2080
2081 func (*DeleteWorkflowTemplateRequest) ProtoMessage() {}
2082
2083 func (x *DeleteWorkflowTemplateRequest) ProtoReflect() protoreflect.Message {
2084 mi := &file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[20]
2085 if protoimpl.UnsafeEnabled && x != nil {
2086 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2087 if ms.LoadMessageInfo() == nil {
2088 ms.StoreMessageInfo(mi)
2089 }
2090 return ms
2091 }
2092 return mi.MessageOf(x)
2093 }
2094
2095
2096 func (*DeleteWorkflowTemplateRequest) Descriptor() ([]byte, []int) {
2097 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP(), []int{20}
2098 }
2099
2100 func (x *DeleteWorkflowTemplateRequest) GetName() string {
2101 if x != nil {
2102 return x.Name
2103 }
2104 return ""
2105 }
2106
2107 func (x *DeleteWorkflowTemplateRequest) GetVersion() int32 {
2108 if x != nil {
2109 return x.Version
2110 }
2111 return 0
2112 }
2113
2114 var File_google_cloud_dataproc_v1beta2_workflow_templates_proto protoreflect.FileDescriptor
2115
2116 var file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDesc = []byte{
2117 0x0a, 0x36, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x64,
2118 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f,
2119 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x5f, 0x74, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74,
2120 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1d, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
2121 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e,
2122 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f,
2123 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e,
2124 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70,
2125 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f,
2126 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64,
2127 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a,
2128 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f,
2129 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x2c, 0x67, 0x6f, 0x6f, 0x67,
2130 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f,
2131 0x63, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65,
2132 0x72, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x28, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
2133 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2f,
2134 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x6a, 0x6f, 0x62, 0x73, 0x2e, 0x70, 0x72, 0x6f,
2135 0x74, 0x6f, 0x1a, 0x23, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x6c, 0x6f, 0x6e, 0x67, 0x72,
2136 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2f, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e,
2137 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f,
2138 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f,
2139 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f,
2140 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70,
2141 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f,
2142 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e,
2143 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xf4, 0x06, 0x0a, 0x10, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c,
2144 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x12, 0x13, 0x0a, 0x02, 0x69, 0x64,
2145 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x02, 0x69, 0x64, 0x12,
2146 0x17, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0,
2147 0x41, 0x03, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x1d, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73,
2148 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x07,
2149 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x40, 0x0a, 0x0b, 0x63, 0x72, 0x65, 0x61, 0x74,
2150 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67,
2151 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54,
2152 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x63,
2153 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x40, 0x0a, 0x0b, 0x75, 0x70, 0x64,
2154 0x61, 0x74, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a,
2155 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66,
2156 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52,
2157 0x0a, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x58, 0x0a, 0x06, 0x6c,
2158 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x06, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x3b, 0x2e, 0x67, 0x6f,
2159 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70,
2160 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x6f, 0x72, 0x6b,
2161 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x2e, 0x4c, 0x61, 0x62,
2162 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x06, 0x6c,
2163 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x56, 0x0a, 0x09, 0x70, 0x6c, 0x61, 0x63, 0x65, 0x6d, 0x65,
2164 0x6e, 0x74, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x38, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
2165 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63,
2166 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f,
2167 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x50, 0x6c, 0x61, 0x63, 0x65, 0x6d, 0x65,
2168 0x6e, 0x74, 0x52, 0x09, 0x70, 0x6c, 0x61, 0x63, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x12, 0x3d, 0x0a,
2169 0x04, 0x6a, 0x6f, 0x62, 0x73, 0x18, 0x08, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x67, 0x6f,
2170 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70,
2171 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x4f, 0x72, 0x64, 0x65,
2172 0x72, 0x65, 0x64, 0x4a, 0x6f, 0x62, 0x52, 0x04, 0x6a, 0x6f, 0x62, 0x73, 0x12, 0x55, 0x0a, 0x0a,
2173 0x70, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x18, 0x09, 0x20, 0x03, 0x28, 0x0b,
2174 0x32, 0x30, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
2175 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32,
2176 0x2e, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74,
2177 0x65, 0x72, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x0a, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74,
2178 0x65, 0x72, 0x73, 0x12, 0x3f, 0x0a, 0x0b, 0x64, 0x61, 0x67, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x6f,
2179 0x75, 0x74, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
2180 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74,
2181 0x69, 0x6f, 0x6e, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x0a, 0x64, 0x61, 0x67, 0x54, 0x69, 0x6d,
2182 0x65, 0x6f, 0x75, 0x74, 0x1a, 0x39, 0x0a, 0x0b, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e,
2183 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
2184 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02,
2185 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x3a,
2186 0xca, 0x01, 0xea, 0x41, 0xc6, 0x01, 0x0a, 0x28, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63,
2187 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
2188 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65,
2189 0x12, 0x49, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a,
2190 0x65, 0x63, 0x74, 0x7d, 0x2f, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x72, 0x65,
2191 0x67, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65,
2192 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x2f, 0x7b, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f,
2193 0x77, 0x5f, 0x74, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x7d, 0x12, 0x4d, 0x70, 0x72, 0x6f,
2194 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f,
2195 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f, 0x63, 0x61, 0x74,
2196 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d,
2197 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x2f, 0x7b, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77,
2198 0x5f, 0x74, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x7d, 0x20, 0x01, 0x22, 0xdf, 0x01, 0x0a,
2199 0x19, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74,
2200 0x65, 0x50, 0x6c, 0x61, 0x63, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x12, 0x58, 0x0a, 0x0f, 0x6d, 0x61,
2201 0x6e, 0x61, 0x67, 0x65, 0x64, 0x5f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x18, 0x01, 0x20,
2202 0x01, 0x28, 0x0b, 0x32, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
2203 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65,
2204 0x74, 0x61, 0x32, 0x2e, 0x4d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x64, 0x43, 0x6c, 0x75, 0x73, 0x74,
2205 0x65, 0x72, 0x48, 0x00, 0x52, 0x0e, 0x6d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x64, 0x43, 0x6c, 0x75,
2206 0x73, 0x74, 0x65, 0x72, 0x12, 0x5b, 0x0a, 0x10, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x5f,
2207 0x73, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2e,
2208 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61,
2209 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x43,
2210 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x53, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x48, 0x00,
2211 0x52, 0x0f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x53, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f,
2212 0x72, 0x42, 0x0b, 0x0a, 0x09, 0x70, 0x6c, 0x61, 0x63, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x22, 0x87,
2213 0x02, 0x0a, 0x0e, 0x4d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x64, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65,
2214 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x5f, 0x6e, 0x61, 0x6d,
2215 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72,
2216 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x44, 0x0a, 0x06, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x03,
2217 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
2218 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62,
2219 0x65, 0x74, 0x61, 0x32, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66,
2220 0x69, 0x67, 0x52, 0x06, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x51, 0x0a, 0x06, 0x6c, 0x61,
2221 0x62, 0x65, 0x6c, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x39, 0x2e, 0x67, 0x6f, 0x6f,
2222 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72,
2223 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x4d, 0x61, 0x6e, 0x61, 0x67,
2224 0x65, 0x64, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73,
2225 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x1a, 0x39, 0x0a,
2226 0x0b, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03,
2227 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14,
2228 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76,
2229 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0xd1, 0x01, 0x0a, 0x0f, 0x43, 0x6c, 0x75,
2230 0x73, 0x74, 0x65, 0x72, 0x53, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x12, 0x12, 0x0a, 0x04,
2231 0x7a, 0x6f, 0x6e, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x7a, 0x6f, 0x6e, 0x65,
2232 0x12, 0x68, 0x0a, 0x0e, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x5f, 0x6c, 0x61, 0x62, 0x65,
2233 0x6c, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x41, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
2234 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63,
2235 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72,
2236 0x53, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72,
2237 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x0d, 0x63, 0x6c, 0x75,
2238 0x73, 0x74, 0x65, 0x72, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x1a, 0x40, 0x0a, 0x12, 0x43, 0x6c,
2239 0x75, 0x73, 0x74, 0x65, 0x72, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79,
2240 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b,
2241 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28,
2242 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0xca, 0x07, 0x0a,
2243 0x0a, 0x4f, 0x72, 0x64, 0x65, 0x72, 0x65, 0x64, 0x4a, 0x6f, 0x62, 0x12, 0x1c, 0x0a, 0x07, 0x73,
2244 0x74, 0x65, 0x70, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41,
2245 0x02, 0x52, 0x06, 0x73, 0x74, 0x65, 0x70, 0x49, 0x64, 0x12, 0x4e, 0x0a, 0x0a, 0x68, 0x61, 0x64,
2246 0x6f, 0x6f, 0x70, 0x5f, 0x6a, 0x6f, 0x62, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x28, 0x2e,
2247 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74,
2248 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x48, 0x61,
2249 0x64, 0x6f, 0x6f, 0x70, 0x4a, 0x6f, 0x62, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x48, 0x00, 0x52, 0x09,
2250 0x68, 0x61, 0x64, 0x6f, 0x6f, 0x70, 0x4a, 0x6f, 0x62, 0x12, 0x4b, 0x0a, 0x09, 0x73, 0x70, 0x61,
2251 0x72, 0x6b, 0x5f, 0x6a, 0x6f, 0x62, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e, 0x67,
2252 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61,
2253 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x53, 0x70, 0x61,
2254 0x72, 0x6b, 0x4a, 0x6f, 0x62, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x48, 0x00, 0x52, 0x08, 0x73, 0x70,
2255 0x61, 0x72, 0x6b, 0x4a, 0x6f, 0x62, 0x12, 0x51, 0x0a, 0x0b, 0x70, 0x79, 0x73, 0x70, 0x61, 0x72,
2256 0x6b, 0x5f, 0x6a, 0x6f, 0x62, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x67, 0x6f,
2257 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70,
2258 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x50, 0x79, 0x53, 0x70,
2259 0x61, 0x72, 0x6b, 0x4a, 0x6f, 0x62, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x48, 0x00, 0x52, 0x0a, 0x70,
2260 0x79, 0x73, 0x70, 0x61, 0x72, 0x6b, 0x4a, 0x6f, 0x62, 0x12, 0x48, 0x0a, 0x08, 0x68, 0x69, 0x76,
2261 0x65, 0x5f, 0x6a, 0x6f, 0x62, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x26, 0x2e, 0x67, 0x6f,
2262 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70,
2263 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x48, 0x69, 0x76, 0x65,
2264 0x4a, 0x6f, 0x62, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x48, 0x00, 0x52, 0x07, 0x68, 0x69, 0x76, 0x65,
2265 0x4a, 0x6f, 0x62, 0x12, 0x45, 0x0a, 0x07, 0x70, 0x69, 0x67, 0x5f, 0x6a, 0x6f, 0x62, 0x18, 0x06,
2266 0x20, 0x01, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
2267 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62,
2268 0x65, 0x74, 0x61, 0x32, 0x2e, 0x50, 0x69, 0x67, 0x4a, 0x6f, 0x62, 0x42, 0x03, 0xe0, 0x41, 0x01,
2269 0x48, 0x00, 0x52, 0x06, 0x70, 0x69, 0x67, 0x4a, 0x6f, 0x62, 0x12, 0x4f, 0x0a, 0x0b, 0x73, 0x70,
2270 0x61, 0x72, 0x6b, 0x5f, 0x72, 0x5f, 0x6a, 0x6f, 0x62, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0b, 0x32,
2271 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64,
2272 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e,
2273 0x53, 0x70, 0x61, 0x72, 0x6b, 0x52, 0x4a, 0x6f, 0x62, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x48, 0x00,
2274 0x52, 0x09, 0x73, 0x70, 0x61, 0x72, 0x6b, 0x52, 0x4a, 0x6f, 0x62, 0x12, 0x55, 0x0a, 0x0d, 0x73,
2275 0x70, 0x61, 0x72, 0x6b, 0x5f, 0x73, 0x71, 0x6c, 0x5f, 0x6a, 0x6f, 0x62, 0x18, 0x07, 0x20, 0x01,
2276 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
2277 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74,
2278 0x61, 0x32, 0x2e, 0x53, 0x70, 0x61, 0x72, 0x6b, 0x53, 0x71, 0x6c, 0x4a, 0x6f, 0x62, 0x42, 0x03,
2279 0xe0, 0x41, 0x01, 0x48, 0x00, 0x52, 0x0b, 0x73, 0x70, 0x61, 0x72, 0x6b, 0x53, 0x71, 0x6c, 0x4a,
2280 0x6f, 0x62, 0x12, 0x4e, 0x0a, 0x0a, 0x70, 0x72, 0x65, 0x73, 0x74, 0x6f, 0x5f, 0x6a, 0x6f, 0x62,
2281 0x18, 0x0c, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
2282 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76,
2283 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x50, 0x72, 0x65, 0x73, 0x74, 0x6f, 0x4a, 0x6f, 0x62,
2284 0x42, 0x03, 0xe0, 0x41, 0x01, 0x48, 0x00, 0x52, 0x09, 0x70, 0x72, 0x65, 0x73, 0x74, 0x6f, 0x4a,
2285 0x6f, 0x62, 0x12, 0x52, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x08, 0x20, 0x03,
2286 0x28, 0x0b, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
2287 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74,
2288 0x61, 0x32, 0x2e, 0x4f, 0x72, 0x64, 0x65, 0x72, 0x65, 0x64, 0x4a, 0x6f, 0x62, 0x2e, 0x4c, 0x61,
2289 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x06,
2290 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x51, 0x0a, 0x0a, 0x73, 0x63, 0x68, 0x65, 0x64, 0x75,
2291 0x6c, 0x69, 0x6e, 0x67, 0x18, 0x09, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f,
2292 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72,
2293 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x4a, 0x6f, 0x62, 0x53, 0x63,
2294 0x68, 0x65, 0x64, 0x75, 0x6c, 0x69, 0x6e, 0x67, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x0a, 0x73,
2295 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x69, 0x6e, 0x67, 0x12, 0x37, 0x0a, 0x15, 0x70, 0x72, 0x65,
2296 0x72, 0x65, 0x71, 0x75, 0x69, 0x73, 0x69, 0x74, 0x65, 0x5f, 0x73, 0x74, 0x65, 0x70, 0x5f, 0x69,
2297 0x64, 0x73, 0x18, 0x0a, 0x20, 0x03, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x13, 0x70,
2298 0x72, 0x65, 0x72, 0x65, 0x71, 0x75, 0x69, 0x73, 0x69, 0x74, 0x65, 0x53, 0x74, 0x65, 0x70, 0x49,
2299 0x64, 0x73, 0x1a, 0x39, 0x0a, 0x0b, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72,
2300 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03,
2301 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01,
2302 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x42, 0x0a, 0x0a,
2303 0x08, 0x6a, 0x6f, 0x62, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x22, 0xb5, 0x01, 0x0a, 0x11, 0x54, 0x65,
2304 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x12,
2305 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e,
2306 0x61, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x73, 0x18, 0x02, 0x20,
2307 0x03, 0x28, 0x09, 0x52, 0x06, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x73, 0x12, 0x20, 0x0a, 0x0b, 0x64,
2308 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09,
2309 0x52, 0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x52, 0x0a,
2310 0x0a, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28,
2311 0x0b, 0x32, 0x32, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
2312 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
2313 0x32, 0x2e, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x56, 0x61, 0x6c, 0x69, 0x64,
2314 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0a, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f,
2315 0x6e, 0x22, 0xba, 0x01, 0x0a, 0x13, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x56,
2316 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x46, 0x0a, 0x05, 0x72, 0x65, 0x67,
2317 0x65, 0x78, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
2318 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63,
2319 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x52, 0x65, 0x67, 0x65, 0x78, 0x56, 0x61,
2320 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x48, 0x00, 0x52, 0x05, 0x72, 0x65, 0x67, 0x65,
2321 0x78, 0x12, 0x48, 0x0a, 0x06, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28,
2322 0x0b, 0x32, 0x2e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
2323 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
2324 0x32, 0x2e, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f,
2325 0x6e, 0x48, 0x00, 0x52, 0x06, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x42, 0x11, 0x0a, 0x0f, 0x76,
2326 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x22, 0x2b,
2327 0x0a, 0x0f, 0x52, 0x65, 0x67, 0x65, 0x78, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f,
2328 0x6e, 0x12, 0x18, 0x0a, 0x07, 0x72, 0x65, 0x67, 0x65, 0x78, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03,
2329 0x28, 0x09, 0x52, 0x07, 0x72, 0x65, 0x67, 0x65, 0x78, 0x65, 0x73, 0x22, 0x29, 0x0a, 0x0f, 0x56,
2330 0x61, 0x6c, 0x75, 0x65, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x16,
2331 0x0a, 0x06, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x06,
2332 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x22, 0x98, 0x08, 0x0a, 0x10, 0x57, 0x6f, 0x72, 0x6b, 0x66,
2333 0x6c, 0x6f, 0x77, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x1f, 0x0a, 0x08, 0x74,
2334 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0,
2335 0x41, 0x03, 0x52, 0x08, 0x74, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x12, 0x1d, 0x0a, 0x07,
2336 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x42, 0x03, 0xe0,
2337 0x41, 0x03, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x5b, 0x0a, 0x0e, 0x63,
2338 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x18, 0x03, 0x20,
2339 0x01, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
2340 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65,
2341 0x74, 0x61, 0x32, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x4f, 0x70, 0x65, 0x72, 0x61,
2342 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0d, 0x63, 0x72, 0x65, 0x61, 0x74,
2343 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x12, 0x47, 0x0a, 0x05, 0x67, 0x72, 0x61, 0x70,
2344 0x68, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
2345 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e,
2346 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77,
2347 0x47, 0x72, 0x61, 0x70, 0x68, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x05, 0x67, 0x72, 0x61, 0x70,
2348 0x68, 0x12, 0x5b, 0x0a, 0x0e, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x5f, 0x63, 0x6c, 0x75, 0x73,
2349 0x74, 0x65, 0x72, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
2350 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f,
2351 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65,
2352 0x72, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52,
2353 0x0d, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x12, 0x50,
2354 0x0a, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x35, 0x2e,
2355 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74,
2356 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x6f,
2357 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x53,
2358 0x74, 0x61, 0x74, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65,
2359 0x12, 0x26, 0x0a, 0x0c, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x5f, 0x6e, 0x61, 0x6d, 0x65,
2360 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0b, 0x63, 0x6c, 0x75,
2361 0x73, 0x74, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x5f, 0x0a, 0x0a, 0x70, 0x61, 0x72, 0x61,
2362 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x18, 0x08, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x3f, 0x2e, 0x67,
2363 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61,
2364 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x6f, 0x72,
2365 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x50, 0x61,
2366 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x0a, 0x70,
2367 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x12, 0x3e, 0x0a, 0x0a, 0x73, 0x74, 0x61,
2368 0x72, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x09, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e,
2369 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e,
2370 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x09,
2371 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x3a, 0x0a, 0x08, 0x65, 0x6e, 0x64,
2372 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f,
2373 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69,
2374 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x07, 0x65, 0x6e,
2375 0x64, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x26, 0x0a, 0x0c, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72,
2376 0x5f, 0x75, 0x75, 0x69, 0x64, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03,
2377 0x52, 0x0b, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x55, 0x75, 0x69, 0x64, 0x12, 0x3f, 0x0a,
2378 0x0b, 0x64, 0x61, 0x67, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74, 0x18, 0x0c, 0x20, 0x01,
2379 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
2380 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x03, 0xe0,
2381 0x41, 0x03, 0x52, 0x0a, 0x64, 0x61, 0x67, 0x54, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74, 0x12, 0x45,
2382 0x0a, 0x0e, 0x64, 0x61, 0x67, 0x5f, 0x73, 0x74, 0x61, 0x72, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65,
2383 0x18, 0x0d, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
2384 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61,
2385 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0c, 0x64, 0x61, 0x67, 0x53, 0x74, 0x61, 0x72,
2386 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x41, 0x0a, 0x0c, 0x64, 0x61, 0x67, 0x5f, 0x65, 0x6e, 0x64,
2387 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f,
2388 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69,
2389 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x64, 0x61,
2390 0x67, 0x45, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x1a, 0x3d, 0x0a, 0x0f, 0x50, 0x61, 0x72, 0x61,
2391 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b,
2392 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a,
2393 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61,
2394 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x38, 0x0a, 0x05, 0x53, 0x74, 0x61, 0x74, 0x65,
2395 0x12, 0x0b, 0x0a, 0x07, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00, 0x12, 0x0b, 0x0a,
2396 0x07, 0x50, 0x45, 0x4e, 0x44, 0x49, 0x4e, 0x47, 0x10, 0x01, 0x12, 0x0b, 0x0a, 0x07, 0x52, 0x55,
2397 0x4e, 0x4e, 0x49, 0x4e, 0x47, 0x10, 0x02, 0x12, 0x08, 0x0a, 0x04, 0x44, 0x4f, 0x4e, 0x45, 0x10,
2398 0x03, 0x22, 0x6e, 0x0a, 0x10, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x4f, 0x70, 0x65, 0x72,
2399 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x26, 0x0a, 0x0c, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69,
2400 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03,
2401 0x52, 0x0b, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x19, 0x0a,
2402 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41,
2403 0x03, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x17, 0x0a, 0x04, 0x64, 0x6f, 0x6e, 0x65,
2404 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x04, 0x64, 0x6f, 0x6e,
2405 0x65, 0x22, 0x57, 0x0a, 0x0d, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x47, 0x72, 0x61,
2406 0x70, 0x68, 0x12, 0x46, 0x0a, 0x05, 0x6e, 0x6f, 0x64, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28,
2407 0x0b, 0x32, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
2408 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
2409 0x32, 0x2e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x4e, 0x6f, 0x64, 0x65, 0x42, 0x03,
2410 0xe0, 0x41, 0x03, 0x52, 0x05, 0x6e, 0x6f, 0x64, 0x65, 0x73, 0x22, 0xdb, 0x02, 0x0a, 0x0c, 0x57,
2411 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x4e, 0x6f, 0x64, 0x65, 0x12, 0x1c, 0x0a, 0x07, 0x73,
2412 0x74, 0x65, 0x70, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41,
2413 0x03, 0x52, 0x06, 0x73, 0x74, 0x65, 0x70, 0x49, 0x64, 0x12, 0x37, 0x0a, 0x15, 0x70, 0x72, 0x65,
2414 0x72, 0x65, 0x71, 0x75, 0x69, 0x73, 0x69, 0x74, 0x65, 0x5f, 0x73, 0x74, 0x65, 0x70, 0x5f, 0x69,
2415 0x64, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x13, 0x70,
2416 0x72, 0x65, 0x72, 0x65, 0x71, 0x75, 0x69, 0x73, 0x69, 0x74, 0x65, 0x53, 0x74, 0x65, 0x70, 0x49,
2417 0x64, 0x73, 0x12, 0x1a, 0x0a, 0x06, 0x6a, 0x6f, 0x62, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01,
2418 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x05, 0x6a, 0x6f, 0x62, 0x49, 0x64, 0x12, 0x50,
2419 0x0a, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x35, 0x2e,
2420 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74,
2421 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x6f,
2422 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x4e, 0x6f, 0x64, 0x65, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x53,
2423 0x74, 0x61, 0x74, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x05, 0x73, 0x74, 0x61, 0x74, 0x65,
2424 0x12, 0x19, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x42,
2425 0x03, 0xe0, 0x41, 0x03, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x22, 0x6b, 0x0a, 0x09, 0x4e,
2426 0x6f, 0x64, 0x65, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12, 0x1b, 0x0a, 0x17, 0x4e, 0x4f, 0x44, 0x45,
2427 0x5f, 0x53, 0x54, 0x41, 0x54, 0x55, 0x53, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46,
2428 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0b, 0x0a, 0x07, 0x42, 0x4c, 0x4f, 0x43, 0x4b, 0x45, 0x44,
2429 0x10, 0x01, 0x12, 0x0c, 0x0a, 0x08, 0x52, 0x55, 0x4e, 0x4e, 0x41, 0x42, 0x4c, 0x45, 0x10, 0x02,
2430 0x12, 0x0b, 0x0a, 0x07, 0x52, 0x55, 0x4e, 0x4e, 0x49, 0x4e, 0x47, 0x10, 0x03, 0x12, 0x0d, 0x0a,
2431 0x09, 0x43, 0x4f, 0x4d, 0x50, 0x4c, 0x45, 0x54, 0x45, 0x44, 0x10, 0x04, 0x12, 0x0a, 0x0a, 0x06,
2432 0x46, 0x41, 0x49, 0x4c, 0x45, 0x44, 0x10, 0x05, 0x22, 0xbb, 0x01, 0x0a, 0x1d, 0x43, 0x72, 0x65,
2433 0x61, 0x74, 0x65, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c,
2434 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x48, 0x0a, 0x06, 0x70, 0x61,
2435 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x30, 0xe0, 0x41, 0x02, 0xfa,
2436 0x41, 0x2a, 0x12, 0x28, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x67, 0x6f, 0x6f,
2437 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x57, 0x6f, 0x72, 0x6b,
2438 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x52, 0x06, 0x70, 0x61,
2439 0x72, 0x65, 0x6e, 0x74, 0x12, 0x50, 0x0a, 0x08, 0x74, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65,
2440 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
2441 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76,
2442 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54,
2443 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x08, 0x74, 0x65,
2444 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x22, 0x7c, 0x0a, 0x1a, 0x47, 0x65, 0x74, 0x57, 0x6f, 0x72,
2445 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71,
2446 0x75, 0x65, 0x73, 0x74, 0x12, 0x44, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01,
2447 0x28, 0x09, 0x42, 0x30, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2a, 0x0a, 0x28, 0x64, 0x61, 0x74, 0x61,
2448 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e,
2449 0x63, 0x6f, 0x6d, 0x2f, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70,
2450 0x6c, 0x61, 0x74, 0x65, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65,
2451 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x07, 0x76, 0x65, 0x72,
2452 0x73, 0x69, 0x6f, 0x6e, 0x22, 0xfa, 0x02, 0x0a, 0x22, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74,
2453 0x69, 0x61, 0x74, 0x65, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70,
2454 0x6c, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x44, 0x0a, 0x04, 0x6e,
2455 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x30, 0xe0, 0x41, 0x02, 0xfa, 0x41,
2456 0x2a, 0x0a, 0x28, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
2457 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x57, 0x6f, 0x72, 0x6b, 0x66,
2458 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x52, 0x04, 0x6e, 0x61, 0x6d,
2459 0x65, 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01,
2460 0x28, 0x05, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x23, 0x0a, 0x0b, 0x69,
2461 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09,
2462 0x42, 0x02, 0x18, 0x01, 0x52, 0x0a, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x49, 0x64,
2463 0x12, 0x1d, 0x0a, 0x0a, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x05,
2464 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x49, 0x64, 0x12,
2465 0x71, 0x0a, 0x0a, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x18, 0x04, 0x20,
2466 0x03, 0x28, 0x0b, 0x32, 0x51, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
2467 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65,
2468 0x74, 0x61, 0x32, 0x2e, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61, 0x74, 0x65, 0x57,
2469 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x52,
2470 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72,
2471 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x0a, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65,
2472 0x72, 0x73, 0x1a, 0x3d, 0x0a, 0x0f, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73,
2473 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01,
2474 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65,
2475 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38,
2476 0x01, 0x22, 0x86, 0x02, 0x0a, 0x28, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61, 0x74,
2477 0x65, 0x49, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54,
2478 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x48,
2479 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x30,
2480 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2a, 0x12, 0x28, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63,
2481 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
2482 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65,
2483 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x50, 0x0a, 0x08, 0x74, 0x65, 0x6d, 0x70,
2484 0x6c, 0x61, 0x74, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x67, 0x6f, 0x6f,
2485 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72,
2486 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x6f, 0x72, 0x6b, 0x66,
2487 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x02,
2488 0x52, 0x08, 0x74, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x69, 0x6e,
2489 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52,
2490 0x0a, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x49, 0x64, 0x12, 0x1d, 0x0a, 0x0a, 0x72,
2491 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52,
2492 0x09, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x49, 0x64, 0x22, 0x71, 0x0a, 0x1d, 0x55, 0x70,
2493 0x64, 0x61, 0x74, 0x65, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70,
2494 0x6c, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x50, 0x0a, 0x08, 0x74,
2495 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2f, 0x2e,
2496 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74,
2497 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x6f,
2498 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x42, 0x03,
2499 0xe0, 0x41, 0x02, 0x52, 0x08, 0x74, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x22, 0xa4, 0x01,
2500 0x0a, 0x1c, 0x4c, 0x69, 0x73, 0x74, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65,
2501 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x48,
2502 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x30,
2503 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2a, 0x12, 0x28, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63,
2504 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
2505 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65,
2506 0x52, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65,
2507 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67,
2508 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f,
2509 0x6b, 0x65, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54,
2510 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0xa0, 0x01, 0x0a, 0x1d, 0x4c, 0x69, 0x73, 0x74, 0x57, 0x6f, 0x72,
2511 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x52, 0x65,
2512 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x52, 0x0a, 0x09, 0x74, 0x65, 0x6d, 0x70, 0x6c, 0x61,
2513 0x74, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
2514 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f,
2515 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c,
2516 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52,
2517 0x09, 0x74, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x12, 0x2b, 0x0a, 0x0f, 0x6e, 0x65,
2518 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20,
2519 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61,
2520 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x7f, 0x0a, 0x1d, 0x44, 0x65, 0x6c, 0x65, 0x74,
2521 0x65, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74,
2522 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x44, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65,
2523 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x30, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2a, 0x0a, 0x28,
2524 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61,
2525 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77,
2526 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x18,
2527 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52,
2528 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x32, 0xe9, 0x11, 0x0a, 0x17, 0x57, 0x6f, 0x72,
2529 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x53, 0x65, 0x72,
2530 0x76, 0x69, 0x63, 0x65, 0x12, 0xb0, 0x02, 0x0a, 0x16, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x57,
2531 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x12,
2532 0x3c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64,
2533 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e,
2534 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65,
2535 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2f, 0x2e,
2536 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74,
2537 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x6f,
2538 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x22, 0xa6,
2539 0x01, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x8c, 0x01, 0x22, 0x38, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74,
2540 0x61, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65,
2541 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d,
2542 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74,
2543 0x65, 0x73, 0x3a, 0x08, 0x74, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x5a, 0x46, 0x22, 0x3a,
2544 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74,
2545 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61,
2546 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f,
2547 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x3a, 0x08, 0x74, 0x65, 0x6d, 0x70,
2548 0x6c, 0x61, 0x74, 0x65, 0xda, 0x41, 0x10, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x20, 0x74,
2549 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x12, 0x89, 0x02, 0x0a, 0x13, 0x47, 0x65, 0x74, 0x57,
2550 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x12,
2551 0x39, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64,
2552 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e,
2553 0x47, 0x65, 0x74, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c,
2554 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2f, 0x2e, 0x67, 0x6f, 0x6f,
2555 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72,
2556 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x6f, 0x72, 0x6b, 0x66,
2557 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x22, 0x85, 0x01, 0x82, 0xd3,
2558 0xe4, 0x93, 0x02, 0x78, 0x12, 0x38, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b,
2559 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f,
2560 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c,
2561 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x5a, 0x3c,
2562 0x12, 0x3a, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65,
2563 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61,
2564 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77,
2565 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0xda, 0x41, 0x04, 0x6e,
2566 0x61, 0x6d, 0x65, 0x12, 0xe5, 0x02, 0x0a, 0x1b, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69,
2567 0x61, 0x74, 0x65, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c,
2568 0x61, 0x74, 0x65, 0x12, 0x41, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
2569 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65,
2570 0x74, 0x61, 0x32, 0x2e, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61, 0x74, 0x65, 0x57,
2571 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x52,
2572 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
2573 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65, 0x72,
2574 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0xe3, 0x01, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x96, 0x01, 0x22,
2575 0x44, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d,
2576 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x72, 0x65, 0x67, 0x69, 0x6f,
2577 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d,
2578 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e,
2579 0x74, 0x69, 0x61, 0x74, 0x65, 0x3a, 0x01, 0x2a, 0x5a, 0x4b, 0x22, 0x46, 0x2f, 0x76, 0x31, 0x62,
2580 0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65,
2581 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f,
2582 0x2a, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61,
2583 0x74, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61,
2584 0x74, 0x65, 0x3a, 0x01, 0x2a, 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0xda, 0x41, 0x10, 0x6e,
2585 0x61, 0x6d, 0x65, 0x2c, 0x20, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0xca,
2586 0x41, 0x29, 0x0a, 0x15, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
2587 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12, 0x10, 0x57, 0x6f, 0x72, 0x6b, 0x66,
2588 0x6c, 0x6f, 0x77, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x84, 0x03, 0x0a, 0x21,
2589 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61, 0x74, 0x65, 0x49, 0x6e, 0x6c, 0x69, 0x6e,
2590 0x65, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74,
2591 0x65, 0x12, 0x47, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
2592 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
2593 0x32, 0x2e, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61, 0x74, 0x65, 0x49, 0x6e, 0x6c,
2594 0x69, 0x6e, 0x65, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c,
2595 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x67, 0x6f, 0x6f,
2596 0x67, 0x6c, 0x65, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2e,
2597 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0xf6, 0x01, 0x82, 0xd3, 0xe4, 0x93,
2598 0x02, 0xb0, 0x01, 0x22, 0x4c, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b, 0x70,
2599 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a,
2600 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x77, 0x6f,
2601 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x3a,
2602 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61, 0x74, 0x65, 0x49, 0x6e, 0x6c, 0x69, 0x6e,
2603 0x65, 0x3a, 0x08, 0x74, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x5a, 0x56, 0x22, 0x4a, 0x2f,
2604 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d,
2605 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x72, 0x65, 0x67, 0x69, 0x6f,
2606 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65,
2607 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x3a, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69,
2608 0x61, 0x74, 0x65, 0x49, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x3a, 0x08, 0x74, 0x65, 0x6d, 0x70, 0x6c,
2609 0x61, 0x74, 0x65, 0xda, 0x41, 0x10, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x2c, 0x20, 0x74, 0x65,
2610 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0xca, 0x41, 0x29, 0x0a, 0x15, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
2611 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79,
2612 0x12, 0x10, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61,
2613 0x74, 0x61, 0x12, 0xba, 0x02, 0x0a, 0x16, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x57, 0x6f, 0x72,
2614 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x12, 0x3c, 0x2e,
2615 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74,
2616 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x55, 0x70,
2617 0x64, 0x61, 0x74, 0x65, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70,
2618 0x6c, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2f, 0x2e, 0x67, 0x6f,
2619 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70,
2620 0x72, 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x6f, 0x72, 0x6b,
2621 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x22, 0xb0, 0x01, 0x82,
2622 0xd3, 0xe4, 0x93, 0x02, 0x9e, 0x01, 0x1a, 0x41, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32,
2623 0x2f, 0x7b, 0x74, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x2e, 0x6e, 0x61, 0x6d, 0x65, 0x3d,
2624 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x72, 0x65, 0x67, 0x69, 0x6f,
2625 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d,
2626 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x08, 0x74, 0x65, 0x6d, 0x70, 0x6c,
2627 0x61, 0x74, 0x65, 0x5a, 0x4f, 0x1a, 0x43, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f,
2628 0x7b, 0x74, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x2e, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70,
2629 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69,
2630 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65,
2631 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x3a, 0x08, 0x74, 0x65, 0x6d, 0x70,
2632 0x6c, 0x61, 0x74, 0x65, 0xda, 0x41, 0x08, 0x74, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x12,
2633 0x9c, 0x02, 0x0a, 0x15, 0x4c, 0x69, 0x73, 0x74, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77,
2634 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x12, 0x3b, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
2635 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f,
2636 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x57, 0x6f,
2637 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x52,
2638 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
2639 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x76,
2640 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x57, 0x6f, 0x72, 0x6b, 0x66,
2641 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70,
2642 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x87, 0x01, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x78, 0x12, 0x38, 0x2f,
2643 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d,
2644 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x72, 0x65, 0x67, 0x69, 0x6f,
2645 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65,
2646 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x5a, 0x3c, 0x12, 0x3a, 0x2f, 0x76, 0x31, 0x62, 0x65,
2647 0x74, 0x61, 0x32, 0x2f, 0x7b, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x3d, 0x70, 0x72, 0x6f, 0x6a,
2648 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73,
2649 0x2f, 0x2a, 0x7d, 0x2f, 0x77, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70,
2650 0x6c, 0x61, 0x74, 0x65, 0x73, 0xda, 0x41, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e, 0x74, 0x12, 0xf6,
2651 0x01, 0x0a, 0x16, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f,
2652 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x12, 0x3c, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
2653 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f,
2654 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65,
2655 0x57, 0x6f, 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65,
2656 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
2657 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22,
2658 0x85, 0x01, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x78, 0x2a, 0x38, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74,
2659 0x61, 0x32, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74,
2660 0x73, 0x2f, 0x2a, 0x2f, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f,
2661 0x72, 0x6b, 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x2f,
2662 0x2a, 0x7d, 0x5a, 0x3c, 0x2a, 0x3a, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x7b,
2663 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f,
2664 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x2f, 0x77, 0x6f, 0x72, 0x6b,
2665 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x2f, 0x2a, 0x7d,
2666 0xda, 0x41, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x1a, 0x4b, 0xca, 0x41, 0x17, 0x64, 0x61, 0x74, 0x61,
2667 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e,
2668 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x2e, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77,
2669 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d,
2670 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74,
2671 0x66, 0x6f, 0x72, 0x6d, 0x42, 0x84, 0x01, 0x0a, 0x21, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f,
2672 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72,
2673 0x6f, 0x63, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x42, 0x16, 0x57, 0x6f, 0x72, 0x6b,
2674 0x66, 0x6c, 0x6f, 0x77, 0x54, 0x65, 0x6d, 0x70, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x50, 0x72, 0x6f,
2675 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x45, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c,
2676 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
2677 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75,
2678 0x64, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74,
2679 0x61, 0x32, 0x3b, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x62, 0x06, 0x70, 0x72, 0x6f,
2680 0x74, 0x6f, 0x33,
2681 }
2682
2683 var (
2684 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescOnce sync.Once
2685 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescData = file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDesc
2686 )
2687
2688 func file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescGZIP() []byte {
2689 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescOnce.Do(func() {
2690 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescData)
2691 })
2692 return file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDescData
2693 }
2694
2695 var file_google_cloud_dataproc_v1beta2_workflow_templates_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
2696 var file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes = make([]protoimpl.MessageInfo, 27)
2697 var file_google_cloud_dataproc_v1beta2_workflow_templates_proto_goTypes = []interface{}{
2698 (WorkflowMetadata_State)(0),
2699 (WorkflowNode_NodeState)(0),
2700 (*WorkflowTemplate)(nil),
2701 (*WorkflowTemplatePlacement)(nil),
2702 (*ManagedCluster)(nil),
2703 (*ClusterSelector)(nil),
2704 (*OrderedJob)(nil),
2705 (*TemplateParameter)(nil),
2706 (*ParameterValidation)(nil),
2707 (*RegexValidation)(nil),
2708 (*ValueValidation)(nil),
2709 (*WorkflowMetadata)(nil),
2710 (*ClusterOperation)(nil),
2711 (*WorkflowGraph)(nil),
2712 (*WorkflowNode)(nil),
2713 (*CreateWorkflowTemplateRequest)(nil),
2714 (*GetWorkflowTemplateRequest)(nil),
2715 (*InstantiateWorkflowTemplateRequest)(nil),
2716 (*InstantiateInlineWorkflowTemplateRequest)(nil),
2717 (*UpdateWorkflowTemplateRequest)(nil),
2718 (*ListWorkflowTemplatesRequest)(nil),
2719 (*ListWorkflowTemplatesResponse)(nil),
2720 (*DeleteWorkflowTemplateRequest)(nil),
2721 nil,
2722 nil,
2723 nil,
2724 nil,
2725 nil,
2726 nil,
2727 (*timestamppb.Timestamp)(nil),
2728 (*durationpb.Duration)(nil),
2729 (*ClusterConfig)(nil),
2730 (*HadoopJob)(nil),
2731 (*SparkJob)(nil),
2732 (*PySparkJob)(nil),
2733 (*HiveJob)(nil),
2734 (*PigJob)(nil),
2735 (*SparkRJob)(nil),
2736 (*SparkSqlJob)(nil),
2737 (*PrestoJob)(nil),
2738 (*JobScheduling)(nil),
2739 (*longrunning.Operation)(nil),
2740 (*emptypb.Empty)(nil),
2741 }
2742 var file_google_cloud_dataproc_v1beta2_workflow_templates_proto_depIdxs = []int32{
2743 29,
2744 29,
2745 23,
2746 3,
2747 6,
2748 7,
2749 30,
2750 4,
2751 5,
2752 31,
2753 24,
2754 25,
2755 32,
2756 33,
2757 34,
2758 35,
2759 36,
2760 37,
2761 38,
2762 39,
2763 26,
2764 40,
2765 8,
2766 9,
2767 10,
2768 12,
2769 13,
2770 12,
2771 0,
2772 27,
2773 29,
2774 29,
2775 30,
2776 29,
2777 29,
2778 14,
2779 1,
2780 2,
2781 28,
2782 2,
2783 2,
2784 2,
2785 15,
2786 16,
2787 17,
2788 18,
2789 19,
2790 20,
2791 22,
2792 2,
2793 2,
2794 41,
2795 41,
2796 2,
2797 21,
2798 42,
2799 49,
2800 42,
2801 42,
2802 42,
2803 0,
2804 }
2805
2806 func init() { file_google_cloud_dataproc_v1beta2_workflow_templates_proto_init() }
2807 func file_google_cloud_dataproc_v1beta2_workflow_templates_proto_init() {
2808 if File_google_cloud_dataproc_v1beta2_workflow_templates_proto != nil {
2809 return
2810 }
2811 file_google_cloud_dataproc_v1beta2_clusters_proto_init()
2812 file_google_cloud_dataproc_v1beta2_jobs_proto_init()
2813 if !protoimpl.UnsafeEnabled {
2814 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
2815 switch v := v.(*WorkflowTemplate); i {
2816 case 0:
2817 return &v.state
2818 case 1:
2819 return &v.sizeCache
2820 case 2:
2821 return &v.unknownFields
2822 default:
2823 return nil
2824 }
2825 }
2826 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
2827 switch v := v.(*WorkflowTemplatePlacement); i {
2828 case 0:
2829 return &v.state
2830 case 1:
2831 return &v.sizeCache
2832 case 2:
2833 return &v.unknownFields
2834 default:
2835 return nil
2836 }
2837 }
2838 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
2839 switch v := v.(*ManagedCluster); i {
2840 case 0:
2841 return &v.state
2842 case 1:
2843 return &v.sizeCache
2844 case 2:
2845 return &v.unknownFields
2846 default:
2847 return nil
2848 }
2849 }
2850 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
2851 switch v := v.(*ClusterSelector); i {
2852 case 0:
2853 return &v.state
2854 case 1:
2855 return &v.sizeCache
2856 case 2:
2857 return &v.unknownFields
2858 default:
2859 return nil
2860 }
2861 }
2862 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
2863 switch v := v.(*OrderedJob); i {
2864 case 0:
2865 return &v.state
2866 case 1:
2867 return &v.sizeCache
2868 case 2:
2869 return &v.unknownFields
2870 default:
2871 return nil
2872 }
2873 }
2874 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
2875 switch v := v.(*TemplateParameter); i {
2876 case 0:
2877 return &v.state
2878 case 1:
2879 return &v.sizeCache
2880 case 2:
2881 return &v.unknownFields
2882 default:
2883 return nil
2884 }
2885 }
2886 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
2887 switch v := v.(*ParameterValidation); i {
2888 case 0:
2889 return &v.state
2890 case 1:
2891 return &v.sizeCache
2892 case 2:
2893 return &v.unknownFields
2894 default:
2895 return nil
2896 }
2897 }
2898 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
2899 switch v := v.(*RegexValidation); i {
2900 case 0:
2901 return &v.state
2902 case 1:
2903 return &v.sizeCache
2904 case 2:
2905 return &v.unknownFields
2906 default:
2907 return nil
2908 }
2909 }
2910 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
2911 switch v := v.(*ValueValidation); i {
2912 case 0:
2913 return &v.state
2914 case 1:
2915 return &v.sizeCache
2916 case 2:
2917 return &v.unknownFields
2918 default:
2919 return nil
2920 }
2921 }
2922 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
2923 switch v := v.(*WorkflowMetadata); i {
2924 case 0:
2925 return &v.state
2926 case 1:
2927 return &v.sizeCache
2928 case 2:
2929 return &v.unknownFields
2930 default:
2931 return nil
2932 }
2933 }
2934 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
2935 switch v := v.(*ClusterOperation); i {
2936 case 0:
2937 return &v.state
2938 case 1:
2939 return &v.sizeCache
2940 case 2:
2941 return &v.unknownFields
2942 default:
2943 return nil
2944 }
2945 }
2946 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
2947 switch v := v.(*WorkflowGraph); i {
2948 case 0:
2949 return &v.state
2950 case 1:
2951 return &v.sizeCache
2952 case 2:
2953 return &v.unknownFields
2954 default:
2955 return nil
2956 }
2957 }
2958 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
2959 switch v := v.(*WorkflowNode); i {
2960 case 0:
2961 return &v.state
2962 case 1:
2963 return &v.sizeCache
2964 case 2:
2965 return &v.unknownFields
2966 default:
2967 return nil
2968 }
2969 }
2970 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
2971 switch v := v.(*CreateWorkflowTemplateRequest); i {
2972 case 0:
2973 return &v.state
2974 case 1:
2975 return &v.sizeCache
2976 case 2:
2977 return &v.unknownFields
2978 default:
2979 return nil
2980 }
2981 }
2982 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
2983 switch v := v.(*GetWorkflowTemplateRequest); i {
2984 case 0:
2985 return &v.state
2986 case 1:
2987 return &v.sizeCache
2988 case 2:
2989 return &v.unknownFields
2990 default:
2991 return nil
2992 }
2993 }
2994 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
2995 switch v := v.(*InstantiateWorkflowTemplateRequest); i {
2996 case 0:
2997 return &v.state
2998 case 1:
2999 return &v.sizeCache
3000 case 2:
3001 return &v.unknownFields
3002 default:
3003 return nil
3004 }
3005 }
3006 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
3007 switch v := v.(*InstantiateInlineWorkflowTemplateRequest); i {
3008 case 0:
3009 return &v.state
3010 case 1:
3011 return &v.sizeCache
3012 case 2:
3013 return &v.unknownFields
3014 default:
3015 return nil
3016 }
3017 }
3018 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
3019 switch v := v.(*UpdateWorkflowTemplateRequest); i {
3020 case 0:
3021 return &v.state
3022 case 1:
3023 return &v.sizeCache
3024 case 2:
3025 return &v.unknownFields
3026 default:
3027 return nil
3028 }
3029 }
3030 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
3031 switch v := v.(*ListWorkflowTemplatesRequest); i {
3032 case 0:
3033 return &v.state
3034 case 1:
3035 return &v.sizeCache
3036 case 2:
3037 return &v.unknownFields
3038 default:
3039 return nil
3040 }
3041 }
3042 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
3043 switch v := v.(*ListWorkflowTemplatesResponse); i {
3044 case 0:
3045 return &v.state
3046 case 1:
3047 return &v.sizeCache
3048 case 2:
3049 return &v.unknownFields
3050 default:
3051 return nil
3052 }
3053 }
3054 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
3055 switch v := v.(*DeleteWorkflowTemplateRequest); i {
3056 case 0:
3057 return &v.state
3058 case 1:
3059 return &v.sizeCache
3060 case 2:
3061 return &v.unknownFields
3062 default:
3063 return nil
3064 }
3065 }
3066 }
3067 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[1].OneofWrappers = []interface{}{
3068 (*WorkflowTemplatePlacement_ManagedCluster)(nil),
3069 (*WorkflowTemplatePlacement_ClusterSelector)(nil),
3070 }
3071 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[4].OneofWrappers = []interface{}{
3072 (*OrderedJob_HadoopJob)(nil),
3073 (*OrderedJob_SparkJob)(nil),
3074 (*OrderedJob_PysparkJob)(nil),
3075 (*OrderedJob_HiveJob)(nil),
3076 (*OrderedJob_PigJob)(nil),
3077 (*OrderedJob_SparkRJob)(nil),
3078 (*OrderedJob_SparkSqlJob)(nil),
3079 (*OrderedJob_PrestoJob)(nil),
3080 }
3081 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes[6].OneofWrappers = []interface{}{
3082 (*ParameterValidation_Regex)(nil),
3083 (*ParameterValidation_Values)(nil),
3084 }
3085 type x struct{}
3086 out := protoimpl.TypeBuilder{
3087 File: protoimpl.DescBuilder{
3088 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
3089 RawDescriptor: file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDesc,
3090 NumEnums: 2,
3091 NumMessages: 27,
3092 NumExtensions: 0,
3093 NumServices: 1,
3094 },
3095 GoTypes: file_google_cloud_dataproc_v1beta2_workflow_templates_proto_goTypes,
3096 DependencyIndexes: file_google_cloud_dataproc_v1beta2_workflow_templates_proto_depIdxs,
3097 EnumInfos: file_google_cloud_dataproc_v1beta2_workflow_templates_proto_enumTypes,
3098 MessageInfos: file_google_cloud_dataproc_v1beta2_workflow_templates_proto_msgTypes,
3099 }.Build()
3100 File_google_cloud_dataproc_v1beta2_workflow_templates_proto = out.File
3101 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_rawDesc = nil
3102 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_goTypes = nil
3103 file_google_cloud_dataproc_v1beta2_workflow_templates_proto_depIdxs = nil
3104 }
3105
3106
3107 var _ context.Context
3108 var _ grpc.ClientConnInterface
3109
3110
3111
3112 const _ = grpc.SupportPackageIsVersion6
3113
3114
3115
3116
3117 type WorkflowTemplateServiceClient interface {
3118
3119 CreateWorkflowTemplate(ctx context.Context, in *CreateWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error)
3120
3121
3122
3123
3124 GetWorkflowTemplate(ctx context.Context, in *GetWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error)
3125
3126
3127
3128
3129
3130
3131
3132
3133
3134
3135
3136
3137
3138
3139
3140
3141
3142
3143
3144
3145 InstantiateWorkflowTemplate(ctx context.Context, in *InstantiateWorkflowTemplateRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
3146
3147
3148
3149
3150
3151
3152
3153
3154
3155
3156
3157
3158
3159
3160
3161
3162
3163
3164
3165
3166
3167
3168
3169
3170
3171 InstantiateInlineWorkflowTemplate(ctx context.Context, in *InstantiateInlineWorkflowTemplateRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
3172
3173
3174 UpdateWorkflowTemplate(ctx context.Context, in *UpdateWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error)
3175
3176 ListWorkflowTemplates(ctx context.Context, in *ListWorkflowTemplatesRequest, opts ...grpc.CallOption) (*ListWorkflowTemplatesResponse, error)
3177
3178 DeleteWorkflowTemplate(ctx context.Context, in *DeleteWorkflowTemplateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
3179 }
3180
3181 type workflowTemplateServiceClient struct {
3182 cc grpc.ClientConnInterface
3183 }
3184
3185 func NewWorkflowTemplateServiceClient(cc grpc.ClientConnInterface) WorkflowTemplateServiceClient {
3186 return &workflowTemplateServiceClient{cc}
3187 }
3188
3189 func (c *workflowTemplateServiceClient) CreateWorkflowTemplate(ctx context.Context, in *CreateWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error) {
3190 out := new(WorkflowTemplate)
3191 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1beta2.WorkflowTemplateService/CreateWorkflowTemplate", in, out, opts...)
3192 if err != nil {
3193 return nil, err
3194 }
3195 return out, nil
3196 }
3197
3198 func (c *workflowTemplateServiceClient) GetWorkflowTemplate(ctx context.Context, in *GetWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error) {
3199 out := new(WorkflowTemplate)
3200 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1beta2.WorkflowTemplateService/GetWorkflowTemplate", in, out, opts...)
3201 if err != nil {
3202 return nil, err
3203 }
3204 return out, nil
3205 }
3206
3207 func (c *workflowTemplateServiceClient) InstantiateWorkflowTemplate(ctx context.Context, in *InstantiateWorkflowTemplateRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) {
3208 out := new(longrunning.Operation)
3209 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1beta2.WorkflowTemplateService/InstantiateWorkflowTemplate", in, out, opts...)
3210 if err != nil {
3211 return nil, err
3212 }
3213 return out, nil
3214 }
3215
3216 func (c *workflowTemplateServiceClient) InstantiateInlineWorkflowTemplate(ctx context.Context, in *InstantiateInlineWorkflowTemplateRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) {
3217 out := new(longrunning.Operation)
3218 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1beta2.WorkflowTemplateService/InstantiateInlineWorkflowTemplate", in, out, opts...)
3219 if err != nil {
3220 return nil, err
3221 }
3222 return out, nil
3223 }
3224
3225 func (c *workflowTemplateServiceClient) UpdateWorkflowTemplate(ctx context.Context, in *UpdateWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error) {
3226 out := new(WorkflowTemplate)
3227 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1beta2.WorkflowTemplateService/UpdateWorkflowTemplate", in, out, opts...)
3228 if err != nil {
3229 return nil, err
3230 }
3231 return out, nil
3232 }
3233
3234 func (c *workflowTemplateServiceClient) ListWorkflowTemplates(ctx context.Context, in *ListWorkflowTemplatesRequest, opts ...grpc.CallOption) (*ListWorkflowTemplatesResponse, error) {
3235 out := new(ListWorkflowTemplatesResponse)
3236 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1beta2.WorkflowTemplateService/ListWorkflowTemplates", in, out, opts...)
3237 if err != nil {
3238 return nil, err
3239 }
3240 return out, nil
3241 }
3242
3243 func (c *workflowTemplateServiceClient) DeleteWorkflowTemplate(ctx context.Context, in *DeleteWorkflowTemplateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
3244 out := new(emptypb.Empty)
3245 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1beta2.WorkflowTemplateService/DeleteWorkflowTemplate", in, out, opts...)
3246 if err != nil {
3247 return nil, err
3248 }
3249 return out, nil
3250 }
3251
3252
3253 type WorkflowTemplateServiceServer interface {
3254
3255 CreateWorkflowTemplate(context.Context, *CreateWorkflowTemplateRequest) (*WorkflowTemplate, error)
3256
3257
3258
3259
3260 GetWorkflowTemplate(context.Context, *GetWorkflowTemplateRequest) (*WorkflowTemplate, error)
3261
3262
3263
3264
3265
3266
3267
3268
3269
3270
3271
3272
3273
3274
3275
3276
3277
3278
3279
3280
3281 InstantiateWorkflowTemplate(context.Context, *InstantiateWorkflowTemplateRequest) (*longrunning.Operation, error)
3282
3283
3284
3285
3286
3287
3288
3289
3290
3291
3292
3293
3294
3295
3296
3297
3298
3299
3300
3301
3302
3303
3304
3305
3306
3307 InstantiateInlineWorkflowTemplate(context.Context, *InstantiateInlineWorkflowTemplateRequest) (*longrunning.Operation, error)
3308
3309
3310 UpdateWorkflowTemplate(context.Context, *UpdateWorkflowTemplateRequest) (*WorkflowTemplate, error)
3311
3312 ListWorkflowTemplates(context.Context, *ListWorkflowTemplatesRequest) (*ListWorkflowTemplatesResponse, error)
3313
3314 DeleteWorkflowTemplate(context.Context, *DeleteWorkflowTemplateRequest) (*emptypb.Empty, error)
3315 }
3316
3317
3318 type UnimplementedWorkflowTemplateServiceServer struct {
3319 }
3320
3321 func (*UnimplementedWorkflowTemplateServiceServer) CreateWorkflowTemplate(context.Context, *CreateWorkflowTemplateRequest) (*WorkflowTemplate, error) {
3322 return nil, status.Errorf(codes.Unimplemented, "method CreateWorkflowTemplate not implemented")
3323 }
3324 func (*UnimplementedWorkflowTemplateServiceServer) GetWorkflowTemplate(context.Context, *GetWorkflowTemplateRequest) (*WorkflowTemplate, error) {
3325 return nil, status.Errorf(codes.Unimplemented, "method GetWorkflowTemplate not implemented")
3326 }
3327 func (*UnimplementedWorkflowTemplateServiceServer) InstantiateWorkflowTemplate(context.Context, *InstantiateWorkflowTemplateRequest) (*longrunning.Operation, error) {
3328 return nil, status.Errorf(codes.Unimplemented, "method InstantiateWorkflowTemplate not implemented")
3329 }
3330 func (*UnimplementedWorkflowTemplateServiceServer) InstantiateInlineWorkflowTemplate(context.Context, *InstantiateInlineWorkflowTemplateRequest) (*longrunning.Operation, error) {
3331 return nil, status.Errorf(codes.Unimplemented, "method InstantiateInlineWorkflowTemplate not implemented")
3332 }
3333 func (*UnimplementedWorkflowTemplateServiceServer) UpdateWorkflowTemplate(context.Context, *UpdateWorkflowTemplateRequest) (*WorkflowTemplate, error) {
3334 return nil, status.Errorf(codes.Unimplemented, "method UpdateWorkflowTemplate not implemented")
3335 }
3336 func (*UnimplementedWorkflowTemplateServiceServer) ListWorkflowTemplates(context.Context, *ListWorkflowTemplatesRequest) (*ListWorkflowTemplatesResponse, error) {
3337 return nil, status.Errorf(codes.Unimplemented, "method ListWorkflowTemplates not implemented")
3338 }
3339 func (*UnimplementedWorkflowTemplateServiceServer) DeleteWorkflowTemplate(context.Context, *DeleteWorkflowTemplateRequest) (*emptypb.Empty, error) {
3340 return nil, status.Errorf(codes.Unimplemented, "method DeleteWorkflowTemplate not implemented")
3341 }
3342
3343 func RegisterWorkflowTemplateServiceServer(s *grpc.Server, srv WorkflowTemplateServiceServer) {
3344 s.RegisterService(&_WorkflowTemplateService_serviceDesc, srv)
3345 }
3346
3347 func _WorkflowTemplateService_CreateWorkflowTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3348 in := new(CreateWorkflowTemplateRequest)
3349 if err := dec(in); err != nil {
3350 return nil, err
3351 }
3352 if interceptor == nil {
3353 return srv.(WorkflowTemplateServiceServer).CreateWorkflowTemplate(ctx, in)
3354 }
3355 info := &grpc.UnaryServerInfo{
3356 Server: srv,
3357 FullMethod: "/google.cloud.dataproc.v1beta2.WorkflowTemplateService/CreateWorkflowTemplate",
3358 }
3359 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3360 return srv.(WorkflowTemplateServiceServer).CreateWorkflowTemplate(ctx, req.(*CreateWorkflowTemplateRequest))
3361 }
3362 return interceptor(ctx, in, info, handler)
3363 }
3364
3365 func _WorkflowTemplateService_GetWorkflowTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3366 in := new(GetWorkflowTemplateRequest)
3367 if err := dec(in); err != nil {
3368 return nil, err
3369 }
3370 if interceptor == nil {
3371 return srv.(WorkflowTemplateServiceServer).GetWorkflowTemplate(ctx, in)
3372 }
3373 info := &grpc.UnaryServerInfo{
3374 Server: srv,
3375 FullMethod: "/google.cloud.dataproc.v1beta2.WorkflowTemplateService/GetWorkflowTemplate",
3376 }
3377 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3378 return srv.(WorkflowTemplateServiceServer).GetWorkflowTemplate(ctx, req.(*GetWorkflowTemplateRequest))
3379 }
3380 return interceptor(ctx, in, info, handler)
3381 }
3382
3383 func _WorkflowTemplateService_InstantiateWorkflowTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3384 in := new(InstantiateWorkflowTemplateRequest)
3385 if err := dec(in); err != nil {
3386 return nil, err
3387 }
3388 if interceptor == nil {
3389 return srv.(WorkflowTemplateServiceServer).InstantiateWorkflowTemplate(ctx, in)
3390 }
3391 info := &grpc.UnaryServerInfo{
3392 Server: srv,
3393 FullMethod: "/google.cloud.dataproc.v1beta2.WorkflowTemplateService/InstantiateWorkflowTemplate",
3394 }
3395 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3396 return srv.(WorkflowTemplateServiceServer).InstantiateWorkflowTemplate(ctx, req.(*InstantiateWorkflowTemplateRequest))
3397 }
3398 return interceptor(ctx, in, info, handler)
3399 }
3400
3401 func _WorkflowTemplateService_InstantiateInlineWorkflowTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3402 in := new(InstantiateInlineWorkflowTemplateRequest)
3403 if err := dec(in); err != nil {
3404 return nil, err
3405 }
3406 if interceptor == nil {
3407 return srv.(WorkflowTemplateServiceServer).InstantiateInlineWorkflowTemplate(ctx, in)
3408 }
3409 info := &grpc.UnaryServerInfo{
3410 Server: srv,
3411 FullMethod: "/google.cloud.dataproc.v1beta2.WorkflowTemplateService/InstantiateInlineWorkflowTemplate",
3412 }
3413 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3414 return srv.(WorkflowTemplateServiceServer).InstantiateInlineWorkflowTemplate(ctx, req.(*InstantiateInlineWorkflowTemplateRequest))
3415 }
3416 return interceptor(ctx, in, info, handler)
3417 }
3418
3419 func _WorkflowTemplateService_UpdateWorkflowTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3420 in := new(UpdateWorkflowTemplateRequest)
3421 if err := dec(in); err != nil {
3422 return nil, err
3423 }
3424 if interceptor == nil {
3425 return srv.(WorkflowTemplateServiceServer).UpdateWorkflowTemplate(ctx, in)
3426 }
3427 info := &grpc.UnaryServerInfo{
3428 Server: srv,
3429 FullMethod: "/google.cloud.dataproc.v1beta2.WorkflowTemplateService/UpdateWorkflowTemplate",
3430 }
3431 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3432 return srv.(WorkflowTemplateServiceServer).UpdateWorkflowTemplate(ctx, req.(*UpdateWorkflowTemplateRequest))
3433 }
3434 return interceptor(ctx, in, info, handler)
3435 }
3436
3437 func _WorkflowTemplateService_ListWorkflowTemplates_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3438 in := new(ListWorkflowTemplatesRequest)
3439 if err := dec(in); err != nil {
3440 return nil, err
3441 }
3442 if interceptor == nil {
3443 return srv.(WorkflowTemplateServiceServer).ListWorkflowTemplates(ctx, in)
3444 }
3445 info := &grpc.UnaryServerInfo{
3446 Server: srv,
3447 FullMethod: "/google.cloud.dataproc.v1beta2.WorkflowTemplateService/ListWorkflowTemplates",
3448 }
3449 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3450 return srv.(WorkflowTemplateServiceServer).ListWorkflowTemplates(ctx, req.(*ListWorkflowTemplatesRequest))
3451 }
3452 return interceptor(ctx, in, info, handler)
3453 }
3454
3455 func _WorkflowTemplateService_DeleteWorkflowTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3456 in := new(DeleteWorkflowTemplateRequest)
3457 if err := dec(in); err != nil {
3458 return nil, err
3459 }
3460 if interceptor == nil {
3461 return srv.(WorkflowTemplateServiceServer).DeleteWorkflowTemplate(ctx, in)
3462 }
3463 info := &grpc.UnaryServerInfo{
3464 Server: srv,
3465 FullMethod: "/google.cloud.dataproc.v1beta2.WorkflowTemplateService/DeleteWorkflowTemplate",
3466 }
3467 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3468 return srv.(WorkflowTemplateServiceServer).DeleteWorkflowTemplate(ctx, req.(*DeleteWorkflowTemplateRequest))
3469 }
3470 return interceptor(ctx, in, info, handler)
3471 }
3472
3473 var _WorkflowTemplateService_serviceDesc = grpc.ServiceDesc{
3474 ServiceName: "google.cloud.dataproc.v1beta2.WorkflowTemplateService",
3475 HandlerType: (*WorkflowTemplateServiceServer)(nil),
3476 Methods: []grpc.MethodDesc{
3477 {
3478 MethodName: "CreateWorkflowTemplate",
3479 Handler: _WorkflowTemplateService_CreateWorkflowTemplate_Handler,
3480 },
3481 {
3482 MethodName: "GetWorkflowTemplate",
3483 Handler: _WorkflowTemplateService_GetWorkflowTemplate_Handler,
3484 },
3485 {
3486 MethodName: "InstantiateWorkflowTemplate",
3487 Handler: _WorkflowTemplateService_InstantiateWorkflowTemplate_Handler,
3488 },
3489 {
3490 MethodName: "InstantiateInlineWorkflowTemplate",
3491 Handler: _WorkflowTemplateService_InstantiateInlineWorkflowTemplate_Handler,
3492 },
3493 {
3494 MethodName: "UpdateWorkflowTemplate",
3495 Handler: _WorkflowTemplateService_UpdateWorkflowTemplate_Handler,
3496 },
3497 {
3498 MethodName: "ListWorkflowTemplates",
3499 Handler: _WorkflowTemplateService_ListWorkflowTemplates_Handler,
3500 },
3501 {
3502 MethodName: "DeleteWorkflowTemplate",
3503 Handler: _WorkflowTemplateService_DeleteWorkflowTemplate_Handler,
3504 },
3505 },
3506 Streams: []grpc.StreamDesc{},
3507 Metadata: "google/cloud/dataproc/v1beta2/workflow_templates.proto",
3508 }
3509
View as plain text