Variables
File_google_cloud_lifesciences_v2beta_workflows_proto
var File_google_cloud_lifesciences_v2beta_workflows_proto protoreflect.FileDescriptorFunctions
func RegisterWorkflowsServiceV2BetaServer
func RegisterWorkflowsServiceV2BetaServer(s *grpc.Server, srv WorkflowsServiceV2BetaServer)Accelerator
type Accelerator struct {
// The accelerator type string (for example, "nvidia-tesla-k80").
//
// Only NVIDIA GPU accelerators are currently supported. If an NVIDIA GPU is
// attached, the required runtime libraries will be made available to all
// containers under `/usr/local/nvidia`. The driver version to install must
// be specified using the NVIDIA driver version parameter on the virtual
// machine specification. Note that attaching a GPU increases the worker VM
// startup time by a few minutes.
Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
// How many accelerators of this type to attach.
Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
// contains filtered or unexported fields
}Carries information about an accelerator that can be attached to a VM.
func (*Accelerator) Descriptor
func (*Accelerator) Descriptor() ([]byte, []int)Deprecated: Use Accelerator.ProtoReflect.Descriptor instead.
func (*Accelerator) GetCount
func (x *Accelerator) GetCount() int64func (*Accelerator) GetType
func (x *Accelerator) GetType() stringfunc (*Accelerator) ProtoMessage
func (*Accelerator) ProtoMessage()func (*Accelerator) ProtoReflect
func (x *Accelerator) ProtoReflect() protoreflect.Messagefunc (*Accelerator) Reset
func (x *Accelerator) Reset()func (*Accelerator) String
func (x *Accelerator) String() stringAction
type Action struct {
ContainerName string `protobuf:"bytes,1,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
ImageUri string `protobuf:"bytes,2,opt,name=image_uri,json=imageUri,proto3" json:"image_uri,omitempty"`
Commands []string `protobuf:"bytes,3,rep,name=commands,proto3" json:"commands,omitempty"`
Entrypoint string `protobuf:"bytes,4,opt,name=entrypoint,proto3" json:"entrypoint,omitempty"`
Environment map[string]string "" /* 163 byte string literal not displayed */
EncryptedEnvironment *Secret `protobuf:"bytes,21,opt,name=encrypted_environment,json=encryptedEnvironment,proto3" json:"encrypted_environment,omitempty"`
PidNamespace string `protobuf:"bytes,6,opt,name=pid_namespace,json=pidNamespace,proto3" json:"pid_namespace,omitempty"`
PortMappings map[int32]int32 "" /* 187 byte string literal not displayed */
Mounts []*Mount `protobuf:"bytes,9,rep,name=mounts,proto3" json:"mounts,omitempty"`
Labels map[string]string "" /* 154 byte string literal not displayed */
Credentials *Secret `protobuf:"bytes,11,opt,name=credentials,proto3" json:"credentials,omitempty"`
Timeout *durationpb.Duration `protobuf:"bytes,12,opt,name=timeout,proto3" json:"timeout,omitempty"`
IgnoreExitStatus bool `protobuf:"varint,13,opt,name=ignore_exit_status,json=ignoreExitStatus,proto3" json:"ignore_exit_status,omitempty"`
RunInBackground bool `protobuf:"varint,14,opt,name=run_in_background,json=runInBackground,proto3" json:"run_in_background,omitempty"`
AlwaysRun bool `protobuf:"varint,15,opt,name=always_run,json=alwaysRun,proto3" json:"always_run,omitempty"`
EnableFuse bool `protobuf:"varint,16,opt,name=enable_fuse,json=enableFuse,proto3" json:"enable_fuse,omitempty"`
PublishExposedPorts bool `protobuf:"varint,17,opt,name=publish_exposed_ports,json=publishExposedPorts,proto3" json:"publish_exposed_ports,omitempty"`
DisableImagePrefetch bool `protobuf:"varint,18,opt,name=disable_image_prefetch,json=disableImagePrefetch,proto3" json:"disable_image_prefetch,omitempty"`
DisableStandardErrorCapture bool "" /* 148 byte string literal not displayed */
BlockExternalNetwork bool `protobuf:"varint,20,opt,name=block_external_network,json=blockExternalNetwork,proto3" json:"block_external_network,omitempty"`
}Specifies a single action that runs a Docker container.
func (*Action) Descriptor
Deprecated: Use Action.ProtoReflect.Descriptor instead.
func (*Action) GetAlwaysRun
func (*Action) GetBlockExternalNetwork
func (*Action) GetCommands
func (*Action) GetContainerName
func (*Action) GetCredentials
func (*Action) GetDisableImagePrefetch
func (*Action) GetDisableStandardErrorCapture
func (*Action) GetEnableFuse
func (*Action) GetEncryptedEnvironment
func (*Action) GetEntrypoint
func (*Action) GetEnvironment
func (*Action) GetIgnoreExitStatus
func (*Action) GetImageUri
func (*Action) GetLabels
func (*Action) GetMounts
func (*Action) GetPidNamespace
func (*Action) GetPortMappings
func (*Action) GetPublishExposedPorts
func (*Action) GetRunInBackground
func (*Action) GetTimeout
func (x *Action) GetTimeout() *durationpb.Durationfunc (*Action) ProtoMessage
func (*Action) ProtoMessage()func (*Action) ProtoReflect
func (x *Action) ProtoReflect() protoreflect.Messagefunc (*Action) Reset
func (x *Action) Reset()func (*Action) String
ContainerKilledEvent
type ContainerKilledEvent struct {
// The numeric ID of the action that started the container.
ActionId int32 `protobuf:"varint,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
// contains filtered or unexported fields
}An event generated when a container is forcibly terminated by the worker. Currently, this only occurs when the container outlives the timeout specified by the user.
func (*ContainerKilledEvent) Descriptor
func (*ContainerKilledEvent) Descriptor() ([]byte, []int)Deprecated: Use ContainerKilledEvent.ProtoReflect.Descriptor instead.
func (*ContainerKilledEvent) GetActionId
func (x *ContainerKilledEvent) GetActionId() int32func (*ContainerKilledEvent) ProtoMessage
func (*ContainerKilledEvent) ProtoMessage()func (*ContainerKilledEvent) ProtoReflect
func (x *ContainerKilledEvent) ProtoReflect() protoreflect.Messagefunc (*ContainerKilledEvent) Reset
func (x *ContainerKilledEvent) Reset()func (*ContainerKilledEvent) String
func (x *ContainerKilledEvent) String() stringContainerStartedEvent
type ContainerStartedEvent struct {
ActionId int32 `protobuf:"varint,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
PortMappings map[int32]int32 "" /* 187 byte string literal not displayed */
IpAddress string `protobuf:"bytes,3,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`
}An event generated when a container starts.
func (*ContainerStartedEvent) Descriptor
func (*ContainerStartedEvent) Descriptor() ([]byte, []int)Deprecated: Use ContainerStartedEvent.ProtoReflect.Descriptor instead.
func (*ContainerStartedEvent) GetActionId
func (x *ContainerStartedEvent) GetActionId() int32func (*ContainerStartedEvent) GetIpAddress
func (x *ContainerStartedEvent) GetIpAddress() stringfunc (*ContainerStartedEvent) GetPortMappings
func (x *ContainerStartedEvent) GetPortMappings() map[int32]int32func (*ContainerStartedEvent) ProtoMessage
func (*ContainerStartedEvent) ProtoMessage()func (*ContainerStartedEvent) ProtoReflect
func (x *ContainerStartedEvent) ProtoReflect() protoreflect.Messagefunc (*ContainerStartedEvent) Reset
func (x *ContainerStartedEvent) Reset()func (*ContainerStartedEvent) String
func (x *ContainerStartedEvent) String() stringContainerStoppedEvent
type ContainerStoppedEvent struct {
// The numeric ID of the action that started this container.
ActionId int32 `protobuf:"varint,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
// The exit status of the container.
ExitStatus int32 `protobuf:"varint,2,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
// The tail end of any content written to standard error by the container.
// If the content emits large amounts of debugging noise or contains
// sensitive information, you can prevent the content from being printed by
// setting the `DISABLE_STANDARD_ERROR_CAPTURE` flag.
//
// Note that only a small amount of the end of the stream is captured here.
// The entire stream is stored in the `/google/logs` directory mounted into
// each action, and can be copied off the machine as described elsewhere.
Stderr string `protobuf:"bytes,3,opt,name=stderr,proto3" json:"stderr,omitempty"`
// contains filtered or unexported fields
}An event generated when a container exits.
func (*ContainerStoppedEvent) Descriptor
func (*ContainerStoppedEvent) Descriptor() ([]byte, []int)Deprecated: Use ContainerStoppedEvent.ProtoReflect.Descriptor instead.
func (*ContainerStoppedEvent) GetActionId
func (x *ContainerStoppedEvent) GetActionId() int32func (*ContainerStoppedEvent) GetExitStatus
func (x *ContainerStoppedEvent) GetExitStatus() int32func (*ContainerStoppedEvent) GetStderr
func (x *ContainerStoppedEvent) GetStderr() stringfunc (*ContainerStoppedEvent) ProtoMessage
func (*ContainerStoppedEvent) ProtoMessage()func (*ContainerStoppedEvent) ProtoReflect
func (x *ContainerStoppedEvent) ProtoReflect() protoreflect.Messagefunc (*ContainerStoppedEvent) Reset
func (x *ContainerStoppedEvent) Reset()func (*ContainerStoppedEvent) String
func (x *ContainerStoppedEvent) String() stringDelayedEvent
type DelayedEvent struct {
// A textual description of the cause of the delay. The string can change
// without notice because it is often generated by another service (such as
// Compute Engine).
Cause string `protobuf:"bytes,1,opt,name=cause,proto3" json:"cause,omitempty"`
// If the delay was caused by a resource shortage, this field lists the
// Compute Engine metrics that are preventing this operation from running
// (for example, `CPUS` or `INSTANCES`). If the particular metric is not
// known, a single `UNKNOWN` metric will be present.
Metrics []string `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
// contains filtered or unexported fields
}An event generated whenever a resource limitation or transient error delays execution of a pipeline that was otherwise ready to run.
func (*DelayedEvent) Descriptor
func (*DelayedEvent) Descriptor() ([]byte, []int)Deprecated: Use DelayedEvent.ProtoReflect.Descriptor instead.
func (*DelayedEvent) GetCause
func (x *DelayedEvent) GetCause() stringfunc (*DelayedEvent) GetMetrics
func (x *DelayedEvent) GetMetrics() []stringfunc (*DelayedEvent) ProtoMessage
func (*DelayedEvent) ProtoMessage()func (*DelayedEvent) ProtoReflect
func (x *DelayedEvent) ProtoReflect() protoreflect.Messagefunc (*DelayedEvent) Reset
func (x *DelayedEvent) Reset()func (*DelayedEvent) String
func (x *DelayedEvent) String() stringDisk
type Disk struct {
// A user-supplied name for the disk. Used when mounting the disk into
// actions. The name must contain only upper and lowercase alphanumeric
// characters and hyphens and cannot start with a hyphen.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The size, in GB, of the disk to attach. If the size is not
// specified, a default is chosen to ensure reasonable I/O performance.
//
// If the disk type is specified as `local-ssd`, multiple local drives are
// automatically combined to provide the requested size. Note, however, that
// each physical SSD is 375GB in size, and no more than 8 drives can be
// attached to a single instance.
SizeGb int32 `protobuf:"varint,2,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"`
// The Compute Engine disk type. If unspecified, `pd-standard` is used.
Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
// An optional image to put on the disk before attaching it to the VM.
SourceImage string `protobuf:"bytes,4,opt,name=source_image,json=sourceImage,proto3" json:"source_image,omitempty"`
// contains filtered or unexported fields
}Carries information about a disk that can be attached to a VM.
See https://cloud.google.com/compute/docs/disks/performance for more information about disk type, size, and performance considerations.
Specify either [Volume][google.cloud.lifesciences.v2beta.Volume] or
[Disk][google.cloud.lifesciences.v2beta.Disk], but not both.
func (*Disk) Descriptor
Deprecated: Use Disk.ProtoReflect.Descriptor instead.
func (*Disk) GetName
func (*Disk) GetSizeGb
func (*Disk) GetSourceImage
func (*Disk) GetType
func (*Disk) ProtoMessage
func (*Disk) ProtoMessage()func (*Disk) ProtoReflect
func (x *Disk) ProtoReflect() protoreflect.Messagefunc (*Disk) Reset
func (x *Disk) Reset()func (*Disk) String
Event
type Event struct {
// The time at which the event occurred.
Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// A human-readable description of the event. Note that these strings can
// change at any time without notice. Any application logic must use the
// information in the `details` field.
Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
// Machine-readable details about the event.
//
// Types that are assignable to Details:
//
// *Event_Delayed
// *Event_WorkerAssigned
// *Event_WorkerReleased
// *Event_PullStarted
// *Event_PullStopped
// *Event_ContainerStarted
// *Event_ContainerStopped
// *Event_ContainerKilled
// *Event_UnexpectedExitStatus
// *Event_Failed
Details isEvent_Details `protobuf_oneof:"details"`
// contains filtered or unexported fields
}Carries information about events that occur during pipeline execution.
func (*Event) Descriptor
Deprecated: Use Event.ProtoReflect.Descriptor instead.
func (*Event) GetContainerKilled
func (x *Event) GetContainerKilled() *ContainerKilledEventfunc (*Event) GetContainerStarted
func (x *Event) GetContainerStarted() *ContainerStartedEventfunc (*Event) GetContainerStopped
func (x *Event) GetContainerStopped() *ContainerStoppedEventfunc (*Event) GetDelayed
func (x *Event) GetDelayed() *DelayedEventfunc (*Event) GetDescription
func (*Event) GetDetails
func (m *Event) GetDetails() isEvent_Detailsfunc (*Event) GetFailed
func (x *Event) GetFailed() *FailedEventfunc (*Event) GetPullStarted
func (x *Event) GetPullStarted() *PullStartedEventfunc (*Event) GetPullStopped
func (x *Event) GetPullStopped() *PullStoppedEventfunc (*Event) GetTimestamp
func (x *Event) GetTimestamp() *timestamppb.Timestampfunc (*Event) GetUnexpectedExitStatus
func (x *Event) GetUnexpectedExitStatus() *UnexpectedExitStatusEventfunc (*Event) GetWorkerAssigned
func (x *Event) GetWorkerAssigned() *WorkerAssignedEventfunc (*Event) GetWorkerReleased
func (x *Event) GetWorkerReleased() *WorkerReleasedEventfunc (*Event) ProtoMessage
func (*Event) ProtoMessage()func (*Event) ProtoReflect
func (x *Event) ProtoReflect() protoreflect.Messagefunc (*Event) Reset
func (x *Event) Reset()func (*Event) String
Event_ContainerKilled
type Event_ContainerKilled struct {
// See
// [google.cloud.lifesciences.v2beta.ContainerKilledEvent][google.cloud.lifesciences.v2beta.ContainerKilledEvent].
ContainerKilled *ContainerKilledEvent `protobuf:"bytes,24,opt,name=container_killed,json=containerKilled,proto3,oneof"`
}Event_ContainerStarted
type Event_ContainerStarted struct {
// See
// [google.cloud.lifesciences.v2beta.ContainerStartedEvent][google.cloud.lifesciences.v2beta.ContainerStartedEvent].
ContainerStarted *ContainerStartedEvent `protobuf:"bytes,22,opt,name=container_started,json=containerStarted,proto3,oneof"`
}Event_ContainerStopped
type Event_ContainerStopped struct {
// See
// [google.cloud.lifesciences.v2beta.ContainerStoppedEvent][google.cloud.lifesciences.v2beta.ContainerStoppedEvent].
ContainerStopped *ContainerStoppedEvent `protobuf:"bytes,23,opt,name=container_stopped,json=containerStopped,proto3,oneof"`
}Event_Delayed
type Event_Delayed struct {
// See
// [google.cloud.lifesciences.v2beta.DelayedEvent][google.cloud.lifesciences.v2beta.DelayedEvent].
Delayed *DelayedEvent `protobuf:"bytes,17,opt,name=delayed,proto3,oneof"`
}Event_Failed
type Event_Failed struct {
// See
// [google.cloud.lifesciences.v2beta.FailedEvent][google.cloud.lifesciences.v2beta.FailedEvent].
Failed *FailedEvent `protobuf:"bytes,26,opt,name=failed,proto3,oneof"`
}Event_PullStarted
type Event_PullStarted struct {
// See
// [google.cloud.lifesciences.v2beta.PullStartedEvent][google.cloud.lifesciences.v2beta.PullStartedEvent].
PullStarted *PullStartedEvent `protobuf:"bytes,20,opt,name=pull_started,json=pullStarted,proto3,oneof"`
}Event_PullStopped
type Event_PullStopped struct {
// See
// [google.cloud.lifesciences.v2beta.PullStoppedEvent][google.cloud.lifesciences.v2beta.PullStoppedEvent].
PullStopped *PullStoppedEvent `protobuf:"bytes,21,opt,name=pull_stopped,json=pullStopped,proto3,oneof"`
}Event_UnexpectedExitStatus
type Event_UnexpectedExitStatus struct {
// See
// [google.cloud.lifesciences.v2beta.UnexpectedExitStatusEvent][google.cloud.lifesciences.v2beta.UnexpectedExitStatusEvent].
UnexpectedExitStatus *UnexpectedExitStatusEvent `protobuf:"bytes,25,opt,name=unexpected_exit_status,json=unexpectedExitStatus,proto3,oneof"`
}Event_WorkerAssigned
type Event_WorkerAssigned struct {
// See
// [google.cloud.lifesciences.v2beta.WorkerAssignedEvent][google.cloud.lifesciences.v2beta.WorkerAssignedEvent].
WorkerAssigned *WorkerAssignedEvent `protobuf:"bytes,18,opt,name=worker_assigned,json=workerAssigned,proto3,oneof"`
}Event_WorkerReleased
type Event_WorkerReleased struct {
// See
// [google.cloud.lifesciences.v2beta.WorkerReleasedEvent][google.cloud.lifesciences.v2beta.WorkerReleasedEvent].
WorkerReleased *WorkerReleasedEvent `protobuf:"bytes,19,opt,name=worker_released,json=workerReleased,proto3,oneof"`
}ExistingDisk
type ExistingDisk struct {
// If `disk` contains slashes, the Cloud Life Sciences API assumes that it is
// a complete URL for the disk. If `disk` does not contain slashes, the Cloud
// Life Sciences API assumes that the disk is a zonal disk and a URL will be
// generated of the form `zones/Configuration for an existing disk to be attached to the VM.
func (*ExistingDisk) Descriptor
func (*ExistingDisk) Descriptor() ([]byte, []int)Deprecated: Use ExistingDisk.ProtoReflect.Descriptor instead.
func (*ExistingDisk) GetDisk
func (x *ExistingDisk) GetDisk() stringfunc (*ExistingDisk) ProtoMessage
func (*ExistingDisk) ProtoMessage()func (*ExistingDisk) ProtoReflect
func (x *ExistingDisk) ProtoReflect() protoreflect.Messagefunc (*ExistingDisk) Reset
func (x *ExistingDisk) Reset()func (*ExistingDisk) String
func (x *ExistingDisk) String() stringFailedEvent
type FailedEvent struct {
// The Google standard error code that best describes this failure.
Code code.Code `protobuf:"varint,1,opt,name=code,proto3,enum=google.rpc.Code" json:"code,omitempty"`
// The human-readable description of the cause of the failure.
Cause string `protobuf:"bytes,2,opt,name=cause,proto3" json:"cause,omitempty"`
// contains filtered or unexported fields
}An event generated when the execution of a pipeline has failed. Note that other events can continue to occur after this event.
func (*FailedEvent) Descriptor
func (*FailedEvent) Descriptor() ([]byte, []int)Deprecated: Use FailedEvent.ProtoReflect.Descriptor instead.
func (*FailedEvent) GetCause
func (x *FailedEvent) GetCause() stringfunc (*FailedEvent) GetCode
func (x *FailedEvent) GetCode() code.Codefunc (*FailedEvent) ProtoMessage
func (*FailedEvent) ProtoMessage()func (*FailedEvent) ProtoReflect
func (x *FailedEvent) ProtoReflect() protoreflect.Messagefunc (*FailedEvent) Reset
func (x *FailedEvent) Reset()func (*FailedEvent) String
func (x *FailedEvent) String() stringMetadata
type Metadata struct {
Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
Labels map[string]string "" /* 153 byte string literal not displayed */
Events []*Event `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"`
CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
StartTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
EndTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
PubSubTopic string `protobuf:"bytes,7,opt,name=pub_sub_topic,json=pubSubTopic,proto3" json:"pub_sub_topic,omitempty"`
}Carries information about the pipeline execution that is returned in the long running operation's metadata field.
func (*Metadata) Descriptor
Deprecated: Use Metadata.ProtoReflect.Descriptor instead.
func (*Metadata) GetCreateTime
func (x *Metadata) GetCreateTime() *timestamppb.Timestampfunc (*Metadata) GetEndTime
func (x *Metadata) GetEndTime() *timestamppb.Timestampfunc (*Metadata) GetEvents
func (*Metadata) GetLabels
func (*Metadata) GetPipeline
func (*Metadata) GetPubSubTopic
func (*Metadata) GetStartTime
func (x *Metadata) GetStartTime() *timestamppb.Timestampfunc (*Metadata) ProtoMessage
func (*Metadata) ProtoMessage()func (*Metadata) ProtoReflect
func (x *Metadata) ProtoReflect() protoreflect.Messagefunc (*Metadata) Reset
func (x *Metadata) Reset()func (*Metadata) String
Mount
type Mount struct {
// The name of the disk to mount, as specified in the resources section.
Disk string `protobuf:"bytes,1,opt,name=disk,proto3" json:"disk,omitempty"`
// The path to mount the disk inside the container.
Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
// If true, the disk is mounted read-only inside the container.
ReadOnly bool `protobuf:"varint,3,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
// contains filtered or unexported fields
}Carries information about a particular disk mount inside a container.
func (*Mount) Descriptor
Deprecated: Use Mount.ProtoReflect.Descriptor instead.
func (*Mount) GetDisk
func (*Mount) GetPath
func (*Mount) GetReadOnly
func (*Mount) ProtoMessage
func (*Mount) ProtoMessage()func (*Mount) ProtoReflect
func (x *Mount) ProtoReflect() protoreflect.Messagefunc (*Mount) Reset
func (x *Mount) Reset()func (*Mount) String
NFSMount
type NFSMount struct {
// A target NFS mount. The target must be specified as `address:/mount".
Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
// contains filtered or unexported fields
}Configuration for an NFSMount to be attached to the VM.
func (*NFSMount) Descriptor
Deprecated: Use NFSMount.ProtoReflect.Descriptor instead.
func (*NFSMount) GetTarget
func (*NFSMount) ProtoMessage
func (*NFSMount) ProtoMessage()func (*NFSMount) ProtoReflect
func (x *NFSMount) ProtoReflect() protoreflect.Messagefunc (*NFSMount) Reset
func (x *NFSMount) Reset()func (*NFSMount) String
Network
type Network struct {
// The network name to attach the VM's network interface to. The value will
// be prefixed with `global/networks/` unless it contains a `/`, in which
// case it is assumed to be a fully specified network resource URL.
//
// If unspecified, the global default network is used.
Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
// If set to true, do not attach a public IP address to the VM. Note that
// without a public IP address, additional configuration is required to
// allow the VM to access Google services.
//
// See https://cloud.google.com/vpc/docs/configure-private-google-access
// for more information.
UsePrivateAddress bool `protobuf:"varint,2,opt,name=use_private_address,json=usePrivateAddress,proto3" json:"use_private_address,omitempty"`
// If the specified network is configured for custom subnet creation, the
// name of the subnetwork to attach the instance to must be specified here.
//
// The value is prefixed with `regions/*/subnetworks/` unless it contains a
// `/`, in which case it is assumed to be a fully specified subnetwork
// resource URL.
//
// If the `*` character appears in the value, it is replaced with the region
// that the virtual machine has been allocated in.
Subnetwork string `protobuf:"bytes,3,opt,name=subnetwork,proto3" json:"subnetwork,omitempty"`
// contains filtered or unexported fields
}VM networking options.
func (*Network) Descriptor
Deprecated: Use Network.ProtoReflect.Descriptor instead.
func (*Network) GetNetwork
func (*Network) GetSubnetwork
func (*Network) GetUsePrivateAddress
func (*Network) ProtoMessage
func (*Network) ProtoMessage()func (*Network) ProtoReflect
func (x *Network) ProtoReflect() protoreflect.Messagefunc (*Network) Reset
func (x *Network) Reset()func (*Network) String
PersistentDisk
type PersistentDisk struct {
// The size, in GB, of the disk to attach. If the size is not
// specified, a default is chosen to ensure reasonable I/O performance.
//
// If the disk type is specified as `local-ssd`, multiple local drives are
// automatically combined to provide the requested size. Note, however, that
// each physical SSD is 375GB in size, and no more than 8 drives can be
// attached to a single instance.
SizeGb int32 `protobuf:"varint,1,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"`
// The Compute Engine disk type. If unspecified, `pd-standard` is used.
Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
// An image to put on the disk before attaching it to the VM.
SourceImage string `protobuf:"bytes,3,opt,name=source_image,json=sourceImage,proto3" json:"source_image,omitempty"`
// contains filtered or unexported fields
}Configuration for a persistent disk to be attached to the VM.
See https://cloud.google.com/compute/docs/disks/performance for more information about disk type, size, and performance considerations.
func (*PersistentDisk) Descriptor
func (*PersistentDisk) Descriptor() ([]byte, []int)Deprecated: Use PersistentDisk.ProtoReflect.Descriptor instead.
func (*PersistentDisk) GetSizeGb
func (x *PersistentDisk) GetSizeGb() int32func (*PersistentDisk) GetSourceImage
func (x *PersistentDisk) GetSourceImage() stringfunc (*PersistentDisk) GetType
func (x *PersistentDisk) GetType() stringfunc (*PersistentDisk) ProtoMessage
func (*PersistentDisk) ProtoMessage()func (*PersistentDisk) ProtoReflect
func (x *PersistentDisk) ProtoReflect() protoreflect.Messagefunc (*PersistentDisk) Reset
func (x *PersistentDisk) Reset()func (*PersistentDisk) String
func (x *PersistentDisk) String() stringPipeline
type Pipeline struct {
Actions []*Action `protobuf:"bytes,1,rep,name=actions,proto3" json:"actions,omitempty"`
Resources *Resources `protobuf:"bytes,2,opt,name=resources,proto3" json:"resources,omitempty"`
Environment map[string]string "" /* 163 byte string literal not displayed */
EncryptedEnvironment *Secret `protobuf:"bytes,5,opt,name=encrypted_environment,json=encryptedEnvironment,proto3" json:"encrypted_environment,omitempty"`
Timeout *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
}Specifies a series of actions to execute, expressed as Docker containers.
func (*Pipeline) Descriptor
Deprecated: Use Pipeline.ProtoReflect.Descriptor instead.
func (*Pipeline) GetActions
func (*Pipeline) GetEncryptedEnvironment
func (*Pipeline) GetEnvironment
func (*Pipeline) GetResources
func (*Pipeline) GetTimeout
func (x *Pipeline) GetTimeout() *durationpb.Durationfunc (*Pipeline) ProtoMessage
func (*Pipeline) ProtoMessage()func (*Pipeline) ProtoReflect
func (x *Pipeline) ProtoReflect() protoreflect.Messagefunc (*Pipeline) Reset
func (x *Pipeline) Reset()func (*Pipeline) String
PullStartedEvent
type PullStartedEvent struct {
// The URI of the image that was pulled.
ImageUri string `protobuf:"bytes,1,opt,name=image_uri,json=imageUri,proto3" json:"image_uri,omitempty"`
// contains filtered or unexported fields
}An event generated when the worker starts pulling an image.
func (*PullStartedEvent) Descriptor
func (*PullStartedEvent) Descriptor() ([]byte, []int)Deprecated: Use PullStartedEvent.ProtoReflect.Descriptor instead.
func (*PullStartedEvent) GetImageUri
func (x *PullStartedEvent) GetImageUri() stringfunc (*PullStartedEvent) ProtoMessage
func (*PullStartedEvent) ProtoMessage()func (*PullStartedEvent) ProtoReflect
func (x *PullStartedEvent) ProtoReflect() protoreflect.Messagefunc (*PullStartedEvent) Reset
func (x *PullStartedEvent) Reset()func (*PullStartedEvent) String
func (x *PullStartedEvent) String() stringPullStoppedEvent
type PullStoppedEvent struct {
// The URI of the image that was pulled.
ImageUri string `protobuf:"bytes,1,opt,name=image_uri,json=imageUri,proto3" json:"image_uri,omitempty"`
// contains filtered or unexported fields
}An event generated when the worker stops pulling an image.
func (*PullStoppedEvent) Descriptor
func (*PullStoppedEvent) Descriptor() ([]byte, []int)Deprecated: Use PullStoppedEvent.ProtoReflect.Descriptor instead.
func (*PullStoppedEvent) GetImageUri
func (x *PullStoppedEvent) GetImageUri() stringfunc (*PullStoppedEvent) ProtoMessage
func (*PullStoppedEvent) ProtoMessage()func (*PullStoppedEvent) ProtoReflect
func (x *PullStoppedEvent) ProtoReflect() protoreflect.Messagefunc (*PullStoppedEvent) Reset
func (x *PullStoppedEvent) Reset()func (*PullStoppedEvent) String
func (x *PullStoppedEvent) String() stringResources
type Resources struct {
// The list of regions allowed for VM allocation. If set, the `zones` field
// must not be set.
Regions []string `protobuf:"bytes,2,rep,name=regions,proto3" json:"regions,omitempty"`
// The list of zones allowed for VM allocation. If set, the `regions` field
// must not be set.
Zones []string `protobuf:"bytes,3,rep,name=zones,proto3" json:"zones,omitempty"`
// The virtual machine specification.
VirtualMachine *VirtualMachine `protobuf:"bytes,4,opt,name=virtual_machine,json=virtualMachine,proto3" json:"virtual_machine,omitempty"`
// contains filtered or unexported fields
}The system resources for the pipeline run.
At least one zone or region must be specified or the pipeline run will fail.
func (*Resources) Descriptor
Deprecated: Use Resources.ProtoReflect.Descriptor instead.
func (*Resources) GetRegions
func (*Resources) GetVirtualMachine
func (x *Resources) GetVirtualMachine() *VirtualMachinefunc (*Resources) GetZones
func (*Resources) ProtoMessage
func (*Resources) ProtoMessage()func (*Resources) ProtoReflect
func (x *Resources) ProtoReflect() protoreflect.Messagefunc (*Resources) Reset
func (x *Resources) Reset()func (*Resources) String
RunPipelineRequest
type RunPipelineRequest struct {
Parent string `protobuf:"bytes,4,opt,name=parent,proto3" json:"parent,omitempty"`
Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
Labels map[string]string "" /* 153 byte string literal not displayed */
PubSubTopic string `protobuf:"bytes,3,opt,name=pub_sub_topic,json=pubSubTopic,proto3" json:"pub_sub_topic,omitempty"`
}The arguments to the RunPipeline method. The requesting user must have
the iam.serviceAccounts.actAs permission for the Cloud Life Sciences
service account or the request will fail.
func (*RunPipelineRequest) Descriptor
func (*RunPipelineRequest) Descriptor() ([]byte, []int)Deprecated: Use RunPipelineRequest.ProtoReflect.Descriptor instead.
func (*RunPipelineRequest) GetLabels
func (x *RunPipelineRequest) GetLabels() map[string]stringfunc (*RunPipelineRequest) GetParent
func (x *RunPipelineRequest) GetParent() stringfunc (*RunPipelineRequest) GetPipeline
func (x *RunPipelineRequest) GetPipeline() *Pipelinefunc (*RunPipelineRequest) GetPubSubTopic
func (x *RunPipelineRequest) GetPubSubTopic() stringfunc (*RunPipelineRequest) ProtoMessage
func (*RunPipelineRequest) ProtoMessage()func (*RunPipelineRequest) ProtoReflect
func (x *RunPipelineRequest) ProtoReflect() protoreflect.Messagefunc (*RunPipelineRequest) Reset
func (x *RunPipelineRequest) Reset()func (*RunPipelineRequest) String
func (x *RunPipelineRequest) String() stringRunPipelineResponse
type RunPipelineResponse struct {
// contains filtered or unexported fields
}The response to the RunPipeline method, returned in the operation's result field on success.
func (*RunPipelineResponse) Descriptor
func (*RunPipelineResponse) Descriptor() ([]byte, []int)Deprecated: Use RunPipelineResponse.ProtoReflect.Descriptor instead.
func (*RunPipelineResponse) ProtoMessage
func (*RunPipelineResponse) ProtoMessage()func (*RunPipelineResponse) ProtoReflect
func (x *RunPipelineResponse) ProtoReflect() protoreflect.Messagefunc (*RunPipelineResponse) Reset
func (x *RunPipelineResponse) Reset()func (*RunPipelineResponse) String
func (x *RunPipelineResponse) String() stringSecret
type Secret struct {
// The name of the Cloud KMS key that will be used to decrypt the secret
// value. The VM service account must have the required permissions and
// authentication scopes to invoke the `decrypt` method on the specified key.
KeyName string `protobuf:"bytes,1,opt,name=key_name,json=keyName,proto3" json:"key_name,omitempty"`
// The value of the cipherText response from the `encrypt` method. This field
// is intentionally unaudited.
CipherText string `protobuf:"bytes,2,opt,name=cipher_text,json=cipherText,proto3" json:"cipher_text,omitempty"`
// contains filtered or unexported fields
}Holds encrypted information that is only decrypted and stored in RAM by the worker VM when running the pipeline.
func (*Secret) Descriptor
Deprecated: Use Secret.ProtoReflect.Descriptor instead.
func (*Secret) GetCipherText
func (*Secret) GetKeyName
func (*Secret) ProtoMessage
func (*Secret) ProtoMessage()func (*Secret) ProtoReflect
func (x *Secret) ProtoReflect() protoreflect.Messagefunc (*Secret) Reset
func (x *Secret) Reset()func (*Secret) String
ServiceAccount
type ServiceAccount struct {
// Email address of the service account. If not specified, the default
// Compute Engine service account for the project will be used.
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, in
// addition to the cloud-platform API scope that will be added by default.
Scopes []string `protobuf:"bytes,2,rep,name=scopes,proto3" json:"scopes,omitempty"`
// contains filtered or unexported fields
}Carries information about a Google Cloud service account.
func (*ServiceAccount) Descriptor
func (*ServiceAccount) Descriptor() ([]byte, []int)Deprecated: Use ServiceAccount.ProtoReflect.Descriptor instead.
func (*ServiceAccount) GetEmail
func (x *ServiceAccount) GetEmail() stringfunc (*ServiceAccount) GetScopes
func (x *ServiceAccount) GetScopes() []stringfunc (*ServiceAccount) ProtoMessage
func (*ServiceAccount) ProtoMessage()func (*ServiceAccount) ProtoReflect
func (x *ServiceAccount) ProtoReflect() protoreflect.Messagefunc (*ServiceAccount) Reset
func (x *ServiceAccount) Reset()func (*ServiceAccount) String
func (x *ServiceAccount) String() stringUnexpectedExitStatusEvent
type UnexpectedExitStatusEvent struct {
// The numeric ID of the action that started the container.
ActionId int32 `protobuf:"varint,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
// The exit status of the container.
ExitStatus int32 `protobuf:"varint,2,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
// contains filtered or unexported fields
}An event generated when the execution of a container results in a
non-zero exit status that was not otherwise ignored. Execution will
continue, but only actions that are flagged as ALWAYS_RUN will be
executed. Other actions will be skipped.
func (*UnexpectedExitStatusEvent) Descriptor
func (*UnexpectedExitStatusEvent) Descriptor() ([]byte, []int)Deprecated: Use UnexpectedExitStatusEvent.ProtoReflect.Descriptor instead.
func (*UnexpectedExitStatusEvent) GetActionId
func (x *UnexpectedExitStatusEvent) GetActionId() int32func (*UnexpectedExitStatusEvent) GetExitStatus
func (x *UnexpectedExitStatusEvent) GetExitStatus() int32func (*UnexpectedExitStatusEvent) ProtoMessage
func (*UnexpectedExitStatusEvent) ProtoMessage()func (*UnexpectedExitStatusEvent) ProtoReflect
func (x *UnexpectedExitStatusEvent) ProtoReflect() protoreflect.Messagefunc (*UnexpectedExitStatusEvent) Reset
func (x *UnexpectedExitStatusEvent) Reset()func (*UnexpectedExitStatusEvent) String
func (x *UnexpectedExitStatusEvent) String() stringUnimplementedWorkflowsServiceV2BetaServer
type UnimplementedWorkflowsServiceV2BetaServer struct {
}UnimplementedWorkflowsServiceV2BetaServer can be embedded to have forward compatible implementations.
func (*UnimplementedWorkflowsServiceV2BetaServer) RunPipeline
func (*UnimplementedWorkflowsServiceV2BetaServer) RunPipeline(context.Context, *RunPipelineRequest) (*longrunningpb.Operation, error)VirtualMachine
type VirtualMachine struct {
MachineType string `protobuf:"bytes,1,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
Preemptible bool `protobuf:"varint,2,opt,name=preemptible,proto3" json:"preemptible,omitempty"`
Labels map[string]string "" /* 153 byte string literal not displayed */
Disks []*Disk `protobuf:"bytes,4,rep,name=disks,proto3" json:"disks,omitempty"`
Network *Network `protobuf:"bytes,5,opt,name=network,proto3" json:"network,omitempty"`
Accelerators []*Accelerator `protobuf:"bytes,6,rep,name=accelerators,proto3" json:"accelerators,omitempty"`
ServiceAccount *ServiceAccount `protobuf:"bytes,7,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
BootDiskSizeGb int32 `protobuf:"varint,8,opt,name=boot_disk_size_gb,json=bootDiskSizeGb,proto3" json:"boot_disk_size_gb,omitempty"`
CpuPlatform string `protobuf:"bytes,9,opt,name=cpu_platform,json=cpuPlatform,proto3" json:"cpu_platform,omitempty"`
BootImage string `protobuf:"bytes,10,opt,name=boot_image,json=bootImage,proto3" json:"boot_image,omitempty"`
NvidiaDriverVersion string `protobuf:"bytes,11,opt,name=nvidia_driver_version,json=nvidiaDriverVersion,proto3" json:"nvidia_driver_version,omitempty"`
EnableStackdriverMonitoring bool "" /* 146 byte string literal not displayed */
DockerCacheImages []string `protobuf:"bytes,13,rep,name=docker_cache_images,json=dockerCacheImages,proto3" json:"docker_cache_images,omitempty"`
Volumes []*Volume `protobuf:"bytes,14,rep,name=volumes,proto3" json:"volumes,omitempty"`
Reservation string `protobuf:"bytes,15,opt,name=reservation,proto3" json:"reservation,omitempty"`
}Carries information about a Compute Engine VM resource.
func (*VirtualMachine) Descriptor
func (*VirtualMachine) Descriptor() ([]byte, []int)Deprecated: Use VirtualMachine.ProtoReflect.Descriptor instead.
func (*VirtualMachine) GetAccelerators
func (x *VirtualMachine) GetAccelerators() []*Acceleratorfunc (*VirtualMachine) GetBootDiskSizeGb
func (x *VirtualMachine) GetBootDiskSizeGb() int32func (*VirtualMachine) GetBootImage
func (x *VirtualMachine) GetBootImage() stringfunc (*VirtualMachine) GetCpuPlatform
func (x *VirtualMachine) GetCpuPlatform() stringfunc (*VirtualMachine) GetDisks
func (x *VirtualMachine) GetDisks() []*Diskfunc (*VirtualMachine) GetDockerCacheImages
func (x *VirtualMachine) GetDockerCacheImages() []stringfunc (*VirtualMachine) GetEnableStackdriverMonitoring
func (x *VirtualMachine) GetEnableStackdriverMonitoring() boolfunc (*VirtualMachine) GetLabels
func (x *VirtualMachine) GetLabels() map[string]stringfunc (*VirtualMachine) GetMachineType
func (x *VirtualMachine) GetMachineType() stringfunc (*VirtualMachine) GetNetwork
func (x *VirtualMachine) GetNetwork() *Networkfunc (*VirtualMachine) GetNvidiaDriverVersion
func (x *VirtualMachine) GetNvidiaDriverVersion() stringDeprecated: Marked as deprecated in google/cloud/lifesciences/v2beta/workflows.proto.
func (*VirtualMachine) GetPreemptible
func (x *VirtualMachine) GetPreemptible() boolfunc (*VirtualMachine) GetReservation
func (x *VirtualMachine) GetReservation() stringfunc (*VirtualMachine) GetServiceAccount
func (x *VirtualMachine) GetServiceAccount() *ServiceAccountfunc (*VirtualMachine) GetVolumes
func (x *VirtualMachine) GetVolumes() []*Volumefunc (*VirtualMachine) ProtoMessage
func (*VirtualMachine) ProtoMessage()func (*VirtualMachine) ProtoReflect
func (x *VirtualMachine) ProtoReflect() protoreflect.Messagefunc (*VirtualMachine) Reset
func (x *VirtualMachine) Reset()func (*VirtualMachine) String
func (x *VirtualMachine) String() stringVolume
type Volume struct {
// A user-supplied name for the volume. Used when mounting the volume into
// [`Actions`][google.cloud.lifesciences.v2beta.Action]. The name must contain
// only upper and lowercase alphanumeric characters and hyphens and cannot
// start with a hyphen.
Volume string `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"`
// Types that are assignable to Storage:
//
// *Volume_PersistentDisk
// *Volume_ExistingDisk
// *Volume_NfsMount
Storage isVolume_Storage `protobuf_oneof:"storage"`
// contains filtered or unexported fields
}Carries information about storage that can be attached to a VM.
Specify either [Volume][google.cloud.lifesciences.v2beta.Volume] or
[Disk][google.cloud.lifesciences.v2beta.Disk], but not both.
func (*Volume) Descriptor
Deprecated: Use Volume.ProtoReflect.Descriptor instead.
func (*Volume) GetExistingDisk
func (x *Volume) GetExistingDisk() *ExistingDiskfunc (*Volume) GetNfsMount
func (*Volume) GetPersistentDisk
func (x *Volume) GetPersistentDisk() *PersistentDiskfunc (*Volume) GetStorage
func (m *Volume) GetStorage() isVolume_Storagefunc (*Volume) GetVolume
func (*Volume) ProtoMessage
func (*Volume) ProtoMessage()func (*Volume) ProtoReflect
func (x *Volume) ProtoReflect() protoreflect.Messagefunc (*Volume) Reset
func (x *Volume) Reset()func (*Volume) String
Volume_ExistingDisk
type Volume_ExistingDisk struct {
// Configuration for a existing disk.
ExistingDisk *ExistingDisk `protobuf:"bytes,3,opt,name=existing_disk,json=existingDisk,proto3,oneof"`
}Volume_NfsMount
type Volume_NfsMount struct {
// Configuration for an NFS mount.
NfsMount *NFSMount `protobuf:"bytes,4,opt,name=nfs_mount,json=nfsMount,proto3,oneof"`
}Volume_PersistentDisk
type Volume_PersistentDisk struct {
// Configuration for a persistent disk.
PersistentDisk *PersistentDisk `protobuf:"bytes,2,opt,name=persistent_disk,json=persistentDisk,proto3,oneof"`
}WorkerAssignedEvent
type WorkerAssignedEvent struct {
// The zone the worker is running in.
Zone string `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"`
// The worker's instance name.
Instance string `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
// The machine type that was assigned for the worker.
MachineType string `protobuf:"bytes,3,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
// contains filtered or unexported fields
}An event generated after a worker VM has been assigned to run the pipeline.
func (*WorkerAssignedEvent) Descriptor
func (*WorkerAssignedEvent) Descriptor() ([]byte, []int)Deprecated: Use WorkerAssignedEvent.ProtoReflect.Descriptor instead.
func (*WorkerAssignedEvent) GetInstance
func (x *WorkerAssignedEvent) GetInstance() stringfunc (*WorkerAssignedEvent) GetMachineType
func (x *WorkerAssignedEvent) GetMachineType() stringfunc (*WorkerAssignedEvent) GetZone
func (x *WorkerAssignedEvent) GetZone() stringfunc (*WorkerAssignedEvent) ProtoMessage
func (*WorkerAssignedEvent) ProtoMessage()func (*WorkerAssignedEvent) ProtoReflect
func (x *WorkerAssignedEvent) ProtoReflect() protoreflect.Messagefunc (*WorkerAssignedEvent) Reset
func (x *WorkerAssignedEvent) Reset()func (*WorkerAssignedEvent) String
func (x *WorkerAssignedEvent) String() stringWorkerReleasedEvent
type WorkerReleasedEvent struct {
// The zone the worker was running in.
Zone string `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"`
// The worker's instance name.
Instance string `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
// contains filtered or unexported fields
}An event generated when the worker VM that was assigned to the pipeline has been released (deleted).
func (*WorkerReleasedEvent) Descriptor
func (*WorkerReleasedEvent) Descriptor() ([]byte, []int)Deprecated: Use WorkerReleasedEvent.ProtoReflect.Descriptor instead.
func (*WorkerReleasedEvent) GetInstance
func (x *WorkerReleasedEvent) GetInstance() stringfunc (*WorkerReleasedEvent) GetZone
func (x *WorkerReleasedEvent) GetZone() stringfunc (*WorkerReleasedEvent) ProtoMessage
func (*WorkerReleasedEvent) ProtoMessage()func (*WorkerReleasedEvent) ProtoReflect
func (x *WorkerReleasedEvent) ProtoReflect() protoreflect.Messagefunc (*WorkerReleasedEvent) Reset
func (x *WorkerReleasedEvent) Reset()func (*WorkerReleasedEvent) String
func (x *WorkerReleasedEvent) String() stringWorkflowsServiceV2BetaClient
type WorkflowsServiceV2BetaClient interface {
// Runs a pipeline. The returned Operation's [metadata]
// [google.longrunning.Operation.metadata] field will contain a
// [google.cloud.lifesciences.v2beta.Metadata][google.cloud.lifesciences.v2beta.Metadata]
// object describing the status of the pipeline execution. The
// [response][google.longrunning.Operation.response] field will contain a
// [google.cloud.lifesciences.v2beta.RunPipelineResponse][google.cloud.lifesciences.v2beta.RunPipelineResponse]
// object if the pipeline completes successfully.
//
// **Note:** Before you can use this method, the *Life Sciences Service Agent*
// must have access to your project. This is done automatically when the
// Cloud Life Sciences API is first enabled, but if you delete this permission
// you must disable and re-enable the API to grant the Life Sciences
// Service Agent the required permissions.
// Authorization requires the following [Google
// IAM](https://cloud.google.com/iam/) permission:
//
// * `lifesciences.workflows.run`
RunPipeline(ctx context.Context, in *RunPipelineRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
}WorkflowsServiceV2BetaClient is the client API for WorkflowsServiceV2Beta service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewWorkflowsServiceV2BetaClient
func NewWorkflowsServiceV2BetaClient(cc grpc.ClientConnInterface) WorkflowsServiceV2BetaClientWorkflowsServiceV2BetaServer
type WorkflowsServiceV2BetaServer interface {
// Runs a pipeline. The returned Operation's [metadata]
// [google.longrunning.Operation.metadata] field will contain a
// [google.cloud.lifesciences.v2beta.Metadata][google.cloud.lifesciences.v2beta.Metadata]
// object describing the status of the pipeline execution. The
// [response][google.longrunning.Operation.response] field will contain a
// [google.cloud.lifesciences.v2beta.RunPipelineResponse][google.cloud.lifesciences.v2beta.RunPipelineResponse]
// object if the pipeline completes successfully.
//
// **Note:** Before you can use this method, the *Life Sciences Service Agent*
// must have access to your project. This is done automatically when the
// Cloud Life Sciences API is first enabled, but if you delete this permission
// you must disable and re-enable the API to grant the Life Sciences
// Service Agent the required permissions.
// Authorization requires the following [Google
// IAM](https://cloud.google.com/iam/) permission:
//
// * `lifesciences.workflows.run`
RunPipeline(context.Context, *RunPipelineRequest) (*longrunningpb.Operation, error)
}WorkflowsServiceV2BetaServer is the server API for WorkflowsServiceV2Beta service.