vendor/google.golang.org/genproto/googleapis/genomics/v1alpha2/pipelines.pb.go

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