Versions in this module Expand all Collapse all v0 v0.9.0 Sep 26, 2024 v0.8.0 Mar 29, 2024 Changes in this version + var AllocationPolicy_ProvisioningModel_name = map[int32]string + var AllocationPolicy_ProvisioningModel_value = map[string]int32 + var File_cloud_batch_v1_data_proto protoreflect.FileDescriptor + var JobNotification_Type_name = map[int32]string + var JobNotification_Type_value = map[string]int32 + var JobStatus_State_name = map[int32]string + var JobStatus_State_value = map[string]int32 + var LifecyclePolicy_Action_name = map[int32]string + var LifecyclePolicy_Action_value = map[string]int32 + var LogsPolicy_Destination_name = map[int32]string + var LogsPolicy_Destination_value = map[string]int32 + var TaskGroup_SchedulingPolicy_name = map[int32]string + var TaskGroup_SchedulingPolicy_value = map[string]int32 + var TaskStatus_State_name = map[int32]string + var TaskStatus_State_value = map[string]int32 + type AllocationPolicy struct + Instances []*AllocationPolicy_InstancePolicyOrTemplate + Labels map[string]string + Location *AllocationPolicy_LocationPolicy + Network *AllocationPolicy_NetworkPolicy + Placement *AllocationPolicy_PlacementPolicy + ServiceAccount *ServiceAccount + func (*AllocationPolicy) Descriptor() ([]byte, []int) + func (*AllocationPolicy) ProtoMessage() + func (x *AllocationPolicy) GetInstances() []*AllocationPolicy_InstancePolicyOrTemplate + func (x *AllocationPolicy) GetLabels() map[string]string + func (x *AllocationPolicy) GetLocation() *AllocationPolicy_LocationPolicy + func (x *AllocationPolicy) GetNetwork() *AllocationPolicy_NetworkPolicy + func (x *AllocationPolicy) GetPlacement() *AllocationPolicy_PlacementPolicy + func (x *AllocationPolicy) GetServiceAccount() *ServiceAccount + func (x *AllocationPolicy) ProtoReflect() protoreflect.Message + func (x *AllocationPolicy) Reset() + func (x *AllocationPolicy) String() string + type AllocationPolicy_Accelerator struct + Count int64 + InstallGpuDrivers bool + Type string + func (*AllocationPolicy_Accelerator) Descriptor() ([]byte, []int) + func (*AllocationPolicy_Accelerator) ProtoMessage() + func (x *AllocationPolicy_Accelerator) GetCount() int64 + func (x *AllocationPolicy_Accelerator) GetInstallGpuDrivers() bool + func (x *AllocationPolicy_Accelerator) GetType() string + func (x *AllocationPolicy_Accelerator) ProtoReflect() protoreflect.Message + func (x *AllocationPolicy_Accelerator) Reset() + func (x *AllocationPolicy_Accelerator) String() string + type AllocationPolicy_AttachedDisk struct + Attached isAllocationPolicy_AttachedDisk_Attached + DeviceName string + func (*AllocationPolicy_AttachedDisk) Descriptor() ([]byte, []int) + func (*AllocationPolicy_AttachedDisk) ProtoMessage() + func (m *AllocationPolicy_AttachedDisk) GetAttached() isAllocationPolicy_AttachedDisk_Attached + func (x *AllocationPolicy_AttachedDisk) GetDeviceName() string + func (x *AllocationPolicy_AttachedDisk) GetExistingDisk() string + func (x *AllocationPolicy_AttachedDisk) GetNewDisk() *AllocationPolicy_Disk + func (x *AllocationPolicy_AttachedDisk) ProtoReflect() protoreflect.Message + func (x *AllocationPolicy_AttachedDisk) Reset() + func (x *AllocationPolicy_AttachedDisk) String() string + type AllocationPolicy_AttachedDisk_ExistingDisk struct + ExistingDisk string + type AllocationPolicy_AttachedDisk_NewDisk struct + NewDisk *AllocationPolicy_Disk + type AllocationPolicy_Disk struct + DataSource isAllocationPolicy_Disk_DataSource + DiskInterface string + SizeGb int64 + Type string + func (*AllocationPolicy_Disk) Descriptor() ([]byte, []int) + func (*AllocationPolicy_Disk) ProtoMessage() + func (m *AllocationPolicy_Disk) GetDataSource() isAllocationPolicy_Disk_DataSource + func (x *AllocationPolicy_Disk) GetDiskInterface() string + func (x *AllocationPolicy_Disk) GetImage() string + func (x *AllocationPolicy_Disk) GetSizeGb() int64 + func (x *AllocationPolicy_Disk) GetSnapshot() string + func (x *AllocationPolicy_Disk) GetType() string + func (x *AllocationPolicy_Disk) ProtoReflect() protoreflect.Message + func (x *AllocationPolicy_Disk) Reset() + func (x *AllocationPolicy_Disk) String() string + type AllocationPolicy_Disk_Image struct + Image string + type AllocationPolicy_Disk_Snapshot struct + Snapshot string + type AllocationPolicy_InstancePolicy struct + Accelerators []*AllocationPolicy_Accelerator + BootDisk *AllocationPolicy_Disk + Disks []*AllocationPolicy_AttachedDisk + MachineType string + MinCpuPlatform string + ProvisioningModel AllocationPolicy_ProvisioningModel + func (*AllocationPolicy_InstancePolicy) Descriptor() ([]byte, []int) + func (*AllocationPolicy_InstancePolicy) ProtoMessage() + func (x *AllocationPolicy_InstancePolicy) GetAccelerators() []*AllocationPolicy_Accelerator + func (x *AllocationPolicy_InstancePolicy) GetBootDisk() *AllocationPolicy_Disk + func (x *AllocationPolicy_InstancePolicy) GetDisks() []*AllocationPolicy_AttachedDisk + func (x *AllocationPolicy_InstancePolicy) GetMachineType() string + func (x *AllocationPolicy_InstancePolicy) GetMinCpuPlatform() string + func (x *AllocationPolicy_InstancePolicy) GetProvisioningModel() AllocationPolicy_ProvisioningModel + func (x *AllocationPolicy_InstancePolicy) ProtoReflect() protoreflect.Message + func (x *AllocationPolicy_InstancePolicy) Reset() + func (x *AllocationPolicy_InstancePolicy) String() string + type AllocationPolicy_InstancePolicyOrTemplate struct + InstallGpuDrivers bool + PolicyTemplate isAllocationPolicy_InstancePolicyOrTemplate_PolicyTemplate + func (*AllocationPolicy_InstancePolicyOrTemplate) Descriptor() ([]byte, []int) + func (*AllocationPolicy_InstancePolicyOrTemplate) ProtoMessage() + func (m *AllocationPolicy_InstancePolicyOrTemplate) GetPolicyTemplate() isAllocationPolicy_InstancePolicyOrTemplate_PolicyTemplate + func (x *AllocationPolicy_InstancePolicyOrTemplate) GetInstallGpuDrivers() bool + func (x *AllocationPolicy_InstancePolicyOrTemplate) GetInstanceTemplate() string + func (x *AllocationPolicy_InstancePolicyOrTemplate) GetPolicy() *AllocationPolicy_InstancePolicy + func (x *AllocationPolicy_InstancePolicyOrTemplate) ProtoReflect() protoreflect.Message + func (x *AllocationPolicy_InstancePolicyOrTemplate) Reset() + func (x *AllocationPolicy_InstancePolicyOrTemplate) String() string + type AllocationPolicy_InstancePolicyOrTemplate_InstanceTemplate struct + InstanceTemplate string + type AllocationPolicy_InstancePolicyOrTemplate_Policy struct + Policy *AllocationPolicy_InstancePolicy + type AllocationPolicy_LocationPolicy struct + AllowedLocations []string + func (*AllocationPolicy_LocationPolicy) Descriptor() ([]byte, []int) + func (*AllocationPolicy_LocationPolicy) ProtoMessage() + func (x *AllocationPolicy_LocationPolicy) GetAllowedLocations() []string + func (x *AllocationPolicy_LocationPolicy) ProtoReflect() protoreflect.Message + func (x *AllocationPolicy_LocationPolicy) Reset() + func (x *AllocationPolicy_LocationPolicy) String() string + type AllocationPolicy_NetworkInterface struct + Network string + NoExternalIpAddress bool + Subnetwork string + func (*AllocationPolicy_NetworkInterface) Descriptor() ([]byte, []int) + func (*AllocationPolicy_NetworkInterface) ProtoMessage() + func (x *AllocationPolicy_NetworkInterface) GetNetwork() string + func (x *AllocationPolicy_NetworkInterface) GetNoExternalIpAddress() bool + func (x *AllocationPolicy_NetworkInterface) GetSubnetwork() string + func (x *AllocationPolicy_NetworkInterface) ProtoReflect() protoreflect.Message + func (x *AllocationPolicy_NetworkInterface) Reset() + func (x *AllocationPolicy_NetworkInterface) String() string + type AllocationPolicy_NetworkPolicy struct + NetworkInterfaces []*AllocationPolicy_NetworkInterface + func (*AllocationPolicy_NetworkPolicy) Descriptor() ([]byte, []int) + func (*AllocationPolicy_NetworkPolicy) ProtoMessage() + func (x *AllocationPolicy_NetworkPolicy) GetNetworkInterfaces() []*AllocationPolicy_NetworkInterface + func (x *AllocationPolicy_NetworkPolicy) ProtoReflect() protoreflect.Message + func (x *AllocationPolicy_NetworkPolicy) Reset() + func (x *AllocationPolicy_NetworkPolicy) String() string + type AllocationPolicy_PlacementPolicy struct + Collocation string + MaxDistance int64 + func (*AllocationPolicy_PlacementPolicy) Descriptor() ([]byte, []int) + func (*AllocationPolicy_PlacementPolicy) ProtoMessage() + func (x *AllocationPolicy_PlacementPolicy) GetCollocation() string + func (x *AllocationPolicy_PlacementPolicy) GetMaxDistance() int64 + func (x *AllocationPolicy_PlacementPolicy) ProtoReflect() protoreflect.Message + func (x *AllocationPolicy_PlacementPolicy) Reset() + func (x *AllocationPolicy_PlacementPolicy) String() string + type AllocationPolicy_ProvisioningModel int32 + const AllocationPolicy_PREEMPTIBLE + const AllocationPolicy_PROVISIONING_MODEL_UNSPECIFIED + const AllocationPolicy_SPOT + const AllocationPolicy_STANDARD + func (AllocationPolicy_ProvisioningModel) Descriptor() protoreflect.EnumDescriptor + func (AllocationPolicy_ProvisioningModel) EnumDescriptor() ([]byte, []int) + func (AllocationPolicy_ProvisioningModel) Type() protoreflect.EnumType + func (x AllocationPolicy_ProvisioningModel) Enum() *AllocationPolicy_ProvisioningModel + func (x AllocationPolicy_ProvisioningModel) Number() protoreflect.EnumNumber + func (x AllocationPolicy_ProvisioningModel) String() string + type ComputeResource struct + BootDiskMib int64 + CpuMilli int64 + MemoryMib int64 + func (*ComputeResource) Descriptor() ([]byte, []int) + func (*ComputeResource) ProtoMessage() + func (x *ComputeResource) GetBootDiskMib() int64 + func (x *ComputeResource) GetCpuMilli() int64 + func (x *ComputeResource) GetMemoryMib() int64 + func (x *ComputeResource) ProtoReflect() protoreflect.Message + func (x *ComputeResource) Reset() + func (x *ComputeResource) String() string + type Environment struct + EncryptedVariables *Environment_KMSEnvMap + SecretVariables map[string]string + Variables map[string]string + func (*Environment) Descriptor() ([]byte, []int) + func (*Environment) ProtoMessage() + func (x *Environment) GetEncryptedVariables() *Environment_KMSEnvMap + func (x *Environment) GetSecretVariables() map[string]string + func (x *Environment) GetVariables() map[string]string + func (x *Environment) ProtoReflect() protoreflect.Message + func (x *Environment) Reset() + func (x *Environment) String() string + type Environment_KMSEnvMap struct + CipherText string + KeyName string + func (*Environment_KMSEnvMap) Descriptor() ([]byte, []int) + func (*Environment_KMSEnvMap) ProtoMessage() + func (x *Environment_KMSEnvMap) GetCipherText() string + func (x *Environment_KMSEnvMap) GetKeyName() string + func (x *Environment_KMSEnvMap) ProtoReflect() protoreflect.Message + func (x *Environment_KMSEnvMap) Reset() + func (x *Environment_KMSEnvMap) String() string + type GCS struct + RemotePath string + func (*GCS) Descriptor() ([]byte, []int) + func (*GCS) ProtoMessage() + func (x *GCS) GetRemotePath() string + func (x *GCS) ProtoReflect() protoreflect.Message + func (x *GCS) Reset() + func (x *GCS) String() string + type Job struct + AllocationPolicy *AllocationPolicy + CreateTime *timestamppb.Timestamp + Labels map[string]string + LogsPolicy *LogsPolicy + Name string + Notifications []*JobNotification + Priority int64 + Status *JobStatus + TaskGroups []*TaskGroup + Uid string + UpdateTime *timestamppb.Timestamp + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (x *Job) GetAllocationPolicy() *AllocationPolicy + func (x *Job) GetCreateTime() *timestamppb.Timestamp + func (x *Job) GetLabels() map[string]string + func (x *Job) GetLogsPolicy() *LogsPolicy + func (x *Job) GetName() string + func (x *Job) GetNotifications() []*JobNotification + func (x *Job) GetPriority() int64 + func (x *Job) GetStatus() *JobStatus + func (x *Job) GetTaskGroups() []*TaskGroup + func (x *Job) GetUid() string + func (x *Job) GetUpdateTime() *timestamppb.Timestamp + func (x *Job) ProtoReflect() protoreflect.Message + func (x *Job) Reset() + func (x *Job) String() string + type JobEventData struct + Payload *Job + func (*JobEventData) Descriptor() ([]byte, []int) + func (*JobEventData) ProtoMessage() + func (x *JobEventData) GetPayload() *Job + func (x *JobEventData) ProtoReflect() protoreflect.Message + func (x *JobEventData) Reset() + func (x *JobEventData) String() string + type JobNotification struct + Message *JobNotification_Message + PubsubTopic string + func (*JobNotification) Descriptor() ([]byte, []int) + func (*JobNotification) ProtoMessage() + func (x *JobNotification) GetMessage() *JobNotification_Message + func (x *JobNotification) GetPubsubTopic() string + func (x *JobNotification) ProtoReflect() protoreflect.Message + func (x *JobNotification) Reset() + func (x *JobNotification) String() string + type JobNotification_Message struct + NewJobState JobStatus_State + NewTaskState TaskStatus_State + Type JobNotification_Type + func (*JobNotification_Message) Descriptor() ([]byte, []int) + func (*JobNotification_Message) ProtoMessage() + func (x *JobNotification_Message) GetNewJobState() JobStatus_State + func (x *JobNotification_Message) GetNewTaskState() TaskStatus_State + func (x *JobNotification_Message) GetType() JobNotification_Type + func (x *JobNotification_Message) ProtoReflect() protoreflect.Message + func (x *JobNotification_Message) Reset() + func (x *JobNotification_Message) String() string + type JobNotification_Type int32 + const JobNotification_JOB_STATE_CHANGED + const JobNotification_TASK_STATE_CHANGED + const JobNotification_TYPE_UNSPECIFIED + func (JobNotification_Type) Descriptor() protoreflect.EnumDescriptor + func (JobNotification_Type) EnumDescriptor() ([]byte, []int) + func (JobNotification_Type) Type() protoreflect.EnumType + func (x JobNotification_Type) Enum() *JobNotification_Type + func (x JobNotification_Type) Number() protoreflect.EnumNumber + func (x JobNotification_Type) String() string + type JobStatus struct + RunDuration *durationpb.Duration + State JobStatus_State + StatusEvents []*StatusEvent + TaskGroups map[string]*JobStatus_TaskGroupStatus + func (*JobStatus) Descriptor() ([]byte, []int) + func (*JobStatus) ProtoMessage() + func (x *JobStatus) GetRunDuration() *durationpb.Duration + func (x *JobStatus) GetState() JobStatus_State + func (x *JobStatus) GetStatusEvents() []*StatusEvent + func (x *JobStatus) GetTaskGroups() map[string]*JobStatus_TaskGroupStatus + func (x *JobStatus) ProtoReflect() protoreflect.Message + func (x *JobStatus) Reset() + func (x *JobStatus) String() string + type JobStatus_InstanceStatus struct + BootDisk *AllocationPolicy_Disk + MachineType string + ProvisioningModel AllocationPolicy_ProvisioningModel + TaskPack int64 + func (*JobStatus_InstanceStatus) Descriptor() ([]byte, []int) + func (*JobStatus_InstanceStatus) ProtoMessage() + func (x *JobStatus_InstanceStatus) GetBootDisk() *AllocationPolicy_Disk + func (x *JobStatus_InstanceStatus) GetMachineType() string + func (x *JobStatus_InstanceStatus) GetProvisioningModel() AllocationPolicy_ProvisioningModel + func (x *JobStatus_InstanceStatus) GetTaskPack() int64 + func (x *JobStatus_InstanceStatus) ProtoReflect() protoreflect.Message + func (x *JobStatus_InstanceStatus) Reset() + func (x *JobStatus_InstanceStatus) String() string + type JobStatus_State int32 + const JobStatus_DELETION_IN_PROGRESS + const JobStatus_FAILED + const JobStatus_QUEUED + const JobStatus_RUNNING + const JobStatus_SCHEDULED + const JobStatus_STATE_UNSPECIFIED + const JobStatus_SUCCEEDED + func (JobStatus_State) Descriptor() protoreflect.EnumDescriptor + func (JobStatus_State) EnumDescriptor() ([]byte, []int) + func (JobStatus_State) Type() protoreflect.EnumType + func (x JobStatus_State) Enum() *JobStatus_State + func (x JobStatus_State) Number() protoreflect.EnumNumber + func (x JobStatus_State) String() string + type JobStatus_TaskGroupStatus struct + Counts map[string]int64 + Instances []*JobStatus_InstanceStatus + func (*JobStatus_TaskGroupStatus) Descriptor() ([]byte, []int) + func (*JobStatus_TaskGroupStatus) ProtoMessage() + func (x *JobStatus_TaskGroupStatus) GetCounts() map[string]int64 + func (x *JobStatus_TaskGroupStatus) GetInstances() []*JobStatus_InstanceStatus + func (x *JobStatus_TaskGroupStatus) ProtoReflect() protoreflect.Message + func (x *JobStatus_TaskGroupStatus) Reset() + func (x *JobStatus_TaskGroupStatus) String() string + type LifecyclePolicy struct + Action LifecyclePolicy_Action + ActionCondition *LifecyclePolicy_ActionCondition + func (*LifecyclePolicy) Descriptor() ([]byte, []int) + func (*LifecyclePolicy) ProtoMessage() + func (x *LifecyclePolicy) GetAction() LifecyclePolicy_Action + func (x *LifecyclePolicy) GetActionCondition() *LifecyclePolicy_ActionCondition + func (x *LifecyclePolicy) ProtoReflect() protoreflect.Message + func (x *LifecyclePolicy) Reset() + func (x *LifecyclePolicy) String() string + type LifecyclePolicy_Action int32 + const LifecyclePolicy_ACTION_UNSPECIFIED + const LifecyclePolicy_FAIL_TASK + const LifecyclePolicy_RETRY_TASK + func (LifecyclePolicy_Action) Descriptor() protoreflect.EnumDescriptor + func (LifecyclePolicy_Action) EnumDescriptor() ([]byte, []int) + func (LifecyclePolicy_Action) Type() protoreflect.EnumType + func (x LifecyclePolicy_Action) Enum() *LifecyclePolicy_Action + func (x LifecyclePolicy_Action) Number() protoreflect.EnumNumber + func (x LifecyclePolicy_Action) String() string + type LifecyclePolicy_ActionCondition struct + ExitCodes []int32 + func (*LifecyclePolicy_ActionCondition) Descriptor() ([]byte, []int) + func (*LifecyclePolicy_ActionCondition) ProtoMessage() + func (x *LifecyclePolicy_ActionCondition) GetExitCodes() []int32 + func (x *LifecyclePolicy_ActionCondition) ProtoReflect() protoreflect.Message + func (x *LifecyclePolicy_ActionCondition) Reset() + func (x *LifecyclePolicy_ActionCondition) String() string + type LogsPolicy struct + Destination LogsPolicy_Destination + LogsPath string + func (*LogsPolicy) Descriptor() ([]byte, []int) + func (*LogsPolicy) ProtoMessage() + func (x *LogsPolicy) GetDestination() LogsPolicy_Destination + func (x *LogsPolicy) GetLogsPath() string + func (x *LogsPolicy) ProtoReflect() protoreflect.Message + func (x *LogsPolicy) Reset() + func (x *LogsPolicy) String() string + type LogsPolicy_Destination int32 + const LogsPolicy_CLOUD_LOGGING + const LogsPolicy_DESTINATION_UNSPECIFIED + const LogsPolicy_PATH + func (LogsPolicy_Destination) Descriptor() protoreflect.EnumDescriptor + func (LogsPolicy_Destination) EnumDescriptor() ([]byte, []int) + func (LogsPolicy_Destination) Type() protoreflect.EnumType + func (x LogsPolicy_Destination) Enum() *LogsPolicy_Destination + func (x LogsPolicy_Destination) Number() protoreflect.EnumNumber + func (x LogsPolicy_Destination) String() string + type NFS struct + RemotePath string + Server string + func (*NFS) Descriptor() ([]byte, []int) + func (*NFS) ProtoMessage() + func (x *NFS) GetRemotePath() string + func (x *NFS) GetServer() string + func (x *NFS) ProtoReflect() protoreflect.Message + func (x *NFS) Reset() + func (x *NFS) String() string + type Runnable struct + AlwaysRun bool + Background bool + Environment *Environment + Executable isRunnable_Executable + IgnoreExitStatus bool + Labels map[string]string + Timeout *durationpb.Duration + func (*Runnable) Descriptor() ([]byte, []int) + func (*Runnable) ProtoMessage() + func (m *Runnable) GetExecutable() isRunnable_Executable + func (x *Runnable) GetAlwaysRun() bool + func (x *Runnable) GetBackground() bool + func (x *Runnable) GetBarrier() *Runnable_Barrier + func (x *Runnable) GetContainer() *Runnable_Container + func (x *Runnable) GetEnvironment() *Environment + func (x *Runnable) GetIgnoreExitStatus() bool + func (x *Runnable) GetLabels() map[string]string + func (x *Runnable) GetScript() *Runnable_Script + func (x *Runnable) GetTimeout() *durationpb.Duration + func (x *Runnable) ProtoReflect() protoreflect.Message + func (x *Runnable) Reset() + func (x *Runnable) String() string + type Runnable_Barrier struct + Name string + func (*Runnable_Barrier) Descriptor() ([]byte, []int) + func (*Runnable_Barrier) ProtoMessage() + func (x *Runnable_Barrier) GetName() string + func (x *Runnable_Barrier) ProtoReflect() protoreflect.Message + func (x *Runnable_Barrier) Reset() + func (x *Runnable_Barrier) String() string + type Runnable_Barrier_ struct + Barrier *Runnable_Barrier + type Runnable_Container struct + BlockExternalNetwork bool + Commands []string + Entrypoint string + ImageUri string + Options string + Password string + Username string + Volumes []string + func (*Runnable_Container) Descriptor() ([]byte, []int) + func (*Runnable_Container) ProtoMessage() + func (x *Runnable_Container) GetBlockExternalNetwork() bool + func (x *Runnable_Container) GetCommands() []string + func (x *Runnable_Container) GetEntrypoint() string + func (x *Runnable_Container) GetImageUri() string + func (x *Runnable_Container) GetOptions() string + func (x *Runnable_Container) GetPassword() string + func (x *Runnable_Container) GetUsername() string + func (x *Runnable_Container) GetVolumes() []string + func (x *Runnable_Container) ProtoReflect() protoreflect.Message + func (x *Runnable_Container) Reset() + func (x *Runnable_Container) String() string + type Runnable_Container_ struct + Container *Runnable_Container + type Runnable_Script struct + Command isRunnable_Script_Command + func (*Runnable_Script) Descriptor() ([]byte, []int) + func (*Runnable_Script) ProtoMessage() + func (m *Runnable_Script) GetCommand() isRunnable_Script_Command + func (x *Runnable_Script) GetPath() string + func (x *Runnable_Script) GetText() string + func (x *Runnable_Script) ProtoReflect() protoreflect.Message + func (x *Runnable_Script) Reset() + func (x *Runnable_Script) String() string + type Runnable_Script_ struct + Script *Runnable_Script + type Runnable_Script_Path struct + Path string + type Runnable_Script_Text struct + Text string + type ServiceAccount struct + Email string + Scopes []string + func (*ServiceAccount) Descriptor() ([]byte, []int) + func (*ServiceAccount) ProtoMessage() + func (x *ServiceAccount) GetEmail() string + func (x *ServiceAccount) GetScopes() []string + func (x *ServiceAccount) ProtoReflect() protoreflect.Message + func (x *ServiceAccount) Reset() + func (x *ServiceAccount) String() string + type StatusEvent struct + Description string + EventTime *timestamppb.Timestamp + TaskExecution *TaskExecution + TaskState TaskStatus_State + Type string + func (*StatusEvent) Descriptor() ([]byte, []int) + func (*StatusEvent) ProtoMessage() + func (x *StatusEvent) GetDescription() string + func (x *StatusEvent) GetEventTime() *timestamppb.Timestamp + func (x *StatusEvent) GetTaskExecution() *TaskExecution + func (x *StatusEvent) GetTaskState() TaskStatus_State + func (x *StatusEvent) GetType() string + func (x *StatusEvent) ProtoReflect() protoreflect.Message + func (x *StatusEvent) Reset() + func (x *StatusEvent) String() string + type TaskExecution struct + ExitCode int32 + func (*TaskExecution) Descriptor() ([]byte, []int) + func (*TaskExecution) ProtoMessage() + func (x *TaskExecution) GetExitCode() int32 + func (x *TaskExecution) ProtoReflect() protoreflect.Message + func (x *TaskExecution) Reset() + func (x *TaskExecution) String() string + type TaskGroup struct + Name string + Parallelism int64 + PermissiveSsh bool + RequireHostsFile bool + SchedulingPolicy TaskGroup_SchedulingPolicy + TaskCount int64 + TaskCountPerNode int64 + TaskEnvironments []*Environment + TaskSpec *TaskSpec + func (*TaskGroup) Descriptor() ([]byte, []int) + func (*TaskGroup) ProtoMessage() + func (x *TaskGroup) GetName() string + func (x *TaskGroup) GetParallelism() int64 + func (x *TaskGroup) GetPermissiveSsh() bool + func (x *TaskGroup) GetRequireHostsFile() bool + func (x *TaskGroup) GetSchedulingPolicy() TaskGroup_SchedulingPolicy + func (x *TaskGroup) GetTaskCount() int64 + func (x *TaskGroup) GetTaskCountPerNode() int64 + func (x *TaskGroup) GetTaskEnvironments() []*Environment + func (x *TaskGroup) GetTaskSpec() *TaskSpec + func (x *TaskGroup) ProtoReflect() protoreflect.Message + func (x *TaskGroup) Reset() + func (x *TaskGroup) String() string + type TaskGroup_SchedulingPolicy int32 + const TaskGroup_AS_SOON_AS_POSSIBLE + const TaskGroup_IN_ORDER + const TaskGroup_SCHEDULING_POLICY_UNSPECIFIED + func (TaskGroup_SchedulingPolicy) Descriptor() protoreflect.EnumDescriptor + func (TaskGroup_SchedulingPolicy) EnumDescriptor() ([]byte, []int) + func (TaskGroup_SchedulingPolicy) Type() protoreflect.EnumType + func (x TaskGroup_SchedulingPolicy) Enum() *TaskGroup_SchedulingPolicy + func (x TaskGroup_SchedulingPolicy) Number() protoreflect.EnumNumber + func (x TaskGroup_SchedulingPolicy) String() string + type TaskSpec struct + ComputeResource *ComputeResource + Environment *Environment + Environments map[string]string + LifecyclePolicies []*LifecyclePolicy + MaxRetryCount int32 + MaxRunDuration *durationpb.Duration + Runnables []*Runnable + Volumes []*Volume + func (*TaskSpec) Descriptor() ([]byte, []int) + func (*TaskSpec) ProtoMessage() + func (x *TaskSpec) GetComputeResource() *ComputeResource + func (x *TaskSpec) GetEnvironment() *Environment + func (x *TaskSpec) GetEnvironments() map[string]string + func (x *TaskSpec) GetLifecyclePolicies() []*LifecyclePolicy + func (x *TaskSpec) GetMaxRetryCount() int32 + func (x *TaskSpec) GetMaxRunDuration() *durationpb.Duration + func (x *TaskSpec) GetRunnables() []*Runnable + func (x *TaskSpec) GetVolumes() []*Volume + func (x *TaskSpec) ProtoReflect() protoreflect.Message + func (x *TaskSpec) Reset() + func (x *TaskSpec) String() string + type TaskStatus struct + func (*TaskStatus) Descriptor() ([]byte, []int) + func (*TaskStatus) ProtoMessage() + func (x *TaskStatus) ProtoReflect() protoreflect.Message + func (x *TaskStatus) Reset() + func (x *TaskStatus) String() string + type TaskStatus_State int32 + const TaskStatus_ASSIGNED + const TaskStatus_FAILED + const TaskStatus_PENDING + const TaskStatus_RUNNING + const TaskStatus_STATE_UNSPECIFIED + const TaskStatus_SUCCEEDED + const TaskStatus_UNEXECUTED + func (TaskStatus_State) Descriptor() protoreflect.EnumDescriptor + func (TaskStatus_State) EnumDescriptor() ([]byte, []int) + func (TaskStatus_State) Type() protoreflect.EnumType + func (x TaskStatus_State) Enum() *TaskStatus_State + func (x TaskStatus_State) Number() protoreflect.EnumNumber + func (x TaskStatus_State) String() string + type Volume struct + MountOptions []string + MountPath string + Source isVolume_Source + func (*Volume) Descriptor() ([]byte, []int) + func (*Volume) ProtoMessage() + func (m *Volume) GetSource() isVolume_Source + func (x *Volume) GetDeviceName() string + func (x *Volume) GetGcs() *GCS + func (x *Volume) GetMountOptions() []string + func (x *Volume) GetMountPath() string + func (x *Volume) GetNfs() *NFS + func (x *Volume) ProtoReflect() protoreflect.Message + func (x *Volume) Reset() + func (x *Volume) String() string + type Volume_DeviceName struct + DeviceName string + type Volume_Gcs struct + Gcs *GCS + type Volume_Nfs struct + Nfs *NFS
Go to main page