1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/genomics/v1alpha2/pipelines.proto 3 4package genomics 5 6import ( 7 context "context" 8 fmt "fmt" 9 math "math" 10 11 proto "github.com/golang/protobuf/proto" 12 duration "github.com/golang/protobuf/ptypes/duration" 13 empty "github.com/golang/protobuf/ptypes/empty" 14 timestamp "github.com/golang/protobuf/ptypes/timestamp" 15 _ "google.golang.org/genproto/googleapis/api/annotations" 16 longrunning "google.golang.org/genproto/googleapis/longrunning" 17 code "google.golang.org/genproto/googleapis/rpc/code" 18 grpc "google.golang.org/grpc" 19) 20 21// Reference imports to suppress errors if they are not otherwise used. 22var _ = proto.Marshal 23var _ = fmt.Errorf 24var _ = math.Inf 25 26// This is a compile-time assertion to ensure that this generated file 27// is compatible with the proto package it is being compiled against. 28// A compilation error at this line likely means your copy of the 29// proto package needs to be updated. 30const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 31 32// The types of disks that may be attached to VMs. 33type PipelineResources_Disk_Type int32 34 35const ( 36 // Default disk type. Use one of the other options below. 37 PipelineResources_Disk_TYPE_UNSPECIFIED PipelineResources_Disk_Type = 0 38 // Specifies a Google Compute Engine persistent hard disk. See 39 // https://cloud.google.com/compute/docs/disks/#pdspecs for details. 40 PipelineResources_Disk_PERSISTENT_HDD PipelineResources_Disk_Type = 1 41 // Specifies a Google Compute Engine persistent solid-state disk. See 42 // https://cloud.google.com/compute/docs/disks/#pdspecs for details. 43 PipelineResources_Disk_PERSISTENT_SSD PipelineResources_Disk_Type = 2 44 // Specifies a Google Compute Engine local SSD. 45 // See https://cloud.google.com/compute/docs/disks/local-ssd for details. 46 PipelineResources_Disk_LOCAL_SSD PipelineResources_Disk_Type = 3 47) 48 49var PipelineResources_Disk_Type_name = map[int32]string{ 50 0: "TYPE_UNSPECIFIED", 51 1: "PERSISTENT_HDD", 52 2: "PERSISTENT_SSD", 53 3: "LOCAL_SSD", 54} 55 56var PipelineResources_Disk_Type_value = map[string]int32{ 57 "TYPE_UNSPECIFIED": 0, 58 "PERSISTENT_HDD": 1, 59 "PERSISTENT_SSD": 2, 60 "LOCAL_SSD": 3, 61} 62 63func (x PipelineResources_Disk_Type) String() string { 64 return proto.EnumName(PipelineResources_Disk_Type_name, int32(x)) 65} 66 67func (PipelineResources_Disk_Type) EnumDescriptor() ([]byte, []int) { 68 return fileDescriptor_72a0789107b705b0, []int{16, 0, 0} 69} 70 71// Describes a Compute Engine resource that is being managed by a running 72// [pipeline][google.genomics.v1alpha2.Pipeline]. 73type ComputeEngine struct { 74 // The instance on which the operation is running. 75 InstanceName string `protobuf:"bytes,1,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"` 76 // The availability zone in which the instance resides. 77 Zone string `protobuf:"bytes,2,opt,name=zone,proto3" json:"zone,omitempty"` 78 // The machine type of the instance. 79 MachineType string `protobuf:"bytes,3,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"` 80 // The names of the disks that were created for this pipeline. 81 DiskNames []string `protobuf:"bytes,4,rep,name=disk_names,json=diskNames,proto3" json:"disk_names,omitempty"` 82 XXX_NoUnkeyedLiteral struct{} `json:"-"` 83 XXX_unrecognized []byte `json:"-"` 84 XXX_sizecache int32 `json:"-"` 85} 86 87func (m *ComputeEngine) Reset() { *m = ComputeEngine{} } 88func (m *ComputeEngine) String() string { return proto.CompactTextString(m) } 89func (*ComputeEngine) ProtoMessage() {} 90func (*ComputeEngine) Descriptor() ([]byte, []int) { 91 return fileDescriptor_72a0789107b705b0, []int{0} 92} 93 94func (m *ComputeEngine) XXX_Unmarshal(b []byte) error { 95 return xxx_messageInfo_ComputeEngine.Unmarshal(m, b) 96} 97func (m *ComputeEngine) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 98 return xxx_messageInfo_ComputeEngine.Marshal(b, m, deterministic) 99} 100func (m *ComputeEngine) XXX_Merge(src proto.Message) { 101 xxx_messageInfo_ComputeEngine.Merge(m, src) 102} 103func (m *ComputeEngine) XXX_Size() int { 104 return xxx_messageInfo_ComputeEngine.Size(m) 105} 106func (m *ComputeEngine) XXX_DiscardUnknown() { 107 xxx_messageInfo_ComputeEngine.DiscardUnknown(m) 108} 109 110var xxx_messageInfo_ComputeEngine proto.InternalMessageInfo 111 112func (m *ComputeEngine) GetInstanceName() string { 113 if m != nil { 114 return m.InstanceName 115 } 116 return "" 117} 118 119func (m *ComputeEngine) GetZone() string { 120 if m != nil { 121 return m.Zone 122 } 123 return "" 124} 125 126func (m *ComputeEngine) GetMachineType() string { 127 if m != nil { 128 return m.MachineType 129 } 130 return "" 131} 132 133func (m *ComputeEngine) GetDiskNames() []string { 134 if m != nil { 135 return m.DiskNames 136 } 137 return nil 138} 139 140// Runtime metadata that will be populated in the 141// [runtimeMetadata][google.genomics.v1.OperationMetadata.runtime_metadata] 142// field of the Operation associated with a RunPipeline execution. 143type RuntimeMetadata struct { 144 // Execution information specific to Google Compute Engine. 145 ComputeEngine *ComputeEngine `protobuf:"bytes,1,opt,name=compute_engine,json=computeEngine,proto3" json:"compute_engine,omitempty"` 146 XXX_NoUnkeyedLiteral struct{} `json:"-"` 147 XXX_unrecognized []byte `json:"-"` 148 XXX_sizecache int32 `json:"-"` 149} 150 151func (m *RuntimeMetadata) Reset() { *m = RuntimeMetadata{} } 152func (m *RuntimeMetadata) String() string { return proto.CompactTextString(m) } 153func (*RuntimeMetadata) ProtoMessage() {} 154func (*RuntimeMetadata) Descriptor() ([]byte, []int) { 155 return fileDescriptor_72a0789107b705b0, []int{1} 156} 157 158func (m *RuntimeMetadata) XXX_Unmarshal(b []byte) error { 159 return xxx_messageInfo_RuntimeMetadata.Unmarshal(m, b) 160} 161func (m *RuntimeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 162 return xxx_messageInfo_RuntimeMetadata.Marshal(b, m, deterministic) 163} 164func (m *RuntimeMetadata) XXX_Merge(src proto.Message) { 165 xxx_messageInfo_RuntimeMetadata.Merge(m, src) 166} 167func (m *RuntimeMetadata) XXX_Size() int { 168 return xxx_messageInfo_RuntimeMetadata.Size(m) 169} 170func (m *RuntimeMetadata) XXX_DiscardUnknown() { 171 xxx_messageInfo_RuntimeMetadata.DiscardUnknown(m) 172} 173 174var xxx_messageInfo_RuntimeMetadata proto.InternalMessageInfo 175 176func (m *RuntimeMetadata) GetComputeEngine() *ComputeEngine { 177 if m != nil { 178 return m.ComputeEngine 179 } 180 return nil 181} 182 183// The pipeline object. Represents a transformation from a set of input 184// parameters to a set of output parameters. The transformation is defined 185// as a docker image and command to run within that image. Each pipeline 186// is run on a Google Compute Engine VM. A pipeline can be created with the 187// `create` method and then later run with the `run` method, or a pipeline can 188// be defined and run all at once with the `run` method. 189type Pipeline struct { 190 // Required. The project in which to create the pipeline. The caller must have 191 // WRITE access. 192 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 193 // Required. A user specified pipeline name that does not have to be unique. 194 // This name can be used for filtering Pipelines in ListPipelines. 195 Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` 196 // User-specified description. 197 Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` 198 // Input parameters of the pipeline. 199 InputParameters []*PipelineParameter `protobuf:"bytes,8,rep,name=input_parameters,json=inputParameters,proto3" json:"input_parameters,omitempty"` 200 // Output parameters of the pipeline. 201 OutputParameters []*PipelineParameter `protobuf:"bytes,9,rep,name=output_parameters,json=outputParameters,proto3" json:"output_parameters,omitempty"` 202 // Required. The executor indicates in which environment the pipeline runs. 203 // 204 // Types that are valid to be assigned to Executor: 205 // *Pipeline_Docker 206 Executor isPipeline_Executor `protobuf_oneof:"executor"` 207 // Required. Specifies resource requirements for the pipeline run. 208 // Required fields: 209 // 210 // * 211 // [minimumCpuCores][google.genomics.v1alpha2.PipelineResources.minimum_cpu_cores] 212 // 213 // * 214 // [minimumRamGb][google.genomics.v1alpha2.PipelineResources.minimum_ram_gb] 215 Resources *PipelineResources `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"` 216 // Unique pipeline id that is generated by the service when CreatePipeline 217 // is called. Cannot be specified in the Pipeline used in the 218 // CreatePipelineRequest, and will be populated in the response to 219 // CreatePipeline and all subsequent Get and List calls. Indicates that the 220 // service has registered this pipeline. 221 PipelineId string `protobuf:"bytes,7,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"` 222 XXX_NoUnkeyedLiteral struct{} `json:"-"` 223 XXX_unrecognized []byte `json:"-"` 224 XXX_sizecache int32 `json:"-"` 225} 226 227func (m *Pipeline) Reset() { *m = Pipeline{} } 228func (m *Pipeline) String() string { return proto.CompactTextString(m) } 229func (*Pipeline) ProtoMessage() {} 230func (*Pipeline) Descriptor() ([]byte, []int) { 231 return fileDescriptor_72a0789107b705b0, []int{2} 232} 233 234func (m *Pipeline) XXX_Unmarshal(b []byte) error { 235 return xxx_messageInfo_Pipeline.Unmarshal(m, b) 236} 237func (m *Pipeline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 238 return xxx_messageInfo_Pipeline.Marshal(b, m, deterministic) 239} 240func (m *Pipeline) XXX_Merge(src proto.Message) { 241 xxx_messageInfo_Pipeline.Merge(m, src) 242} 243func (m *Pipeline) XXX_Size() int { 244 return xxx_messageInfo_Pipeline.Size(m) 245} 246func (m *Pipeline) XXX_DiscardUnknown() { 247 xxx_messageInfo_Pipeline.DiscardUnknown(m) 248} 249 250var xxx_messageInfo_Pipeline proto.InternalMessageInfo 251 252func (m *Pipeline) GetProjectId() string { 253 if m != nil { 254 return m.ProjectId 255 } 256 return "" 257} 258 259func (m *Pipeline) GetName() string { 260 if m != nil { 261 return m.Name 262 } 263 return "" 264} 265 266func (m *Pipeline) GetDescription() string { 267 if m != nil { 268 return m.Description 269 } 270 return "" 271} 272 273func (m *Pipeline) GetInputParameters() []*PipelineParameter { 274 if m != nil { 275 return m.InputParameters 276 } 277 return nil 278} 279 280func (m *Pipeline) GetOutputParameters() []*PipelineParameter { 281 if m != nil { 282 return m.OutputParameters 283 } 284 return nil 285} 286 287type isPipeline_Executor interface { 288 isPipeline_Executor() 289} 290 291type Pipeline_Docker struct { 292 Docker *DockerExecutor `protobuf:"bytes,5,opt,name=docker,proto3,oneof"` 293} 294 295func (*Pipeline_Docker) isPipeline_Executor() {} 296 297func (m *Pipeline) GetExecutor() isPipeline_Executor { 298 if m != nil { 299 return m.Executor 300 } 301 return nil 302} 303 304func (m *Pipeline) GetDocker() *DockerExecutor { 305 if x, ok := m.GetExecutor().(*Pipeline_Docker); ok { 306 return x.Docker 307 } 308 return nil 309} 310 311func (m *Pipeline) GetResources() *PipelineResources { 312 if m != nil { 313 return m.Resources 314 } 315 return nil 316} 317 318func (m *Pipeline) GetPipelineId() string { 319 if m != nil { 320 return m.PipelineId 321 } 322 return "" 323} 324 325// XXX_OneofWrappers is for the internal use of the proto package. 326func (*Pipeline) XXX_OneofWrappers() []interface{} { 327 return []interface{}{ 328 (*Pipeline_Docker)(nil), 329 } 330} 331 332// The request to create a pipeline. The pipeline field here should not have 333// `pipelineId` populated, as that will be populated by the server. 334type CreatePipelineRequest struct { 335 // The pipeline to create. Should not have `pipelineId` populated. 336 Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` 337 XXX_NoUnkeyedLiteral struct{} `json:"-"` 338 XXX_unrecognized []byte `json:"-"` 339 XXX_sizecache int32 `json:"-"` 340} 341 342func (m *CreatePipelineRequest) Reset() { *m = CreatePipelineRequest{} } 343func (m *CreatePipelineRequest) String() string { return proto.CompactTextString(m) } 344func (*CreatePipelineRequest) ProtoMessage() {} 345func (*CreatePipelineRequest) Descriptor() ([]byte, []int) { 346 return fileDescriptor_72a0789107b705b0, []int{3} 347} 348 349func (m *CreatePipelineRequest) XXX_Unmarshal(b []byte) error { 350 return xxx_messageInfo_CreatePipelineRequest.Unmarshal(m, b) 351} 352func (m *CreatePipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 353 return xxx_messageInfo_CreatePipelineRequest.Marshal(b, m, deterministic) 354} 355func (m *CreatePipelineRequest) XXX_Merge(src proto.Message) { 356 xxx_messageInfo_CreatePipelineRequest.Merge(m, src) 357} 358func (m *CreatePipelineRequest) XXX_Size() int { 359 return xxx_messageInfo_CreatePipelineRequest.Size(m) 360} 361func (m *CreatePipelineRequest) XXX_DiscardUnknown() { 362 xxx_messageInfo_CreatePipelineRequest.DiscardUnknown(m) 363} 364 365var xxx_messageInfo_CreatePipelineRequest proto.InternalMessageInfo 366 367func (m *CreatePipelineRequest) GetPipeline() *Pipeline { 368 if m != nil { 369 return m.Pipeline 370 } 371 return nil 372} 373 374// The pipeline run arguments. 375type RunPipelineArgs struct { 376 // Required. The project in which to run the pipeline. The caller must have 377 // WRITER access to all Google Cloud services and resources (e.g. Google 378 // Compute Engine) will be used. 379 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 380 // Pipeline input arguments; keys are defined in the pipeline documentation. 381 // All input parameters that do not have default values must be specified. 382 // If parameters with defaults are specified here, the defaults will be 383 // overridden. 384 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"` 385 // Pipeline output arguments; keys are defined in the pipeline 386 // documentation. All output parameters of without default values 387 // must be specified. If parameters with defaults are specified 388 // here, the defaults will be overridden. 389 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"` 390 // The Google Cloud Service Account that will be used to access data and 391 // services. By default, the compute service account associated with 392 // `projectId` is used. 393 ServiceAccount *ServiceAccount `protobuf:"bytes,4,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"` 394 // This field is deprecated. Use `labels` instead. Client-specified pipeline 395 // operation identifier. 396 ClientId string `protobuf:"bytes,5,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"` 397 // Specifies resource requirements/overrides for the pipeline run. 398 Resources *PipelineResources `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"` 399 // Required. Logging options. Used by the service to communicate results 400 // to the user. 401 Logging *LoggingOptions `protobuf:"bytes,7,opt,name=logging,proto3" json:"logging,omitempty"` 402 // How long to keep the VM up after a failure (for example docker command 403 // failed, copying input or output files failed, etc). While the VM is up, one 404 // can ssh into the VM to debug. Default is 0; maximum allowed value is 1 day. 405 KeepVmAliveOnFailureDuration *duration.Duration `protobuf:"bytes,8,opt,name=keep_vm_alive_on_failure_duration,json=keepVmAliveOnFailureDuration,proto3" json:"keep_vm_alive_on_failure_duration,omitempty"` 406 // Labels to apply to this pipeline run. Labels will also be applied to 407 // compute resources (VM, disks) created by this pipeline run. When listing 408 // operations, operations can [filtered by labels] 409 // [google.longrunning.ListOperationsRequest.filter]. 410 // Label keys may not be empty; label values may be empty. Non-empty labels 411 // must be 1-63 characters long, and comply with [RFC1035] 412 // (https://www.ietf.org/rfc/rfc1035.txt). 413 // Specifically, the name must be 1-63 characters long and match the regular 414 // expression `[a-z]([-a-z0-9]*[a-z0-9])?` which means the first 415 // character must be a lowercase letter, and all following characters must be 416 // a dash, lowercase letter, or digit, except the last character, which cannot 417 // be a dash. 418 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"` 419 XXX_NoUnkeyedLiteral struct{} `json:"-"` 420 XXX_unrecognized []byte `json:"-"` 421 XXX_sizecache int32 `json:"-"` 422} 423 424func (m *RunPipelineArgs) Reset() { *m = RunPipelineArgs{} } 425func (m *RunPipelineArgs) String() string { return proto.CompactTextString(m) } 426func (*RunPipelineArgs) ProtoMessage() {} 427func (*RunPipelineArgs) Descriptor() ([]byte, []int) { 428 return fileDescriptor_72a0789107b705b0, []int{4} 429} 430 431func (m *RunPipelineArgs) XXX_Unmarshal(b []byte) error { 432 return xxx_messageInfo_RunPipelineArgs.Unmarshal(m, b) 433} 434func (m *RunPipelineArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 435 return xxx_messageInfo_RunPipelineArgs.Marshal(b, m, deterministic) 436} 437func (m *RunPipelineArgs) XXX_Merge(src proto.Message) { 438 xxx_messageInfo_RunPipelineArgs.Merge(m, src) 439} 440func (m *RunPipelineArgs) XXX_Size() int { 441 return xxx_messageInfo_RunPipelineArgs.Size(m) 442} 443func (m *RunPipelineArgs) XXX_DiscardUnknown() { 444 xxx_messageInfo_RunPipelineArgs.DiscardUnknown(m) 445} 446 447var xxx_messageInfo_RunPipelineArgs proto.InternalMessageInfo 448 449func (m *RunPipelineArgs) GetProjectId() string { 450 if m != nil { 451 return m.ProjectId 452 } 453 return "" 454} 455 456func (m *RunPipelineArgs) GetInputs() map[string]string { 457 if m != nil { 458 return m.Inputs 459 } 460 return nil 461} 462 463func (m *RunPipelineArgs) GetOutputs() map[string]string { 464 if m != nil { 465 return m.Outputs 466 } 467 return nil 468} 469 470func (m *RunPipelineArgs) GetServiceAccount() *ServiceAccount { 471 if m != nil { 472 return m.ServiceAccount 473 } 474 return nil 475} 476 477func (m *RunPipelineArgs) GetClientId() string { 478 if m != nil { 479 return m.ClientId 480 } 481 return "" 482} 483 484func (m *RunPipelineArgs) GetResources() *PipelineResources { 485 if m != nil { 486 return m.Resources 487 } 488 return nil 489} 490 491func (m *RunPipelineArgs) GetLogging() *LoggingOptions { 492 if m != nil { 493 return m.Logging 494 } 495 return nil 496} 497 498func (m *RunPipelineArgs) GetKeepVmAliveOnFailureDuration() *duration.Duration { 499 if m != nil { 500 return m.KeepVmAliveOnFailureDuration 501 } 502 return nil 503} 504 505func (m *RunPipelineArgs) GetLabels() map[string]string { 506 if m != nil { 507 return m.Labels 508 } 509 return nil 510} 511 512// The request to run a pipeline. If `pipelineId` is specified, it 513// refers to a saved pipeline created with CreatePipeline and set as 514// the `pipelineId` of the returned Pipeline object. If 515// `ephemeralPipeline` is specified, that pipeline is run once 516// with the given args and not saved. It is an error to specify both 517// `pipelineId` and `ephemeralPipeline`. `pipelineArgs` 518// must be specified. 519type RunPipelineRequest struct { 520 // Types that are valid to be assigned to Pipeline: 521 // *RunPipelineRequest_PipelineId 522 // *RunPipelineRequest_EphemeralPipeline 523 Pipeline isRunPipelineRequest_Pipeline `protobuf_oneof:"pipeline"` 524 // The arguments to use when running this pipeline. 525 PipelineArgs *RunPipelineArgs `protobuf:"bytes,3,opt,name=pipeline_args,json=pipelineArgs,proto3" json:"pipeline_args,omitempty"` 526 XXX_NoUnkeyedLiteral struct{} `json:"-"` 527 XXX_unrecognized []byte `json:"-"` 528 XXX_sizecache int32 `json:"-"` 529} 530 531func (m *RunPipelineRequest) Reset() { *m = RunPipelineRequest{} } 532func (m *RunPipelineRequest) String() string { return proto.CompactTextString(m) } 533func (*RunPipelineRequest) ProtoMessage() {} 534func (*RunPipelineRequest) Descriptor() ([]byte, []int) { 535 return fileDescriptor_72a0789107b705b0, []int{5} 536} 537 538func (m *RunPipelineRequest) XXX_Unmarshal(b []byte) error { 539 return xxx_messageInfo_RunPipelineRequest.Unmarshal(m, b) 540} 541func (m *RunPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 542 return xxx_messageInfo_RunPipelineRequest.Marshal(b, m, deterministic) 543} 544func (m *RunPipelineRequest) XXX_Merge(src proto.Message) { 545 xxx_messageInfo_RunPipelineRequest.Merge(m, src) 546} 547func (m *RunPipelineRequest) XXX_Size() int { 548 return xxx_messageInfo_RunPipelineRequest.Size(m) 549} 550func (m *RunPipelineRequest) XXX_DiscardUnknown() { 551 xxx_messageInfo_RunPipelineRequest.DiscardUnknown(m) 552} 553 554var xxx_messageInfo_RunPipelineRequest proto.InternalMessageInfo 555 556type isRunPipelineRequest_Pipeline interface { 557 isRunPipelineRequest_Pipeline() 558} 559 560type RunPipelineRequest_PipelineId struct { 561 PipelineId string `protobuf:"bytes,1,opt,name=pipeline_id,json=pipelineId,proto3,oneof"` 562} 563 564type RunPipelineRequest_EphemeralPipeline struct { 565 EphemeralPipeline *Pipeline `protobuf:"bytes,2,opt,name=ephemeral_pipeline,json=ephemeralPipeline,proto3,oneof"` 566} 567 568func (*RunPipelineRequest_PipelineId) isRunPipelineRequest_Pipeline() {} 569 570func (*RunPipelineRequest_EphemeralPipeline) isRunPipelineRequest_Pipeline() {} 571 572func (m *RunPipelineRequest) GetPipeline() isRunPipelineRequest_Pipeline { 573 if m != nil { 574 return m.Pipeline 575 } 576 return nil 577} 578 579func (m *RunPipelineRequest) GetPipelineId() string { 580 if x, ok := m.GetPipeline().(*RunPipelineRequest_PipelineId); ok { 581 return x.PipelineId 582 } 583 return "" 584} 585 586func (m *RunPipelineRequest) GetEphemeralPipeline() *Pipeline { 587 if x, ok := m.GetPipeline().(*RunPipelineRequest_EphemeralPipeline); ok { 588 return x.EphemeralPipeline 589 } 590 return nil 591} 592 593func (m *RunPipelineRequest) GetPipelineArgs() *RunPipelineArgs { 594 if m != nil { 595 return m.PipelineArgs 596 } 597 return nil 598} 599 600// XXX_OneofWrappers is for the internal use of the proto package. 601func (*RunPipelineRequest) XXX_OneofWrappers() []interface{} { 602 return []interface{}{ 603 (*RunPipelineRequest_PipelineId)(nil), 604 (*RunPipelineRequest_EphemeralPipeline)(nil), 605 } 606} 607 608// A request to get a saved pipeline by id. 609type GetPipelineRequest struct { 610 // Caller must have READ access to the project in which this pipeline 611 // is defined. 612 PipelineId string `protobuf:"bytes,1,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"` 613 XXX_NoUnkeyedLiteral struct{} `json:"-"` 614 XXX_unrecognized []byte `json:"-"` 615 XXX_sizecache int32 `json:"-"` 616} 617 618func (m *GetPipelineRequest) Reset() { *m = GetPipelineRequest{} } 619func (m *GetPipelineRequest) String() string { return proto.CompactTextString(m) } 620func (*GetPipelineRequest) ProtoMessage() {} 621func (*GetPipelineRequest) Descriptor() ([]byte, []int) { 622 return fileDescriptor_72a0789107b705b0, []int{6} 623} 624 625func (m *GetPipelineRequest) XXX_Unmarshal(b []byte) error { 626 return xxx_messageInfo_GetPipelineRequest.Unmarshal(m, b) 627} 628func (m *GetPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 629 return xxx_messageInfo_GetPipelineRequest.Marshal(b, m, deterministic) 630} 631func (m *GetPipelineRequest) XXX_Merge(src proto.Message) { 632 xxx_messageInfo_GetPipelineRequest.Merge(m, src) 633} 634func (m *GetPipelineRequest) XXX_Size() int { 635 return xxx_messageInfo_GetPipelineRequest.Size(m) 636} 637func (m *GetPipelineRequest) XXX_DiscardUnknown() { 638 xxx_messageInfo_GetPipelineRequest.DiscardUnknown(m) 639} 640 641var xxx_messageInfo_GetPipelineRequest proto.InternalMessageInfo 642 643func (m *GetPipelineRequest) GetPipelineId() string { 644 if m != nil { 645 return m.PipelineId 646 } 647 return "" 648} 649 650// A request to list pipelines in a given project. Pipelines can be 651// filtered by name using `namePrefix`: all pipelines with names that 652// begin with `namePrefix` will be returned. Uses standard pagination: 653// `pageSize` indicates how many pipelines to return, and 654// `pageToken` comes from a previous ListPipelinesResponse to 655// indicate offset. 656type ListPipelinesRequest struct { 657 // Required. The name of the project to search for pipelines. Caller 658 // must have READ access to this project. 659 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 660 // Pipelines with names that match this prefix should be 661 // returned. If unspecified, all pipelines in the project, up to 662 // `pageSize`, will be returned. 663 NamePrefix string `protobuf:"bytes,2,opt,name=name_prefix,json=namePrefix,proto3" json:"name_prefix,omitempty"` 664 // Number of pipelines to return at once. Defaults to 256, and max 665 // is 2048. 666 PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 667 // Token to use to indicate where to start getting results. 668 // If unspecified, returns the first page of results. 669 PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 670 XXX_NoUnkeyedLiteral struct{} `json:"-"` 671 XXX_unrecognized []byte `json:"-"` 672 XXX_sizecache int32 `json:"-"` 673} 674 675func (m *ListPipelinesRequest) Reset() { *m = ListPipelinesRequest{} } 676func (m *ListPipelinesRequest) String() string { return proto.CompactTextString(m) } 677func (*ListPipelinesRequest) ProtoMessage() {} 678func (*ListPipelinesRequest) Descriptor() ([]byte, []int) { 679 return fileDescriptor_72a0789107b705b0, []int{7} 680} 681 682func (m *ListPipelinesRequest) XXX_Unmarshal(b []byte) error { 683 return xxx_messageInfo_ListPipelinesRequest.Unmarshal(m, b) 684} 685func (m *ListPipelinesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 686 return xxx_messageInfo_ListPipelinesRequest.Marshal(b, m, deterministic) 687} 688func (m *ListPipelinesRequest) XXX_Merge(src proto.Message) { 689 xxx_messageInfo_ListPipelinesRequest.Merge(m, src) 690} 691func (m *ListPipelinesRequest) XXX_Size() int { 692 return xxx_messageInfo_ListPipelinesRequest.Size(m) 693} 694func (m *ListPipelinesRequest) XXX_DiscardUnknown() { 695 xxx_messageInfo_ListPipelinesRequest.DiscardUnknown(m) 696} 697 698var xxx_messageInfo_ListPipelinesRequest proto.InternalMessageInfo 699 700func (m *ListPipelinesRequest) GetProjectId() string { 701 if m != nil { 702 return m.ProjectId 703 } 704 return "" 705} 706 707func (m *ListPipelinesRequest) GetNamePrefix() string { 708 if m != nil { 709 return m.NamePrefix 710 } 711 return "" 712} 713 714func (m *ListPipelinesRequest) GetPageSize() int32 { 715 if m != nil { 716 return m.PageSize 717 } 718 return 0 719} 720 721func (m *ListPipelinesRequest) GetPageToken() string { 722 if m != nil { 723 return m.PageToken 724 } 725 return "" 726} 727 728// The response of ListPipelines. Contains at most `pageSize` 729// pipelines. If it contains `pageSize` pipelines, and more pipelines 730// exist, then `nextPageToken` will be populated and should be 731// used as the `pageToken` argument to a subsequent ListPipelines 732// request. 733type ListPipelinesResponse struct { 734 // The matched pipelines. 735 Pipelines []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"` 736 // The token to use to get the next page of results. 737 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 738 XXX_NoUnkeyedLiteral struct{} `json:"-"` 739 XXX_unrecognized []byte `json:"-"` 740 XXX_sizecache int32 `json:"-"` 741} 742 743func (m *ListPipelinesResponse) Reset() { *m = ListPipelinesResponse{} } 744func (m *ListPipelinesResponse) String() string { return proto.CompactTextString(m) } 745func (*ListPipelinesResponse) ProtoMessage() {} 746func (*ListPipelinesResponse) Descriptor() ([]byte, []int) { 747 return fileDescriptor_72a0789107b705b0, []int{8} 748} 749 750func (m *ListPipelinesResponse) XXX_Unmarshal(b []byte) error { 751 return xxx_messageInfo_ListPipelinesResponse.Unmarshal(m, b) 752} 753func (m *ListPipelinesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 754 return xxx_messageInfo_ListPipelinesResponse.Marshal(b, m, deterministic) 755} 756func (m *ListPipelinesResponse) XXX_Merge(src proto.Message) { 757 xxx_messageInfo_ListPipelinesResponse.Merge(m, src) 758} 759func (m *ListPipelinesResponse) XXX_Size() int { 760 return xxx_messageInfo_ListPipelinesResponse.Size(m) 761} 762func (m *ListPipelinesResponse) XXX_DiscardUnknown() { 763 xxx_messageInfo_ListPipelinesResponse.DiscardUnknown(m) 764} 765 766var xxx_messageInfo_ListPipelinesResponse proto.InternalMessageInfo 767 768func (m *ListPipelinesResponse) GetPipelines() []*Pipeline { 769 if m != nil { 770 return m.Pipelines 771 } 772 return nil 773} 774 775func (m *ListPipelinesResponse) GetNextPageToken() string { 776 if m != nil { 777 return m.NextPageToken 778 } 779 return "" 780} 781 782// The request to delete a saved pipeline by ID. 783type DeletePipelineRequest struct { 784 // Caller must have WRITE access to the project in which this pipeline 785 // is defined. 786 PipelineId string `protobuf:"bytes,1,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"` 787 XXX_NoUnkeyedLiteral struct{} `json:"-"` 788 XXX_unrecognized []byte `json:"-"` 789 XXX_sizecache int32 `json:"-"` 790} 791 792func (m *DeletePipelineRequest) Reset() { *m = DeletePipelineRequest{} } 793func (m *DeletePipelineRequest) String() string { return proto.CompactTextString(m) } 794func (*DeletePipelineRequest) ProtoMessage() {} 795func (*DeletePipelineRequest) Descriptor() ([]byte, []int) { 796 return fileDescriptor_72a0789107b705b0, []int{9} 797} 798 799func (m *DeletePipelineRequest) XXX_Unmarshal(b []byte) error { 800 return xxx_messageInfo_DeletePipelineRequest.Unmarshal(m, b) 801} 802func (m *DeletePipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 803 return xxx_messageInfo_DeletePipelineRequest.Marshal(b, m, deterministic) 804} 805func (m *DeletePipelineRequest) XXX_Merge(src proto.Message) { 806 xxx_messageInfo_DeletePipelineRequest.Merge(m, src) 807} 808func (m *DeletePipelineRequest) XXX_Size() int { 809 return xxx_messageInfo_DeletePipelineRequest.Size(m) 810} 811func (m *DeletePipelineRequest) XXX_DiscardUnknown() { 812 xxx_messageInfo_DeletePipelineRequest.DiscardUnknown(m) 813} 814 815var xxx_messageInfo_DeletePipelineRequest proto.InternalMessageInfo 816 817func (m *DeletePipelineRequest) GetPipelineId() string { 818 if m != nil { 819 return m.PipelineId 820 } 821 return "" 822} 823 824// Request to get controller configuation. Should only be used 825// by VMs created by the Pipelines Service and not by end users. 826type GetControllerConfigRequest struct { 827 // The operation to retrieve controller configuration for. 828 OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` 829 ValidationToken uint64 `protobuf:"varint,2,opt,name=validation_token,json=validationToken,proto3" json:"validation_token,omitempty"` 830 XXX_NoUnkeyedLiteral struct{} `json:"-"` 831 XXX_unrecognized []byte `json:"-"` 832 XXX_sizecache int32 `json:"-"` 833} 834 835func (m *GetControllerConfigRequest) Reset() { *m = GetControllerConfigRequest{} } 836func (m *GetControllerConfigRequest) String() string { return proto.CompactTextString(m) } 837func (*GetControllerConfigRequest) ProtoMessage() {} 838func (*GetControllerConfigRequest) Descriptor() ([]byte, []int) { 839 return fileDescriptor_72a0789107b705b0, []int{10} 840} 841 842func (m *GetControllerConfigRequest) XXX_Unmarshal(b []byte) error { 843 return xxx_messageInfo_GetControllerConfigRequest.Unmarshal(m, b) 844} 845func (m *GetControllerConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 846 return xxx_messageInfo_GetControllerConfigRequest.Marshal(b, m, deterministic) 847} 848func (m *GetControllerConfigRequest) XXX_Merge(src proto.Message) { 849 xxx_messageInfo_GetControllerConfigRequest.Merge(m, src) 850} 851func (m *GetControllerConfigRequest) XXX_Size() int { 852 return xxx_messageInfo_GetControllerConfigRequest.Size(m) 853} 854func (m *GetControllerConfigRequest) XXX_DiscardUnknown() { 855 xxx_messageInfo_GetControllerConfigRequest.DiscardUnknown(m) 856} 857 858var xxx_messageInfo_GetControllerConfigRequest proto.InternalMessageInfo 859 860func (m *GetControllerConfigRequest) GetOperationId() string { 861 if m != nil { 862 return m.OperationId 863 } 864 return "" 865} 866 867func (m *GetControllerConfigRequest) GetValidationToken() uint64 { 868 if m != nil { 869 return m.ValidationToken 870 } 871 return 0 872} 873 874// Stores the information that the controller will fetch from the 875// server in order to run. Should only be used by VMs created by the 876// Pipelines Service and not by end users. 877type ControllerConfig struct { 878 Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"` 879 Cmd string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"` 880 GcsLogPath string `protobuf:"bytes,3,opt,name=gcs_log_path,json=gcsLogPath,proto3" json:"gcs_log_path,omitempty"` 881 MachineType string `protobuf:"bytes,4,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"` 882 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"` 883 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"` 884 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"` 885 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"` 886 XXX_NoUnkeyedLiteral struct{} `json:"-"` 887 XXX_unrecognized []byte `json:"-"` 888 XXX_sizecache int32 `json:"-"` 889} 890 891func (m *ControllerConfig) Reset() { *m = ControllerConfig{} } 892func (m *ControllerConfig) String() string { return proto.CompactTextString(m) } 893func (*ControllerConfig) ProtoMessage() {} 894func (*ControllerConfig) Descriptor() ([]byte, []int) { 895 return fileDescriptor_72a0789107b705b0, []int{11} 896} 897 898func (m *ControllerConfig) XXX_Unmarshal(b []byte) error { 899 return xxx_messageInfo_ControllerConfig.Unmarshal(m, b) 900} 901func (m *ControllerConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 902 return xxx_messageInfo_ControllerConfig.Marshal(b, m, deterministic) 903} 904func (m *ControllerConfig) XXX_Merge(src proto.Message) { 905 xxx_messageInfo_ControllerConfig.Merge(m, src) 906} 907func (m *ControllerConfig) XXX_Size() int { 908 return xxx_messageInfo_ControllerConfig.Size(m) 909} 910func (m *ControllerConfig) XXX_DiscardUnknown() { 911 xxx_messageInfo_ControllerConfig.DiscardUnknown(m) 912} 913 914var xxx_messageInfo_ControllerConfig proto.InternalMessageInfo 915 916func (m *ControllerConfig) GetImage() string { 917 if m != nil { 918 return m.Image 919 } 920 return "" 921} 922 923func (m *ControllerConfig) GetCmd() string { 924 if m != nil { 925 return m.Cmd 926 } 927 return "" 928} 929 930func (m *ControllerConfig) GetGcsLogPath() string { 931 if m != nil { 932 return m.GcsLogPath 933 } 934 return "" 935} 936 937func (m *ControllerConfig) GetMachineType() string { 938 if m != nil { 939 return m.MachineType 940 } 941 return "" 942} 943 944func (m *ControllerConfig) GetVars() map[string]string { 945 if m != nil { 946 return m.Vars 947 } 948 return nil 949} 950 951func (m *ControllerConfig) GetDisks() map[string]string { 952 if m != nil { 953 return m.Disks 954 } 955 return nil 956} 957 958func (m *ControllerConfig) GetGcsSources() map[string]*ControllerConfig_RepeatedString { 959 if m != nil { 960 return m.GcsSources 961 } 962 return nil 963} 964 965func (m *ControllerConfig) GetGcsSinks() map[string]*ControllerConfig_RepeatedString { 966 if m != nil { 967 return m.GcsSinks 968 } 969 return nil 970} 971 972type ControllerConfig_RepeatedString struct { 973 Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` 974 XXX_NoUnkeyedLiteral struct{} `json:"-"` 975 XXX_unrecognized []byte `json:"-"` 976 XXX_sizecache int32 `json:"-"` 977} 978 979func (m *ControllerConfig_RepeatedString) Reset() { *m = ControllerConfig_RepeatedString{} } 980func (m *ControllerConfig_RepeatedString) String() string { return proto.CompactTextString(m) } 981func (*ControllerConfig_RepeatedString) ProtoMessage() {} 982func (*ControllerConfig_RepeatedString) Descriptor() ([]byte, []int) { 983 return fileDescriptor_72a0789107b705b0, []int{11, 0} 984} 985 986func (m *ControllerConfig_RepeatedString) XXX_Unmarshal(b []byte) error { 987 return xxx_messageInfo_ControllerConfig_RepeatedString.Unmarshal(m, b) 988} 989func (m *ControllerConfig_RepeatedString) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 990 return xxx_messageInfo_ControllerConfig_RepeatedString.Marshal(b, m, deterministic) 991} 992func (m *ControllerConfig_RepeatedString) XXX_Merge(src proto.Message) { 993 xxx_messageInfo_ControllerConfig_RepeatedString.Merge(m, src) 994} 995func (m *ControllerConfig_RepeatedString) XXX_Size() int { 996 return xxx_messageInfo_ControllerConfig_RepeatedString.Size(m) 997} 998func (m *ControllerConfig_RepeatedString) XXX_DiscardUnknown() { 999 xxx_messageInfo_ControllerConfig_RepeatedString.DiscardUnknown(m) 1000} 1001 1002var xxx_messageInfo_ControllerConfig_RepeatedString proto.InternalMessageInfo 1003 1004func (m *ControllerConfig_RepeatedString) GetValues() []string { 1005 if m != nil { 1006 return m.Values 1007 } 1008 return nil 1009} 1010 1011// Stores the list of events and times they occured for major events in job 1012// execution. 1013type TimestampEvent struct { 1014 // String indicating the type of event 1015 Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"` 1016 // The time this event occured. 1017 Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` 1018 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1019 XXX_unrecognized []byte `json:"-"` 1020 XXX_sizecache int32 `json:"-"` 1021} 1022 1023func (m *TimestampEvent) Reset() { *m = TimestampEvent{} } 1024func (m *TimestampEvent) String() string { return proto.CompactTextString(m) } 1025func (*TimestampEvent) ProtoMessage() {} 1026func (*TimestampEvent) Descriptor() ([]byte, []int) { 1027 return fileDescriptor_72a0789107b705b0, []int{12} 1028} 1029 1030func (m *TimestampEvent) XXX_Unmarshal(b []byte) error { 1031 return xxx_messageInfo_TimestampEvent.Unmarshal(m, b) 1032} 1033func (m *TimestampEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1034 return xxx_messageInfo_TimestampEvent.Marshal(b, m, deterministic) 1035} 1036func (m *TimestampEvent) XXX_Merge(src proto.Message) { 1037 xxx_messageInfo_TimestampEvent.Merge(m, src) 1038} 1039func (m *TimestampEvent) XXX_Size() int { 1040 return xxx_messageInfo_TimestampEvent.Size(m) 1041} 1042func (m *TimestampEvent) XXX_DiscardUnknown() { 1043 xxx_messageInfo_TimestampEvent.DiscardUnknown(m) 1044} 1045 1046var xxx_messageInfo_TimestampEvent proto.InternalMessageInfo 1047 1048func (m *TimestampEvent) GetDescription() string { 1049 if m != nil { 1050 return m.Description 1051 } 1052 return "" 1053} 1054 1055func (m *TimestampEvent) GetTimestamp() *timestamp.Timestamp { 1056 if m != nil { 1057 return m.Timestamp 1058 } 1059 return nil 1060} 1061 1062// Request to set operation status. Should only be used by VMs 1063// created by the Pipelines Service and not by end users. 1064type SetOperationStatusRequest struct { 1065 OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` 1066 TimestampEvents []*TimestampEvent `protobuf:"bytes,2,rep,name=timestamp_events,json=timestampEvents,proto3" json:"timestamp_events,omitempty"` 1067 ErrorCode code.Code `protobuf:"varint,3,opt,name=error_code,json=errorCode,proto3,enum=google.rpc.Code" json:"error_code,omitempty"` 1068 ErrorMessage string `protobuf:"bytes,4,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` 1069 ValidationToken uint64 `protobuf:"varint,5,opt,name=validation_token,json=validationToken,proto3" json:"validation_token,omitempty"` 1070 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1071 XXX_unrecognized []byte `json:"-"` 1072 XXX_sizecache int32 `json:"-"` 1073} 1074 1075func (m *SetOperationStatusRequest) Reset() { *m = SetOperationStatusRequest{} } 1076func (m *SetOperationStatusRequest) String() string { return proto.CompactTextString(m) } 1077func (*SetOperationStatusRequest) ProtoMessage() {} 1078func (*SetOperationStatusRequest) Descriptor() ([]byte, []int) { 1079 return fileDescriptor_72a0789107b705b0, []int{13} 1080} 1081 1082func (m *SetOperationStatusRequest) XXX_Unmarshal(b []byte) error { 1083 return xxx_messageInfo_SetOperationStatusRequest.Unmarshal(m, b) 1084} 1085func (m *SetOperationStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1086 return xxx_messageInfo_SetOperationStatusRequest.Marshal(b, m, deterministic) 1087} 1088func (m *SetOperationStatusRequest) XXX_Merge(src proto.Message) { 1089 xxx_messageInfo_SetOperationStatusRequest.Merge(m, src) 1090} 1091func (m *SetOperationStatusRequest) XXX_Size() int { 1092 return xxx_messageInfo_SetOperationStatusRequest.Size(m) 1093} 1094func (m *SetOperationStatusRequest) XXX_DiscardUnknown() { 1095 xxx_messageInfo_SetOperationStatusRequest.DiscardUnknown(m) 1096} 1097 1098var xxx_messageInfo_SetOperationStatusRequest proto.InternalMessageInfo 1099 1100func (m *SetOperationStatusRequest) GetOperationId() string { 1101 if m != nil { 1102 return m.OperationId 1103 } 1104 return "" 1105} 1106 1107func (m *SetOperationStatusRequest) GetTimestampEvents() []*TimestampEvent { 1108 if m != nil { 1109 return m.TimestampEvents 1110 } 1111 return nil 1112} 1113 1114func (m *SetOperationStatusRequest) GetErrorCode() code.Code { 1115 if m != nil { 1116 return m.ErrorCode 1117 } 1118 return code.Code_OK 1119} 1120 1121func (m *SetOperationStatusRequest) GetErrorMessage() string { 1122 if m != nil { 1123 return m.ErrorMessage 1124 } 1125 return "" 1126} 1127 1128func (m *SetOperationStatusRequest) GetValidationToken() uint64 { 1129 if m != nil { 1130 return m.ValidationToken 1131 } 1132 return 0 1133} 1134 1135// A Google Cloud Service Account. 1136type ServiceAccount struct { 1137 // Email address of the service account. Defaults to `default`, 1138 // which uses the compute service account associated with the project. 1139 Email string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"` 1140 // List of scopes to be enabled for this service account on the VM. 1141 // The following scopes are automatically included: 1142 // 1143 // * https://www.googleapis.com/auth/compute 1144 // * https://www.googleapis.com/auth/devstorage.full_control 1145 // * https://www.googleapis.com/auth/genomics 1146 // * https://www.googleapis.com/auth/logging.write 1147 // * https://www.googleapis.com/auth/monitoring.write 1148 Scopes []string `protobuf:"bytes,2,rep,name=scopes,proto3" json:"scopes,omitempty"` 1149 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1150 XXX_unrecognized []byte `json:"-"` 1151 XXX_sizecache int32 `json:"-"` 1152} 1153 1154func (m *ServiceAccount) Reset() { *m = ServiceAccount{} } 1155func (m *ServiceAccount) String() string { return proto.CompactTextString(m) } 1156func (*ServiceAccount) ProtoMessage() {} 1157func (*ServiceAccount) Descriptor() ([]byte, []int) { 1158 return fileDescriptor_72a0789107b705b0, []int{14} 1159} 1160 1161func (m *ServiceAccount) XXX_Unmarshal(b []byte) error { 1162 return xxx_messageInfo_ServiceAccount.Unmarshal(m, b) 1163} 1164func (m *ServiceAccount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1165 return xxx_messageInfo_ServiceAccount.Marshal(b, m, deterministic) 1166} 1167func (m *ServiceAccount) XXX_Merge(src proto.Message) { 1168 xxx_messageInfo_ServiceAccount.Merge(m, src) 1169} 1170func (m *ServiceAccount) XXX_Size() int { 1171 return xxx_messageInfo_ServiceAccount.Size(m) 1172} 1173func (m *ServiceAccount) XXX_DiscardUnknown() { 1174 xxx_messageInfo_ServiceAccount.DiscardUnknown(m) 1175} 1176 1177var xxx_messageInfo_ServiceAccount proto.InternalMessageInfo 1178 1179func (m *ServiceAccount) GetEmail() string { 1180 if m != nil { 1181 return m.Email 1182 } 1183 return "" 1184} 1185 1186func (m *ServiceAccount) GetScopes() []string { 1187 if m != nil { 1188 return m.Scopes 1189 } 1190 return nil 1191} 1192 1193// The logging options for the pipeline run. 1194type LoggingOptions struct { 1195 // The location in Google Cloud Storage to which the pipeline logs 1196 // will be copied. Can be specified as a fully qualified directory 1197 // path, in which case logs will be output with a unique identifier 1198 // as the filename in that directory, or as a fully specified path, 1199 // which must end in `.log`, in which case that path will be 1200 // used, and the user must ensure that logs are not 1201 // overwritten. Stdout and stderr logs from the run are also 1202 // generated and output as `-stdout.log` and `-stderr.log`. 1203 GcsPath string `protobuf:"bytes,1,opt,name=gcs_path,json=gcsPath,proto3" json:"gcs_path,omitempty"` 1204 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1205 XXX_unrecognized []byte `json:"-"` 1206 XXX_sizecache int32 `json:"-"` 1207} 1208 1209func (m *LoggingOptions) Reset() { *m = LoggingOptions{} } 1210func (m *LoggingOptions) String() string { return proto.CompactTextString(m) } 1211func (*LoggingOptions) ProtoMessage() {} 1212func (*LoggingOptions) Descriptor() ([]byte, []int) { 1213 return fileDescriptor_72a0789107b705b0, []int{15} 1214} 1215 1216func (m *LoggingOptions) XXX_Unmarshal(b []byte) error { 1217 return xxx_messageInfo_LoggingOptions.Unmarshal(m, b) 1218} 1219func (m *LoggingOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1220 return xxx_messageInfo_LoggingOptions.Marshal(b, m, deterministic) 1221} 1222func (m *LoggingOptions) XXX_Merge(src proto.Message) { 1223 xxx_messageInfo_LoggingOptions.Merge(m, src) 1224} 1225func (m *LoggingOptions) XXX_Size() int { 1226 return xxx_messageInfo_LoggingOptions.Size(m) 1227} 1228func (m *LoggingOptions) XXX_DiscardUnknown() { 1229 xxx_messageInfo_LoggingOptions.DiscardUnknown(m) 1230} 1231 1232var xxx_messageInfo_LoggingOptions proto.InternalMessageInfo 1233 1234func (m *LoggingOptions) GetGcsPath() string { 1235 if m != nil { 1236 return m.GcsPath 1237 } 1238 return "" 1239} 1240 1241// The system resources for the pipeline run. 1242type PipelineResources struct { 1243 // The minimum number of cores to use. Defaults to 1. 1244 MinimumCpuCores int32 `protobuf:"varint,1,opt,name=minimum_cpu_cores,json=minimumCpuCores,proto3" json:"minimum_cpu_cores,omitempty"` 1245 // Whether to use preemptible VMs. Defaults to `false`. In order to use this, 1246 // must be true for both create time and run time. Cannot be true at run time 1247 // if false at create time. 1248 Preemptible bool `protobuf:"varint,2,opt,name=preemptible,proto3" json:"preemptible,omitempty"` 1249 // The minimum amount of RAM to use. Defaults to 3.75 (GB) 1250 MinimumRamGb float64 `protobuf:"fixed64,3,opt,name=minimum_ram_gb,json=minimumRamGb,proto3" json:"minimum_ram_gb,omitempty"` 1251 // Disks to attach. 1252 Disks []*PipelineResources_Disk `protobuf:"bytes,4,rep,name=disks,proto3" json:"disks,omitempty"` 1253 // List of Google Compute Engine availability zones to which resource 1254 // creation will restricted. If empty, any zone may be chosen. 1255 Zones []string `protobuf:"bytes,5,rep,name=zones,proto3" json:"zones,omitempty"` 1256 // The size of the boot disk. Defaults to 10 (GB). 1257 BootDiskSizeGb int32 `protobuf:"varint,6,opt,name=boot_disk_size_gb,json=bootDiskSizeGb,proto3" json:"boot_disk_size_gb,omitempty"` 1258 // Whether to assign an external IP to the instance. This is an experimental 1259 // feature that may go away. Defaults to false. 1260 // Corresponds to `--no_address` flag for [gcloud compute instances create] 1261 // (https://cloud.google.com/sdk/gcloud/reference/compute/instances/create). 1262 // In order to use this, must be true for both create time and run time. 1263 // Cannot be true at run time if false at create time. If you need to ssh into 1264 // a private IP VM for debugging, you can ssh to a public VM and then ssh into 1265 // the private VM's Internal IP. If noAddress is set, this pipeline run may 1266 // only load docker images from Google Container Registry and not Docker Hub. 1267 // ** Note: To use this option, your project must be in Google Access for 1268 // Private IPs Early Access Program.** 1269 NoAddress bool `protobuf:"varint,7,opt,name=no_address,json=noAddress,proto3" json:"no_address,omitempty"` 1270 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1271 XXX_unrecognized []byte `json:"-"` 1272 XXX_sizecache int32 `json:"-"` 1273} 1274 1275func (m *PipelineResources) Reset() { *m = PipelineResources{} } 1276func (m *PipelineResources) String() string { return proto.CompactTextString(m) } 1277func (*PipelineResources) ProtoMessage() {} 1278func (*PipelineResources) Descriptor() ([]byte, []int) { 1279 return fileDescriptor_72a0789107b705b0, []int{16} 1280} 1281 1282func (m *PipelineResources) XXX_Unmarshal(b []byte) error { 1283 return xxx_messageInfo_PipelineResources.Unmarshal(m, b) 1284} 1285func (m *PipelineResources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1286 return xxx_messageInfo_PipelineResources.Marshal(b, m, deterministic) 1287} 1288func (m *PipelineResources) XXX_Merge(src proto.Message) { 1289 xxx_messageInfo_PipelineResources.Merge(m, src) 1290} 1291func (m *PipelineResources) XXX_Size() int { 1292 return xxx_messageInfo_PipelineResources.Size(m) 1293} 1294func (m *PipelineResources) XXX_DiscardUnknown() { 1295 xxx_messageInfo_PipelineResources.DiscardUnknown(m) 1296} 1297 1298var xxx_messageInfo_PipelineResources proto.InternalMessageInfo 1299 1300func (m *PipelineResources) GetMinimumCpuCores() int32 { 1301 if m != nil { 1302 return m.MinimumCpuCores 1303 } 1304 return 0 1305} 1306 1307func (m *PipelineResources) GetPreemptible() bool { 1308 if m != nil { 1309 return m.Preemptible 1310 } 1311 return false 1312} 1313 1314func (m *PipelineResources) GetMinimumRamGb() float64 { 1315 if m != nil { 1316 return m.MinimumRamGb 1317 } 1318 return 0 1319} 1320 1321func (m *PipelineResources) GetDisks() []*PipelineResources_Disk { 1322 if m != nil { 1323 return m.Disks 1324 } 1325 return nil 1326} 1327 1328func (m *PipelineResources) GetZones() []string { 1329 if m != nil { 1330 return m.Zones 1331 } 1332 return nil 1333} 1334 1335func (m *PipelineResources) GetBootDiskSizeGb() int32 { 1336 if m != nil { 1337 return m.BootDiskSizeGb 1338 } 1339 return 0 1340} 1341 1342func (m *PipelineResources) GetNoAddress() bool { 1343 if m != nil { 1344 return m.NoAddress 1345 } 1346 return false 1347} 1348 1349// A Google Compute Engine disk resource specification. 1350type PipelineResources_Disk struct { 1351 // Required. The name of the disk that can be used in the pipeline 1352 // parameters. Must be 1 - 63 characters. 1353 // The name "boot" is reserved for system use. 1354 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 1355 // Required. The type of the disk to create. 1356 Type PipelineResources_Disk_Type `protobuf:"varint,2,opt,name=type,proto3,enum=google.genomics.v1alpha2.PipelineResources_Disk_Type" json:"type,omitempty"` 1357 // The size of the disk. Defaults to 500 (GB). 1358 // This field is not applicable for local SSD. 1359 SizeGb int32 `protobuf:"varint,3,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"` 1360 // The full or partial URL of the persistent disk to attach. See 1361 // https://cloud.google.com/compute/docs/reference/latest/instances#resource 1362 // and 1363 // https://cloud.google.com/compute/docs/disks/persistent-disks#snapshots 1364 // for more details. 1365 Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` 1366 // Deprecated. Disks created by the Pipelines API will be deleted at the end 1367 // of the pipeline run, regardless of what this field is set to. 1368 AutoDelete bool `protobuf:"varint,6,opt,name=auto_delete,json=autoDelete,proto3" json:"auto_delete,omitempty"` 1369 // Required at create time and cannot be overridden at run time. 1370 // Specifies the path in the docker container where files on 1371 // this disk should be located. For example, if `mountPoint` 1372 // is `/mnt/disk`, and the parameter has `localPath` 1373 // `inputs/file.txt`, the docker container can access the data at 1374 // `/mnt/disk/inputs/file.txt`. 1375 MountPoint string `protobuf:"bytes,8,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,omitempty"` 1376 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1377 XXX_unrecognized []byte `json:"-"` 1378 XXX_sizecache int32 `json:"-"` 1379} 1380 1381func (m *PipelineResources_Disk) Reset() { *m = PipelineResources_Disk{} } 1382func (m *PipelineResources_Disk) String() string { return proto.CompactTextString(m) } 1383func (*PipelineResources_Disk) ProtoMessage() {} 1384func (*PipelineResources_Disk) Descriptor() ([]byte, []int) { 1385 return fileDescriptor_72a0789107b705b0, []int{16, 0} 1386} 1387 1388func (m *PipelineResources_Disk) XXX_Unmarshal(b []byte) error { 1389 return xxx_messageInfo_PipelineResources_Disk.Unmarshal(m, b) 1390} 1391func (m *PipelineResources_Disk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1392 return xxx_messageInfo_PipelineResources_Disk.Marshal(b, m, deterministic) 1393} 1394func (m *PipelineResources_Disk) XXX_Merge(src proto.Message) { 1395 xxx_messageInfo_PipelineResources_Disk.Merge(m, src) 1396} 1397func (m *PipelineResources_Disk) XXX_Size() int { 1398 return xxx_messageInfo_PipelineResources_Disk.Size(m) 1399} 1400func (m *PipelineResources_Disk) XXX_DiscardUnknown() { 1401 xxx_messageInfo_PipelineResources_Disk.DiscardUnknown(m) 1402} 1403 1404var xxx_messageInfo_PipelineResources_Disk proto.InternalMessageInfo 1405 1406func (m *PipelineResources_Disk) GetName() string { 1407 if m != nil { 1408 return m.Name 1409 } 1410 return "" 1411} 1412 1413func (m *PipelineResources_Disk) GetType() PipelineResources_Disk_Type { 1414 if m != nil { 1415 return m.Type 1416 } 1417 return PipelineResources_Disk_TYPE_UNSPECIFIED 1418} 1419 1420func (m *PipelineResources_Disk) GetSizeGb() int32 { 1421 if m != nil { 1422 return m.SizeGb 1423 } 1424 return 0 1425} 1426 1427func (m *PipelineResources_Disk) GetSource() string { 1428 if m != nil { 1429 return m.Source 1430 } 1431 return "" 1432} 1433 1434func (m *PipelineResources_Disk) GetAutoDelete() bool { 1435 if m != nil { 1436 return m.AutoDelete 1437 } 1438 return false 1439} 1440 1441func (m *PipelineResources_Disk) GetMountPoint() string { 1442 if m != nil { 1443 return m.MountPoint 1444 } 1445 return "" 1446} 1447 1448// Parameters facilitate setting and delivering data into the 1449// pipeline's execution environment. They are defined at create time, 1450// with optional defaults, and can be overridden at run time. 1451// 1452// If `localCopy` is unset, then the parameter specifies a string that 1453// is passed as-is into the pipeline, as the value of the environment 1454// variable with the given name. A default value can be optionally 1455// specified at create time. The default can be overridden at run time 1456// using the inputs map. If no default is given, a value must be 1457// supplied at runtime. 1458// 1459// If `localCopy` is defined, then the parameter specifies a data 1460// source or sink, both in Google Cloud Storage and on the Docker container 1461// where the pipeline computation is run. The [service account associated with 1462// the Pipeline][google.genomics.v1alpha2.RunPipelineArgs.service_account] (by 1463// default the project's Compute Engine service account) must have access to the 1464// Google Cloud Storage paths. 1465// 1466// At run time, the Google Cloud Storage paths can be overridden if a default 1467// was provided at create time, or must be set otherwise. The pipeline runner 1468// should add a key/value pair to either the inputs or outputs map. The 1469// indicated data copies will be carried out before/after pipeline execution, 1470// just as if the corresponding arguments were provided to `gsutil cp`. 1471// 1472// For example: Given the following `PipelineParameter`, specified 1473// in the `inputParameters` list: 1474// 1475// ``` 1476// {name: "input_file", localCopy: {path: "file.txt", disk: "pd1"}} 1477// ``` 1478// 1479// where `disk` is defined in the `PipelineResources` object as: 1480// 1481// ``` 1482// {name: "pd1", mountPoint: "/mnt/disk/"} 1483// ``` 1484// 1485// We create a disk named `pd1`, mount it on the host VM, and map 1486// `/mnt/pd1` to `/mnt/disk` in the docker container. At 1487// runtime, an entry for `input_file` would be required in the inputs 1488// map, such as: 1489// 1490// ``` 1491// inputs["input_file"] = "gs://my-bucket/bar.txt" 1492// ``` 1493// 1494// This would generate the following gsutil call: 1495// 1496// ``` 1497// gsutil cp gs://my-bucket/bar.txt /mnt/pd1/file.txt 1498// ``` 1499// 1500// The file `/mnt/pd1/file.txt` maps to `/mnt/disk/file.txt` in the 1501// Docker container. Acceptable paths are: 1502// 1503// <table> 1504// <thead> 1505// <tr><th>Google Cloud storage path</th><th>Local path</th></tr> 1506// </thead> 1507// <tbody> 1508// <tr><td>file</td><td>file</td></tr> 1509// <tr><td>glob</td><td>directory</td></tr> 1510// </tbody> 1511// </table> 1512// 1513// For outputs, the direction of the copy is reversed: 1514// 1515// ``` 1516// gsutil cp /mnt/disk/file.txt gs://my-bucket/bar.txt 1517// ``` 1518// 1519// Acceptable paths are: 1520// 1521// <table> 1522// <thead> 1523// <tr><th>Local path</th><th>Google Cloud Storage path</th></tr> 1524// </thead> 1525// <tbody> 1526// <tr><td>file</td><td>file</td></tr> 1527// <tr> 1528// <td>file</td> 1529// <td>directory - directory must already exist</td> 1530// </tr> 1531// <tr> 1532// <td>glob</td> 1533// <td>directory - directory will be created if it doesn't exist</td></tr> 1534// </tbody> 1535// </table> 1536// 1537// One restriction due to docker limitations, is that for outputs that are found 1538// on the boot disk, the local path cannot be a glob and must be a file. 1539type PipelineParameter struct { 1540 // Required. Name of the parameter - the pipeline runner uses this string 1541 // as the key to the input and output maps in RunPipeline. 1542 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 1543 // Human-readable description. 1544 Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` 1545 // The default value for this parameter. Can be overridden at runtime. 1546 // If `localCopy` is present, then this must be a Google Cloud Storage path 1547 // beginning with `gs://`. 1548 DefaultValue string `protobuf:"bytes,5,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"` 1549 // If present, this parameter is marked for copying to and from the VM. 1550 // `LocalCopy` indicates where on the VM the file should be. The value 1551 // given to this parameter (either at runtime or using `defaultValue`) 1552 // must be the remote path where the file should be. 1553 LocalCopy *PipelineParameter_LocalCopy `protobuf:"bytes,6,opt,name=local_copy,json=localCopy,proto3" json:"local_copy,omitempty"` 1554 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1555 XXX_unrecognized []byte `json:"-"` 1556 XXX_sizecache int32 `json:"-"` 1557} 1558 1559func (m *PipelineParameter) Reset() { *m = PipelineParameter{} } 1560func (m *PipelineParameter) String() string { return proto.CompactTextString(m) } 1561func (*PipelineParameter) ProtoMessage() {} 1562func (*PipelineParameter) Descriptor() ([]byte, []int) { 1563 return fileDescriptor_72a0789107b705b0, []int{17} 1564} 1565 1566func (m *PipelineParameter) XXX_Unmarshal(b []byte) error { 1567 return xxx_messageInfo_PipelineParameter.Unmarshal(m, b) 1568} 1569func (m *PipelineParameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1570 return xxx_messageInfo_PipelineParameter.Marshal(b, m, deterministic) 1571} 1572func (m *PipelineParameter) XXX_Merge(src proto.Message) { 1573 xxx_messageInfo_PipelineParameter.Merge(m, src) 1574} 1575func (m *PipelineParameter) XXX_Size() int { 1576 return xxx_messageInfo_PipelineParameter.Size(m) 1577} 1578func (m *PipelineParameter) XXX_DiscardUnknown() { 1579 xxx_messageInfo_PipelineParameter.DiscardUnknown(m) 1580} 1581 1582var xxx_messageInfo_PipelineParameter proto.InternalMessageInfo 1583 1584func (m *PipelineParameter) GetName() string { 1585 if m != nil { 1586 return m.Name 1587 } 1588 return "" 1589} 1590 1591func (m *PipelineParameter) GetDescription() string { 1592 if m != nil { 1593 return m.Description 1594 } 1595 return "" 1596} 1597 1598func (m *PipelineParameter) GetDefaultValue() string { 1599 if m != nil { 1600 return m.DefaultValue 1601 } 1602 return "" 1603} 1604 1605func (m *PipelineParameter) GetLocalCopy() *PipelineParameter_LocalCopy { 1606 if m != nil { 1607 return m.LocalCopy 1608 } 1609 return nil 1610} 1611 1612// LocalCopy defines how a remote file should be copied to and from the VM. 1613type PipelineParameter_LocalCopy struct { 1614 // Required. The path within the user's docker container where 1615 // this input should be localized to and from, relative to the specified 1616 // disk's mount point. For example: file.txt, 1617 Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` 1618 // Required. The name of the disk where this parameter is 1619 // located. Can be the name of one of the disks specified in the 1620 // Resources field, or "boot", which represents the Docker 1621 // instance's boot disk and has a mount point of `/`. 1622 Disk string `protobuf:"bytes,2,opt,name=disk,proto3" json:"disk,omitempty"` 1623 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1624 XXX_unrecognized []byte `json:"-"` 1625 XXX_sizecache int32 `json:"-"` 1626} 1627 1628func (m *PipelineParameter_LocalCopy) Reset() { *m = PipelineParameter_LocalCopy{} } 1629func (m *PipelineParameter_LocalCopy) String() string { return proto.CompactTextString(m) } 1630func (*PipelineParameter_LocalCopy) ProtoMessage() {} 1631func (*PipelineParameter_LocalCopy) Descriptor() ([]byte, []int) { 1632 return fileDescriptor_72a0789107b705b0, []int{17, 0} 1633} 1634 1635func (m *PipelineParameter_LocalCopy) XXX_Unmarshal(b []byte) error { 1636 return xxx_messageInfo_PipelineParameter_LocalCopy.Unmarshal(m, b) 1637} 1638func (m *PipelineParameter_LocalCopy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1639 return xxx_messageInfo_PipelineParameter_LocalCopy.Marshal(b, m, deterministic) 1640} 1641func (m *PipelineParameter_LocalCopy) XXX_Merge(src proto.Message) { 1642 xxx_messageInfo_PipelineParameter_LocalCopy.Merge(m, src) 1643} 1644func (m *PipelineParameter_LocalCopy) XXX_Size() int { 1645 return xxx_messageInfo_PipelineParameter_LocalCopy.Size(m) 1646} 1647func (m *PipelineParameter_LocalCopy) XXX_DiscardUnknown() { 1648 xxx_messageInfo_PipelineParameter_LocalCopy.DiscardUnknown(m) 1649} 1650 1651var xxx_messageInfo_PipelineParameter_LocalCopy proto.InternalMessageInfo 1652 1653func (m *PipelineParameter_LocalCopy) GetPath() string { 1654 if m != nil { 1655 return m.Path 1656 } 1657 return "" 1658} 1659 1660func (m *PipelineParameter_LocalCopy) GetDisk() string { 1661 if m != nil { 1662 return m.Disk 1663 } 1664 return "" 1665} 1666 1667// The Docker execuctor specification. 1668type DockerExecutor struct { 1669 // Required. Image name from either Docker Hub or Google Container Registry. 1670 // Users that run pipelines must have READ access to the image. 1671 ImageName string `protobuf:"bytes,1,opt,name=image_name,json=imageName,proto3" json:"image_name,omitempty"` 1672 // Required. The command or newline delimited script to run. The command 1673 // string will be executed within a bash shell. 1674 // 1675 // If the command exits with a non-zero exit code, output parameter 1676 // de-localization will be skipped and the pipeline operation's 1677 // [`error`][google.longrunning.Operation.error] field will be populated. 1678 // 1679 // Maximum command string length is 16384. 1680 Cmd string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"` 1681 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1682 XXX_unrecognized []byte `json:"-"` 1683 XXX_sizecache int32 `json:"-"` 1684} 1685 1686func (m *DockerExecutor) Reset() { *m = DockerExecutor{} } 1687func (m *DockerExecutor) String() string { return proto.CompactTextString(m) } 1688func (*DockerExecutor) ProtoMessage() {} 1689func (*DockerExecutor) Descriptor() ([]byte, []int) { 1690 return fileDescriptor_72a0789107b705b0, []int{18} 1691} 1692 1693func (m *DockerExecutor) XXX_Unmarshal(b []byte) error { 1694 return xxx_messageInfo_DockerExecutor.Unmarshal(m, b) 1695} 1696func (m *DockerExecutor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1697 return xxx_messageInfo_DockerExecutor.Marshal(b, m, deterministic) 1698} 1699func (m *DockerExecutor) XXX_Merge(src proto.Message) { 1700 xxx_messageInfo_DockerExecutor.Merge(m, src) 1701} 1702func (m *DockerExecutor) XXX_Size() int { 1703 return xxx_messageInfo_DockerExecutor.Size(m) 1704} 1705func (m *DockerExecutor) XXX_DiscardUnknown() { 1706 xxx_messageInfo_DockerExecutor.DiscardUnknown(m) 1707} 1708 1709var xxx_messageInfo_DockerExecutor proto.InternalMessageInfo 1710 1711func (m *DockerExecutor) GetImageName() string { 1712 if m != nil { 1713 return m.ImageName 1714 } 1715 return "" 1716} 1717 1718func (m *DockerExecutor) GetCmd() string { 1719 if m != nil { 1720 return m.Cmd 1721 } 1722 return "" 1723} 1724 1725func init() { 1726 proto.RegisterEnum("google.genomics.v1alpha2.PipelineResources_Disk_Type", PipelineResources_Disk_Type_name, PipelineResources_Disk_Type_value) 1727 proto.RegisterType((*ComputeEngine)(nil), "google.genomics.v1alpha2.ComputeEngine") 1728 proto.RegisterType((*RuntimeMetadata)(nil), "google.genomics.v1alpha2.RuntimeMetadata") 1729 proto.RegisterType((*Pipeline)(nil), "google.genomics.v1alpha2.Pipeline") 1730 proto.RegisterType((*CreatePipelineRequest)(nil), "google.genomics.v1alpha2.CreatePipelineRequest") 1731 proto.RegisterType((*RunPipelineArgs)(nil), "google.genomics.v1alpha2.RunPipelineArgs") 1732 proto.RegisterMapType((map[string]string)(nil), "google.genomics.v1alpha2.RunPipelineArgs.InputsEntry") 1733 proto.RegisterMapType((map[string]string)(nil), "google.genomics.v1alpha2.RunPipelineArgs.LabelsEntry") 1734 proto.RegisterMapType((map[string]string)(nil), "google.genomics.v1alpha2.RunPipelineArgs.OutputsEntry") 1735 proto.RegisterType((*RunPipelineRequest)(nil), "google.genomics.v1alpha2.RunPipelineRequest") 1736 proto.RegisterType((*GetPipelineRequest)(nil), "google.genomics.v1alpha2.GetPipelineRequest") 1737 proto.RegisterType((*ListPipelinesRequest)(nil), "google.genomics.v1alpha2.ListPipelinesRequest") 1738 proto.RegisterType((*ListPipelinesResponse)(nil), "google.genomics.v1alpha2.ListPipelinesResponse") 1739 proto.RegisterType((*DeletePipelineRequest)(nil), "google.genomics.v1alpha2.DeletePipelineRequest") 1740 proto.RegisterType((*GetControllerConfigRequest)(nil), "google.genomics.v1alpha2.GetControllerConfigRequest") 1741 proto.RegisterType((*ControllerConfig)(nil), "google.genomics.v1alpha2.ControllerConfig") 1742 proto.RegisterMapType((map[string]string)(nil), "google.genomics.v1alpha2.ControllerConfig.DisksEntry") 1743 proto.RegisterMapType((map[string]*ControllerConfig_RepeatedString)(nil), "google.genomics.v1alpha2.ControllerConfig.GcsSinksEntry") 1744 proto.RegisterMapType((map[string]*ControllerConfig_RepeatedString)(nil), "google.genomics.v1alpha2.ControllerConfig.GcsSourcesEntry") 1745 proto.RegisterMapType((map[string]string)(nil), "google.genomics.v1alpha2.ControllerConfig.VarsEntry") 1746 proto.RegisterType((*ControllerConfig_RepeatedString)(nil), "google.genomics.v1alpha2.ControllerConfig.RepeatedString") 1747 proto.RegisterType((*TimestampEvent)(nil), "google.genomics.v1alpha2.TimestampEvent") 1748 proto.RegisterType((*SetOperationStatusRequest)(nil), "google.genomics.v1alpha2.SetOperationStatusRequest") 1749 proto.RegisterType((*ServiceAccount)(nil), "google.genomics.v1alpha2.ServiceAccount") 1750 proto.RegisterType((*LoggingOptions)(nil), "google.genomics.v1alpha2.LoggingOptions") 1751 proto.RegisterType((*PipelineResources)(nil), "google.genomics.v1alpha2.PipelineResources") 1752 proto.RegisterType((*PipelineResources_Disk)(nil), "google.genomics.v1alpha2.PipelineResources.Disk") 1753 proto.RegisterType((*PipelineParameter)(nil), "google.genomics.v1alpha2.PipelineParameter") 1754 proto.RegisterType((*PipelineParameter_LocalCopy)(nil), "google.genomics.v1alpha2.PipelineParameter.LocalCopy") 1755 proto.RegisterType((*DockerExecutor)(nil), "google.genomics.v1alpha2.DockerExecutor") 1756} 1757 1758func init() { 1759 proto.RegisterFile("google/genomics/v1alpha2/pipelines.proto", fileDescriptor_72a0789107b705b0) 1760} 1761 1762var fileDescriptor_72a0789107b705b0 = []byte{ 1763 // 2065 bytes of a gzipped FileDescriptorProto 1764 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x58, 0x4d, 0x73, 0xdb, 0xc8, 1765 0xd1, 0x36, 0x28, 0x4a, 0x22, 0x9a, 0x12, 0x45, 0xcf, 0xda, 0x6b, 0x9a, 0xf6, 0xbe, 0xb6, 0xe1, 1766 0x37, 0xbb, 0xb2, 0x9c, 0x22, 0x63, 0x79, 0x9d, 0xc8, 0x4a, 0xd5, 0xd6, 0x4a, 0x14, 0x2d, 0xb1, 1767 0x22, 0x4b, 0x0c, 0xa8, 0x55, 0xbe, 0x0e, 0xa8, 0x11, 0x38, 0x82, 0xb0, 0x02, 0x30, 0x08, 0x06, 1768 0x50, 0x59, 0x4e, 0x25, 0x55, 0x49, 0xe5, 0x90, 0xda, 0x4a, 0x2e, 0xc9, 0xfe, 0x88, 0x5c, 0x72, 1769 0xcc, 0xcf, 0xc8, 0x29, 0xa7, 0x9c, 0x72, 0xc9, 0x21, 0x3f, 0x21, 0xb9, 0xa5, 0x66, 0x06, 0x03, 1770 0x82, 0x1f, 0x92, 0xc8, 0xaa, 0x54, 0x6e, 0x33, 0x3d, 0xdd, 0x0f, 0x9e, 0xe9, 0xe9, 0xe9, 0xe9, 1771 0x06, 0xac, 0x3a, 0x94, 0x3a, 0x1e, 0x69, 0x3a, 0x24, 0xa0, 0xbe, 0x6b, 0xb3, 0xe6, 0xc5, 0x0b, 1772 0xec, 0x85, 0x67, 0x78, 0xbd, 0x19, 0xba, 0x21, 0xf1, 0xdc, 0x80, 0xb0, 0x46, 0x18, 0xd1, 0x98, 1773 0xa2, 0x9a, 0xd4, 0x6c, 0x28, 0xcd, 0x86, 0xd2, 0xac, 0x3f, 0x4c, 0x31, 0x70, 0xe8, 0x36, 0x71, 1774 0x10, 0xd0, 0x18, 0xc7, 0x2e, 0x0d, 0x52, 0xbb, 0xfa, 0xd3, 0x74, 0xd5, 0xa3, 0x81, 0x13, 0x25, 1775 0x41, 0xe0, 0x06, 0x4e, 0x93, 0x86, 0x24, 0x1a, 0x52, 0xfa, 0xbf, 0x54, 0x49, 0xcc, 0x4e, 0x92, 1776 0xd3, 0x66, 0x3f, 0x91, 0x0a, 0xe9, 0xfa, 0x83, 0xd1, 0x75, 0xe2, 0x87, 0xf1, 0x65, 0xba, 0xf8, 1777 0x68, 0x74, 0x31, 0x76, 0x7d, 0xc2, 0x62, 0xec, 0x87, 0xa9, 0xc2, 0xdd, 0x54, 0x21, 0x0a, 0xed, 1778 0xa6, 0x4d, 0xfb, 0x44, 0x8a, 0x8d, 0xaf, 0x34, 0x58, 0x6e, 0x51, 0x3f, 0x4c, 0x62, 0xd2, 0x0e, 1779 0x1c, 0x37, 0x20, 0xe8, 0x29, 0x2c, 0xbb, 0x01, 0x8b, 0x71, 0x60, 0x13, 0x2b, 0xc0, 0x3e, 0xa9, 1780 0x69, 0x8f, 0xb5, 0x55, 0xdd, 0x5c, 0x52, 0xc2, 0x03, 0xec, 0x13, 0x84, 0xa0, 0xf8, 0x9e, 0x06, 1781 0xa4, 0x56, 0x10, 0x6b, 0x62, 0x8c, 0x9e, 0xc0, 0x92, 0x8f, 0xed, 0x33, 0x37, 0x20, 0x56, 0x7c, 1782 0x19, 0x92, 0xda, 0x9c, 0x58, 0x2b, 0xa7, 0xb2, 0xa3, 0xcb, 0x90, 0xa0, 0x8f, 0x00, 0xfa, 0x2e, 1783 0x3b, 0x17, 0xb8, 0xac, 0x56, 0x7c, 0x3c, 0xb7, 0xaa, 0x9b, 0x3a, 0x97, 0x70, 0x50, 0x66, 0x60, 1784 0x58, 0x31, 0x93, 0x80, 0x33, 0x7f, 0x4b, 0x62, 0xdc, 0xc7, 0x31, 0x46, 0x07, 0x50, 0xb1, 0x25, 1785 0x3d, 0x8b, 0x08, 0x7e, 0x82, 0x4e, 0x79, 0xfd, 0x93, 0xc6, 0x55, 0x47, 0xd1, 0x18, 0xda, 0x8e, 1786 0xb9, 0x6c, 0xe7, 0xa7, 0xc6, 0x5f, 0xe6, 0xa0, 0xd4, 0x4d, 0x4f, 0x95, 0xd3, 0x09, 0x23, 0xfa, 1787 0x25, 0xb1, 0x63, 0xcb, 0xed, 0xa7, 0xfb, 0xd4, 0x53, 0x49, 0xa7, 0xcf, 0x37, 0x29, 0x1c, 0x90, 1788 0x6e, 0x92, 0x8f, 0xd1, 0x63, 0x28, 0xf7, 0x09, 0xb3, 0x23, 0x37, 0xe4, 0x27, 0xa3, 0xf6, 0x98, 1789 0x13, 0xa1, 0x63, 0xa8, 0xba, 0x41, 0x98, 0xc4, 0x56, 0x88, 0x23, 0xec, 0x93, 0x98, 0x44, 0xac, 1790 0x56, 0x7a, 0x3c, 0xb7, 0x5a, 0x5e, 0x7f, 0x7e, 0x35, 0x67, 0x45, 0xa9, 0xab, 0x6c, 0xcc, 0x15, 1791 0x01, 0x92, 0xcd, 0x19, 0xfa, 0x21, 0xdc, 0xa6, 0x49, 0x3c, 0x02, 0xac, 0xcf, 0x0e, 0x5c, 0x95, 1792 0x28, 0x39, 0xe4, 0x6d, 0x58, 0xe8, 0x53, 0xfb, 0x9c, 0x44, 0xb5, 0x79, 0xe1, 0xdb, 0xd5, 0xab, 1793 0xe1, 0x76, 0x84, 0x5e, 0xfb, 0x1d, 0xb1, 0x93, 0x98, 0x46, 0x7b, 0xb7, 0xcc, 0xd4, 0x12, 0x75, 1794 0x40, 0x8f, 0x08, 0xa3, 0x49, 0x64, 0x13, 0x56, 0x5b, 0x10, 0x30, 0x53, 0xb0, 0x32, 0x95, 0x89, 1795 0x39, 0xb0, 0x46, 0x8f, 0xa0, 0xac, 0xee, 0x1d, 0x3f, 0x96, 0x45, 0xe1, 0x62, 0x50, 0xa2, 0x4e, 1796 0x7f, 0x1b, 0xa0, 0x44, 0x52, 0x06, 0xc6, 0x0f, 0xe0, 0x6e, 0x2b, 0x22, 0x38, 0x26, 0x03, 0xc8, 1797 0x9f, 0x26, 0x84, 0xc5, 0xe8, 0x33, 0x28, 0x29, 0x93, 0x34, 0x64, 0x8c, 0x29, 0xf8, 0x64, 0x36, 1798 0xc6, 0x9f, 0x17, 0x44, 0x30, 0xaa, 0x95, 0xad, 0xc8, 0x61, 0x37, 0xc5, 0xcb, 0x5b, 0x58, 0x10, 1799 0x87, 0xc6, 0x6a, 0x05, 0x71, 0x2c, 0xaf, 0xae, 0xfe, 0xe0, 0x08, 0x72, 0xa3, 0x23, 0xec, 0xda, 1800 0x41, 0x1c, 0x5d, 0x9a, 0x29, 0x08, 0xea, 0xc2, 0xa2, 0x3c, 0x2a, 0x56, 0x9b, 0x13, 0x78, 0xdf, 1801 0x9e, 0x1e, 0xef, 0x50, 0x1a, 0x4a, 0x40, 0x05, 0x83, 0xbe, 0x0f, 0x2b, 0x8c, 0x44, 0x17, 0xae, 1802 0x4d, 0x2c, 0x6c, 0xdb, 0x34, 0x09, 0xe2, 0x5a, 0xf1, 0xa6, 0x13, 0xef, 0x49, 0x83, 0x2d, 0xa9, 1803 0x6f, 0x56, 0xd8, 0xd0, 0x1c, 0x3d, 0x00, 0xdd, 0xf6, 0x5c, 0x12, 0x08, 0x8f, 0xcc, 0x0b, 0x8f, 1804 0x94, 0xa4, 0xa0, 0xd3, 0xff, 0x6f, 0x06, 0xc5, 0x36, 0x2c, 0x7a, 0xd4, 0x71, 0xdc, 0xc0, 0x11, 1805 0x01, 0x71, 0x2d, 0xe5, 0x7d, 0xa9, 0x78, 0x28, 0xee, 0x23, 0x33, 0x95, 0x21, 0x3a, 0x81, 0x27, 1806 0xe7, 0x84, 0x84, 0xd6, 0x85, 0x6f, 0x61, 0xcf, 0xbd, 0x20, 0x16, 0x0d, 0xac, 0x53, 0xec, 0x7a, 1807 0x49, 0x44, 0x2c, 0x95, 0x6b, 0x6b, 0x25, 0x81, 0x7e, 0x5f, 0xa1, 0xab, 0x7c, 0xda, 0xd8, 0x49, 1808 0x15, 0xcc, 0x87, 0x1c, 0xe3, 0xd8, 0xdf, 0xe2, 0x08, 0x87, 0xc1, 0x1b, 0x69, 0xaf, 0x56, 0x79, 1809 0x0c, 0x78, 0xf8, 0x84, 0x78, 0xea, 0x6a, 0xce, 0x10, 0x03, 0xfb, 0xc2, 0x2e, 0x8d, 0x01, 0x09, 1810 0x52, 0x7f, 0x0d, 0xe5, 0x5c, 0x68, 0xa0, 0x2a, 0xcc, 0x9d, 0x93, 0xcb, 0x34, 0xf2, 0xf8, 0x10, 1811 0xdd, 0x81, 0xf9, 0x0b, 0xec, 0x25, 0x2a, 0x49, 0xc9, 0xc9, 0x66, 0x61, 0x43, 0xab, 0x6f, 0xc2, 1812 0x52, 0x3e, 0x0a, 0x66, 0xb2, 0x7d, 0x0d, 0xe5, 0x1c, 0x9b, 0x59, 0x4c, 0x8d, 0x7f, 0x6a, 0x80, 1813 0x72, 0x3b, 0x53, 0xd7, 0xf1, 0xc9, 0xf0, 0xa5, 0x16, 0x50, 0x7b, 0xb7, 0xf2, 0xd7, 0x1a, 0xf5, 1814 0x00, 0x91, 0xf0, 0x8c, 0xf8, 0x24, 0xc2, 0x9e, 0x95, 0xdd, 0xdd, 0xc2, 0xb4, 0x77, 0x77, 0xef, 1815 0x96, 0x79, 0x3b, 0xb3, 0xcf, 0x52, 0xfc, 0x01, 0x2c, 0x67, 0xdf, 0xc5, 0x91, 0xc3, 0x44, 0xc6, 1816 0x2e, 0xaf, 0x3f, 0x9b, 0xfa, 0x58, 0xcc, 0xa5, 0x30, 0x37, 0xe3, 0xb9, 0x27, 0x4b, 0x11, 0xaf, 1817 0x00, 0xed, 0x92, 0x78, 0x74, 0xa7, 0x8f, 0x26, 0xec, 0x34, 0xbf, 0x4f, 0xe3, 0xf7, 0x1a, 0xdc, 1818 0xd9, 0x77, 0x59, 0x66, 0xc8, 0x94, 0xe5, 0x0d, 0xe9, 0xe5, 0x11, 0x94, 0xf9, 0x13, 0x64, 0x85, 1819 0x11, 0x39, 0x75, 0xdf, 0xa5, 0x9e, 0x07, 0x2e, 0xea, 0x0a, 0x09, 0xbf, 0x8b, 0x21, 0x76, 0x88, 1820 0xc5, 0xdc, 0xf7, 0xf2, 0xf5, 0x9d, 0x37, 0x4b, 0x5c, 0xd0, 0x73, 0xdf, 0xcb, 0xb7, 0x8e, 0x2f, 1821 0xc6, 0xf4, 0x9c, 0x04, 0xe2, 0xda, 0x73, 0x70, 0xec, 0x90, 0x23, 0x2e, 0x30, 0x7e, 0xa9, 0xc1, 1822 0xdd, 0x11, 0x52, 0x2c, 0xa4, 0x01, 0x23, 0xe8, 0x73, 0xd0, 0xb3, 0x32, 0xa8, 0xa6, 0x89, 0xa0, 1823 0x9e, 0x26, 0x93, 0x0e, 0x8c, 0xd0, 0xc7, 0xb0, 0x12, 0x90, 0x77, 0xfc, 0xdd, 0xca, 0xbe, 0x2f, 1824 0xc9, 0x2f, 0x73, 0x71, 0x37, 0xe3, 0xb0, 0x01, 0x77, 0x77, 0x88, 0x47, 0xc6, 0x73, 0xf9, 0x8d, 1825 0x2e, 0xfd, 0x12, 0xea, 0xbb, 0x24, 0x6e, 0xd1, 0x20, 0x8e, 0xa8, 0xe7, 0x91, 0xa8, 0x45, 0x83, 1826 0x53, 0xd7, 0x19, 0xc4, 0xde, 0x52, 0x56, 0x6c, 0x0d, 0xec, 0xcb, 0x99, 0xac, 0xd3, 0x47, 0xcf, 1827 0xa0, 0x7a, 0x81, 0x3d, 0xb7, 0x2f, 0x75, 0x06, 0x1c, 0x8b, 0xe6, 0xca, 0x40, 0x2e, 0x59, 0xfe, 1828 0x6d, 0x01, 0xaa, 0xa3, 0x5f, 0xe2, 0xf7, 0xc1, 0xf5, 0xb1, 0xa3, 0x8a, 0x25, 0x39, 0xe1, 0xf7, 1829 0xc6, 0xf6, 0xfb, 0xe9, 0x66, 0xf9, 0x10, 0x3d, 0x86, 0x25, 0xc7, 0x66, 0x96, 0x47, 0x1d, 0x2b, 1830 0xc4, 0xf1, 0x59, 0x5a, 0x3f, 0x80, 0x63, 0xb3, 0x7d, 0xea, 0x74, 0x71, 0x7c, 0x36, 0x56, 0x45, 1831 0x15, 0xc7, 0xab, 0xa8, 0x3d, 0x28, 0x5e, 0xe0, 0x88, 0xd5, 0xe6, 0xc5, 0x61, 0x7c, 0x7a, 0x5d, 1832 0x25, 0x34, 0x4c, 0xb3, 0x71, 0x8c, 0xa3, 0x34, 0xc1, 0x08, 0x04, 0xf4, 0x3d, 0x98, 0xe7, 0xd5, 1833 0x17, 0x4f, 0xce, 0x37, 0x24, 0xab, 0x31, 0xa8, 0x1d, 0x6e, 0x27, 0xb1, 0x24, 0x06, 0xfa, 0x09, 1834 0x94, 0xf9, 0xde, 0x54, 0xbe, 0x5f, 0x14, 0x90, 0x9b, 0x33, 0x40, 0xee, 0xda, 0xac, 0x27, 0x8d, 1835 0x25, 0x2e, 0x77, 0x4b, 0x2a, 0x40, 0x5f, 0x80, 0x2e, 0xc0, 0xdd, 0xe0, 0x5c, 0x95, 0x53, 0x1b, 1836 0x33, 0x42, 0x73, 0x53, 0x09, 0x5c, 0x72, 0xd2, 0x69, 0x7d, 0x15, 0x2a, 0x26, 0x09, 0x79, 0xfd, 1837 0xd0, 0xef, 0xc5, 0x11, 0x7f, 0x24, 0x3e, 0x84, 0x05, 0x91, 0xcc, 0x64, 0xac, 0xeb, 0x66, 0x3a, 1838 0xab, 0x7f, 0x07, 0xf4, 0xcc, 0x7b, 0x33, 0xe5, 0xd2, 0x0d, 0x80, 0x81, 0xaf, 0x66, 0xb2, 0x7c, 1839 0x07, 0x2b, 0x23, 0x2e, 0x99, 0x60, 0x7e, 0x98, 0x37, 0x2f, 0xaf, 0xbf, 0x9e, 0xc1, 0x29, 0xc3, 1840 0x3b, 0xcf, 0x7f, 0xf9, 0x02, 0x96, 0x87, 0x3c, 0xf6, 0x3f, 0xfa, 0xae, 0xe1, 0x41, 0xe5, 0x48, 1841 0xf5, 0x2d, 0xed, 0x0b, 0x12, 0xc4, 0xa3, 0xf5, 0xb6, 0x36, 0x5e, 0x6f, 0x6f, 0x80, 0x9e, 0xf5, 1842 0x3a, 0x29, 0x99, 0xfa, 0xd8, 0xeb, 0x9d, 0xa1, 0x9a, 0x03, 0x65, 0xe3, 0xeb, 0x02, 0xdc, 0xef, 1843 0x91, 0xf8, 0x50, 0xe5, 0x81, 0x5e, 0x8c, 0xe3, 0x84, 0xcd, 0x90, 0x35, 0x7a, 0x50, 0xcd, 0xd0, 1844 0x2c, 0xc2, 0xf9, 0xaa, 0xd2, 0xef, 0x9a, 0xea, 0x64, 0x78, 0x83, 0xe6, 0x4a, 0x3c, 0x34, 0x67, 1845 0xa8, 0x09, 0x40, 0xa2, 0x88, 0x46, 0x16, 0xef, 0xd2, 0x44, 0x82, 0xa8, 0xac, 0x57, 0x15, 0x5c, 1846 0x14, 0xda, 0x8d, 0x16, 0xed, 0x13, 0x53, 0x17, 0x3a, 0x7c, 0xc8, 0x1b, 0x36, 0x69, 0xe0, 0x13, 1847 0xc6, 0x78, 0x0e, 0x92, 0x29, 0x63, 0x49, 0x08, 0xdf, 0x4a, 0xd9, 0xc4, 0x04, 0x37, 0x3f, 0x39, 1848 0xc1, 0x7d, 0x06, 0x95, 0xe1, 0xa2, 0x8f, 0x87, 0x28, 0xf1, 0xb1, 0xeb, 0xa9, 0xec, 0x26, 0x26, 1849 0xfc, 0xa6, 0x30, 0x9b, 0x86, 0x44, 0xee, 0x59, 0x37, 0xd3, 0x99, 0xf1, 0x1c, 0x2a, 0xc3, 0x15, 1850 0x18, 0xba, 0x0f, 0xfc, 0xc6, 0xc9, 0x8c, 0x27, 0x21, 0x16, 0x1d, 0x9b, 0xf1, 0x74, 0x67, 0xfc, 1851 0xbd, 0x08, 0xb7, 0xc7, 0x0a, 0x3f, 0xb4, 0x06, 0xb7, 0x7d, 0x37, 0x70, 0xfd, 0xc4, 0xb7, 0xec, 1852 0x30, 0xb1, 0x6c, 0x1a, 0x89, 0xfb, 0xc8, 0x5f, 0xb4, 0x95, 0x74, 0xa1, 0x15, 0x26, 0x2d, 0x2e, 1853 0xe6, 0x11, 0x12, 0x46, 0x84, 0xf7, 0xc2, 0xee, 0x89, 0x27, 0xc3, 0xb1, 0x64, 0xe6, 0x45, 0xe8, 1854 0xff, 0xa1, 0xa2, 0xd0, 0x22, 0xec, 0x5b, 0xce, 0x89, 0xf0, 0xaa, 0x66, 0x2e, 0xa5, 0x52, 0x13, 1855 0xfb, 0xbb, 0x27, 0xe8, 0x8d, 0xca, 0x85, 0x45, 0x71, 0x82, 0xdf, 0x9a, 0xa1, 0x50, 0x15, 0xc9, 1856 0x50, 0xa5, 0xc1, 0x3b, 0x30, 0xcf, 0xdb, 0x61, 0x99, 0x9e, 0x75, 0x53, 0x4e, 0xd0, 0x33, 0xb8, 1857 0x7d, 0x42, 0x69, 0x6c, 0x89, 0xf6, 0x97, 0x3f, 0xd0, 0x9c, 0xc6, 0x82, 0xd8, 0x51, 0x85, 0x2f, 1858 0x70, 0x04, 0xfe, 0x4e, 0xef, 0x9e, 0xf0, 0x97, 0x3a, 0xa0, 0x16, 0xee, 0xf7, 0x23, 0xc2, 0x98, 1859 0xa8, 0x76, 0x4b, 0xa6, 0x1e, 0xd0, 0x2d, 0x29, 0xa8, 0xff, 0xa9, 0x00, 0x45, 0xae, 0x9d, 0xb5, 1860 0xa7, 0x5a, 0xae, 0x3d, 0xed, 0x40, 0x51, 0xbc, 0x1a, 0x05, 0x11, 0x36, 0xaf, 0x66, 0xdd, 0x43, 1861 0x83, 0xbf, 0x2f, 0xa6, 0x80, 0x40, 0xf7, 0x60, 0x51, 0xf1, 0x94, 0xb5, 0xc4, 0x02, 0x93, 0xfc, 1862 0xf8, 0xb9, 0x0b, 0x9b, 0x34, 0xd0, 0xd2, 0x19, 0x7f, 0xa5, 0x71, 0x12, 0x53, 0xab, 0x2f, 0xde, 1863 0x70, 0xb1, 0xb9, 0x92, 0x09, 0x5c, 0x24, 0x5f, 0x75, 0xae, 0xe0, 0xf3, 0x78, 0xb2, 0x42, 0xea, 1864 0x06, 0xb1, 0xa8, 0xb4, 0x75, 0x13, 0x84, 0xa8, 0xcb, 0x25, 0x46, 0x0f, 0x8a, 0xe2, 0x81, 0xbb, 1865 0x03, 0xd5, 0xa3, 0x1f, 0x75, 0xdb, 0xd6, 0x17, 0x07, 0xbd, 0x6e, 0xbb, 0xd5, 0x79, 0xd3, 0x69, 1866 0xef, 0x54, 0x6f, 0x21, 0x04, 0x95, 0x6e, 0xdb, 0xec, 0x75, 0x7a, 0x47, 0xed, 0x83, 0x23, 0x6b, 1867 0x6f, 0x67, 0xa7, 0xaa, 0x8d, 0xc8, 0x7a, 0xbd, 0x9d, 0x6a, 0x01, 0x2d, 0x83, 0xbe, 0x7f, 0xd8, 1868 0xda, 0xda, 0x17, 0xd3, 0x39, 0xe3, 0xdf, 0xda, 0x20, 0xc2, 0xb2, 0xa6, 0x77, 0xa2, 0xf3, 0x46, 1869 0x72, 0x4d, 0x61, 0x3c, 0xd7, 0x3c, 0x85, 0xe5, 0x3e, 0x39, 0xc5, 0x89, 0x17, 0x5b, 0x32, 0xf9, 1870 0xc9, 0x8e, 0x67, 0x29, 0x15, 0x1e, 0x73, 0x19, 0x3a, 0x02, 0xf0, 0xa8, 0x8d, 0x3d, 0xcb, 0xa6, 1871 0xe1, 0x65, 0xda, 0xf6, 0xbc, 0x9a, 0xa1, 0x43, 0x6f, 0xec, 0x73, 0xeb, 0x16, 0x0d, 0x2f, 0x4d, 1872 0xdd, 0x53, 0xc3, 0xfa, 0x4b, 0xd0, 0x33, 0x39, 0x67, 0x9f, 0xbb, 0x4c, 0x62, 0xcc, 0x65, 0x3c, 1873 0xb8, 0xd4, 0xdf, 0x0a, 0x3e, 0x36, 0xb6, 0xa0, 0x32, 0xdc, 0xb1, 0xf3, 0xe0, 0x12, 0xb5, 0x49, 1874 0xfe, 0xd7, 0x8e, 0x2e, 0x24, 0xe2, 0xbf, 0xce, 0x58, 0xc5, 0xb2, 0xfe, 0x9b, 0xd2, 0xc0, 0x7d, 1875 0xec, 0xf8, 0xc5, 0x96, 0x20, 0x8d, 0x7e, 0xab, 0x41, 0x65, 0xb8, 0xef, 0x46, 0xcd, 0x6b, 0x5e, 1876 0x80, 0x49, 0x1d, 0x7a, 0x7d, 0x8a, 0x2a, 0xd2, 0xf8, 0xc6, 0xaf, 0xfe, 0xfa, 0x8f, 0x3f, 0x14, 1877 0x1e, 0x19, 0x1f, 0x4c, 0xf8, 0x27, 0xb7, 0x99, 0x55, 0xe2, 0xe8, 0x17, 0x50, 0xce, 0x95, 0xed, 1878 0xe8, 0x9b, 0x53, 0x55, 0xf7, 0x8a, 0xc7, 0x47, 0x4a, 0x3b, 0xf7, 0x77, 0xae, 0x91, 0x3d, 0x0a, 1879 0x86, 0x21, 0x28, 0x3c, 0x34, 0xee, 0x4d, 0xa2, 0x10, 0x25, 0xc1, 0xa6, 0xb6, 0x86, 0xbe, 0xd2, 1880 0xa0, 0x9c, 0x6b, 0x05, 0xae, 0x23, 0x30, 0xde, 0x31, 0x4c, 0xe5, 0x88, 0x67, 0x82, 0xc5, 0x53, 1881 0xf4, 0x64, 0x02, 0x8b, 0xe6, 0xcf, 0x72, 0xd5, 0xf1, 0xcf, 0xd1, 0xef, 0x34, 0x58, 0x1e, 0x2a, 1882 0xe5, 0x51, 0xe3, 0x9a, 0x5e, 0x79, 0x42, 0x23, 0x52, 0x6f, 0x4e, 0xad, 0x2f, 0x7b, 0x04, 0xe3, 1883 0x81, 0x60, 0x77, 0x17, 0x4d, 0x3a, 0x26, 0xf4, 0x6b, 0x0d, 0x2a, 0xc3, 0x75, 0xfd, 0x75, 0xb1, 1884 0x32, 0xb1, 0x03, 0xa8, 0x7f, 0x38, 0xf6, 0xa2, 0xb7, 0xfd, 0x30, 0xbe, 0x54, 0x6e, 0x59, 0x9b, 1885 0xc2, 0x2d, 0x7f, 0xd4, 0xe0, 0x83, 0x09, 0x4d, 0x02, 0xfa, 0xf4, 0xda, 0xb3, 0xba, 0xa2, 0xa7, 1886 0xa8, 0xaf, 0x4d, 0x5f, 0xef, 0x18, 0x4d, 0x41, 0xf2, 0x19, 0xfa, 0x64, 0x52, 0x04, 0x39, 0x13, 1887 0x28, 0x7d, 0xad, 0x01, 0x1a, 0x2f, 0x4c, 0xd0, 0xcb, 0xeb, 0xfe, 0xd2, 0x5c, 0x51, 0xc6, 0x5c, 1888 0xe9, 0xb9, 0x17, 0x82, 0xd4, 0xf3, 0xfa, 0xc7, 0x93, 0x48, 0xb1, 0x31, 0xb8, 0x4d, 0x6d, 0x6d, 1889 0x3b, 0x84, 0x7b, 0x36, 0xf5, 0x27, 0x91, 0xd8, 0xae, 0x64, 0x31, 0xd1, 0xe5, 0x9f, 0xe9, 0x6a, 1890 0x3f, 0xfe, 0x5c, 0xa9, 0x51, 0x0f, 0x07, 0x4e, 0x83, 0x46, 0x4e, 0xd3, 0x21, 0x81, 0x20, 0xd1, 1891 0x94, 0x4b, 0x38, 0x74, 0xd9, 0xf8, 0x3f, 0xf7, 0xef, 0x2a, 0xc9, 0xbf, 0x34, 0xed, 0x64, 0x41, 1892 0xe8, 0xbf, 0xfc, 0x4f, 0x00, 0x00, 0x00, 0xff, 0xff, 0x13, 0x10, 0x96, 0x1d, 0xa2, 0x17, 0x00, 1893 0x00, 1894} 1895 1896// Reference imports to suppress errors if they are not otherwise used. 1897var _ context.Context 1898var _ grpc.ClientConn 1899 1900// This is a compile-time assertion to ensure that this generated file 1901// is compatible with the grpc package it is being compiled against. 1902const _ = grpc.SupportPackageIsVersion4 1903 1904// PipelinesV1Alpha2Client is the client API for PipelinesV1Alpha2 service. 1905// 1906// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1907type PipelinesV1Alpha2Client interface { 1908 // Creates a pipeline that can be run later. Create takes a Pipeline that 1909 // has all fields other than `pipelineId` populated, and then returns 1910 // the same pipeline with `pipelineId` populated. This id can be used 1911 // to run the pipeline. 1912 // 1913 // Caller must have WRITE permission to the project. 1914 CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*Pipeline, error) 1915 // Runs a pipeline. If `pipelineId` is specified in the request, then 1916 // run a saved pipeline. If `ephemeralPipeline` is specified, then run 1917 // that pipeline once without saving a copy. 1918 // 1919 // The caller must have READ permission to the project where the pipeline 1920 // is stored and WRITE permission to the project where the pipeline will be 1921 // run, as VMs will be created and storage will be used. 1922 RunPipeline(ctx context.Context, in *RunPipelineRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 1923 // Retrieves a pipeline based on ID. 1924 // 1925 // Caller must have READ permission to the project. 1926 GetPipeline(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*Pipeline, error) 1927 // Lists pipelines. 1928 // 1929 // Caller must have READ permission to the project. 1930 ListPipelines(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*ListPipelinesResponse, error) 1931 // Deletes a pipeline based on ID. 1932 // 1933 // Caller must have WRITE permission to the project. 1934 DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*empty.Empty, error) 1935 // Gets controller configuration information. Should only be called 1936 // by VMs created by the Pipelines Service and not by end users. 1937 GetControllerConfig(ctx context.Context, in *GetControllerConfigRequest, opts ...grpc.CallOption) (*ControllerConfig, error) 1938 // Sets status of a given operation. Any new timestamps (as determined by 1939 // description) are appended to TimestampEvents. Should only be called by VMs 1940 // created by the Pipelines Service and not by end users. 1941 SetOperationStatus(ctx context.Context, in *SetOperationStatusRequest, opts ...grpc.CallOption) (*empty.Empty, error) 1942} 1943 1944type pipelinesV1Alpha2Client struct { 1945 cc *grpc.ClientConn 1946} 1947 1948func NewPipelinesV1Alpha2Client(cc *grpc.ClientConn) PipelinesV1Alpha2Client { 1949 return &pipelinesV1Alpha2Client{cc} 1950} 1951 1952func (c *pipelinesV1Alpha2Client) CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*Pipeline, error) { 1953 out := new(Pipeline) 1954 err := c.cc.Invoke(ctx, "/google.genomics.v1alpha2.PipelinesV1Alpha2/CreatePipeline", in, out, opts...) 1955 if err != nil { 1956 return nil, err 1957 } 1958 return out, nil 1959} 1960 1961func (c *pipelinesV1Alpha2Client) RunPipeline(ctx context.Context, in *RunPipelineRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 1962 out := new(longrunning.Operation) 1963 err := c.cc.Invoke(ctx, "/google.genomics.v1alpha2.PipelinesV1Alpha2/RunPipeline", in, out, opts...) 1964 if err != nil { 1965 return nil, err 1966 } 1967 return out, nil 1968} 1969 1970func (c *pipelinesV1Alpha2Client) GetPipeline(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*Pipeline, error) { 1971 out := new(Pipeline) 1972 err := c.cc.Invoke(ctx, "/google.genomics.v1alpha2.PipelinesV1Alpha2/GetPipeline", in, out, opts...) 1973 if err != nil { 1974 return nil, err 1975 } 1976 return out, nil 1977} 1978 1979func (c *pipelinesV1Alpha2Client) ListPipelines(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*ListPipelinesResponse, error) { 1980 out := new(ListPipelinesResponse) 1981 err := c.cc.Invoke(ctx, "/google.genomics.v1alpha2.PipelinesV1Alpha2/ListPipelines", in, out, opts...) 1982 if err != nil { 1983 return nil, err 1984 } 1985 return out, nil 1986} 1987 1988func (c *pipelinesV1Alpha2Client) DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 1989 out := new(empty.Empty) 1990 err := c.cc.Invoke(ctx, "/google.genomics.v1alpha2.PipelinesV1Alpha2/DeletePipeline", in, out, opts...) 1991 if err != nil { 1992 return nil, err 1993 } 1994 return out, nil 1995} 1996 1997func (c *pipelinesV1Alpha2Client) GetControllerConfig(ctx context.Context, in *GetControllerConfigRequest, opts ...grpc.CallOption) (*ControllerConfig, error) { 1998 out := new(ControllerConfig) 1999 err := c.cc.Invoke(ctx, "/google.genomics.v1alpha2.PipelinesV1Alpha2/GetControllerConfig", in, out, opts...) 2000 if err != nil { 2001 return nil, err 2002 } 2003 return out, nil 2004} 2005 2006func (c *pipelinesV1Alpha2Client) SetOperationStatus(ctx context.Context, in *SetOperationStatusRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 2007 out := new(empty.Empty) 2008 err := c.cc.Invoke(ctx, "/google.genomics.v1alpha2.PipelinesV1Alpha2/SetOperationStatus", in, out, opts...) 2009 if err != nil { 2010 return nil, err 2011 } 2012 return out, nil 2013} 2014 2015// PipelinesV1Alpha2Server is the server API for PipelinesV1Alpha2 service. 2016type PipelinesV1Alpha2Server interface { 2017 // Creates a pipeline that can be run later. Create takes a Pipeline that 2018 // has all fields other than `pipelineId` populated, and then returns 2019 // the same pipeline with `pipelineId` populated. This id can be used 2020 // to run the pipeline. 2021 // 2022 // Caller must have WRITE permission to the project. 2023 CreatePipeline(context.Context, *CreatePipelineRequest) (*Pipeline, error) 2024 // Runs a pipeline. If `pipelineId` is specified in the request, then 2025 // run a saved pipeline. If `ephemeralPipeline` is specified, then run 2026 // that pipeline once without saving a copy. 2027 // 2028 // The caller must have READ permission to the project where the pipeline 2029 // is stored and WRITE permission to the project where the pipeline will be 2030 // run, as VMs will be created and storage will be used. 2031 RunPipeline(context.Context, *RunPipelineRequest) (*longrunning.Operation, error) 2032 // Retrieves a pipeline based on ID. 2033 // 2034 // Caller must have READ permission to the project. 2035 GetPipeline(context.Context, *GetPipelineRequest) (*Pipeline, error) 2036 // Lists pipelines. 2037 // 2038 // Caller must have READ permission to the project. 2039 ListPipelines(context.Context, *ListPipelinesRequest) (*ListPipelinesResponse, error) 2040 // Deletes a pipeline based on ID. 2041 // 2042 // Caller must have WRITE permission to the project. 2043 DeletePipeline(context.Context, *DeletePipelineRequest) (*empty.Empty, error) 2044 // Gets controller configuration information. Should only be called 2045 // by VMs created by the Pipelines Service and not by end users. 2046 GetControllerConfig(context.Context, *GetControllerConfigRequest) (*ControllerConfig, error) 2047 // Sets status of a given operation. Any new timestamps (as determined by 2048 // description) are appended to TimestampEvents. Should only be called by VMs 2049 // created by the Pipelines Service and not by end users. 2050 SetOperationStatus(context.Context, *SetOperationStatusRequest) (*empty.Empty, error) 2051} 2052 2053func RegisterPipelinesV1Alpha2Server(s *grpc.Server, srv PipelinesV1Alpha2Server) { 2054 s.RegisterService(&_PipelinesV1Alpha2_serviceDesc, srv) 2055} 2056 2057func _PipelinesV1Alpha2_CreatePipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2058 in := new(CreatePipelineRequest) 2059 if err := dec(in); err != nil { 2060 return nil, err 2061 } 2062 if interceptor == nil { 2063 return srv.(PipelinesV1Alpha2Server).CreatePipeline(ctx, in) 2064 } 2065 info := &grpc.UnaryServerInfo{ 2066 Server: srv, 2067 FullMethod: "/google.genomics.v1alpha2.PipelinesV1Alpha2/CreatePipeline", 2068 } 2069 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2070 return srv.(PipelinesV1Alpha2Server).CreatePipeline(ctx, req.(*CreatePipelineRequest)) 2071 } 2072 return interceptor(ctx, in, info, handler) 2073} 2074 2075func _PipelinesV1Alpha2_RunPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2076 in := new(RunPipelineRequest) 2077 if err := dec(in); err != nil { 2078 return nil, err 2079 } 2080 if interceptor == nil { 2081 return srv.(PipelinesV1Alpha2Server).RunPipeline(ctx, in) 2082 } 2083 info := &grpc.UnaryServerInfo{ 2084 Server: srv, 2085 FullMethod: "/google.genomics.v1alpha2.PipelinesV1Alpha2/RunPipeline", 2086 } 2087 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2088 return srv.(PipelinesV1Alpha2Server).RunPipeline(ctx, req.(*RunPipelineRequest)) 2089 } 2090 return interceptor(ctx, in, info, handler) 2091} 2092 2093func _PipelinesV1Alpha2_GetPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2094 in := new(GetPipelineRequest) 2095 if err := dec(in); err != nil { 2096 return nil, err 2097 } 2098 if interceptor == nil { 2099 return srv.(PipelinesV1Alpha2Server).GetPipeline(ctx, in) 2100 } 2101 info := &grpc.UnaryServerInfo{ 2102 Server: srv, 2103 FullMethod: "/google.genomics.v1alpha2.PipelinesV1Alpha2/GetPipeline", 2104 } 2105 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2106 return srv.(PipelinesV1Alpha2Server).GetPipeline(ctx, req.(*GetPipelineRequest)) 2107 } 2108 return interceptor(ctx, in, info, handler) 2109} 2110 2111func _PipelinesV1Alpha2_ListPipelines_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2112 in := new(ListPipelinesRequest) 2113 if err := dec(in); err != nil { 2114 return nil, err 2115 } 2116 if interceptor == nil { 2117 return srv.(PipelinesV1Alpha2Server).ListPipelines(ctx, in) 2118 } 2119 info := &grpc.UnaryServerInfo{ 2120 Server: srv, 2121 FullMethod: "/google.genomics.v1alpha2.PipelinesV1Alpha2/ListPipelines", 2122 } 2123 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2124 return srv.(PipelinesV1Alpha2Server).ListPipelines(ctx, req.(*ListPipelinesRequest)) 2125 } 2126 return interceptor(ctx, in, info, handler) 2127} 2128 2129func _PipelinesV1Alpha2_DeletePipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2130 in := new(DeletePipelineRequest) 2131 if err := dec(in); err != nil { 2132 return nil, err 2133 } 2134 if interceptor == nil { 2135 return srv.(PipelinesV1Alpha2Server).DeletePipeline(ctx, in) 2136 } 2137 info := &grpc.UnaryServerInfo{ 2138 Server: srv, 2139 FullMethod: "/google.genomics.v1alpha2.PipelinesV1Alpha2/DeletePipeline", 2140 } 2141 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2142 return srv.(PipelinesV1Alpha2Server).DeletePipeline(ctx, req.(*DeletePipelineRequest)) 2143 } 2144 return interceptor(ctx, in, info, handler) 2145} 2146 2147func _PipelinesV1Alpha2_GetControllerConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2148 in := new(GetControllerConfigRequest) 2149 if err := dec(in); err != nil { 2150 return nil, err 2151 } 2152 if interceptor == nil { 2153 return srv.(PipelinesV1Alpha2Server).GetControllerConfig(ctx, in) 2154 } 2155 info := &grpc.UnaryServerInfo{ 2156 Server: srv, 2157 FullMethod: "/google.genomics.v1alpha2.PipelinesV1Alpha2/GetControllerConfig", 2158 } 2159 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2160 return srv.(PipelinesV1Alpha2Server).GetControllerConfig(ctx, req.(*GetControllerConfigRequest)) 2161 } 2162 return interceptor(ctx, in, info, handler) 2163} 2164 2165func _PipelinesV1Alpha2_SetOperationStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2166 in := new(SetOperationStatusRequest) 2167 if err := dec(in); err != nil { 2168 return nil, err 2169 } 2170 if interceptor == nil { 2171 return srv.(PipelinesV1Alpha2Server).SetOperationStatus(ctx, in) 2172 } 2173 info := &grpc.UnaryServerInfo{ 2174 Server: srv, 2175 FullMethod: "/google.genomics.v1alpha2.PipelinesV1Alpha2/SetOperationStatus", 2176 } 2177 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2178 return srv.(PipelinesV1Alpha2Server).SetOperationStatus(ctx, req.(*SetOperationStatusRequest)) 2179 } 2180 return interceptor(ctx, in, info, handler) 2181} 2182 2183var _PipelinesV1Alpha2_serviceDesc = grpc.ServiceDesc{ 2184 ServiceName: "google.genomics.v1alpha2.PipelinesV1Alpha2", 2185 HandlerType: (*PipelinesV1Alpha2Server)(nil), 2186 Methods: []grpc.MethodDesc{ 2187 { 2188 MethodName: "CreatePipeline", 2189 Handler: _PipelinesV1Alpha2_CreatePipeline_Handler, 2190 }, 2191 { 2192 MethodName: "RunPipeline", 2193 Handler: _PipelinesV1Alpha2_RunPipeline_Handler, 2194 }, 2195 { 2196 MethodName: "GetPipeline", 2197 Handler: _PipelinesV1Alpha2_GetPipeline_Handler, 2198 }, 2199 { 2200 MethodName: "ListPipelines", 2201 Handler: _PipelinesV1Alpha2_ListPipelines_Handler, 2202 }, 2203 { 2204 MethodName: "DeletePipeline", 2205 Handler: _PipelinesV1Alpha2_DeletePipeline_Handler, 2206 }, 2207 { 2208 MethodName: "GetControllerConfig", 2209 Handler: _PipelinesV1Alpha2_GetControllerConfig_Handler, 2210 }, 2211 { 2212 MethodName: "SetOperationStatus", 2213 Handler: _PipelinesV1Alpha2_SetOperationStatus_Handler, 2214 }, 2215 }, 2216 Streams: []grpc.StreamDesc{}, 2217 Metadata: "google/genomics/v1alpha2/pipelines.proto", 2218} 2219