batchpb

package

Go to main page

Versions in this module

v1

v1.11.5

Jan 2, 2025

v1.11.4

Dec 12, 2024

v1.11.3

Dec 4, 2024

v1.11.2

Oct 23, 2024

v1.11.1

Oct 10, 2024

v1.11.0

Sep 12, 2024

Changes in this version

type AllocationPolicy_InstancePolicyOrTemplate

+ BlockProjectSshKeys bool

+ func (x *AllocationPolicy_InstancePolicyOrTemplate) GetBlockProjectSshKeys() bool

v1.10.0

Aug 20, 2024

v1.9.4

Aug 13, 2024

v1.9.3

Aug 8, 2024

v1.9.2

Jul 24, 2024

v1.9.1

Jul 10, 2024

v1.9.0

Jul 1, 2024

Changes in this version

type AllocationPolicy_InstancePolicyOrTemplate

+ InstallOpsAgent bool

+ func (x *AllocationPolicy_InstancePolicyOrTemplate) GetInstallOpsAgent() bool

v1.8.8

Jun 26, 2024

v1.8.7

Jun 5, 2024

v1.8.6

May 16, 2024

v1.8.5

May 1, 2024

v1.8.4

Apr 15, 2024

v1.8.3

Mar 14, 2024

v1.8.2

Mar 4, 2024

v1.8.1

Feb 21, 2024

v1.8.0

Jan 30, 2024

Changes in this version

type AllocationPolicy

+ Tags []string

+ func (x *AllocationPolicy) GetTags() []string

type LogsPolicy_CloudLoggingOption

+ UseGenericTaskMonitoredResource bool

+ func (x *LogsPolicy_CloudLoggingOption) GetUseGenericTaskMonitoredResource() bool

type Runnable_Container

+ EnableImageStreaming bool

+ func (x *Runnable_Container) GetEnableImageStreaming() bool

type TaskGroup

+ RunAsNonRoot bool

+ func (x *TaskGroup) GetRunAsNonRoot() bool

v1.7.0

Nov 27, 2023

Changes in this version

type LogsPolicy

+ CloudLoggingOption *LogsPolicy_CloudLoggingOption

+ func (x *LogsPolicy) GetCloudLoggingOption() *LogsPolicy_CloudLoggingOption

+ type LogsPolicy_CloudLoggingOption struct

+ func (*LogsPolicy_CloudLoggingOption) Descriptor() ([]byte, []int)

+ func (*LogsPolicy_CloudLoggingOption) ProtoMessage()

+ func (x *LogsPolicy_CloudLoggingOption) ProtoReflect() protoreflect.Message

+ func (x *LogsPolicy_CloudLoggingOption) Reset()

+ func (x *LogsPolicy_CloudLoggingOption) String() string

v1.6.3

Nov 1, 2023

v1.6.2

Oct 31, 2023

v1.6.1

Oct 26, 2023

v1.6.0

Oct 17, 2023

Changes in this version

type Runnable

+ DisplayName string

+ func (x *Runnable) GetDisplayName() string

v1.5.1

Oct 12, 2023

v1.5.0

Oct 4, 2023

Changes in this version

type AllocationPolicy_InstancePolicy

+ Reservation string

+ func (x *AllocationPolicy_InstancePolicy) GetReservation() string

v1.4.1

Sep 11, 2023

v1.4.0

Aug 8, 2023

Changes in this version

type AllocationPolicy_Accelerator

+ DriverVersion string

+ func (x *AllocationPolicy_Accelerator) GetDriverVersion() string

type ListJobsRequest

+ OrderBy string

+ func (x *ListJobsRequest) GetOrderBy() string

v1.3.1

Jul 10, 2023

v1.3.0

Jun 20, 2023

Changes in this version

+ var TaskGroup_SchedulingPolicy_name = map[int32]string

+ var TaskGroup_SchedulingPolicy_value = map[string]int32

type TaskGroup

+ SchedulingPolicy TaskGroup_SchedulingPolicy

+ func (x *TaskGroup) GetSchedulingPolicy() TaskGroup_SchedulingPolicy

+ 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

v1.2.0

May 30, 2023

v1.1.0

May 16, 2023

Changes in this version

type AllocationPolicy

+ Placement *AllocationPolicy_PlacementPolicy

+ func (x *AllocationPolicy) GetPlacement() *AllocationPolicy_PlacementPolicy

+ 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 Runnable

+ Labels map[string]string

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

type TaskStatus_State

+ const TaskStatus_UNEXECUTED

v1.0.1

May 8, 2023

v1.0.0

Apr 4, 2023

Changes in this version

type StatusEvent

+ TaskState TaskStatus_State

+ func (x *StatusEvent) GetTaskState() TaskStatus_State

v0

v0.7.0

Feb 14, 2023

Changes in this version

type AllocationPolicy_InstancePolicy

+ BootDisk *AllocationPolicy_Disk

+ func (x *AllocationPolicy_InstancePolicy) GetBootDisk() *AllocationPolicy_Disk

type JobStatus_InstanceStatus

+ BootDisk *AllocationPolicy_Disk

+ func (x *JobStatus_InstanceStatus) GetBootDisk() *AllocationPolicy_Disk

type ServiceAccount

+ Scopes []string

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

v0.6.0

Jan 5, 2023

Changes in this version

type Environment

+ EncryptedVariables *Environment_KMSEnvMap

+ SecretVariables map[string]string

+ func (x *Environment) GetEncryptedVariables() *Environment_KMSEnvMap

+ func (x *Environment) GetSecretVariables() map[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

v0.5.0

Dec 1, 2022

v0.4.1

Nov 16, 2022

v0.4.0

Nov 3, 2022

v0.3.0

Oct 25, 2022

Changes in this version

+ var AllocationPolicy_ProvisioningModel_name = map[int32]string

+ var AllocationPolicy_ProvisioningModel_value = map[string]int32

+ var File_google_cloud_batch_v1_batch_proto protoreflect.FileDescriptor

+ var File_google_cloud_batch_v1_job_proto protoreflect.FileDescriptor

+ var File_google_cloud_batch_v1_task_proto protoreflect.FileDescriptor

+ var File_google_cloud_batch_v1_volume_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 TaskStatus_State_name = map[int32]string

+ var TaskStatus_State_value = map[string]int32

+ func RegisterBatchServiceServer(s *grpc.Server, srv BatchServiceServer)

+ type AllocationPolicy struct

+ Instances []*AllocationPolicy_InstancePolicyOrTemplate

+ Labels map[string]string

+ Location *AllocationPolicy_LocationPolicy

+ Network *AllocationPolicy_NetworkPolicy

+ 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) 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

+ 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) 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_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 BatchServiceClient interface

+ CreateJob func(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error)

+ DeleteJob func(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)

+ GetJob func(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)

+ GetTask func(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error)

+ ListJobs func(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)

+ ListTasks func(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)

+ func NewBatchServiceClient(cc grpc.ClientConnInterface) BatchServiceClient

+ type BatchServiceServer interface

+ CreateJob func(context.Context, *CreateJobRequest) (*Job, error)

+ DeleteJob func(context.Context, *DeleteJobRequest) (*longrunning.Operation, error)

+ GetJob func(context.Context, *GetJobRequest) (*Job, error)

+ GetTask func(context.Context, *GetTaskRequest) (*Task, error)

+ ListJobs func(context.Context, *ListJobsRequest) (*ListJobsResponse, error)

+ ListTasks func(context.Context, *ListTasksRequest) (*ListTasksResponse, error)

+ 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 CreateJobRequest struct

+ Job *Job

+ JobId string

+ Parent string

+ RequestId string

+ func (*CreateJobRequest) Descriptor() ([]byte, []int)

+ func (*CreateJobRequest) ProtoMessage()

+ func (x *CreateJobRequest) GetJob() *Job

+ func (x *CreateJobRequest) GetJobId() string

+ func (x *CreateJobRequest) GetParent() string

+ func (x *CreateJobRequest) GetRequestId() string

+ func (x *CreateJobRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateJobRequest) Reset()

+ func (x *CreateJobRequest) String() string

+ type DeleteJobRequest struct

+ Name string

+ Reason string

+ RequestId string

+ func (*DeleteJobRequest) Descriptor() ([]byte, []int)

+ func (*DeleteJobRequest) ProtoMessage()

+ func (x *DeleteJobRequest) GetName() string

+ func (x *DeleteJobRequest) GetReason() string

+ func (x *DeleteJobRequest) GetRequestId() string

+ func (x *DeleteJobRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteJobRequest) Reset()

+ func (x *DeleteJobRequest) String() string

+ type Environment struct

+ Variables map[string]string

+ func (*Environment) Descriptor() ([]byte, []int)

+ func (*Environment) ProtoMessage()

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

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

+ func (x *Environment) Reset()

+ func (x *Environment) 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 GetJobRequest struct

+ Name string

+ func (*GetJobRequest) Descriptor() ([]byte, []int)

+ func (*GetJobRequest) ProtoMessage()

+ func (x *GetJobRequest) GetName() string

+ func (x *GetJobRequest) ProtoReflect() protoreflect.Message

+ func (x *GetJobRequest) Reset()

+ func (x *GetJobRequest) String() string

+ type GetTaskRequest struct

+ Name string

+ func (*GetTaskRequest) Descriptor() ([]byte, []int)

+ func (*GetTaskRequest) ProtoMessage()

+ func (x *GetTaskRequest) GetName() string

+ func (x *GetTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *GetTaskRequest) Reset()

+ func (x *GetTaskRequest) String() string

+ type Job struct

+ AllocationPolicy *AllocationPolicy

+ CreateTime *timestamp.Timestamp

+ Labels map[string]string

+ LogsPolicy *LogsPolicy

+ Name string

+ Notifications []*JobNotification

+ Priority int64

+ Status *JobStatus

+ TaskGroups []*TaskGroup

+ Uid string

+ UpdateTime *timestamp.Timestamp

+ func (*Job) Descriptor() ([]byte, []int)

+ func (*Job) ProtoMessage()

+ func (x *Job) GetAllocationPolicy() *AllocationPolicy

+ func (x *Job) GetCreateTime() *timestamp.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() *timestamp.Timestamp

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

+ func (x *Job) Reset()

+ func (x *Job) 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 *duration.Duration

+ State JobStatus_State

+ StatusEvents []*StatusEvent

+ TaskGroups map[string]*JobStatus_TaskGroupStatus

+ func (*JobStatus) Descriptor() ([]byte, []int)

+ func (*JobStatus) ProtoMessage()

+ func (x *JobStatus) GetRunDuration() *duration.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

+ MachineType string

+ ProvisioningModel AllocationPolicy_ProvisioningModel

+ TaskPack int64

+ func (*JobStatus_InstanceStatus) Descriptor() ([]byte, []int)

+ func (*JobStatus_InstanceStatus) ProtoMessage()

+ 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 ListJobsRequest struct

+ Filter string

+ PageSize int32

+ PageToken string

+ Parent string

+ func (*ListJobsRequest) Descriptor() ([]byte, []int)

+ func (*ListJobsRequest) ProtoMessage()

+ func (x *ListJobsRequest) GetFilter() string

+ func (x *ListJobsRequest) GetPageSize() int32

+ func (x *ListJobsRequest) GetPageToken() string

+ func (x *ListJobsRequest) GetParent() string

+ func (x *ListJobsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListJobsRequest) Reset()

+ func (x *ListJobsRequest) String() string

+ type ListJobsResponse struct

+ Jobs []*Job

+ NextPageToken string

+ Unreachable []string

+ func (*ListJobsResponse) Descriptor() ([]byte, []int)

+ func (*ListJobsResponse) ProtoMessage()

+ func (x *ListJobsResponse) GetJobs() []*Job

+ func (x *ListJobsResponse) GetNextPageToken() string

+ func (x *ListJobsResponse) GetUnreachable() []string

+ func (x *ListJobsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListJobsResponse) Reset()

+ func (x *ListJobsResponse) String() string

+ type ListTasksRequest struct

+ Filter string

+ PageSize int32

+ PageToken string

+ Parent string

+ func (*ListTasksRequest) Descriptor() ([]byte, []int)

+ func (*ListTasksRequest) ProtoMessage()

+ func (x *ListTasksRequest) GetFilter() string

+ func (x *ListTasksRequest) GetPageSize() int32

+ func (x *ListTasksRequest) GetPageToken() string

+ func (x *ListTasksRequest) GetParent() string

+ func (x *ListTasksRequest) ProtoReflect() protoreflect.Message

+ func (x *ListTasksRequest) Reset()

+ func (x *ListTasksRequest) String() string

+ type ListTasksResponse struct

+ NextPageToken string

+ Tasks []*Task

+ Unreachable []string

+ func (*ListTasksResponse) Descriptor() ([]byte, []int)

+ func (*ListTasksResponse) ProtoMessage()

+ func (x *ListTasksResponse) GetNextPageToken() string

+ func (x *ListTasksResponse) GetTasks() []*Task

+ func (x *ListTasksResponse) GetUnreachable() []string

+ func (x *ListTasksResponse) ProtoReflect() protoreflect.Message

+ func (x *ListTasksResponse) Reset()

+ func (x *ListTasksResponse) 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 OperationMetadata struct

+ ApiVersion string

+ CreateTime *timestamp.Timestamp

+ EndTime *timestamp.Timestamp

+ RequestedCancellation bool

+ StatusMessage string

+ Target string

+ Verb string

+ func (*OperationMetadata) Descriptor() ([]byte, []int)

+ func (*OperationMetadata) ProtoMessage()

+ func (x *OperationMetadata) GetApiVersion() string

+ func (x *OperationMetadata) GetCreateTime() *timestamp.Timestamp

+ func (x *OperationMetadata) GetEndTime() *timestamp.Timestamp

+ func (x *OperationMetadata) GetRequestedCancellation() bool

+ func (x *OperationMetadata) GetStatusMessage() string

+ func (x *OperationMetadata) GetTarget() string

+ func (x *OperationMetadata) GetVerb() string

+ func (x *OperationMetadata) ProtoReflect() protoreflect.Message

+ func (x *OperationMetadata) Reset()

+ func (x *OperationMetadata) String() string

+ type Runnable struct

+ AlwaysRun bool

+ Background bool

+ Environment *Environment

+ Executable isRunnable_Executable

+ IgnoreExitStatus bool

+ Timeout *duration.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) GetScript() *Runnable_Script

+ func (x *Runnable) GetTimeout() *duration.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

+ func (*ServiceAccount) Descriptor() ([]byte, []int)

+ func (*ServiceAccount) ProtoMessage()

+ func (x *ServiceAccount) GetEmail() string

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

+ func (x *ServiceAccount) Reset()

+ func (x *ServiceAccount) String() string

+ type StatusEvent struct

+ Description string

+ EventTime *timestamp.Timestamp

+ TaskExecution *TaskExecution

+ Type string

+ func (*StatusEvent) Descriptor() ([]byte, []int)

+ func (*StatusEvent) ProtoMessage()

+ func (x *StatusEvent) GetDescription() string

+ func (x *StatusEvent) GetEventTime() *timestamp.Timestamp

+ func (x *StatusEvent) GetTaskExecution() *TaskExecution

+ func (x *StatusEvent) GetType() string

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

+ func (x *StatusEvent) Reset()

+ func (x *StatusEvent) String() string

+ type Task struct

+ Name string

+ Status *TaskStatus

+ func (*Task) Descriptor() ([]byte, []int)

+ func (*Task) ProtoMessage()

+ func (x *Task) GetName() string

+ func (x *Task) GetStatus() *TaskStatus

+ func (x *Task) ProtoReflect() protoreflect.Message

+ func (x *Task) Reset()

+ func (x *Task) 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

+ 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) 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 TaskSpec struct

+ ComputeResource *ComputeResource

+ Environment *Environment

+ Environments map[string]string

+ LifecyclePolicies []*LifecyclePolicy

+ MaxRetryCount int32

+ MaxRunDuration *duration.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() *duration.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

+ State TaskStatus_State

+ StatusEvents []*StatusEvent

+ func (*TaskStatus) Descriptor() ([]byte, []int)

+ func (*TaskStatus) ProtoMessage()

+ func (x *TaskStatus) GetState() TaskStatus_State

+ func (x *TaskStatus) GetStatusEvents() []*StatusEvent

+ 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

+ 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 UnimplementedBatchServiceServer struct

+ func (*UnimplementedBatchServiceServer) CreateJob(context.Context, *CreateJobRequest) (*Job, error)

+ func (*UnimplementedBatchServiceServer) DeleteJob(context.Context, *DeleteJobRequest) (*longrunning.Operation, error)

+ func (*UnimplementedBatchServiceServer) GetJob(context.Context, *GetJobRequest) (*Job, error)

+ func (*UnimplementedBatchServiceServer) GetTask(context.Context, *GetTaskRequest) (*Task, error)

+ func (*UnimplementedBatchServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)

+ func (*UnimplementedBatchServiceServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)

+ 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL