batchv1

package
v1.36.11-2024050211440... Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: unknown License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const AllocationPolicy_AttachedDisk_Attached_not_set_case case_AllocationPolicy_AttachedDisk_Attached = 0
View Source 
const AllocationPolicy_AttachedDisk_ExistingDisk_case case_AllocationPolicy_AttachedDisk_Attached = 2
View Source 
const AllocationPolicy_AttachedDisk_NewDisk_case case_AllocationPolicy_AttachedDisk_Attached = 1
View Source 
const AllocationPolicy_Disk_DataSource_not_set_case case_AllocationPolicy_Disk_DataSource = 0
View Source 
const AllocationPolicy_Disk_Image_case case_AllocationPolicy_Disk_DataSource = 4
View Source 
const AllocationPolicy_Disk_Snapshot_case case_AllocationPolicy_Disk_DataSource = 5
View Source 
const AllocationPolicy_InstancePolicyOrTemplate_InstanceTemplate_case case_AllocationPolicy_InstancePolicyOrTemplate_PolicyTemplate = 2
View Source 
const AllocationPolicy_InstancePolicyOrTemplate_PolicyTemplate_not_set_case case_AllocationPolicy_InstancePolicyOrTemplate_PolicyTemplate = 0
View Source 
const AllocationPolicy_InstancePolicyOrTemplate_Policy_case case_AllocationPolicy_InstancePolicyOrTemplate_PolicyTemplate = 1
View Source 
const Runnable_Barrier_case case_Runnable_Executable = 6
View Source 
const Runnable_Container_case case_Runnable_Executable = 1
View Source 
const Runnable_Executable_not_set_case case_Runnable_Executable = 0
View Source 
const Runnable_Script_Command_not_set_case case_Runnable_Script_Command = 0
View Source 
const Runnable_Script_Path_case case_Runnable_Script_Command = 1
View Source 
const Runnable_Script_Text_case case_Runnable_Script_Command = 2
View Source 
const Runnable_Script_case case_Runnable_Executable = 2
View Source 
const Volume_DeviceName_case case_Volume_Source = 6
View Source 
const Volume_Gcs_case case_Volume_Source = 3
View Source 
const Volume_Nfs_case case_Volume_Source = 1
View Source 
const Volume_Source_not_set_case case_Volume_Source = 0

Variables

View Source 
var (
	TaskStatus_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "PENDING",
		2: "ASSIGNED",
		3: "RUNNING",
		4: "FAILED",
		5: "SUCCEEDED",
		6: "UNEXECUTED",
	}
	TaskStatus_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"PENDING":           1,
		"ASSIGNED":          2,
		"RUNNING":           3,
		"FAILED":            4,
		"SUCCEEDED":         5,
		"UNEXECUTED":        6,
	}
)

Enum value maps for TaskStatus_State.

View Source 
var (
	LifecyclePolicy_Action_name = map[int32]string{
		0: "ACTION_UNSPECIFIED",
		1: "RETRY_TASK",
		2: "FAIL_TASK",
	}
	LifecyclePolicy_Action_value = map[string]int32{
		"ACTION_UNSPECIFIED": 0,
		"RETRY_TASK":         1,
		"FAIL_TASK":          2,
	}
)

Enum value maps for LifecyclePolicy_Action.

View Source 
var (
	LogsPolicy_Destination_name = map[int32]string{
		0: "DESTINATION_UNSPECIFIED",
		1: "CLOUD_LOGGING",
		2: "PATH",
	}
	LogsPolicy_Destination_value = map[string]int32{
		"DESTINATION_UNSPECIFIED": 0,
		"CLOUD_LOGGING":           1,
		"PATH":                    2,
	}
)

Enum value maps for LogsPolicy_Destination.

View Source 
var (
	JobStatus_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "QUEUED",
		2: "SCHEDULED",
		3: "RUNNING",
		4: "SUCCEEDED",
		5: "FAILED",
		6: "DELETION_IN_PROGRESS",
	}
	JobStatus_State_value = map[string]int32{
		"STATE_UNSPECIFIED":    0,
		"QUEUED":               1,
		"SCHEDULED":            2,
		"RUNNING":              3,
		"SUCCEEDED":            4,
		"FAILED":               5,
		"DELETION_IN_PROGRESS": 6,
	}
)

Enum value maps for JobStatus_State.

View Source 
var (
	JobNotification_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "JOB_STATE_CHANGED",
		2: "TASK_STATE_CHANGED",
	}
	JobNotification_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED":   0,
		"JOB_STATE_CHANGED":  1,
		"TASK_STATE_CHANGED": 2,
	}
)

Enum value maps for JobNotification_Type.

View Source 
var (
	AllocationPolicy_ProvisioningModel_name = map[int32]string{
		0: "PROVISIONING_MODEL_UNSPECIFIED",
		1: "STANDARD",
		2: "SPOT",
		3: "PREEMPTIBLE",
	}
	AllocationPolicy_ProvisioningModel_value = map[string]int32{
		"PROVISIONING_MODEL_UNSPECIFIED": 0,
		"STANDARD":                       1,
		"SPOT":                           2,
		"PREEMPTIBLE":                    3,
	}
)

Enum value maps for AllocationPolicy_ProvisioningModel.

View Source 
var (
	TaskGroup_SchedulingPolicy_name = map[int32]string{
		0: "SCHEDULING_POLICY_UNSPECIFIED",
		1: "AS_SOON_AS_POSSIBLE",
		2: "IN_ORDER",
	}
	TaskGroup_SchedulingPolicy_value = map[string]int32{
		"SCHEDULING_POLICY_UNSPECIFIED": 0,
		"AS_SOON_AS_POSSIBLE":           1,
		"IN_ORDER":                      2,
	}
)

Enum value maps for TaskGroup_SchedulingPolicy.

View Source 
var File_google_events_cloud_batch_v1_data_proto protoreflect.FileDescriptor
View Source 
var File_google_events_cloud_batch_v1_events_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AllocationPolicy 

type AllocationPolicy struct {

	// Location where compute resources should be allocated for the Job.
	Location *AllocationPolicy_LocationPolicy `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// Describe instances that can be created by this AllocationPolicy.
	// Only instances[0] is supported now.
	Instances []*AllocationPolicy_InstancePolicyOrTemplate `protobuf:"bytes,8,rep,name=instances,proto3" json:"instances,omitempty"`
	// Service account that VMs will run as.
	ServiceAccount *ServiceAccount `protobuf:"bytes,9,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// Labels applied to all VM instances and other resources
	// created by AllocationPolicy.
	// Labels could be user provided or system generated.
	// You can assign up to 64 labels. [Google Compute Engine label
	// restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions)
	// apply.
	// Label names that start with "goog-" or "google-" are reserved.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// The network policy.
	Network *AllocationPolicy_NetworkPolicy `protobuf:"bytes,7,opt,name=network,proto3" json:"network,omitempty"`
	// The placement policy.
	Placement *AllocationPolicy_PlacementPolicy `protobuf:"bytes,10,opt,name=placement,proto3" json:"placement,omitempty"`
	// contains filtered or unexported fields
}

A Job's resource allocation policy describes when, where, and how compute resources should be allocated for the Job.

func (*AllocationPolicy) ClearLocation 

func (x *AllocationPolicy) ClearLocation()

func (*AllocationPolicy) ClearNetwork 

func (x *AllocationPolicy) ClearNetwork()

func (*AllocationPolicy) ClearPlacement 

func (x *AllocationPolicy) ClearPlacement()

func (*AllocationPolicy) ClearServiceAccount 

func (x *AllocationPolicy) ClearServiceAccount()

func (*AllocationPolicy) GetInstances 

func (x *AllocationPolicy) GetInstances() []*AllocationPolicy_InstancePolicyOrTemplate

func (*AllocationPolicy) GetLabels 

func (x *AllocationPolicy) GetLabels() map[string]string

func (*AllocationPolicy) GetLocation 

func (x *AllocationPolicy) GetLocation() *AllocationPolicy_LocationPolicy

func (*AllocationPolicy) GetNetwork 

func (x *AllocationPolicy) GetNetwork() *AllocationPolicy_NetworkPolicy

func (*AllocationPolicy) GetPlacement 

func (x *AllocationPolicy) GetPlacement() *AllocationPolicy_PlacementPolicy

func (*AllocationPolicy) GetServiceAccount 

func (x *AllocationPolicy) GetServiceAccount() *ServiceAccount

func (*AllocationPolicy) HasLocation 

func (x *AllocationPolicy) HasLocation() bool

func (*AllocationPolicy) HasNetwork 

func (x *AllocationPolicy) HasNetwork() bool

func (*AllocationPolicy) HasPlacement 

func (x *AllocationPolicy) HasPlacement() bool

func (*AllocationPolicy) HasServiceAccount 

func (x *AllocationPolicy) HasServiceAccount() bool

func (*AllocationPolicy) ProtoMessage 

func (*AllocationPolicy) ProtoMessage()

func (*AllocationPolicy) ProtoReflect 

func (x *AllocationPolicy) ProtoReflect() protoreflect.Message

func (*AllocationPolicy) Reset 

func (x *AllocationPolicy) Reset()

func (*AllocationPolicy) SetInstances 

func (x *AllocationPolicy) SetInstances(v []*AllocationPolicy_InstancePolicyOrTemplate)

func (*AllocationPolicy) SetLabels 

func (x *AllocationPolicy) SetLabels(v map[string]string)

func (*AllocationPolicy) SetLocation 

func (x *AllocationPolicy) SetLocation(v *AllocationPolicy_LocationPolicy)

func (*AllocationPolicy) SetNetwork 

func (x *AllocationPolicy) SetNetwork(v *AllocationPolicy_NetworkPolicy)

func (*AllocationPolicy) SetPlacement 

func (x *AllocationPolicy) SetPlacement(v *AllocationPolicy_PlacementPolicy)

func (*AllocationPolicy) SetServiceAccount 

func (x *AllocationPolicy) SetServiceAccount(v *ServiceAccount)

func (*AllocationPolicy) String 

func (x *AllocationPolicy) String() string

type AllocationPolicy_Accelerator 

type AllocationPolicy_Accelerator struct {

	// The accelerator type. For example, "nvidia-tesla-t4".
	// See `gcloud compute accelerator-types list`.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// The number of accelerators of this type.
	Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// Deprecated: please use instances[0].install_gpu_drivers instead.
	InstallGpuDrivers bool `protobuf:"varint,3,opt,name=install_gpu_drivers,json=installGpuDrivers,proto3" json:"install_gpu_drivers,omitempty"`
	// contains filtered or unexported fields
}

Accelerator describes Compute Engine accelerators to be attached to the VM.

func (*AllocationPolicy_Accelerator) GetCount 

func (x *AllocationPolicy_Accelerator) GetCount() int64

func (*AllocationPolicy_Accelerator) GetInstallGpuDrivers 

func (x *AllocationPolicy_Accelerator) GetInstallGpuDrivers() bool

func (*AllocationPolicy_Accelerator) GetType 

func (x *AllocationPolicy_Accelerator) GetType() string

func (*AllocationPolicy_Accelerator) ProtoMessage 

func (*AllocationPolicy_Accelerator) ProtoMessage()

func (*AllocationPolicy_Accelerator) ProtoReflect 

func (x *AllocationPolicy_Accelerator) ProtoReflect() protoreflect.Message

func (*AllocationPolicy_Accelerator) Reset 

func (x *AllocationPolicy_Accelerator) Reset()

func (*AllocationPolicy_Accelerator) SetCount 

func (x *AllocationPolicy_Accelerator) SetCount(v int64)

func (*AllocationPolicy_Accelerator) SetInstallGpuDrivers 

func (x *AllocationPolicy_Accelerator) SetInstallGpuDrivers(v bool)

func (*AllocationPolicy_Accelerator) SetType 

func (x *AllocationPolicy_Accelerator) SetType(v string)

func (*AllocationPolicy_Accelerator) String 

func (x *AllocationPolicy_Accelerator) String() string

type AllocationPolicy_Accelerator_builder 

type AllocationPolicy_Accelerator_builder struct {

	// The accelerator type. For example, "nvidia-tesla-t4".
	// See `gcloud compute accelerator-types list`.
	Type string
	// The number of accelerators of this type.
	Count int64
	// Deprecated: please use instances[0].install_gpu_drivers instead.
	InstallGpuDrivers bool
	// contains filtered or unexported fields
}

func (AllocationPolicy_Accelerator_builder) Build 

func (b0 AllocationPolicy_Accelerator_builder) Build() *AllocationPolicy_Accelerator

type AllocationPolicy_AttachedDisk 

type AllocationPolicy_AttachedDisk struct {

	// Types that are valid to be assigned to Attached:
	//
	//	*AllocationPolicy_AttachedDisk_NewDisk
	//	*AllocationPolicy_AttachedDisk_ExistingDisk
	Attached isAllocationPolicy_AttachedDisk_Attached `protobuf_oneof:"attached"`
	// Device name that the guest operating system will see.
	// It is used by Runnable.volumes field to mount disks. So please specify
	// the device_name if you want Batch to help mount the disk, and it should
	// match the device_name field in volumes.
	DeviceName string `protobuf:"bytes,3,opt,name=device_name,json=deviceName,proto3" json:"device_name,omitempty"`
	// contains filtered or unexported fields
}

A new or an existing persistent disk (PD) or a local ssd attached to a VM instance.

func (*AllocationPolicy_AttachedDisk) ClearAttached 

func (x *AllocationPolicy_AttachedDisk) ClearAttached()

func (*AllocationPolicy_AttachedDisk) ClearExistingDisk 

func (x *AllocationPolicy_AttachedDisk) ClearExistingDisk()

func (*AllocationPolicy_AttachedDisk) ClearNewDisk 

func (x *AllocationPolicy_AttachedDisk) ClearNewDisk()

func (*AllocationPolicy_AttachedDisk) GetAttached 

func (x *AllocationPolicy_AttachedDisk) GetAttached() isAllocationPolicy_AttachedDisk_Attached

func (*AllocationPolicy_AttachedDisk) GetDeviceName 

func (x *AllocationPolicy_AttachedDisk) GetDeviceName() string

func (*AllocationPolicy_AttachedDisk) GetExistingDisk 

func (x *AllocationPolicy_AttachedDisk) GetExistingDisk() string

func (*AllocationPolicy_AttachedDisk) GetNewDisk 

func (x *AllocationPolicy_AttachedDisk) GetNewDisk() *AllocationPolicy_Disk

func (*AllocationPolicy_AttachedDisk) HasAttached 

func (x *AllocationPolicy_AttachedDisk) HasAttached() bool

func (*AllocationPolicy_AttachedDisk) HasExistingDisk 

func (x *AllocationPolicy_AttachedDisk) HasExistingDisk() bool

func (*AllocationPolicy_AttachedDisk) HasNewDisk 

func (x *AllocationPolicy_AttachedDisk) HasNewDisk() bool

func (*AllocationPolicy_AttachedDisk) ProtoMessage 

func (*AllocationPolicy_AttachedDisk) ProtoMessage()

func (*AllocationPolicy_AttachedDisk) ProtoReflect 

func (x *AllocationPolicy_AttachedDisk) ProtoReflect() protoreflect.Message

func (*AllocationPolicy_AttachedDisk) Reset 

func (x *AllocationPolicy_AttachedDisk) Reset()

func (*AllocationPolicy_AttachedDisk) SetDeviceName 

func (x *AllocationPolicy_AttachedDisk) SetDeviceName(v string)

func (*AllocationPolicy_AttachedDisk) SetExistingDisk 

func (x *AllocationPolicy_AttachedDisk) SetExistingDisk(v string)

func (*AllocationPolicy_AttachedDisk) SetNewDisk 

func (x *AllocationPolicy_AttachedDisk) SetNewDisk(v *AllocationPolicy_Disk)

func (*AllocationPolicy_AttachedDisk) String 

func (x *AllocationPolicy_AttachedDisk) String() string

func (*AllocationPolicy_AttachedDisk) WhichAttached 

func (x *AllocationPolicy_AttachedDisk) WhichAttached() case_AllocationPolicy_AttachedDisk_Attached

type AllocationPolicy_AttachedDisk_ExistingDisk 

type AllocationPolicy_AttachedDisk_ExistingDisk struct {
	// Name of an existing PD.
	ExistingDisk string `protobuf:"bytes,2,opt,name=existing_disk,json=existingDisk,proto3,oneof"`
}

type AllocationPolicy_AttachedDisk_NewDisk 

type AllocationPolicy_AttachedDisk_NewDisk struct {
	NewDisk *AllocationPolicy_Disk `protobuf:"bytes,1,opt,name=new_disk,json=newDisk,proto3,oneof"`
}

type AllocationPolicy_AttachedDisk_builder 

type AllocationPolicy_AttachedDisk_builder struct {

	// Fields of oneof Attached:
	NewDisk *AllocationPolicy_Disk
	// Name of an existing PD.
	ExistingDisk *string
	// -- end of Attached
	// Device name that the guest operating system will see.
	// It is used by Runnable.volumes field to mount disks. So please specify
	// the device_name if you want Batch to help mount the disk, and it should
	// match the device_name field in volumes.
	DeviceName string
	// contains filtered or unexported fields
}

func (AllocationPolicy_AttachedDisk_builder) Build 

func (b0 AllocationPolicy_AttachedDisk_builder) Build() *AllocationPolicy_AttachedDisk

type AllocationPolicy_Disk 

type AllocationPolicy_Disk struct {

	// A data source from which a PD will be created.
	//
	// Types that are valid to be assigned to DataSource:
	//
	//	*AllocationPolicy_Disk_Image
	//	*AllocationPolicy_Disk_Snapshot
	DataSource isAllocationPolicy_Disk_DataSource `protobuf_oneof:"data_source"`
	// Disk type as shown in `gcloud compute disk-types list`.
	// For example, local SSD uses type "local-ssd".
	// Persistent disks and boot disks use "pd-balanced", "pd-extreme", "pd-ssd"
	// or "pd-standard".
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Disk size in GB.
	//
	// For persistent disk, this field is ignored if `data_source` is `image` or
	// `snapshot`.
	// For local SSD, size_gb should be a multiple of 375GB,
	// otherwise, the final size will be the next greater multiple of 375 GB.
	// For boot disk, Batch will calculate the boot disk size based on source
	// image and task requirements if you do not speicify the size.
	// If both this field and the boot_disk_mib field in task spec's
	// compute_resource are defined, Batch will only honor this field.
	SizeGb int64 `protobuf:"varint,2,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"`
	// Local SSDs are available through both "SCSI" and "NVMe" interfaces.
	// If not indicated, "NVMe" will be the default one for local ssds.
	// We only support "SCSI" for persistent disks now.
	DiskInterface string `protobuf:"bytes,6,opt,name=disk_interface,json=diskInterface,proto3" json:"disk_interface,omitempty"`
	// contains filtered or unexported fields
}

A new persistent disk or a local ssd. A VM can only have one local SSD setting but multiple local SSD partitions. See https://cloud.google.com/compute/docs/disks#pdspecs and https://cloud.google.com/compute/docs/disks#localssds.

func (*AllocationPolicy_Disk) ClearDataSource 

func (x *AllocationPolicy_Disk) ClearDataSource()

func (*AllocationPolicy_Disk) ClearImage 

func (x *AllocationPolicy_Disk) ClearImage()

func (*AllocationPolicy_Disk) ClearSnapshot 

func (x *AllocationPolicy_Disk) ClearSnapshot()

func (*AllocationPolicy_Disk) GetDataSource 

func (x *AllocationPolicy_Disk) GetDataSource() isAllocationPolicy_Disk_DataSource

func (*AllocationPolicy_Disk) GetDiskInterface 

func (x *AllocationPolicy_Disk) GetDiskInterface() string

func (*AllocationPolicy_Disk) GetImage 

func (x *AllocationPolicy_Disk) GetImage() string

func (*AllocationPolicy_Disk) GetSizeGb 

func (x *AllocationPolicy_Disk) GetSizeGb() int64

func (*AllocationPolicy_Disk) GetSnapshot 

func (x *AllocationPolicy_Disk) GetSnapshot() string

func (*AllocationPolicy_Disk) GetType 

func (x *AllocationPolicy_Disk) GetType() string

func (*AllocationPolicy_Disk) HasDataSource 

func (x *AllocationPolicy_Disk) HasDataSource() bool

func (*AllocationPolicy_Disk) HasImage 

func (x *AllocationPolicy_Disk) HasImage() bool

func (*AllocationPolicy_Disk) HasSnapshot 

func (x *AllocationPolicy_Disk) HasSnapshot() bool

func (*AllocationPolicy_Disk) ProtoMessage 

func (*AllocationPolicy_Disk) ProtoMessage()

func (*AllocationPolicy_Disk) ProtoReflect 

func (x *AllocationPolicy_Disk) ProtoReflect() protoreflect.Message

func (*AllocationPolicy_Disk) Reset 

func (x *AllocationPolicy_Disk) Reset()

func (*AllocationPolicy_Disk) SetDiskInterface 

func (x *AllocationPolicy_Disk) SetDiskInterface(v string)

func (*AllocationPolicy_Disk) SetImage 

func (x *AllocationPolicy_Disk) SetImage(v string)

func (*AllocationPolicy_Disk) SetSizeGb 

func (x *AllocationPolicy_Disk) SetSizeGb(v int64)

func (*AllocationPolicy_Disk) SetSnapshot 

func (x *AllocationPolicy_Disk) SetSnapshot(v string)

func (*AllocationPolicy_Disk) SetType 

func (x *AllocationPolicy_Disk) SetType(v string)

func (*AllocationPolicy_Disk) String 

func (x *AllocationPolicy_Disk) String() string

func (*AllocationPolicy_Disk) WhichDataSource 

func (x *AllocationPolicy_Disk) WhichDataSource() case_AllocationPolicy_Disk_DataSource

type AllocationPolicy_Disk_Image 

type AllocationPolicy_Disk_Image struct {
	// Name of a public or custom image used as the data source.
	// For example, the following are all valid URLs:
	//
	// * Specify the image by its family name:
	// projects/{project}/global/images/family/{image_family}
	// * Specify the image version:
	// projects/{project}/global/images/{image_version}
	//
	// You can also use Batch customized image in short names.
	// The following image values are supported for a boot disk:
	//
	// * "batch-debian": use Batch Debian images.
	// * "batch-centos": use Batch CentOS images.
	// * "batch-cos": use Batch Container-Optimized images.
	// * "batch-hpc-centos": use Batch HPC CentOS images.
	Image string `protobuf:"bytes,4,opt,name=image,proto3,oneof"`
}

type AllocationPolicy_Disk_Snapshot 

type AllocationPolicy_Disk_Snapshot struct {
	// Name of a snapshot used as the data source.
	// Snapshot is not supported as boot disk now.
	Snapshot string `protobuf:"bytes,5,opt,name=snapshot,proto3,oneof"`
}

type AllocationPolicy_Disk_builder 

type AllocationPolicy_Disk_builder struct {

	// Fields of oneof DataSource:
	// Name of a public or custom image used as the data source.
	// For example, the following are all valid URLs:
	//
	// * Specify the image by its family name:
	// projects/{project}/global/images/family/{image_family}
	// * Specify the image version:
	// projects/{project}/global/images/{image_version}
	//
	// You can also use Batch customized image in short names.
	// The following image values are supported for a boot disk:
	//
	// * "batch-debian": use Batch Debian images.
	// * "batch-centos": use Batch CentOS images.
	// * "batch-cos": use Batch Container-Optimized images.
	// * "batch-hpc-centos": use Batch HPC CentOS images.
	Image *string
	// Name of a snapshot used as the data source.
	// Snapshot is not supported as boot disk now.
	Snapshot *string
	// -- end of DataSource
	// Disk type as shown in `gcloud compute disk-types list`.
	// For example, local SSD uses type "local-ssd".
	// Persistent disks and boot disks use "pd-balanced", "pd-extreme", "pd-ssd"
	// or "pd-standard".
	Type string
	// Disk size in GB.
	//
	// For persistent disk, this field is ignored if `data_source` is `image` or
	// `snapshot`.
	// For local SSD, size_gb should be a multiple of 375GB,
	// otherwise, the final size will be the next greater multiple of 375 GB.
	// For boot disk, Batch will calculate the boot disk size based on source
	// image and task requirements if you do not speicify the size.
	// If both this field and the boot_disk_mib field in task spec's
	// compute_resource are defined, Batch will only honor this field.
	SizeGb int64
	// Local SSDs are available through both "SCSI" and "NVMe" interfaces.
	// If not indicated, "NVMe" will be the default one for local ssds.
	// We only support "SCSI" for persistent disks now.
	DiskInterface string
	// contains filtered or unexported fields
}

func (AllocationPolicy_Disk_builder) Build 

func (b0 AllocationPolicy_Disk_builder) Build() *AllocationPolicy_Disk

type AllocationPolicy_InstancePolicy 

type AllocationPolicy_InstancePolicy struct {

	// The Compute Engine machine type.
	MachineType string `protobuf:"bytes,2,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
	// The minimum CPU platform.
	// See
	// https://cloud.google.com/compute/docs/instances/specify-min-cpu-platform.
	MinCpuPlatform string `protobuf:"bytes,3,opt,name=min_cpu_platform,json=minCpuPlatform,proto3" json:"min_cpu_platform,omitempty"`
	// The provisioning model.
	ProvisioningModel AllocationPolicy_ProvisioningModel `` /* 182-byte string literal not displayed */
	// The accelerators attached to each VM instance.
	Accelerators []*AllocationPolicy_Accelerator `protobuf:"bytes,5,rep,name=accelerators,proto3" json:"accelerators,omitempty"`
	// Boot disk to be created and attached to each VM by this InstancePolicy.
	// Boot disk will be deleted when the VM is deleted.
	// Batch API now only supports booting from image.
	BootDisk *AllocationPolicy_Disk `protobuf:"bytes,8,opt,name=boot_disk,json=bootDisk,proto3" json:"boot_disk,omitempty"`
	// Non-boot disks to be attached for each VM created by this InstancePolicy.
	// New disks will be deleted when the VM is deleted.
	Disks []*AllocationPolicy_AttachedDisk `protobuf:"bytes,6,rep,name=disks,proto3" json:"disks,omitempty"`
	// contains filtered or unexported fields
}

InstancePolicy describes an instance type and resources attached to each VM created by this InstancePolicy.

func (*AllocationPolicy_InstancePolicy) ClearBootDisk 

func (x *AllocationPolicy_InstancePolicy) ClearBootDisk()

func (*AllocationPolicy_InstancePolicy) GetAccelerators 

func (x *AllocationPolicy_InstancePolicy) GetAccelerators() []*AllocationPolicy_Accelerator

func (*AllocationPolicy_InstancePolicy) GetBootDisk 

func (x *AllocationPolicy_InstancePolicy) GetBootDisk() *AllocationPolicy_Disk

func (*AllocationPolicy_InstancePolicy) GetDisks 

func (x *AllocationPolicy_InstancePolicy) GetDisks() []*AllocationPolicy_AttachedDisk

func (*AllocationPolicy_InstancePolicy) GetMachineType 

func (x *AllocationPolicy_InstancePolicy) GetMachineType() string

func (*AllocationPolicy_InstancePolicy) GetMinCpuPlatform 

func (x *AllocationPolicy_InstancePolicy) GetMinCpuPlatform() string

func (*AllocationPolicy_InstancePolicy) GetProvisioningModel 

func (x *AllocationPolicy_InstancePolicy) GetProvisioningModel() AllocationPolicy_ProvisioningModel

func (*AllocationPolicy_InstancePolicy) HasBootDisk 

func (x *AllocationPolicy_InstancePolicy) HasBootDisk() bool

func (*AllocationPolicy_InstancePolicy) ProtoMessage 

func (*AllocationPolicy_InstancePolicy) ProtoMessage()

func (*AllocationPolicy_InstancePolicy) ProtoReflect 

func (x *AllocationPolicy_InstancePolicy) ProtoReflect() protoreflect.Message

func (*AllocationPolicy_InstancePolicy) Reset 

func (x *AllocationPolicy_InstancePolicy) Reset()

func (*AllocationPolicy_InstancePolicy) SetAccelerators 

func (x *AllocationPolicy_InstancePolicy) SetAccelerators(v []*AllocationPolicy_Accelerator)

func (*AllocationPolicy_InstancePolicy) SetBootDisk 

func (x *AllocationPolicy_InstancePolicy) SetBootDisk(v *AllocationPolicy_Disk)

func (*AllocationPolicy_InstancePolicy) SetDisks 

func (x *AllocationPolicy_InstancePolicy) SetDisks(v []*AllocationPolicy_AttachedDisk)

func (*AllocationPolicy_InstancePolicy) SetMachineType 

func (x *AllocationPolicy_InstancePolicy) SetMachineType(v string)

func (*AllocationPolicy_InstancePolicy) SetMinCpuPlatform 

func (x *AllocationPolicy_InstancePolicy) SetMinCpuPlatform(v string)

func (*AllocationPolicy_InstancePolicy) SetProvisioningModel 

func (x *AllocationPolicy_InstancePolicy) SetProvisioningModel(v AllocationPolicy_ProvisioningModel)

func (*AllocationPolicy_InstancePolicy) String 

func (x *AllocationPolicy_InstancePolicy) String() string

type AllocationPolicy_InstancePolicyOrTemplate 

type AllocationPolicy_InstancePolicyOrTemplate struct {

	// Types that are valid to be assigned to PolicyTemplate:
	//
	//	*AllocationPolicy_InstancePolicyOrTemplate_Policy
	//	*AllocationPolicy_InstancePolicyOrTemplate_InstanceTemplate
	PolicyTemplate isAllocationPolicy_InstancePolicyOrTemplate_PolicyTemplate `protobuf_oneof:"policy_template"`
	// Set this field true if users want Batch to help fetch drivers from a
	// third party location and install them for GPUs specified in
	// policy.accelerators or instance_template on their behalf. Default is
	// false.
	InstallGpuDrivers bool `protobuf:"varint,3,opt,name=install_gpu_drivers,json=installGpuDrivers,proto3" json:"install_gpu_drivers,omitempty"`
	// contains filtered or unexported fields
}

Either an InstancePolicy or an instance template.

func (*AllocationPolicy_InstancePolicyOrTemplate) ClearInstanceTemplate 

func (x *AllocationPolicy_InstancePolicyOrTemplate) ClearInstanceTemplate()

func (*AllocationPolicy_InstancePolicyOrTemplate) ClearPolicy 

func (x *AllocationPolicy_InstancePolicyOrTemplate) ClearPolicy()

func (*AllocationPolicy_InstancePolicyOrTemplate) ClearPolicyTemplate 

func (x *AllocationPolicy_InstancePolicyOrTemplate) ClearPolicyTemplate()

func (*AllocationPolicy_InstancePolicyOrTemplate) GetInstallGpuDrivers 

func (x *AllocationPolicy_InstancePolicyOrTemplate) GetInstallGpuDrivers() bool

func (*AllocationPolicy_InstancePolicyOrTemplate) GetInstanceTemplate 

func (x *AllocationPolicy_InstancePolicyOrTemplate) GetInstanceTemplate() string

func (*AllocationPolicy_InstancePolicyOrTemplate) GetPolicy 

func (x *AllocationPolicy_InstancePolicyOrTemplate) GetPolicy() *AllocationPolicy_InstancePolicy

func (*AllocationPolicy_InstancePolicyOrTemplate) GetPolicyTemplate 

func (x *AllocationPolicy_InstancePolicyOrTemplate) GetPolicyTemplate() isAllocationPolicy_InstancePolicyOrTemplate_PolicyTemplate

func (*AllocationPolicy_InstancePolicyOrTemplate) HasInstanceTemplate 

func (x *AllocationPolicy_InstancePolicyOrTemplate) HasInstanceTemplate() bool

func (*AllocationPolicy_InstancePolicyOrTemplate) HasPolicy 

func (x *AllocationPolicy_InstancePolicyOrTemplate) HasPolicy() bool

func (*AllocationPolicy_InstancePolicyOrTemplate) HasPolicyTemplate 

func (x *AllocationPolicy_InstancePolicyOrTemplate) HasPolicyTemplate() bool

func (*AllocationPolicy_InstancePolicyOrTemplate) ProtoMessage 

func (*AllocationPolicy_InstancePolicyOrTemplate) ProtoMessage()

func (*AllocationPolicy_InstancePolicyOrTemplate) ProtoReflect 

func (x *AllocationPolicy_InstancePolicyOrTemplate) ProtoReflect() protoreflect.Message

func (*AllocationPolicy_InstancePolicyOrTemplate) Reset 

func (x *AllocationPolicy_InstancePolicyOrTemplate) Reset()

func (*AllocationPolicy_InstancePolicyOrTemplate) SetInstallGpuDrivers 

func (x *AllocationPolicy_InstancePolicyOrTemplate) SetInstallGpuDrivers(v bool)

func (*AllocationPolicy_InstancePolicyOrTemplate) SetInstanceTemplate 

func (x *AllocationPolicy_InstancePolicyOrTemplate) SetInstanceTemplate(v string)

func (*AllocationPolicy_InstancePolicyOrTemplate) SetPolicy 

func (x *AllocationPolicy_InstancePolicyOrTemplate) SetPolicy(v *AllocationPolicy_InstancePolicy)

func (*AllocationPolicy_InstancePolicyOrTemplate) String 

func (x *AllocationPolicy_InstancePolicyOrTemplate) String() string

func (*AllocationPolicy_InstancePolicyOrTemplate) WhichPolicyTemplate 

func (x *AllocationPolicy_InstancePolicyOrTemplate) WhichPolicyTemplate() case_AllocationPolicy_InstancePolicyOrTemplate_PolicyTemplate

type AllocationPolicy_InstancePolicyOrTemplate_InstanceTemplate 

type AllocationPolicy_InstancePolicyOrTemplate_InstanceTemplate struct {
	// Name of an instance template used to create VMs.
	// Named the field as 'instance_template' instead of 'template' to avoid
	// c++ keyword conflict.
	InstanceTemplate string `protobuf:"bytes,2,opt,name=instance_template,json=instanceTemplate,proto3,oneof"`
}

type AllocationPolicy_InstancePolicyOrTemplate_Policy 

type AllocationPolicy_InstancePolicyOrTemplate_Policy struct {
	// InstancePolicy.
	Policy *AllocationPolicy_InstancePolicy `protobuf:"bytes,1,opt,name=policy,proto3,oneof"`
}

type AllocationPolicy_InstancePolicyOrTemplate_builder 

type AllocationPolicy_InstancePolicyOrTemplate_builder struct {

	// Fields of oneof PolicyTemplate:
	// InstancePolicy.
	Policy *AllocationPolicy_InstancePolicy
	// Name of an instance template used to create VMs.
	// Named the field as 'instance_template' instead of 'template' to avoid
	// c++ keyword conflict.
	InstanceTemplate *string
	// -- end of PolicyTemplate
	// Set this field true if users want Batch to help fetch drivers from a
	// third party location and install them for GPUs specified in
	// policy.accelerators or instance_template on their behalf. Default is
	// false.
	InstallGpuDrivers bool
	// contains filtered or unexported fields
}

func (AllocationPolicy_InstancePolicyOrTemplate_builder) Build 

func (b0 AllocationPolicy_InstancePolicyOrTemplate_builder) Build() *AllocationPolicy_InstancePolicyOrTemplate

type AllocationPolicy_InstancePolicy_builder 

type AllocationPolicy_InstancePolicy_builder struct {

	// The Compute Engine machine type.
	MachineType string
	// The minimum CPU platform.
	// See
	// https://cloud.google.com/compute/docs/instances/specify-min-cpu-platform.
	MinCpuPlatform string
	// The provisioning model.
	ProvisioningModel AllocationPolicy_ProvisioningModel
	// The accelerators attached to each VM instance.
	Accelerators []*AllocationPolicy_Accelerator
	// Boot disk to be created and attached to each VM by this InstancePolicy.
	// Boot disk will be deleted when the VM is deleted.
	// Batch API now only supports booting from image.
	BootDisk *AllocationPolicy_Disk
	// Non-boot disks to be attached for each VM created by this InstancePolicy.
	// New disks will be deleted when the VM is deleted.
	Disks []*AllocationPolicy_AttachedDisk
	// contains filtered or unexported fields
}

func (AllocationPolicy_InstancePolicy_builder) Build 

func (b0 AllocationPolicy_InstancePolicy_builder) Build() *AllocationPolicy_InstancePolicy

type AllocationPolicy_LocationPolicy 

type AllocationPolicy_LocationPolicy struct {

	// A list of allowed location names represented by internal URLs.
	//
	// Each location can be a region or a zone.
	// Only one region or multiple zones in one region is supported now.
	// For example,
	// ["regions/us-central1"] allow VMs in any zones in region us-central1.
	// ["zones/us-central1-a", "zones/us-central1-c"] only allow VMs
	// in zones us-central1-a and us-central1-c.
	//
	// All locations end up in different regions would cause errors.
	// For example,
	// ["regions/us-central1", "zones/us-central1-a", "zones/us-central1-b",
	// "zones/us-west1-a"] contains 2 regions "us-central1" and
	// "us-west1". An error is expected in this case.
	AllowedLocations []string `protobuf:"bytes,1,rep,name=allowed_locations,json=allowedLocations,proto3" json:"allowed_locations,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocationPolicy_LocationPolicy) GetAllowedLocations 

func (x *AllocationPolicy_LocationPolicy) GetAllowedLocations() []string

func (*AllocationPolicy_LocationPolicy) ProtoMessage 

func (*AllocationPolicy_LocationPolicy) ProtoMessage()

func (*AllocationPolicy_LocationPolicy) ProtoReflect 

func (x *AllocationPolicy_LocationPolicy) ProtoReflect() protoreflect.Message

func (*AllocationPolicy_LocationPolicy) Reset 

func (x *AllocationPolicy_LocationPolicy) Reset()

func (*AllocationPolicy_LocationPolicy) SetAllowedLocations 

func (x *AllocationPolicy_LocationPolicy) SetAllowedLocations(v []string)

func (*AllocationPolicy_LocationPolicy) String 

func (x *AllocationPolicy_LocationPolicy) String() string

type AllocationPolicy_LocationPolicy_builder 

type AllocationPolicy_LocationPolicy_builder struct {

	// A list of allowed location names represented by internal URLs.
	//
	// Each location can be a region or a zone.
	// Only one region or multiple zones in one region is supported now.
	// For example,
	// ["regions/us-central1"] allow VMs in any zones in region us-central1.
	// ["zones/us-central1-a", "zones/us-central1-c"] only allow VMs
	// in zones us-central1-a and us-central1-c.
	//
	// All locations end up in different regions would cause errors.
	// For example,
	// ["regions/us-central1", "zones/us-central1-a", "zones/us-central1-b",
	// "zones/us-west1-a"] contains 2 regions "us-central1" and
	// "us-west1". An error is expected in this case.
	AllowedLocations []string
	// contains filtered or unexported fields
}

func (AllocationPolicy_LocationPolicy_builder) Build 

func (b0 AllocationPolicy_LocationPolicy_builder) Build() *AllocationPolicy_LocationPolicy

type AllocationPolicy_NetworkInterface 

type AllocationPolicy_NetworkInterface struct {

	// The URL of an existing network resource.
	// You can specify the network as a full or partial URL.
	//
	// For example, the following are all valid URLs:
	//
	// * https://www.googleapis.com/compute/v1/projects/{project}/global/networks/{network}
	// * projects/{project}/global/networks/{network}
	// * global/networks/{network}
	Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
	// The URL of an existing subnetwork resource in the network.
	// You can specify the subnetwork as a full or partial URL.
	//
	// For example, the following are all valid URLs:
	//
	// * https://www.googleapis.com/compute/v1/projects/{project}/regions/{region}/subnetworks/{subnetwork}
	// * projects/{project}/regions/{region}/subnetworks/{subnetwork}
	// * regions/{region}/subnetworks/{subnetwork}
	Subnetwork string `protobuf:"bytes,2,opt,name=subnetwork,proto3" json:"subnetwork,omitempty"`
	// Default is false (with an external IP address). Required if
	// no external public IP address is attached to the VM. If no external
	// 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 and
	// https://cloud.google.com/nat/docs/gce-example#create-nat for more
	// information.
	NoExternalIpAddress bool `protobuf:"varint,3,opt,name=no_external_ip_address,json=noExternalIpAddress,proto3" json:"no_external_ip_address,omitempty"`
	// contains filtered or unexported fields
}

A network interface.

func (*AllocationPolicy_NetworkInterface) GetNetwork 

func (x *AllocationPolicy_NetworkInterface) GetNetwork() string

func (*AllocationPolicy_NetworkInterface) GetNoExternalIpAddress 

func (x *AllocationPolicy_NetworkInterface) GetNoExternalIpAddress() bool

func (*AllocationPolicy_NetworkInterface) GetSubnetwork 

func (x *AllocationPolicy_NetworkInterface) GetSubnetwork() string

func (*AllocationPolicy_NetworkInterface) ProtoMessage 

func (*AllocationPolicy_NetworkInterface) ProtoMessage()

func (*AllocationPolicy_NetworkInterface) ProtoReflect 

func (x *AllocationPolicy_NetworkInterface) ProtoReflect() protoreflect.Message

func (*AllocationPolicy_NetworkInterface) Reset 

func (x *AllocationPolicy_NetworkInterface) Reset()

func (*AllocationPolicy_NetworkInterface) SetNetwork 

func (x *AllocationPolicy_NetworkInterface) SetNetwork(v string)

func (*AllocationPolicy_NetworkInterface) SetNoExternalIpAddress 

func (x *AllocationPolicy_NetworkInterface) SetNoExternalIpAddress(v bool)

func (*AllocationPolicy_NetworkInterface) SetSubnetwork 

func (x *AllocationPolicy_NetworkInterface) SetSubnetwork(v string)

func (*AllocationPolicy_NetworkInterface) String 

func (x *AllocationPolicy_NetworkInterface) String() string

type AllocationPolicy_NetworkInterface_builder 

type AllocationPolicy_NetworkInterface_builder struct {

	// The URL of an existing network resource.
	// You can specify the network as a full or partial URL.
	//
	// For example, the following are all valid URLs:
	//
	// * https://www.googleapis.com/compute/v1/projects/{project}/global/networks/{network}
	// * projects/{project}/global/networks/{network}
	// * global/networks/{network}
	Network string
	// The URL of an existing subnetwork resource in the network.
	// You can specify the subnetwork as a full or partial URL.
	//
	// For example, the following are all valid URLs:
	//
	// * https://www.googleapis.com/compute/v1/projects/{project}/regions/{region}/subnetworks/{subnetwork}
	// * projects/{project}/regions/{region}/subnetworks/{subnetwork}
	// * regions/{region}/subnetworks/{subnetwork}
	Subnetwork string
	// Default is false (with an external IP address). Required if
	// no external public IP address is attached to the VM. If no external
	// 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 and
	// https://cloud.google.com/nat/docs/gce-example#create-nat for more
	// information.
	NoExternalIpAddress bool
	// contains filtered or unexported fields
}

func (AllocationPolicy_NetworkInterface_builder) Build 

func (b0 AllocationPolicy_NetworkInterface_builder) Build() *AllocationPolicy_NetworkInterface

type AllocationPolicy_NetworkPolicy 

type AllocationPolicy_NetworkPolicy struct {

	// Network configurations.
	NetworkInterfaces []*AllocationPolicy_NetworkInterface `protobuf:"bytes,1,rep,name=network_interfaces,json=networkInterfaces,proto3" json:"network_interfaces,omitempty"`
	// contains filtered or unexported fields
}

NetworkPolicy describes VM instance network configurations.

func (*AllocationPolicy_NetworkPolicy) GetNetworkInterfaces 

func (x *AllocationPolicy_NetworkPolicy) GetNetworkInterfaces() []*AllocationPolicy_NetworkInterface

func (*AllocationPolicy_NetworkPolicy) ProtoMessage 

func (*AllocationPolicy_NetworkPolicy) ProtoMessage()

func (*AllocationPolicy_NetworkPolicy) ProtoReflect 

func (x *AllocationPolicy_NetworkPolicy) ProtoReflect() protoreflect.Message

func (*AllocationPolicy_NetworkPolicy) Reset 

func (x *AllocationPolicy_NetworkPolicy) Reset()

func (*AllocationPolicy_NetworkPolicy) SetNetworkInterfaces 

func (x *AllocationPolicy_NetworkPolicy) SetNetworkInterfaces(v []*AllocationPolicy_NetworkInterface)

func (*AllocationPolicy_NetworkPolicy) String 

func (x *AllocationPolicy_NetworkPolicy) String() string

type AllocationPolicy_NetworkPolicy_builder 

type AllocationPolicy_NetworkPolicy_builder struct {

	// Network configurations.
	NetworkInterfaces []*AllocationPolicy_NetworkInterface
	// contains filtered or unexported fields
}

func (AllocationPolicy_NetworkPolicy_builder) Build 

func (b0 AllocationPolicy_NetworkPolicy_builder) Build() *AllocationPolicy_NetworkPolicy

type AllocationPolicy_PlacementPolicy 

type AllocationPolicy_PlacementPolicy struct {

	// UNSPECIFIED vs. COLLOCATED (default UNSPECIFIED). Use COLLOCATED when you
	// want VMs to be located close to each other for low network latency
	// between the VMs. No placement policy will be generated when collocation
	// is UNSPECIFIED.
	Collocation string `protobuf:"bytes,1,opt,name=collocation,proto3" json:"collocation,omitempty"`
	// When specified, causes the job to fail if more than max_distance logical
	// switches are required between VMs. Batch uses the most compact possible
	// placement of VMs even when max_distance is not specified. An explicit
	// max_distance makes that level of compactness a strict requirement.
	// Not yet implemented
	MaxDistance int64 `protobuf:"varint,2,opt,name=max_distance,json=maxDistance,proto3" json:"max_distance,omitempty"`
	// contains filtered or unexported fields
}

PlacementPolicy describes a group placement policy for the VMs controlled by this AllocationPolicy.

func (*AllocationPolicy_PlacementPolicy) GetCollocation 

func (x *AllocationPolicy_PlacementPolicy) GetCollocation() string

func (*AllocationPolicy_PlacementPolicy) GetMaxDistance 

func (x *AllocationPolicy_PlacementPolicy) GetMaxDistance() int64

func (*AllocationPolicy_PlacementPolicy) ProtoMessage 

func (*AllocationPolicy_PlacementPolicy) ProtoMessage()

func (*AllocationPolicy_PlacementPolicy) ProtoReflect 

func (x *AllocationPolicy_PlacementPolicy) ProtoReflect() protoreflect.Message

func (*AllocationPolicy_PlacementPolicy) Reset 

func (x *AllocationPolicy_PlacementPolicy) Reset()

func (*AllocationPolicy_PlacementPolicy) SetCollocation 

func (x *AllocationPolicy_PlacementPolicy) SetCollocation(v string)

func (*AllocationPolicy_PlacementPolicy) SetMaxDistance 

func (x *AllocationPolicy_PlacementPolicy) SetMaxDistance(v int64)

func (*AllocationPolicy_PlacementPolicy) String 

func (x *AllocationPolicy_PlacementPolicy) String() string

type AllocationPolicy_PlacementPolicy_builder 

type AllocationPolicy_PlacementPolicy_builder struct {

	// UNSPECIFIED vs. COLLOCATED (default UNSPECIFIED). Use COLLOCATED when you
	// want VMs to be located close to each other for low network latency
	// between the VMs. No placement policy will be generated when collocation
	// is UNSPECIFIED.
	Collocation string
	// When specified, causes the job to fail if more than max_distance logical
	// switches are required between VMs. Batch uses the most compact possible
	// placement of VMs even when max_distance is not specified. An explicit
	// max_distance makes that level of compactness a strict requirement.
	// Not yet implemented
	MaxDistance int64
	// contains filtered or unexported fields
}

func (AllocationPolicy_PlacementPolicy_builder) Build 

func (b0 AllocationPolicy_PlacementPolicy_builder) Build() *AllocationPolicy_PlacementPolicy

type AllocationPolicy_ProvisioningModel 

type AllocationPolicy_ProvisioningModel int32

Compute Engine VM instance provisioning model. 

const (
	// Unspecified.
	AllocationPolicy_PROVISIONING_MODEL_UNSPECIFIED AllocationPolicy_ProvisioningModel = 0
	// Standard VM.
	AllocationPolicy_STANDARD AllocationPolicy_ProvisioningModel = 1
	// SPOT VM.
	AllocationPolicy_SPOT AllocationPolicy_ProvisioningModel = 2
	// Preemptible VM (PVM).
	//
	// Above SPOT VM is the preferable model for preemptible VM instances: the
	// old preemptible VM model (indicated by this field) is the older model,
	// and has been migrated to use the SPOT model as the underlying technology.
	// This old model will still be supported.
	AllocationPolicy_PREEMPTIBLE AllocationPolicy_ProvisioningModel = 3
)

func (AllocationPolicy_ProvisioningModel) Descriptor 

func (AllocationPolicy_ProvisioningModel) Descriptor() protoreflect.EnumDescriptor

func (AllocationPolicy_ProvisioningModel) Enum 

func (x AllocationPolicy_ProvisioningModel) Enum() *AllocationPolicy_ProvisioningModel

func (AllocationPolicy_ProvisioningModel) Number 

func (x AllocationPolicy_ProvisioningModel) Number() protoreflect.EnumNumber

func (AllocationPolicy_ProvisioningModel) String 

func (x AllocationPolicy_ProvisioningModel) String() string

func (AllocationPolicy_ProvisioningModel) Type 

func (AllocationPolicy_ProvisioningModel) Type() protoreflect.EnumType

type AllocationPolicy_builder 

type AllocationPolicy_builder struct {

	// Location where compute resources should be allocated for the Job.
	Location *AllocationPolicy_LocationPolicy
	// Describe instances that can be created by this AllocationPolicy.
	// Only instances[0] is supported now.
	Instances []*AllocationPolicy_InstancePolicyOrTemplate
	// Service account that VMs will run as.
	ServiceAccount *ServiceAccount
	// Labels applied to all VM instances and other resources
	// created by AllocationPolicy.
	// Labels could be user provided or system generated.
	// You can assign up to 64 labels. [Google Compute Engine label
	// restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions)
	// apply.
	// Label names that start with "goog-" or "google-" are reserved.
	Labels map[string]string
	// The network policy.
	Network *AllocationPolicy_NetworkPolicy
	// The placement policy.
	Placement *AllocationPolicy_PlacementPolicy
	// contains filtered or unexported fields
}

func (AllocationPolicy_builder) Build 

func (b0 AllocationPolicy_builder) Build() *AllocationPolicy

type ComputeResource 

type ComputeResource struct {

	// The milliCPU count.
	CpuMilli int64 `protobuf:"varint,1,opt,name=cpu_milli,json=cpuMilli,proto3" json:"cpu_milli,omitempty"`
	// Memory in MiB.
	MemoryMib int64 `protobuf:"varint,2,opt,name=memory_mib,json=memoryMib,proto3" json:"memory_mib,omitempty"`
	// Extra boot disk size in MiB for each task.
	BootDiskMib int64 `protobuf:"varint,4,opt,name=boot_disk_mib,json=bootDiskMib,proto3" json:"boot_disk_mib,omitempty"`
	// contains filtered or unexported fields
}

Compute resource requirements

func (*ComputeResource) GetBootDiskMib 

func (x *ComputeResource) GetBootDiskMib() int64

func (*ComputeResource) GetCpuMilli 

func (x *ComputeResource) GetCpuMilli() int64

func (*ComputeResource) GetMemoryMib 

func (x *ComputeResource) GetMemoryMib() int64

func (*ComputeResource) ProtoMessage 

func (*ComputeResource) ProtoMessage()

func (*ComputeResource) ProtoReflect 

func (x *ComputeResource) ProtoReflect() protoreflect.Message

func (*ComputeResource) Reset 

func (x *ComputeResource) Reset()

func (*ComputeResource) SetBootDiskMib 

func (x *ComputeResource) SetBootDiskMib(v int64)

func (*ComputeResource) SetCpuMilli 

func (x *ComputeResource) SetCpuMilli(v int64)

func (*ComputeResource) SetMemoryMib 

func (x *ComputeResource) SetMemoryMib(v int64)

func (*ComputeResource) String 

func (x *ComputeResource) String() string

type ComputeResource_builder 

type ComputeResource_builder struct {

	// The milliCPU count.
	CpuMilli int64
	// Memory in MiB.
	MemoryMib int64
	// Extra boot disk size in MiB for each task.
	BootDiskMib int64
	// contains filtered or unexported fields
}

func (ComputeResource_builder) Build 

func (b0 ComputeResource_builder) Build() *ComputeResource

type Environment 

type Environment struct {

	// A map of environment variable names to values.
	Variables map[string]string `` /* 145-byte string literal not displayed */
	// A map of environment variable names to Secret Manager secret names.
	// The VM will access the named secrets to set the value of each environment
	// variable.
	SecretVariables map[string]string `` /* 180-byte string literal not displayed */
	// An encrypted JSON dictionary where the key/value pairs correspond to
	// environment variable names and their values.
	EncryptedVariables *Environment_KMSEnvMap `protobuf:"bytes,3,opt,name=encrypted_variables,json=encryptedVariables,proto3" json:"encrypted_variables,omitempty"`
	// contains filtered or unexported fields
}

An Environment describes a collection of environment variables to set when executing Tasks.

func (*Environment) ClearEncryptedVariables 

func (x *Environment) ClearEncryptedVariables()

func (*Environment) GetEncryptedVariables 

func (x *Environment) GetEncryptedVariables() *Environment_KMSEnvMap

func (*Environment) GetSecretVariables 

func (x *Environment) GetSecretVariables() map[string]string

func (*Environment) GetVariables 

func (x *Environment) GetVariables() map[string]string

func (*Environment) HasEncryptedVariables 

func (x *Environment) HasEncryptedVariables() bool

func (*Environment) ProtoMessage 

func (*Environment) ProtoMessage()

func (*Environment) ProtoReflect 

func (x *Environment) ProtoReflect() protoreflect.Message

func (*Environment) Reset 

func (x *Environment) Reset()

func (*Environment) SetEncryptedVariables 

func (x *Environment) SetEncryptedVariables(v *Environment_KMSEnvMap)

func (*Environment) SetSecretVariables 

func (x *Environment) SetSecretVariables(v map[string]string)

func (*Environment) SetVariables 

func (x *Environment) SetVariables(v map[string]string)

func (*Environment) String 

func (x *Environment) String() string

type Environment_KMSEnvMap 

type Environment_KMSEnvMap struct {

	// The name of the KMS key that will be used to decrypt the cipher text.
	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.
	CipherText string `protobuf:"bytes,2,opt,name=cipher_text,json=cipherText,proto3" json:"cipher_text,omitempty"`
	// contains filtered or unexported fields
}

func (*Environment_KMSEnvMap) GetCipherText 

func (x *Environment_KMSEnvMap) GetCipherText() string

func (*Environment_KMSEnvMap) GetKeyName 

func (x *Environment_KMSEnvMap) GetKeyName() string

func (*Environment_KMSEnvMap) ProtoMessage 

func (*Environment_KMSEnvMap) ProtoMessage()

func (*Environment_KMSEnvMap) ProtoReflect 

func (x *Environment_KMSEnvMap) ProtoReflect() protoreflect.Message

func (*Environment_KMSEnvMap) Reset 

func (x *Environment_KMSEnvMap) Reset()

func (*Environment_KMSEnvMap) SetCipherText 

func (x *Environment_KMSEnvMap) SetCipherText(v string)

func (*Environment_KMSEnvMap) SetKeyName 

func (x *Environment_KMSEnvMap) SetKeyName(v string)

func (*Environment_KMSEnvMap) String 

func (x *Environment_KMSEnvMap) String() string

type Environment_KMSEnvMap_builder 

type Environment_KMSEnvMap_builder struct {

	// The name of the KMS key that will be used to decrypt the cipher text.
	KeyName string
	// The value of the cipherText response from the `encrypt` method.
	CipherText string
	// contains filtered or unexported fields
}

func (Environment_KMSEnvMap_builder) Build 

func (b0 Environment_KMSEnvMap_builder) Build() *Environment_KMSEnvMap

type Environment_builder 

type Environment_builder struct {

	// A map of environment variable names to values.
	Variables map[string]string
	// A map of environment variable names to Secret Manager secret names.
	// The VM will access the named secrets to set the value of each environment
	// variable.
	SecretVariables map[string]string
	// An encrypted JSON dictionary where the key/value pairs correspond to
	// environment variable names and their values.
	EncryptedVariables *Environment_KMSEnvMap
	// contains filtered or unexported fields
}

func (Environment_builder) Build 

func (b0 Environment_builder) Build() *Environment

type GCS 

type GCS struct {

	// Remote path, either a bucket name or a subdirectory of a bucket, e.g.:
	// bucket_name, bucket_name/subdirectory/
	RemotePath string `protobuf:"bytes,1,opt,name=remote_path,json=remotePath,proto3" json:"remote_path,omitempty"`
	// contains filtered or unexported fields
}

Represents a Google Cloud Storage volume.

func (*GCS) GetRemotePath 

func (x *GCS) GetRemotePath() string

func (*GCS) ProtoMessage 

func (*GCS) ProtoMessage()

func (*GCS) ProtoReflect 

func (x *GCS) ProtoReflect() protoreflect.Message

func (*GCS) Reset 

func (x *GCS) Reset()

func (*GCS) SetRemotePath 

func (x *GCS) SetRemotePath(v string)

func (*GCS) String 

func (x *GCS) String() string

type GCS_builder 

type GCS_builder struct {

	// Remote path, either a bucket name or a subdirectory of a bucket, e.g.:
	// bucket_name, bucket_name/subdirectory/
	RemotePath string
	// contains filtered or unexported fields
}

func (GCS_builder) Build 

func (b0 GCS_builder) Build() *GCS

type Job 

type Job struct {

	// Output only. Job name.
	// For example: "projects/123456/locations/us-central1/jobs/job01".
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. A system generated unique ID (in UUID4 format) for the Job.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Priority of the Job.
	// The valid value range is [0, 100). Default value is 0.
	// Higher value indicates higher priority.
	// A job with higher priority value is more likely to run earlier if all other
	// requirements are satisfied.
	Priority int64 `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	// Required. TaskGroups in the Job. Only one TaskGroup is supported now.
	TaskGroups []*TaskGroup `protobuf:"bytes,4,rep,name=task_groups,json=taskGroups,proto3" json:"task_groups,omitempty"`
	// Compute resource allocation for all TaskGroups in the Job.
	AllocationPolicy *AllocationPolicy `protobuf:"bytes,7,opt,name=allocation_policy,json=allocationPolicy,proto3" json:"allocation_policy,omitempty"`
	// Labels for the Job. Labels could be user provided or system generated.
	// For example,
	//
	//	"labels": {
	//	   "department": "finance",
	//	   "environment": "test"
	//	 }
	//
	// You can assign up to 64 labels.  [Google Compute Engine label
	// restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions)
	// apply.
	// Label names that start with "goog-" or "google-" are reserved.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Output only. Job status. It is read only for users.
	Status *JobStatus `protobuf:"bytes,9,opt,name=status,proto3" json:"status,omitempty"`
	// Output only. When the Job was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The last time the Job was updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Log preservation policy for the Job.
	LogsPolicy *LogsPolicy `protobuf:"bytes,13,opt,name=logs_policy,json=logsPolicy,proto3" json:"logs_policy,omitempty"`
	// Notification configurations.
	Notifications []*JobNotification `protobuf:"bytes,14,rep,name=notifications,proto3" json:"notifications,omitempty"`
	// contains filtered or unexported fields
}

The Cloud Batch Job description.

func (*Job) ClearAllocationPolicy 

func (x *Job) ClearAllocationPolicy()

func (*Job) ClearCreateTime 

func (x *Job) ClearCreateTime()

func (*Job) ClearLogsPolicy 

func (x *Job) ClearLogsPolicy()

func (*Job) ClearStatus 

func (x *Job) ClearStatus()

func (*Job) ClearUpdateTime 

func (x *Job) ClearUpdateTime()

func (*Job) GetAllocationPolicy 

func (x *Job) GetAllocationPolicy() *AllocationPolicy

func (*Job) GetCreateTime 

func (x *Job) GetCreateTime() *timestamppb.Timestamp

func (*Job) GetLabels 

func (x *Job) GetLabels() map[string]string

func (*Job) GetLogsPolicy 

func (x *Job) GetLogsPolicy() *LogsPolicy

func (*Job) GetName 

func (x *Job) GetName() string

func (*Job) GetNotifications 

func (x *Job) GetNotifications() []*JobNotification

func (*Job) GetPriority 

func (x *Job) GetPriority() int64

func (*Job) GetStatus 

func (x *Job) GetStatus() *JobStatus

func (*Job) GetTaskGroups 

func (x *Job) GetTaskGroups() []*TaskGroup

func (*Job) GetUid 

func (x *Job) GetUid() string

func (*Job) GetUpdateTime 

func (x *Job) GetUpdateTime() *timestamppb.Timestamp

func (*Job) HasAllocationPolicy 

func (x *Job) HasAllocationPolicy() bool

func (*Job) HasCreateTime 

func (x *Job) HasCreateTime() bool

func (*Job) HasLogsPolicy 

func (x *Job) HasLogsPolicy() bool

func (*Job) HasStatus 

func (x *Job) HasStatus() bool

func (*Job) HasUpdateTime 

func (x *Job) HasUpdateTime() bool

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

func (x *Job) ProtoReflect() protoreflect.Message

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) SetAllocationPolicy 

func (x *Job) SetAllocationPolicy(v *AllocationPolicy)

func (*Job) SetCreateTime 

func (x *Job) SetCreateTime(v *timestamppb.Timestamp)

func (*Job) SetLabels 

func (x *Job) SetLabels(v map[string]string)

func (*Job) SetLogsPolicy 

func (x *Job) SetLogsPolicy(v *LogsPolicy)

func (*Job) SetName 

func (x *Job) SetName(v string)

func (*Job) SetNotifications 

func (x *Job) SetNotifications(v []*JobNotification)

func (*Job) SetPriority 

func (x *Job) SetPriority(v int64)

func (*Job) SetStatus 

func (x *Job) SetStatus(v *JobStatus)

func (*Job) SetTaskGroups 

func (x *Job) SetTaskGroups(v []*TaskGroup)

func (*Job) SetUid 

func (x *Job) SetUid(v string)

func (*Job) SetUpdateTime 

func (x *Job) SetUpdateTime(v *timestamppb.Timestamp)

func (*Job) String 

func (x *Job) String() string

type JobCreatedEvent 

type JobCreatedEvent struct {

	// The data associated with the event.
	Data *JobEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Job is created.

func (*JobCreatedEvent) ClearData 

func (x *JobCreatedEvent) ClearData()

func (*JobCreatedEvent) GetData 

func (x *JobCreatedEvent) GetData() *JobEventData

func (*JobCreatedEvent) HasData 

func (x *JobCreatedEvent) HasData() bool

func (*JobCreatedEvent) ProtoMessage 

func (*JobCreatedEvent) ProtoMessage()

func (*JobCreatedEvent) ProtoReflect 

func (x *JobCreatedEvent) ProtoReflect() protoreflect.Message

func (*JobCreatedEvent) Reset 

func (x *JobCreatedEvent) Reset()

func (*JobCreatedEvent) SetData 

func (x *JobCreatedEvent) SetData(v *JobEventData)

func (*JobCreatedEvent) String 

func (x *JobCreatedEvent) String() string

type JobCreatedEvent_builder 

type JobCreatedEvent_builder struct {

	// The data associated with the event.
	Data *JobEventData
	// contains filtered or unexported fields
}

func (JobCreatedEvent_builder) Build 

func (b0 JobCreatedEvent_builder) Build() *JobCreatedEvent

type JobDeletedEvent 

type JobDeletedEvent struct {

	// The data associated with the event.
	Data *JobEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Job is deleted.

func (*JobDeletedEvent) ClearData 

func (x *JobDeletedEvent) ClearData()

func (*JobDeletedEvent) GetData 

func (x *JobDeletedEvent) GetData() *JobEventData

func (*JobDeletedEvent) HasData 

func (x *JobDeletedEvent) HasData() bool

func (*JobDeletedEvent) ProtoMessage 

func (*JobDeletedEvent) ProtoMessage()

func (*JobDeletedEvent) ProtoReflect 

func (x *JobDeletedEvent) ProtoReflect() protoreflect.Message

func (*JobDeletedEvent) Reset 

func (x *JobDeletedEvent) Reset()

func (*JobDeletedEvent) SetData 

func (x *JobDeletedEvent) SetData(v *JobEventData)

func (*JobDeletedEvent) String 

func (x *JobDeletedEvent) String() string

type JobDeletedEvent_builder 

type JobDeletedEvent_builder struct {

	// The data associated with the event.
	Data *JobEventData
	// contains filtered or unexported fields
}

func (JobDeletedEvent_builder) Build 

func (b0 JobDeletedEvent_builder) Build() *JobDeletedEvent

type JobEventData 

type JobEventData struct {

	// Optional. The Job event payload. Unset for deletion events.
	Payload *Job `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Job events.

func (*JobEventData) ClearPayload 

func (x *JobEventData) ClearPayload()

func (*JobEventData) GetPayload 

func (x *JobEventData) GetPayload() *Job

func (*JobEventData) HasPayload 

func (x *JobEventData) HasPayload() bool

func (*JobEventData) ProtoMessage 

func (*JobEventData) ProtoMessage()

func (*JobEventData) ProtoReflect 

func (x *JobEventData) ProtoReflect() protoreflect.Message

func (*JobEventData) Reset 

func (x *JobEventData) Reset()

func (*JobEventData) SetPayload 

func (x *JobEventData) SetPayload(v *Job)

func (*JobEventData) String 

func (x *JobEventData) String() string

type JobEventData_builder 

type JobEventData_builder struct {

	// Optional. The Job event payload. Unset for deletion events.
	Payload *Job
	// contains filtered or unexported fields
}

func (JobEventData_builder) Build 

func (b0 JobEventData_builder) Build() *JobEventData

type JobNotification 

type JobNotification struct {

	// The Pub/Sub topic where notifications like the job state changes
	// will be published. This topic exist in the same project as the job
	// and billings will be charged to this project.
	// If not specified, no Pub/Sub messages will be sent.
	// Topic format: `projects/{project}/topics/{topic}`.
	PubsubTopic string `protobuf:"bytes,1,opt,name=pubsub_topic,json=pubsubTopic,proto3" json:"pubsub_topic,omitempty"`
	// The attribute requirements of messages to be sent to this Pub/Sub topic.
	// Without this field, no message will be sent.
	Message *JobNotification_Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Notification configurations.

func (*JobNotification) ClearMessage 

func (x *JobNotification) ClearMessage()

func (*JobNotification) GetMessage 

func (x *JobNotification) GetMessage() *JobNotification_Message

func (*JobNotification) GetPubsubTopic 

func (x *JobNotification) GetPubsubTopic() string

func (*JobNotification) HasMessage 

func (x *JobNotification) HasMessage() bool

func (*JobNotification) ProtoMessage 

func (*JobNotification) ProtoMessage()

func (*JobNotification) ProtoReflect 

func (x *JobNotification) ProtoReflect() protoreflect.Message

func (*JobNotification) Reset 

func (x *JobNotification) Reset()

func (*JobNotification) SetMessage 

func (x *JobNotification) SetMessage(v *JobNotification_Message)

func (*JobNotification) SetPubsubTopic 

func (x *JobNotification) SetPubsubTopic(v string)

func (*JobNotification) String 

func (x *JobNotification) String() string

type JobNotification_Message 

type JobNotification_Message struct {

	// The message type.
	Type JobNotification_Type `protobuf:"varint,1,opt,name=type,proto3,enum=google.events.cloud.batch.v1.JobNotification_Type" json:"type,omitempty"`
	// The new job state.
	NewJobState JobStatus_State `` /* 147-byte string literal not displayed */
	// The new task state.
	NewTaskState TaskStatus_State `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message details. Describe the attribute that a message should have. Without specified message attributes, no message will be sent by default.

func (*JobNotification_Message) GetNewJobState 

func (x *JobNotification_Message) GetNewJobState() JobStatus_State

func (*JobNotification_Message) GetNewTaskState 

func (x *JobNotification_Message) GetNewTaskState() TaskStatus_State

func (*JobNotification_Message) GetType 

func (x *JobNotification_Message) GetType() JobNotification_Type

func (*JobNotification_Message) ProtoMessage 

func (*JobNotification_Message) ProtoMessage()

func (*JobNotification_Message) ProtoReflect 

func (x *JobNotification_Message) ProtoReflect() protoreflect.Message

func (*JobNotification_Message) Reset 

func (x *JobNotification_Message) Reset()

func (*JobNotification_Message) SetNewJobState 

func (x *JobNotification_Message) SetNewJobState(v JobStatus_State)

func (*JobNotification_Message) SetNewTaskState 

func (x *JobNotification_Message) SetNewTaskState(v TaskStatus_State)

func (*JobNotification_Message) SetType 

func (x *JobNotification_Message) SetType(v JobNotification_Type)

func (*JobNotification_Message) String 

func (x *JobNotification_Message) String() string

type JobNotification_Message_builder 

type JobNotification_Message_builder struct {

	// The message type.
	Type JobNotification_Type
	// The new job state.
	NewJobState JobStatus_State
	// The new task state.
	NewTaskState TaskStatus_State
	// contains filtered or unexported fields
}

func (JobNotification_Message_builder) Build 

func (b0 JobNotification_Message_builder) Build() *JobNotification_Message

type JobNotification_Type 

type JobNotification_Type int32

The message type. 

const (
	// Unspecified.
	JobNotification_TYPE_UNSPECIFIED JobNotification_Type = 0
	// Notify users that the job state has changed.
	JobNotification_JOB_STATE_CHANGED JobNotification_Type = 1
	// Notify users that the task state has changed.
	JobNotification_TASK_STATE_CHANGED JobNotification_Type = 2
)

func (JobNotification_Type) Descriptor 

func (JobNotification_Type) Descriptor() protoreflect.EnumDescriptor

func (JobNotification_Type) Enum 

func (x JobNotification_Type) Enum() *JobNotification_Type

func (JobNotification_Type) Number 

func (x JobNotification_Type) Number() protoreflect.EnumNumber

func (JobNotification_Type) String 

func (x JobNotification_Type) String() string

func (JobNotification_Type) Type 

func (JobNotification_Type) Type() protoreflect.EnumType

type JobNotification_builder 

type JobNotification_builder struct {

	// The Pub/Sub topic where notifications like the job state changes
	// will be published. This topic exist in the same project as the job
	// and billings will be charged to this project.
	// If not specified, no Pub/Sub messages will be sent.
	// Topic format: `projects/{project}/topics/{topic}`.
	PubsubTopic string
	// The attribute requirements of messages to be sent to this Pub/Sub topic.
	// Without this field, no message will be sent.
	Message *JobNotification_Message
	// contains filtered or unexported fields
}

func (JobNotification_builder) Build 

func (b0 JobNotification_builder) Build() *JobNotification

type JobStatus 

type JobStatus struct {

	// Job state
	State JobStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.events.cloud.batch.v1.JobStatus_State" json:"state,omitempty"`
	// Job status events
	StatusEvents []*StatusEvent `protobuf:"bytes,2,rep,name=status_events,json=statusEvents,proto3" json:"status_events,omitempty"`
	// Aggregated task status for each TaskGroup in the Job.
	// The map key is TaskGroup ID.
	TaskGroups map[string]*JobStatus_TaskGroupStatus `` /* 165-byte string literal not displayed */
	// The duration of time that the Job spent in status RUNNING.
	RunDuration *durationpb.Duration `protobuf:"bytes,5,opt,name=run_duration,json=runDuration,proto3" json:"run_duration,omitempty"`
	// contains filtered or unexported fields
}

Job status.

func (*JobStatus) ClearRunDuration 

func (x *JobStatus) ClearRunDuration()

func (*JobStatus) GetRunDuration 

func (x *JobStatus) GetRunDuration() *durationpb.Duration

func (*JobStatus) GetState 

func (x *JobStatus) GetState() JobStatus_State

func (*JobStatus) GetStatusEvents 

func (x *JobStatus) GetStatusEvents() []*StatusEvent

func (*JobStatus) GetTaskGroups 

func (x *JobStatus) GetTaskGroups() map[string]*JobStatus_TaskGroupStatus

func (*JobStatus) HasRunDuration 

func (x *JobStatus) HasRunDuration() bool

func (*JobStatus) ProtoMessage 

func (*JobStatus) ProtoMessage()

func (*JobStatus) ProtoReflect 

func (x *JobStatus) ProtoReflect() protoreflect.Message

func (*JobStatus) Reset 

func (x *JobStatus) Reset()

func (*JobStatus) SetRunDuration 

func (x *JobStatus) SetRunDuration(v *durationpb.Duration)

func (*JobStatus) SetState 

func (x *JobStatus) SetState(v JobStatus_State)

func (*JobStatus) SetStatusEvents 

func (x *JobStatus) SetStatusEvents(v []*StatusEvent)

func (*JobStatus) SetTaskGroups 

func (x *JobStatus) SetTaskGroups(v map[string]*JobStatus_TaskGroupStatus)

func (*JobStatus) String 

func (x *JobStatus) String() string

type JobStatus_InstanceStatus 

type JobStatus_InstanceStatus struct {

	// The Compute Engine machine type.
	MachineType string `protobuf:"bytes,1,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
	// The VM instance provisioning model.
	ProvisioningModel AllocationPolicy_ProvisioningModel `` /* 182-byte string literal not displayed */
	// The max number of tasks can be assigned to this instance type.
	TaskPack int64 `protobuf:"varint,3,opt,name=task_pack,json=taskPack,proto3" json:"task_pack,omitempty"`
	// The VM boot disk.
	BootDisk *AllocationPolicy_Disk `protobuf:"bytes,4,opt,name=boot_disk,json=bootDisk,proto3" json:"boot_disk,omitempty"`
	// contains filtered or unexported fields
}

VM instance status.

func (*JobStatus_InstanceStatus) ClearBootDisk 

func (x *JobStatus_InstanceStatus) ClearBootDisk()

func (*JobStatus_InstanceStatus) GetBootDisk 

func (x *JobStatus_InstanceStatus) GetBootDisk() *AllocationPolicy_Disk

func (*JobStatus_InstanceStatus) GetMachineType 

func (x *JobStatus_InstanceStatus) GetMachineType() string

func (*JobStatus_InstanceStatus) GetProvisioningModel 

func (x *JobStatus_InstanceStatus) GetProvisioningModel() AllocationPolicy_ProvisioningModel

func (*JobStatus_InstanceStatus) GetTaskPack 

func (x *JobStatus_InstanceStatus) GetTaskPack() int64

func (*JobStatus_InstanceStatus) HasBootDisk 

func (x *JobStatus_InstanceStatus) HasBootDisk() bool

func (*JobStatus_InstanceStatus) ProtoMessage 

func (*JobStatus_InstanceStatus) ProtoMessage()

func (*JobStatus_InstanceStatus) ProtoReflect 

func (x *JobStatus_InstanceStatus) ProtoReflect() protoreflect.Message

func (*JobStatus_InstanceStatus) Reset 

func (x *JobStatus_InstanceStatus) Reset()

func (*JobStatus_InstanceStatus) SetBootDisk 

func (x *JobStatus_InstanceStatus) SetBootDisk(v *AllocationPolicy_Disk)

func (*JobStatus_InstanceStatus) SetMachineType 

func (x *JobStatus_InstanceStatus) SetMachineType(v string)

func (*JobStatus_InstanceStatus) SetProvisioningModel 

func (x *JobStatus_InstanceStatus) SetProvisioningModel(v AllocationPolicy_ProvisioningModel)

func (*JobStatus_InstanceStatus) SetTaskPack 

func (x *JobStatus_InstanceStatus) SetTaskPack(v int64)

func (*JobStatus_InstanceStatus) String 

func (x *JobStatus_InstanceStatus) String() string

type JobStatus_InstanceStatus_builder 

type JobStatus_InstanceStatus_builder struct {

	// The Compute Engine machine type.
	MachineType string
	// The VM instance provisioning model.
	ProvisioningModel AllocationPolicy_ProvisioningModel
	// The max number of tasks can be assigned to this instance type.
	TaskPack int64
	// The VM boot disk.
	BootDisk *AllocationPolicy_Disk
	// contains filtered or unexported fields
}

func (JobStatus_InstanceStatus_builder) Build 

func (b0 JobStatus_InstanceStatus_builder) Build() *JobStatus_InstanceStatus

type JobStatus_State 

type JobStatus_State int32

Valid Job states. 

const (
	// Job state unspecified.
	JobStatus_STATE_UNSPECIFIED JobStatus_State = 0
	// Job is admitted (validated and persisted) and waiting for resources.
	JobStatus_QUEUED JobStatus_State = 1
	// Job is scheduled to run as soon as resource allocation is ready.
	// The resource allocation may happen at a later time but with a high
	// chance to succeed.
	JobStatus_SCHEDULED JobStatus_State = 2
	// Resource allocation has been successful. At least one Task in the Job is
	// RUNNING.
	JobStatus_RUNNING JobStatus_State = 3
	// All Tasks in the Job have finished successfully.
	JobStatus_SUCCEEDED JobStatus_State = 4
	// At least one Task in the Job has failed.
	JobStatus_FAILED JobStatus_State = 5
	// The Job will be deleted, but has not been deleted yet. Typically this is
	// because resources used by the Job are still being cleaned up.
	JobStatus_DELETION_IN_PROGRESS JobStatus_State = 6
)

func (JobStatus_State) Descriptor 

func (JobStatus_State) Descriptor() protoreflect.EnumDescriptor

func (JobStatus_State) Enum 

func (x JobStatus_State) Enum() *JobStatus_State

func (JobStatus_State) Number 

func (x JobStatus_State) Number() protoreflect.EnumNumber

func (JobStatus_State) String 

func (x JobStatus_State) String() string

func (JobStatus_State) Type 

func (JobStatus_State) Type() protoreflect.EnumType

type JobStatus_TaskGroupStatus 

type JobStatus_TaskGroupStatus struct {

	// Count of task in each state in the TaskGroup.
	// The map key is task state name.
	Counts map[string]int64 `` /* 140-byte string literal not displayed */
	// Status of instances allocated for the TaskGroup.
	Instances []*JobStatus_InstanceStatus `protobuf:"bytes,2,rep,name=instances,proto3" json:"instances,omitempty"`
	// contains filtered or unexported fields
}

Aggregated task status for a TaskGroup.

func (*JobStatus_TaskGroupStatus) GetCounts 

func (x *JobStatus_TaskGroupStatus) GetCounts() map[string]int64

func (*JobStatus_TaskGroupStatus) GetInstances 

func (x *JobStatus_TaskGroupStatus) GetInstances() []*JobStatus_InstanceStatus

func (*JobStatus_TaskGroupStatus) ProtoMessage 

func (*JobStatus_TaskGroupStatus) ProtoMessage()

func (*JobStatus_TaskGroupStatus) ProtoReflect 

func (x *JobStatus_TaskGroupStatus) ProtoReflect() protoreflect.Message

func (*JobStatus_TaskGroupStatus) Reset 

func (x *JobStatus_TaskGroupStatus) Reset()

func (*JobStatus_TaskGroupStatus) SetCounts 

func (x *JobStatus_TaskGroupStatus) SetCounts(v map[string]int64)

func (*JobStatus_TaskGroupStatus) SetInstances 

func (x *JobStatus_TaskGroupStatus) SetInstances(v []*JobStatus_InstanceStatus)

func (*JobStatus_TaskGroupStatus) String 

func (x *JobStatus_TaskGroupStatus) String() string

type JobStatus_TaskGroupStatus_builder 

type JobStatus_TaskGroupStatus_builder struct {

	// Count of task in each state in the TaskGroup.
	// The map key is task state name.
	Counts map[string]int64
	// Status of instances allocated for the TaskGroup.
	Instances []*JobStatus_InstanceStatus
	// contains filtered or unexported fields
}

func (JobStatus_TaskGroupStatus_builder) Build 

func (b0 JobStatus_TaskGroupStatus_builder) Build() *JobStatus_TaskGroupStatus

type JobStatus_builder 

type JobStatus_builder struct {

	// Job state
	State JobStatus_State
	// Job status events
	StatusEvents []*StatusEvent
	// Aggregated task status for each TaskGroup in the Job.
	// The map key is TaskGroup ID.
	TaskGroups map[string]*JobStatus_TaskGroupStatus
	// The duration of time that the Job spent in status RUNNING.
	RunDuration *durationpb.Duration
	// contains filtered or unexported fields
}

func (JobStatus_builder) Build 

func (b0 JobStatus_builder) Build() *JobStatus

type Job_builder 

type Job_builder struct {

	// Output only. Job name.
	// For example: "projects/123456/locations/us-central1/jobs/job01".
	Name string
	// Output only. A system generated unique ID (in UUID4 format) for the Job.
	Uid string
	// Priority of the Job.
	// The valid value range is [0, 100). Default value is 0.
	// Higher value indicates higher priority.
	// A job with higher priority value is more likely to run earlier if all other
	// requirements are satisfied.
	Priority int64
	// Required. TaskGroups in the Job. Only one TaskGroup is supported now.
	TaskGroups []*TaskGroup
	// Compute resource allocation for all TaskGroups in the Job.
	AllocationPolicy *AllocationPolicy
	// Labels for the Job. Labels could be user provided or system generated.
	// For example,
	//
	//	"labels": {
	//	   "department": "finance",
	//	   "environment": "test"
	//	 }
	//
	// You can assign up to 64 labels.  [Google Compute Engine label
	// restrictions](https://cloud.google.com/compute/docs/labeling-resources#restrictions)
	// apply.
	// Label names that start with "goog-" or "google-" are reserved.
	Labels map[string]string
	// Output only. Job status. It is read only for users.
	Status *JobStatus
	// Output only. When the Job was created.
	CreateTime *timestamppb.Timestamp
	// Output only. The last time the Job was updated.
	UpdateTime *timestamppb.Timestamp
	// Log preservation policy for the Job.
	LogsPolicy *LogsPolicy
	// Notification configurations.
	Notifications []*JobNotification
	// contains filtered or unexported fields
}

func (Job_builder) Build 

func (b0 Job_builder) Build() *Job

type LifecyclePolicy 

type LifecyclePolicy struct {

	// Action to execute when ActionCondition is true.
	// When RETRY_TASK is specified, we will retry failed tasks
	// if we notice any exit code match and fail tasks if no match is found.
	// Likewise, when FAIL_TASK is specified, we will fail tasks
	// if we notice any exit code match and retry tasks if no match is found.
	Action LifecyclePolicy_Action `protobuf:"varint,1,opt,name=action,proto3,enum=google.events.cloud.batch.v1.LifecyclePolicy_Action" json:"action,omitempty"`
	// Conditions that decide why a task failure is dealt with a specific action.
	ActionCondition *LifecyclePolicy_ActionCondition `protobuf:"bytes,2,opt,name=action_condition,json=actionCondition,proto3" json:"action_condition,omitempty"`
	// contains filtered or unexported fields
}

LifecyclePolicy describes how to deal with task failures based on different conditions.

func (*LifecyclePolicy) ClearActionCondition 

func (x *LifecyclePolicy) ClearActionCondition()

func (*LifecyclePolicy) GetAction 

func (x *LifecyclePolicy) GetAction() LifecyclePolicy_Action

func (*LifecyclePolicy) GetActionCondition 

func (x *LifecyclePolicy) GetActionCondition() *LifecyclePolicy_ActionCondition

func (*LifecyclePolicy) HasActionCondition 

func (x *LifecyclePolicy) HasActionCondition() bool

func (*LifecyclePolicy) ProtoMessage 

func (*LifecyclePolicy) ProtoMessage()

func (*LifecyclePolicy) ProtoReflect 

func (x *LifecyclePolicy) ProtoReflect() protoreflect.Message

func (*LifecyclePolicy) Reset 

func (x *LifecyclePolicy) Reset()

func (*LifecyclePolicy) SetAction 

func (x *LifecyclePolicy) SetAction(v LifecyclePolicy_Action)

func (*LifecyclePolicy) SetActionCondition 

func (x *LifecyclePolicy) SetActionCondition(v *LifecyclePolicy_ActionCondition)

func (*LifecyclePolicy) String 

func (x *LifecyclePolicy) String() string

type LifecyclePolicy_Action 

type LifecyclePolicy_Action int32

Action on task failures based on different conditions. 

const (
	// Action unspecified.
	LifecyclePolicy_ACTION_UNSPECIFIED LifecyclePolicy_Action = 0
	// Action that tasks in the group will be scheduled to re-execute.
	LifecyclePolicy_RETRY_TASK LifecyclePolicy_Action = 1
	// Action that tasks in the group will be stopped immediately.
	LifecyclePolicy_FAIL_TASK LifecyclePolicy_Action = 2
)

func (LifecyclePolicy_Action) Descriptor 

func (LifecyclePolicy_Action) Descriptor() protoreflect.EnumDescriptor

func (LifecyclePolicy_Action) Enum 

func (x LifecyclePolicy_Action) Enum() *LifecyclePolicy_Action

func (LifecyclePolicy_Action) Number 

func (x LifecyclePolicy_Action) Number() protoreflect.EnumNumber

func (LifecyclePolicy_Action) String 

func (x LifecyclePolicy_Action) String() string

func (LifecyclePolicy_Action) Type 

func (LifecyclePolicy_Action) Type() protoreflect.EnumType

type LifecyclePolicy_ActionCondition 

type LifecyclePolicy_ActionCondition struct {

	// Exit codes of a task execution.
	// If there are more than 1 exit codes,
	// when task executes with any of the exit code in the list,
	// the condition is met and the action will be executed.
	ExitCodes []int32 `protobuf:"varint,1,rep,packed,name=exit_codes,json=exitCodes,proto3" json:"exit_codes,omitempty"`
	// contains filtered or unexported fields
}

Conditions for actions to deal with task failures.

func (*LifecyclePolicy_ActionCondition) GetExitCodes 

func (x *LifecyclePolicy_ActionCondition) GetExitCodes() []int32

func (*LifecyclePolicy_ActionCondition) ProtoMessage 

func (*LifecyclePolicy_ActionCondition) ProtoMessage()

func (*LifecyclePolicy_ActionCondition) ProtoReflect 

func (x *LifecyclePolicy_ActionCondition) ProtoReflect() protoreflect.Message

func (*LifecyclePolicy_ActionCondition) Reset 

func (x *LifecyclePolicy_ActionCondition) Reset()

func (*LifecyclePolicy_ActionCondition) SetExitCodes 

func (x *LifecyclePolicy_ActionCondition) SetExitCodes(v []int32)

func (*LifecyclePolicy_ActionCondition) String 

func (x *LifecyclePolicy_ActionCondition) String() string

type LifecyclePolicy_ActionCondition_builder 

type LifecyclePolicy_ActionCondition_builder struct {

	// Exit codes of a task execution.
	// If there are more than 1 exit codes,
	// when task executes with any of the exit code in the list,
	// the condition is met and the action will be executed.
	ExitCodes []int32
	// contains filtered or unexported fields
}

func (LifecyclePolicy_ActionCondition_builder) Build 

func (b0 LifecyclePolicy_ActionCondition_builder) Build() *LifecyclePolicy_ActionCondition

type LifecyclePolicy_builder 

type LifecyclePolicy_builder struct {

	// Action to execute when ActionCondition is true.
	// When RETRY_TASK is specified, we will retry failed tasks
	// if we notice any exit code match and fail tasks if no match is found.
	// Likewise, when FAIL_TASK is specified, we will fail tasks
	// if we notice any exit code match and retry tasks if no match is found.
	Action LifecyclePolicy_Action
	// Conditions that decide why a task failure is dealt with a specific action.
	ActionCondition *LifecyclePolicy_ActionCondition
	// contains filtered or unexported fields
}

func (LifecyclePolicy_builder) Build 

func (b0 LifecyclePolicy_builder) Build() *LifecyclePolicy

type LogsPolicy 

type LogsPolicy struct {

	// Where logs should be saved.
	Destination LogsPolicy_Destination `` /* 133-byte string literal not displayed */
	// The path to which logs are saved when the destination = PATH. This can be a
	// local file path on the VM, or under the mount point of a Persistent Disk or
	// Filestore, or a Cloud Storage path.
	LogsPath string `protobuf:"bytes,2,opt,name=logs_path,json=logsPath,proto3" json:"logs_path,omitempty"`
	// contains filtered or unexported fields
}

LogsPolicy describes how outputs from a Job's Tasks (stdout/stderr) will be preserved.

func (*LogsPolicy) GetDestination 

func (x *LogsPolicy) GetDestination() LogsPolicy_Destination

func (*LogsPolicy) GetLogsPath 

func (x *LogsPolicy) GetLogsPath() string

func (*LogsPolicy) ProtoMessage 

func (*LogsPolicy) ProtoMessage()

func (*LogsPolicy) ProtoReflect 

func (x *LogsPolicy) ProtoReflect() protoreflect.Message

func (*LogsPolicy) Reset 

func (x *LogsPolicy) Reset()

func (*LogsPolicy) SetDestination 

func (x *LogsPolicy) SetDestination(v LogsPolicy_Destination)

func (*LogsPolicy) SetLogsPath 

func (x *LogsPolicy) SetLogsPath(v string)

func (*LogsPolicy) String 

func (x *LogsPolicy) String() string

type LogsPolicy_Destination 

type LogsPolicy_Destination int32

The destination (if any) for logs. 

const (
	// Logs are not preserved.
	LogsPolicy_DESTINATION_UNSPECIFIED LogsPolicy_Destination = 0
	// Logs are streamed to Cloud Logging.
	LogsPolicy_CLOUD_LOGGING LogsPolicy_Destination = 1
	// Logs are saved to a file path.
	LogsPolicy_PATH LogsPolicy_Destination = 2
)

func (LogsPolicy_Destination) Descriptor 

func (LogsPolicy_Destination) Descriptor() protoreflect.EnumDescriptor

func (LogsPolicy_Destination) Enum 

func (x LogsPolicy_Destination) Enum() *LogsPolicy_Destination

func (LogsPolicy_Destination) Number 

func (x LogsPolicy_Destination) Number() protoreflect.EnumNumber

func (LogsPolicy_Destination) String 

func (x LogsPolicy_Destination) String() string

func (LogsPolicy_Destination) Type 

func (LogsPolicy_Destination) Type() protoreflect.EnumType

type LogsPolicy_builder 

type LogsPolicy_builder struct {

	// Where logs should be saved.
	Destination LogsPolicy_Destination
	// The path to which logs are saved when the destination = PATH. This can be a
	// local file path on the VM, or under the mount point of a Persistent Disk or
	// Filestore, or a Cloud Storage path.
	LogsPath string
	// contains filtered or unexported fields
}

func (LogsPolicy_builder) Build 

func (b0 LogsPolicy_builder) Build() *LogsPolicy

type NFS 

type NFS struct {

	// The IP address of the NFS.
	Server string `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	// Remote source path exported from the NFS, e.g., "/share".
	RemotePath string `protobuf:"bytes,2,opt,name=remote_path,json=remotePath,proto3" json:"remote_path,omitempty"`
	// contains filtered or unexported fields
}

Represents an NFS volume.

func (*NFS) GetRemotePath 

func (x *NFS) GetRemotePath() string

func (*NFS) GetServer 

func (x *NFS) GetServer() string

func (*NFS) ProtoMessage 

func (*NFS) ProtoMessage()

func (*NFS) ProtoReflect 

func (x *NFS) ProtoReflect() protoreflect.Message

func (*NFS) Reset 

func (x *NFS) Reset()

func (*NFS) SetRemotePath 

func (x *NFS) SetRemotePath(v string)

func (*NFS) SetServer 

func (x *NFS) SetServer(v string)

func (*NFS) String 

func (x *NFS) String() string

type NFS_builder 

type NFS_builder struct {

	// The IP address of the NFS.
	Server string
	// Remote source path exported from the NFS, e.g., "/share".
	RemotePath string
	// contains filtered or unexported fields
}

func (NFS_builder) Build 

func (b0 NFS_builder) Build() *NFS

type Runnable 

type Runnable struct {

	// The script or container to run.
	//
	// Types that are valid to be assigned to Executable:
	//
	//	*Runnable_Container_
	//	*Runnable_Script_
	//	*Runnable_Barrier_
	Executable isRunnable_Executable `protobuf_oneof:"executable"`
	// Normally, a non-zero exit status causes the Task to fail. This flag allows
	// execution of other Runnables to continue instead.
	IgnoreExitStatus bool `protobuf:"varint,3,opt,name=ignore_exit_status,json=ignoreExitStatus,proto3" json:"ignore_exit_status,omitempty"`
	// This flag allows a Runnable to continue running in the background while the
	// Task executes subsequent Runnables. This is useful to provide services to
	// other Runnables (or to provide debugging support tools like SSH servers).
	Background bool `protobuf:"varint,4,opt,name=background,proto3" json:"background,omitempty"`
	// By default, after a Runnable fails, no further Runnable are executed. This
	// flag indicates that this Runnable must be run even if the Task has already
	// failed. This is useful for Runnables that copy output files off of the VM
	// or for debugging.
	//
	// The always_run flag does not override the Task's overall max_run_duration.
	// If the max_run_duration has expired then no further Runnables will execute,
	// not even always_run Runnables.
	AlwaysRun bool `protobuf:"varint,5,opt,name=always_run,json=alwaysRun,proto3" json:"always_run,omitempty"`
	// Environment variables for this Runnable (overrides variables set for the
	// whole Task or TaskGroup).
	Environment *Environment `protobuf:"bytes,7,opt,name=environment,proto3" json:"environment,omitempty"`
	// Timeout for this Runnable.
	Timeout *durationpb.Duration `protobuf:"bytes,8,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Labels for this Runnable.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

Runnable describes instructions for executing a specific script or container as part of a Task.

func (*Runnable) ClearBarrier 

func (x *Runnable) ClearBarrier()

func (*Runnable) ClearContainer 

func (x *Runnable) ClearContainer()

func (*Runnable) ClearEnvironment 

func (x *Runnable) ClearEnvironment()

func (*Runnable) ClearExecutable 

func (x *Runnable) ClearExecutable()

func (*Runnable) ClearScript 

func (x *Runnable) ClearScript()

func (*Runnable) ClearTimeout 

func (x *Runnable) ClearTimeout()

func (*Runnable) GetAlwaysRun 

func (x *Runnable) GetAlwaysRun() bool

func (*Runnable) GetBackground 

func (x *Runnable) GetBackground() bool

func (*Runnable) GetBarrier 

func (x *Runnable) GetBarrier() *Runnable_Barrier

func (*Runnable) GetContainer 

func (x *Runnable) GetContainer() *Runnable_Container

func (*Runnable) GetEnvironment 

func (x *Runnable) GetEnvironment() *Environment

func (*Runnable) GetExecutable 

func (x *Runnable) GetExecutable() isRunnable_Executable

func (*Runnable) GetIgnoreExitStatus 

func (x *Runnable) GetIgnoreExitStatus() bool

func (*Runnable) GetLabels 

func (x *Runnable) GetLabels() map[string]string

func (*Runnable) GetScript 

func (x *Runnable) GetScript() *Runnable_Script

func (*Runnable) GetTimeout 

func (x *Runnable) GetTimeout() *durationpb.Duration

func (*Runnable) HasBarrier 

func (x *Runnable) HasBarrier() bool

func (*Runnable) HasContainer 

func (x *Runnable) HasContainer() bool

func (*Runnable) HasEnvironment 

func (x *Runnable) HasEnvironment() bool

func (*Runnable) HasExecutable 

func (x *Runnable) HasExecutable() bool

func (*Runnable) HasScript 

func (x *Runnable) HasScript() bool

func (*Runnable) HasTimeout 

func (x *Runnable) HasTimeout() bool

func (*Runnable) ProtoMessage 

func (*Runnable) ProtoMessage()

func (*Runnable) ProtoReflect 

func (x *Runnable) ProtoReflect() protoreflect.Message

func (*Runnable) Reset 

func (x *Runnable) Reset()

func (*Runnable) SetAlwaysRun 

func (x *Runnable) SetAlwaysRun(v bool)

func (*Runnable) SetBackground 

func (x *Runnable) SetBackground(v bool)

func (*Runnable) SetBarrier 

func (x *Runnable) SetBarrier(v *Runnable_Barrier)

func (*Runnable) SetContainer 

func (x *Runnable) SetContainer(v *Runnable_Container)

func (*Runnable) SetEnvironment 

func (x *Runnable) SetEnvironment(v *Environment)

func (*Runnable) SetIgnoreExitStatus 

func (x *Runnable) SetIgnoreExitStatus(v bool)

func (*Runnable) SetLabels 

func (x *Runnable) SetLabels(v map[string]string)

func (*Runnable) SetScript 

func (x *Runnable) SetScript(v *Runnable_Script)

func (*Runnable) SetTimeout 

func (x *Runnable) SetTimeout(v *durationpb.Duration)

func (*Runnable) String 

func (x *Runnable) String() string

func (*Runnable) WhichExecutable 

func (x *Runnable) WhichExecutable() case_Runnable_Executable

type Runnable_Barrier 

type Runnable_Barrier struct {

	// Barriers are identified by their index in runnable list.
	// Names are not required, but if present should be an identifier.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Barrier runnable blocks until all tasks in a taskgroup reach it.

func (*Runnable_Barrier) GetName 

func (x *Runnable_Barrier) GetName() string

func (*Runnable_Barrier) ProtoMessage 

func (*Runnable_Barrier) ProtoMessage()

func (*Runnable_Barrier) ProtoReflect 

func (x *Runnable_Barrier) ProtoReflect() protoreflect.Message

func (*Runnable_Barrier) Reset 

func (x *Runnable_Barrier) Reset()

func (*Runnable_Barrier) SetName 

func (x *Runnable_Barrier) SetName(v string)

func (*Runnable_Barrier) String 

func (x *Runnable_Barrier) String() string

type Runnable_Barrier_ 

type Runnable_Barrier_ struct {
	// Barrier runnable.
	Barrier *Runnable_Barrier `protobuf:"bytes,6,opt,name=barrier,proto3,oneof"`
}

type Runnable_Barrier_builder 

type Runnable_Barrier_builder struct {

	// Barriers are identified by their index in runnable list.
	// Names are not required, but if present should be an identifier.
	Name string
	// contains filtered or unexported fields
}

func (Runnable_Barrier_builder) Build 

func (b0 Runnable_Barrier_builder) Build() *Runnable_Barrier

type Runnable_Container 

type Runnable_Container struct {

	// The URI to pull the container image from.
	ImageUri string `protobuf:"bytes,1,opt,name=image_uri,json=imageUri,proto3" json:"image_uri,omitempty"`
	// Overrides the `CMD` specified in the container. If there is an ENTRYPOINT
	// (either in the container image or with the entrypoint field below) then
	// commands are appended as arguments to the ENTRYPOINT.
	Commands []string `protobuf:"bytes,2,rep,name=commands,proto3" json:"commands,omitempty"`
	// Overrides the `ENTRYPOINT` specified in the container.
	Entrypoint string `protobuf:"bytes,3,opt,name=entrypoint,proto3" json:"entrypoint,omitempty"`
	// Volumes to mount (bind mount) from the host machine files or directories
	// into the container, formatted to match docker run's --volume option,
	// e.g. /foo:/bar, or /foo:/bar:ro
	Volumes []string `protobuf:"bytes,7,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// Arbitrary additional options to include in the "docker run" command when
	// running this container, e.g. "--network host".
	Options string `protobuf:"bytes,8,opt,name=options,proto3" json:"options,omitempty"`
	// If set to true, external network access to and from container will be
	// blocked, containers that are with block_external_network as true can
	// still communicate with each other, network cannot be specified in the
	// `container.options` field.
	BlockExternalNetwork bool `protobuf:"varint,9,opt,name=block_external_network,json=blockExternalNetwork,proto3" json:"block_external_network,omitempty"`
	// Optional username for logging in to a docker registry. If username
	// matches `projects/*/secrets/*/versions/*` then Batch will read the
	// username from the Secret Manager.
	Username string `protobuf:"bytes,10,opt,name=username,proto3" json:"username,omitempty"`
	// Optional password for logging in to a docker registry. If password
	// matches `projects/*/secrets/*/versions/*` then Batch will read the
	// password from the Secret Manager;
	Password string `protobuf:"bytes,11,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

Container runnable.

func (*Runnable_Container) GetBlockExternalNetwork 

func (x *Runnable_Container) GetBlockExternalNetwork() bool

func (*Runnable_Container) GetCommands 

func (x *Runnable_Container) GetCommands() []string

func (*Runnable_Container) GetEntrypoint 

func (x *Runnable_Container) GetEntrypoint() string

func (*Runnable_Container) GetImageUri 

func (x *Runnable_Container) GetImageUri() string

func (*Runnable_Container) GetOptions 

func (x *Runnable_Container) GetOptions() string

func (*Runnable_Container) GetPassword 

func (x *Runnable_Container) GetPassword() string

func (*Runnable_Container) GetUsername 

func (x *Runnable_Container) GetUsername() string

func (*Runnable_Container) GetVolumes 

func (x *Runnable_Container) GetVolumes() []string

func (*Runnable_Container) ProtoMessage 

func (*Runnable_Container) ProtoMessage()

func (*Runnable_Container) ProtoReflect 

func (x *Runnable_Container) ProtoReflect() protoreflect.Message

func (*Runnable_Container) Reset 

func (x *Runnable_Container) Reset()

func (*Runnable_Container) SetBlockExternalNetwork 

func (x *Runnable_Container) SetBlockExternalNetwork(v bool)

func (*Runnable_Container) SetCommands 

func (x *Runnable_Container) SetCommands(v []string)

func (*Runnable_Container) SetEntrypoint 

func (x *Runnable_Container) SetEntrypoint(v string)

func (*Runnable_Container) SetImageUri 

func (x *Runnable_Container) SetImageUri(v string)

func (*Runnable_Container) SetOptions 

func (x *Runnable_Container) SetOptions(v string)

func (*Runnable_Container) SetPassword 

func (x *Runnable_Container) SetPassword(v string)

func (*Runnable_Container) SetUsername 

func (x *Runnable_Container) SetUsername(v string)

func (*Runnable_Container) SetVolumes 

func (x *Runnable_Container) SetVolumes(v []string)

func (*Runnable_Container) String 

func (x *Runnable_Container) String() string

type Runnable_Container_ 

type Runnable_Container_ struct {
	// Container runnable.
	Container *Runnable_Container `protobuf:"bytes,1,opt,name=container,proto3,oneof"`
}

type Runnable_Container_builder 

type Runnable_Container_builder struct {

	// The URI to pull the container image from.
	ImageUri string
	// Overrides the `CMD` specified in the container. If there is an ENTRYPOINT
	// (either in the container image or with the entrypoint field below) then
	// commands are appended as arguments to the ENTRYPOINT.
	Commands []string
	// Overrides the `ENTRYPOINT` specified in the container.
	Entrypoint string
	// Volumes to mount (bind mount) from the host machine files or directories
	// into the container, formatted to match docker run's --volume option,
	// e.g. /foo:/bar, or /foo:/bar:ro
	Volumes []string
	// Arbitrary additional options to include in the "docker run" command when
	// running this container, e.g. "--network host".
	Options string
	// If set to true, external network access to and from container will be
	// blocked, containers that are with block_external_network as true can
	// still communicate with each other, network cannot be specified in the
	// `container.options` field.
	BlockExternalNetwork bool
	// Optional username for logging in to a docker registry. If username
	// matches `projects/*/secrets/*/versions/*` then Batch will read the
	// username from the Secret Manager.
	Username string
	// Optional password for logging in to a docker registry. If password
	// matches `projects/*/secrets/*/versions/*` then Batch will read the
	// password from the Secret Manager;
	Password string
	// contains filtered or unexported fields
}

func (Runnable_Container_builder) Build 

func (b0 Runnable_Container_builder) Build() *Runnable_Container

type Runnable_Script 

type Runnable_Script struct {

	// Types that are valid to be assigned to Command:
	//
	//	*Runnable_Script_Path
	//	*Runnable_Script_Text
	Command isRunnable_Script_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

Script runnable.

func (*Runnable_Script) ClearCommand 

func (x *Runnable_Script) ClearCommand()

func (*Runnable_Script) ClearPath 

func (x *Runnable_Script) ClearPath()

func (*Runnable_Script) ClearText 

func (x *Runnable_Script) ClearText()

func (*Runnable_Script) GetCommand 

func (x *Runnable_Script) GetCommand() isRunnable_Script_Command

func (*Runnable_Script) GetPath 

func (x *Runnable_Script) GetPath() string

func (*Runnable_Script) GetText 

func (x *Runnable_Script) GetText() string

func (*Runnable_Script) HasCommand 

func (x *Runnable_Script) HasCommand() bool

func (*Runnable_Script) HasPath 

func (x *Runnable_Script) HasPath() bool

func (*Runnable_Script) HasText 

func (x *Runnable_Script) HasText() bool

func (*Runnable_Script) ProtoMessage 

func (*Runnable_Script) ProtoMessage()

func (*Runnable_Script) ProtoReflect 

func (x *Runnable_Script) ProtoReflect() protoreflect.Message

func (*Runnable_Script) Reset 

func (x *Runnable_Script) Reset()

func (*Runnable_Script) SetPath 

func (x *Runnable_Script) SetPath(v string)

func (*Runnable_Script) SetText 

func (x *Runnable_Script) SetText(v string)

func (*Runnable_Script) String 

func (x *Runnable_Script) String() string

func (*Runnable_Script) WhichCommand 

func (x *Runnable_Script) WhichCommand() case_Runnable_Script_Command

type Runnable_Script_ 

type Runnable_Script_ struct {
	// Script runnable.
	Script *Runnable_Script `protobuf:"bytes,2,opt,name=script,proto3,oneof"`
}

type Runnable_Script_Path 

type Runnable_Script_Path struct {
	// Script file path on the host VM.
	//
	// To specify an interpreter, please add a `#!<interpreter>`(also known as
	// [shebang line](https://en.wikipedia.org/wiki/Shebang_(Unix))) as the
	// first line of the file.(For example, to execute the script using bash,
	// `#!/bin/bash` should be the first line of the file. To execute the
	// script using`Python3`, `#!/usr/bin/env python3` should be the first
	// line of the file.) Otherwise, the file will by default be excuted by
	// `/bin/sh`.
	Path string `protobuf:"bytes,1,opt,name=path,proto3,oneof"`
}

type Runnable_Script_Text 

type Runnable_Script_Text struct {
	// Shell script text.
	//
	// To specify an interpreter, please add a `#!<interpreter>\n` at the
	// beginning of the text.(For example, to execute the script using bash,
	// `#!/bin/bash\n` should be added. To execute the script using`Python3`,
	// `#!/usr/bin/env python3\n` should be added.) Otherwise, the script will
	// by default be excuted by `/bin/sh`.
	Text string `protobuf:"bytes,2,opt,name=text,proto3,oneof"`
}

type Runnable_Script_builder 

type Runnable_Script_builder struct {

	// Fields of oneof Command:
	// Script file path on the host VM.
	//
	// To specify an interpreter, please add a `#!<interpreter>`(also known as
	// [shebang line](https://en.wikipedia.org/wiki/Shebang_(Unix))) as the
	// first line of the file.(For example, to execute the script using bash,
	// `#!/bin/bash` should be the first line of the file. To execute the
	// script using`Python3`, `#!/usr/bin/env python3` should be the first
	// line of the file.) Otherwise, the file will by default be excuted by
	// `/bin/sh`.
	Path *string
	// Shell script text.
	//
	// To specify an interpreter, please add a `#!<interpreter>\n` at the
	// beginning of the text.(For example, to execute the script using bash,
	// `#!/bin/bash\n` should be added. To execute the script using`Python3`,
	// `#!/usr/bin/env python3\n` should be added.) Otherwise, the script will
	// by default be excuted by `/bin/sh`.
	Text *string
	// contains filtered or unexported fields
}

func (Runnable_Script_builder) Build 

func (b0 Runnable_Script_builder) Build() *Runnable_Script

type Runnable_builder 

type Runnable_builder struct {

	// Fields of oneof Executable:
	// Container runnable.
	Container *Runnable_Container
	// Script runnable.
	Script *Runnable_Script
	// Barrier runnable.
	Barrier *Runnable_Barrier
	// -- end of Executable
	// Normally, a non-zero exit status causes the Task to fail. This flag allows
	// execution of other Runnables to continue instead.
	IgnoreExitStatus bool
	// This flag allows a Runnable to continue running in the background while the
	// Task executes subsequent Runnables. This is useful to provide services to
	// other Runnables (or to provide debugging support tools like SSH servers).
	Background bool
	// By default, after a Runnable fails, no further Runnable are executed. This
	// flag indicates that this Runnable must be run even if the Task has already
	// failed. This is useful for Runnables that copy output files off of the VM
	// or for debugging.
	//
	// The always_run flag does not override the Task's overall max_run_duration.
	// If the max_run_duration has expired then no further Runnables will execute,
	// not even always_run Runnables.
	AlwaysRun bool
	// Environment variables for this Runnable (overrides variables set for the
	// whole Task or TaskGroup).
	Environment *Environment
	// Timeout for this Runnable.
	Timeout *durationpb.Duration
	// Labels for this Runnable.
	Labels map[string]string
	// contains filtered or unexported fields
}

func (Runnable_builder) Build 

func (b0 Runnable_builder) Build() *Runnable

type 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. If instance
	// template is being used, the service account has to be specified in the
	// instance template and it has to match the email field here.
	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) GetEmail 

func (x *ServiceAccount) GetEmail() string

func (*ServiceAccount) GetScopes 

func (x *ServiceAccount) GetScopes() []string

func (*ServiceAccount) ProtoMessage 

func (*ServiceAccount) ProtoMessage()

func (*ServiceAccount) ProtoReflect 

func (x *ServiceAccount) ProtoReflect() protoreflect.Message

func (*ServiceAccount) Reset 

func (x *ServiceAccount) Reset()

func (*ServiceAccount) SetEmail 

func (x *ServiceAccount) SetEmail(v string)

func (*ServiceAccount) SetScopes 

func (x *ServiceAccount) SetScopes(v []string)

func (*ServiceAccount) String 

func (x *ServiceAccount) String() string

type ServiceAccount_builder 

type ServiceAccount_builder struct {

	// Email address of the service account. If not specified, the default
	// Compute Engine service account for the project will be used. If instance
	// template is being used, the service account has to be specified in the
	// instance template and it has to match the email field here.
	Email string
	// 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
	// contains filtered or unexported fields
}

func (ServiceAccount_builder) Build 

func (b0 ServiceAccount_builder) Build() *ServiceAccount

type StatusEvent 

type StatusEvent struct {

	// Type of the event.
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// Description of the event.
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	// The time this event occurred.
	EventTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	// Task Execution
	TaskExecution *TaskExecution `protobuf:"bytes,4,opt,name=task_execution,json=taskExecution,proto3" json:"task_execution,omitempty"`
	// Task State
	TaskState TaskStatus_State `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

Status event

func (*StatusEvent) ClearEventTime 

func (x *StatusEvent) ClearEventTime()

func (*StatusEvent) ClearTaskExecution 

func (x *StatusEvent) ClearTaskExecution()

func (*StatusEvent) GetDescription 

func (x *StatusEvent) GetDescription() string

func (*StatusEvent) GetEventTime 

func (x *StatusEvent) GetEventTime() *timestamppb.Timestamp

func (*StatusEvent) GetTaskExecution 

func (x *StatusEvent) GetTaskExecution() *TaskExecution

func (*StatusEvent) GetTaskState 

func (x *StatusEvent) GetTaskState() TaskStatus_State

func (*StatusEvent) GetType 

func (x *StatusEvent) GetType() string

func (*StatusEvent) HasEventTime 

func (x *StatusEvent) HasEventTime() bool

func (*StatusEvent) HasTaskExecution 

func (x *StatusEvent) HasTaskExecution() bool

func (*StatusEvent) ProtoMessage 

func (*StatusEvent) ProtoMessage()

func (*StatusEvent) ProtoReflect 

func (x *StatusEvent) ProtoReflect() protoreflect.Message

func (*StatusEvent) Reset 

func (x *StatusEvent) Reset()

func (*StatusEvent) SetDescription 

func (x *StatusEvent) SetDescription(v string)

func (*StatusEvent) SetEventTime 

func (x *StatusEvent) SetEventTime(v *timestamppb.Timestamp)

func (*StatusEvent) SetTaskExecution 

func (x *StatusEvent) SetTaskExecution(v *TaskExecution)

func (*StatusEvent) SetTaskState 

func (x *StatusEvent) SetTaskState(v TaskStatus_State)

func (*StatusEvent) SetType 

func (x *StatusEvent) SetType(v string)

func (*StatusEvent) String 

func (x *StatusEvent) String() string

type StatusEvent_builder 

type StatusEvent_builder struct {

	// Type of the event.
	Type string
	// Description of the event.
	Description string
	// The time this event occurred.
	EventTime *timestamppb.Timestamp
	// Task Execution
	TaskExecution *TaskExecution
	// Task State
	TaskState TaskStatus_State
	// contains filtered or unexported fields
}

func (StatusEvent_builder) Build 

func (b0 StatusEvent_builder) Build() *StatusEvent

type TaskExecution 

type TaskExecution struct {

	// When task is completed as the status of FAILED or SUCCEEDED,
	// exit code is for one task execution result, default is 0 as success.
	ExitCode int32 `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// contains filtered or unexported fields
}

This Task Execution field includes detail information for task execution procedures, based on StatusEvent types.

func (*TaskExecution) GetExitCode 

func (x *TaskExecution) GetExitCode() int32

func (*TaskExecution) ProtoMessage 

func (*TaskExecution) ProtoMessage()

func (*TaskExecution) ProtoReflect 

func (x *TaskExecution) ProtoReflect() protoreflect.Message

func (*TaskExecution) Reset 

func (x *TaskExecution) Reset()

func (*TaskExecution) SetExitCode 

func (x *TaskExecution) SetExitCode(v int32)

func (*TaskExecution) String 

func (x *TaskExecution) String() string

type TaskExecution_builder 

type TaskExecution_builder struct {

	// When task is completed as the status of FAILED or SUCCEEDED,
	// exit code is for one task execution result, default is 0 as success.
	ExitCode int32
	// contains filtered or unexported fields
}

func (TaskExecution_builder) Build 

func (b0 TaskExecution_builder) Build() *TaskExecution

type TaskGroup 

type TaskGroup struct {

	// Output only. TaskGroup name.
	// The system generates this field based on parent Job name.
	// For example:
	// "projects/123456/locations/us-west1/jobs/job01/taskGroups/group01".
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. Tasks in the group share the same task spec.
	TaskSpec *TaskSpec `protobuf:"bytes,3,opt,name=task_spec,json=taskSpec,proto3" json:"task_spec,omitempty"`
	// Number of Tasks in the TaskGroup.
	// Default is 1.
	TaskCount int64 `protobuf:"varint,4,opt,name=task_count,json=taskCount,proto3" json:"task_count,omitempty"`
	// Max number of tasks that can run in parallel.
	// Default to min(task_count, 1000).
	// Field parallelism must be 1 if the scheduling_policy is IN_ORDER.
	Parallelism int64 `protobuf:"varint,5,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	// Scheduling policy for Tasks in the TaskGroup.
	// The default value is AS_SOON_AS_POSSIBLE.
	SchedulingPolicy TaskGroup_SchedulingPolicy `` /* 171-byte string literal not displayed */
	// An array of environment variable mappings, which are passed to Tasks with
	// matching indices. If task_environments is used then task_count should
	// not be specified in the request (and will be ignored). Task count will be
	// the length of task_environments.
	//
	// Tasks get a BATCH_TASK_INDEX and BATCH_TASK_COUNT environment variable, in
	// addition to any environment variables set in task_environments, specifying
	// the number of Tasks in the Task's parent TaskGroup, and the specific Task's
	// index in the TaskGroup (0 through BATCH_TASK_COUNT - 1).
	TaskEnvironments []*Environment `protobuf:"bytes,9,rep,name=task_environments,json=taskEnvironments,proto3" json:"task_environments,omitempty"`
	// Max number of tasks that can be run on a VM at the same time.
	// If not specified, the system will decide a value based on available
	// compute resources on a VM and task requirements.
	TaskCountPerNode int64 `protobuf:"varint,10,opt,name=task_count_per_node,json=taskCountPerNode,proto3" json:"task_count_per_node,omitempty"`
	// When true, Batch will populate a file with a list of all VMs assigned to
	// the TaskGroup and set the BATCH_HOSTS_FILE environment variable to the path
	// of that file. Defaults to false.
	RequireHostsFile bool `protobuf:"varint,11,opt,name=require_hosts_file,json=requireHostsFile,proto3" json:"require_hosts_file,omitempty"`
	// When true, Batch will configure SSH to allow passwordless login between
	// VMs running the Batch tasks in the same TaskGroup.
	PermissiveSsh bool `protobuf:"varint,12,opt,name=permissive_ssh,json=permissiveSsh,proto3" json:"permissive_ssh,omitempty"`
	// contains filtered or unexported fields
}

A TaskGroup defines one or more Tasks that all share the same TaskSpec.

func (*TaskGroup) ClearTaskSpec 

func (x *TaskGroup) ClearTaskSpec()

func (*TaskGroup) GetName 

func (x *TaskGroup) GetName() string

func (*TaskGroup) GetParallelism 

func (x *TaskGroup) GetParallelism() int64

func (*TaskGroup) GetPermissiveSsh 

func (x *TaskGroup) GetPermissiveSsh() bool

func (*TaskGroup) GetRequireHostsFile 

func (x *TaskGroup) GetRequireHostsFile() bool

func (*TaskGroup) GetSchedulingPolicy 

func (x *TaskGroup) GetSchedulingPolicy() TaskGroup_SchedulingPolicy

func (*TaskGroup) GetTaskCount 

func (x *TaskGroup) GetTaskCount() int64

func (*TaskGroup) GetTaskCountPerNode 

func (x *TaskGroup) GetTaskCountPerNode() int64

func (*TaskGroup) GetTaskEnvironments 

func (x *TaskGroup) GetTaskEnvironments() []*Environment

func (*TaskGroup) GetTaskSpec 

func (x *TaskGroup) GetTaskSpec() *TaskSpec

func (*TaskGroup) HasTaskSpec 

func (x *TaskGroup) HasTaskSpec() bool

func (*TaskGroup) ProtoMessage 

func (*TaskGroup) ProtoMessage()

func (*TaskGroup) ProtoReflect 

func (x *TaskGroup) ProtoReflect() protoreflect.Message

func (*TaskGroup) Reset 

func (x *TaskGroup) Reset()

func (*TaskGroup) SetName 

func (x *TaskGroup) SetName(v string)

func (*TaskGroup) SetParallelism 

func (x *TaskGroup) SetParallelism(v int64)

func (*TaskGroup) SetPermissiveSsh 

func (x *TaskGroup) SetPermissiveSsh(v bool)

func (*TaskGroup) SetRequireHostsFile 

func (x *TaskGroup) SetRequireHostsFile(v bool)

func (*TaskGroup) SetSchedulingPolicy 

func (x *TaskGroup) SetSchedulingPolicy(v TaskGroup_SchedulingPolicy)

func (*TaskGroup) SetTaskCount 

func (x *TaskGroup) SetTaskCount(v int64)

func (*TaskGroup) SetTaskCountPerNode 

func (x *TaskGroup) SetTaskCountPerNode(v int64)

func (*TaskGroup) SetTaskEnvironments 

func (x *TaskGroup) SetTaskEnvironments(v []*Environment)

func (*TaskGroup) SetTaskSpec 

func (x *TaskGroup) SetTaskSpec(v *TaskSpec)

func (*TaskGroup) String 

func (x *TaskGroup) String() string

type TaskGroup_SchedulingPolicy 

type TaskGroup_SchedulingPolicy int32

How Tasks in the TaskGroup should be scheduled relative to each other. 

const (
	// Unspecified.
	TaskGroup_SCHEDULING_POLICY_UNSPECIFIED TaskGroup_SchedulingPolicy = 0
	// Run Tasks as soon as resources are available.
	//
	// Tasks might be executed in parallel depending on parallelism and
	// task_count values.
	TaskGroup_AS_SOON_AS_POSSIBLE TaskGroup_SchedulingPolicy = 1
	// Run Tasks sequentially with increased task index.
	TaskGroup_IN_ORDER TaskGroup_SchedulingPolicy = 2
)

func (TaskGroup_SchedulingPolicy) Descriptor 

func (TaskGroup_SchedulingPolicy) Descriptor() protoreflect.EnumDescriptor

func (TaskGroup_SchedulingPolicy) Enum 

func (x TaskGroup_SchedulingPolicy) Enum() *TaskGroup_SchedulingPolicy

func (TaskGroup_SchedulingPolicy) Number 

func (x TaskGroup_SchedulingPolicy) Number() protoreflect.EnumNumber

func (TaskGroup_SchedulingPolicy) String 

func (x TaskGroup_SchedulingPolicy) String() string

func (TaskGroup_SchedulingPolicy) Type 

func (TaskGroup_SchedulingPolicy) Type() protoreflect.EnumType

type TaskGroup_builder 

type TaskGroup_builder struct {

	// Output only. TaskGroup name.
	// The system generates this field based on parent Job name.
	// For example:
	// "projects/123456/locations/us-west1/jobs/job01/taskGroups/group01".
	Name string
	// Required. Tasks in the group share the same task spec.
	TaskSpec *TaskSpec
	// Number of Tasks in the TaskGroup.
	// Default is 1.
	TaskCount int64
	// Max number of tasks that can run in parallel.
	// Default to min(task_count, 1000).
	// Field parallelism must be 1 if the scheduling_policy is IN_ORDER.
	Parallelism int64
	// Scheduling policy for Tasks in the TaskGroup.
	// The default value is AS_SOON_AS_POSSIBLE.
	SchedulingPolicy TaskGroup_SchedulingPolicy
	// An array of environment variable mappings, which are passed to Tasks with
	// matching indices. If task_environments is used then task_count should
	// not be specified in the request (and will be ignored). Task count will be
	// the length of task_environments.
	//
	// Tasks get a BATCH_TASK_INDEX and BATCH_TASK_COUNT environment variable, in
	// addition to any environment variables set in task_environments, specifying
	// the number of Tasks in the Task's parent TaskGroup, and the specific Task's
	// index in the TaskGroup (0 through BATCH_TASK_COUNT - 1).
	TaskEnvironments []*Environment
	// Max number of tasks that can be run on a VM at the same time.
	// If not specified, the system will decide a value based on available
	// compute resources on a VM and task requirements.
	TaskCountPerNode int64
	// When true, Batch will populate a file with a list of all VMs assigned to
	// the TaskGroup and set the BATCH_HOSTS_FILE environment variable to the path
	// of that file. Defaults to false.
	RequireHostsFile bool
	// When true, Batch will configure SSH to allow passwordless login between
	// VMs running the Batch tasks in the same TaskGroup.
	PermissiveSsh bool
	// contains filtered or unexported fields
}

func (TaskGroup_builder) Build 

func (b0 TaskGroup_builder) Build() *TaskGroup

type TaskSpec 

type TaskSpec struct {

	// The sequence of scripts or containers to run for this Task. Each Task using
	// this TaskSpec executes its list of runnables in order. The Task succeeds if
	// all of its runnables either exit with a zero status or any that exit with a
	// non-zero status have the ignore_exit_status flag.
	//
	// Background runnables are killed automatically (if they have not already
	// exited) a short time after all foreground runnables have completed. Even
	// though this is likely to result in a non-zero exit status for the
	// background runnable, these automatic kills are not treated as Task
	// failures.
	Runnables []*Runnable `protobuf:"bytes,8,rep,name=runnables,proto3" json:"runnables,omitempty"`
	// ComputeResource requirements.
	ComputeResource *ComputeResource `protobuf:"bytes,3,opt,name=compute_resource,json=computeResource,proto3" json:"compute_resource,omitempty"`
	// Maximum duration the task should run.
	// The task will be killed and marked as FAILED if over this limit.
	MaxRunDuration *durationpb.Duration `protobuf:"bytes,4,opt,name=max_run_duration,json=maxRunDuration,proto3" json:"max_run_duration,omitempty"`
	// Maximum number of retries on failures.
	// The default, 0, which means never retry.
	// The valid value range is [0, 10].
	MaxRetryCount int32 `protobuf:"varint,5,opt,name=max_retry_count,json=maxRetryCount,proto3" json:"max_retry_count,omitempty"`
	// Lifecycle management schema when any task in a task group is failed.
	// Currently we only support one lifecycle policy.
	// When the lifecycle policy condition is met,
	// the action in the policy will execute.
	// If task execution result does not meet with the defined lifecycle
	// policy, we consider it as the default policy.
	// Default policy means if the exit code is 0, exit task.
	// If task ends with non-zero exit code, retry the task with max_retry_count.
	LifecyclePolicies []*LifecyclePolicy `protobuf:"bytes,9,rep,name=lifecycle_policies,json=lifecyclePolicies,proto3" json:"lifecycle_policies,omitempty"`
	// Deprecated: please use environment(non-plural) instead.
	Environments map[string]string `` /* 151-byte string literal not displayed */
	// Volumes to mount before running Tasks using this TaskSpec.
	Volumes []*Volume `protobuf:"bytes,7,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// Environment variables to set before running the Task.
	Environment *Environment `protobuf:"bytes,10,opt,name=environment,proto3" json:"environment,omitempty"`
	// contains filtered or unexported fields
}

Spec of a task

func (*TaskSpec) ClearComputeResource 

func (x *TaskSpec) ClearComputeResource()

func (*TaskSpec) ClearEnvironment 

func (x *TaskSpec) ClearEnvironment()

func (*TaskSpec) ClearMaxRunDuration 

func (x *TaskSpec) ClearMaxRunDuration()

func (*TaskSpec) GetComputeResource 

func (x *TaskSpec) GetComputeResource() *ComputeResource

func (*TaskSpec) GetEnvironment 

func (x *TaskSpec) GetEnvironment() *Environment

func (*TaskSpec) GetEnvironments 

func (x *TaskSpec) GetEnvironments() map[string]string

func (*TaskSpec) GetLifecyclePolicies 

func (x *TaskSpec) GetLifecyclePolicies() []*LifecyclePolicy

func (*TaskSpec) GetMaxRetryCount 

func (x *TaskSpec) GetMaxRetryCount() int32

func (*TaskSpec) GetMaxRunDuration 

func (x *TaskSpec) GetMaxRunDuration() *durationpb.Duration

func (*TaskSpec) GetRunnables 

func (x *TaskSpec) GetRunnables() []*Runnable

func (*TaskSpec) GetVolumes 

func (x *TaskSpec) GetVolumes() []*Volume

func (*TaskSpec) HasComputeResource 

func (x *TaskSpec) HasComputeResource() bool

func (*TaskSpec) HasEnvironment 

func (x *TaskSpec) HasEnvironment() bool

func (*TaskSpec) HasMaxRunDuration 

func (x *TaskSpec) HasMaxRunDuration() bool

func (*TaskSpec) ProtoMessage 

func (*TaskSpec) ProtoMessage()

func (*TaskSpec) ProtoReflect 

func (x *TaskSpec) ProtoReflect() protoreflect.Message

func (*TaskSpec) Reset 

func (x *TaskSpec) Reset()

func (*TaskSpec) SetComputeResource 

func (x *TaskSpec) SetComputeResource(v *ComputeResource)

func (*TaskSpec) SetEnvironment 

func (x *TaskSpec) SetEnvironment(v *Environment)

func (*TaskSpec) SetEnvironments 

func (x *TaskSpec) SetEnvironments(v map[string]string)

func (*TaskSpec) SetLifecyclePolicies 

func (x *TaskSpec) SetLifecyclePolicies(v []*LifecyclePolicy)

func (*TaskSpec) SetMaxRetryCount 

func (x *TaskSpec) SetMaxRetryCount(v int32)

func (*TaskSpec) SetMaxRunDuration 

func (x *TaskSpec) SetMaxRunDuration(v *durationpb.Duration)

func (*TaskSpec) SetRunnables 

func (x *TaskSpec) SetRunnables(v []*Runnable)

func (*TaskSpec) SetVolumes 

func (x *TaskSpec) SetVolumes(v []*Volume)

func (*TaskSpec) String 

func (x *TaskSpec) String() string

type TaskSpec_builder 

type TaskSpec_builder struct {

	// The sequence of scripts or containers to run for this Task. Each Task using
	// this TaskSpec executes its list of runnables in order. The Task succeeds if
	// all of its runnables either exit with a zero status or any that exit with a
	// non-zero status have the ignore_exit_status flag.
	//
	// Background runnables are killed automatically (if they have not already
	// exited) a short time after all foreground runnables have completed. Even
	// though this is likely to result in a non-zero exit status for the
	// background runnable, these automatic kills are not treated as Task
	// failures.
	Runnables []*Runnable
	// ComputeResource requirements.
	ComputeResource *ComputeResource
	// Maximum duration the task should run.
	// The task will be killed and marked as FAILED if over this limit.
	MaxRunDuration *durationpb.Duration
	// Maximum number of retries on failures.
	// The default, 0, which means never retry.
	// The valid value range is [0, 10].
	MaxRetryCount int32
	// Lifecycle management schema when any task in a task group is failed.
	// Currently we only support one lifecycle policy.
	// When the lifecycle policy condition is met,
	// the action in the policy will execute.
	// If task execution result does not meet with the defined lifecycle
	// policy, we consider it as the default policy.
	// Default policy means if the exit code is 0, exit task.
	// If task ends with non-zero exit code, retry the task with max_retry_count.
	LifecyclePolicies []*LifecyclePolicy
	// Deprecated: please use environment(non-plural) instead.
	Environments map[string]string
	// Volumes to mount before running Tasks using this TaskSpec.
	Volumes []*Volume
	// Environment variables to set before running the Task.
	Environment *Environment
	// contains filtered or unexported fields
}

func (TaskSpec_builder) Build 

func (b0 TaskSpec_builder) Build() *TaskSpec

type TaskStatus 

type TaskStatus struct {
	// contains filtered or unexported fields
}

Status of a task

func (*TaskStatus) ProtoMessage 

func (*TaskStatus) ProtoMessage()

func (*TaskStatus) ProtoReflect 

func (x *TaskStatus) ProtoReflect() protoreflect.Message

func (*TaskStatus) Reset 

func (x *TaskStatus) Reset()

func (*TaskStatus) String 

func (x *TaskStatus) String() string

type TaskStatus_State 

type TaskStatus_State int32

Task states. 

const (
	// Unknown state.
	TaskStatus_STATE_UNSPECIFIED TaskStatus_State = 0
	// The Task is created and waiting for resources.
	TaskStatus_PENDING TaskStatus_State = 1
	// The Task is assigned to at least one VM.
	TaskStatus_ASSIGNED TaskStatus_State = 2
	// The Task is running.
	TaskStatus_RUNNING TaskStatus_State = 3
	// The Task has failed.
	TaskStatus_FAILED TaskStatus_State = 4
	// The Task has succeeded.
	TaskStatus_SUCCEEDED TaskStatus_State = 5
	// The Task has not been executed when the Job finishes.
	TaskStatus_UNEXECUTED TaskStatus_State = 6
)

func (TaskStatus_State) Descriptor 

func (TaskStatus_State) Descriptor() protoreflect.EnumDescriptor

func (TaskStatus_State) Enum 

func (x TaskStatus_State) Enum() *TaskStatus_State

func (TaskStatus_State) Number 

func (x TaskStatus_State) Number() protoreflect.EnumNumber

func (TaskStatus_State) String 

func (x TaskStatus_State) String() string

func (TaskStatus_State) Type 

func (TaskStatus_State) Type() protoreflect.EnumType

type TaskStatus_builder 

type TaskStatus_builder struct {
	// contains filtered or unexported fields
}

func (TaskStatus_builder) Build 

func (b0 TaskStatus_builder) Build() *TaskStatus

type Volume 

type Volume struct {

	// The source for the volume.
	//
	// Types that are valid to be assigned to Source:
	//
	//	*Volume_Nfs
	//	*Volume_Gcs
	//	*Volume_DeviceName
	Source isVolume_Source `protobuf_oneof:"source"`
	// The mount path for the volume, e.g. /mnt/disks/share.
	MountPath string `protobuf:"bytes,4,opt,name=mount_path,json=mountPath,proto3" json:"mount_path,omitempty"`
	// For Google Cloud Storage (GCS), mount options are the options supported by
	// the gcsfuse tool (https://github.com/GoogleCloudPlatform/gcsfuse).
	// For existing persistent disks, mount options provided by the
	// mount command (https://man7.org/linux/man-pages/man8/mount.8.html) except
	// writing are supported. This is due to restrictions of multi-writer mode
	// (https://cloud.google.com/compute/docs/disks/sharing-disks-between-vms).
	// For other attached disks and Network File System (NFS), mount options are
	// these supported by the mount command
	// (https://man7.org/linux/man-pages/man8/mount.8.html).
	MountOptions []string `protobuf:"bytes,5,rep,name=mount_options,json=mountOptions,proto3" json:"mount_options,omitempty"`
	// contains filtered or unexported fields
}

Volume describes a volume and parameters for it to be mounted to a VM.

func (*Volume) ClearDeviceName 

func (x *Volume) ClearDeviceName()

func (*Volume) ClearGcs 

func (x *Volume) ClearGcs()

func (*Volume) ClearNfs 

func (x *Volume) ClearNfs()

func (*Volume) ClearSource 

func (x *Volume) ClearSource()

func (*Volume) GetDeviceName 

func (x *Volume) GetDeviceName() string

func (*Volume) GetGcs 

func (x *Volume) GetGcs() *GCS

func (*Volume) GetMountOptions 

func (x *Volume) GetMountOptions() []string

func (*Volume) GetMountPath 

func (x *Volume) GetMountPath() string

func (*Volume) GetNfs 

func (x *Volume) GetNfs() *NFS

func (*Volume) GetSource 

func (x *Volume) GetSource() isVolume_Source

func (*Volume) HasDeviceName 

func (x *Volume) HasDeviceName() bool

func (*Volume) HasGcs 

func (x *Volume) HasGcs() bool

func (*Volume) HasNfs 

func (x *Volume) HasNfs() bool

func (*Volume) HasSource 

func (x *Volume) HasSource() bool

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) ProtoReflect 

func (x *Volume) ProtoReflect() protoreflect.Message

func (*Volume) Reset 

func (x *Volume) Reset()

func (*Volume) SetDeviceName 

func (x *Volume) SetDeviceName(v string)

func (*Volume) SetGcs 

func (x *Volume) SetGcs(v *GCS)

func (*Volume) SetMountOptions 

func (x *Volume) SetMountOptions(v []string)

func (*Volume) SetMountPath 

func (x *Volume) SetMountPath(v string)

func (*Volume) SetNfs 

func (x *Volume) SetNfs(v *NFS)

func (*Volume) String 

func (x *Volume) String() string

func (*Volume) WhichSource 

func (x *Volume) WhichSource() case_Volume_Source

type Volume_DeviceName 

type Volume_DeviceName struct {
	// Device name of an attached disk volume, which should align with a
	// device_name specified by
	// job.allocation_policy.instances[0].policy.disks[i].device_name or
	// defined by the given instance template in
	// job.allocation_policy.instances[0].instance_template.
	DeviceName string `protobuf:"bytes,6,opt,name=device_name,json=deviceName,proto3,oneof"`
}

type Volume_Gcs 

type Volume_Gcs struct {
	// A Google Cloud Storage (GCS) volume.
	Gcs *GCS `protobuf:"bytes,3,opt,name=gcs,proto3,oneof"`
}

type Volume_Nfs 

type Volume_Nfs struct {
	// A Network File System (NFS) volume. For example, a
	// Filestore file share.
	Nfs *NFS `protobuf:"bytes,1,opt,name=nfs,proto3,oneof"`
}

type Volume_builder 

type Volume_builder struct {

	// Fields of oneof Source:
	// A Network File System (NFS) volume. For example, a
	// Filestore file share.
	Nfs *NFS
	// A Google Cloud Storage (GCS) volume.
	Gcs *GCS
	// Device name of an attached disk volume, which should align with a
	// device_name specified by
	// job.allocation_policy.instances[0].policy.disks[i].device_name or
	// defined by the given instance template in
	// job.allocation_policy.instances[0].instance_template.
	DeviceName *string
	// -- end of Source
	// The mount path for the volume, e.g. /mnt/disks/share.
	MountPath string
	// For Google Cloud Storage (GCS), mount options are the options supported by
	// the gcsfuse tool (https://github.com/GoogleCloudPlatform/gcsfuse).
	// For existing persistent disks, mount options provided by the
	// mount command (https://man7.org/linux/man-pages/man8/mount.8.html) except
	// writing are supported. This is due to restrictions of multi-writer mode
	// (https://cloud.google.com/compute/docs/disks/sharing-disks-between-vms).
	// For other attached disks and Network File System (NFS), mount options are
	// these supported by the mount command
	// (https://man7.org/linux/man-pages/man8/mount.8.html).
	MountOptions []string
	// contains filtered or unexported fields
}

func (Volume_builder) Build 

func (b0 Volume_builder) Build() *Volume

Source Files

  • data.pb.go
  • events.pb.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.