Versions in this module Expand all Collapse all v0 v0.9.7 May 1, 2024 v0.9.6 Mar 14, 2024 v0.9.5 Jan 30, 2024 v0.9.4 Nov 1, 2023 v0.9.3 Oct 26, 2023 v0.9.2 Oct 12, 2023 v0.9.1 Jun 20, 2023 v0.9.0 May 30, 2023 v0.8.1 May 8, 2023 v0.8.0 Jan 5, 2023 v0.7.0 Sep 22, 2022 v0.6.0 Sep 19, 2022 Changes in this version + var AutoscalingAlgorithm_name = map[int32]string + var AutoscalingAlgorithm_value = map[string]int32 + var AutoscalingEvent_AutoscalingEventType_name = map[int32]string + var AutoscalingEvent_AutoscalingEventType_value = map[string]int32 + var DefaultPackageSet_name = map[int32]string + var DefaultPackageSet_value = map[string]int32 + var ExecutionState_name = map[int32]string + var ExecutionState_value = map[string]int32 + var File_google_dataflow_v1beta3_environment_proto protoreflect.FileDescriptor + var File_google_dataflow_v1beta3_jobs_proto protoreflect.FileDescriptor + var File_google_dataflow_v1beta3_messages_proto protoreflect.FileDescriptor + var File_google_dataflow_v1beta3_metrics_proto protoreflect.FileDescriptor + var File_google_dataflow_v1beta3_snapshots_proto protoreflect.FileDescriptor + var File_google_dataflow_v1beta3_streaming_proto protoreflect.FileDescriptor + var File_google_dataflow_v1beta3_templates_proto protoreflect.FileDescriptor + var FlexResourceSchedulingGoal_name = map[int32]string + var FlexResourceSchedulingGoal_value = map[string]int32 + var GetTemplateRequest_TemplateView_name = map[int32]string + var GetTemplateRequest_TemplateView_value = map[string]int32 + var GetTemplateResponse_TemplateType_name = map[int32]string + var GetTemplateResponse_TemplateType_value = map[string]int32 + var JobMessageImportance_name = map[int32]string + var JobMessageImportance_value = map[string]int32 + var JobState_name = map[int32]string + var JobState_value = map[string]int32 + var JobType_name = map[int32]string + var JobType_value = map[string]int32 + var JobView_name = map[int32]string + var JobView_value = map[string]int32 + var KindType_name = map[int32]string + var KindType_value = map[string]int32 + var ListJobsRequest_Filter_name = map[int32]string + var ListJobsRequest_Filter_value = map[string]int32 + var ParameterType_name = map[int32]string + var ParameterType_value = map[string]int32 + var SDKInfo_Language_name = map[int32]string + var SDKInfo_Language_value = map[string]int32 + var SdkVersion_SdkSupportStatus_name = map[int32]string + var SdkVersion_SdkSupportStatus_value = map[string]int32 + var ShuffleMode_name = map[int32]string + var ShuffleMode_value = map[string]int32 + var SnapshotState_name = map[int32]string + var SnapshotState_value = map[string]int32 + var TeardownPolicy_name = map[int32]string + var TeardownPolicy_value = map[string]int32 + var WorkerIPAddressConfiguration_name = map[int32]string + var WorkerIPAddressConfiguration_value = map[string]int32 + func RegisterFlexTemplatesServiceServer(s *grpc.Server, srv FlexTemplatesServiceServer) + func RegisterJobsV1Beta3Server(s *grpc.Server, srv JobsV1Beta3Server) + func RegisterMessagesV1Beta3Server(s *grpc.Server, srv MessagesV1Beta3Server) + func RegisterMetricsV1Beta3Server(s *grpc.Server, srv MetricsV1Beta3Server) + func RegisterSnapshotsV1Beta3Server(s *grpc.Server, srv SnapshotsV1Beta3Server) + func RegisterTemplatesServiceServer(s *grpc.Server, srv TemplatesServiceServer) + type AutoscalingAlgorithm int32 + const AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_BASIC + const AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_NONE + const AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_UNKNOWN + func (AutoscalingAlgorithm) Descriptor() protoreflect.EnumDescriptor + func (AutoscalingAlgorithm) EnumDescriptor() ([]byte, []int) + func (AutoscalingAlgorithm) Type() protoreflect.EnumType + func (x AutoscalingAlgorithm) Enum() *AutoscalingAlgorithm + func (x AutoscalingAlgorithm) Number() protoreflect.EnumNumber + func (x AutoscalingAlgorithm) String() string + type AutoscalingEvent struct + CurrentNumWorkers int64 + Description *StructuredMessage + EventType AutoscalingEvent_AutoscalingEventType + TargetNumWorkers int64 + Time *timestamppb.Timestamp + WorkerPool string + func (*AutoscalingEvent) Descriptor() ([]byte, []int) + func (*AutoscalingEvent) ProtoMessage() + func (x *AutoscalingEvent) GetCurrentNumWorkers() int64 + func (x *AutoscalingEvent) GetDescription() *StructuredMessage + func (x *AutoscalingEvent) GetEventType() AutoscalingEvent_AutoscalingEventType + func (x *AutoscalingEvent) GetTargetNumWorkers() int64 + func (x *AutoscalingEvent) GetTime() *timestamppb.Timestamp + func (x *AutoscalingEvent) GetWorkerPool() string + func (x *AutoscalingEvent) ProtoReflect() protoreflect.Message + func (x *AutoscalingEvent) Reset() + func (x *AutoscalingEvent) String() string + type AutoscalingEvent_AutoscalingEventType int32 + const AutoscalingEvent_ACTUATION_FAILURE + const AutoscalingEvent_CURRENT_NUM_WORKERS_CHANGED + const AutoscalingEvent_NO_CHANGE + const AutoscalingEvent_TARGET_NUM_WORKERS_CHANGED + const AutoscalingEvent_TYPE_UNKNOWN + func (AutoscalingEvent_AutoscalingEventType) Descriptor() protoreflect.EnumDescriptor + func (AutoscalingEvent_AutoscalingEventType) EnumDescriptor() ([]byte, []int) + func (AutoscalingEvent_AutoscalingEventType) Type() protoreflect.EnumType + func (x AutoscalingEvent_AutoscalingEventType) Enum() *AutoscalingEvent_AutoscalingEventType + func (x AutoscalingEvent_AutoscalingEventType) Number() protoreflect.EnumNumber + func (x AutoscalingEvent_AutoscalingEventType) String() string + type AutoscalingSettings struct + Algorithm AutoscalingAlgorithm + MaxNumWorkers int32 + func (*AutoscalingSettings) Descriptor() ([]byte, []int) + func (*AutoscalingSettings) ProtoMessage() + func (x *AutoscalingSettings) GetAlgorithm() AutoscalingAlgorithm + func (x *AutoscalingSettings) GetMaxNumWorkers() int32 + func (x *AutoscalingSettings) ProtoReflect() protoreflect.Message + func (x *AutoscalingSettings) Reset() + func (x *AutoscalingSettings) String() string + type BigQueryIODetails struct + Dataset string + ProjectId string + Query string + Table string + func (*BigQueryIODetails) Descriptor() ([]byte, []int) + func (*BigQueryIODetails) ProtoMessage() + func (x *BigQueryIODetails) GetDataset() string + func (x *BigQueryIODetails) GetProjectId() string + func (x *BigQueryIODetails) GetQuery() string + func (x *BigQueryIODetails) GetTable() string + func (x *BigQueryIODetails) ProtoReflect() protoreflect.Message + func (x *BigQueryIODetails) Reset() + func (x *BigQueryIODetails) String() string + type BigTableIODetails struct + InstanceId string + ProjectId string + TableId string + func (*BigTableIODetails) Descriptor() ([]byte, []int) + func (*BigTableIODetails) ProtoMessage() + func (x *BigTableIODetails) GetInstanceId() string + func (x *BigTableIODetails) GetProjectId() string + func (x *BigTableIODetails) GetTableId() string + func (x *BigTableIODetails) ProtoReflect() protoreflect.Message + func (x *BigTableIODetails) Reset() + func (x *BigTableIODetails) String() string + type CheckActiveJobsRequest struct + ProjectId string + func (*CheckActiveJobsRequest) Descriptor() ([]byte, []int) + func (*CheckActiveJobsRequest) ProtoMessage() + func (x *CheckActiveJobsRequest) GetProjectId() string + func (x *CheckActiveJobsRequest) ProtoReflect() protoreflect.Message + func (x *CheckActiveJobsRequest) Reset() + func (x *CheckActiveJobsRequest) String() string + type CheckActiveJobsResponse struct + ActiveJobsExist bool + func (*CheckActiveJobsResponse) Descriptor() ([]byte, []int) + func (*CheckActiveJobsResponse) ProtoMessage() + func (x *CheckActiveJobsResponse) GetActiveJobsExist() bool + func (x *CheckActiveJobsResponse) ProtoReflect() protoreflect.Message + func (x *CheckActiveJobsResponse) Reset() + func (x *CheckActiveJobsResponse) String() string + type ComputationTopology struct + ComputationId string + Inputs []*StreamLocation + KeyRanges []*KeyRangeLocation + Outputs []*StreamLocation + StateFamilies []*StateFamilyConfig + SystemStageName string + func (*ComputationTopology) Descriptor() ([]byte, []int) + func (*ComputationTopology) ProtoMessage() + func (x *ComputationTopology) GetComputationId() string + func (x *ComputationTopology) GetInputs() []*StreamLocation + func (x *ComputationTopology) GetKeyRanges() []*KeyRangeLocation + func (x *ComputationTopology) GetOutputs() []*StreamLocation + func (x *ComputationTopology) GetStateFamilies() []*StateFamilyConfig + func (x *ComputationTopology) GetSystemStageName() string + func (x *ComputationTopology) ProtoReflect() protoreflect.Message + func (x *ComputationTopology) Reset() + func (x *ComputationTopology) String() string + type ContainerSpec struct + DefaultEnvironment *FlexTemplateRuntimeEnvironment + Image string + Metadata *TemplateMetadata + SdkInfo *SDKInfo + func (*ContainerSpec) Descriptor() ([]byte, []int) + func (*ContainerSpec) ProtoMessage() + func (x *ContainerSpec) GetDefaultEnvironment() *FlexTemplateRuntimeEnvironment + func (x *ContainerSpec) GetImage() string + func (x *ContainerSpec) GetMetadata() *TemplateMetadata + func (x *ContainerSpec) GetSdkInfo() *SDKInfo + func (x *ContainerSpec) ProtoReflect() protoreflect.Message + func (x *ContainerSpec) Reset() + func (x *ContainerSpec) String() string + type CreateJobFromTemplateRequest struct + Environment *RuntimeEnvironment + JobName string + Location string + Parameters map[string]string + ProjectId string + Template isCreateJobFromTemplateRequest_Template + func (*CreateJobFromTemplateRequest) Descriptor() ([]byte, []int) + func (*CreateJobFromTemplateRequest) ProtoMessage() + func (m *CreateJobFromTemplateRequest) GetTemplate() isCreateJobFromTemplateRequest_Template + func (x *CreateJobFromTemplateRequest) GetEnvironment() *RuntimeEnvironment + func (x *CreateJobFromTemplateRequest) GetGcsPath() string + func (x *CreateJobFromTemplateRequest) GetJobName() string + func (x *CreateJobFromTemplateRequest) GetLocation() string + func (x *CreateJobFromTemplateRequest) GetParameters() map[string]string + func (x *CreateJobFromTemplateRequest) GetProjectId() string + func (x *CreateJobFromTemplateRequest) ProtoReflect() protoreflect.Message + func (x *CreateJobFromTemplateRequest) Reset() + func (x *CreateJobFromTemplateRequest) String() string + type CreateJobFromTemplateRequest_GcsPath struct + GcsPath string + type CreateJobRequest struct + Job *Job + Location string + ProjectId string + ReplaceJobId string + View JobView + func (*CreateJobRequest) Descriptor() ([]byte, []int) + func (*CreateJobRequest) ProtoMessage() + func (x *CreateJobRequest) GetJob() *Job + func (x *CreateJobRequest) GetLocation() string + func (x *CreateJobRequest) GetProjectId() string + func (x *CreateJobRequest) GetReplaceJobId() string + func (x *CreateJobRequest) GetView() JobView + func (x *CreateJobRequest) ProtoReflect() protoreflect.Message + func (x *CreateJobRequest) Reset() + func (x *CreateJobRequest) String() string + type CustomSourceLocation struct + Stateful bool + func (*CustomSourceLocation) Descriptor() ([]byte, []int) + func (*CustomSourceLocation) ProtoMessage() + func (x *CustomSourceLocation) GetStateful() bool + func (x *CustomSourceLocation) ProtoReflect() protoreflect.Message + func (x *CustomSourceLocation) Reset() + func (x *CustomSourceLocation) String() string + type DataDiskAssignment struct + DataDisks []string + VmInstance string + func (*DataDiskAssignment) Descriptor() ([]byte, []int) + func (*DataDiskAssignment) ProtoMessage() + func (x *DataDiskAssignment) GetDataDisks() []string + func (x *DataDiskAssignment) GetVmInstance() string + func (x *DataDiskAssignment) ProtoReflect() protoreflect.Message + func (x *DataDiskAssignment) Reset() + func (x *DataDiskAssignment) String() string + type DatastoreIODetails struct + Namespace string + ProjectId string + func (*DatastoreIODetails) Descriptor() ([]byte, []int) + func (*DatastoreIODetails) ProtoMessage() + func (x *DatastoreIODetails) GetNamespace() string + func (x *DatastoreIODetails) GetProjectId() string + func (x *DatastoreIODetails) ProtoReflect() protoreflect.Message + func (x *DatastoreIODetails) Reset() + func (x *DatastoreIODetails) String() string + type DebugOptions struct + EnableHotKeyLogging bool + func (*DebugOptions) Descriptor() ([]byte, []int) + func (*DebugOptions) ProtoMessage() + func (x *DebugOptions) GetEnableHotKeyLogging() bool + func (x *DebugOptions) ProtoReflect() protoreflect.Message + func (x *DebugOptions) Reset() + func (x *DebugOptions) String() string + type DefaultPackageSet int32 + const DefaultPackageSet_DEFAULT_PACKAGE_SET_JAVA + const DefaultPackageSet_DEFAULT_PACKAGE_SET_NONE + const DefaultPackageSet_DEFAULT_PACKAGE_SET_PYTHON + const DefaultPackageSet_DEFAULT_PACKAGE_SET_UNKNOWN + func (DefaultPackageSet) Descriptor() protoreflect.EnumDescriptor + func (DefaultPackageSet) EnumDescriptor() ([]byte, []int) + func (DefaultPackageSet) Type() protoreflect.EnumType + func (x DefaultPackageSet) Enum() *DefaultPackageSet + func (x DefaultPackageSet) Number() protoreflect.EnumNumber + func (x DefaultPackageSet) String() string + type DeleteSnapshotRequest struct + Location string + ProjectId string + SnapshotId string + func (*DeleteSnapshotRequest) Descriptor() ([]byte, []int) + func (*DeleteSnapshotRequest) ProtoMessage() + func (x *DeleteSnapshotRequest) GetLocation() string + func (x *DeleteSnapshotRequest) GetProjectId() string + func (x *DeleteSnapshotRequest) GetSnapshotId() string + func (x *DeleteSnapshotRequest) ProtoReflect() protoreflect.Message + func (x *DeleteSnapshotRequest) Reset() + func (x *DeleteSnapshotRequest) String() string + type DeleteSnapshotResponse struct + func (*DeleteSnapshotResponse) Descriptor() ([]byte, []int) + func (*DeleteSnapshotResponse) ProtoMessage() + func (x *DeleteSnapshotResponse) ProtoReflect() protoreflect.Message + func (x *DeleteSnapshotResponse) Reset() + func (x *DeleteSnapshotResponse) String() string + type Disk struct + DiskType string + MountPoint string + SizeGb int32 + func (*Disk) Descriptor() ([]byte, []int) + func (*Disk) ProtoMessage() + func (x *Disk) GetDiskType() string + func (x *Disk) GetMountPoint() string + func (x *Disk) GetSizeGb() int32 + func (x *Disk) ProtoReflect() protoreflect.Message + func (x *Disk) Reset() + func (x *Disk) String() string + type DisplayData struct + Key string + Label string + Namespace string + ShortStrValue string + Url string + Value isDisplayData_Value + func (*DisplayData) Descriptor() ([]byte, []int) + func (*DisplayData) ProtoMessage() + func (m *DisplayData) GetValue() isDisplayData_Value + func (x *DisplayData) GetBoolValue() bool + func (x *DisplayData) GetDurationValue() *durationpb.Duration + func (x *DisplayData) GetFloatValue() float32 + func (x *DisplayData) GetInt64Value() int64 + func (x *DisplayData) GetJavaClassValue() string + func (x *DisplayData) GetKey() string + func (x *DisplayData) GetLabel() string + func (x *DisplayData) GetNamespace() string + func (x *DisplayData) GetShortStrValue() string + func (x *DisplayData) GetStrValue() string + func (x *DisplayData) GetTimestampValue() *timestamppb.Timestamp + func (x *DisplayData) GetUrl() string + func (x *DisplayData) ProtoReflect() protoreflect.Message + func (x *DisplayData) Reset() + func (x *DisplayData) String() string + type DisplayData_BoolValue struct + BoolValue bool + type DisplayData_DurationValue struct + DurationValue *durationpb.Duration + type DisplayData_FloatValue struct + FloatValue float32 + type DisplayData_Int64Value struct + Int64Value int64 + type DisplayData_JavaClassValue struct + JavaClassValue string + type DisplayData_StrValue struct + StrValue string + type DisplayData_TimestampValue struct + TimestampValue *timestamppb.Timestamp + type DynamicTemplateLaunchParams struct + GcsPath string + StagingLocation string + func (*DynamicTemplateLaunchParams) Descriptor() ([]byte, []int) + func (*DynamicTemplateLaunchParams) ProtoMessage() + func (x *DynamicTemplateLaunchParams) GetGcsPath() string + func (x *DynamicTemplateLaunchParams) GetStagingLocation() string + func (x *DynamicTemplateLaunchParams) ProtoReflect() protoreflect.Message + func (x *DynamicTemplateLaunchParams) Reset() + func (x *DynamicTemplateLaunchParams) String() string + type Environment struct + ClusterManagerApiService string + Dataset string + DebugOptions *DebugOptions + Experiments []string + FlexResourceSchedulingGoal FlexResourceSchedulingGoal + InternalExperiments *anypb.Any + SdkPipelineOptions *structpb.Struct + ServiceAccountEmail string + ServiceKmsKeyName string + ServiceOptions []string + ShuffleMode ShuffleMode + TempStoragePrefix string + UserAgent *structpb.Struct + Version *structpb.Struct + WorkerPools []*WorkerPool + WorkerRegion string + WorkerZone string + func (*Environment) Descriptor() ([]byte, []int) + func (*Environment) ProtoMessage() + func (x *Environment) GetClusterManagerApiService() string + func (x *Environment) GetDataset() string + func (x *Environment) GetDebugOptions() *DebugOptions + func (x *Environment) GetExperiments() []string + func (x *Environment) GetFlexResourceSchedulingGoal() FlexResourceSchedulingGoal + func (x *Environment) GetInternalExperiments() *anypb.Any + func (x *Environment) GetSdkPipelineOptions() *structpb.Struct + func (x *Environment) GetServiceAccountEmail() string + func (x *Environment) GetServiceKmsKeyName() string + func (x *Environment) GetServiceOptions() []string + func (x *Environment) GetShuffleMode() ShuffleMode + func (x *Environment) GetTempStoragePrefix() string + func (x *Environment) GetUserAgent() *structpb.Struct + func (x *Environment) GetVersion() *structpb.Struct + func (x *Environment) GetWorkerPools() []*WorkerPool + func (x *Environment) GetWorkerRegion() string + func (x *Environment) GetWorkerZone() string + func (x *Environment) ProtoReflect() protoreflect.Message + func (x *Environment) Reset() + func (x *Environment) String() string + type ExecutionStageState struct + CurrentStateTime *timestamppb.Timestamp + ExecutionStageName string + ExecutionStageState JobState + func (*ExecutionStageState) Descriptor() ([]byte, []int) + func (*ExecutionStageState) ProtoMessage() + func (x *ExecutionStageState) GetCurrentStateTime() *timestamppb.Timestamp + func (x *ExecutionStageState) GetExecutionStageName() string + func (x *ExecutionStageState) GetExecutionStageState() JobState + func (x *ExecutionStageState) ProtoReflect() protoreflect.Message + func (x *ExecutionStageState) Reset() + func (x *ExecutionStageState) String() string + type ExecutionStageSummary struct + ComponentSource []*ExecutionStageSummary_ComponentSource + ComponentTransform []*ExecutionStageSummary_ComponentTransform + Id string + InputSource []*ExecutionStageSummary_StageSource + Kind KindType + Name string + OutputSource []*ExecutionStageSummary_StageSource + PrerequisiteStage []string + func (*ExecutionStageSummary) Descriptor() ([]byte, []int) + func (*ExecutionStageSummary) ProtoMessage() + func (x *ExecutionStageSummary) GetComponentSource() []*ExecutionStageSummary_ComponentSource + func (x *ExecutionStageSummary) GetComponentTransform() []*ExecutionStageSummary_ComponentTransform + func (x *ExecutionStageSummary) GetId() string + func (x *ExecutionStageSummary) GetInputSource() []*ExecutionStageSummary_StageSource + func (x *ExecutionStageSummary) GetKind() KindType + func (x *ExecutionStageSummary) GetName() string + func (x *ExecutionStageSummary) GetOutputSource() []*ExecutionStageSummary_StageSource + func (x *ExecutionStageSummary) GetPrerequisiteStage() []string + func (x *ExecutionStageSummary) ProtoReflect() protoreflect.Message + func (x *ExecutionStageSummary) Reset() + func (x *ExecutionStageSummary) String() string + type ExecutionStageSummary_ComponentSource struct + Name string + OriginalTransformOrCollection string + UserName string + func (*ExecutionStageSummary_ComponentSource) Descriptor() ([]byte, []int) + func (*ExecutionStageSummary_ComponentSource) ProtoMessage() + func (x *ExecutionStageSummary_ComponentSource) GetName() string + func (x *ExecutionStageSummary_ComponentSource) GetOriginalTransformOrCollection() string + func (x *ExecutionStageSummary_ComponentSource) GetUserName() string + func (x *ExecutionStageSummary_ComponentSource) ProtoReflect() protoreflect.Message + func (x *ExecutionStageSummary_ComponentSource) Reset() + func (x *ExecutionStageSummary_ComponentSource) String() string + type ExecutionStageSummary_ComponentTransform struct + Name string + OriginalTransform string + UserName string + func (*ExecutionStageSummary_ComponentTransform) Descriptor() ([]byte, []int) + func (*ExecutionStageSummary_ComponentTransform) ProtoMessage() + func (x *ExecutionStageSummary_ComponentTransform) GetName() string + func (x *ExecutionStageSummary_ComponentTransform) GetOriginalTransform() string + func (x *ExecutionStageSummary_ComponentTransform) GetUserName() string + func (x *ExecutionStageSummary_ComponentTransform) ProtoReflect() protoreflect.Message + func (x *ExecutionStageSummary_ComponentTransform) Reset() + func (x *ExecutionStageSummary_ComponentTransform) String() string + type ExecutionStageSummary_StageSource struct + Name string + OriginalTransformOrCollection string + SizeBytes int64 + UserName string + func (*ExecutionStageSummary_StageSource) Descriptor() ([]byte, []int) + func (*ExecutionStageSummary_StageSource) ProtoMessage() + func (x *ExecutionStageSummary_StageSource) GetName() string + func (x *ExecutionStageSummary_StageSource) GetOriginalTransformOrCollection() string + func (x *ExecutionStageSummary_StageSource) GetSizeBytes() int64 + func (x *ExecutionStageSummary_StageSource) GetUserName() string + func (x *ExecutionStageSummary_StageSource) ProtoReflect() protoreflect.Message + func (x *ExecutionStageSummary_StageSource) Reset() + func (x *ExecutionStageSummary_StageSource) String() string + type ExecutionState int32 + const ExecutionState_EXECUTION_STATE_CANCELLED + const ExecutionState_EXECUTION_STATE_FAILED + const ExecutionState_EXECUTION_STATE_NOT_STARTED + const ExecutionState_EXECUTION_STATE_RUNNING + const ExecutionState_EXECUTION_STATE_SUCCEEDED + const ExecutionState_EXECUTION_STATE_UNKNOWN + func (ExecutionState) Descriptor() protoreflect.EnumDescriptor + func (ExecutionState) EnumDescriptor() ([]byte, []int) + func (ExecutionState) Type() protoreflect.EnumType + func (x ExecutionState) Enum() *ExecutionState + func (x ExecutionState) Number() protoreflect.EnumNumber + func (x ExecutionState) String() string + type FailedLocation struct + Name string + func (*FailedLocation) Descriptor() ([]byte, []int) + func (*FailedLocation) ProtoMessage() + func (x *FailedLocation) GetName() string + func (x *FailedLocation) ProtoReflect() protoreflect.Message + func (x *FailedLocation) Reset() + func (x *FailedLocation) String() string + type FileIODetails struct + FilePattern string + func (*FileIODetails) Descriptor() ([]byte, []int) + func (*FileIODetails) ProtoMessage() + func (x *FileIODetails) GetFilePattern() string + func (x *FileIODetails) ProtoReflect() protoreflect.Message + func (x *FileIODetails) Reset() + func (x *FileIODetails) String() string + type FlexResourceSchedulingGoal int32 + const FlexResourceSchedulingGoal_FLEXRS_COST_OPTIMIZED + const FlexResourceSchedulingGoal_FLEXRS_SPEED_OPTIMIZED + const FlexResourceSchedulingGoal_FLEXRS_UNSPECIFIED + func (FlexResourceSchedulingGoal) Descriptor() protoreflect.EnumDescriptor + func (FlexResourceSchedulingGoal) EnumDescriptor() ([]byte, []int) + func (FlexResourceSchedulingGoal) Type() protoreflect.EnumType + func (x FlexResourceSchedulingGoal) Enum() *FlexResourceSchedulingGoal + func (x FlexResourceSchedulingGoal) Number() protoreflect.EnumNumber + func (x FlexResourceSchedulingGoal) String() string + type FlexTemplateRuntimeEnvironment struct + AdditionalExperiments []string + AdditionalUserLabels map[string]string + AutoscalingAlgorithm AutoscalingAlgorithm + DiskSizeGb int32 + DumpHeapOnOom bool + EnableStreamingEngine bool + FlexrsGoal FlexResourceSchedulingGoal + IpConfiguration WorkerIPAddressConfiguration + KmsKeyName string + LauncherMachineType string + MachineType string + MaxWorkers int32 + Network string + NumWorkers int32 + SaveHeapDumpsToGcsPath string + SdkContainerImage string + ServiceAccountEmail string + StagingLocation string + Subnetwork string + TempLocation string + WorkerRegion string + WorkerZone string + Zone string + func (*FlexTemplateRuntimeEnvironment) Descriptor() ([]byte, []int) + func (*FlexTemplateRuntimeEnvironment) ProtoMessage() + func (x *FlexTemplateRuntimeEnvironment) GetAdditionalExperiments() []string + func (x *FlexTemplateRuntimeEnvironment) GetAdditionalUserLabels() map[string]string + func (x *FlexTemplateRuntimeEnvironment) GetAutoscalingAlgorithm() AutoscalingAlgorithm + func (x *FlexTemplateRuntimeEnvironment) GetDiskSizeGb() int32 + func (x *FlexTemplateRuntimeEnvironment) GetDumpHeapOnOom() bool + func (x *FlexTemplateRuntimeEnvironment) GetEnableStreamingEngine() bool + func (x *FlexTemplateRuntimeEnvironment) GetFlexrsGoal() FlexResourceSchedulingGoal + func (x *FlexTemplateRuntimeEnvironment) GetIpConfiguration() WorkerIPAddressConfiguration + func (x *FlexTemplateRuntimeEnvironment) GetKmsKeyName() string + func (x *FlexTemplateRuntimeEnvironment) GetLauncherMachineType() string + func (x *FlexTemplateRuntimeEnvironment) GetMachineType() string + func (x *FlexTemplateRuntimeEnvironment) GetMaxWorkers() int32 + func (x *FlexTemplateRuntimeEnvironment) GetNetwork() string + func (x *FlexTemplateRuntimeEnvironment) GetNumWorkers() int32 + func (x *FlexTemplateRuntimeEnvironment) GetSaveHeapDumpsToGcsPath() string + func (x *FlexTemplateRuntimeEnvironment) GetSdkContainerImage() string + func (x *FlexTemplateRuntimeEnvironment) GetServiceAccountEmail() string + func (x *FlexTemplateRuntimeEnvironment) GetStagingLocation() string + func (x *FlexTemplateRuntimeEnvironment) GetSubnetwork() string + func (x *FlexTemplateRuntimeEnvironment) GetTempLocation() string + func (x *FlexTemplateRuntimeEnvironment) GetWorkerRegion() string + func (x *FlexTemplateRuntimeEnvironment) GetWorkerZone() string + func (x *FlexTemplateRuntimeEnvironment) GetZone() string + func (x *FlexTemplateRuntimeEnvironment) ProtoReflect() protoreflect.Message + func (x *FlexTemplateRuntimeEnvironment) Reset() + func (x *FlexTemplateRuntimeEnvironment) String() string + type FlexTemplatesServiceClient interface + LaunchFlexTemplate func(ctx context.Context, in *LaunchFlexTemplateRequest, opts ...grpc.CallOption) (*LaunchFlexTemplateResponse, error) + func NewFlexTemplatesServiceClient(cc grpc.ClientConnInterface) FlexTemplatesServiceClient + type FlexTemplatesServiceServer interface + LaunchFlexTemplate func(context.Context, *LaunchFlexTemplateRequest) (*LaunchFlexTemplateResponse, error) + type GetJobExecutionDetailsRequest struct + JobId string + Location string + PageSize int32 + PageToken string + ProjectId string + func (*GetJobExecutionDetailsRequest) Descriptor() ([]byte, []int) + func (*GetJobExecutionDetailsRequest) ProtoMessage() + func (x *GetJobExecutionDetailsRequest) GetJobId() string + func (x *GetJobExecutionDetailsRequest) GetLocation() string + func (x *GetJobExecutionDetailsRequest) GetPageSize() int32 + func (x *GetJobExecutionDetailsRequest) GetPageToken() string + func (x *GetJobExecutionDetailsRequest) GetProjectId() string + func (x *GetJobExecutionDetailsRequest) ProtoReflect() protoreflect.Message + func (x *GetJobExecutionDetailsRequest) Reset() + func (x *GetJobExecutionDetailsRequest) String() string + type GetJobMetricsRequest struct + JobId string + Location string + ProjectId string + StartTime *timestamppb.Timestamp + func (*GetJobMetricsRequest) Descriptor() ([]byte, []int) + func (*GetJobMetricsRequest) ProtoMessage() + func (x *GetJobMetricsRequest) GetJobId() string + func (x *GetJobMetricsRequest) GetLocation() string + func (x *GetJobMetricsRequest) GetProjectId() string + func (x *GetJobMetricsRequest) GetStartTime() *timestamppb.Timestamp + func (x *GetJobMetricsRequest) ProtoReflect() protoreflect.Message + func (x *GetJobMetricsRequest) Reset() + func (x *GetJobMetricsRequest) String() string + type GetJobRequest struct + JobId string + Location string + ProjectId string + View JobView + func (*GetJobRequest) Descriptor() ([]byte, []int) + func (*GetJobRequest) ProtoMessage() + func (x *GetJobRequest) GetJobId() string + func (x *GetJobRequest) GetLocation() string + func (x *GetJobRequest) GetProjectId() string + func (x *GetJobRequest) GetView() JobView + func (x *GetJobRequest) ProtoReflect() protoreflect.Message + func (x *GetJobRequest) Reset() + func (x *GetJobRequest) String() string + type GetSnapshotRequest struct + Location string + ProjectId string + SnapshotId string + func (*GetSnapshotRequest) Descriptor() ([]byte, []int) + func (*GetSnapshotRequest) ProtoMessage() + func (x *GetSnapshotRequest) GetLocation() string + func (x *GetSnapshotRequest) GetProjectId() string + func (x *GetSnapshotRequest) GetSnapshotId() string + func (x *GetSnapshotRequest) ProtoReflect() protoreflect.Message + func (x *GetSnapshotRequest) Reset() + func (x *GetSnapshotRequest) String() string + type GetStageExecutionDetailsRequest struct + EndTime *timestamppb.Timestamp + JobId string + Location string + PageSize int32 + PageToken string + ProjectId string + StageId string + StartTime *timestamppb.Timestamp + func (*GetStageExecutionDetailsRequest) Descriptor() ([]byte, []int) + func (*GetStageExecutionDetailsRequest) ProtoMessage() + func (x *GetStageExecutionDetailsRequest) GetEndTime() *timestamppb.Timestamp + func (x *GetStageExecutionDetailsRequest) GetJobId() string + func (x *GetStageExecutionDetailsRequest) GetLocation() string + func (x *GetStageExecutionDetailsRequest) GetPageSize() int32 + func (x *GetStageExecutionDetailsRequest) GetPageToken() string + func (x *GetStageExecutionDetailsRequest) GetProjectId() string + func (x *GetStageExecutionDetailsRequest) GetStageId() string + func (x *GetStageExecutionDetailsRequest) GetStartTime() *timestamppb.Timestamp + func (x *GetStageExecutionDetailsRequest) ProtoReflect() protoreflect.Message + func (x *GetStageExecutionDetailsRequest) Reset() + func (x *GetStageExecutionDetailsRequest) String() string + type GetTemplateRequest struct + Location string + ProjectId string + Template isGetTemplateRequest_Template + View GetTemplateRequest_TemplateView + func (*GetTemplateRequest) Descriptor() ([]byte, []int) + func (*GetTemplateRequest) ProtoMessage() + func (m *GetTemplateRequest) GetTemplate() isGetTemplateRequest_Template + func (x *GetTemplateRequest) GetGcsPath() string + func (x *GetTemplateRequest) GetLocation() string + func (x *GetTemplateRequest) GetProjectId() string + func (x *GetTemplateRequest) GetView() GetTemplateRequest_TemplateView + func (x *GetTemplateRequest) ProtoReflect() protoreflect.Message + func (x *GetTemplateRequest) Reset() + func (x *GetTemplateRequest) String() string + type GetTemplateRequest_GcsPath struct + GcsPath string + type GetTemplateRequest_TemplateView int32 + const GetTemplateRequest_METADATA_ONLY + func (GetTemplateRequest_TemplateView) Descriptor() protoreflect.EnumDescriptor + func (GetTemplateRequest_TemplateView) EnumDescriptor() ([]byte, []int) + func (GetTemplateRequest_TemplateView) Type() protoreflect.EnumType + func (x GetTemplateRequest_TemplateView) Enum() *GetTemplateRequest_TemplateView + func (x GetTemplateRequest_TemplateView) Number() protoreflect.EnumNumber + func (x GetTemplateRequest_TemplateView) String() string + type GetTemplateResponse struct + Metadata *TemplateMetadata + RuntimeMetadata *RuntimeMetadata + Status *status.Status + TemplateType GetTemplateResponse_TemplateType + func (*GetTemplateResponse) Descriptor() ([]byte, []int) + func (*GetTemplateResponse) ProtoMessage() + func (x *GetTemplateResponse) GetMetadata() *TemplateMetadata + func (x *GetTemplateResponse) GetRuntimeMetadata() *RuntimeMetadata + func (x *GetTemplateResponse) GetStatus() *status.Status + func (x *GetTemplateResponse) GetTemplateType() GetTemplateResponse_TemplateType + func (x *GetTemplateResponse) ProtoReflect() protoreflect.Message + func (x *GetTemplateResponse) Reset() + func (x *GetTemplateResponse) String() string + type GetTemplateResponse_TemplateType int32 + const GetTemplateResponse_FLEX + const GetTemplateResponse_LEGACY + const GetTemplateResponse_UNKNOWN + func (GetTemplateResponse_TemplateType) Descriptor() protoreflect.EnumDescriptor + func (GetTemplateResponse_TemplateType) EnumDescriptor() ([]byte, []int) + func (GetTemplateResponse_TemplateType) Type() protoreflect.EnumType + func (x GetTemplateResponse_TemplateType) Enum() *GetTemplateResponse_TemplateType + func (x GetTemplateResponse_TemplateType) Number() protoreflect.EnumNumber + func (x GetTemplateResponse_TemplateType) String() string + type InvalidTemplateParameters struct + ParameterViolations []*InvalidTemplateParameters_ParameterViolation + func (*InvalidTemplateParameters) Descriptor() ([]byte, []int) + func (*InvalidTemplateParameters) ProtoMessage() + func (x *InvalidTemplateParameters) GetParameterViolations() []*InvalidTemplateParameters_ParameterViolation + func (x *InvalidTemplateParameters) ProtoReflect() protoreflect.Message + func (x *InvalidTemplateParameters) Reset() + func (x *InvalidTemplateParameters) String() string + type InvalidTemplateParameters_ParameterViolation struct + Description string + Parameter string + func (*InvalidTemplateParameters_ParameterViolation) Descriptor() ([]byte, []int) + func (*InvalidTemplateParameters_ParameterViolation) ProtoMessage() + func (x *InvalidTemplateParameters_ParameterViolation) GetDescription() string + func (x *InvalidTemplateParameters_ParameterViolation) GetParameter() string + func (x *InvalidTemplateParameters_ParameterViolation) ProtoReflect() protoreflect.Message + func (x *InvalidTemplateParameters_ParameterViolation) Reset() + func (x *InvalidTemplateParameters_ParameterViolation) String() string + type Job struct + ClientRequestId string + CreateTime *timestamppb.Timestamp + CreatedFromSnapshotId string + CurrentState JobState + CurrentStateTime *timestamppb.Timestamp + Environment *Environment + ExecutionInfo *JobExecutionInfo + Id string + JobMetadata *JobMetadata + Labels map[string]string + Location string + Name string + PipelineDescription *PipelineDescription + ProjectId string + ReplaceJobId string + ReplacedByJobId string + RequestedState JobState + SatisfiesPzs bool + StageStates []*ExecutionStageState + StartTime *timestamppb.Timestamp + Steps []*Step + StepsLocation string + TempFiles []string + TransformNameMapping map[string]string + Type JobType + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (x *Job) GetClientRequestId() string + func (x *Job) GetCreateTime() *timestamppb.Timestamp + func (x *Job) GetCreatedFromSnapshotId() string + func (x *Job) GetCurrentState() JobState + func (x *Job) GetCurrentStateTime() *timestamppb.Timestamp + func (x *Job) GetEnvironment() *Environment + func (x *Job) GetExecutionInfo() *JobExecutionInfo + func (x *Job) GetId() string + func (x *Job) GetJobMetadata() *JobMetadata + func (x *Job) GetLabels() map[string]string + func (x *Job) GetLocation() string + func (x *Job) GetName() string + func (x *Job) GetPipelineDescription() *PipelineDescription + func (x *Job) GetProjectId() string + func (x *Job) GetReplaceJobId() string + func (x *Job) GetReplacedByJobId() string + func (x *Job) GetRequestedState() JobState + func (x *Job) GetSatisfiesPzs() bool + func (x *Job) GetStageStates() []*ExecutionStageState + func (x *Job) GetStartTime() *timestamppb.Timestamp + func (x *Job) GetSteps() []*Step + func (x *Job) GetStepsLocation() string + func (x *Job) GetTempFiles() []string + func (x *Job) GetTransformNameMapping() map[string]string + func (x *Job) GetType() JobType + func (x *Job) ProtoReflect() protoreflect.Message + func (x *Job) Reset() + func (x *Job) String() string + type JobExecutionDetails struct + NextPageToken string + Stages []*StageSummary + func (*JobExecutionDetails) Descriptor() ([]byte, []int) + func (*JobExecutionDetails) ProtoMessage() + func (x *JobExecutionDetails) GetNextPageToken() string + func (x *JobExecutionDetails) GetStages() []*StageSummary + func (x *JobExecutionDetails) ProtoReflect() protoreflect.Message + func (x *JobExecutionDetails) Reset() + func (x *JobExecutionDetails) String() string + type JobExecutionInfo struct + Stages map[string]*JobExecutionStageInfo + func (*JobExecutionInfo) Descriptor() ([]byte, []int) + func (*JobExecutionInfo) ProtoMessage() + func (x *JobExecutionInfo) GetStages() map[string]*JobExecutionStageInfo + func (x *JobExecutionInfo) ProtoReflect() protoreflect.Message + func (x *JobExecutionInfo) Reset() + func (x *JobExecutionInfo) String() string + type JobExecutionStageInfo struct + StepName []string + func (*JobExecutionStageInfo) Descriptor() ([]byte, []int) + func (*JobExecutionStageInfo) ProtoMessage() + func (x *JobExecutionStageInfo) GetStepName() []string + func (x *JobExecutionStageInfo) ProtoReflect() protoreflect.Message + func (x *JobExecutionStageInfo) Reset() + func (x *JobExecutionStageInfo) String() string + type JobMessage struct + Id string + MessageImportance JobMessageImportance + MessageText string + Time *timestamppb.Timestamp + func (*JobMessage) Descriptor() ([]byte, []int) + func (*JobMessage) ProtoMessage() + func (x *JobMessage) GetId() string + func (x *JobMessage) GetMessageImportance() JobMessageImportance + func (x *JobMessage) GetMessageText() string + func (x *JobMessage) GetTime() *timestamppb.Timestamp + func (x *JobMessage) ProtoReflect() protoreflect.Message + func (x *JobMessage) Reset() + func (x *JobMessage) String() string + type JobMessageImportance int32 + const JobMessageImportance_JOB_MESSAGE_BASIC + const JobMessageImportance_JOB_MESSAGE_DEBUG + const JobMessageImportance_JOB_MESSAGE_DETAILED + const JobMessageImportance_JOB_MESSAGE_ERROR + const JobMessageImportance_JOB_MESSAGE_IMPORTANCE_UNKNOWN + const JobMessageImportance_JOB_MESSAGE_WARNING + func (JobMessageImportance) Descriptor() protoreflect.EnumDescriptor + func (JobMessageImportance) EnumDescriptor() ([]byte, []int) + func (JobMessageImportance) Type() protoreflect.EnumType + func (x JobMessageImportance) Enum() *JobMessageImportance + func (x JobMessageImportance) Number() protoreflect.EnumNumber + func (x JobMessageImportance) String() string + type JobMetadata struct + BigTableDetails []*BigTableIODetails + BigqueryDetails []*BigQueryIODetails + DatastoreDetails []*DatastoreIODetails + FileDetails []*FileIODetails + PubsubDetails []*PubSubIODetails + SdkVersion *SdkVersion + SpannerDetails []*SpannerIODetails + func (*JobMetadata) Descriptor() ([]byte, []int) + func (*JobMetadata) ProtoMessage() + func (x *JobMetadata) GetBigTableDetails() []*BigTableIODetails + func (x *JobMetadata) GetBigqueryDetails() []*BigQueryIODetails + func (x *JobMetadata) GetDatastoreDetails() []*DatastoreIODetails + func (x *JobMetadata) GetFileDetails() []*FileIODetails + func (x *JobMetadata) GetPubsubDetails() []*PubSubIODetails + func (x *JobMetadata) GetSdkVersion() *SdkVersion + func (x *JobMetadata) GetSpannerDetails() []*SpannerIODetails + func (x *JobMetadata) ProtoReflect() protoreflect.Message + func (x *JobMetadata) Reset() + func (x *JobMetadata) String() string + type JobMetrics struct + MetricTime *timestamppb.Timestamp + Metrics []*MetricUpdate + func (*JobMetrics) Descriptor() ([]byte, []int) + func (*JobMetrics) ProtoMessage() + func (x *JobMetrics) GetMetricTime() *timestamppb.Timestamp + func (x *JobMetrics) GetMetrics() []*MetricUpdate + func (x *JobMetrics) ProtoReflect() protoreflect.Message + func (x *JobMetrics) Reset() + func (x *JobMetrics) String() string + type JobState int32 + const JobState_JOB_STATE_CANCELLED + const JobState_JOB_STATE_CANCELLING + const JobState_JOB_STATE_DONE + const JobState_JOB_STATE_DRAINED + const JobState_JOB_STATE_DRAINING + const JobState_JOB_STATE_FAILED + const JobState_JOB_STATE_PENDING + const JobState_JOB_STATE_QUEUED + const JobState_JOB_STATE_RESOURCE_CLEANING_UP + const JobState_JOB_STATE_RUNNING + const JobState_JOB_STATE_STOPPED + const JobState_JOB_STATE_UNKNOWN + const JobState_JOB_STATE_UPDATED + func (JobState) Descriptor() protoreflect.EnumDescriptor + func (JobState) EnumDescriptor() ([]byte, []int) + func (JobState) Type() protoreflect.EnumType + func (x JobState) Enum() *JobState + func (x JobState) Number() protoreflect.EnumNumber + func (x JobState) String() string + type JobType int32 + const JobType_JOB_TYPE_BATCH + const JobType_JOB_TYPE_STREAMING + const JobType_JOB_TYPE_UNKNOWN + func (JobType) Descriptor() protoreflect.EnumDescriptor + func (JobType) EnumDescriptor() ([]byte, []int) + func (JobType) Type() protoreflect.EnumType + func (x JobType) Enum() *JobType + func (x JobType) Number() protoreflect.EnumNumber + func (x JobType) String() string + type JobView int32 + const JobView_JOB_VIEW_ALL + const JobView_JOB_VIEW_DESCRIPTION + const JobView_JOB_VIEW_SUMMARY + const JobView_JOB_VIEW_UNKNOWN + func (JobView) Descriptor() protoreflect.EnumDescriptor + func (JobView) EnumDescriptor() ([]byte, []int) + func (JobView) Type() protoreflect.EnumType + func (x JobView) Enum() *JobView + func (x JobView) Number() protoreflect.EnumNumber + func (x JobView) String() string + type JobsV1Beta3Client interface + AggregatedListJobs func(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) + CheckActiveJobs func(ctx context.Context, in *CheckActiveJobsRequest, opts ...grpc.CallOption) (*CheckActiveJobsResponse, error) + CreateJob func(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error) + GetJob func(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error) + ListJobs func(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) + SnapshotJob func(ctx context.Context, in *SnapshotJobRequest, opts ...grpc.CallOption) (*Snapshot, error) + UpdateJob func(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*Job, error) + func NewJobsV1Beta3Client(cc grpc.ClientConnInterface) JobsV1Beta3Client + type JobsV1Beta3Server interface + AggregatedListJobs func(context.Context, *ListJobsRequest) (*ListJobsResponse, error) + CheckActiveJobs func(context.Context, *CheckActiveJobsRequest) (*CheckActiveJobsResponse, error) + CreateJob func(context.Context, *CreateJobRequest) (*Job, error) + GetJob func(context.Context, *GetJobRequest) (*Job, error) + ListJobs func(context.Context, *ListJobsRequest) (*ListJobsResponse, error) + SnapshotJob func(context.Context, *SnapshotJobRequest) (*Snapshot, error) + UpdateJob func(context.Context, *UpdateJobRequest) (*Job, error) + type KeyRangeDataDiskAssignment struct + DataDisk string + End string + Start string + func (*KeyRangeDataDiskAssignment) Descriptor() ([]byte, []int) + func (*KeyRangeDataDiskAssignment) ProtoMessage() + func (x *KeyRangeDataDiskAssignment) GetDataDisk() string + func (x *KeyRangeDataDiskAssignment) GetEnd() string + func (x *KeyRangeDataDiskAssignment) GetStart() string + func (x *KeyRangeDataDiskAssignment) ProtoReflect() protoreflect.Message + func (x *KeyRangeDataDiskAssignment) Reset() + func (x *KeyRangeDataDiskAssignment) String() string + type KeyRangeLocation struct + DataDisk string + DeliveryEndpoint string + DeprecatedPersistentDirectory string + End string + Start string + func (*KeyRangeLocation) Descriptor() ([]byte, []int) + func (*KeyRangeLocation) ProtoMessage() + func (x *KeyRangeLocation) GetDataDisk() string + func (x *KeyRangeLocation) GetDeliveryEndpoint() string + func (x *KeyRangeLocation) GetDeprecatedPersistentDirectory() string + func (x *KeyRangeLocation) GetEnd() string + func (x *KeyRangeLocation) GetStart() string + func (x *KeyRangeLocation) ProtoReflect() protoreflect.Message + func (x *KeyRangeLocation) Reset() + func (x *KeyRangeLocation) String() string + type KindType int32 + const KindType_CONSTANT_KIND + const KindType_FLATTEN_KIND + const KindType_GROUP_BY_KEY_KIND + const KindType_PAR_DO_KIND + const KindType_READ_KIND + const KindType_SHUFFLE_KIND + const KindType_SINGLETON_KIND + const KindType_UNKNOWN_KIND + const KindType_WRITE_KIND + func (KindType) Descriptor() protoreflect.EnumDescriptor + func (KindType) EnumDescriptor() ([]byte, []int) + func (KindType) Type() protoreflect.EnumType + func (x KindType) Enum() *KindType + func (x KindType) Number() protoreflect.EnumNumber + func (x KindType) String() string + type LaunchFlexTemplateParameter struct + Environment *FlexTemplateRuntimeEnvironment + JobName string + LaunchOptions map[string]string + Parameters map[string]string + Template isLaunchFlexTemplateParameter_Template + TransformNameMappings map[string]string + Update bool + func (*LaunchFlexTemplateParameter) Descriptor() ([]byte, []int) + func (*LaunchFlexTemplateParameter) ProtoMessage() + func (m *LaunchFlexTemplateParameter) GetTemplate() isLaunchFlexTemplateParameter_Template + func (x *LaunchFlexTemplateParameter) GetContainerSpec() *ContainerSpec + func (x *LaunchFlexTemplateParameter) GetContainerSpecGcsPath() string + func (x *LaunchFlexTemplateParameter) GetEnvironment() *FlexTemplateRuntimeEnvironment + func (x *LaunchFlexTemplateParameter) GetJobName() string + func (x *LaunchFlexTemplateParameter) GetLaunchOptions() map[string]string + func (x *LaunchFlexTemplateParameter) GetParameters() map[string]string + func (x *LaunchFlexTemplateParameter) GetTransformNameMappings() map[string]string + func (x *LaunchFlexTemplateParameter) GetUpdate() bool + func (x *LaunchFlexTemplateParameter) ProtoReflect() protoreflect.Message + func (x *LaunchFlexTemplateParameter) Reset() + func (x *LaunchFlexTemplateParameter) String() string + type LaunchFlexTemplateParameter_ContainerSpec struct + ContainerSpec *ContainerSpec + type LaunchFlexTemplateParameter_ContainerSpecGcsPath struct + ContainerSpecGcsPath string + type LaunchFlexTemplateRequest struct + LaunchParameter *LaunchFlexTemplateParameter + Location string + ProjectId string + ValidateOnly bool + func (*LaunchFlexTemplateRequest) Descriptor() ([]byte, []int) + func (*LaunchFlexTemplateRequest) ProtoMessage() + func (x *LaunchFlexTemplateRequest) GetLaunchParameter() *LaunchFlexTemplateParameter + func (x *LaunchFlexTemplateRequest) GetLocation() string + func (x *LaunchFlexTemplateRequest) GetProjectId() string + func (x *LaunchFlexTemplateRequest) GetValidateOnly() bool + func (x *LaunchFlexTemplateRequest) ProtoReflect() protoreflect.Message + func (x *LaunchFlexTemplateRequest) Reset() + func (x *LaunchFlexTemplateRequest) String() string + type LaunchFlexTemplateResponse struct + Job *Job + func (*LaunchFlexTemplateResponse) Descriptor() ([]byte, []int) + func (*LaunchFlexTemplateResponse) ProtoMessage() + func (x *LaunchFlexTemplateResponse) GetJob() *Job + func (x *LaunchFlexTemplateResponse) ProtoReflect() protoreflect.Message + func (x *LaunchFlexTemplateResponse) Reset() + func (x *LaunchFlexTemplateResponse) String() string + type LaunchTemplateParameters struct + Environment *RuntimeEnvironment + JobName string + Parameters map[string]string + TransformNameMapping map[string]string + Update bool + func (*LaunchTemplateParameters) Descriptor() ([]byte, []int) + func (*LaunchTemplateParameters) ProtoMessage() + func (x *LaunchTemplateParameters) GetEnvironment() *RuntimeEnvironment + func (x *LaunchTemplateParameters) GetJobName() string + func (x *LaunchTemplateParameters) GetParameters() map[string]string + func (x *LaunchTemplateParameters) GetTransformNameMapping() map[string]string + func (x *LaunchTemplateParameters) GetUpdate() bool + func (x *LaunchTemplateParameters) ProtoReflect() protoreflect.Message + func (x *LaunchTemplateParameters) Reset() + func (x *LaunchTemplateParameters) String() string + type LaunchTemplateRequest struct + LaunchParameters *LaunchTemplateParameters + Location string + ProjectId string + Template isLaunchTemplateRequest_Template + ValidateOnly bool + func (*LaunchTemplateRequest) Descriptor() ([]byte, []int) + func (*LaunchTemplateRequest) ProtoMessage() + func (m *LaunchTemplateRequest) GetTemplate() isLaunchTemplateRequest_Template + func (x *LaunchTemplateRequest) GetDynamicTemplate() *DynamicTemplateLaunchParams + func (x *LaunchTemplateRequest) GetGcsPath() string + func (x *LaunchTemplateRequest) GetLaunchParameters() *LaunchTemplateParameters + func (x *LaunchTemplateRequest) GetLocation() string + func (x *LaunchTemplateRequest) GetProjectId() string + func (x *LaunchTemplateRequest) GetValidateOnly() bool + func (x *LaunchTemplateRequest) ProtoReflect() protoreflect.Message + func (x *LaunchTemplateRequest) Reset() + func (x *LaunchTemplateRequest) String() string + type LaunchTemplateRequest_DynamicTemplate struct + DynamicTemplate *DynamicTemplateLaunchParams + type LaunchTemplateRequest_GcsPath struct + GcsPath string + type LaunchTemplateResponse struct + Job *Job + func (*LaunchTemplateResponse) Descriptor() ([]byte, []int) + func (*LaunchTemplateResponse) ProtoMessage() + func (x *LaunchTemplateResponse) GetJob() *Job + func (x *LaunchTemplateResponse) ProtoReflect() protoreflect.Message + func (x *LaunchTemplateResponse) Reset() + func (x *LaunchTemplateResponse) String() string + type ListJobMessagesRequest struct + EndTime *timestamppb.Timestamp + JobId string + Location string + MinimumImportance JobMessageImportance + PageSize int32 + PageToken string + ProjectId string + StartTime *timestamppb.Timestamp + func (*ListJobMessagesRequest) Descriptor() ([]byte, []int) + func (*ListJobMessagesRequest) ProtoMessage() + func (x *ListJobMessagesRequest) GetEndTime() *timestamppb.Timestamp + func (x *ListJobMessagesRequest) GetJobId() string + func (x *ListJobMessagesRequest) GetLocation() string + func (x *ListJobMessagesRequest) GetMinimumImportance() JobMessageImportance + func (x *ListJobMessagesRequest) GetPageSize() int32 + func (x *ListJobMessagesRequest) GetPageToken() string + func (x *ListJobMessagesRequest) GetProjectId() string + func (x *ListJobMessagesRequest) GetStartTime() *timestamppb.Timestamp + func (x *ListJobMessagesRequest) ProtoReflect() protoreflect.Message + func (x *ListJobMessagesRequest) Reset() + func (x *ListJobMessagesRequest) String() string + type ListJobMessagesResponse struct + AutoscalingEvents []*AutoscalingEvent + JobMessages []*JobMessage + NextPageToken string + func (*ListJobMessagesResponse) Descriptor() ([]byte, []int) + func (*ListJobMessagesResponse) ProtoMessage() + func (x *ListJobMessagesResponse) GetAutoscalingEvents() []*AutoscalingEvent + func (x *ListJobMessagesResponse) GetJobMessages() []*JobMessage + func (x *ListJobMessagesResponse) GetNextPageToken() string + func (x *ListJobMessagesResponse) ProtoReflect() protoreflect.Message + func (x *ListJobMessagesResponse) Reset() + func (x *ListJobMessagesResponse) String() string + type ListJobsRequest struct + Filter ListJobsRequest_Filter + Location string + PageSize int32 + PageToken string + ProjectId string + View JobView + func (*ListJobsRequest) Descriptor() ([]byte, []int) + func (*ListJobsRequest) ProtoMessage() + func (x *ListJobsRequest) GetFilter() ListJobsRequest_Filter + func (x *ListJobsRequest) GetLocation() string + func (x *ListJobsRequest) GetPageSize() int32 + func (x *ListJobsRequest) GetPageToken() string + func (x *ListJobsRequest) GetProjectId() string + func (x *ListJobsRequest) GetView() JobView + func (x *ListJobsRequest) ProtoReflect() protoreflect.Message + func (x *ListJobsRequest) Reset() + func (x *ListJobsRequest) String() string + type ListJobsRequest_Filter int32 + const ListJobsRequest_ACTIVE + const ListJobsRequest_ALL + const ListJobsRequest_TERMINATED + const ListJobsRequest_UNKNOWN + func (ListJobsRequest_Filter) Descriptor() protoreflect.EnumDescriptor + func (ListJobsRequest_Filter) EnumDescriptor() ([]byte, []int) + func (ListJobsRequest_Filter) Type() protoreflect.EnumType + func (x ListJobsRequest_Filter) Enum() *ListJobsRequest_Filter + func (x ListJobsRequest_Filter) Number() protoreflect.EnumNumber + func (x ListJobsRequest_Filter) String() string + type ListJobsResponse struct + FailedLocation []*FailedLocation + Jobs []*Job + NextPageToken string + func (*ListJobsResponse) Descriptor() ([]byte, []int) + func (*ListJobsResponse) ProtoMessage() + func (x *ListJobsResponse) GetFailedLocation() []*FailedLocation + func (x *ListJobsResponse) GetJobs() []*Job + func (x *ListJobsResponse) GetNextPageToken() string + func (x *ListJobsResponse) ProtoReflect() protoreflect.Message + func (x *ListJobsResponse) Reset() + func (x *ListJobsResponse) String() string + type ListSnapshotsRequest struct + JobId string + Location string + ProjectId string + func (*ListSnapshotsRequest) Descriptor() ([]byte, []int) + func (*ListSnapshotsRequest) ProtoMessage() + func (x *ListSnapshotsRequest) GetJobId() string + func (x *ListSnapshotsRequest) GetLocation() string + func (x *ListSnapshotsRequest) GetProjectId() string + func (x *ListSnapshotsRequest) ProtoReflect() protoreflect.Message + func (x *ListSnapshotsRequest) Reset() + func (x *ListSnapshotsRequest) String() string + type ListSnapshotsResponse struct + Snapshots []*Snapshot + func (*ListSnapshotsResponse) Descriptor() ([]byte, []int) + func (*ListSnapshotsResponse) ProtoMessage() + func (x *ListSnapshotsResponse) GetSnapshots() []*Snapshot + func (x *ListSnapshotsResponse) ProtoReflect() protoreflect.Message + func (x *ListSnapshotsResponse) Reset() + func (x *ListSnapshotsResponse) String() string + type MessagesV1Beta3Client interface + ListJobMessages func(ctx context.Context, in *ListJobMessagesRequest, opts ...grpc.CallOption) (*ListJobMessagesResponse, error) + func NewMessagesV1Beta3Client(cc grpc.ClientConnInterface) MessagesV1Beta3Client + type MessagesV1Beta3Server interface + ListJobMessages func(context.Context, *ListJobMessagesRequest) (*ListJobMessagesResponse, error) + type MetricStructuredName struct + Context map[string]string + Name string + Origin string + func (*MetricStructuredName) Descriptor() ([]byte, []int) + func (*MetricStructuredName) ProtoMessage() + func (x *MetricStructuredName) GetContext() map[string]string + func (x *MetricStructuredName) GetName() string + func (x *MetricStructuredName) GetOrigin() string + func (x *MetricStructuredName) ProtoReflect() protoreflect.Message + func (x *MetricStructuredName) Reset() + func (x *MetricStructuredName) String() string + type MetricUpdate struct + Cumulative bool + Distribution *structpb.Value + Gauge *structpb.Value + Internal *structpb.Value + Kind string + MeanCount *structpb.Value + MeanSum *structpb.Value + Name *MetricStructuredName + Scalar *structpb.Value + Set *structpb.Value + UpdateTime *timestamppb.Timestamp + func (*MetricUpdate) Descriptor() ([]byte, []int) + func (*MetricUpdate) ProtoMessage() + func (x *MetricUpdate) GetCumulative() bool + func (x *MetricUpdate) GetDistribution() *structpb.Value + func (x *MetricUpdate) GetGauge() *structpb.Value + func (x *MetricUpdate) GetInternal() *structpb.Value + func (x *MetricUpdate) GetKind() string + func (x *MetricUpdate) GetMeanCount() *structpb.Value + func (x *MetricUpdate) GetMeanSum() *structpb.Value + func (x *MetricUpdate) GetName() *MetricStructuredName + func (x *MetricUpdate) GetScalar() *structpb.Value + func (x *MetricUpdate) GetSet() *structpb.Value + func (x *MetricUpdate) GetUpdateTime() *timestamppb.Timestamp + func (x *MetricUpdate) ProtoReflect() protoreflect.Message + func (x *MetricUpdate) Reset() + func (x *MetricUpdate) String() string + type MetricsV1Beta3Client interface + GetJobExecutionDetails func(ctx context.Context, in *GetJobExecutionDetailsRequest, ...) (*JobExecutionDetails, error) + GetJobMetrics func(ctx context.Context, in *GetJobMetricsRequest, opts ...grpc.CallOption) (*JobMetrics, error) + GetStageExecutionDetails func(ctx context.Context, in *GetStageExecutionDetailsRequest, ...) (*StageExecutionDetails, error) + func NewMetricsV1Beta3Client(cc grpc.ClientConnInterface) MetricsV1Beta3Client + type MetricsV1Beta3Server interface + GetJobExecutionDetails func(context.Context, *GetJobExecutionDetailsRequest) (*JobExecutionDetails, error) + GetJobMetrics func(context.Context, *GetJobMetricsRequest) (*JobMetrics, error) + GetStageExecutionDetails func(context.Context, *GetStageExecutionDetailsRequest) (*StageExecutionDetails, error) + type MountedDataDisk struct + DataDisk string + func (*MountedDataDisk) Descriptor() ([]byte, []int) + func (*MountedDataDisk) ProtoMessage() + func (x *MountedDataDisk) GetDataDisk() string + func (x *MountedDataDisk) ProtoReflect() protoreflect.Message + func (x *MountedDataDisk) Reset() + func (x *MountedDataDisk) String() string + type Package struct + Location string + Name string + func (*Package) Descriptor() ([]byte, []int) + func (*Package) ProtoMessage() + func (x *Package) GetLocation() string + func (x *Package) GetName() string + func (x *Package) ProtoReflect() protoreflect.Message + func (x *Package) Reset() + func (x *Package) String() string + type ParameterMetadata struct + CustomMetadata map[string]string + HelpText string + IsOptional bool + Label string + Name string + ParamType ParameterType + Regexes []string + func (*ParameterMetadata) Descriptor() ([]byte, []int) + func (*ParameterMetadata) ProtoMessage() + func (x *ParameterMetadata) GetCustomMetadata() map[string]string + func (x *ParameterMetadata) GetHelpText() string + func (x *ParameterMetadata) GetIsOptional() bool + func (x *ParameterMetadata) GetLabel() string + func (x *ParameterMetadata) GetName() string + func (x *ParameterMetadata) GetParamType() ParameterType + func (x *ParameterMetadata) GetRegexes() []string + func (x *ParameterMetadata) ProtoReflect() protoreflect.Message + func (x *ParameterMetadata) Reset() + func (x *ParameterMetadata) String() string + type ParameterType int32 + const ParameterType_DEFAULT + const ParameterType_GCS_READ_BUCKET + const ParameterType_GCS_READ_FILE + const ParameterType_GCS_READ_FOLDER + const ParameterType_GCS_WRITE_BUCKET + const ParameterType_GCS_WRITE_FILE + const ParameterType_GCS_WRITE_FOLDER + const ParameterType_PUBSUB_SUBSCRIPTION + const ParameterType_PUBSUB_TOPIC + const ParameterType_TEXT + func (ParameterType) Descriptor() protoreflect.EnumDescriptor + func (ParameterType) EnumDescriptor() ([]byte, []int) + func (ParameterType) Type() protoreflect.EnumType + func (x ParameterType) Enum() *ParameterType + func (x ParameterType) Number() protoreflect.EnumNumber + func (x ParameterType) String() string + type PipelineDescription struct + DisplayData []*DisplayData + ExecutionPipelineStage []*ExecutionStageSummary + OriginalPipelineTransform []*TransformSummary + func (*PipelineDescription) Descriptor() ([]byte, []int) + func (*PipelineDescription) ProtoMessage() + func (x *PipelineDescription) GetDisplayData() []*DisplayData + func (x *PipelineDescription) GetExecutionPipelineStage() []*ExecutionStageSummary + func (x *PipelineDescription) GetOriginalPipelineTransform() []*TransformSummary + func (x *PipelineDescription) ProtoReflect() protoreflect.Message + func (x *PipelineDescription) Reset() + func (x *PipelineDescription) String() string + type ProgressTimeseries struct + CurrentProgress float64 + DataPoints []*ProgressTimeseries_Point + func (*ProgressTimeseries) Descriptor() ([]byte, []int) + func (*ProgressTimeseries) ProtoMessage() + func (x *ProgressTimeseries) GetCurrentProgress() float64 + func (x *ProgressTimeseries) GetDataPoints() []*ProgressTimeseries_Point + func (x *ProgressTimeseries) ProtoReflect() protoreflect.Message + func (x *ProgressTimeseries) Reset() + func (x *ProgressTimeseries) String() string + type ProgressTimeseries_Point struct + Time *timestamppb.Timestamp + Value float64 + func (*ProgressTimeseries_Point) Descriptor() ([]byte, []int) + func (*ProgressTimeseries_Point) ProtoMessage() + func (x *ProgressTimeseries_Point) GetTime() *timestamppb.Timestamp + func (x *ProgressTimeseries_Point) GetValue() float64 + func (x *ProgressTimeseries_Point) ProtoReflect() protoreflect.Message + func (x *ProgressTimeseries_Point) Reset() + func (x *ProgressTimeseries_Point) String() string + type PubSubIODetails struct + Subscription string + Topic string + func (*PubSubIODetails) Descriptor() ([]byte, []int) + func (*PubSubIODetails) ProtoMessage() + func (x *PubSubIODetails) GetSubscription() string + func (x *PubSubIODetails) GetTopic() string + func (x *PubSubIODetails) ProtoReflect() protoreflect.Message + func (x *PubSubIODetails) Reset() + func (x *PubSubIODetails) String() string + type PubsubLocation struct + DropLateData bool + IdLabel string + Subscription string + TimestampLabel string + Topic string + TrackingSubscription string + WithAttributes bool + func (*PubsubLocation) Descriptor() ([]byte, []int) + func (*PubsubLocation) ProtoMessage() + func (x *PubsubLocation) GetDropLateData() bool + func (x *PubsubLocation) GetIdLabel() string + func (x *PubsubLocation) GetSubscription() string + func (x *PubsubLocation) GetTimestampLabel() string + func (x *PubsubLocation) GetTopic() string + func (x *PubsubLocation) GetTrackingSubscription() string + func (x *PubsubLocation) GetWithAttributes() bool + func (x *PubsubLocation) ProtoReflect() protoreflect.Message + func (x *PubsubLocation) Reset() + func (x *PubsubLocation) String() string + type PubsubSnapshotMetadata struct + ExpireTime *timestamppb.Timestamp + SnapshotName string + TopicName string + func (*PubsubSnapshotMetadata) Descriptor() ([]byte, []int) + func (*PubsubSnapshotMetadata) ProtoMessage() + func (x *PubsubSnapshotMetadata) GetExpireTime() *timestamppb.Timestamp + func (x *PubsubSnapshotMetadata) GetSnapshotName() string + func (x *PubsubSnapshotMetadata) GetTopicName() string + func (x *PubsubSnapshotMetadata) ProtoReflect() protoreflect.Message + func (x *PubsubSnapshotMetadata) Reset() + func (x *PubsubSnapshotMetadata) String() string + type RuntimeEnvironment struct + AdditionalExperiments []string + AdditionalUserLabels map[string]string + BypassTempDirValidation bool + EnableStreamingEngine bool + IpConfiguration WorkerIPAddressConfiguration + KmsKeyName string + MachineType string + MaxWorkers int32 + Network string + NumWorkers int32 + ServiceAccountEmail string + Subnetwork string + TempLocation string + WorkerRegion string + WorkerZone string + Zone string + func (*RuntimeEnvironment) Descriptor() ([]byte, []int) + func (*RuntimeEnvironment) ProtoMessage() + func (x *RuntimeEnvironment) GetAdditionalExperiments() []string + func (x *RuntimeEnvironment) GetAdditionalUserLabels() map[string]string + func (x *RuntimeEnvironment) GetBypassTempDirValidation() bool + func (x *RuntimeEnvironment) GetEnableStreamingEngine() bool + func (x *RuntimeEnvironment) GetIpConfiguration() WorkerIPAddressConfiguration + func (x *RuntimeEnvironment) GetKmsKeyName() string + func (x *RuntimeEnvironment) GetMachineType() string + func (x *RuntimeEnvironment) GetMaxWorkers() int32 + func (x *RuntimeEnvironment) GetNetwork() string + func (x *RuntimeEnvironment) GetNumWorkers() int32 + func (x *RuntimeEnvironment) GetServiceAccountEmail() string + func (x *RuntimeEnvironment) GetSubnetwork() string + func (x *RuntimeEnvironment) GetTempLocation() string + func (x *RuntimeEnvironment) GetWorkerRegion() string + func (x *RuntimeEnvironment) GetWorkerZone() string + func (x *RuntimeEnvironment) GetZone() string + func (x *RuntimeEnvironment) ProtoReflect() protoreflect.Message + func (x *RuntimeEnvironment) Reset() + func (x *RuntimeEnvironment) String() string + type RuntimeMetadata struct + Parameters []*ParameterMetadata + SdkInfo *SDKInfo + func (*RuntimeMetadata) Descriptor() ([]byte, []int) + func (*RuntimeMetadata) ProtoMessage() + func (x *RuntimeMetadata) GetParameters() []*ParameterMetadata + func (x *RuntimeMetadata) GetSdkInfo() *SDKInfo + func (x *RuntimeMetadata) ProtoReflect() protoreflect.Message + func (x *RuntimeMetadata) Reset() + func (x *RuntimeMetadata) String() string + type SDKInfo struct + Language SDKInfo_Language + Version string + func (*SDKInfo) Descriptor() ([]byte, []int) + func (*SDKInfo) ProtoMessage() + func (x *SDKInfo) GetLanguage() SDKInfo_Language + func (x *SDKInfo) GetVersion() string + func (x *SDKInfo) ProtoReflect() protoreflect.Message + func (x *SDKInfo) Reset() + func (x *SDKInfo) String() string + type SDKInfo_Language int32 + const SDKInfo_JAVA + const SDKInfo_PYTHON + const SDKInfo_UNKNOWN + func (SDKInfo_Language) Descriptor() protoreflect.EnumDescriptor + func (SDKInfo_Language) EnumDescriptor() ([]byte, []int) + func (SDKInfo_Language) Type() protoreflect.EnumType + func (x SDKInfo_Language) Enum() *SDKInfo_Language + func (x SDKInfo_Language) Number() protoreflect.EnumNumber + func (x SDKInfo_Language) String() string + type SdkHarnessContainerImage struct + Capabilities []string + ContainerImage string + EnvironmentId string + UseSingleCorePerContainer bool + func (*SdkHarnessContainerImage) Descriptor() ([]byte, []int) + func (*SdkHarnessContainerImage) ProtoMessage() + func (x *SdkHarnessContainerImage) GetCapabilities() []string + func (x *SdkHarnessContainerImage) GetContainerImage() string + func (x *SdkHarnessContainerImage) GetEnvironmentId() string + func (x *SdkHarnessContainerImage) GetUseSingleCorePerContainer() bool + func (x *SdkHarnessContainerImage) ProtoReflect() protoreflect.Message + func (x *SdkHarnessContainerImage) Reset() + func (x *SdkHarnessContainerImage) String() string + type SdkVersion struct + SdkSupportStatus SdkVersion_SdkSupportStatus + Version string + VersionDisplayName string + func (*SdkVersion) Descriptor() ([]byte, []int) + func (*SdkVersion) ProtoMessage() + func (x *SdkVersion) GetSdkSupportStatus() SdkVersion_SdkSupportStatus + func (x *SdkVersion) GetVersion() string + func (x *SdkVersion) GetVersionDisplayName() string + func (x *SdkVersion) ProtoReflect() protoreflect.Message + func (x *SdkVersion) Reset() + func (x *SdkVersion) String() string + type SdkVersion_SdkSupportStatus int32 + const SdkVersion_DEPRECATED + const SdkVersion_STALE + const SdkVersion_SUPPORTED + const SdkVersion_UNKNOWN + const SdkVersion_UNSUPPORTED + func (SdkVersion_SdkSupportStatus) Descriptor() protoreflect.EnumDescriptor + func (SdkVersion_SdkSupportStatus) EnumDescriptor() ([]byte, []int) + func (SdkVersion_SdkSupportStatus) Type() protoreflect.EnumType + func (x SdkVersion_SdkSupportStatus) Enum() *SdkVersion_SdkSupportStatus + func (x SdkVersion_SdkSupportStatus) Number() protoreflect.EnumNumber + func (x SdkVersion_SdkSupportStatus) String() string + type ShuffleMode int32 + const ShuffleMode_SERVICE_BASED + const ShuffleMode_SHUFFLE_MODE_UNSPECIFIED + const ShuffleMode_VM_BASED + func (ShuffleMode) Descriptor() protoreflect.EnumDescriptor + func (ShuffleMode) EnumDescriptor() ([]byte, []int) + func (ShuffleMode) Type() protoreflect.EnumType + func (x ShuffleMode) Enum() *ShuffleMode + func (x ShuffleMode) Number() protoreflect.EnumNumber + func (x ShuffleMode) String() string + type Snapshot struct + CreationTime *timestamppb.Timestamp + Description string + DiskSizeBytes int64 + Id string + ProjectId string + PubsubMetadata []*PubsubSnapshotMetadata + Region string + SourceJobId string + State SnapshotState + Ttl *durationpb.Duration + func (*Snapshot) Descriptor() ([]byte, []int) + func (*Snapshot) ProtoMessage() + func (x *Snapshot) GetCreationTime() *timestamppb.Timestamp + func (x *Snapshot) GetDescription() string + func (x *Snapshot) GetDiskSizeBytes() int64 + func (x *Snapshot) GetId() string + func (x *Snapshot) GetProjectId() string + func (x *Snapshot) GetPubsubMetadata() []*PubsubSnapshotMetadata + func (x *Snapshot) GetRegion() string + func (x *Snapshot) GetSourceJobId() string + func (x *Snapshot) GetState() SnapshotState + func (x *Snapshot) GetTtl() *durationpb.Duration + func (x *Snapshot) ProtoReflect() protoreflect.Message + func (x *Snapshot) Reset() + func (x *Snapshot) String() string + type SnapshotJobRequest struct + Description string + JobId string + Location string + ProjectId string + SnapshotSources bool + Ttl *durationpb.Duration + func (*SnapshotJobRequest) Descriptor() ([]byte, []int) + func (*SnapshotJobRequest) ProtoMessage() + func (x *SnapshotJobRequest) GetDescription() string + func (x *SnapshotJobRequest) GetJobId() string + func (x *SnapshotJobRequest) GetLocation() string + func (x *SnapshotJobRequest) GetProjectId() string + func (x *SnapshotJobRequest) GetSnapshotSources() bool + func (x *SnapshotJobRequest) GetTtl() *durationpb.Duration + func (x *SnapshotJobRequest) ProtoReflect() protoreflect.Message + func (x *SnapshotJobRequest) Reset() + func (x *SnapshotJobRequest) String() string + type SnapshotState int32 + const SnapshotState_DELETED + const SnapshotState_FAILED + const SnapshotState_PENDING + const SnapshotState_READY + const SnapshotState_RUNNING + const SnapshotState_UNKNOWN_SNAPSHOT_STATE + func (SnapshotState) Descriptor() protoreflect.EnumDescriptor + func (SnapshotState) EnumDescriptor() ([]byte, []int) + func (SnapshotState) Type() protoreflect.EnumType + func (x SnapshotState) Enum() *SnapshotState + func (x SnapshotState) Number() protoreflect.EnumNumber + func (x SnapshotState) String() string + type SnapshotsV1Beta3Client interface + DeleteSnapshot func(ctx context.Context, in *DeleteSnapshotRequest, opts ...grpc.CallOption) (*DeleteSnapshotResponse, error) + GetSnapshot func(ctx context.Context, in *GetSnapshotRequest, opts ...grpc.CallOption) (*Snapshot, error) + ListSnapshots func(ctx context.Context, in *ListSnapshotsRequest, opts ...grpc.CallOption) (*ListSnapshotsResponse, error) + func NewSnapshotsV1Beta3Client(cc grpc.ClientConnInterface) SnapshotsV1Beta3Client + type SnapshotsV1Beta3Server interface + DeleteSnapshot func(context.Context, *DeleteSnapshotRequest) (*DeleteSnapshotResponse, error) + GetSnapshot func(context.Context, *GetSnapshotRequest) (*Snapshot, error) + ListSnapshots func(context.Context, *ListSnapshotsRequest) (*ListSnapshotsResponse, error) + type SpannerIODetails struct + DatabaseId string + InstanceId string + ProjectId string + func (*SpannerIODetails) Descriptor() ([]byte, []int) + func (*SpannerIODetails) ProtoMessage() + func (x *SpannerIODetails) GetDatabaseId() string + func (x *SpannerIODetails) GetInstanceId() string + func (x *SpannerIODetails) GetProjectId() string + func (x *SpannerIODetails) ProtoReflect() protoreflect.Message + func (x *SpannerIODetails) Reset() + func (x *SpannerIODetails) String() string + type StageExecutionDetails struct + NextPageToken string + Workers []*WorkerDetails + func (*StageExecutionDetails) Descriptor() ([]byte, []int) + func (*StageExecutionDetails) ProtoMessage() + func (x *StageExecutionDetails) GetNextPageToken() string + func (x *StageExecutionDetails) GetWorkers() []*WorkerDetails + func (x *StageExecutionDetails) ProtoReflect() protoreflect.Message + func (x *StageExecutionDetails) Reset() + func (x *StageExecutionDetails) String() string + type StageSummary struct + EndTime *timestamppb.Timestamp + Metrics []*MetricUpdate + Progress *ProgressTimeseries + StageId string + StartTime *timestamppb.Timestamp + State ExecutionState + func (*StageSummary) Descriptor() ([]byte, []int) + func (*StageSummary) ProtoMessage() + func (x *StageSummary) GetEndTime() *timestamppb.Timestamp + func (x *StageSummary) GetMetrics() []*MetricUpdate + func (x *StageSummary) GetProgress() *ProgressTimeseries + func (x *StageSummary) GetStageId() string + func (x *StageSummary) GetStartTime() *timestamppb.Timestamp + func (x *StageSummary) GetState() ExecutionState + func (x *StageSummary) ProtoReflect() protoreflect.Message + func (x *StageSummary) Reset() + func (x *StageSummary) String() string + type StateFamilyConfig struct + IsRead bool + StateFamily string + func (*StateFamilyConfig) Descriptor() ([]byte, []int) + func (*StateFamilyConfig) ProtoMessage() + func (x *StateFamilyConfig) GetIsRead() bool + func (x *StateFamilyConfig) GetStateFamily() string + func (x *StateFamilyConfig) ProtoReflect() protoreflect.Message + func (x *StateFamilyConfig) Reset() + func (x *StateFamilyConfig) String() string + type Step struct + Kind string + Name string + Properties *structpb.Struct + func (*Step) Descriptor() ([]byte, []int) + func (*Step) ProtoMessage() + func (x *Step) GetKind() string + func (x *Step) GetName() string + func (x *Step) GetProperties() *structpb.Struct + func (x *Step) ProtoReflect() protoreflect.Message + func (x *Step) Reset() + func (x *Step) String() string + type StreamLocation struct + Location isStreamLocation_Location + func (*StreamLocation) Descriptor() ([]byte, []int) + func (*StreamLocation) ProtoMessage() + func (m *StreamLocation) GetLocation() isStreamLocation_Location + func (x *StreamLocation) GetCustomSourceLocation() *CustomSourceLocation + func (x *StreamLocation) GetPubsubLocation() *PubsubLocation + func (x *StreamLocation) GetSideInputLocation() *StreamingSideInputLocation + func (x *StreamLocation) GetStreamingStageLocation() *StreamingStageLocation + func (x *StreamLocation) ProtoReflect() protoreflect.Message + func (x *StreamLocation) Reset() + func (x *StreamLocation) String() string + type StreamLocation_CustomSourceLocation struct + CustomSourceLocation *CustomSourceLocation + type StreamLocation_PubsubLocation struct + PubsubLocation *PubsubLocation + type StreamLocation_SideInputLocation struct + SideInputLocation *StreamingSideInputLocation + type StreamLocation_StreamingStageLocation struct + StreamingStageLocation *StreamingStageLocation + type StreamingApplianceSnapshotConfig struct + ImportStateEndpoint string + SnapshotId string + func (*StreamingApplianceSnapshotConfig) Descriptor() ([]byte, []int) + func (*StreamingApplianceSnapshotConfig) ProtoMessage() + func (x *StreamingApplianceSnapshotConfig) GetImportStateEndpoint() string + func (x *StreamingApplianceSnapshotConfig) GetSnapshotId() string + func (x *StreamingApplianceSnapshotConfig) ProtoReflect() protoreflect.Message + func (x *StreamingApplianceSnapshotConfig) Reset() + func (x *StreamingApplianceSnapshotConfig) String() string + type StreamingComputationRanges struct + ComputationId string + RangeAssignments []*KeyRangeDataDiskAssignment + func (*StreamingComputationRanges) Descriptor() ([]byte, []int) + func (*StreamingComputationRanges) ProtoMessage() + func (x *StreamingComputationRanges) GetComputationId() string + func (x *StreamingComputationRanges) GetRangeAssignments() []*KeyRangeDataDiskAssignment + func (x *StreamingComputationRanges) ProtoReflect() protoreflect.Message + func (x *StreamingComputationRanges) Reset() + func (x *StreamingComputationRanges) String() string + type StreamingSideInputLocation struct + StateFamily string + Tag string + func (*StreamingSideInputLocation) Descriptor() ([]byte, []int) + func (*StreamingSideInputLocation) ProtoMessage() + func (x *StreamingSideInputLocation) GetStateFamily() string + func (x *StreamingSideInputLocation) GetTag() string + func (x *StreamingSideInputLocation) ProtoReflect() protoreflect.Message + func (x *StreamingSideInputLocation) Reset() + func (x *StreamingSideInputLocation) String() string + type StreamingStageLocation struct + StreamId string + func (*StreamingStageLocation) Descriptor() ([]byte, []int) + func (*StreamingStageLocation) ProtoMessage() + func (x *StreamingStageLocation) GetStreamId() string + func (x *StreamingStageLocation) ProtoReflect() protoreflect.Message + func (x *StreamingStageLocation) Reset() + func (x *StreamingStageLocation) String() string + type StructuredMessage struct + MessageKey string + MessageText string + Parameters []*StructuredMessage_Parameter + func (*StructuredMessage) Descriptor() ([]byte, []int) + func (*StructuredMessage) ProtoMessage() + func (x *StructuredMessage) GetMessageKey() string + func (x *StructuredMessage) GetMessageText() string + func (x *StructuredMessage) GetParameters() []*StructuredMessage_Parameter + func (x *StructuredMessage) ProtoReflect() protoreflect.Message + func (x *StructuredMessage) Reset() + func (x *StructuredMessage) String() string + type StructuredMessage_Parameter struct + Key string + Value *structpb.Value + func (*StructuredMessage_Parameter) Descriptor() ([]byte, []int) + func (*StructuredMessage_Parameter) ProtoMessage() + func (x *StructuredMessage_Parameter) GetKey() string + func (x *StructuredMessage_Parameter) GetValue() *structpb.Value + func (x *StructuredMessage_Parameter) ProtoReflect() protoreflect.Message + func (x *StructuredMessage_Parameter) Reset() + func (x *StructuredMessage_Parameter) String() string + type TaskRunnerSettings struct + Alsologtostderr bool + BaseTaskDir string + BaseUrl string + CommandlinesFileName string + ContinueOnException bool + DataflowApiVersion string + HarnessCommand string + LanguageHint string + LogDir string + LogToSerialconsole bool + LogUploadLocation string + OauthScopes []string + ParallelWorkerSettings *WorkerSettings + StreamingWorkerMainClass string + TaskGroup string + TaskUser string + TempStoragePrefix string + VmId string + WorkflowFileName string + func (*TaskRunnerSettings) Descriptor() ([]byte, []int) + func (*TaskRunnerSettings) ProtoMessage() + func (x *TaskRunnerSettings) GetAlsologtostderr() bool + func (x *TaskRunnerSettings) GetBaseTaskDir() string + func (x *TaskRunnerSettings) GetBaseUrl() string + func (x *TaskRunnerSettings) GetCommandlinesFileName() string + func (x *TaskRunnerSettings) GetContinueOnException() bool + func (x *TaskRunnerSettings) GetDataflowApiVersion() string + func (x *TaskRunnerSettings) GetHarnessCommand() string + func (x *TaskRunnerSettings) GetLanguageHint() string + func (x *TaskRunnerSettings) GetLogDir() string + func (x *TaskRunnerSettings) GetLogToSerialconsole() bool + func (x *TaskRunnerSettings) GetLogUploadLocation() string + func (x *TaskRunnerSettings) GetOauthScopes() []string + func (x *TaskRunnerSettings) GetParallelWorkerSettings() *WorkerSettings + func (x *TaskRunnerSettings) GetStreamingWorkerMainClass() string + func (x *TaskRunnerSettings) GetTaskGroup() string + func (x *TaskRunnerSettings) GetTaskUser() string + func (x *TaskRunnerSettings) GetTempStoragePrefix() string + func (x *TaskRunnerSettings) GetVmId() string + func (x *TaskRunnerSettings) GetWorkflowFileName() string + func (x *TaskRunnerSettings) ProtoReflect() protoreflect.Message + func (x *TaskRunnerSettings) Reset() + func (x *TaskRunnerSettings) String() string + type TeardownPolicy int32 + const TeardownPolicy_TEARDOWN_ALWAYS + const TeardownPolicy_TEARDOWN_NEVER + const TeardownPolicy_TEARDOWN_ON_SUCCESS + const TeardownPolicy_TEARDOWN_POLICY_UNKNOWN + func (TeardownPolicy) Descriptor() protoreflect.EnumDescriptor + func (TeardownPolicy) EnumDescriptor() ([]byte, []int) + func (TeardownPolicy) Type() protoreflect.EnumType + func (x TeardownPolicy) Enum() *TeardownPolicy + func (x TeardownPolicy) Number() protoreflect.EnumNumber + func (x TeardownPolicy) String() string + type TemplateMetadata struct + Description string + Name string + Parameters []*ParameterMetadata + func (*TemplateMetadata) Descriptor() ([]byte, []int) + func (*TemplateMetadata) ProtoMessage() + func (x *TemplateMetadata) GetDescription() string + func (x *TemplateMetadata) GetName() string + func (x *TemplateMetadata) GetParameters() []*ParameterMetadata + func (x *TemplateMetadata) ProtoReflect() protoreflect.Message + func (x *TemplateMetadata) Reset() + func (x *TemplateMetadata) String() string + type TemplatesServiceClient interface + CreateJobFromTemplate func(ctx context.Context, in *CreateJobFromTemplateRequest, opts ...grpc.CallOption) (*Job, error) + GetTemplate func(ctx context.Context, in *GetTemplateRequest, opts ...grpc.CallOption) (*GetTemplateResponse, error) + LaunchTemplate func(ctx context.Context, in *LaunchTemplateRequest, opts ...grpc.CallOption) (*LaunchTemplateResponse, error) + func NewTemplatesServiceClient(cc grpc.ClientConnInterface) TemplatesServiceClient + type TemplatesServiceServer interface + CreateJobFromTemplate func(context.Context, *CreateJobFromTemplateRequest) (*Job, error) + GetTemplate func(context.Context, *GetTemplateRequest) (*GetTemplateResponse, error) + LaunchTemplate func(context.Context, *LaunchTemplateRequest) (*LaunchTemplateResponse, error) + type TopologyConfig struct + Computations []*ComputationTopology + DataDiskAssignments []*DataDiskAssignment + ForwardingKeyBits int32 + PersistentStateVersion int32 + UserStageToComputationNameMap map[string]string + func (*TopologyConfig) Descriptor() ([]byte, []int) + func (*TopologyConfig) ProtoMessage() + func (x *TopologyConfig) GetComputations() []*ComputationTopology + func (x *TopologyConfig) GetDataDiskAssignments() []*DataDiskAssignment + func (x *TopologyConfig) GetForwardingKeyBits() int32 + func (x *TopologyConfig) GetPersistentStateVersion() int32 + func (x *TopologyConfig) GetUserStageToComputationNameMap() map[string]string + func (x *TopologyConfig) ProtoReflect() protoreflect.Message + func (x *TopologyConfig) Reset() + func (x *TopologyConfig) String() string + type TransformSummary struct + DisplayData []*DisplayData + Id string + InputCollectionName []string + Kind KindType + Name string + OutputCollectionName []string + func (*TransformSummary) Descriptor() ([]byte, []int) + func (*TransformSummary) ProtoMessage() + func (x *TransformSummary) GetDisplayData() []*DisplayData + func (x *TransformSummary) GetId() string + func (x *TransformSummary) GetInputCollectionName() []string + func (x *TransformSummary) GetKind() KindType + func (x *TransformSummary) GetName() string + func (x *TransformSummary) GetOutputCollectionName() []string + func (x *TransformSummary) ProtoReflect() protoreflect.Message + func (x *TransformSummary) Reset() + func (x *TransformSummary) String() string + type UnimplementedFlexTemplatesServiceServer struct + func (*UnimplementedFlexTemplatesServiceServer) LaunchFlexTemplate(context.Context, *LaunchFlexTemplateRequest) (*LaunchFlexTemplateResponse, error) + type UnimplementedJobsV1Beta3Server struct + func (*UnimplementedJobsV1Beta3Server) AggregatedListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) + func (*UnimplementedJobsV1Beta3Server) CheckActiveJobs(context.Context, *CheckActiveJobsRequest) (*CheckActiveJobsResponse, error) + func (*UnimplementedJobsV1Beta3Server) CreateJob(context.Context, *CreateJobRequest) (*Job, error) + func (*UnimplementedJobsV1Beta3Server) GetJob(context.Context, *GetJobRequest) (*Job, error) + func (*UnimplementedJobsV1Beta3Server) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) + func (*UnimplementedJobsV1Beta3Server) SnapshotJob(context.Context, *SnapshotJobRequest) (*Snapshot, error) + func (*UnimplementedJobsV1Beta3Server) UpdateJob(context.Context, *UpdateJobRequest) (*Job, error) + type UnimplementedMessagesV1Beta3Server struct + func (*UnimplementedMessagesV1Beta3Server) ListJobMessages(context.Context, *ListJobMessagesRequest) (*ListJobMessagesResponse, error) + type UnimplementedMetricsV1Beta3Server struct + func (*UnimplementedMetricsV1Beta3Server) GetJobExecutionDetails(context.Context, *GetJobExecutionDetailsRequest) (*JobExecutionDetails, error) + func (*UnimplementedMetricsV1Beta3Server) GetJobMetrics(context.Context, *GetJobMetricsRequest) (*JobMetrics, error) + func (*UnimplementedMetricsV1Beta3Server) GetStageExecutionDetails(context.Context, *GetStageExecutionDetailsRequest) (*StageExecutionDetails, error) + type UnimplementedSnapshotsV1Beta3Server struct + func (*UnimplementedSnapshotsV1Beta3Server) DeleteSnapshot(context.Context, *DeleteSnapshotRequest) (*DeleteSnapshotResponse, error) + func (*UnimplementedSnapshotsV1Beta3Server) GetSnapshot(context.Context, *GetSnapshotRequest) (*Snapshot, error) + func (*UnimplementedSnapshotsV1Beta3Server) ListSnapshots(context.Context, *ListSnapshotsRequest) (*ListSnapshotsResponse, error) + type UnimplementedTemplatesServiceServer struct + func (*UnimplementedTemplatesServiceServer) CreateJobFromTemplate(context.Context, *CreateJobFromTemplateRequest) (*Job, error) + func (*UnimplementedTemplatesServiceServer) GetTemplate(context.Context, *GetTemplateRequest) (*GetTemplateResponse, error) + func (*UnimplementedTemplatesServiceServer) LaunchTemplate(context.Context, *LaunchTemplateRequest) (*LaunchTemplateResponse, error) + type UpdateJobRequest struct + Job *Job + JobId string + Location string + ProjectId string + func (*UpdateJobRequest) Descriptor() ([]byte, []int) + func (*UpdateJobRequest) ProtoMessage() + func (x *UpdateJobRequest) GetJob() *Job + func (x *UpdateJobRequest) GetJobId() string + func (x *UpdateJobRequest) GetLocation() string + func (x *UpdateJobRequest) GetProjectId() string + func (x *UpdateJobRequest) ProtoReflect() protoreflect.Message + func (x *UpdateJobRequest) Reset() + func (x *UpdateJobRequest) String() string + type WorkItemDetails struct + AttemptId string + EndTime *timestamppb.Timestamp + Metrics []*MetricUpdate + Progress *ProgressTimeseries + StartTime *timestamppb.Timestamp + State ExecutionState + TaskId string + func (*WorkItemDetails) Descriptor() ([]byte, []int) + func (*WorkItemDetails) ProtoMessage() + func (x *WorkItemDetails) GetAttemptId() string + func (x *WorkItemDetails) GetEndTime() *timestamppb.Timestamp + func (x *WorkItemDetails) GetMetrics() []*MetricUpdate + func (x *WorkItemDetails) GetProgress() *ProgressTimeseries + func (x *WorkItemDetails) GetStartTime() *timestamppb.Timestamp + func (x *WorkItemDetails) GetState() ExecutionState + func (x *WorkItemDetails) GetTaskId() string + func (x *WorkItemDetails) ProtoReflect() protoreflect.Message + func (x *WorkItemDetails) Reset() + func (x *WorkItemDetails) String() string + type WorkerDetails struct + WorkItems []*WorkItemDetails + WorkerName string + func (*WorkerDetails) Descriptor() ([]byte, []int) + func (*WorkerDetails) ProtoMessage() + func (x *WorkerDetails) GetWorkItems() []*WorkItemDetails + func (x *WorkerDetails) GetWorkerName() string + func (x *WorkerDetails) ProtoReflect() protoreflect.Message + func (x *WorkerDetails) Reset() + func (x *WorkerDetails) String() string + type WorkerIPAddressConfiguration int32 + const WorkerIPAddressConfiguration_WORKER_IP_PRIVATE + const WorkerIPAddressConfiguration_WORKER_IP_PUBLIC + const WorkerIPAddressConfiguration_WORKER_IP_UNSPECIFIED + func (WorkerIPAddressConfiguration) Descriptor() protoreflect.EnumDescriptor + func (WorkerIPAddressConfiguration) EnumDescriptor() ([]byte, []int) + func (WorkerIPAddressConfiguration) Type() protoreflect.EnumType + func (x WorkerIPAddressConfiguration) Enum() *WorkerIPAddressConfiguration + func (x WorkerIPAddressConfiguration) Number() protoreflect.EnumNumber + func (x WorkerIPAddressConfiguration) String() string + type WorkerPool struct + AutoscalingSettings *AutoscalingSettings + DataDisks []*Disk + DefaultPackageSet DefaultPackageSet + DiskSizeGb int32 + DiskSourceImage string + DiskType string + IpConfiguration WorkerIPAddressConfiguration + Kind string + MachineType string + Metadata map[string]string + Network string + NumThreadsPerWorker int32 + NumWorkers int32 + OnHostMaintenance string + Packages []*Package + PoolArgs *anypb.Any + SdkHarnessContainerImages []*SdkHarnessContainerImage + Subnetwork string + TaskrunnerSettings *TaskRunnerSettings + TeardownPolicy TeardownPolicy + WorkerHarnessContainerImage string + Zone string + func (*WorkerPool) Descriptor() ([]byte, []int) + func (*WorkerPool) ProtoMessage() + func (x *WorkerPool) GetAutoscalingSettings() *AutoscalingSettings + func (x *WorkerPool) GetDataDisks() []*Disk + func (x *WorkerPool) GetDefaultPackageSet() DefaultPackageSet + func (x *WorkerPool) GetDiskSizeGb() int32 + func (x *WorkerPool) GetDiskSourceImage() string + func (x *WorkerPool) GetDiskType() string + func (x *WorkerPool) GetIpConfiguration() WorkerIPAddressConfiguration + func (x *WorkerPool) GetKind() string + func (x *WorkerPool) GetMachineType() string + func (x *WorkerPool) GetMetadata() map[string]string + func (x *WorkerPool) GetNetwork() string + func (x *WorkerPool) GetNumThreadsPerWorker() int32 + func (x *WorkerPool) GetNumWorkers() int32 + func (x *WorkerPool) GetOnHostMaintenance() string + func (x *WorkerPool) GetPackages() []*Package + func (x *WorkerPool) GetPoolArgs() *anypb.Any + func (x *WorkerPool) GetSdkHarnessContainerImages() []*SdkHarnessContainerImage + func (x *WorkerPool) GetSubnetwork() string + func (x *WorkerPool) GetTaskrunnerSettings() *TaskRunnerSettings + func (x *WorkerPool) GetTeardownPolicy() TeardownPolicy + func (x *WorkerPool) GetWorkerHarnessContainerImage() string + func (x *WorkerPool) GetZone() string + func (x *WorkerPool) ProtoReflect() protoreflect.Message + func (x *WorkerPool) Reset() + func (x *WorkerPool) String() string + type WorkerSettings struct + BaseUrl string + ReportingEnabled bool + ServicePath string + ShuffleServicePath string + TempStoragePrefix string + WorkerId string + func (*WorkerSettings) Descriptor() ([]byte, []int) + func (*WorkerSettings) ProtoMessage() + func (x *WorkerSettings) GetBaseUrl() string + func (x *WorkerSettings) GetReportingEnabled() bool + func (x *WorkerSettings) GetServicePath() string + func (x *WorkerSettings) GetShuffleServicePath() string + func (x *WorkerSettings) GetTempStoragePrefix() string + func (x *WorkerSettings) GetWorkerId() string + func (x *WorkerSettings) ProtoReflect() protoreflect.Message + func (x *WorkerSettings) Reset() + func (x *WorkerSettings) String() string