1// Copyright 2016 Google Inc. 2// 3// Licensed under the Apache License, Version 2.0 (the "License"); 4// you may not use this file except in compliance with the License. 5// You may obtain a copy of the License at 6// 7// http://www.apache.org/licenses/LICENSE-2.0 8// 9// Unless required by applicable law or agreed to in writing, software 10// distributed under the License is distributed on an "AS IS" BASIS, 11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12// See the License for the specific language governing permissions and 13// limitations under the License. 14 15// Code generated by protoc-gen-go. DO NOT EDIT. 16// versions: 17// protoc-gen-go v1.26.0 18// protoc v3.12.2 19// source: google/genomics/v1alpha2/pipelines.proto 20 21package genomics 22 23import ( 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 code "google.golang.org/genproto/googleapis/rpc/code" 31 grpc "google.golang.org/grpc" 32 codes "google.golang.org/grpc/codes" 33 status "google.golang.org/grpc/status" 34 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 35 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 36 durationpb "google.golang.org/protobuf/types/known/durationpb" 37 emptypb "google.golang.org/protobuf/types/known/emptypb" 38 timestamppb "google.golang.org/protobuf/types/known/timestamppb" 39) 40 41const ( 42 // Verify that this generated code is sufficiently up-to-date. 43 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 44 // Verify that runtime/protoimpl is sufficiently up-to-date. 45 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 46) 47 48// The types of disks that may be attached to VMs. 49type PipelineResources_Disk_Type int32 50 51const ( 52 // Default disk type. Use one of the other options below. 53 PipelineResources_Disk_TYPE_UNSPECIFIED PipelineResources_Disk_Type = 0 54 // Specifies a Google Compute Engine persistent hard disk. See 55 // https://cloud.google.com/compute/docs/disks/#pdspecs for details. 56 PipelineResources_Disk_PERSISTENT_HDD PipelineResources_Disk_Type = 1 57 // Specifies a Google Compute Engine persistent solid-state disk. See 58 // https://cloud.google.com/compute/docs/disks/#pdspecs for details. 59 PipelineResources_Disk_PERSISTENT_SSD PipelineResources_Disk_Type = 2 60 // Specifies a Google Compute Engine local SSD. 61 // See https://cloud.google.com/compute/docs/disks/local-ssd for details. 62 PipelineResources_Disk_LOCAL_SSD PipelineResources_Disk_Type = 3 63) 64 65// Enum value maps for PipelineResources_Disk_Type. 66var ( 67 PipelineResources_Disk_Type_name = map[int32]string{ 68 0: "TYPE_UNSPECIFIED", 69 1: "PERSISTENT_HDD", 70 2: "PERSISTENT_SSD", 71 3: "LOCAL_SSD", 72 } 73 PipelineResources_Disk_Type_value = map[string]int32{ 74 "TYPE_UNSPECIFIED": 0, 75 "PERSISTENT_HDD": 1, 76 "PERSISTENT_SSD": 2, 77 "LOCAL_SSD": 3, 78 } 79) 80 81func (x PipelineResources_Disk_Type) Enum() *PipelineResources_Disk_Type { 82 p := new(PipelineResources_Disk_Type) 83 *p = x 84 return p 85} 86 87func (x PipelineResources_Disk_Type) String() string { 88 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 89} 90 91func (PipelineResources_Disk_Type) Descriptor() protoreflect.EnumDescriptor { 92 return file_google_genomics_v1alpha2_pipelines_proto_enumTypes[0].Descriptor() 93} 94 95func (PipelineResources_Disk_Type) Type() protoreflect.EnumType { 96 return &file_google_genomics_v1alpha2_pipelines_proto_enumTypes[0] 97} 98 99func (x PipelineResources_Disk_Type) Number() protoreflect.EnumNumber { 100 return protoreflect.EnumNumber(x) 101} 102 103// Deprecated: Use PipelineResources_Disk_Type.Descriptor instead. 104func (PipelineResources_Disk_Type) EnumDescriptor() ([]byte, []int) { 105 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{16, 0, 0} 106} 107 108// Describes a Compute Engine resource that is being managed by a running 109// [pipeline][google.genomics.v1alpha2.Pipeline]. 110type ComputeEngine struct { 111 state protoimpl.MessageState 112 sizeCache protoimpl.SizeCache 113 unknownFields protoimpl.UnknownFields 114 115 // The instance on which the operation is running. 116 InstanceName string `protobuf:"bytes,1,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"` 117 // The availability zone in which the instance resides. 118 Zone string `protobuf:"bytes,2,opt,name=zone,proto3" json:"zone,omitempty"` 119 // The machine type of the instance. 120 MachineType string `protobuf:"bytes,3,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"` 121 // The names of the disks that were created for this pipeline. 122 DiskNames []string `protobuf:"bytes,4,rep,name=disk_names,json=diskNames,proto3" json:"disk_names,omitempty"` 123} 124 125func (x *ComputeEngine) Reset() { 126 *x = ComputeEngine{} 127 if protoimpl.UnsafeEnabled { 128 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[0] 129 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 130 ms.StoreMessageInfo(mi) 131 } 132} 133 134func (x *ComputeEngine) String() string { 135 return protoimpl.X.MessageStringOf(x) 136} 137 138func (*ComputeEngine) ProtoMessage() {} 139 140func (x *ComputeEngine) ProtoReflect() protoreflect.Message { 141 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[0] 142 if protoimpl.UnsafeEnabled && x != nil { 143 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 144 if ms.LoadMessageInfo() == nil { 145 ms.StoreMessageInfo(mi) 146 } 147 return ms 148 } 149 return mi.MessageOf(x) 150} 151 152// Deprecated: Use ComputeEngine.ProtoReflect.Descriptor instead. 153func (*ComputeEngine) Descriptor() ([]byte, []int) { 154 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{0} 155} 156 157func (x *ComputeEngine) GetInstanceName() string { 158 if x != nil { 159 return x.InstanceName 160 } 161 return "" 162} 163 164func (x *ComputeEngine) GetZone() string { 165 if x != nil { 166 return x.Zone 167 } 168 return "" 169} 170 171func (x *ComputeEngine) GetMachineType() string { 172 if x != nil { 173 return x.MachineType 174 } 175 return "" 176} 177 178func (x *ComputeEngine) GetDiskNames() []string { 179 if x != nil { 180 return x.DiskNames 181 } 182 return nil 183} 184 185// Runtime metadata that will be populated in the 186// [runtimeMetadata][google.genomics.v1.OperationMetadata.runtime_metadata] 187// field of the Operation associated with a RunPipeline execution. 188type RuntimeMetadata struct { 189 state protoimpl.MessageState 190 sizeCache protoimpl.SizeCache 191 unknownFields protoimpl.UnknownFields 192 193 // Execution information specific to Google Compute Engine. 194 ComputeEngine *ComputeEngine `protobuf:"bytes,1,opt,name=compute_engine,json=computeEngine,proto3" json:"compute_engine,omitempty"` 195} 196 197func (x *RuntimeMetadata) Reset() { 198 *x = RuntimeMetadata{} 199 if protoimpl.UnsafeEnabled { 200 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[1] 201 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 202 ms.StoreMessageInfo(mi) 203 } 204} 205 206func (x *RuntimeMetadata) String() string { 207 return protoimpl.X.MessageStringOf(x) 208} 209 210func (*RuntimeMetadata) ProtoMessage() {} 211 212func (x *RuntimeMetadata) ProtoReflect() protoreflect.Message { 213 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[1] 214 if protoimpl.UnsafeEnabled && x != nil { 215 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 216 if ms.LoadMessageInfo() == nil { 217 ms.StoreMessageInfo(mi) 218 } 219 return ms 220 } 221 return mi.MessageOf(x) 222} 223 224// Deprecated: Use RuntimeMetadata.ProtoReflect.Descriptor instead. 225func (*RuntimeMetadata) Descriptor() ([]byte, []int) { 226 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{1} 227} 228 229func (x *RuntimeMetadata) GetComputeEngine() *ComputeEngine { 230 if x != nil { 231 return x.ComputeEngine 232 } 233 return nil 234} 235 236// The pipeline object. Represents a transformation from a set of input 237// parameters to a set of output parameters. The transformation is defined 238// as a docker image and command to run within that image. Each pipeline 239// is run on a Google Compute Engine VM. A pipeline can be created with the 240// `create` method and then later run with the `run` method, or a pipeline can 241// be defined and run all at once with the `run` method. 242type Pipeline struct { 243 state protoimpl.MessageState 244 sizeCache protoimpl.SizeCache 245 unknownFields protoimpl.UnknownFields 246 247 // Required. The project in which to create the pipeline. The caller must have 248 // WRITE access. 249 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 250 // Required. A user specified pipeline name that does not have to be unique. 251 // This name can be used for filtering Pipelines in ListPipelines. 252 Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` 253 // User-specified description. 254 Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` 255 // Input parameters of the pipeline. 256 InputParameters []*PipelineParameter `protobuf:"bytes,8,rep,name=input_parameters,json=inputParameters,proto3" json:"input_parameters,omitempty"` 257 // Output parameters of the pipeline. 258 OutputParameters []*PipelineParameter `protobuf:"bytes,9,rep,name=output_parameters,json=outputParameters,proto3" json:"output_parameters,omitempty"` 259 // Required. The executor indicates in which environment the pipeline runs. 260 // 261 // Types that are assignable to Executor: 262 // *Pipeline_Docker 263 Executor isPipeline_Executor `protobuf_oneof:"executor"` 264 // Required. Specifies resource requirements for the pipeline run. 265 // Required fields: 266 // 267 // * 268 // [minimumCpuCores][google.genomics.v1alpha2.PipelineResources.minimum_cpu_cores] 269 // 270 // * 271 // [minimumRamGb][google.genomics.v1alpha2.PipelineResources.minimum_ram_gb] 272 Resources *PipelineResources `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"` 273 // Unique pipeline id that is generated by the service when CreatePipeline 274 // is called. Cannot be specified in the Pipeline used in the 275 // CreatePipelineRequest, and will be populated in the response to 276 // CreatePipeline and all subsequent Get and List calls. Indicates that the 277 // service has registered this pipeline. 278 PipelineId string `protobuf:"bytes,7,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"` 279} 280 281func (x *Pipeline) Reset() { 282 *x = Pipeline{} 283 if protoimpl.UnsafeEnabled { 284 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[2] 285 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 286 ms.StoreMessageInfo(mi) 287 } 288} 289 290func (x *Pipeline) String() string { 291 return protoimpl.X.MessageStringOf(x) 292} 293 294func (*Pipeline) ProtoMessage() {} 295 296func (x *Pipeline) ProtoReflect() protoreflect.Message { 297 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[2] 298 if protoimpl.UnsafeEnabled && x != nil { 299 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 300 if ms.LoadMessageInfo() == nil { 301 ms.StoreMessageInfo(mi) 302 } 303 return ms 304 } 305 return mi.MessageOf(x) 306} 307 308// Deprecated: Use Pipeline.ProtoReflect.Descriptor instead. 309func (*Pipeline) Descriptor() ([]byte, []int) { 310 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{2} 311} 312 313func (x *Pipeline) GetProjectId() string { 314 if x != nil { 315 return x.ProjectId 316 } 317 return "" 318} 319 320func (x *Pipeline) GetName() string { 321 if x != nil { 322 return x.Name 323 } 324 return "" 325} 326 327func (x *Pipeline) GetDescription() string { 328 if x != nil { 329 return x.Description 330 } 331 return "" 332} 333 334func (x *Pipeline) GetInputParameters() []*PipelineParameter { 335 if x != nil { 336 return x.InputParameters 337 } 338 return nil 339} 340 341func (x *Pipeline) GetOutputParameters() []*PipelineParameter { 342 if x != nil { 343 return x.OutputParameters 344 } 345 return nil 346} 347 348func (m *Pipeline) GetExecutor() isPipeline_Executor { 349 if m != nil { 350 return m.Executor 351 } 352 return nil 353} 354 355func (x *Pipeline) GetDocker() *DockerExecutor { 356 if x, ok := x.GetExecutor().(*Pipeline_Docker); ok { 357 return x.Docker 358 } 359 return nil 360} 361 362func (x *Pipeline) GetResources() *PipelineResources { 363 if x != nil { 364 return x.Resources 365 } 366 return nil 367} 368 369func (x *Pipeline) GetPipelineId() string { 370 if x != nil { 371 return x.PipelineId 372 } 373 return "" 374} 375 376type isPipeline_Executor interface { 377 isPipeline_Executor() 378} 379 380type Pipeline_Docker struct { 381 // Specifies the docker run information. 382 Docker *DockerExecutor `protobuf:"bytes,5,opt,name=docker,proto3,oneof"` 383} 384 385func (*Pipeline_Docker) isPipeline_Executor() {} 386 387// The request to create a pipeline. The pipeline field here should not have 388// `pipelineId` populated, as that will be populated by the server. 389type CreatePipelineRequest struct { 390 state protoimpl.MessageState 391 sizeCache protoimpl.SizeCache 392 unknownFields protoimpl.UnknownFields 393 394 // The pipeline to create. Should not have `pipelineId` populated. 395 Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` 396} 397 398func (x *CreatePipelineRequest) Reset() { 399 *x = CreatePipelineRequest{} 400 if protoimpl.UnsafeEnabled { 401 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[3] 402 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 403 ms.StoreMessageInfo(mi) 404 } 405} 406 407func (x *CreatePipelineRequest) String() string { 408 return protoimpl.X.MessageStringOf(x) 409} 410 411func (*CreatePipelineRequest) ProtoMessage() {} 412 413func (x *CreatePipelineRequest) ProtoReflect() protoreflect.Message { 414 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[3] 415 if protoimpl.UnsafeEnabled && x != nil { 416 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 417 if ms.LoadMessageInfo() == nil { 418 ms.StoreMessageInfo(mi) 419 } 420 return ms 421 } 422 return mi.MessageOf(x) 423} 424 425// Deprecated: Use CreatePipelineRequest.ProtoReflect.Descriptor instead. 426func (*CreatePipelineRequest) Descriptor() ([]byte, []int) { 427 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{3} 428} 429 430func (x *CreatePipelineRequest) GetPipeline() *Pipeline { 431 if x != nil { 432 return x.Pipeline 433 } 434 return nil 435} 436 437// The pipeline run arguments. 438type RunPipelineArgs struct { 439 state protoimpl.MessageState 440 sizeCache protoimpl.SizeCache 441 unknownFields protoimpl.UnknownFields 442 443 // Required. The project in which to run the pipeline. The caller must have 444 // WRITER access to all Google Cloud services and resources (e.g. Google 445 // Compute Engine) will be used. 446 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 447 // Pipeline input arguments; keys are defined in the pipeline documentation. 448 // All input parameters that do not have default values must be specified. 449 // If parameters with defaults are specified here, the defaults will be 450 // overridden. 451 Inputs map[string]string `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 452 // Pipeline output arguments; keys are defined in the pipeline 453 // documentation. All output parameters of without default values 454 // must be specified. If parameters with defaults are specified 455 // here, the defaults will be overridden. 456 Outputs map[string]string `protobuf:"bytes,3,rep,name=outputs,proto3" json:"outputs,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 457 // The Google Cloud Service Account that will be used to access data and 458 // services. By default, the compute service account associated with 459 // `projectId` is used. 460 ServiceAccount *ServiceAccount `protobuf:"bytes,4,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"` 461 // This field is deprecated. Use `labels` instead. Client-specified pipeline 462 // operation identifier. 463 ClientId string `protobuf:"bytes,5,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"` 464 // Specifies resource requirements/overrides for the pipeline run. 465 Resources *PipelineResources `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"` 466 // Required. Logging options. Used by the service to communicate results 467 // to the user. 468 Logging *LoggingOptions `protobuf:"bytes,7,opt,name=logging,proto3" json:"logging,omitempty"` 469 // How long to keep the VM up after a failure (for example docker command 470 // failed, copying input or output files failed, etc). While the VM is up, one 471 // can ssh into the VM to debug. Default is 0; maximum allowed value is 1 day. 472 KeepVmAliveOnFailureDuration *durationpb.Duration `protobuf:"bytes,8,opt,name=keep_vm_alive_on_failure_duration,json=keepVmAliveOnFailureDuration,proto3" json:"keep_vm_alive_on_failure_duration,omitempty"` 473 // Labels to apply to this pipeline run. Labels will also be applied to 474 // compute resources (VM, disks) created by this pipeline run. When listing 475 // operations, operations can [filtered by labels] 476 // [google.longrunning.ListOperationsRequest.filter]. 477 // Label keys may not be empty; label values may be empty. Non-empty labels 478 // must be 1-63 characters long, and comply with [RFC1035] 479 // (https://www.ietf.org/rfc/rfc1035.txt). 480 // Specifically, the name must be 1-63 characters long and match the regular 481 // expression `[a-z]([-a-z0-9]*[a-z0-9])?` which means the first 482 // character must be a lowercase letter, and all following characters must be 483 // a dash, lowercase letter, or digit, except the last character, which cannot 484 // be a dash. 485 Labels map[string]string `protobuf:"bytes,9,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 486} 487 488func (x *RunPipelineArgs) Reset() { 489 *x = RunPipelineArgs{} 490 if protoimpl.UnsafeEnabled { 491 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[4] 492 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 493 ms.StoreMessageInfo(mi) 494 } 495} 496 497func (x *RunPipelineArgs) String() string { 498 return protoimpl.X.MessageStringOf(x) 499} 500 501func (*RunPipelineArgs) ProtoMessage() {} 502 503func (x *RunPipelineArgs) ProtoReflect() protoreflect.Message { 504 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[4] 505 if protoimpl.UnsafeEnabled && x != nil { 506 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 507 if ms.LoadMessageInfo() == nil { 508 ms.StoreMessageInfo(mi) 509 } 510 return ms 511 } 512 return mi.MessageOf(x) 513} 514 515// Deprecated: Use RunPipelineArgs.ProtoReflect.Descriptor instead. 516func (*RunPipelineArgs) Descriptor() ([]byte, []int) { 517 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{4} 518} 519 520func (x *RunPipelineArgs) GetProjectId() string { 521 if x != nil { 522 return x.ProjectId 523 } 524 return "" 525} 526 527func (x *RunPipelineArgs) GetInputs() map[string]string { 528 if x != nil { 529 return x.Inputs 530 } 531 return nil 532} 533 534func (x *RunPipelineArgs) GetOutputs() map[string]string { 535 if x != nil { 536 return x.Outputs 537 } 538 return nil 539} 540 541func (x *RunPipelineArgs) GetServiceAccount() *ServiceAccount { 542 if x != nil { 543 return x.ServiceAccount 544 } 545 return nil 546} 547 548func (x *RunPipelineArgs) GetClientId() string { 549 if x != nil { 550 return x.ClientId 551 } 552 return "" 553} 554 555func (x *RunPipelineArgs) GetResources() *PipelineResources { 556 if x != nil { 557 return x.Resources 558 } 559 return nil 560} 561 562func (x *RunPipelineArgs) GetLogging() *LoggingOptions { 563 if x != nil { 564 return x.Logging 565 } 566 return nil 567} 568 569func (x *RunPipelineArgs) GetKeepVmAliveOnFailureDuration() *durationpb.Duration { 570 if x != nil { 571 return x.KeepVmAliveOnFailureDuration 572 } 573 return nil 574} 575 576func (x *RunPipelineArgs) GetLabels() map[string]string { 577 if x != nil { 578 return x.Labels 579 } 580 return nil 581} 582 583// The request to run a pipeline. If `pipelineId` is specified, it 584// refers to a saved pipeline created with CreatePipeline and set as 585// the `pipelineId` of the returned Pipeline object. If 586// `ephemeralPipeline` is specified, that pipeline is run once 587// with the given args and not saved. It is an error to specify both 588// `pipelineId` and `ephemeralPipeline`. `pipelineArgs` 589// must be specified. 590type RunPipelineRequest struct { 591 state protoimpl.MessageState 592 sizeCache protoimpl.SizeCache 593 unknownFields protoimpl.UnknownFields 594 595 // Types that are assignable to Pipeline: 596 // *RunPipelineRequest_PipelineId 597 // *RunPipelineRequest_EphemeralPipeline 598 Pipeline isRunPipelineRequest_Pipeline `protobuf_oneof:"pipeline"` 599 // The arguments to use when running this pipeline. 600 PipelineArgs *RunPipelineArgs `protobuf:"bytes,3,opt,name=pipeline_args,json=pipelineArgs,proto3" json:"pipeline_args,omitempty"` 601} 602 603func (x *RunPipelineRequest) Reset() { 604 *x = RunPipelineRequest{} 605 if protoimpl.UnsafeEnabled { 606 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[5] 607 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 608 ms.StoreMessageInfo(mi) 609 } 610} 611 612func (x *RunPipelineRequest) String() string { 613 return protoimpl.X.MessageStringOf(x) 614} 615 616func (*RunPipelineRequest) ProtoMessage() {} 617 618func (x *RunPipelineRequest) ProtoReflect() protoreflect.Message { 619 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[5] 620 if protoimpl.UnsafeEnabled && x != nil { 621 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 622 if ms.LoadMessageInfo() == nil { 623 ms.StoreMessageInfo(mi) 624 } 625 return ms 626 } 627 return mi.MessageOf(x) 628} 629 630// Deprecated: Use RunPipelineRequest.ProtoReflect.Descriptor instead. 631func (*RunPipelineRequest) Descriptor() ([]byte, []int) { 632 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{5} 633} 634 635func (m *RunPipelineRequest) GetPipeline() isRunPipelineRequest_Pipeline { 636 if m != nil { 637 return m.Pipeline 638 } 639 return nil 640} 641 642func (x *RunPipelineRequest) GetPipelineId() string { 643 if x, ok := x.GetPipeline().(*RunPipelineRequest_PipelineId); ok { 644 return x.PipelineId 645 } 646 return "" 647} 648 649func (x *RunPipelineRequest) GetEphemeralPipeline() *Pipeline { 650 if x, ok := x.GetPipeline().(*RunPipelineRequest_EphemeralPipeline); ok { 651 return x.EphemeralPipeline 652 } 653 return nil 654} 655 656func (x *RunPipelineRequest) GetPipelineArgs() *RunPipelineArgs { 657 if x != nil { 658 return x.PipelineArgs 659 } 660 return nil 661} 662 663type isRunPipelineRequest_Pipeline interface { 664 isRunPipelineRequest_Pipeline() 665} 666 667type RunPipelineRequest_PipelineId struct { 668 // The already created pipeline to run. 669 PipelineId string `protobuf:"bytes,1,opt,name=pipeline_id,json=pipelineId,proto3,oneof"` 670} 671 672type RunPipelineRequest_EphemeralPipeline struct { 673 // A new pipeline object to run once and then delete. 674 EphemeralPipeline *Pipeline `protobuf:"bytes,2,opt,name=ephemeral_pipeline,json=ephemeralPipeline,proto3,oneof"` 675} 676 677func (*RunPipelineRequest_PipelineId) isRunPipelineRequest_Pipeline() {} 678 679func (*RunPipelineRequest_EphemeralPipeline) isRunPipelineRequest_Pipeline() {} 680 681// A request to get a saved pipeline by id. 682type GetPipelineRequest struct { 683 state protoimpl.MessageState 684 sizeCache protoimpl.SizeCache 685 unknownFields protoimpl.UnknownFields 686 687 // Caller must have READ access to the project in which this pipeline 688 // is defined. 689 PipelineId string `protobuf:"bytes,1,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"` 690} 691 692func (x *GetPipelineRequest) Reset() { 693 *x = GetPipelineRequest{} 694 if protoimpl.UnsafeEnabled { 695 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[6] 696 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 697 ms.StoreMessageInfo(mi) 698 } 699} 700 701func (x *GetPipelineRequest) String() string { 702 return protoimpl.X.MessageStringOf(x) 703} 704 705func (*GetPipelineRequest) ProtoMessage() {} 706 707func (x *GetPipelineRequest) ProtoReflect() protoreflect.Message { 708 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[6] 709 if protoimpl.UnsafeEnabled && x != nil { 710 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 711 if ms.LoadMessageInfo() == nil { 712 ms.StoreMessageInfo(mi) 713 } 714 return ms 715 } 716 return mi.MessageOf(x) 717} 718 719// Deprecated: Use GetPipelineRequest.ProtoReflect.Descriptor instead. 720func (*GetPipelineRequest) Descriptor() ([]byte, []int) { 721 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{6} 722} 723 724func (x *GetPipelineRequest) GetPipelineId() string { 725 if x != nil { 726 return x.PipelineId 727 } 728 return "" 729} 730 731// A request to list pipelines in a given project. Pipelines can be 732// filtered by name using `namePrefix`: all pipelines with names that 733// begin with `namePrefix` will be returned. Uses standard pagination: 734// `pageSize` indicates how many pipelines to return, and 735// `pageToken` comes from a previous ListPipelinesResponse to 736// indicate offset. 737type ListPipelinesRequest struct { 738 state protoimpl.MessageState 739 sizeCache protoimpl.SizeCache 740 unknownFields protoimpl.UnknownFields 741 742 // Required. The name of the project to search for pipelines. Caller 743 // must have READ access to this project. 744 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 745 // Pipelines with names that match this prefix should be 746 // returned. If unspecified, all pipelines in the project, up to 747 // `pageSize`, will be returned. 748 NamePrefix string `protobuf:"bytes,2,opt,name=name_prefix,json=namePrefix,proto3" json:"name_prefix,omitempty"` 749 // Number of pipelines to return at once. Defaults to 256, and max 750 // is 2048. 751 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 752 // Token to use to indicate where to start getting results. 753 // If unspecified, returns the first page of results. 754 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 755} 756 757func (x *ListPipelinesRequest) Reset() { 758 *x = ListPipelinesRequest{} 759 if protoimpl.UnsafeEnabled { 760 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[7] 761 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 762 ms.StoreMessageInfo(mi) 763 } 764} 765 766func (x *ListPipelinesRequest) String() string { 767 return protoimpl.X.MessageStringOf(x) 768} 769 770func (*ListPipelinesRequest) ProtoMessage() {} 771 772func (x *ListPipelinesRequest) ProtoReflect() protoreflect.Message { 773 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[7] 774 if protoimpl.UnsafeEnabled && x != nil { 775 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 776 if ms.LoadMessageInfo() == nil { 777 ms.StoreMessageInfo(mi) 778 } 779 return ms 780 } 781 return mi.MessageOf(x) 782} 783 784// Deprecated: Use ListPipelinesRequest.ProtoReflect.Descriptor instead. 785func (*ListPipelinesRequest) Descriptor() ([]byte, []int) { 786 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{7} 787} 788 789func (x *ListPipelinesRequest) GetProjectId() string { 790 if x != nil { 791 return x.ProjectId 792 } 793 return "" 794} 795 796func (x *ListPipelinesRequest) GetNamePrefix() string { 797 if x != nil { 798 return x.NamePrefix 799 } 800 return "" 801} 802 803func (x *ListPipelinesRequest) GetPageSize() int32 { 804 if x != nil { 805 return x.PageSize 806 } 807 return 0 808} 809 810func (x *ListPipelinesRequest) GetPageToken() string { 811 if x != nil { 812 return x.PageToken 813 } 814 return "" 815} 816 817// The response of ListPipelines. Contains at most `pageSize` 818// pipelines. If it contains `pageSize` pipelines, and more pipelines 819// exist, then `nextPageToken` will be populated and should be 820// used as the `pageToken` argument to a subsequent ListPipelines 821// request. 822type ListPipelinesResponse struct { 823 state protoimpl.MessageState 824 sizeCache protoimpl.SizeCache 825 unknownFields protoimpl.UnknownFields 826 827 // The matched pipelines. 828 Pipelines []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"` 829 // The token to use to get the next page of results. 830 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 831} 832 833func (x *ListPipelinesResponse) Reset() { 834 *x = ListPipelinesResponse{} 835 if protoimpl.UnsafeEnabled { 836 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[8] 837 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 838 ms.StoreMessageInfo(mi) 839 } 840} 841 842func (x *ListPipelinesResponse) String() string { 843 return protoimpl.X.MessageStringOf(x) 844} 845 846func (*ListPipelinesResponse) ProtoMessage() {} 847 848func (x *ListPipelinesResponse) ProtoReflect() protoreflect.Message { 849 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[8] 850 if protoimpl.UnsafeEnabled && x != nil { 851 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 852 if ms.LoadMessageInfo() == nil { 853 ms.StoreMessageInfo(mi) 854 } 855 return ms 856 } 857 return mi.MessageOf(x) 858} 859 860// Deprecated: Use ListPipelinesResponse.ProtoReflect.Descriptor instead. 861func (*ListPipelinesResponse) Descriptor() ([]byte, []int) { 862 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{8} 863} 864 865func (x *ListPipelinesResponse) GetPipelines() []*Pipeline { 866 if x != nil { 867 return x.Pipelines 868 } 869 return nil 870} 871 872func (x *ListPipelinesResponse) GetNextPageToken() string { 873 if x != nil { 874 return x.NextPageToken 875 } 876 return "" 877} 878 879// The request to delete a saved pipeline by ID. 880type DeletePipelineRequest struct { 881 state protoimpl.MessageState 882 sizeCache protoimpl.SizeCache 883 unknownFields protoimpl.UnknownFields 884 885 // Caller must have WRITE access to the project in which this pipeline 886 // is defined. 887 PipelineId string `protobuf:"bytes,1,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"` 888} 889 890func (x *DeletePipelineRequest) Reset() { 891 *x = DeletePipelineRequest{} 892 if protoimpl.UnsafeEnabled { 893 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[9] 894 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 895 ms.StoreMessageInfo(mi) 896 } 897} 898 899func (x *DeletePipelineRequest) String() string { 900 return protoimpl.X.MessageStringOf(x) 901} 902 903func (*DeletePipelineRequest) ProtoMessage() {} 904 905func (x *DeletePipelineRequest) ProtoReflect() protoreflect.Message { 906 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[9] 907 if protoimpl.UnsafeEnabled && x != nil { 908 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 909 if ms.LoadMessageInfo() == nil { 910 ms.StoreMessageInfo(mi) 911 } 912 return ms 913 } 914 return mi.MessageOf(x) 915} 916 917// Deprecated: Use DeletePipelineRequest.ProtoReflect.Descriptor instead. 918func (*DeletePipelineRequest) Descriptor() ([]byte, []int) { 919 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{9} 920} 921 922func (x *DeletePipelineRequest) GetPipelineId() string { 923 if x != nil { 924 return x.PipelineId 925 } 926 return "" 927} 928 929// Request to get controller configuation. Should only be used 930// by VMs created by the Pipelines Service and not by end users. 931type GetControllerConfigRequest struct { 932 state protoimpl.MessageState 933 sizeCache protoimpl.SizeCache 934 unknownFields protoimpl.UnknownFields 935 936 // The operation to retrieve controller configuration for. 937 OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` 938 ValidationToken uint64 `protobuf:"varint,2,opt,name=validation_token,json=validationToken,proto3" json:"validation_token,omitempty"` 939} 940 941func (x *GetControllerConfigRequest) Reset() { 942 *x = GetControllerConfigRequest{} 943 if protoimpl.UnsafeEnabled { 944 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[10] 945 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 946 ms.StoreMessageInfo(mi) 947 } 948} 949 950func (x *GetControllerConfigRequest) String() string { 951 return protoimpl.X.MessageStringOf(x) 952} 953 954func (*GetControllerConfigRequest) ProtoMessage() {} 955 956func (x *GetControllerConfigRequest) ProtoReflect() protoreflect.Message { 957 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[10] 958 if protoimpl.UnsafeEnabled && x != nil { 959 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 960 if ms.LoadMessageInfo() == nil { 961 ms.StoreMessageInfo(mi) 962 } 963 return ms 964 } 965 return mi.MessageOf(x) 966} 967 968// Deprecated: Use GetControllerConfigRequest.ProtoReflect.Descriptor instead. 969func (*GetControllerConfigRequest) Descriptor() ([]byte, []int) { 970 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{10} 971} 972 973func (x *GetControllerConfigRequest) GetOperationId() string { 974 if x != nil { 975 return x.OperationId 976 } 977 return "" 978} 979 980func (x *GetControllerConfigRequest) GetValidationToken() uint64 { 981 if x != nil { 982 return x.ValidationToken 983 } 984 return 0 985} 986 987// Stores the information that the controller will fetch from the 988// server in order to run. Should only be used by VMs created by the 989// Pipelines Service and not by end users. 990type ControllerConfig struct { 991 state protoimpl.MessageState 992 sizeCache protoimpl.SizeCache 993 unknownFields protoimpl.UnknownFields 994 995 Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"` 996 Cmd string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"` 997 GcsLogPath string `protobuf:"bytes,3,opt,name=gcs_log_path,json=gcsLogPath,proto3" json:"gcs_log_path,omitempty"` 998 MachineType string `protobuf:"bytes,4,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"` 999 Vars map[string]string `protobuf:"bytes,5,rep,name=vars,proto3" json:"vars,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 1000 Disks map[string]string `protobuf:"bytes,6,rep,name=disks,proto3" json:"disks,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 1001 GcsSources map[string]*ControllerConfig_RepeatedString `protobuf:"bytes,7,rep,name=gcs_sources,json=gcsSources,proto3" json:"gcs_sources,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 1002 GcsSinks map[string]*ControllerConfig_RepeatedString `protobuf:"bytes,8,rep,name=gcs_sinks,json=gcsSinks,proto3" json:"gcs_sinks,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 1003} 1004 1005func (x *ControllerConfig) Reset() { 1006 *x = ControllerConfig{} 1007 if protoimpl.UnsafeEnabled { 1008 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[11] 1009 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1010 ms.StoreMessageInfo(mi) 1011 } 1012} 1013 1014func (x *ControllerConfig) String() string { 1015 return protoimpl.X.MessageStringOf(x) 1016} 1017 1018func (*ControllerConfig) ProtoMessage() {} 1019 1020func (x *ControllerConfig) ProtoReflect() protoreflect.Message { 1021 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[11] 1022 if protoimpl.UnsafeEnabled && x != nil { 1023 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1024 if ms.LoadMessageInfo() == nil { 1025 ms.StoreMessageInfo(mi) 1026 } 1027 return ms 1028 } 1029 return mi.MessageOf(x) 1030} 1031 1032// Deprecated: Use ControllerConfig.ProtoReflect.Descriptor instead. 1033func (*ControllerConfig) Descriptor() ([]byte, []int) { 1034 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{11} 1035} 1036 1037func (x *ControllerConfig) GetImage() string { 1038 if x != nil { 1039 return x.Image 1040 } 1041 return "" 1042} 1043 1044func (x *ControllerConfig) GetCmd() string { 1045 if x != nil { 1046 return x.Cmd 1047 } 1048 return "" 1049} 1050 1051func (x *ControllerConfig) GetGcsLogPath() string { 1052 if x != nil { 1053 return x.GcsLogPath 1054 } 1055 return "" 1056} 1057 1058func (x *ControllerConfig) GetMachineType() string { 1059 if x != nil { 1060 return x.MachineType 1061 } 1062 return "" 1063} 1064 1065func (x *ControllerConfig) GetVars() map[string]string { 1066 if x != nil { 1067 return x.Vars 1068 } 1069 return nil 1070} 1071 1072func (x *ControllerConfig) GetDisks() map[string]string { 1073 if x != nil { 1074 return x.Disks 1075 } 1076 return nil 1077} 1078 1079func (x *ControllerConfig) GetGcsSources() map[string]*ControllerConfig_RepeatedString { 1080 if x != nil { 1081 return x.GcsSources 1082 } 1083 return nil 1084} 1085 1086func (x *ControllerConfig) GetGcsSinks() map[string]*ControllerConfig_RepeatedString { 1087 if x != nil { 1088 return x.GcsSinks 1089 } 1090 return nil 1091} 1092 1093// Stores the list of events and times they occured for major events in job 1094// execution. 1095type TimestampEvent struct { 1096 state protoimpl.MessageState 1097 sizeCache protoimpl.SizeCache 1098 unknownFields protoimpl.UnknownFields 1099 1100 // String indicating the type of event 1101 Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"` 1102 // The time this event occured. 1103 Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` 1104} 1105 1106func (x *TimestampEvent) Reset() { 1107 *x = TimestampEvent{} 1108 if protoimpl.UnsafeEnabled { 1109 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[12] 1110 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1111 ms.StoreMessageInfo(mi) 1112 } 1113} 1114 1115func (x *TimestampEvent) String() string { 1116 return protoimpl.X.MessageStringOf(x) 1117} 1118 1119func (*TimestampEvent) ProtoMessage() {} 1120 1121func (x *TimestampEvent) ProtoReflect() protoreflect.Message { 1122 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[12] 1123 if protoimpl.UnsafeEnabled && x != nil { 1124 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1125 if ms.LoadMessageInfo() == nil { 1126 ms.StoreMessageInfo(mi) 1127 } 1128 return ms 1129 } 1130 return mi.MessageOf(x) 1131} 1132 1133// Deprecated: Use TimestampEvent.ProtoReflect.Descriptor instead. 1134func (*TimestampEvent) Descriptor() ([]byte, []int) { 1135 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{12} 1136} 1137 1138func (x *TimestampEvent) GetDescription() string { 1139 if x != nil { 1140 return x.Description 1141 } 1142 return "" 1143} 1144 1145func (x *TimestampEvent) GetTimestamp() *timestamppb.Timestamp { 1146 if x != nil { 1147 return x.Timestamp 1148 } 1149 return nil 1150} 1151 1152// Request to set operation status. Should only be used by VMs 1153// created by the Pipelines Service and not by end users. 1154type SetOperationStatusRequest struct { 1155 state protoimpl.MessageState 1156 sizeCache protoimpl.SizeCache 1157 unknownFields protoimpl.UnknownFields 1158 1159 OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` 1160 TimestampEvents []*TimestampEvent `protobuf:"bytes,2,rep,name=timestamp_events,json=timestampEvents,proto3" json:"timestamp_events,omitempty"` 1161 ErrorCode code.Code `protobuf:"varint,3,opt,name=error_code,json=errorCode,proto3,enum=google.rpc.Code" json:"error_code,omitempty"` 1162 ErrorMessage string `protobuf:"bytes,4,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` 1163 ValidationToken uint64 `protobuf:"varint,5,opt,name=validation_token,json=validationToken,proto3" json:"validation_token,omitempty"` 1164} 1165 1166func (x *SetOperationStatusRequest) Reset() { 1167 *x = SetOperationStatusRequest{} 1168 if protoimpl.UnsafeEnabled { 1169 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[13] 1170 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1171 ms.StoreMessageInfo(mi) 1172 } 1173} 1174 1175func (x *SetOperationStatusRequest) String() string { 1176 return protoimpl.X.MessageStringOf(x) 1177} 1178 1179func (*SetOperationStatusRequest) ProtoMessage() {} 1180 1181func (x *SetOperationStatusRequest) ProtoReflect() protoreflect.Message { 1182 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[13] 1183 if protoimpl.UnsafeEnabled && x != nil { 1184 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1185 if ms.LoadMessageInfo() == nil { 1186 ms.StoreMessageInfo(mi) 1187 } 1188 return ms 1189 } 1190 return mi.MessageOf(x) 1191} 1192 1193// Deprecated: Use SetOperationStatusRequest.ProtoReflect.Descriptor instead. 1194func (*SetOperationStatusRequest) Descriptor() ([]byte, []int) { 1195 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{13} 1196} 1197 1198func (x *SetOperationStatusRequest) GetOperationId() string { 1199 if x != nil { 1200 return x.OperationId 1201 } 1202 return "" 1203} 1204 1205func (x *SetOperationStatusRequest) GetTimestampEvents() []*TimestampEvent { 1206 if x != nil { 1207 return x.TimestampEvents 1208 } 1209 return nil 1210} 1211 1212func (x *SetOperationStatusRequest) GetErrorCode() code.Code { 1213 if x != nil { 1214 return x.ErrorCode 1215 } 1216 return code.Code_OK 1217} 1218 1219func (x *SetOperationStatusRequest) GetErrorMessage() string { 1220 if x != nil { 1221 return x.ErrorMessage 1222 } 1223 return "" 1224} 1225 1226func (x *SetOperationStatusRequest) GetValidationToken() uint64 { 1227 if x != nil { 1228 return x.ValidationToken 1229 } 1230 return 0 1231} 1232 1233// A Google Cloud Service Account. 1234type ServiceAccount struct { 1235 state protoimpl.MessageState 1236 sizeCache protoimpl.SizeCache 1237 unknownFields protoimpl.UnknownFields 1238 1239 // Email address of the service account. Defaults to `default`, 1240 // which uses the compute service account associated with the project. 1241 Email string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"` 1242 // List of scopes to be enabled for this service account on the VM. 1243 // The following scopes are automatically included: 1244 // 1245 // * https://www.googleapis.com/auth/compute 1246 // * https://www.googleapis.com/auth/devstorage.full_control 1247 // * https://www.googleapis.com/auth/genomics 1248 // * https://www.googleapis.com/auth/logging.write 1249 // * https://www.googleapis.com/auth/monitoring.write 1250 Scopes []string `protobuf:"bytes,2,rep,name=scopes,proto3" json:"scopes,omitempty"` 1251} 1252 1253func (x *ServiceAccount) Reset() { 1254 *x = ServiceAccount{} 1255 if protoimpl.UnsafeEnabled { 1256 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[14] 1257 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1258 ms.StoreMessageInfo(mi) 1259 } 1260} 1261 1262func (x *ServiceAccount) String() string { 1263 return protoimpl.X.MessageStringOf(x) 1264} 1265 1266func (*ServiceAccount) ProtoMessage() {} 1267 1268func (x *ServiceAccount) ProtoReflect() protoreflect.Message { 1269 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[14] 1270 if protoimpl.UnsafeEnabled && x != nil { 1271 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1272 if ms.LoadMessageInfo() == nil { 1273 ms.StoreMessageInfo(mi) 1274 } 1275 return ms 1276 } 1277 return mi.MessageOf(x) 1278} 1279 1280// Deprecated: Use ServiceAccount.ProtoReflect.Descriptor instead. 1281func (*ServiceAccount) Descriptor() ([]byte, []int) { 1282 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{14} 1283} 1284 1285func (x *ServiceAccount) GetEmail() string { 1286 if x != nil { 1287 return x.Email 1288 } 1289 return "" 1290} 1291 1292func (x *ServiceAccount) GetScopes() []string { 1293 if x != nil { 1294 return x.Scopes 1295 } 1296 return nil 1297} 1298 1299// The logging options for the pipeline run. 1300type LoggingOptions struct { 1301 state protoimpl.MessageState 1302 sizeCache protoimpl.SizeCache 1303 unknownFields protoimpl.UnknownFields 1304 1305 // The location in Google Cloud Storage to which the pipeline logs 1306 // will be copied. Can be specified as a fully qualified directory 1307 // path, in which case logs will be output with a unique identifier 1308 // as the filename in that directory, or as a fully specified path, 1309 // which must end in `.log`, in which case that path will be 1310 // used, and the user must ensure that logs are not 1311 // overwritten. Stdout and stderr logs from the run are also 1312 // generated and output as `-stdout.log` and `-stderr.log`. 1313 GcsPath string `protobuf:"bytes,1,opt,name=gcs_path,json=gcsPath,proto3" json:"gcs_path,omitempty"` 1314} 1315 1316func (x *LoggingOptions) Reset() { 1317 *x = LoggingOptions{} 1318 if protoimpl.UnsafeEnabled { 1319 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[15] 1320 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1321 ms.StoreMessageInfo(mi) 1322 } 1323} 1324 1325func (x *LoggingOptions) String() string { 1326 return protoimpl.X.MessageStringOf(x) 1327} 1328 1329func (*LoggingOptions) ProtoMessage() {} 1330 1331func (x *LoggingOptions) ProtoReflect() protoreflect.Message { 1332 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[15] 1333 if protoimpl.UnsafeEnabled && x != nil { 1334 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1335 if ms.LoadMessageInfo() == nil { 1336 ms.StoreMessageInfo(mi) 1337 } 1338 return ms 1339 } 1340 return mi.MessageOf(x) 1341} 1342 1343// Deprecated: Use LoggingOptions.ProtoReflect.Descriptor instead. 1344func (*LoggingOptions) Descriptor() ([]byte, []int) { 1345 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{15} 1346} 1347 1348func (x *LoggingOptions) GetGcsPath() string { 1349 if x != nil { 1350 return x.GcsPath 1351 } 1352 return "" 1353} 1354 1355// The system resources for the pipeline run. 1356type PipelineResources struct { 1357 state protoimpl.MessageState 1358 sizeCache protoimpl.SizeCache 1359 unknownFields protoimpl.UnknownFields 1360 1361 // The minimum number of cores to use. Defaults to 1. 1362 MinimumCpuCores int32 `protobuf:"varint,1,opt,name=minimum_cpu_cores,json=minimumCpuCores,proto3" json:"minimum_cpu_cores,omitempty"` 1363 // Whether to use preemptible VMs. Defaults to `false`. In order to use this, 1364 // must be true for both create time and run time. Cannot be true at run time 1365 // if false at create time. 1366 Preemptible bool `protobuf:"varint,2,opt,name=preemptible,proto3" json:"preemptible,omitempty"` 1367 // The minimum amount of RAM to use. Defaults to 3.75 (GB) 1368 MinimumRamGb float64 `protobuf:"fixed64,3,opt,name=minimum_ram_gb,json=minimumRamGb,proto3" json:"minimum_ram_gb,omitempty"` 1369 // Disks to attach. 1370 Disks []*PipelineResources_Disk `protobuf:"bytes,4,rep,name=disks,proto3" json:"disks,omitempty"` 1371 // List of Google Compute Engine availability zones to which resource 1372 // creation will restricted. If empty, any zone may be chosen. 1373 Zones []string `protobuf:"bytes,5,rep,name=zones,proto3" json:"zones,omitempty"` 1374 // The size of the boot disk. Defaults to 10 (GB). 1375 BootDiskSizeGb int32 `protobuf:"varint,6,opt,name=boot_disk_size_gb,json=bootDiskSizeGb,proto3" json:"boot_disk_size_gb,omitempty"` 1376 // Whether to assign an external IP to the instance. This is an experimental 1377 // feature that may go away. Defaults to false. 1378 // Corresponds to `--no_address` flag for [gcloud compute instances create] 1379 // (https://cloud.google.com/sdk/gcloud/reference/compute/instances/create). 1380 // In order to use this, must be true for both create time and run time. 1381 // Cannot be true at run time if false at create time. If you need to ssh into 1382 // a private IP VM for debugging, you can ssh to a public VM and then ssh into 1383 // the private VM's Internal IP. If noAddress is set, this pipeline run may 1384 // only load docker images from Google Container Registry and not Docker Hub. 1385 // ** Note: To use this option, your project must be in Google Access for 1386 // Private IPs Early Access Program.** 1387 NoAddress bool `protobuf:"varint,7,opt,name=no_address,json=noAddress,proto3" json:"no_address,omitempty"` 1388} 1389 1390func (x *PipelineResources) Reset() { 1391 *x = PipelineResources{} 1392 if protoimpl.UnsafeEnabled { 1393 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[16] 1394 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1395 ms.StoreMessageInfo(mi) 1396 } 1397} 1398 1399func (x *PipelineResources) String() string { 1400 return protoimpl.X.MessageStringOf(x) 1401} 1402 1403func (*PipelineResources) ProtoMessage() {} 1404 1405func (x *PipelineResources) ProtoReflect() protoreflect.Message { 1406 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[16] 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// Deprecated: Use PipelineResources.ProtoReflect.Descriptor instead. 1418func (*PipelineResources) Descriptor() ([]byte, []int) { 1419 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{16} 1420} 1421 1422func (x *PipelineResources) GetMinimumCpuCores() int32 { 1423 if x != nil { 1424 return x.MinimumCpuCores 1425 } 1426 return 0 1427} 1428 1429func (x *PipelineResources) GetPreemptible() bool { 1430 if x != nil { 1431 return x.Preemptible 1432 } 1433 return false 1434} 1435 1436func (x *PipelineResources) GetMinimumRamGb() float64 { 1437 if x != nil { 1438 return x.MinimumRamGb 1439 } 1440 return 0 1441} 1442 1443func (x *PipelineResources) GetDisks() []*PipelineResources_Disk { 1444 if x != nil { 1445 return x.Disks 1446 } 1447 return nil 1448} 1449 1450func (x *PipelineResources) GetZones() []string { 1451 if x != nil { 1452 return x.Zones 1453 } 1454 return nil 1455} 1456 1457func (x *PipelineResources) GetBootDiskSizeGb() int32 { 1458 if x != nil { 1459 return x.BootDiskSizeGb 1460 } 1461 return 0 1462} 1463 1464func (x *PipelineResources) GetNoAddress() bool { 1465 if x != nil { 1466 return x.NoAddress 1467 } 1468 return false 1469} 1470 1471// Parameters facilitate setting and delivering data into the 1472// pipeline's execution environment. They are defined at create time, 1473// with optional defaults, and can be overridden at run time. 1474// 1475// If `localCopy` is unset, then the parameter specifies a string that 1476// is passed as-is into the pipeline, as the value of the environment 1477// variable with the given name. A default value can be optionally 1478// specified at create time. The default can be overridden at run time 1479// using the inputs map. If no default is given, a value must be 1480// supplied at runtime. 1481// 1482// If `localCopy` is defined, then the parameter specifies a data 1483// source or sink, both in Google Cloud Storage and on the Docker container 1484// where the pipeline computation is run. The [service account associated with 1485// the Pipeline][google.genomics.v1alpha2.RunPipelineArgs.service_account] (by 1486// default the project's Compute Engine service account) must have access to the 1487// Google Cloud Storage paths. 1488// 1489// At run time, the Google Cloud Storage paths can be overridden if a default 1490// was provided at create time, or must be set otherwise. The pipeline runner 1491// should add a key/value pair to either the inputs or outputs map. The 1492// indicated data copies will be carried out before/after pipeline execution, 1493// just as if the corresponding arguments were provided to `gsutil cp`. 1494// 1495// For example: Given the following `PipelineParameter`, specified 1496// in the `inputParameters` list: 1497// 1498// ``` 1499// {name: "input_file", localCopy: {path: "file.txt", disk: "pd1"}} 1500// ``` 1501// 1502// where `disk` is defined in the `PipelineResources` object as: 1503// 1504// ``` 1505// {name: "pd1", mountPoint: "/mnt/disk/"} 1506// ``` 1507// 1508// We create a disk named `pd1`, mount it on the host VM, and map 1509// `/mnt/pd1` to `/mnt/disk` in the docker container. At 1510// runtime, an entry for `input_file` would be required in the inputs 1511// map, such as: 1512// 1513// ``` 1514// inputs["input_file"] = "gs://my-bucket/bar.txt" 1515// ``` 1516// 1517// This would generate the following gsutil call: 1518// 1519// ``` 1520// gsutil cp gs://my-bucket/bar.txt /mnt/pd1/file.txt 1521// ``` 1522// 1523// The file `/mnt/pd1/file.txt` maps to `/mnt/disk/file.txt` in the 1524// Docker container. Acceptable paths are: 1525// 1526// <table> 1527// <thead> 1528// <tr><th>Google Cloud storage path</th><th>Local path</th></tr> 1529// </thead> 1530// <tbody> 1531// <tr><td>file</td><td>file</td></tr> 1532// <tr><td>glob</td><td>directory</td></tr> 1533// </tbody> 1534// </table> 1535// 1536// For outputs, the direction of the copy is reversed: 1537// 1538// ``` 1539// gsutil cp /mnt/disk/file.txt gs://my-bucket/bar.txt 1540// ``` 1541// 1542// Acceptable paths are: 1543// 1544// <table> 1545// <thead> 1546// <tr><th>Local path</th><th>Google Cloud Storage path</th></tr> 1547// </thead> 1548// <tbody> 1549// <tr><td>file</td><td>file</td></tr> 1550// <tr> 1551// <td>file</td> 1552// <td>directory - directory must already exist</td> 1553// </tr> 1554// <tr> 1555// <td>glob</td> 1556// <td>directory - directory will be created if it doesn't exist</td></tr> 1557// </tbody> 1558// </table> 1559// 1560// One restriction due to docker limitations, is that for outputs that are found 1561// on the boot disk, the local path cannot be a glob and must be a file. 1562type PipelineParameter struct { 1563 state protoimpl.MessageState 1564 sizeCache protoimpl.SizeCache 1565 unknownFields protoimpl.UnknownFields 1566 1567 // Required. Name of the parameter - the pipeline runner uses this string 1568 // as the key to the input and output maps in RunPipeline. 1569 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 1570 // Human-readable description. 1571 Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` 1572 // The default value for this parameter. Can be overridden at runtime. 1573 // If `localCopy` is present, then this must be a Google Cloud Storage path 1574 // beginning with `gs://`. 1575 DefaultValue string `protobuf:"bytes,5,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"` 1576 // If present, this parameter is marked for copying to and from the VM. 1577 // `LocalCopy` indicates where on the VM the file should be. The value 1578 // given to this parameter (either at runtime or using `defaultValue`) 1579 // must be the remote path where the file should be. 1580 LocalCopy *PipelineParameter_LocalCopy `protobuf:"bytes,6,opt,name=local_copy,json=localCopy,proto3" json:"local_copy,omitempty"` 1581} 1582 1583func (x *PipelineParameter) Reset() { 1584 *x = PipelineParameter{} 1585 if protoimpl.UnsafeEnabled { 1586 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[17] 1587 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1588 ms.StoreMessageInfo(mi) 1589 } 1590} 1591 1592func (x *PipelineParameter) String() string { 1593 return protoimpl.X.MessageStringOf(x) 1594} 1595 1596func (*PipelineParameter) ProtoMessage() {} 1597 1598func (x *PipelineParameter) ProtoReflect() protoreflect.Message { 1599 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[17] 1600 if protoimpl.UnsafeEnabled && x != nil { 1601 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1602 if ms.LoadMessageInfo() == nil { 1603 ms.StoreMessageInfo(mi) 1604 } 1605 return ms 1606 } 1607 return mi.MessageOf(x) 1608} 1609 1610// Deprecated: Use PipelineParameter.ProtoReflect.Descriptor instead. 1611func (*PipelineParameter) Descriptor() ([]byte, []int) { 1612 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{17} 1613} 1614 1615func (x *PipelineParameter) GetName() string { 1616 if x != nil { 1617 return x.Name 1618 } 1619 return "" 1620} 1621 1622func (x *PipelineParameter) GetDescription() string { 1623 if x != nil { 1624 return x.Description 1625 } 1626 return "" 1627} 1628 1629func (x *PipelineParameter) GetDefaultValue() string { 1630 if x != nil { 1631 return x.DefaultValue 1632 } 1633 return "" 1634} 1635 1636func (x *PipelineParameter) GetLocalCopy() *PipelineParameter_LocalCopy { 1637 if x != nil { 1638 return x.LocalCopy 1639 } 1640 return nil 1641} 1642 1643// The Docker execuctor specification. 1644type DockerExecutor struct { 1645 state protoimpl.MessageState 1646 sizeCache protoimpl.SizeCache 1647 unknownFields protoimpl.UnknownFields 1648 1649 // Required. Image name from either Docker Hub or Google Container Registry. 1650 // Users that run pipelines must have READ access to the image. 1651 ImageName string `protobuf:"bytes,1,opt,name=image_name,json=imageName,proto3" json:"image_name,omitempty"` 1652 // Required. The command or newline delimited script to run. The command 1653 // string will be executed within a bash shell. 1654 // 1655 // If the command exits with a non-zero exit code, output parameter 1656 // de-localization will be skipped and the pipeline operation's 1657 // [`error`][google.longrunning.Operation.error] field will be populated. 1658 // 1659 // Maximum command string length is 16384. 1660 Cmd string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"` 1661} 1662 1663func (x *DockerExecutor) Reset() { 1664 *x = DockerExecutor{} 1665 if protoimpl.UnsafeEnabled { 1666 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[18] 1667 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1668 ms.StoreMessageInfo(mi) 1669 } 1670} 1671 1672func (x *DockerExecutor) String() string { 1673 return protoimpl.X.MessageStringOf(x) 1674} 1675 1676func (*DockerExecutor) ProtoMessage() {} 1677 1678func (x *DockerExecutor) ProtoReflect() protoreflect.Message { 1679 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[18] 1680 if protoimpl.UnsafeEnabled && x != nil { 1681 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1682 if ms.LoadMessageInfo() == nil { 1683 ms.StoreMessageInfo(mi) 1684 } 1685 return ms 1686 } 1687 return mi.MessageOf(x) 1688} 1689 1690// Deprecated: Use DockerExecutor.ProtoReflect.Descriptor instead. 1691func (*DockerExecutor) Descriptor() ([]byte, []int) { 1692 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{18} 1693} 1694 1695func (x *DockerExecutor) GetImageName() string { 1696 if x != nil { 1697 return x.ImageName 1698 } 1699 return "" 1700} 1701 1702func (x *DockerExecutor) GetCmd() string { 1703 if x != nil { 1704 return x.Cmd 1705 } 1706 return "" 1707} 1708 1709type ControllerConfig_RepeatedString struct { 1710 state protoimpl.MessageState 1711 sizeCache protoimpl.SizeCache 1712 unknownFields protoimpl.UnknownFields 1713 1714 Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` 1715} 1716 1717func (x *ControllerConfig_RepeatedString) Reset() { 1718 *x = ControllerConfig_RepeatedString{} 1719 if protoimpl.UnsafeEnabled { 1720 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[22] 1721 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1722 ms.StoreMessageInfo(mi) 1723 } 1724} 1725 1726func (x *ControllerConfig_RepeatedString) String() string { 1727 return protoimpl.X.MessageStringOf(x) 1728} 1729 1730func (*ControllerConfig_RepeatedString) ProtoMessage() {} 1731 1732func (x *ControllerConfig_RepeatedString) ProtoReflect() protoreflect.Message { 1733 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[22] 1734 if protoimpl.UnsafeEnabled && x != nil { 1735 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1736 if ms.LoadMessageInfo() == nil { 1737 ms.StoreMessageInfo(mi) 1738 } 1739 return ms 1740 } 1741 return mi.MessageOf(x) 1742} 1743 1744// Deprecated: Use ControllerConfig_RepeatedString.ProtoReflect.Descriptor instead. 1745func (*ControllerConfig_RepeatedString) Descriptor() ([]byte, []int) { 1746 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{11, 0} 1747} 1748 1749func (x *ControllerConfig_RepeatedString) GetValues() []string { 1750 if x != nil { 1751 return x.Values 1752 } 1753 return nil 1754} 1755 1756// A Google Compute Engine disk resource specification. 1757type PipelineResources_Disk struct { 1758 state protoimpl.MessageState 1759 sizeCache protoimpl.SizeCache 1760 unknownFields protoimpl.UnknownFields 1761 1762 // Required. The name of the disk that can be used in the pipeline 1763 // parameters. Must be 1 - 63 characters. 1764 // The name "boot" is reserved for system use. 1765 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 1766 // Required. The type of the disk to create. 1767 Type PipelineResources_Disk_Type `protobuf:"varint,2,opt,name=type,proto3,enum=google.genomics.v1alpha2.PipelineResources_Disk_Type" json:"type,omitempty"` 1768 // The size of the disk. Defaults to 500 (GB). 1769 // This field is not applicable for local SSD. 1770 SizeGb int32 `protobuf:"varint,3,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"` 1771 // The full or partial URL of the persistent disk to attach. See 1772 // https://cloud.google.com/compute/docs/reference/latest/instances#resource 1773 // and 1774 // https://cloud.google.com/compute/docs/disks/persistent-disks#snapshots 1775 // for more details. 1776 Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` 1777 // Deprecated. Disks created by the Pipelines API will be deleted at the end 1778 // of the pipeline run, regardless of what this field is set to. 1779 AutoDelete bool `protobuf:"varint,6,opt,name=auto_delete,json=autoDelete,proto3" json:"auto_delete,omitempty"` 1780 // Required at create time and cannot be overridden at run time. 1781 // Specifies the path in the docker container where files on 1782 // this disk should be located. For example, if `mountPoint` 1783 // is `/mnt/disk`, and the parameter has `localPath` 1784 // `inputs/file.txt`, the docker container can access the data at 1785 // `/mnt/disk/inputs/file.txt`. 1786 MountPoint string `protobuf:"bytes,8,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,omitempty"` 1787} 1788 1789func (x *PipelineResources_Disk) Reset() { 1790 *x = PipelineResources_Disk{} 1791 if protoimpl.UnsafeEnabled { 1792 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[27] 1793 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1794 ms.StoreMessageInfo(mi) 1795 } 1796} 1797 1798func (x *PipelineResources_Disk) String() string { 1799 return protoimpl.X.MessageStringOf(x) 1800} 1801 1802func (*PipelineResources_Disk) ProtoMessage() {} 1803 1804func (x *PipelineResources_Disk) ProtoReflect() protoreflect.Message { 1805 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[27] 1806 if protoimpl.UnsafeEnabled && x != nil { 1807 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1808 if ms.LoadMessageInfo() == nil { 1809 ms.StoreMessageInfo(mi) 1810 } 1811 return ms 1812 } 1813 return mi.MessageOf(x) 1814} 1815 1816// Deprecated: Use PipelineResources_Disk.ProtoReflect.Descriptor instead. 1817func (*PipelineResources_Disk) Descriptor() ([]byte, []int) { 1818 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{16, 0} 1819} 1820 1821func (x *PipelineResources_Disk) GetName() string { 1822 if x != nil { 1823 return x.Name 1824 } 1825 return "" 1826} 1827 1828func (x *PipelineResources_Disk) GetType() PipelineResources_Disk_Type { 1829 if x != nil { 1830 return x.Type 1831 } 1832 return PipelineResources_Disk_TYPE_UNSPECIFIED 1833} 1834 1835func (x *PipelineResources_Disk) GetSizeGb() int32 { 1836 if x != nil { 1837 return x.SizeGb 1838 } 1839 return 0 1840} 1841 1842func (x *PipelineResources_Disk) GetSource() string { 1843 if x != nil { 1844 return x.Source 1845 } 1846 return "" 1847} 1848 1849func (x *PipelineResources_Disk) GetAutoDelete() bool { 1850 if x != nil { 1851 return x.AutoDelete 1852 } 1853 return false 1854} 1855 1856func (x *PipelineResources_Disk) GetMountPoint() string { 1857 if x != nil { 1858 return x.MountPoint 1859 } 1860 return "" 1861} 1862 1863// LocalCopy defines how a remote file should be copied to and from the VM. 1864type PipelineParameter_LocalCopy struct { 1865 state protoimpl.MessageState 1866 sizeCache protoimpl.SizeCache 1867 unknownFields protoimpl.UnknownFields 1868 1869 // Required. The path within the user's docker container where 1870 // this input should be localized to and from, relative to the specified 1871 // disk's mount point. For example: file.txt, 1872 Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` 1873 // Required. The name of the disk where this parameter is 1874 // located. Can be the name of one of the disks specified in the 1875 // Resources field, or "boot", which represents the Docker 1876 // instance's boot disk and has a mount point of `/`. 1877 Disk string `protobuf:"bytes,2,opt,name=disk,proto3" json:"disk,omitempty"` 1878} 1879 1880func (x *PipelineParameter_LocalCopy) Reset() { 1881 *x = PipelineParameter_LocalCopy{} 1882 if protoimpl.UnsafeEnabled { 1883 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[28] 1884 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1885 ms.StoreMessageInfo(mi) 1886 } 1887} 1888 1889func (x *PipelineParameter_LocalCopy) String() string { 1890 return protoimpl.X.MessageStringOf(x) 1891} 1892 1893func (*PipelineParameter_LocalCopy) ProtoMessage() {} 1894 1895func (x *PipelineParameter_LocalCopy) ProtoReflect() protoreflect.Message { 1896 mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[28] 1897 if protoimpl.UnsafeEnabled && x != nil { 1898 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1899 if ms.LoadMessageInfo() == nil { 1900 ms.StoreMessageInfo(mi) 1901 } 1902 return ms 1903 } 1904 return mi.MessageOf(x) 1905} 1906 1907// Deprecated: Use PipelineParameter_LocalCopy.ProtoReflect.Descriptor instead. 1908func (*PipelineParameter_LocalCopy) Descriptor() ([]byte, []int) { 1909 return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{17, 0} 1910} 1911 1912func (x *PipelineParameter_LocalCopy) GetPath() string { 1913 if x != nil { 1914 return x.Path 1915 } 1916 return "" 1917} 1918 1919func (x *PipelineParameter_LocalCopy) GetDisk() string { 1920 if x != nil { 1921 return x.Disk 1922 } 1923 return "" 1924} 1925 1926var File_google_genomics_v1alpha2_pipelines_proto protoreflect.FileDescriptor 1927 1928var file_google_genomics_v1alpha2_pipelines_proto_rawDesc = []byte{ 1929 0x0a, 0x28, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 1930 0x73, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2f, 0x70, 0x69, 0x70, 0x65, 0x6c, 1931 0x69, 0x6e, 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x18, 0x67, 0x6f, 0x6f, 0x67, 1932 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 1933 0x70, 0x68, 0x61, 0x32, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 1934 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 1935 0x74, 0x6f, 0x1a, 0x23, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 1936 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x2f, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 1937 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 1938 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 1939 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 1940 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 1941 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 1942 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 1943 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x15, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x72, 0x70, 1944 0x63, 0x2f, 0x63, 0x6f, 0x64, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x8a, 0x01, 0x0a, 1945 0x0d, 0x43, 0x6f, 0x6d, 0x70, 0x75, 0x74, 0x65, 0x45, 0x6e, 0x67, 0x69, 0x6e, 0x65, 0x12, 0x23, 1946 0x0a, 0x0d, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 1947 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x4e, 1948 0x61, 0x6d, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x7a, 0x6f, 0x6e, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 1949 0x09, 0x52, 0x04, 0x7a, 0x6f, 0x6e, 0x65, 0x12, 0x21, 0x0a, 0x0c, 0x6d, 0x61, 0x63, 0x68, 0x69, 1950 0x6e, 0x65, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x6d, 1951 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x54, 0x79, 0x70, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x64, 0x69, 1952 0x73, 0x6b, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x09, 0x52, 0x09, 1953 0x64, 0x69, 0x73, 0x6b, 0x4e, 0x61, 0x6d, 0x65, 0x73, 0x22, 0x61, 0x0a, 0x0f, 0x52, 0x75, 0x6e, 1954 0x74, 0x69, 0x6d, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x4e, 0x0a, 0x0e, 1955 0x63, 0x6f, 0x6d, 0x70, 0x75, 0x74, 0x65, 0x5f, 0x65, 0x6e, 0x67, 0x69, 0x6e, 0x65, 0x18, 0x01, 1956 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 1957 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 1958 0x43, 0x6f, 0x6d, 0x70, 0x75, 0x74, 0x65, 0x45, 0x6e, 0x67, 0x69, 0x6e, 0x65, 0x52, 0x0d, 0x63, 1959 0x6f, 0x6d, 0x70, 0x75, 0x74, 0x65, 0x45, 0x6e, 0x67, 0x69, 0x6e, 0x65, 0x22, 0xcd, 0x03, 0x0a, 1960 0x08, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 1961 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 1962 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 1963 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x20, 0x0a, 0x0b, 1964 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 1965 0x09, 0x52, 0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x56, 1966 0x0a, 0x10, 0x69, 0x6e, 0x70, 0x75, 0x74, 0x5f, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 1967 0x72, 0x73, 0x18, 0x08, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 1968 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 1969 0x68, 0x61, 0x32, 0x2e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x50, 0x61, 0x72, 0x61, 1970 0x6d, 0x65, 0x74, 0x65, 0x72, 0x52, 0x0f, 0x69, 0x6e, 0x70, 0x75, 0x74, 0x50, 0x61, 0x72, 0x61, 1971 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x12, 0x58, 0x0a, 0x11, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 1972 0x5f, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x18, 0x09, 0x20, 0x03, 0x28, 1973 0x0b, 0x32, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 1974 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x50, 0x69, 0x70, 1975 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x52, 0x10, 1976 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 1977 0x12, 0x42, 0x0a, 0x06, 0x64, 0x6f, 0x63, 0x6b, 0x65, 0x72, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 1978 0x32, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 1979 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x44, 0x6f, 0x63, 0x6b, 1980 0x65, 0x72, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x6f, 0x72, 0x48, 0x00, 0x52, 0x06, 0x64, 0x6f, 1981 0x63, 0x6b, 0x65, 0x72, 0x12, 0x49, 0x0a, 0x09, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 1982 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 1983 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 1984 0x61, 0x32, 0x2e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x73, 0x6f, 0x75, 1985 0x72, 0x63, 0x65, 0x73, 0x52, 0x09, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x12, 1986 0x1f, 0x0a, 0x0b, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x07, 1987 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x49, 0x64, 1988 0x42, 0x0a, 0x0a, 0x08, 0x65, 0x78, 0x65, 0x63, 0x75, 0x74, 0x6f, 0x72, 0x22, 0x57, 0x0a, 0x15, 1989 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 1990 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x3e, 0x0a, 0x08, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 1991 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 1992 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 1993 0x61, 0x32, 0x2e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x08, 0x70, 0x69, 0x70, 1994 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x22, 0xb5, 0x06, 0x0a, 0x0f, 0x52, 0x75, 0x6e, 0x50, 0x69, 0x70, 1995 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x41, 0x72, 0x67, 0x73, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 1996 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 1997 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x64, 0x12, 0x4d, 0x0a, 0x06, 0x69, 0x6e, 0x70, 0x75, 1998 0x74, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 1999 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 2000 0x68, 0x61, 0x32, 0x2e, 0x52, 0x75, 0x6e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x41, 2001 0x72, 0x67, 0x73, 0x2e, 0x49, 0x6e, 0x70, 0x75, 0x74, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 2002 0x06, 0x69, 0x6e, 0x70, 0x75, 0x74, 0x73, 0x12, 0x50, 0x0a, 0x07, 0x6f, 0x75, 0x74, 0x70, 0x75, 2003 0x74, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x36, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 2004 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 2005 0x68, 0x61, 0x32, 0x2e, 0x52, 0x75, 0x6e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x41, 2006 0x72, 0x67, 0x73, 0x2e, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 2007 0x52, 0x07, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x73, 0x12, 0x51, 0x0a, 0x0f, 0x73, 0x65, 0x72, 2008 0x76, 0x69, 0x63, 0x65, 0x5f, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x04, 0x20, 0x01, 2009 0x28, 0x0b, 0x32, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 2010 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x53, 0x65, 2011 0x72, 0x76, 0x69, 0x63, 0x65, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x0e, 0x73, 0x65, 2012 0x72, 0x76, 0x69, 0x63, 0x65, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x1b, 0x0a, 0x09, 2013 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 2014 0x08, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x49, 0x0a, 0x09, 0x72, 0x65, 0x73, 2015 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2b, 0x2e, 0x67, 2016 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 2017 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 2018 0x52, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x52, 0x09, 0x72, 0x65, 0x73, 0x6f, 0x75, 2019 0x72, 0x63, 0x65, 0x73, 0x12, 0x42, 0x0a, 0x07, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x18, 2020 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 2021 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 2022 0x2e, 0x4c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 2023 0x07, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x12, 0x62, 0x0a, 0x21, 0x6b, 0x65, 0x65, 0x70, 2024 0x5f, 0x76, 0x6d, 0x5f, 0x61, 0x6c, 0x69, 0x76, 0x65, 0x5f, 0x6f, 0x6e, 0x5f, 0x66, 0x61, 0x69, 2025 0x6c, 0x75, 0x72, 0x65, 0x5f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x08, 0x20, 2026 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 2027 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x1c, 2028 0x6b, 0x65, 0x65, 0x70, 0x56, 0x6d, 0x41, 0x6c, 0x69, 0x76, 0x65, 0x4f, 0x6e, 0x46, 0x61, 0x69, 2029 0x6c, 0x75, 0x72, 0x65, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x4d, 0x0a, 0x06, 2030 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x09, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x35, 0x2e, 0x67, 2031 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 2032 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x52, 0x75, 0x6e, 0x50, 0x69, 0x70, 0x65, 0x6c, 2033 0x69, 0x6e, 0x65, 0x41, 0x72, 0x67, 0x73, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 2034 0x74, 0x72, 0x79, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x1a, 0x39, 0x0a, 0x0b, 0x49, 2035 0x6e, 0x70, 0x75, 0x74, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 2036 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 2037 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 2038 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x1a, 0x3a, 0x0a, 0x0c, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74, 2039 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 2040 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 2041 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 2042 0x38, 0x01, 0x1a, 0x39, 0x0a, 0x0b, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 2043 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 2044 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 2045 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0xe8, 0x01, 2046 0x0a, 0x12, 0x52, 0x75, 0x6e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x71, 2047 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x0b, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 2048 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x0a, 0x70, 0x69, 0x70, 2049 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x49, 0x64, 0x12, 0x53, 0x0a, 0x12, 0x65, 0x70, 0x68, 0x65, 0x6d, 2050 0x65, 0x72, 0x61, 0x6c, 0x5f, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x18, 0x02, 0x20, 2051 0x01, 0x28, 0x0b, 0x32, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 2052 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x50, 2053 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x48, 0x00, 0x52, 0x11, 0x65, 0x70, 0x68, 0x65, 0x6d, 2054 0x65, 0x72, 0x61, 0x6c, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x12, 0x4e, 0x0a, 0x0d, 2055 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x61, 0x72, 0x67, 0x73, 0x18, 0x03, 0x20, 2056 0x01, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 2057 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x52, 2058 0x75, 0x6e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x41, 0x72, 0x67, 0x73, 0x52, 0x0c, 2059 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x41, 0x72, 0x67, 0x73, 0x42, 0x0a, 0x0a, 0x08, 2060 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x22, 0x35, 0x0a, 0x12, 0x47, 0x65, 0x74, 0x50, 2061 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1f, 2062 0x0a, 0x0b, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 2063 0x01, 0x28, 0x09, 0x52, 0x0a, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x49, 0x64, 0x22, 2064 0x92, 0x01, 0x0a, 0x14, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 2065 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, 2066 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x72, 2067 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x64, 0x12, 0x1f, 0x0a, 0x0b, 0x6e, 0x61, 0x6d, 0x65, 0x5f, 2068 0x70, 0x72, 0x65, 0x66, 0x69, 0x78, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x6e, 0x61, 2069 0x6d, 0x65, 0x50, 0x72, 0x65, 0x66, 0x69, 0x78, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 2070 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 2071 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 2072 0x6b, 0x65, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 2073 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x81, 0x01, 0x0a, 0x15, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x69, 0x70, 2074 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x40, 2075 0x0a, 0x09, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 2076 0x0b, 0x32, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 2077 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x50, 0x69, 0x70, 2078 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x09, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 2079 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 2080 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 2081 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x38, 0x0a, 0x15, 0x44, 0x65, 0x6c, 0x65, 2082 0x74, 0x65, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 2083 0x74, 0x12, 0x1f, 0x0a, 0x0b, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x69, 0x64, 2084 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 2085 0x49, 0x64, 0x22, 0x6a, 0x0a, 0x1a, 0x47, 0x65, 0x74, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 2086 0x6c, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 2087 0x12, 0x21, 0x0a, 0x0c, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 2088 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 2089 0x6e, 0x49, 0x64, 0x12, 0x29, 0x0a, 0x10, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f, 2090 0x6e, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0f, 0x76, 2091 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0xd9, 2092 0x06, 0x0a, 0x10, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x43, 0x6f, 0x6e, 2093 0x66, 0x69, 0x67, 0x12, 0x14, 0x0a, 0x05, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x18, 0x01, 0x20, 0x01, 2094 0x28, 0x09, 0x52, 0x05, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x63, 0x6d, 0x64, 2095 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x63, 0x6d, 0x64, 0x12, 0x20, 0x0a, 0x0c, 0x67, 2096 0x63, 0x73, 0x5f, 0x6c, 0x6f, 0x67, 0x5f, 0x70, 0x61, 0x74, 0x68, 0x18, 0x03, 0x20, 0x01, 0x28, 2097 0x09, 0x52, 0x0a, 0x67, 0x63, 0x73, 0x4c, 0x6f, 0x67, 0x50, 0x61, 0x74, 0x68, 0x12, 0x21, 0x0a, 2098 0x0c, 0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x04, 0x20, 2099 0x01, 0x28, 0x09, 0x52, 0x0b, 0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x54, 0x79, 0x70, 0x65, 2100 0x12, 0x48, 0x0a, 0x04, 0x76, 0x61, 0x72, 0x73, 0x18, 0x05, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x34, 2101 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 2102 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 2103 0x6c, 0x6c, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x56, 0x61, 0x72, 0x73, 0x45, 2104 0x6e, 0x74, 0x72, 0x79, 0x52, 0x04, 0x76, 0x61, 0x72, 0x73, 0x12, 0x4b, 0x0a, 0x05, 0x64, 0x69, 2105 0x73, 0x6b, 0x73, 0x18, 0x06, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 2106 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 2107 0x70, 0x68, 0x61, 0x32, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x43, 2108 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x44, 0x69, 0x73, 0x6b, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 2109 0x52, 0x05, 0x64, 0x69, 0x73, 0x6b, 0x73, 0x12, 0x5b, 0x0a, 0x0b, 0x67, 0x63, 0x73, 0x5f, 0x73, 2110 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x18, 0x07, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x3a, 0x2e, 0x67, 2111 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 2112 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 2113 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x47, 0x63, 0x73, 0x53, 0x6f, 0x75, 0x72, 2114 0x63, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x0a, 0x67, 0x63, 0x73, 0x53, 0x6f, 0x75, 2115 0x72, 0x63, 0x65, 0x73, 0x12, 0x55, 0x0a, 0x09, 0x67, 0x63, 0x73, 0x5f, 0x73, 0x69, 0x6e, 0x6b, 2116 0x73, 0x18, 0x08, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x38, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 2117 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 2118 0x61, 0x32, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x43, 0x6f, 0x6e, 2119 0x66, 0x69, 0x67, 0x2e, 0x47, 0x63, 0x73, 0x53, 0x69, 0x6e, 0x6b, 0x73, 0x45, 0x6e, 0x74, 0x72, 2120 0x79, 0x52, 0x08, 0x67, 0x63, 0x73, 0x53, 0x69, 0x6e, 0x6b, 0x73, 0x1a, 0x28, 0x0a, 0x0e, 0x52, 2121 0x65, 0x70, 0x65, 0x61, 0x74, 0x65, 0x64, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x12, 0x16, 0x0a, 2122 0x06, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x06, 0x76, 2123 0x61, 0x6c, 0x75, 0x65, 0x73, 0x1a, 0x37, 0x0a, 0x09, 0x56, 0x61, 0x72, 0x73, 0x45, 0x6e, 0x74, 2124 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 2125 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 2126 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x1a, 0x38, 2127 0x0a, 0x0a, 0x44, 0x69, 0x73, 0x6b, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 2128 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 2129 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 2130 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x1a, 0x78, 0x0a, 0x0f, 0x47, 0x63, 0x73, 0x53, 2131 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 2132 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x4f, 0x0a, 2133 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x39, 0x2e, 0x67, 2134 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 2135 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 2136 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x52, 0x65, 0x70, 0x65, 0x61, 0x74, 0x65, 2137 0x64, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 2138 0x38, 0x01, 0x1a, 0x76, 0x0a, 0x0d, 0x47, 0x63, 0x73, 0x53, 0x69, 0x6e, 0x6b, 0x73, 0x45, 0x6e, 2139 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 2140 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x4f, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 2141 0x20, 0x01, 0x28, 0x0b, 0x32, 0x39, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 2142 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 2143 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 2144 0x2e, 0x52, 0x65, 0x70, 0x65, 0x61, 0x74, 0x65, 0x64, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x52, 2145 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x6c, 0x0a, 0x0e, 0x54, 0x69, 2146 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x20, 0x0a, 0x0b, 2147 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 2148 0x09, 0x52, 0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x38, 2149 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x02, 0x20, 0x01, 0x28, 2150 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 2151 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x09, 0x74, 2152 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x22, 0x94, 0x02, 0x0a, 0x19, 0x53, 0x65, 0x74, 2153 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 2154 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 2155 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x6f, 0x70, 2156 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x53, 0x0a, 0x10, 0x74, 0x69, 0x6d, 2157 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x18, 0x02, 0x20, 2158 0x03, 0x28, 0x0b, 0x32, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 2159 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x54, 2160 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x52, 0x0f, 0x74, 2161 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x12, 0x2f, 2162 0x0a, 0x0a, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x03, 0x20, 0x01, 2163 0x28, 0x0e, 0x32, 0x10, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x72, 0x70, 0x63, 0x2e, 2164 0x43, 0x6f, 0x64, 0x65, 0x52, 0x09, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x43, 0x6f, 0x64, 0x65, 0x12, 2165 0x23, 0x0a, 0x0d, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 2166 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x4d, 0x65, 0x73, 2167 0x73, 0x61, 0x67, 0x65, 0x12, 0x29, 0x0a, 0x10, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 2168 0x6f, 0x6e, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x05, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0f, 2169 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 2170 0x3e, 0x0a, 0x0e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 2171 0x74, 0x12, 0x14, 0x0a, 0x05, 0x65, 0x6d, 0x61, 0x69, 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 2172 0x52, 0x05, 0x65, 0x6d, 0x61, 0x69, 0x6c, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x63, 0x6f, 0x70, 0x65, 2173 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x06, 0x73, 0x63, 0x6f, 0x70, 0x65, 0x73, 0x22, 2174 0x2b, 0x0a, 0x0e, 0x4c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 2175 0x73, 0x12, 0x19, 0x0a, 0x08, 0x67, 0x63, 0x73, 0x5f, 0x70, 0x61, 0x74, 0x68, 0x18, 0x01, 0x20, 2176 0x01, 0x28, 0x09, 0x52, 0x07, 0x67, 0x63, 0x73, 0x50, 0x61, 0x74, 0x68, 0x22, 0xdf, 0x04, 0x0a, 2177 0x11, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 2178 0x65, 0x73, 0x12, 0x2a, 0x0a, 0x11, 0x6d, 0x69, 0x6e, 0x69, 0x6d, 0x75, 0x6d, 0x5f, 0x63, 0x70, 2179 0x75, 0x5f, 0x63, 0x6f, 0x72, 0x65, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0f, 0x6d, 2180 0x69, 0x6e, 0x69, 0x6d, 0x75, 0x6d, 0x43, 0x70, 0x75, 0x43, 0x6f, 0x72, 0x65, 0x73, 0x12, 0x20, 2181 0x0a, 0x0b, 0x70, 0x72, 0x65, 0x65, 0x6d, 0x70, 0x74, 0x69, 0x62, 0x6c, 0x65, 0x18, 0x02, 0x20, 2182 0x01, 0x28, 0x08, 0x52, 0x0b, 0x70, 0x72, 0x65, 0x65, 0x6d, 0x70, 0x74, 0x69, 0x62, 0x6c, 0x65, 2183 0x12, 0x24, 0x0a, 0x0e, 0x6d, 0x69, 0x6e, 0x69, 0x6d, 0x75, 0x6d, 0x5f, 0x72, 0x61, 0x6d, 0x5f, 2184 0x67, 0x62, 0x18, 0x03, 0x20, 0x01, 0x28, 0x01, 0x52, 0x0c, 0x6d, 0x69, 0x6e, 0x69, 0x6d, 0x75, 2185 0x6d, 0x52, 0x61, 0x6d, 0x47, 0x62, 0x12, 0x46, 0x0a, 0x05, 0x64, 0x69, 0x73, 0x6b, 0x73, 0x18, 2186 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x30, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 2187 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 2188 0x2e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 2189 0x65, 0x73, 0x2e, 0x44, 0x69, 0x73, 0x6b, 0x52, 0x05, 0x64, 0x69, 0x73, 0x6b, 0x73, 0x12, 0x14, 2190 0x0a, 0x05, 0x7a, 0x6f, 0x6e, 0x65, 0x73, 0x18, 0x05, 0x20, 0x03, 0x28, 0x09, 0x52, 0x05, 0x7a, 2191 0x6f, 0x6e, 0x65, 0x73, 0x12, 0x29, 0x0a, 0x11, 0x62, 0x6f, 0x6f, 0x74, 0x5f, 0x64, 0x69, 0x73, 2192 0x6b, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x5f, 0x67, 0x62, 0x18, 0x06, 0x20, 0x01, 0x28, 0x05, 0x52, 2193 0x0e, 0x62, 0x6f, 0x6f, 0x74, 0x44, 0x69, 0x73, 0x6b, 0x53, 0x69, 0x7a, 0x65, 0x47, 0x62, 0x12, 2194 0x1d, 0x0a, 0x0a, 0x6e, 0x6f, 0x5f, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x18, 0x07, 0x20, 2195 0x01, 0x28, 0x08, 0x52, 0x09, 0x6e, 0x6f, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x1a, 0xad, 2196 0x02, 0x0a, 0x04, 0x44, 0x69, 0x73, 0x6b, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 2197 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x49, 0x0a, 0x04, 0x74, 2198 0x79, 0x70, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 2199 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 2200 0x70, 0x68, 0x61, 0x32, 0x2e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x73, 2201 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x2e, 0x44, 0x69, 0x73, 0x6b, 0x2e, 0x54, 0x79, 0x70, 0x65, 2202 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x17, 0x0a, 0x07, 0x73, 0x69, 0x7a, 0x65, 0x5f, 0x67, 2203 0x62, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06, 0x73, 0x69, 0x7a, 0x65, 0x47, 0x62, 0x12, 2204 0x16, 0x0a, 0x06, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 2205 0x06, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x61, 0x75, 0x74, 0x6f, 0x5f, 2206 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0a, 0x61, 0x75, 2207 0x74, 0x6f, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x6d, 0x6f, 0x75, 0x6e, 2208 0x74, 0x5f, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x6d, 2209 0x6f, 0x75, 0x6e, 0x74, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x22, 0x53, 0x0a, 0x04, 0x54, 0x79, 0x70, 2210 0x65, 0x12, 0x14, 0x0a, 0x10, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 2211 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x12, 0x0a, 0x0e, 0x50, 0x45, 0x52, 0x53, 0x49, 2212 0x53, 0x54, 0x45, 0x4e, 0x54, 0x5f, 0x48, 0x44, 0x44, 0x10, 0x01, 0x12, 0x12, 0x0a, 0x0e, 0x50, 2213 0x45, 0x52, 0x53, 0x49, 0x53, 0x54, 0x45, 0x4e, 0x54, 0x5f, 0x53, 0x53, 0x44, 0x10, 0x02, 0x12, 2214 0x0d, 0x0a, 0x09, 0x4c, 0x4f, 0x43, 0x41, 0x4c, 0x5f, 0x53, 0x53, 0x44, 0x10, 0x03, 0x22, 0xf9, 2215 0x01, 0x0a, 0x11, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x50, 0x61, 0x72, 0x61, 0x6d, 2216 0x65, 0x74, 0x65, 0x72, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 2217 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x64, 0x65, 0x73, 0x63, 2218 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x64, 2219 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x23, 0x0a, 0x0d, 0x64, 0x65, 2220 0x66, 0x61, 0x75, 0x6c, 0x74, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 2221 0x09, 0x52, 0x0c, 0x64, 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 2222 0x54, 0x0a, 0x0a, 0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x5f, 0x63, 0x6f, 0x70, 0x79, 0x18, 0x06, 0x20, 2223 0x01, 0x28, 0x0b, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 2224 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x50, 2225 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 2226 0x2e, 0x4c, 0x6f, 0x63, 0x61, 0x6c, 0x43, 0x6f, 0x70, 0x79, 0x52, 0x09, 0x6c, 0x6f, 0x63, 0x61, 2227 0x6c, 0x43, 0x6f, 0x70, 0x79, 0x1a, 0x33, 0x0a, 0x09, 0x4c, 0x6f, 0x63, 0x61, 0x6c, 0x43, 0x6f, 2228 0x70, 0x79, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x61, 0x74, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 2229 0x52, 0x04, 0x70, 0x61, 0x74, 0x68, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x69, 0x73, 0x6b, 0x18, 0x02, 2230 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x64, 0x69, 0x73, 0x6b, 0x22, 0x41, 0x0a, 0x0e, 0x44, 0x6f, 2231 0x63, 0x6b, 0x65, 0x72, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x6f, 0x72, 0x12, 0x1d, 0x0a, 0x0a, 2232 0x69, 0x6d, 0x61, 0x67, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 2233 0x52, 0x09, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x63, 2234 0x6d, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x63, 0x6d, 0x64, 0x32, 0x88, 0x08, 2235 0x0a, 0x11, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x56, 0x31, 0x41, 0x6c, 0x70, 2236 0x68, 0x61, 0x32, 0x12, 0x8c, 0x01, 0x0a, 0x0e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x50, 0x69, 2237 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x12, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 2238 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 2239 0x32, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 2240 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 2241 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 2242 0x61, 0x32, 0x2e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x22, 0x25, 0x82, 0xd3, 0xe4, 2243 0x93, 0x02, 0x1f, 0x22, 0x13, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2f, 0x70, 2244 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x3a, 0x08, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 2245 0x6e, 0x65, 0x12, 0x7e, 0x0a, 0x0b, 0x52, 0x75, 0x6e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 2246 0x65, 0x12, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 2247 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x52, 0x75, 0x6e, 2248 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 2249 0x1d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x6c, 0x6f, 0x6e, 0x67, 0x72, 0x75, 0x6e, 2250 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x22, 2251 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x1c, 0x22, 0x17, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 2252 0x32, 0x2f, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x3a, 0x72, 0x75, 0x6e, 0x3a, 2253 0x01, 0x2a, 0x12, 0x8a, 0x01, 0x0a, 0x0b, 0x47, 0x65, 0x74, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 2254 0x6e, 0x65, 0x12, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 2255 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x47, 0x65, 2256 0x74, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 2257 0x1a, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 2258 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x50, 0x69, 0x70, 0x65, 2259 0x6c, 0x69, 0x6e, 0x65, 0x22, 0x29, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x23, 0x12, 0x21, 0x2f, 0x76, 2260 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2f, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 2261 0x73, 0x2f, 0x7b, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x69, 0x64, 0x7d, 0x12, 2262 0x8d, 0x01, 0x0a, 0x0d, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 2263 0x73, 0x12, 0x2e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 2264 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x4c, 0x69, 0x73, 2265 0x74, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 2266 0x74, 0x1a, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 2267 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x4c, 0x69, 0x73, 2268 0x74, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 2269 0x73, 0x65, 0x22, 0x1b, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x15, 0x12, 0x13, 0x2f, 0x76, 0x31, 0x61, 2270 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2f, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x12, 2271 0x84, 0x01, 0x0a, 0x0e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 2272 0x6e, 0x65, 0x12, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 2273 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x44, 0x65, 2274 0x6c, 0x65, 0x74, 0x65, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75, 2275 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 2276 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x29, 0x82, 0xd3, 0xe4, 2277 0x93, 0x02, 0x23, 0x2a, 0x21, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2f, 0x70, 2278 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x2f, 0x7b, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 2279 0x6e, 0x65, 0x5f, 0x69, 0x64, 0x7d, 0x12, 0xa8, 0x01, 0x0a, 0x13, 0x47, 0x65, 0x74, 0x43, 0x6f, 2280 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x34, 2281 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 2282 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x47, 0x65, 0x74, 0x43, 0x6f, 0x6e, 2283 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x71, 2284 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 2285 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 2286 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 2287 0x22, 0x2f, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x29, 0x12, 0x27, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 2288 0x68, 0x61, 0x32, 0x2f, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x3a, 0x67, 0x65, 2289 0x74, 0x43, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66, 0x69, 2290 0x67, 0x12, 0x94, 0x01, 0x0a, 0x12, 0x53, 0x65, 0x74, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 2291 0x6f, 0x6e, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x33, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 2292 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 2293 0x68, 0x61, 0x32, 0x2e, 0x53, 0x65, 0x74, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 2294 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 2295 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 2296 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x31, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2b, 0x1a, 0x26, 0x2f, 2297 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2f, 0x70, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 2298 0x65, 0x73, 0x3a, 0x73, 0x65, 0x74, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 2299 0x74, 0x61, 0x74, 0x75, 0x73, 0x3a, 0x01, 0x2a, 0x42, 0x70, 0x0a, 0x17, 0x63, 0x6f, 0x6d, 0x2e, 2300 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2e, 2301 0x76, 0x31, 0x61, 0x42, 0x0e, 0x50, 0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x73, 0x50, 0x72, 2302 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x40, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 2303 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 2304 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x67, 0x65, 0x6e, 2305 0x6f, 0x6d, 0x69, 0x63, 0x73, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x3b, 0x67, 2306 0x65, 0x6e, 0x6f, 0x6d, 0x69, 0x63, 0x73, 0xf8, 0x01, 0x01, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 2307 0x6f, 0x33, 2308} 2309 2310var ( 2311 file_google_genomics_v1alpha2_pipelines_proto_rawDescOnce sync.Once 2312 file_google_genomics_v1alpha2_pipelines_proto_rawDescData = file_google_genomics_v1alpha2_pipelines_proto_rawDesc 2313) 2314 2315func file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP() []byte { 2316 file_google_genomics_v1alpha2_pipelines_proto_rawDescOnce.Do(func() { 2317 file_google_genomics_v1alpha2_pipelines_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_genomics_v1alpha2_pipelines_proto_rawDescData) 2318 }) 2319 return file_google_genomics_v1alpha2_pipelines_proto_rawDescData 2320} 2321 2322var file_google_genomics_v1alpha2_pipelines_proto_enumTypes = make([]protoimpl.EnumInfo, 1) 2323var file_google_genomics_v1alpha2_pipelines_proto_msgTypes = make([]protoimpl.MessageInfo, 29) 2324var file_google_genomics_v1alpha2_pipelines_proto_goTypes = []interface{}{ 2325 (PipelineResources_Disk_Type)(0), // 0: google.genomics.v1alpha2.PipelineResources.Disk.Type 2326 (*ComputeEngine)(nil), // 1: google.genomics.v1alpha2.ComputeEngine 2327 (*RuntimeMetadata)(nil), // 2: google.genomics.v1alpha2.RuntimeMetadata 2328 (*Pipeline)(nil), // 3: google.genomics.v1alpha2.Pipeline 2329 (*CreatePipelineRequest)(nil), // 4: google.genomics.v1alpha2.CreatePipelineRequest 2330 (*RunPipelineArgs)(nil), // 5: google.genomics.v1alpha2.RunPipelineArgs 2331 (*RunPipelineRequest)(nil), // 6: google.genomics.v1alpha2.RunPipelineRequest 2332 (*GetPipelineRequest)(nil), // 7: google.genomics.v1alpha2.GetPipelineRequest 2333 (*ListPipelinesRequest)(nil), // 8: google.genomics.v1alpha2.ListPipelinesRequest 2334 (*ListPipelinesResponse)(nil), // 9: google.genomics.v1alpha2.ListPipelinesResponse 2335 (*DeletePipelineRequest)(nil), // 10: google.genomics.v1alpha2.DeletePipelineRequest 2336 (*GetControllerConfigRequest)(nil), // 11: google.genomics.v1alpha2.GetControllerConfigRequest 2337 (*ControllerConfig)(nil), // 12: google.genomics.v1alpha2.ControllerConfig 2338 (*TimestampEvent)(nil), // 13: google.genomics.v1alpha2.TimestampEvent 2339 (*SetOperationStatusRequest)(nil), // 14: google.genomics.v1alpha2.SetOperationStatusRequest 2340 (*ServiceAccount)(nil), // 15: google.genomics.v1alpha2.ServiceAccount 2341 (*LoggingOptions)(nil), // 16: google.genomics.v1alpha2.LoggingOptions 2342 (*PipelineResources)(nil), // 17: google.genomics.v1alpha2.PipelineResources 2343 (*PipelineParameter)(nil), // 18: google.genomics.v1alpha2.PipelineParameter 2344 (*DockerExecutor)(nil), // 19: google.genomics.v1alpha2.DockerExecutor 2345 nil, // 20: google.genomics.v1alpha2.RunPipelineArgs.InputsEntry 2346 nil, // 21: google.genomics.v1alpha2.RunPipelineArgs.OutputsEntry 2347 nil, // 22: google.genomics.v1alpha2.RunPipelineArgs.LabelsEntry 2348 (*ControllerConfig_RepeatedString)(nil), // 23: google.genomics.v1alpha2.ControllerConfig.RepeatedString 2349 nil, // 24: google.genomics.v1alpha2.ControllerConfig.VarsEntry 2350 nil, // 25: google.genomics.v1alpha2.ControllerConfig.DisksEntry 2351 nil, // 26: google.genomics.v1alpha2.ControllerConfig.GcsSourcesEntry 2352 nil, // 27: google.genomics.v1alpha2.ControllerConfig.GcsSinksEntry 2353 (*PipelineResources_Disk)(nil), // 28: google.genomics.v1alpha2.PipelineResources.Disk 2354 (*PipelineParameter_LocalCopy)(nil), // 29: google.genomics.v1alpha2.PipelineParameter.LocalCopy 2355 (*durationpb.Duration)(nil), // 30: google.protobuf.Duration 2356 (*timestamppb.Timestamp)(nil), // 31: google.protobuf.Timestamp 2357 (code.Code)(0), // 32: google.rpc.Code 2358 (*longrunning.Operation)(nil), // 33: google.longrunning.Operation 2359 (*emptypb.Empty)(nil), // 34: google.protobuf.Empty 2360} 2361var file_google_genomics_v1alpha2_pipelines_proto_depIdxs = []int32{ 2362 1, // 0: google.genomics.v1alpha2.RuntimeMetadata.compute_engine:type_name -> google.genomics.v1alpha2.ComputeEngine 2363 18, // 1: google.genomics.v1alpha2.Pipeline.input_parameters:type_name -> google.genomics.v1alpha2.PipelineParameter 2364 18, // 2: google.genomics.v1alpha2.Pipeline.output_parameters:type_name -> google.genomics.v1alpha2.PipelineParameter 2365 19, // 3: google.genomics.v1alpha2.Pipeline.docker:type_name -> google.genomics.v1alpha2.DockerExecutor 2366 17, // 4: google.genomics.v1alpha2.Pipeline.resources:type_name -> google.genomics.v1alpha2.PipelineResources 2367 3, // 5: google.genomics.v1alpha2.CreatePipelineRequest.pipeline:type_name -> google.genomics.v1alpha2.Pipeline 2368 20, // 6: google.genomics.v1alpha2.RunPipelineArgs.inputs:type_name -> google.genomics.v1alpha2.RunPipelineArgs.InputsEntry 2369 21, // 7: google.genomics.v1alpha2.RunPipelineArgs.outputs:type_name -> google.genomics.v1alpha2.RunPipelineArgs.OutputsEntry 2370 15, // 8: google.genomics.v1alpha2.RunPipelineArgs.service_account:type_name -> google.genomics.v1alpha2.ServiceAccount 2371 17, // 9: google.genomics.v1alpha2.RunPipelineArgs.resources:type_name -> google.genomics.v1alpha2.PipelineResources 2372 16, // 10: google.genomics.v1alpha2.RunPipelineArgs.logging:type_name -> google.genomics.v1alpha2.LoggingOptions 2373 30, // 11: google.genomics.v1alpha2.RunPipelineArgs.keep_vm_alive_on_failure_duration:type_name -> google.protobuf.Duration 2374 22, // 12: google.genomics.v1alpha2.RunPipelineArgs.labels:type_name -> google.genomics.v1alpha2.RunPipelineArgs.LabelsEntry 2375 3, // 13: google.genomics.v1alpha2.RunPipelineRequest.ephemeral_pipeline:type_name -> google.genomics.v1alpha2.Pipeline 2376 5, // 14: google.genomics.v1alpha2.RunPipelineRequest.pipeline_args:type_name -> google.genomics.v1alpha2.RunPipelineArgs 2377 3, // 15: google.genomics.v1alpha2.ListPipelinesResponse.pipelines:type_name -> google.genomics.v1alpha2.Pipeline 2378 24, // 16: google.genomics.v1alpha2.ControllerConfig.vars:type_name -> google.genomics.v1alpha2.ControllerConfig.VarsEntry 2379 25, // 17: google.genomics.v1alpha2.ControllerConfig.disks:type_name -> google.genomics.v1alpha2.ControllerConfig.DisksEntry 2380 26, // 18: google.genomics.v1alpha2.ControllerConfig.gcs_sources:type_name -> google.genomics.v1alpha2.ControllerConfig.GcsSourcesEntry 2381 27, // 19: google.genomics.v1alpha2.ControllerConfig.gcs_sinks:type_name -> google.genomics.v1alpha2.ControllerConfig.GcsSinksEntry 2382 31, // 20: google.genomics.v1alpha2.TimestampEvent.timestamp:type_name -> google.protobuf.Timestamp 2383 13, // 21: google.genomics.v1alpha2.SetOperationStatusRequest.timestamp_events:type_name -> google.genomics.v1alpha2.TimestampEvent 2384 32, // 22: google.genomics.v1alpha2.SetOperationStatusRequest.error_code:type_name -> google.rpc.Code 2385 28, // 23: google.genomics.v1alpha2.PipelineResources.disks:type_name -> google.genomics.v1alpha2.PipelineResources.Disk 2386 29, // 24: google.genomics.v1alpha2.PipelineParameter.local_copy:type_name -> google.genomics.v1alpha2.PipelineParameter.LocalCopy 2387 23, // 25: google.genomics.v1alpha2.ControllerConfig.GcsSourcesEntry.value:type_name -> google.genomics.v1alpha2.ControllerConfig.RepeatedString 2388 23, // 26: google.genomics.v1alpha2.ControllerConfig.GcsSinksEntry.value:type_name -> google.genomics.v1alpha2.ControllerConfig.RepeatedString 2389 0, // 27: google.genomics.v1alpha2.PipelineResources.Disk.type:type_name -> google.genomics.v1alpha2.PipelineResources.Disk.Type 2390 4, // 28: google.genomics.v1alpha2.PipelinesV1Alpha2.CreatePipeline:input_type -> google.genomics.v1alpha2.CreatePipelineRequest 2391 6, // 29: google.genomics.v1alpha2.PipelinesV1Alpha2.RunPipeline:input_type -> google.genomics.v1alpha2.RunPipelineRequest 2392 7, // 30: google.genomics.v1alpha2.PipelinesV1Alpha2.GetPipeline:input_type -> google.genomics.v1alpha2.GetPipelineRequest 2393 8, // 31: google.genomics.v1alpha2.PipelinesV1Alpha2.ListPipelines:input_type -> google.genomics.v1alpha2.ListPipelinesRequest 2394 10, // 32: google.genomics.v1alpha2.PipelinesV1Alpha2.DeletePipeline:input_type -> google.genomics.v1alpha2.DeletePipelineRequest 2395 11, // 33: google.genomics.v1alpha2.PipelinesV1Alpha2.GetControllerConfig:input_type -> google.genomics.v1alpha2.GetControllerConfigRequest 2396 14, // 34: google.genomics.v1alpha2.PipelinesV1Alpha2.SetOperationStatus:input_type -> google.genomics.v1alpha2.SetOperationStatusRequest 2397 3, // 35: google.genomics.v1alpha2.PipelinesV1Alpha2.CreatePipeline:output_type -> google.genomics.v1alpha2.Pipeline 2398 33, // 36: google.genomics.v1alpha2.PipelinesV1Alpha2.RunPipeline:output_type -> google.longrunning.Operation 2399 3, // 37: google.genomics.v1alpha2.PipelinesV1Alpha2.GetPipeline:output_type -> google.genomics.v1alpha2.Pipeline 2400 9, // 38: google.genomics.v1alpha2.PipelinesV1Alpha2.ListPipelines:output_type -> google.genomics.v1alpha2.ListPipelinesResponse 2401 34, // 39: google.genomics.v1alpha2.PipelinesV1Alpha2.DeletePipeline:output_type -> google.protobuf.Empty 2402 12, // 40: google.genomics.v1alpha2.PipelinesV1Alpha2.GetControllerConfig:output_type -> google.genomics.v1alpha2.ControllerConfig 2403 34, // 41: google.genomics.v1alpha2.PipelinesV1Alpha2.SetOperationStatus:output_type -> google.protobuf.Empty 2404 35, // [35:42] is the sub-list for method output_type 2405 28, // [28:35] is the sub-list for method input_type 2406 28, // [28:28] is the sub-list for extension type_name 2407 28, // [28:28] is the sub-list for extension extendee 2408 0, // [0:28] is the sub-list for field type_name 2409} 2410 2411func init() { file_google_genomics_v1alpha2_pipelines_proto_init() } 2412func file_google_genomics_v1alpha2_pipelines_proto_init() { 2413 if File_google_genomics_v1alpha2_pipelines_proto != nil { 2414 return 2415 } 2416 if !protoimpl.UnsafeEnabled { 2417 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 2418 switch v := v.(*ComputeEngine); i { 2419 case 0: 2420 return &v.state 2421 case 1: 2422 return &v.sizeCache 2423 case 2: 2424 return &v.unknownFields 2425 default: 2426 return nil 2427 } 2428 } 2429 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 2430 switch v := v.(*RuntimeMetadata); i { 2431 case 0: 2432 return &v.state 2433 case 1: 2434 return &v.sizeCache 2435 case 2: 2436 return &v.unknownFields 2437 default: 2438 return nil 2439 } 2440 } 2441 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 2442 switch v := v.(*Pipeline); i { 2443 case 0: 2444 return &v.state 2445 case 1: 2446 return &v.sizeCache 2447 case 2: 2448 return &v.unknownFields 2449 default: 2450 return nil 2451 } 2452 } 2453 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 2454 switch v := v.(*CreatePipelineRequest); i { 2455 case 0: 2456 return &v.state 2457 case 1: 2458 return &v.sizeCache 2459 case 2: 2460 return &v.unknownFields 2461 default: 2462 return nil 2463 } 2464 } 2465 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 2466 switch v := v.(*RunPipelineArgs); i { 2467 case 0: 2468 return &v.state 2469 case 1: 2470 return &v.sizeCache 2471 case 2: 2472 return &v.unknownFields 2473 default: 2474 return nil 2475 } 2476 } 2477 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 2478 switch v := v.(*RunPipelineRequest); i { 2479 case 0: 2480 return &v.state 2481 case 1: 2482 return &v.sizeCache 2483 case 2: 2484 return &v.unknownFields 2485 default: 2486 return nil 2487 } 2488 } 2489 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 2490 switch v := v.(*GetPipelineRequest); i { 2491 case 0: 2492 return &v.state 2493 case 1: 2494 return &v.sizeCache 2495 case 2: 2496 return &v.unknownFields 2497 default: 2498 return nil 2499 } 2500 } 2501 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 2502 switch v := v.(*ListPipelinesRequest); i { 2503 case 0: 2504 return &v.state 2505 case 1: 2506 return &v.sizeCache 2507 case 2: 2508 return &v.unknownFields 2509 default: 2510 return nil 2511 } 2512 } 2513 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 2514 switch v := v.(*ListPipelinesResponse); i { 2515 case 0: 2516 return &v.state 2517 case 1: 2518 return &v.sizeCache 2519 case 2: 2520 return &v.unknownFields 2521 default: 2522 return nil 2523 } 2524 } 2525 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { 2526 switch v := v.(*DeletePipelineRequest); i { 2527 case 0: 2528 return &v.state 2529 case 1: 2530 return &v.sizeCache 2531 case 2: 2532 return &v.unknownFields 2533 default: 2534 return nil 2535 } 2536 } 2537 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { 2538 switch v := v.(*GetControllerConfigRequest); i { 2539 case 0: 2540 return &v.state 2541 case 1: 2542 return &v.sizeCache 2543 case 2: 2544 return &v.unknownFields 2545 default: 2546 return nil 2547 } 2548 } 2549 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { 2550 switch v := v.(*ControllerConfig); i { 2551 case 0: 2552 return &v.state 2553 case 1: 2554 return &v.sizeCache 2555 case 2: 2556 return &v.unknownFields 2557 default: 2558 return nil 2559 } 2560 } 2561 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { 2562 switch v := v.(*TimestampEvent); i { 2563 case 0: 2564 return &v.state 2565 case 1: 2566 return &v.sizeCache 2567 case 2: 2568 return &v.unknownFields 2569 default: 2570 return nil 2571 } 2572 } 2573 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { 2574 switch v := v.(*SetOperationStatusRequest); i { 2575 case 0: 2576 return &v.state 2577 case 1: 2578 return &v.sizeCache 2579 case 2: 2580 return &v.unknownFields 2581 default: 2582 return nil 2583 } 2584 } 2585 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { 2586 switch v := v.(*ServiceAccount); i { 2587 case 0: 2588 return &v.state 2589 case 1: 2590 return &v.sizeCache 2591 case 2: 2592 return &v.unknownFields 2593 default: 2594 return nil 2595 } 2596 } 2597 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { 2598 switch v := v.(*LoggingOptions); i { 2599 case 0: 2600 return &v.state 2601 case 1: 2602 return &v.sizeCache 2603 case 2: 2604 return &v.unknownFields 2605 default: 2606 return nil 2607 } 2608 } 2609 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} { 2610 switch v := v.(*PipelineResources); i { 2611 case 0: 2612 return &v.state 2613 case 1: 2614 return &v.sizeCache 2615 case 2: 2616 return &v.unknownFields 2617 default: 2618 return nil 2619 } 2620 } 2621 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} { 2622 switch v := v.(*PipelineParameter); i { 2623 case 0: 2624 return &v.state 2625 case 1: 2626 return &v.sizeCache 2627 case 2: 2628 return &v.unknownFields 2629 default: 2630 return nil 2631 } 2632 } 2633 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} { 2634 switch v := v.(*DockerExecutor); i { 2635 case 0: 2636 return &v.state 2637 case 1: 2638 return &v.sizeCache 2639 case 2: 2640 return &v.unknownFields 2641 default: 2642 return nil 2643 } 2644 } 2645 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} { 2646 switch v := v.(*ControllerConfig_RepeatedString); i { 2647 case 0: 2648 return &v.state 2649 case 1: 2650 return &v.sizeCache 2651 case 2: 2652 return &v.unknownFields 2653 default: 2654 return nil 2655 } 2656 } 2657 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} { 2658 switch v := v.(*PipelineResources_Disk); i { 2659 case 0: 2660 return &v.state 2661 case 1: 2662 return &v.sizeCache 2663 case 2: 2664 return &v.unknownFields 2665 default: 2666 return nil 2667 } 2668 } 2669 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[28].Exporter = func(v interface{}, i int) interface{} { 2670 switch v := v.(*PipelineParameter_LocalCopy); i { 2671 case 0: 2672 return &v.state 2673 case 1: 2674 return &v.sizeCache 2675 case 2: 2676 return &v.unknownFields 2677 default: 2678 return nil 2679 } 2680 } 2681 } 2682 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[2].OneofWrappers = []interface{}{ 2683 (*Pipeline_Docker)(nil), 2684 } 2685 file_google_genomics_v1alpha2_pipelines_proto_msgTypes[5].OneofWrappers = []interface{}{ 2686 (*RunPipelineRequest_PipelineId)(nil), 2687 (*RunPipelineRequest_EphemeralPipeline)(nil), 2688 } 2689 type x struct{} 2690 out := protoimpl.TypeBuilder{ 2691 File: protoimpl.DescBuilder{ 2692 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 2693 RawDescriptor: file_google_genomics_v1alpha2_pipelines_proto_rawDesc, 2694 NumEnums: 1, 2695 NumMessages: 29, 2696 NumExtensions: 0, 2697 NumServices: 1, 2698 }, 2699 GoTypes: file_google_genomics_v1alpha2_pipelines_proto_goTypes, 2700 DependencyIndexes: file_google_genomics_v1alpha2_pipelines_proto_depIdxs, 2701 EnumInfos: file_google_genomics_v1alpha2_pipelines_proto_enumTypes, 2702 MessageInfos: file_google_genomics_v1alpha2_pipelines_proto_msgTypes, 2703 }.Build() 2704 File_google_genomics_v1alpha2_pipelines_proto = out.File 2705 file_google_genomics_v1alpha2_pipelines_proto_rawDesc = nil 2706 file_google_genomics_v1alpha2_pipelines_proto_goTypes = nil 2707 file_google_genomics_v1alpha2_pipelines_proto_depIdxs = nil 2708} 2709 2710// Reference imports to suppress errors if they are not otherwise used. 2711var _ context.Context 2712var _ grpc.ClientConnInterface 2713 2714// This is a compile-time assertion to ensure that this generated file 2715// is compatible with the grpc package it is being compiled against. 2716const _ = grpc.SupportPackageIsVersion6 2717 2718// PipelinesV1Alpha2Client is the client API for PipelinesV1Alpha2 service. 2719// 2720// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 2721type PipelinesV1Alpha2Client interface { 2722 // Creates a pipeline that can be run later. Create takes a Pipeline that 2723 // has all fields other than `pipelineId` populated, and then returns 2724 // the same pipeline with `pipelineId` populated. This id can be used 2725 // to run the pipeline. 2726 // 2727 // Caller must have WRITE permission to the project. 2728 CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*Pipeline, error) 2729 // Runs a pipeline. If `pipelineId` is specified in the request, then 2730 // run a saved pipeline. If `ephemeralPipeline` is specified, then run 2731 // that pipeline once without saving a copy. 2732 // 2733 // The caller must have READ permission to the project where the pipeline 2734 // is stored and WRITE permission to the project where the pipeline will be 2735 // run, as VMs will be created and storage will be used. 2736 RunPipeline(ctx context.Context, in *RunPipelineRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 2737 // Retrieves a pipeline based on ID. 2738 // 2739 // Caller must have READ permission to the project. 2740 GetPipeline(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*Pipeline, error) 2741 // Lists pipelines. 2742 // 2743 // Caller must have READ permission to the project. 2744 ListPipelines(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*ListPipelinesResponse, error) 2745 // Deletes a pipeline based on ID. 2746 // 2747 // Caller must have WRITE permission to the project. 2748 DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 2749 // Gets controller configuration information. Should only be called 2750 // by VMs created by the Pipelines Service and not by end users. 2751 GetControllerConfig(ctx context.Context, in *GetControllerConfigRequest, opts ...grpc.CallOption) (*ControllerConfig, error) 2752 // Sets status of a given operation. Any new timestamps (as determined by 2753 // description) are appended to TimestampEvents. Should only be called by VMs 2754 // created by the Pipelines Service and not by end users. 2755 SetOperationStatus(ctx context.Context, in *SetOperationStatusRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 2756} 2757 2758type pipelinesV1Alpha2Client struct { 2759 cc grpc.ClientConnInterface 2760} 2761 2762func NewPipelinesV1Alpha2Client(cc grpc.ClientConnInterface) PipelinesV1Alpha2Client { 2763 return &pipelinesV1Alpha2Client{cc} 2764} 2765 2766func (c *pipelinesV1Alpha2Client) CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*Pipeline, error) { 2767 out := new(Pipeline) 2768 err := c.cc.Invoke(ctx, "/google.genomics.v1alpha2.PipelinesV1Alpha2/CreatePipeline", in, out, opts...) 2769 if err != nil { 2770 return nil, err 2771 } 2772 return out, nil 2773} 2774 2775func (c *pipelinesV1Alpha2Client) RunPipeline(ctx context.Context, in *RunPipelineRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 2776 out := new(longrunning.Operation) 2777 err := c.cc.Invoke(ctx, "/google.genomics.v1alpha2.PipelinesV1Alpha2/RunPipeline", in, out, opts...) 2778 if err != nil { 2779 return nil, err 2780 } 2781 return out, nil 2782} 2783 2784func (c *pipelinesV1Alpha2Client) GetPipeline(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*Pipeline, error) { 2785 out := new(Pipeline) 2786 err := c.cc.Invoke(ctx, "/google.genomics.v1alpha2.PipelinesV1Alpha2/GetPipeline", in, out, opts...) 2787 if err != nil { 2788 return nil, err 2789 } 2790 return out, nil 2791} 2792 2793func (c *pipelinesV1Alpha2Client) ListPipelines(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*ListPipelinesResponse, error) { 2794 out := new(ListPipelinesResponse) 2795 err := c.cc.Invoke(ctx, "/google.genomics.v1alpha2.PipelinesV1Alpha2/ListPipelines", in, out, opts...) 2796 if err != nil { 2797 return nil, err 2798 } 2799 return out, nil 2800} 2801 2802func (c *pipelinesV1Alpha2Client) DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 2803 out := new(emptypb.Empty) 2804 err := c.cc.Invoke(ctx, "/google.genomics.v1alpha2.PipelinesV1Alpha2/DeletePipeline", in, out, opts...) 2805 if err != nil { 2806 return nil, err 2807 } 2808 return out, nil 2809} 2810 2811func (c *pipelinesV1Alpha2Client) GetControllerConfig(ctx context.Context, in *GetControllerConfigRequest, opts ...grpc.CallOption) (*ControllerConfig, error) { 2812 out := new(ControllerConfig) 2813 err := c.cc.Invoke(ctx, "/google.genomics.v1alpha2.PipelinesV1Alpha2/GetControllerConfig", in, out, opts...) 2814 if err != nil { 2815 return nil, err 2816 } 2817 return out, nil 2818} 2819 2820func (c *pipelinesV1Alpha2Client) SetOperationStatus(ctx context.Context, in *SetOperationStatusRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 2821 out := new(emptypb.Empty) 2822 err := c.cc.Invoke(ctx, "/google.genomics.v1alpha2.PipelinesV1Alpha2/SetOperationStatus", in, out, opts...) 2823 if err != nil { 2824 return nil, err 2825 } 2826 return out, nil 2827} 2828 2829// PipelinesV1Alpha2Server is the server API for PipelinesV1Alpha2 service. 2830type PipelinesV1Alpha2Server interface { 2831 // Creates a pipeline that can be run later. Create takes a Pipeline that 2832 // has all fields other than `pipelineId` populated, and then returns 2833 // the same pipeline with `pipelineId` populated. This id can be used 2834 // to run the pipeline. 2835 // 2836 // Caller must have WRITE permission to the project. 2837 CreatePipeline(context.Context, *CreatePipelineRequest) (*Pipeline, error) 2838 // Runs a pipeline. If `pipelineId` is specified in the request, then 2839 // run a saved pipeline. If `ephemeralPipeline` is specified, then run 2840 // that pipeline once without saving a copy. 2841 // 2842 // The caller must have READ permission to the project where the pipeline 2843 // is stored and WRITE permission to the project where the pipeline will be 2844 // run, as VMs will be created and storage will be used. 2845 RunPipeline(context.Context, *RunPipelineRequest) (*longrunning.Operation, error) 2846 // Retrieves a pipeline based on ID. 2847 // 2848 // Caller must have READ permission to the project. 2849 GetPipeline(context.Context, *GetPipelineRequest) (*Pipeline, error) 2850 // Lists pipelines. 2851 // 2852 // Caller must have READ permission to the project. 2853 ListPipelines(context.Context, *ListPipelinesRequest) (*ListPipelinesResponse, error) 2854 // Deletes a pipeline based on ID. 2855 // 2856 // Caller must have WRITE permission to the project. 2857 DeletePipeline(context.Context, *DeletePipelineRequest) (*emptypb.Empty, error) 2858 // Gets controller configuration information. Should only be called 2859 // by VMs created by the Pipelines Service and not by end users. 2860 GetControllerConfig(context.Context, *GetControllerConfigRequest) (*ControllerConfig, error) 2861 // Sets status of a given operation. Any new timestamps (as determined by 2862 // description) are appended to TimestampEvents. Should only be called by VMs 2863 // created by the Pipelines Service and not by end users. 2864 SetOperationStatus(context.Context, *SetOperationStatusRequest) (*emptypb.Empty, error) 2865} 2866 2867// UnimplementedPipelinesV1Alpha2Server can be embedded to have forward compatible implementations. 2868type UnimplementedPipelinesV1Alpha2Server struct { 2869} 2870 2871func (*UnimplementedPipelinesV1Alpha2Server) CreatePipeline(context.Context, *CreatePipelineRequest) (*Pipeline, error) { 2872 return nil, status.Errorf(codes.Unimplemented, "method CreatePipeline not implemented") 2873} 2874func (*UnimplementedPipelinesV1Alpha2Server) RunPipeline(context.Context, *RunPipelineRequest) (*longrunning.Operation, error) { 2875 return nil, status.Errorf(codes.Unimplemented, "method RunPipeline not implemented") 2876} 2877func (*UnimplementedPipelinesV1Alpha2Server) GetPipeline(context.Context, *GetPipelineRequest) (*Pipeline, error) { 2878 return nil, status.Errorf(codes.Unimplemented, "method GetPipeline not implemented") 2879} 2880func (*UnimplementedPipelinesV1Alpha2Server) ListPipelines(context.Context, *ListPipelinesRequest) (*ListPipelinesResponse, error) { 2881 return nil, status.Errorf(codes.Unimplemented, "method ListPipelines not implemented") 2882} 2883func (*UnimplementedPipelinesV1Alpha2Server) DeletePipeline(context.Context, *DeletePipelineRequest) (*emptypb.Empty, error) { 2884 return nil, status.Errorf(codes.Unimplemented, "method DeletePipeline not implemented") 2885} 2886func (*UnimplementedPipelinesV1Alpha2Server) GetControllerConfig(context.Context, *GetControllerConfigRequest) (*ControllerConfig, error) { 2887 return nil, status.Errorf(codes.Unimplemented, "method GetControllerConfig not implemented") 2888} 2889func (*UnimplementedPipelinesV1Alpha2Server) SetOperationStatus(context.Context, *SetOperationStatusRequest) (*emptypb.Empty, error) { 2890 return nil, status.Errorf(codes.Unimplemented, "method SetOperationStatus not implemented") 2891} 2892 2893func RegisterPipelinesV1Alpha2Server(s *grpc.Server, srv PipelinesV1Alpha2Server) { 2894 s.RegisterService(&_PipelinesV1Alpha2_serviceDesc, srv) 2895} 2896 2897func _PipelinesV1Alpha2_CreatePipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2898 in := new(CreatePipelineRequest) 2899 if err := dec(in); err != nil { 2900 return nil, err 2901 } 2902 if interceptor == nil { 2903 return srv.(PipelinesV1Alpha2Server).CreatePipeline(ctx, in) 2904 } 2905 info := &grpc.UnaryServerInfo{ 2906 Server: srv, 2907 FullMethod: "/google.genomics.v1alpha2.PipelinesV1Alpha2/CreatePipeline", 2908 } 2909 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2910 return srv.(PipelinesV1Alpha2Server).CreatePipeline(ctx, req.(*CreatePipelineRequest)) 2911 } 2912 return interceptor(ctx, in, info, handler) 2913} 2914 2915func _PipelinesV1Alpha2_RunPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2916 in := new(RunPipelineRequest) 2917 if err := dec(in); err != nil { 2918 return nil, err 2919 } 2920 if interceptor == nil { 2921 return srv.(PipelinesV1Alpha2Server).RunPipeline(ctx, in) 2922 } 2923 info := &grpc.UnaryServerInfo{ 2924 Server: srv, 2925 FullMethod: "/google.genomics.v1alpha2.PipelinesV1Alpha2/RunPipeline", 2926 } 2927 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2928 return srv.(PipelinesV1Alpha2Server).RunPipeline(ctx, req.(*RunPipelineRequest)) 2929 } 2930 return interceptor(ctx, in, info, handler) 2931} 2932 2933func _PipelinesV1Alpha2_GetPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2934 in := new(GetPipelineRequest) 2935 if err := dec(in); err != nil { 2936 return nil, err 2937 } 2938 if interceptor == nil { 2939 return srv.(PipelinesV1Alpha2Server).GetPipeline(ctx, in) 2940 } 2941 info := &grpc.UnaryServerInfo{ 2942 Server: srv, 2943 FullMethod: "/google.genomics.v1alpha2.PipelinesV1Alpha2/GetPipeline", 2944 } 2945 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2946 return srv.(PipelinesV1Alpha2Server).GetPipeline(ctx, req.(*GetPipelineRequest)) 2947 } 2948 return interceptor(ctx, in, info, handler) 2949} 2950 2951func _PipelinesV1Alpha2_ListPipelines_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2952 in := new(ListPipelinesRequest) 2953 if err := dec(in); err != nil { 2954 return nil, err 2955 } 2956 if interceptor == nil { 2957 return srv.(PipelinesV1Alpha2Server).ListPipelines(ctx, in) 2958 } 2959 info := &grpc.UnaryServerInfo{ 2960 Server: srv, 2961 FullMethod: "/google.genomics.v1alpha2.PipelinesV1Alpha2/ListPipelines", 2962 } 2963 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2964 return srv.(PipelinesV1Alpha2Server).ListPipelines(ctx, req.(*ListPipelinesRequest)) 2965 } 2966 return interceptor(ctx, in, info, handler) 2967} 2968 2969func _PipelinesV1Alpha2_DeletePipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2970 in := new(DeletePipelineRequest) 2971 if err := dec(in); err != nil { 2972 return nil, err 2973 } 2974 if interceptor == nil { 2975 return srv.(PipelinesV1Alpha2Server).DeletePipeline(ctx, in) 2976 } 2977 info := &grpc.UnaryServerInfo{ 2978 Server: srv, 2979 FullMethod: "/google.genomics.v1alpha2.PipelinesV1Alpha2/DeletePipeline", 2980 } 2981 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2982 return srv.(PipelinesV1Alpha2Server).DeletePipeline(ctx, req.(*DeletePipelineRequest)) 2983 } 2984 return interceptor(ctx, in, info, handler) 2985} 2986 2987func _PipelinesV1Alpha2_GetControllerConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2988 in := new(GetControllerConfigRequest) 2989 if err := dec(in); err != nil { 2990 return nil, err 2991 } 2992 if interceptor == nil { 2993 return srv.(PipelinesV1Alpha2Server).GetControllerConfig(ctx, in) 2994 } 2995 info := &grpc.UnaryServerInfo{ 2996 Server: srv, 2997 FullMethod: "/google.genomics.v1alpha2.PipelinesV1Alpha2/GetControllerConfig", 2998 } 2999 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3000 return srv.(PipelinesV1Alpha2Server).GetControllerConfig(ctx, req.(*GetControllerConfigRequest)) 3001 } 3002 return interceptor(ctx, in, info, handler) 3003} 3004 3005func _PipelinesV1Alpha2_SetOperationStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3006 in := new(SetOperationStatusRequest) 3007 if err := dec(in); err != nil { 3008 return nil, err 3009 } 3010 if interceptor == nil { 3011 return srv.(PipelinesV1Alpha2Server).SetOperationStatus(ctx, in) 3012 } 3013 info := &grpc.UnaryServerInfo{ 3014 Server: srv, 3015 FullMethod: "/google.genomics.v1alpha2.PipelinesV1Alpha2/SetOperationStatus", 3016 } 3017 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3018 return srv.(PipelinesV1Alpha2Server).SetOperationStatus(ctx, req.(*SetOperationStatusRequest)) 3019 } 3020 return interceptor(ctx, in, info, handler) 3021} 3022 3023var _PipelinesV1Alpha2_serviceDesc = grpc.ServiceDesc{ 3024 ServiceName: "google.genomics.v1alpha2.PipelinesV1Alpha2", 3025 HandlerType: (*PipelinesV1Alpha2Server)(nil), 3026 Methods: []grpc.MethodDesc{ 3027 { 3028 MethodName: "CreatePipeline", 3029 Handler: _PipelinesV1Alpha2_CreatePipeline_Handler, 3030 }, 3031 { 3032 MethodName: "RunPipeline", 3033 Handler: _PipelinesV1Alpha2_RunPipeline_Handler, 3034 }, 3035 { 3036 MethodName: "GetPipeline", 3037 Handler: _PipelinesV1Alpha2_GetPipeline_Handler, 3038 }, 3039 { 3040 MethodName: "ListPipelines", 3041 Handler: _PipelinesV1Alpha2_ListPipelines_Handler, 3042 }, 3043 { 3044 MethodName: "DeletePipeline", 3045 Handler: _PipelinesV1Alpha2_DeletePipeline_Handler, 3046 }, 3047 { 3048 MethodName: "GetControllerConfig", 3049 Handler: _PipelinesV1Alpha2_GetControllerConfig_Handler, 3050 }, 3051 { 3052 MethodName: "SetOperationStatus", 3053 Handler: _PipelinesV1Alpha2_SetOperationStatus_Handler, 3054 }, 3055 }, 3056 Streams: []grpc.StreamDesc{}, 3057 Metadata: "google/genomics/v1alpha2/pipelines.proto", 3058} 3059