// Copyright 2025 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.26.0
// protoc v4.24.4
// source: google/genomics/v1alpha2/pipelines.proto
package genomics
import (
context "context"
reflect "reflect"
sync "sync"
longrunningpb "cloud.google.com/go/longrunning/autogen/longrunningpb"
_ "google.golang.org/genproto/googleapis/api/annotations"
code "google.golang.org/genproto/googleapis/rpc/code"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
durationpb "google.golang.org/protobuf/types/known/durationpb"
emptypb "google.golang.org/protobuf/types/known/emptypb"
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
)
const (
// Verify that this generated code is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
// Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
// The types of disks that may be attached to VMs.
type PipelineResources_Disk_Type int32
const (
// Default disk type. Use one of the other options below.
PipelineResources_Disk_TYPE_UNSPECIFIED PipelineResources_Disk_Type = 0
// Specifies a Google Compute Engine persistent hard disk. See
// https://cloud.google.com/compute/docs/disks/#pdspecs for details.
PipelineResources_Disk_PERSISTENT_HDD PipelineResources_Disk_Type = 1
// Specifies a Google Compute Engine persistent solid-state disk. See
// https://cloud.google.com/compute/docs/disks/#pdspecs for details.
PipelineResources_Disk_PERSISTENT_SSD PipelineResources_Disk_Type = 2
// Specifies a Google Compute Engine local SSD.
// See https://cloud.google.com/compute/docs/disks/local-ssd for details.
PipelineResources_Disk_LOCAL_SSD PipelineResources_Disk_Type = 3
)
// Enum value maps for PipelineResources_Disk_Type.
var (
PipelineResources_Disk_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "PERSISTENT_HDD",
2: "PERSISTENT_SSD",
3: "LOCAL_SSD",
}
PipelineResources_Disk_Type_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"PERSISTENT_HDD": 1,
"PERSISTENT_SSD": 2,
"LOCAL_SSD": 3,
}
)
func (x PipelineResources_Disk_Type) Enum() *PipelineResources_Disk_Type {
p := new(PipelineResources_Disk_Type)
*p = x
return p
}
func (x PipelineResources_Disk_Type) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (PipelineResources_Disk_Type) Descriptor() protoreflect.EnumDescriptor {
return file_google_genomics_v1alpha2_pipelines_proto_enumTypes[0].Descriptor()
}
func (PipelineResources_Disk_Type) Type() protoreflect.EnumType {
return &file_google_genomics_v1alpha2_pipelines_proto_enumTypes[0]
}
func (x PipelineResources_Disk_Type) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use PipelineResources_Disk_Type.Descriptor instead.
func (PipelineResources_Disk_Type) EnumDescriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{16, 0, 0}
}
// Describes a Compute Engine resource that is being managed by a running
// [pipeline][google.genomics.v1alpha2.Pipeline].
type ComputeEngine struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// The instance on which the operation is running.
InstanceName string `protobuf:"bytes,1,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
// The availability zone in which the instance resides.
Zone string `protobuf:"bytes,2,opt,name=zone,proto3" json:"zone,omitempty"`
// The machine type of the instance.
MachineType string `protobuf:"bytes,3,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
// The names of the disks that were created for this pipeline.
DiskNames []string `protobuf:"bytes,4,rep,name=disk_names,json=diskNames,proto3" json:"disk_names,omitempty"`
}
func (x *ComputeEngine) Reset() {
*x = ComputeEngine{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *ComputeEngine) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ComputeEngine) ProtoMessage() {}
func (x *ComputeEngine) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[0]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ComputeEngine.ProtoReflect.Descriptor instead.
func (*ComputeEngine) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{0}
}
func (x *ComputeEngine) GetInstanceName() string {
if x != nil {
return x.InstanceName
}
return ""
}
func (x *ComputeEngine) GetZone() string {
if x != nil {
return x.Zone
}
return ""
}
func (x *ComputeEngine) GetMachineType() string {
if x != nil {
return x.MachineType
}
return ""
}
func (x *ComputeEngine) GetDiskNames() []string {
if x != nil {
return x.DiskNames
}
return nil
}
// Runtime metadata that will be populated in the
// [runtimeMetadata][google.genomics.v1.OperationMetadata.runtime_metadata]
// field of the Operation associated with a RunPipeline execution.
type RuntimeMetadata struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Execution information specific to Google Compute Engine.
ComputeEngine *ComputeEngine `protobuf:"bytes,1,opt,name=compute_engine,json=computeEngine,proto3" json:"compute_engine,omitempty"`
}
func (x *RuntimeMetadata) Reset() {
*x = RuntimeMetadata{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *RuntimeMetadata) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*RuntimeMetadata) ProtoMessage() {}
func (x *RuntimeMetadata) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[1]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use RuntimeMetadata.ProtoReflect.Descriptor instead.
func (*RuntimeMetadata) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{1}
}
func (x *RuntimeMetadata) GetComputeEngine() *ComputeEngine {
if x != nil {
return x.ComputeEngine
}
return nil
}
// The pipeline object. Represents a transformation from a set of input
// parameters to a set of output parameters. The transformation is defined
// as a docker image and command to run within that image. Each pipeline
// is run on a Google Compute Engine VM. A pipeline can be created with the
// `create` method and then later run with the `run` method, or a pipeline can
// be defined and run all at once with the `run` method.
type Pipeline struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Required. The project in which to create the pipeline. The caller must have
// WRITE access.
ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
// Required. A user specified pipeline name that does not have to be unique.
// This name can be used for filtering Pipelines in ListPipelines.
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// User-specified description.
Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
// Input parameters of the pipeline.
InputParameters []*PipelineParameter `protobuf:"bytes,8,rep,name=input_parameters,json=inputParameters,proto3" json:"input_parameters,omitempty"`
// Output parameters of the pipeline.
OutputParameters []*PipelineParameter `protobuf:"bytes,9,rep,name=output_parameters,json=outputParameters,proto3" json:"output_parameters,omitempty"`
// Required. The executor indicates in which environment the pipeline runs.
//
// Types that are assignable to Executor:
//
// *Pipeline_Docker
Executor isPipeline_Executor `protobuf_oneof:"executor"`
// Required. Specifies resource requirements for the pipeline run.
// Required fields:
//
// *
// [minimumCpuCores][google.genomics.v1alpha2.PipelineResources.minimum_cpu_cores]
//
// *
// [minimumRamGb][google.genomics.v1alpha2.PipelineResources.minimum_ram_gb]
Resources *PipelineResources `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"`
// Unique pipeline id that is generated by the service when CreatePipeline
// is called. Cannot be specified in the Pipeline used in the
// CreatePipelineRequest, and will be populated in the response to
// CreatePipeline and all subsequent Get and List calls. Indicates that the
// service has registered this pipeline.
PipelineId string `protobuf:"bytes,7,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
}
func (x *Pipeline) Reset() {
*x = Pipeline{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *Pipeline) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Pipeline) ProtoMessage() {}
func (x *Pipeline) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[2]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Pipeline.ProtoReflect.Descriptor instead.
func (*Pipeline) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{2}
}
func (x *Pipeline) GetProjectId() string {
if x != nil {
return x.ProjectId
}
return ""
}
func (x *Pipeline) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *Pipeline) GetDescription() string {
if x != nil {
return x.Description
}
return ""
}
func (x *Pipeline) GetInputParameters() []*PipelineParameter {
if x != nil {
return x.InputParameters
}
return nil
}
func (x *Pipeline) GetOutputParameters() []*PipelineParameter {
if x != nil {
return x.OutputParameters
}
return nil
}
func (m *Pipeline) GetExecutor() isPipeline_Executor {
if m != nil {
return m.Executor
}
return nil
}
func (x *Pipeline) GetDocker() *DockerExecutor {
if x, ok := x.GetExecutor().(*Pipeline_Docker); ok {
return x.Docker
}
return nil
}
func (x *Pipeline) GetResources() *PipelineResources {
if x != nil {
return x.Resources
}
return nil
}
func (x *Pipeline) GetPipelineId() string {
if x != nil {
return x.PipelineId
}
return ""
}
type isPipeline_Executor interface {
isPipeline_Executor()
}
type Pipeline_Docker struct {
// Specifies the docker run information.
Docker *DockerExecutor `protobuf:"bytes,5,opt,name=docker,proto3,oneof"`
}
func (*Pipeline_Docker) isPipeline_Executor() {}
// The request to create a pipeline. The pipeline field here should not have
// `pipelineId` populated, as that will be populated by the server.
type CreatePipelineRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// The pipeline to create. Should not have `pipelineId` populated.
Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
}
func (x *CreatePipelineRequest) Reset() {
*x = CreatePipelineRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CreatePipelineRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreatePipelineRequest) ProtoMessage() {}
func (x *CreatePipelineRequest) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[3]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CreatePipelineRequest.ProtoReflect.Descriptor instead.
func (*CreatePipelineRequest) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{3}
}
func (x *CreatePipelineRequest) GetPipeline() *Pipeline {
if x != nil {
return x.Pipeline
}
return nil
}
// The pipeline run arguments.
type RunPipelineArgs struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Required. The project in which to run the pipeline. The caller must have
// WRITER access to all Google Cloud services and resources (e.g. Google
// Compute Engine) will be used.
ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
// Pipeline input arguments; keys are defined in the pipeline documentation.
// All input parameters that do not have default values must be specified.
// If parameters with defaults are specified here, the defaults will be
// overridden.
Inputs map[string]string `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// Pipeline output arguments; keys are defined in the pipeline
// documentation. All output parameters of without default values
// must be specified. If parameters with defaults are specified
// here, the defaults will be overridden.
Outputs map[string]string `protobuf:"bytes,3,rep,name=outputs,proto3" json:"outputs,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// The Google Cloud Service Account that will be used to access data and
// services. By default, the compute service account associated with
// `projectId` is used.
ServiceAccount *ServiceAccount `protobuf:"bytes,4,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
// This field is deprecated. Use `labels` instead. Client-specified pipeline
// operation identifier.
ClientId string `protobuf:"bytes,5,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
// Specifies resource requirements/overrides for the pipeline run.
Resources *PipelineResources `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"`
// Required. Logging options. Used by the service to communicate results
// to the user.
Logging *LoggingOptions `protobuf:"bytes,7,opt,name=logging,proto3" json:"logging,omitempty"`
// How long to keep the VM up after a failure (for example docker command
// failed, copying input or output files failed, etc). While the VM is up, one
// can ssh into the VM to debug. Default is 0; maximum allowed value is 1 day.
KeepVmAliveOnFailureDuration *durationpb.Duration `protobuf:"bytes,8,opt,name=keep_vm_alive_on_failure_duration,json=keepVmAliveOnFailureDuration,proto3" json:"keep_vm_alive_on_failure_duration,omitempty"`
// Labels to apply to this pipeline run. Labels will also be applied to
// compute resources (VM, disks) created by this pipeline run. When listing
// operations, operations can [filtered by labels]
// [google.longrunning.ListOperationsRequest.filter].
// Label keys may not be empty; label values may be empty. Non-empty labels
// must be 1-63 characters long, and comply with [RFC1035]
// (https://www.ietf.org/rfc/rfc1035.txt).
// Specifically, the name must be 1-63 characters long and match the regular
// expression `[a-z]([-a-z0-9]*[a-z0-9])?` which means the first
// character must be a lowercase letter, and all following characters must be
// a dash, lowercase letter, or digit, except the last character, which cannot
// be a dash.
Labels map[string]string `protobuf:"bytes,9,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
}
func (x *RunPipelineArgs) Reset() {
*x = RunPipelineArgs{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *RunPipelineArgs) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*RunPipelineArgs) ProtoMessage() {}
func (x *RunPipelineArgs) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[4]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use RunPipelineArgs.ProtoReflect.Descriptor instead.
func (*RunPipelineArgs) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{4}
}
func (x *RunPipelineArgs) GetProjectId() string {
if x != nil {
return x.ProjectId
}
return ""
}
func (x *RunPipelineArgs) GetInputs() map[string]string {
if x != nil {
return x.Inputs
}
return nil
}
func (x *RunPipelineArgs) GetOutputs() map[string]string {
if x != nil {
return x.Outputs
}
return nil
}
func (x *RunPipelineArgs) GetServiceAccount() *ServiceAccount {
if x != nil {
return x.ServiceAccount
}
return nil
}
func (x *RunPipelineArgs) GetClientId() string {
if x != nil {
return x.ClientId
}
return ""
}
func (x *RunPipelineArgs) GetResources() *PipelineResources {
if x != nil {
return x.Resources
}
return nil
}
func (x *RunPipelineArgs) GetLogging() *LoggingOptions {
if x != nil {
return x.Logging
}
return nil
}
func (x *RunPipelineArgs) GetKeepVmAliveOnFailureDuration() *durationpb.Duration {
if x != nil {
return x.KeepVmAliveOnFailureDuration
}
return nil
}
func (x *RunPipelineArgs) GetLabels() map[string]string {
if x != nil {
return x.Labels
}
return nil
}
// The request to run a pipeline. If `pipelineId` is specified, it
// refers to a saved pipeline created with CreatePipeline and set as
// the `pipelineId` of the returned Pipeline object. If
// `ephemeralPipeline` is specified, that pipeline is run once
// with the given args and not saved. It is an error to specify both
// `pipelineId` and `ephemeralPipeline`. `pipelineArgs`
// must be specified.
type RunPipelineRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Types that are assignable to Pipeline:
//
// *RunPipelineRequest_PipelineId
// *RunPipelineRequest_EphemeralPipeline
Pipeline isRunPipelineRequest_Pipeline `protobuf_oneof:"pipeline"`
// The arguments to use when running this pipeline.
PipelineArgs *RunPipelineArgs `protobuf:"bytes,3,opt,name=pipeline_args,json=pipelineArgs,proto3" json:"pipeline_args,omitempty"`
}
func (x *RunPipelineRequest) Reset() {
*x = RunPipelineRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *RunPipelineRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*RunPipelineRequest) ProtoMessage() {}
func (x *RunPipelineRequest) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[5]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use RunPipelineRequest.ProtoReflect.Descriptor instead.
func (*RunPipelineRequest) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{5}
}
func (m *RunPipelineRequest) GetPipeline() isRunPipelineRequest_Pipeline {
if m != nil {
return m.Pipeline
}
return nil
}
func (x *RunPipelineRequest) GetPipelineId() string {
if x, ok := x.GetPipeline().(*RunPipelineRequest_PipelineId); ok {
return x.PipelineId
}
return ""
}
func (x *RunPipelineRequest) GetEphemeralPipeline() *Pipeline {
if x, ok := x.GetPipeline().(*RunPipelineRequest_EphemeralPipeline); ok {
return x.EphemeralPipeline
}
return nil
}
func (x *RunPipelineRequest) GetPipelineArgs() *RunPipelineArgs {
if x != nil {
return x.PipelineArgs
}
return nil
}
type isRunPipelineRequest_Pipeline interface {
isRunPipelineRequest_Pipeline()
}
type RunPipelineRequest_PipelineId struct {
// The already created pipeline to run.
PipelineId string `protobuf:"bytes,1,opt,name=pipeline_id,json=pipelineId,proto3,oneof"`
}
type RunPipelineRequest_EphemeralPipeline struct {
// A new pipeline object to run once and then delete.
EphemeralPipeline *Pipeline `protobuf:"bytes,2,opt,name=ephemeral_pipeline,json=ephemeralPipeline,proto3,oneof"`
}
func (*RunPipelineRequest_PipelineId) isRunPipelineRequest_Pipeline() {}
func (*RunPipelineRequest_EphemeralPipeline) isRunPipelineRequest_Pipeline() {}
// A request to get a saved pipeline by id.
type GetPipelineRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Caller must have READ access to the project in which this pipeline
// is defined.
PipelineId string `protobuf:"bytes,1,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
}
func (x *GetPipelineRequest) Reset() {
*x = GetPipelineRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *GetPipelineRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetPipelineRequest) ProtoMessage() {}
func (x *GetPipelineRequest) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[6]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetPipelineRequest.ProtoReflect.Descriptor instead.
func (*GetPipelineRequest) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{6}
}
func (x *GetPipelineRequest) GetPipelineId() string {
if x != nil {
return x.PipelineId
}
return ""
}
// A request to list pipelines in a given project. Pipelines can be
// filtered by name using `namePrefix`: all pipelines with names that
// begin with `namePrefix` will be returned. Uses standard pagination:
// `pageSize` indicates how many pipelines to return, and
// `pageToken` comes from a previous ListPipelinesResponse to
// indicate offset.
type ListPipelinesRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Required. The name of the project to search for pipelines. Caller
// must have READ access to this project.
ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
// Pipelines with names that match this prefix should be
// returned. If unspecified, all pipelines in the project, up to
// `pageSize`, will be returned.
NamePrefix string `protobuf:"bytes,2,opt,name=name_prefix,json=namePrefix,proto3" json:"name_prefix,omitempty"`
// Number of pipelines to return at once. Defaults to 256, and max
// is 2048.
PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// Token to use to indicate where to start getting results.
// If unspecified, returns the first page of results.
PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
}
func (x *ListPipelinesRequest) Reset() {
*x = ListPipelinesRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *ListPipelinesRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ListPipelinesRequest) ProtoMessage() {}
func (x *ListPipelinesRequest) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[7]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ListPipelinesRequest.ProtoReflect.Descriptor instead.
func (*ListPipelinesRequest) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{7}
}
func (x *ListPipelinesRequest) GetProjectId() string {
if x != nil {
return x.ProjectId
}
return ""
}
func (x *ListPipelinesRequest) GetNamePrefix() string {
if x != nil {
return x.NamePrefix
}
return ""
}
func (x *ListPipelinesRequest) GetPageSize() int32 {
if x != nil {
return x.PageSize
}
return 0
}
func (x *ListPipelinesRequest) GetPageToken() string {
if x != nil {
return x.PageToken
}
return ""
}
// The response of ListPipelines. Contains at most `pageSize`
// pipelines. If it contains `pageSize` pipelines, and more pipelines
// exist, then `nextPageToken` will be populated and should be
// used as the `pageToken` argument to a subsequent ListPipelines
// request.
type ListPipelinesResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// The matched pipelines.
Pipelines []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
// The token to use to get the next page of results.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}
func (x *ListPipelinesResponse) Reset() {
*x = ListPipelinesResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *ListPipelinesResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ListPipelinesResponse) ProtoMessage() {}
func (x *ListPipelinesResponse) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[8]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ListPipelinesResponse.ProtoReflect.Descriptor instead.
func (*ListPipelinesResponse) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{8}
}
func (x *ListPipelinesResponse) GetPipelines() []*Pipeline {
if x != nil {
return x.Pipelines
}
return nil
}
func (x *ListPipelinesResponse) GetNextPageToken() string {
if x != nil {
return x.NextPageToken
}
return ""
}
// The request to delete a saved pipeline by ID.
type DeletePipelineRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Caller must have WRITE access to the project in which this pipeline
// is defined.
PipelineId string `protobuf:"bytes,1,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
}
func (x *DeletePipelineRequest) Reset() {
*x = DeletePipelineRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *DeletePipelineRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DeletePipelineRequest) ProtoMessage() {}
func (x *DeletePipelineRequest) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[9]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use DeletePipelineRequest.ProtoReflect.Descriptor instead.
func (*DeletePipelineRequest) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{9}
}
func (x *DeletePipelineRequest) GetPipelineId() string {
if x != nil {
return x.PipelineId
}
return ""
}
// Request to get controller configuation. Should only be used
// by VMs created by the Pipelines Service and not by end users.
type GetControllerConfigRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// The operation to retrieve controller configuration for.
OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
ValidationToken uint64 `protobuf:"varint,2,opt,name=validation_token,json=validationToken,proto3" json:"validation_token,omitempty"`
}
func (x *GetControllerConfigRequest) Reset() {
*x = GetControllerConfigRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *GetControllerConfigRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetControllerConfigRequest) ProtoMessage() {}
func (x *GetControllerConfigRequest) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[10]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetControllerConfigRequest.ProtoReflect.Descriptor instead.
func (*GetControllerConfigRequest) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{10}
}
func (x *GetControllerConfigRequest) GetOperationId() string {
if x != nil {
return x.OperationId
}
return ""
}
func (x *GetControllerConfigRequest) GetValidationToken() uint64 {
if x != nil {
return x.ValidationToken
}
return 0
}
// Stores the information that the controller will fetch from the
// server in order to run. Should only be used by VMs created by the
// Pipelines Service and not by end users.
type ControllerConfig struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
Cmd string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
GcsLogPath string `protobuf:"bytes,3,opt,name=gcs_log_path,json=gcsLogPath,proto3" json:"gcs_log_path,omitempty"`
MachineType string `protobuf:"bytes,4,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
Vars map[string]string `protobuf:"bytes,5,rep,name=vars,proto3" json:"vars,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
Disks map[string]string `protobuf:"bytes,6,rep,name=disks,proto3" json:"disks,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
GcsSources map[string]*ControllerConfig_RepeatedString `protobuf:"bytes,7,rep,name=gcs_sources,json=gcsSources,proto3" json:"gcs_sources,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
GcsSinks map[string]*ControllerConfig_RepeatedString `protobuf:"bytes,8,rep,name=gcs_sinks,json=gcsSinks,proto3" json:"gcs_sinks,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
}
func (x *ControllerConfig) Reset() {
*x = ControllerConfig{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *ControllerConfig) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ControllerConfig) ProtoMessage() {}
func (x *ControllerConfig) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[11]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ControllerConfig.ProtoReflect.Descriptor instead.
func (*ControllerConfig) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{11}
}
func (x *ControllerConfig) GetImage() string {
if x != nil {
return x.Image
}
return ""
}
func (x *ControllerConfig) GetCmd() string {
if x != nil {
return x.Cmd
}
return ""
}
func (x *ControllerConfig) GetGcsLogPath() string {
if x != nil {
return x.GcsLogPath
}
return ""
}
func (x *ControllerConfig) GetMachineType() string {
if x != nil {
return x.MachineType
}
return ""
}
func (x *ControllerConfig) GetVars() map[string]string {
if x != nil {
return x.Vars
}
return nil
}
func (x *ControllerConfig) GetDisks() map[string]string {
if x != nil {
return x.Disks
}
return nil
}
func (x *ControllerConfig) GetGcsSources() map[string]*ControllerConfig_RepeatedString {
if x != nil {
return x.GcsSources
}
return nil
}
func (x *ControllerConfig) GetGcsSinks() map[string]*ControllerConfig_RepeatedString {
if x != nil {
return x.GcsSinks
}
return nil
}
// Stores the list of events and times they occured for major events in job
// execution.
type TimestampEvent struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// String indicating the type of event
Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
// The time this event occured.
Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}
func (x *TimestampEvent) Reset() {
*x = TimestampEvent{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[12]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *TimestampEvent) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TimestampEvent) ProtoMessage() {}
func (x *TimestampEvent) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[12]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TimestampEvent.ProtoReflect.Descriptor instead.
func (*TimestampEvent) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{12}
}
func (x *TimestampEvent) GetDescription() string {
if x != nil {
return x.Description
}
return ""
}
func (x *TimestampEvent) GetTimestamp() *timestamppb.Timestamp {
if x != nil {
return x.Timestamp
}
return nil
}
// Request to set operation status. Should only be used by VMs
// created by the Pipelines Service and not by end users.
type SetOperationStatusRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
TimestampEvents []*TimestampEvent `protobuf:"bytes,2,rep,name=timestamp_events,json=timestampEvents,proto3" json:"timestamp_events,omitempty"`
ErrorCode code.Code `protobuf:"varint,3,opt,name=error_code,json=errorCode,proto3,enum=google.rpc.Code" json:"error_code,omitempty"`
ErrorMessage string `protobuf:"bytes,4,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
ValidationToken uint64 `protobuf:"varint,5,opt,name=validation_token,json=validationToken,proto3" json:"validation_token,omitempty"`
}
func (x *SetOperationStatusRequest) Reset() {
*x = SetOperationStatusRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[13]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *SetOperationStatusRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SetOperationStatusRequest) ProtoMessage() {}
func (x *SetOperationStatusRequest) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[13]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use SetOperationStatusRequest.ProtoReflect.Descriptor instead.
func (*SetOperationStatusRequest) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{13}
}
func (x *SetOperationStatusRequest) GetOperationId() string {
if x != nil {
return x.OperationId
}
return ""
}
func (x *SetOperationStatusRequest) GetTimestampEvents() []*TimestampEvent {
if x != nil {
return x.TimestampEvents
}
return nil
}
func (x *SetOperationStatusRequest) GetErrorCode() code.Code {
if x != nil {
return x.ErrorCode
}
return code.Code_OK
}
func (x *SetOperationStatusRequest) GetErrorMessage() string {
if x != nil {
return x.ErrorMessage
}
return ""
}
func (x *SetOperationStatusRequest) GetValidationToken() uint64 {
if x != nil {
return x.ValidationToken
}
return 0
}
// A Google Cloud Service Account.
type ServiceAccount struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// Email address of the service account. Defaults to `default`,
// which uses the compute service account associated with the project.
Email string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
// List of scopes to be enabled for this service account on the VM.
// The following scopes are automatically included:
//
// * https://www.googleapis.com/auth/compute
// * https://www.googleapis.com/auth/devstorage.full_control
// * https://www.googleapis.com/auth/genomics
// * https://www.googleapis.com/auth/logging.write
// * https://www.googleapis.com/auth/monitoring.write
Scopes []string `protobuf:"bytes,2,rep,name=scopes,proto3" json:"scopes,omitempty"`
}
func (x *ServiceAccount) Reset() {
*x = ServiceAccount{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[14]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *ServiceAccount) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ServiceAccount) ProtoMessage() {}
func (x *ServiceAccount) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[14]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ServiceAccount.ProtoReflect.Descriptor instead.
func (*ServiceAccount) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{14}
}
func (x *ServiceAccount) GetEmail() string {
if x != nil {
return x.Email
}
return ""
}
func (x *ServiceAccount) GetScopes() []string {
if x != nil {
return x.Scopes
}
return nil
}
// The logging options for the pipeline run.
type LoggingOptions struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// The location in Google Cloud Storage to which the pipeline logs
// will be copied. Can be specified as a fully qualified directory
// path, in which case logs will be output with a unique identifier
// as the filename in that directory, or as a fully specified path,
// which must end in `.log`, in which case that path will be
// used, and the user must ensure that logs are not
// overwritten. Stdout and stderr logs from the run are also
// generated and output as `-stdout.log` and `-stderr.log`.
GcsPath string `protobuf:"bytes,1,opt,name=gcs_path,json=gcsPath,proto3" json:"gcs_path,omitempty"`
}
func (x *LoggingOptions) Reset() {
*x = LoggingOptions{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[15]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *LoggingOptions) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*LoggingOptions) ProtoMessage() {}
func (x *LoggingOptions) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[15]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use LoggingOptions.ProtoReflect.Descriptor instead.
func (*LoggingOptions) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{15}
}
func (x *LoggingOptions) GetGcsPath() string {
if x != nil {
return x.GcsPath
}
return ""
}
// The system resources for the pipeline run.
type PipelineResources struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
// The minimum number of cores to use. Defaults to 1.
MinimumCpuCores int32 `protobuf:"varint,1,opt,name=minimum_cpu_cores,json=minimumCpuCores,proto3" json:"minimum_cpu_cores,omitempty"`
// Whether to use preemptible VMs. Defaults to `false`. In order to use this,
// must be true for both create time and run time. Cannot be true at run time
// if false at create time.
Preemptible bool `protobuf:"varint,2,opt,name=preemptible,proto3" json:"preemptible,omitempty"`
// The minimum amount of RAM to use. Defaults to 3.75 (GB)
MinimumRamGb float64 `protobuf:"fixed64,3,opt,name=minimum_ram_gb,json=minimumRamGb,proto3" json:"minimum_ram_gb,omitempty"`
// Disks to attach.
Disks []*PipelineResources_Disk `protobuf:"bytes,4,rep,name=disks,proto3" json:"disks,omitempty"`
// List of Google Compute Engine availability zones to which resource
// creation will restricted. If empty, any zone may be chosen.
Zones []string `protobuf:"bytes,5,rep,name=zones,proto3" json:"zones,omitempty"`
// The size of the boot disk. Defaults to 10 (GB).
BootDiskSizeGb int32 `protobuf:"varint,6,opt,name=boot_disk_size_gb,json=bootDiskSizeGb,proto3" json:"boot_disk_size_gb,omitempty"`
// Whether to assign an external IP to the instance. This is an experimental
// feature that may go away. Defaults to false.
// Corresponds to `--no_address` flag for [gcloud compute instances create]
// (https://cloud.google.com/sdk/gcloud/reference/compute/instances/create).
// In order to use this, must be true for both create time and run time.
// Cannot be true at run time if false at create time. If you need to ssh into
// a private IP VM for debugging, you can ssh to a public VM and then ssh into
// the private VM's Internal IP. If noAddress is set, this pipeline run may
// only load docker images from Google Container Registry and not Docker Hub.
// ** Note: To use this option, your project must be in Google Access for
// Private IPs Early Access Program.**
NoAddress bool `protobuf:"varint,7,opt,name=no_address,json=noAddress,proto3" json:"no_address,omitempty"`
}
func (x *PipelineResources) Reset() {
*x = PipelineResources{}
if protoimpl.UnsafeEnabled {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[16]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *PipelineResources) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PipelineResources) ProtoMessage() {}
func (x *PipelineResources) ProtoReflect() protoreflect.Message {
mi := &file_google_genomics_v1alpha2_pipelines_proto_msgTypes[16]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PipelineResources.ProtoReflect.Descriptor instead.
func (*PipelineResources) Descriptor() ([]byte, []int) {
return file_google_genomics_v1alpha2_pipelines_proto_rawDescGZIP(), []int{16}
}
func (x *PipelineResources) GetMinimumCpuCores() int32 {
if x != nil {
return x.MinimumCpuCores
}
return 0
}
func (x *PipelineResources) GetPreemptible() bool {
if x != nil {
return x.Preemptible
}
return false
}
func (x *PipelineResources) GetMinimumRamGb() float64 {
if x != nil {
return x.MinimumRamGb
}
return 0
}
func (x *PipelineResources) GetDisks() []*PipelineResources_Disk {
if x != nil {
return x.Disks
}
return nil
}
func (x *PipelineResources) GetZones() []string {
if x != nil {
return x.Zones
}
return nil
}
func (x *PipelineResources) GetBootDiskSizeGb() int32 {
if x != nil {
return x.BootDiskSizeGb
}
return 0
}
func (x *PipelineResources) GetNoAddress() bool {
if x != nil {
return x.NoAddress
}
return false
}
// Parameters facilitate setting and delivering data into the
// pipeline's execution environment. They are defined at create time,
// with optional defaults, and can be overridden at run time.
//
// If `localCopy` is unset, then the parameter specifies a string that
// is passed as-is into the pipeline, as the value of the environment
// variable with the given name. A default value can be optionally
// specified at create time. The default can be overridden at run time
// using the inputs map. If no default is given, a value must be
// supplied at runtime.
//
// If `localCopy` is defined, then the parameter specifies a data
// source or sink, both in Google Cloud Storage and on the Docker container
// where the pipeline computation is run. The [service account associated with
// the Pipeline][google.genomics.v1alpha2.RunPipelineArgs.service_account] (by
// default the project's Compute Engine service account) must have access to the
// Google Cloud Storage paths.
//
// At run time, the Google Cloud Storage paths can be overridden if a default
// was provided at create time, or must be set otherwise. The pipeline runner
// should add a key/value pair to either the inputs or outputs map. The
// indicated data copies will be carried out before/after pipeline execution,
// just as if the corresponding arguments were provided to `gsutil cp`.
//
// For example: Given the following `PipelineParameter`, specified
// in the `inputParameters` list:
//
// ```
// {name: "input_file", localCopy: {path: "file.txt", disk: "pd1"}}
// ```
//
// where `disk` is defined in the `PipelineResources` object as:
//
// ```
// {name: "pd1", mountPoint: "/mnt/disk/"}
// ```
//
// We create a disk named `pd1`, mount it on the host VM, and map
// `/mnt/pd1` to `/mnt/disk` in the docker container. At
// runtime, an entry for `input_file` would be required in the inputs
// map, such as:
//
// ```
//
// inputs["input_file"] = "gs://my-bucket/bar.txt"
//
// ```
//
// This would generate the following gsutil call:
//
// ```
//
// gsutil cp gs://my-bucket/bar.txt /mnt/pd1/file.txt
//
// ```
//
// The file `/mnt/pd1/file.txt` maps to `/mnt/disk/file.txt` in the
// Docker container. Acceptable paths are:
//
//
//
//
//
Google Cloud storage path
Local path
//
//
//
file
file
//
glob
directory
//
//
//
//
// For outputs, the direction of the copy is reversed:
//
// ```
//
// gsutil cp /mnt/disk/file.txt gs://my-bucket/bar.txt
//
// ```
//
// Acceptable paths are:
//
//
//
//
//
Local path
Google Cloud Storage path
//
//
//
file
file
//
//
file
//
directory - directory must already exist
//
//
//
glob
//
directory - directory will be created if it doesn't exist