Versions in this module Expand all Collapse all v1 v1.12.0 Jan 26, 2023 Changes in this version type InstanceGroupConfig_Preemptibility + const InstanceGroupConfig_SPOT v1.9.0 Jan 5, 2023 Changes in this version + var File_google_cloud_dataproc_v1_node_groups_proto protoreflect.FileDescriptor + var NodeGroupOperationMetadata_NodeGroupOperationType_name = map[int32]string + var NodeGroupOperationMetadata_NodeGroupOperationType_value = map[string]int32 + var NodeGroup_Role_name = map[int32]string + var NodeGroup_Role_value = map[string]int32 + func RegisterNodeGroupControllerServer(s *grpc.Server, srv NodeGroupControllerServer) + type AuxiliaryNodeGroup struct + NodeGroup *NodeGroup + NodeGroupId string + func (*AuxiliaryNodeGroup) Descriptor() ([]byte, []int) + func (*AuxiliaryNodeGroup) ProtoMessage() + func (x *AuxiliaryNodeGroup) GetNodeGroup() *NodeGroup + func (x *AuxiliaryNodeGroup) GetNodeGroupId() string + func (x *AuxiliaryNodeGroup) ProtoReflect() protoreflect.Message + func (x *AuxiliaryNodeGroup) Reset() + func (x *AuxiliaryNodeGroup) String() string type ClusterConfig + AuxiliaryNodeGroups []*AuxiliaryNodeGroup + func (x *ClusterConfig) GetAuxiliaryNodeGroups() []*AuxiliaryNodeGroup + type CreateNodeGroupRequest struct + NodeGroup *NodeGroup + NodeGroupId string + Parent string + RequestId string + func (*CreateNodeGroupRequest) Descriptor() ([]byte, []int) + func (*CreateNodeGroupRequest) ProtoMessage() + func (x *CreateNodeGroupRequest) GetNodeGroup() *NodeGroup + func (x *CreateNodeGroupRequest) GetNodeGroupId() string + func (x *CreateNodeGroupRequest) GetParent() string + func (x *CreateNodeGroupRequest) GetRequestId() string + func (x *CreateNodeGroupRequest) ProtoReflect() protoreflect.Message + func (x *CreateNodeGroupRequest) Reset() + func (x *CreateNodeGroupRequest) String() string + type DriverSchedulingConfig struct + MemoryMb int32 + Vcores int32 + func (*DriverSchedulingConfig) Descriptor() ([]byte, []int) + func (*DriverSchedulingConfig) ProtoMessage() + func (x *DriverSchedulingConfig) GetMemoryMb() int32 + func (x *DriverSchedulingConfig) GetVcores() int32 + func (x *DriverSchedulingConfig) ProtoReflect() protoreflect.Message + func (x *DriverSchedulingConfig) Reset() + func (x *DriverSchedulingConfig) String() string + type GetNodeGroupRequest struct + Name string + func (*GetNodeGroupRequest) Descriptor() ([]byte, []int) + func (*GetNodeGroupRequest) ProtoMessage() + func (x *GetNodeGroupRequest) GetName() string + func (x *GetNodeGroupRequest) ProtoReflect() protoreflect.Message + func (x *GetNodeGroupRequest) Reset() + func (x *GetNodeGroupRequest) String() string type Job + DriverSchedulingConfig *DriverSchedulingConfig + func (x *Job) GetDriverSchedulingConfig() *DriverSchedulingConfig + type NodeGroup struct + Labels map[string]string + Name string + NodeGroupConfig *InstanceGroupConfig + Roles []NodeGroup_Role + func (*NodeGroup) Descriptor() ([]byte, []int) + func (*NodeGroup) ProtoMessage() + func (x *NodeGroup) GetLabels() map[string]string + func (x *NodeGroup) GetName() string + func (x *NodeGroup) GetNodeGroupConfig() *InstanceGroupConfig + func (x *NodeGroup) GetRoles() []NodeGroup_Role + func (x *NodeGroup) ProtoReflect() protoreflect.Message + func (x *NodeGroup) Reset() + func (x *NodeGroup) String() string + type NodeGroupControllerClient interface + CreateNodeGroup func(ctx context.Context, in *CreateNodeGroupRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) + GetNodeGroup func(ctx context.Context, in *GetNodeGroupRequest, opts ...grpc.CallOption) (*NodeGroup, error) + ResizeNodeGroup func(ctx context.Context, in *ResizeNodeGroupRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) + func NewNodeGroupControllerClient(cc grpc.ClientConnInterface) NodeGroupControllerClient + type NodeGroupControllerServer interface + CreateNodeGroup func(context.Context, *CreateNodeGroupRequest) (*longrunning.Operation, error) + GetNodeGroup func(context.Context, *GetNodeGroupRequest) (*NodeGroup, error) + ResizeNodeGroup func(context.Context, *ResizeNodeGroupRequest) (*longrunning.Operation, error) + type NodeGroupOperationMetadata struct + ClusterUuid string + Description string + Labels map[string]string + NodeGroupId string + OperationType NodeGroupOperationMetadata_NodeGroupOperationType + Status *ClusterOperationStatus + StatusHistory []*ClusterOperationStatus + Warnings []string + func (*NodeGroupOperationMetadata) Descriptor() ([]byte, []int) + func (*NodeGroupOperationMetadata) ProtoMessage() + func (x *NodeGroupOperationMetadata) GetClusterUuid() string + func (x *NodeGroupOperationMetadata) GetDescription() string + func (x *NodeGroupOperationMetadata) GetLabels() map[string]string + func (x *NodeGroupOperationMetadata) GetNodeGroupId() string + func (x *NodeGroupOperationMetadata) GetOperationType() NodeGroupOperationMetadata_NodeGroupOperationType + func (x *NodeGroupOperationMetadata) GetStatus() *ClusterOperationStatus + func (x *NodeGroupOperationMetadata) GetStatusHistory() []*ClusterOperationStatus + func (x *NodeGroupOperationMetadata) GetWarnings() []string + func (x *NodeGroupOperationMetadata) ProtoReflect() protoreflect.Message + func (x *NodeGroupOperationMetadata) Reset() + func (x *NodeGroupOperationMetadata) String() string + type NodeGroupOperationMetadata_NodeGroupOperationType int32 + const NodeGroupOperationMetadata_CREATE + const NodeGroupOperationMetadata_DELETE + const NodeGroupOperationMetadata_NODE_GROUP_OPERATION_TYPE_UNSPECIFIED + const NodeGroupOperationMetadata_RESIZE + const NodeGroupOperationMetadata_UPDATE + func (NodeGroupOperationMetadata_NodeGroupOperationType) Descriptor() protoreflect.EnumDescriptor + func (NodeGroupOperationMetadata_NodeGroupOperationType) EnumDescriptor() ([]byte, []int) + func (NodeGroupOperationMetadata_NodeGroupOperationType) Type() protoreflect.EnumType + func (x NodeGroupOperationMetadata_NodeGroupOperationType) Enum() *NodeGroupOperationMetadata_NodeGroupOperationType + func (x NodeGroupOperationMetadata_NodeGroupOperationType) Number() protoreflect.EnumNumber + func (x NodeGroupOperationMetadata_NodeGroupOperationType) String() string + type NodeGroup_Role int32 + const NodeGroup_DRIVER + const NodeGroup_ROLE_UNSPECIFIED + func (NodeGroup_Role) Descriptor() protoreflect.EnumDescriptor + func (NodeGroup_Role) EnumDescriptor() ([]byte, []int) + func (NodeGroup_Role) Type() protoreflect.EnumType + func (x NodeGroup_Role) Enum() *NodeGroup_Role + func (x NodeGroup_Role) Number() protoreflect.EnumNumber + func (x NodeGroup_Role) String() string + type ResizeNodeGroupRequest struct + GracefulDecommissionTimeout *durationpb.Duration + Name string + RequestId string + Size int32 + func (*ResizeNodeGroupRequest) Descriptor() ([]byte, []int) + func (*ResizeNodeGroupRequest) ProtoMessage() + func (x *ResizeNodeGroupRequest) GetGracefulDecommissionTimeout() *durationpb.Duration + func (x *ResizeNodeGroupRequest) GetName() string + func (x *ResizeNodeGroupRequest) GetRequestId() string + func (x *ResizeNodeGroupRequest) GetSize() int32 + func (x *ResizeNodeGroupRequest) ProtoReflect() protoreflect.Message + func (x *ResizeNodeGroupRequest) Reset() + func (x *ResizeNodeGroupRequest) String() string + type UnimplementedNodeGroupControllerServer struct + func (*UnimplementedNodeGroupControllerServer) CreateNodeGroup(context.Context, *CreateNodeGroupRequest) (*longrunning.Operation, error) + func (*UnimplementedNodeGroupControllerServer) GetNodeGroup(context.Context, *GetNodeGroupRequest) (*NodeGroup, error) + func (*UnimplementedNodeGroupControllerServer) ResizeNodeGroup(context.Context, *ResizeNodeGroupRequest) (*longrunning.Operation, error) v1.8.0 Nov 3, 2022 v1.7.0 Oct 25, 2022 Changes in this version + var BatchOperationMetadata_BatchOperationType_name = map[int32]string + var BatchOperationMetadata_BatchOperationType_value = map[string]int32 + var Batch_State_name = map[int32]string + var Batch_State_value = map[string]int32 + var ClusterOperationStatus_State_name = map[int32]string + var ClusterOperationStatus_State_value = map[string]int32 + var ClusterStatus_State_name = map[int32]string + var ClusterStatus_State_value = map[string]int32 + var ClusterStatus_Substate_name = map[int32]string + var ClusterStatus_Substate_value = map[string]int32 + var Component_name = map[int32]string + var Component_value = map[string]int32 + var DataprocMetricConfig_MetricSource_name = map[int32]string + var DataprocMetricConfig_MetricSource_value = map[string]int32 + var FailureAction_name = map[int32]string + var FailureAction_value = map[string]int32 + var File_google_cloud_dataproc_v1_autoscaling_policies_proto protoreflect.FileDescriptor + var File_google_cloud_dataproc_v1_batches_proto protoreflect.FileDescriptor + var File_google_cloud_dataproc_v1_clusters_proto protoreflect.FileDescriptor + var File_google_cloud_dataproc_v1_jobs_proto protoreflect.FileDescriptor + var File_google_cloud_dataproc_v1_operations_proto protoreflect.FileDescriptor + var File_google_cloud_dataproc_v1_shared_proto protoreflect.FileDescriptor + var File_google_cloud_dataproc_v1_workflow_templates_proto protoreflect.FileDescriptor + var GceClusterConfig_PrivateIpv6GoogleAccess_name = map[int32]string + var GceClusterConfig_PrivateIpv6GoogleAccess_value = map[string]int32 + var GkeNodePoolTarget_Role_name = map[int32]string + var GkeNodePoolTarget_Role_value = map[string]int32 + var InstanceGroupConfig_Preemptibility_name = map[int32]string + var InstanceGroupConfig_Preemptibility_value = map[string]int32 + var JobStatus_State_name = map[int32]string + var JobStatus_State_value = map[string]int32 + var JobStatus_Substate_name = map[int32]string + var JobStatus_Substate_value = map[string]int32 + var ListJobsRequest_JobStateMatcher_name = map[int32]string + var ListJobsRequest_JobStateMatcher_value = map[string]int32 + var LoggingConfig_Level_name = map[int32]string + var LoggingConfig_Level_value = map[string]int32 + var ReservationAffinity_Type_name = map[int32]string + var ReservationAffinity_Type_value = map[string]int32 + var WorkflowMetadata_State_name = map[int32]string + var WorkflowMetadata_State_value = map[string]int32 + var WorkflowNode_NodeState_name = map[int32]string + var WorkflowNode_NodeState_value = map[string]int32 + var YarnApplication_State_name = map[int32]string + var YarnApplication_State_value = map[string]int32 + func RegisterAutoscalingPolicyServiceServer(s *grpc.Server, srv AutoscalingPolicyServiceServer) + func RegisterBatchControllerServer(s *grpc.Server, srv BatchControllerServer) + func RegisterClusterControllerServer(s *grpc.Server, srv ClusterControllerServer) + func RegisterJobControllerServer(s *grpc.Server, srv JobControllerServer) + func RegisterWorkflowTemplateServiceServer(s *grpc.Server, srv WorkflowTemplateServiceServer) + type AcceleratorConfig struct + AcceleratorCount int32 + AcceleratorTypeUri string + func (*AcceleratorConfig) Descriptor() ([]byte, []int) + func (*AcceleratorConfig) ProtoMessage() + func (x *AcceleratorConfig) GetAcceleratorCount() int32 + func (x *AcceleratorConfig) GetAcceleratorTypeUri() string + func (x *AcceleratorConfig) ProtoReflect() protoreflect.Message + func (x *AcceleratorConfig) Reset() + func (x *AcceleratorConfig) String() string + type AutoscalingConfig struct + PolicyUri string + func (*AutoscalingConfig) Descriptor() ([]byte, []int) + func (*AutoscalingConfig) ProtoMessage() + func (x *AutoscalingConfig) GetPolicyUri() string + func (x *AutoscalingConfig) ProtoReflect() protoreflect.Message + func (x *AutoscalingConfig) Reset() + func (x *AutoscalingConfig) String() string + type AutoscalingPolicy struct + Algorithm isAutoscalingPolicy_Algorithm + Id string + Labels map[string]string + Name string + SecondaryWorkerConfig *InstanceGroupAutoscalingPolicyConfig + WorkerConfig *InstanceGroupAutoscalingPolicyConfig + func (*AutoscalingPolicy) Descriptor() ([]byte, []int) + func (*AutoscalingPolicy) ProtoMessage() + func (m *AutoscalingPolicy) GetAlgorithm() isAutoscalingPolicy_Algorithm + func (x *AutoscalingPolicy) GetBasicAlgorithm() *BasicAutoscalingAlgorithm + func (x *AutoscalingPolicy) GetId() string + func (x *AutoscalingPolicy) GetLabels() map[string]string + func (x *AutoscalingPolicy) GetName() string + func (x *AutoscalingPolicy) GetSecondaryWorkerConfig() *InstanceGroupAutoscalingPolicyConfig + func (x *AutoscalingPolicy) GetWorkerConfig() *InstanceGroupAutoscalingPolicyConfig + func (x *AutoscalingPolicy) ProtoReflect() protoreflect.Message + func (x *AutoscalingPolicy) Reset() + func (x *AutoscalingPolicy) String() string + type AutoscalingPolicyServiceClient interface + CreateAutoscalingPolicy func(ctx context.Context, in *CreateAutoscalingPolicyRequest, ...) (*AutoscalingPolicy, error) + DeleteAutoscalingPolicy func(ctx context.Context, in *DeleteAutoscalingPolicyRequest, ...) (*empty.Empty, error) + GetAutoscalingPolicy func(ctx context.Context, in *GetAutoscalingPolicyRequest, opts ...grpc.CallOption) (*AutoscalingPolicy, error) + ListAutoscalingPolicies func(ctx context.Context, in *ListAutoscalingPoliciesRequest, ...) (*ListAutoscalingPoliciesResponse, error) + UpdateAutoscalingPolicy func(ctx context.Context, in *UpdateAutoscalingPolicyRequest, ...) (*AutoscalingPolicy, error) + func NewAutoscalingPolicyServiceClient(cc grpc.ClientConnInterface) AutoscalingPolicyServiceClient + type AutoscalingPolicyServiceServer interface + CreateAutoscalingPolicy func(context.Context, *CreateAutoscalingPolicyRequest) (*AutoscalingPolicy, error) + DeleteAutoscalingPolicy func(context.Context, *DeleteAutoscalingPolicyRequest) (*empty.Empty, error) + GetAutoscalingPolicy func(context.Context, *GetAutoscalingPolicyRequest) (*AutoscalingPolicy, error) + ListAutoscalingPolicies func(context.Context, *ListAutoscalingPoliciesRequest) (*ListAutoscalingPoliciesResponse, error) + UpdateAutoscalingPolicy func(context.Context, *UpdateAutoscalingPolicyRequest) (*AutoscalingPolicy, error) + type AutoscalingPolicy_BasicAlgorithm struct + BasicAlgorithm *BasicAutoscalingAlgorithm + type AuxiliaryServicesConfig struct + MetastoreConfig *MetastoreConfig + SparkHistoryServerConfig *SparkHistoryServerConfig + func (*AuxiliaryServicesConfig) Descriptor() ([]byte, []int) + func (*AuxiliaryServicesConfig) ProtoMessage() + func (x *AuxiliaryServicesConfig) GetMetastoreConfig() *MetastoreConfig + func (x *AuxiliaryServicesConfig) GetSparkHistoryServerConfig() *SparkHistoryServerConfig + func (x *AuxiliaryServicesConfig) ProtoReflect() protoreflect.Message + func (x *AuxiliaryServicesConfig) Reset() + func (x *AuxiliaryServicesConfig) String() string + type BasicAutoscalingAlgorithm struct + Config isBasicAutoscalingAlgorithm_Config + CooldownPeriod *duration.Duration + func (*BasicAutoscalingAlgorithm) Descriptor() ([]byte, []int) + func (*BasicAutoscalingAlgorithm) ProtoMessage() + func (m *BasicAutoscalingAlgorithm) GetConfig() isBasicAutoscalingAlgorithm_Config + func (x *BasicAutoscalingAlgorithm) GetCooldownPeriod() *duration.Duration + func (x *BasicAutoscalingAlgorithm) GetYarnConfig() *BasicYarnAutoscalingConfig + func (x *BasicAutoscalingAlgorithm) ProtoReflect() protoreflect.Message + func (x *BasicAutoscalingAlgorithm) Reset() + func (x *BasicAutoscalingAlgorithm) String() string + type BasicAutoscalingAlgorithm_YarnConfig struct + YarnConfig *BasicYarnAutoscalingConfig + type BasicYarnAutoscalingConfig struct + GracefulDecommissionTimeout *duration.Duration + ScaleDownFactor float64 + ScaleDownMinWorkerFraction float64 + ScaleUpFactor float64 + ScaleUpMinWorkerFraction float64 + func (*BasicYarnAutoscalingConfig) Descriptor() ([]byte, []int) + func (*BasicYarnAutoscalingConfig) ProtoMessage() + func (x *BasicYarnAutoscalingConfig) GetGracefulDecommissionTimeout() *duration.Duration + func (x *BasicYarnAutoscalingConfig) GetScaleDownFactor() float64 + func (x *BasicYarnAutoscalingConfig) GetScaleDownMinWorkerFraction() float64 + func (x *BasicYarnAutoscalingConfig) GetScaleUpFactor() float64 + func (x *BasicYarnAutoscalingConfig) GetScaleUpMinWorkerFraction() float64 + func (x *BasicYarnAutoscalingConfig) ProtoReflect() protoreflect.Message + func (x *BasicYarnAutoscalingConfig) Reset() + func (x *BasicYarnAutoscalingConfig) String() string + type Batch struct + BatchConfig isBatch_BatchConfig + CreateTime *timestamp.Timestamp + Creator string + EnvironmentConfig *EnvironmentConfig + Labels map[string]string + Name string + Operation string + RuntimeConfig *RuntimeConfig + RuntimeInfo *RuntimeInfo + State Batch_State + StateHistory []*Batch_StateHistory + StateMessage string + StateTime *timestamp.Timestamp + Uuid string + func (*Batch) Descriptor() ([]byte, []int) + func (*Batch) ProtoMessage() + func (m *Batch) GetBatchConfig() isBatch_BatchConfig + func (x *Batch) GetCreateTime() *timestamp.Timestamp + func (x *Batch) GetCreator() string + func (x *Batch) GetEnvironmentConfig() *EnvironmentConfig + func (x *Batch) GetLabels() map[string]string + func (x *Batch) GetName() string + func (x *Batch) GetOperation() string + func (x *Batch) GetPysparkBatch() *PySparkBatch + func (x *Batch) GetRuntimeConfig() *RuntimeConfig + func (x *Batch) GetRuntimeInfo() *RuntimeInfo + func (x *Batch) GetSparkBatch() *SparkBatch + func (x *Batch) GetSparkRBatch() *SparkRBatch + func (x *Batch) GetSparkSqlBatch() *SparkSqlBatch + func (x *Batch) GetState() Batch_State + func (x *Batch) GetStateHistory() []*Batch_StateHistory + func (x *Batch) GetStateMessage() string + func (x *Batch) GetStateTime() *timestamp.Timestamp + func (x *Batch) GetUuid() string + func (x *Batch) ProtoReflect() protoreflect.Message + func (x *Batch) Reset() + func (x *Batch) String() string + type BatchControllerClient interface + CreateBatch func(ctx context.Context, in *CreateBatchRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) + DeleteBatch func(ctx context.Context, in *DeleteBatchRequest, opts ...grpc.CallOption) (*empty.Empty, error) + GetBatch func(ctx context.Context, in *GetBatchRequest, opts ...grpc.CallOption) (*Batch, error) + ListBatches func(ctx context.Context, in *ListBatchesRequest, opts ...grpc.CallOption) (*ListBatchesResponse, error) + func NewBatchControllerClient(cc grpc.ClientConnInterface) BatchControllerClient + type BatchControllerServer interface + CreateBatch func(context.Context, *CreateBatchRequest) (*longrunning.Operation, error) + DeleteBatch func(context.Context, *DeleteBatchRequest) (*empty.Empty, error) + GetBatch func(context.Context, *GetBatchRequest) (*Batch, error) + ListBatches func(context.Context, *ListBatchesRequest) (*ListBatchesResponse, error) + type BatchOperationMetadata struct + Batch string + BatchUuid string + CreateTime *timestamp.Timestamp + Description string + DoneTime *timestamp.Timestamp + Labels map[string]string + OperationType BatchOperationMetadata_BatchOperationType + Warnings []string + func (*BatchOperationMetadata) Descriptor() ([]byte, []int) + func (*BatchOperationMetadata) ProtoMessage() + func (x *BatchOperationMetadata) GetBatch() string + func (x *BatchOperationMetadata) GetBatchUuid() string + func (x *BatchOperationMetadata) GetCreateTime() *timestamp.Timestamp + func (x *BatchOperationMetadata) GetDescription() string + func (x *BatchOperationMetadata) GetDoneTime() *timestamp.Timestamp + func (x *BatchOperationMetadata) GetLabels() map[string]string + func (x *BatchOperationMetadata) GetOperationType() BatchOperationMetadata_BatchOperationType + func (x *BatchOperationMetadata) GetWarnings() []string + func (x *BatchOperationMetadata) ProtoReflect() protoreflect.Message + func (x *BatchOperationMetadata) Reset() + func (x *BatchOperationMetadata) String() string + type BatchOperationMetadata_BatchOperationType int32 + const BatchOperationMetadata_BATCH + const BatchOperationMetadata_BATCH_OPERATION_TYPE_UNSPECIFIED + func (BatchOperationMetadata_BatchOperationType) Descriptor() protoreflect.EnumDescriptor + func (BatchOperationMetadata_BatchOperationType) EnumDescriptor() ([]byte, []int) + func (BatchOperationMetadata_BatchOperationType) Type() protoreflect.EnumType + func (x BatchOperationMetadata_BatchOperationType) Enum() *BatchOperationMetadata_BatchOperationType + func (x BatchOperationMetadata_BatchOperationType) Number() protoreflect.EnumNumber + func (x BatchOperationMetadata_BatchOperationType) String() string + type Batch_PysparkBatch struct + PysparkBatch *PySparkBatch + type Batch_SparkBatch struct + SparkBatch *SparkBatch + type Batch_SparkRBatch struct + SparkRBatch *SparkRBatch + type Batch_SparkSqlBatch struct + SparkSqlBatch *SparkSqlBatch + type Batch_State int32 + const Batch_CANCELLED + const Batch_CANCELLING + const Batch_FAILED + const Batch_PENDING + const Batch_RUNNING + const Batch_STATE_UNSPECIFIED + const Batch_SUCCEEDED + func (Batch_State) Descriptor() protoreflect.EnumDescriptor + func (Batch_State) EnumDescriptor() ([]byte, []int) + func (Batch_State) Type() protoreflect.EnumType + func (x Batch_State) Enum() *Batch_State + func (x Batch_State) Number() protoreflect.EnumNumber + func (x Batch_State) String() string + type Batch_StateHistory struct + State Batch_State + StateMessage string + StateStartTime *timestamp.Timestamp + func (*Batch_StateHistory) Descriptor() ([]byte, []int) + func (*Batch_StateHistory) ProtoMessage() + func (x *Batch_StateHistory) GetState() Batch_State + func (x *Batch_StateHistory) GetStateMessage() string + func (x *Batch_StateHistory) GetStateStartTime() *timestamp.Timestamp + func (x *Batch_StateHistory) ProtoReflect() protoreflect.Message + func (x *Batch_StateHistory) Reset() + func (x *Batch_StateHistory) String() string + type CancelJobRequest struct + JobId string + ProjectId string + Region string + func (*CancelJobRequest) Descriptor() ([]byte, []int) + func (*CancelJobRequest) ProtoMessage() + func (x *CancelJobRequest) GetJobId() string + func (x *CancelJobRequest) GetProjectId() string + func (x *CancelJobRequest) GetRegion() string + func (x *CancelJobRequest) ProtoReflect() protoreflect.Message + func (x *CancelJobRequest) Reset() + func (x *CancelJobRequest) String() string + type Cluster struct + ClusterName string + ClusterUuid string + Config *ClusterConfig + Labels map[string]string + Metrics *ClusterMetrics + ProjectId string + Status *ClusterStatus + StatusHistory []*ClusterStatus + VirtualClusterConfig *VirtualClusterConfig + func (*Cluster) Descriptor() ([]byte, []int) + func (*Cluster) ProtoMessage() + func (x *Cluster) GetClusterName() string + func (x *Cluster) GetClusterUuid() string + func (x *Cluster) GetConfig() *ClusterConfig + func (x *Cluster) GetLabels() map[string]string + func (x *Cluster) GetMetrics() *ClusterMetrics + func (x *Cluster) GetProjectId() string + func (x *Cluster) GetStatus() *ClusterStatus + func (x *Cluster) GetStatusHistory() []*ClusterStatus + func (x *Cluster) GetVirtualClusterConfig() *VirtualClusterConfig + func (x *Cluster) ProtoReflect() protoreflect.Message + func (x *Cluster) Reset() + func (x *Cluster) String() string + type ClusterConfig struct + AutoscalingConfig *AutoscalingConfig + ConfigBucket string + DataprocMetricConfig *DataprocMetricConfig + EncryptionConfig *EncryptionConfig + EndpointConfig *EndpointConfig + GceClusterConfig *GceClusterConfig + InitializationActions []*NodeInitializationAction + LifecycleConfig *LifecycleConfig + MasterConfig *InstanceGroupConfig + MetastoreConfig *MetastoreConfig + SecondaryWorkerConfig *InstanceGroupConfig + SecurityConfig *SecurityConfig + SoftwareConfig *SoftwareConfig + TempBucket string + WorkerConfig *InstanceGroupConfig + func (*ClusterConfig) Descriptor() ([]byte, []int) + func (*ClusterConfig) ProtoMessage() + func (x *ClusterConfig) GetAutoscalingConfig() *AutoscalingConfig + func (x *ClusterConfig) GetConfigBucket() string + func (x *ClusterConfig) GetDataprocMetricConfig() *DataprocMetricConfig + func (x *ClusterConfig) GetEncryptionConfig() *EncryptionConfig + func (x *ClusterConfig) GetEndpointConfig() *EndpointConfig + func (x *ClusterConfig) GetGceClusterConfig() *GceClusterConfig + func (x *ClusterConfig) GetInitializationActions() []*NodeInitializationAction + func (x *ClusterConfig) GetLifecycleConfig() *LifecycleConfig + func (x *ClusterConfig) GetMasterConfig() *InstanceGroupConfig + func (x *ClusterConfig) GetMetastoreConfig() *MetastoreConfig + func (x *ClusterConfig) GetSecondaryWorkerConfig() *InstanceGroupConfig + func (x *ClusterConfig) GetSecurityConfig() *SecurityConfig + func (x *ClusterConfig) GetSoftwareConfig() *SoftwareConfig + func (x *ClusterConfig) GetTempBucket() string + func (x *ClusterConfig) GetWorkerConfig() *InstanceGroupConfig + func (x *ClusterConfig) ProtoReflect() protoreflect.Message + func (x *ClusterConfig) Reset() + func (x *ClusterConfig) String() string + type ClusterControllerClient interface + CreateCluster func(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) + DeleteCluster func(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) + DiagnoseCluster func(ctx context.Context, in *DiagnoseClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) + GetCluster func(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error) + ListClusters func(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error) + StartCluster func(ctx context.Context, in *StartClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) + StopCluster func(ctx context.Context, in *StopClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) + UpdateCluster func(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) + func NewClusterControllerClient(cc grpc.ClientConnInterface) ClusterControllerClient + type ClusterControllerServer interface + CreateCluster func(context.Context, *CreateClusterRequest) (*longrunning.Operation, error) + DeleteCluster func(context.Context, *DeleteClusterRequest) (*longrunning.Operation, error) + DiagnoseCluster func(context.Context, *DiagnoseClusterRequest) (*longrunning.Operation, error) + GetCluster func(context.Context, *GetClusterRequest) (*Cluster, error) + ListClusters func(context.Context, *ListClustersRequest) (*ListClustersResponse, error) + StartCluster func(context.Context, *StartClusterRequest) (*longrunning.Operation, error) + StopCluster func(context.Context, *StopClusterRequest) (*longrunning.Operation, error) + UpdateCluster func(context.Context, *UpdateClusterRequest) (*longrunning.Operation, error) + type ClusterMetrics struct + HdfsMetrics map[string]int64 + YarnMetrics map[string]int64 + func (*ClusterMetrics) Descriptor() ([]byte, []int) + func (*ClusterMetrics) ProtoMessage() + func (x *ClusterMetrics) GetHdfsMetrics() map[string]int64 + func (x *ClusterMetrics) GetYarnMetrics() map[string]int64 + func (x *ClusterMetrics) ProtoReflect() protoreflect.Message + func (x *ClusterMetrics) Reset() + func (x *ClusterMetrics) String() string + type ClusterOperation struct + Done bool + Error string + OperationId string + func (*ClusterOperation) Descriptor() ([]byte, []int) + func (*ClusterOperation) ProtoMessage() + func (x *ClusterOperation) GetDone() bool + func (x *ClusterOperation) GetError() string + func (x *ClusterOperation) GetOperationId() string + func (x *ClusterOperation) ProtoReflect() protoreflect.Message + func (x *ClusterOperation) Reset() + func (x *ClusterOperation) String() string + type ClusterOperationMetadata struct + ClusterName string + ClusterUuid string + Description string + Labels map[string]string + OperationType string + Status *ClusterOperationStatus + StatusHistory []*ClusterOperationStatus + Warnings []string + func (*ClusterOperationMetadata) Descriptor() ([]byte, []int) + func (*ClusterOperationMetadata) ProtoMessage() + func (x *ClusterOperationMetadata) GetClusterName() string + func (x *ClusterOperationMetadata) GetClusterUuid() string + func (x *ClusterOperationMetadata) GetDescription() string + func (x *ClusterOperationMetadata) GetLabels() map[string]string + func (x *ClusterOperationMetadata) GetOperationType() string + func (x *ClusterOperationMetadata) GetStatus() *ClusterOperationStatus + func (x *ClusterOperationMetadata) GetStatusHistory() []*ClusterOperationStatus + func (x *ClusterOperationMetadata) GetWarnings() []string + func (x *ClusterOperationMetadata) ProtoReflect() protoreflect.Message + func (x *ClusterOperationMetadata) Reset() + func (x *ClusterOperationMetadata) String() string + type ClusterOperationStatus struct + Details string + InnerState string + State ClusterOperationStatus_State + StateStartTime *timestamp.Timestamp + func (*ClusterOperationStatus) Descriptor() ([]byte, []int) + func (*ClusterOperationStatus) ProtoMessage() + func (x *ClusterOperationStatus) GetDetails() string + func (x *ClusterOperationStatus) GetInnerState() string + func (x *ClusterOperationStatus) GetState() ClusterOperationStatus_State + func (x *ClusterOperationStatus) GetStateStartTime() *timestamp.Timestamp + func (x *ClusterOperationStatus) ProtoReflect() protoreflect.Message + func (x *ClusterOperationStatus) Reset() + func (x *ClusterOperationStatus) String() string + type ClusterOperationStatus_State int32 + const ClusterOperationStatus_DONE + const ClusterOperationStatus_PENDING + const ClusterOperationStatus_RUNNING + const ClusterOperationStatus_UNKNOWN + func (ClusterOperationStatus_State) Descriptor() protoreflect.EnumDescriptor + func (ClusterOperationStatus_State) EnumDescriptor() ([]byte, []int) + func (ClusterOperationStatus_State) Type() protoreflect.EnumType + func (x ClusterOperationStatus_State) Enum() *ClusterOperationStatus_State + func (x ClusterOperationStatus_State) Number() protoreflect.EnumNumber + func (x ClusterOperationStatus_State) String() string + type ClusterSelector struct + ClusterLabels map[string]string + Zone string + func (*ClusterSelector) Descriptor() ([]byte, []int) + func (*ClusterSelector) ProtoMessage() + func (x *ClusterSelector) GetClusterLabels() map[string]string + func (x *ClusterSelector) GetZone() string + func (x *ClusterSelector) ProtoReflect() protoreflect.Message + func (x *ClusterSelector) Reset() + func (x *ClusterSelector) String() string + type ClusterStatus struct + Detail string + State ClusterStatus_State + StateStartTime *timestamp.Timestamp + Substate ClusterStatus_Substate + func (*ClusterStatus) Descriptor() ([]byte, []int) + func (*ClusterStatus) ProtoMessage() + func (x *ClusterStatus) GetDetail() string + func (x *ClusterStatus) GetState() ClusterStatus_State + func (x *ClusterStatus) GetStateStartTime() *timestamp.Timestamp + func (x *ClusterStatus) GetSubstate() ClusterStatus_Substate + func (x *ClusterStatus) ProtoReflect() protoreflect.Message + func (x *ClusterStatus) Reset() + func (x *ClusterStatus) String() string + type ClusterStatus_State int32 + const ClusterStatus_CREATING + const ClusterStatus_DELETING + const ClusterStatus_ERROR + const ClusterStatus_ERROR_DUE_TO_UPDATE + const ClusterStatus_RUNNING + const ClusterStatus_STARTING + const ClusterStatus_STOPPED + const ClusterStatus_STOPPING + const ClusterStatus_UNKNOWN + const ClusterStatus_UPDATING + func (ClusterStatus_State) Descriptor() protoreflect.EnumDescriptor + func (ClusterStatus_State) EnumDescriptor() ([]byte, []int) + func (ClusterStatus_State) Type() protoreflect.EnumType + func (x ClusterStatus_State) Enum() *ClusterStatus_State + func (x ClusterStatus_State) Number() protoreflect.EnumNumber + func (x ClusterStatus_State) String() string + type ClusterStatus_Substate int32 + const ClusterStatus_STALE_STATUS + const ClusterStatus_UNHEALTHY + const ClusterStatus_UNSPECIFIED + func (ClusterStatus_Substate) Descriptor() protoreflect.EnumDescriptor + func (ClusterStatus_Substate) EnumDescriptor() ([]byte, []int) + func (ClusterStatus_Substate) Type() protoreflect.EnumType + func (x ClusterStatus_Substate) Enum() *ClusterStatus_Substate + func (x ClusterStatus_Substate) Number() protoreflect.EnumNumber + func (x ClusterStatus_Substate) String() string + type Component int32 + const Component_ANACONDA + const Component_COMPONENT_UNSPECIFIED + const Component_DOCKER + const Component_DRUID + const Component_FLINK + const Component_HBASE + const Component_HIVE_WEBHCAT + const Component_JUPYTER + const Component_PRESTO + const Component_RANGER + const Component_SOLR + const Component_ZEPPELIN + const Component_ZOOKEEPER + func (Component) Descriptor() protoreflect.EnumDescriptor + func (Component) EnumDescriptor() ([]byte, []int) + func (Component) Type() protoreflect.EnumType + func (x Component) Enum() *Component + func (x Component) Number() protoreflect.EnumNumber + func (x Component) String() string + type ConfidentialInstanceConfig struct + EnableConfidentialCompute bool + func (*ConfidentialInstanceConfig) Descriptor() ([]byte, []int) + func (*ConfidentialInstanceConfig) ProtoMessage() + func (x *ConfidentialInstanceConfig) GetEnableConfidentialCompute() bool + func (x *ConfidentialInstanceConfig) ProtoReflect() protoreflect.Message + func (x *ConfidentialInstanceConfig) Reset() + func (x *ConfidentialInstanceConfig) String() string + type CreateAutoscalingPolicyRequest struct + Parent string + Policy *AutoscalingPolicy + func (*CreateAutoscalingPolicyRequest) Descriptor() ([]byte, []int) + func (*CreateAutoscalingPolicyRequest) ProtoMessage() + func (x *CreateAutoscalingPolicyRequest) GetParent() string + func (x *CreateAutoscalingPolicyRequest) GetPolicy() *AutoscalingPolicy + func (x *CreateAutoscalingPolicyRequest) ProtoReflect() protoreflect.Message + func (x *CreateAutoscalingPolicyRequest) Reset() + func (x *CreateAutoscalingPolicyRequest) String() string + type CreateBatchRequest struct + Batch *Batch + BatchId string + Parent string + RequestId string + func (*CreateBatchRequest) Descriptor() ([]byte, []int) + func (*CreateBatchRequest) ProtoMessage() + func (x *CreateBatchRequest) GetBatch() *Batch + func (x *CreateBatchRequest) GetBatchId() string + func (x *CreateBatchRequest) GetParent() string + func (x *CreateBatchRequest) GetRequestId() string + func (x *CreateBatchRequest) ProtoReflect() protoreflect.Message + func (x *CreateBatchRequest) Reset() + func (x *CreateBatchRequest) String() string + type CreateClusterRequest struct + ActionOnFailedPrimaryWorkers FailureAction + Cluster *Cluster + ProjectId string + Region string + RequestId string + func (*CreateClusterRequest) Descriptor() ([]byte, []int) + func (*CreateClusterRequest) ProtoMessage() + func (x *CreateClusterRequest) GetActionOnFailedPrimaryWorkers() FailureAction + func (x *CreateClusterRequest) GetCluster() *Cluster + func (x *CreateClusterRequest) GetProjectId() string + func (x *CreateClusterRequest) GetRegion() string + func (x *CreateClusterRequest) GetRequestId() string + func (x *CreateClusterRequest) ProtoReflect() protoreflect.Message + func (x *CreateClusterRequest) Reset() + func (x *CreateClusterRequest) String() string + type CreateWorkflowTemplateRequest struct + Parent string + Template *WorkflowTemplate + func (*CreateWorkflowTemplateRequest) Descriptor() ([]byte, []int) + func (*CreateWorkflowTemplateRequest) ProtoMessage() + func (x *CreateWorkflowTemplateRequest) GetParent() string + func (x *CreateWorkflowTemplateRequest) GetTemplate() *WorkflowTemplate + func (x *CreateWorkflowTemplateRequest) ProtoReflect() protoreflect.Message + func (x *CreateWorkflowTemplateRequest) Reset() + func (x *CreateWorkflowTemplateRequest) String() string + type DataprocMetricConfig struct + Metrics []*DataprocMetricConfig_Metric + func (*DataprocMetricConfig) Descriptor() ([]byte, []int) + func (*DataprocMetricConfig) ProtoMessage() + func (x *DataprocMetricConfig) GetMetrics() []*DataprocMetricConfig_Metric + func (x *DataprocMetricConfig) ProtoReflect() protoreflect.Message + func (x *DataprocMetricConfig) Reset() + func (x *DataprocMetricConfig) String() string + type DataprocMetricConfig_Metric struct + MetricOverrides []string + MetricSource DataprocMetricConfig_MetricSource + func (*DataprocMetricConfig_Metric) Descriptor() ([]byte, []int) + func (*DataprocMetricConfig_Metric) ProtoMessage() + func (x *DataprocMetricConfig_Metric) GetMetricOverrides() []string + func (x *DataprocMetricConfig_Metric) GetMetricSource() DataprocMetricConfig_MetricSource + func (x *DataprocMetricConfig_Metric) ProtoReflect() protoreflect.Message + func (x *DataprocMetricConfig_Metric) Reset() + func (x *DataprocMetricConfig_Metric) String() string + type DataprocMetricConfig_MetricSource int32 + const DataprocMetricConfig_HDFS + const DataprocMetricConfig_HIVESERVER2 + const DataprocMetricConfig_METRIC_SOURCE_UNSPECIFIED + const DataprocMetricConfig_MONITORING_AGENT_DEFAULTS + const DataprocMetricConfig_SPARK + const DataprocMetricConfig_SPARK_HISTORY_SERVER + const DataprocMetricConfig_YARN + func (DataprocMetricConfig_MetricSource) Descriptor() protoreflect.EnumDescriptor + func (DataprocMetricConfig_MetricSource) EnumDescriptor() ([]byte, []int) + func (DataprocMetricConfig_MetricSource) Type() protoreflect.EnumType + func (x DataprocMetricConfig_MetricSource) Enum() *DataprocMetricConfig_MetricSource + func (x DataprocMetricConfig_MetricSource) Number() protoreflect.EnumNumber + func (x DataprocMetricConfig_MetricSource) String() string + type DeleteAutoscalingPolicyRequest struct + Name string + func (*DeleteAutoscalingPolicyRequest) Descriptor() ([]byte, []int) + func (*DeleteAutoscalingPolicyRequest) ProtoMessage() + func (x *DeleteAutoscalingPolicyRequest) GetName() string + func (x *DeleteAutoscalingPolicyRequest) ProtoReflect() protoreflect.Message + func (x *DeleteAutoscalingPolicyRequest) Reset() + func (x *DeleteAutoscalingPolicyRequest) String() string + type DeleteBatchRequest struct + Name string + func (*DeleteBatchRequest) Descriptor() ([]byte, []int) + func (*DeleteBatchRequest) ProtoMessage() + func (x *DeleteBatchRequest) GetName() string + func (x *DeleteBatchRequest) ProtoReflect() protoreflect.Message + func (x *DeleteBatchRequest) Reset() + func (x *DeleteBatchRequest) String() string + type DeleteClusterRequest struct + ClusterName string + ClusterUuid string + ProjectId string + Region string + RequestId string + func (*DeleteClusterRequest) Descriptor() ([]byte, []int) + func (*DeleteClusterRequest) ProtoMessage() + func (x *DeleteClusterRequest) GetClusterName() string + func (x *DeleteClusterRequest) GetClusterUuid() string + func (x *DeleteClusterRequest) GetProjectId() string + func (x *DeleteClusterRequest) GetRegion() string + func (x *DeleteClusterRequest) GetRequestId() string + func (x *DeleteClusterRequest) ProtoReflect() protoreflect.Message + func (x *DeleteClusterRequest) Reset() + func (x *DeleteClusterRequest) String() string + type DeleteJobRequest struct + JobId string + ProjectId string + Region string + func (*DeleteJobRequest) Descriptor() ([]byte, []int) + func (*DeleteJobRequest) ProtoMessage() + func (x *DeleteJobRequest) GetJobId() string + func (x *DeleteJobRequest) GetProjectId() string + func (x *DeleteJobRequest) GetRegion() string + func (x *DeleteJobRequest) ProtoReflect() protoreflect.Message + func (x *DeleteJobRequest) Reset() + func (x *DeleteJobRequest) String() string + type DeleteWorkflowTemplateRequest struct + Name string + Version int32 + func (*DeleteWorkflowTemplateRequest) Descriptor() ([]byte, []int) + func (*DeleteWorkflowTemplateRequest) ProtoMessage() + func (x *DeleteWorkflowTemplateRequest) GetName() string + func (x *DeleteWorkflowTemplateRequest) GetVersion() int32 + func (x *DeleteWorkflowTemplateRequest) ProtoReflect() protoreflect.Message + func (x *DeleteWorkflowTemplateRequest) Reset() + func (x *DeleteWorkflowTemplateRequest) String() string + type DiagnoseClusterRequest struct + ClusterName string + ProjectId string + Region string + func (*DiagnoseClusterRequest) Descriptor() ([]byte, []int) + func (*DiagnoseClusterRequest) ProtoMessage() + func (x *DiagnoseClusterRequest) GetClusterName() string + func (x *DiagnoseClusterRequest) GetProjectId() string + func (x *DiagnoseClusterRequest) GetRegion() string + func (x *DiagnoseClusterRequest) ProtoReflect() protoreflect.Message + func (x *DiagnoseClusterRequest) Reset() + func (x *DiagnoseClusterRequest) String() string + type DiagnoseClusterResults struct + OutputUri string + func (*DiagnoseClusterResults) Descriptor() ([]byte, []int) + func (*DiagnoseClusterResults) ProtoMessage() + func (x *DiagnoseClusterResults) GetOutputUri() string + func (x *DiagnoseClusterResults) ProtoReflect() protoreflect.Message + func (x *DiagnoseClusterResults) Reset() + func (x *DiagnoseClusterResults) String() string + type DiskConfig struct + BootDiskSizeGb int32 + BootDiskType string + LocalSsdInterface string + NumLocalSsds int32 + func (*DiskConfig) Descriptor() ([]byte, []int) + func (*DiskConfig) ProtoMessage() + func (x *DiskConfig) GetBootDiskSizeGb() int32 + func (x *DiskConfig) GetBootDiskType() string + func (x *DiskConfig) GetLocalSsdInterface() string + func (x *DiskConfig) GetNumLocalSsds() int32 + func (x *DiskConfig) ProtoReflect() protoreflect.Message + func (x *DiskConfig) Reset() + func (x *DiskConfig) String() string + type EncryptionConfig struct + GcePdKmsKeyName string + func (*EncryptionConfig) Descriptor() ([]byte, []int) + func (*EncryptionConfig) ProtoMessage() + func (x *EncryptionConfig) GetGcePdKmsKeyName() string + func (x *EncryptionConfig) ProtoReflect() protoreflect.Message + func (x *EncryptionConfig) Reset() + func (x *EncryptionConfig) String() string + type EndpointConfig struct + EnableHttpPortAccess bool + HttpPorts map[string]string + func (*EndpointConfig) Descriptor() ([]byte, []int) + func (*EndpointConfig) ProtoMessage() + func (x *EndpointConfig) GetEnableHttpPortAccess() bool + func (x *EndpointConfig) GetHttpPorts() map[string]string + func (x *EndpointConfig) ProtoReflect() protoreflect.Message + func (x *EndpointConfig) Reset() + func (x *EndpointConfig) String() string + type EnvironmentConfig struct + ExecutionConfig *ExecutionConfig + PeripheralsConfig *PeripheralsConfig + func (*EnvironmentConfig) Descriptor() ([]byte, []int) + func (*EnvironmentConfig) ProtoMessage() + func (x *EnvironmentConfig) GetExecutionConfig() *ExecutionConfig + func (x *EnvironmentConfig) GetPeripheralsConfig() *PeripheralsConfig + func (x *EnvironmentConfig) ProtoReflect() protoreflect.Message + func (x *EnvironmentConfig) Reset() + func (x *EnvironmentConfig) String() string + type ExecutionConfig struct + KmsKey string + Network isExecutionConfig_Network + NetworkTags []string + ServiceAccount string + func (*ExecutionConfig) Descriptor() ([]byte, []int) + func (*ExecutionConfig) ProtoMessage() + func (m *ExecutionConfig) GetNetwork() isExecutionConfig_Network + func (x *ExecutionConfig) GetKmsKey() string + func (x *ExecutionConfig) GetNetworkTags() []string + func (x *ExecutionConfig) GetNetworkUri() string + func (x *ExecutionConfig) GetServiceAccount() string + func (x *ExecutionConfig) GetSubnetworkUri() string + func (x *ExecutionConfig) ProtoReflect() protoreflect.Message + func (x *ExecutionConfig) Reset() + func (x *ExecutionConfig) String() string + type ExecutionConfig_NetworkUri struct + NetworkUri string + type ExecutionConfig_SubnetworkUri struct + SubnetworkUri string + type FailureAction int32 + const FailureAction_DELETE + const FailureAction_FAILURE_ACTION_UNSPECIFIED + const FailureAction_NO_ACTION + func (FailureAction) Descriptor() protoreflect.EnumDescriptor + func (FailureAction) EnumDescriptor() ([]byte, []int) + func (FailureAction) Type() protoreflect.EnumType + func (x FailureAction) Enum() *FailureAction + func (x FailureAction) Number() protoreflect.EnumNumber + func (x FailureAction) String() string + type GceClusterConfig struct + ConfidentialInstanceConfig *ConfidentialInstanceConfig + InternalIpOnly bool + Metadata map[string]string + NetworkUri string + NodeGroupAffinity *NodeGroupAffinity + PrivateIpv6GoogleAccess GceClusterConfig_PrivateIpv6GoogleAccess + ReservationAffinity *ReservationAffinity + ServiceAccount string + ServiceAccountScopes []string + ShieldedInstanceConfig *ShieldedInstanceConfig + SubnetworkUri string + Tags []string + ZoneUri string + func (*GceClusterConfig) Descriptor() ([]byte, []int) + func (*GceClusterConfig) ProtoMessage() + func (x *GceClusterConfig) GetConfidentialInstanceConfig() *ConfidentialInstanceConfig + func (x *GceClusterConfig) GetInternalIpOnly() bool + func (x *GceClusterConfig) GetMetadata() map[string]string + func (x *GceClusterConfig) GetNetworkUri() string + func (x *GceClusterConfig) GetNodeGroupAffinity() *NodeGroupAffinity + func (x *GceClusterConfig) GetPrivateIpv6GoogleAccess() GceClusterConfig_PrivateIpv6GoogleAccess + func (x *GceClusterConfig) GetReservationAffinity() *ReservationAffinity + func (x *GceClusterConfig) GetServiceAccount() string + func (x *GceClusterConfig) GetServiceAccountScopes() []string + func (x *GceClusterConfig) GetShieldedInstanceConfig() *ShieldedInstanceConfig + func (x *GceClusterConfig) GetSubnetworkUri() string + func (x *GceClusterConfig) GetTags() []string + func (x *GceClusterConfig) GetZoneUri() string + func (x *GceClusterConfig) ProtoReflect() protoreflect.Message + func (x *GceClusterConfig) Reset() + func (x *GceClusterConfig) String() string + type GceClusterConfig_PrivateIpv6GoogleAccess int32 + const GceClusterConfig_BIDIRECTIONAL + const GceClusterConfig_INHERIT_FROM_SUBNETWORK + const GceClusterConfig_OUTBOUND + const GceClusterConfig_PRIVATE_IPV6_GOOGLE_ACCESS_UNSPECIFIED + func (GceClusterConfig_PrivateIpv6GoogleAccess) Descriptor() protoreflect.EnumDescriptor + func (GceClusterConfig_PrivateIpv6GoogleAccess) EnumDescriptor() ([]byte, []int) + func (GceClusterConfig_PrivateIpv6GoogleAccess) Type() protoreflect.EnumType + func (x GceClusterConfig_PrivateIpv6GoogleAccess) Enum() *GceClusterConfig_PrivateIpv6GoogleAccess + func (x GceClusterConfig_PrivateIpv6GoogleAccess) Number() protoreflect.EnumNumber + func (x GceClusterConfig_PrivateIpv6GoogleAccess) String() string + type GetAutoscalingPolicyRequest struct + Name string + func (*GetAutoscalingPolicyRequest) Descriptor() ([]byte, []int) + func (*GetAutoscalingPolicyRequest) ProtoMessage() + func (x *GetAutoscalingPolicyRequest) GetName() string + func (x *GetAutoscalingPolicyRequest) ProtoReflect() protoreflect.Message + func (x *GetAutoscalingPolicyRequest) Reset() + func (x *GetAutoscalingPolicyRequest) String() string + type GetBatchRequest struct + Name string + func (*GetBatchRequest) Descriptor() ([]byte, []int) + func (*GetBatchRequest) ProtoMessage() + func (x *GetBatchRequest) GetName() string + func (x *GetBatchRequest) ProtoReflect() protoreflect.Message + func (x *GetBatchRequest) Reset() + func (x *GetBatchRequest) String() string + type GetClusterRequest struct + ClusterName string + ProjectId string + Region string + func (*GetClusterRequest) Descriptor() ([]byte, []int) + func (*GetClusterRequest) ProtoMessage() + func (x *GetClusterRequest) GetClusterName() string + func (x *GetClusterRequest) GetProjectId() string + func (x *GetClusterRequest) GetRegion() string + func (x *GetClusterRequest) ProtoReflect() protoreflect.Message + func (x *GetClusterRequest) Reset() + func (x *GetClusterRequest) String() string + type GetJobRequest struct + JobId string + ProjectId string + Region string + func (*GetJobRequest) Descriptor() ([]byte, []int) + func (*GetJobRequest) ProtoMessage() + func (x *GetJobRequest) GetJobId() string + func (x *GetJobRequest) GetProjectId() string + func (x *GetJobRequest) GetRegion() string + func (x *GetJobRequest) ProtoReflect() protoreflect.Message + func (x *GetJobRequest) Reset() + func (x *GetJobRequest) String() string + type GetWorkflowTemplateRequest struct + Name string + Version int32 + func (*GetWorkflowTemplateRequest) Descriptor() ([]byte, []int) + func (*GetWorkflowTemplateRequest) ProtoMessage() + func (x *GetWorkflowTemplateRequest) GetName() string + func (x *GetWorkflowTemplateRequest) GetVersion() int32 + func (x *GetWorkflowTemplateRequest) ProtoReflect() protoreflect.Message + func (x *GetWorkflowTemplateRequest) Reset() + func (x *GetWorkflowTemplateRequest) String() string + type GkeClusterConfig struct + GkeClusterTarget string + NodePoolTarget []*GkeNodePoolTarget + func (*GkeClusterConfig) Descriptor() ([]byte, []int) + func (*GkeClusterConfig) ProtoMessage() + func (x *GkeClusterConfig) GetGkeClusterTarget() string + func (x *GkeClusterConfig) GetNodePoolTarget() []*GkeNodePoolTarget + func (x *GkeClusterConfig) ProtoReflect() protoreflect.Message + func (x *GkeClusterConfig) Reset() + func (x *GkeClusterConfig) String() string + type GkeNodePoolConfig struct + Autoscaling *GkeNodePoolConfig_GkeNodePoolAutoscalingConfig + Config *GkeNodePoolConfig_GkeNodeConfig + Locations []string + func (*GkeNodePoolConfig) Descriptor() ([]byte, []int) + func (*GkeNodePoolConfig) ProtoMessage() + func (x *GkeNodePoolConfig) GetAutoscaling() *GkeNodePoolConfig_GkeNodePoolAutoscalingConfig + func (x *GkeNodePoolConfig) GetConfig() *GkeNodePoolConfig_GkeNodeConfig + func (x *GkeNodePoolConfig) GetLocations() []string + func (x *GkeNodePoolConfig) ProtoReflect() protoreflect.Message + func (x *GkeNodePoolConfig) Reset() + func (x *GkeNodePoolConfig) String() string + type GkeNodePoolConfig_GkeNodeConfig struct + Accelerators []*GkeNodePoolConfig_GkeNodePoolAcceleratorConfig + LocalSsdCount int32 + MachineType string + MinCpuPlatform string + Preemptible bool + func (*GkeNodePoolConfig_GkeNodeConfig) Descriptor() ([]byte, []int) + func (*GkeNodePoolConfig_GkeNodeConfig) ProtoMessage() + func (x *GkeNodePoolConfig_GkeNodeConfig) GetAccelerators() []*GkeNodePoolConfig_GkeNodePoolAcceleratorConfig + func (x *GkeNodePoolConfig_GkeNodeConfig) GetLocalSsdCount() int32 + func (x *GkeNodePoolConfig_GkeNodeConfig) GetMachineType() string + func (x *GkeNodePoolConfig_GkeNodeConfig) GetMinCpuPlatform() string + func (x *GkeNodePoolConfig_GkeNodeConfig) GetPreemptible() bool + func (x *GkeNodePoolConfig_GkeNodeConfig) ProtoReflect() protoreflect.Message + func (x *GkeNodePoolConfig_GkeNodeConfig) Reset() + func (x *GkeNodePoolConfig_GkeNodeConfig) String() string + type GkeNodePoolConfig_GkeNodePoolAcceleratorConfig struct + AcceleratorCount int64 + AcceleratorType string + func (*GkeNodePoolConfig_GkeNodePoolAcceleratorConfig) Descriptor() ([]byte, []int) + func (*GkeNodePoolConfig_GkeNodePoolAcceleratorConfig) ProtoMessage() + func (x *GkeNodePoolConfig_GkeNodePoolAcceleratorConfig) GetAcceleratorCount() int64 + func (x *GkeNodePoolConfig_GkeNodePoolAcceleratorConfig) GetAcceleratorType() string + func (x *GkeNodePoolConfig_GkeNodePoolAcceleratorConfig) ProtoReflect() protoreflect.Message + func (x *GkeNodePoolConfig_GkeNodePoolAcceleratorConfig) Reset() + func (x *GkeNodePoolConfig_GkeNodePoolAcceleratorConfig) String() string + type GkeNodePoolConfig_GkeNodePoolAutoscalingConfig struct + MaxNodeCount int32 + MinNodeCount int32 + func (*GkeNodePoolConfig_GkeNodePoolAutoscalingConfig) Descriptor() ([]byte, []int) + func (*GkeNodePoolConfig_GkeNodePoolAutoscalingConfig) ProtoMessage() + func (x *GkeNodePoolConfig_GkeNodePoolAutoscalingConfig) GetMaxNodeCount() int32 + func (x *GkeNodePoolConfig_GkeNodePoolAutoscalingConfig) GetMinNodeCount() int32 + func (x *GkeNodePoolConfig_GkeNodePoolAutoscalingConfig) ProtoReflect() protoreflect.Message + func (x *GkeNodePoolConfig_GkeNodePoolAutoscalingConfig) Reset() + func (x *GkeNodePoolConfig_GkeNodePoolAutoscalingConfig) String() string + type GkeNodePoolTarget struct + NodePool string + NodePoolConfig *GkeNodePoolConfig + Roles []GkeNodePoolTarget_Role + func (*GkeNodePoolTarget) Descriptor() ([]byte, []int) + func (*GkeNodePoolTarget) ProtoMessage() + func (x *GkeNodePoolTarget) GetNodePool() string + func (x *GkeNodePoolTarget) GetNodePoolConfig() *GkeNodePoolConfig + func (x *GkeNodePoolTarget) GetRoles() []GkeNodePoolTarget_Role + func (x *GkeNodePoolTarget) ProtoReflect() protoreflect.Message + func (x *GkeNodePoolTarget) Reset() + func (x *GkeNodePoolTarget) String() string + type GkeNodePoolTarget_Role int32 + const GkeNodePoolTarget_CONTROLLER + const GkeNodePoolTarget_DEFAULT + const GkeNodePoolTarget_ROLE_UNSPECIFIED + const GkeNodePoolTarget_SPARK_DRIVER + const GkeNodePoolTarget_SPARK_EXECUTOR + func (GkeNodePoolTarget_Role) Descriptor() protoreflect.EnumDescriptor + func (GkeNodePoolTarget_Role) EnumDescriptor() ([]byte, []int) + func (GkeNodePoolTarget_Role) Type() protoreflect.EnumType + func (x GkeNodePoolTarget_Role) Enum() *GkeNodePoolTarget_Role + func (x GkeNodePoolTarget_Role) Number() protoreflect.EnumNumber + func (x GkeNodePoolTarget_Role) String() string + type HadoopJob struct + ArchiveUris []string + Args []string + Driver isHadoopJob_Driver + FileUris []string + JarFileUris []string + LoggingConfig *LoggingConfig + Properties map[string]string + func (*HadoopJob) Descriptor() ([]byte, []int) + func (*HadoopJob) ProtoMessage() + func (m *HadoopJob) GetDriver() isHadoopJob_Driver + func (x *HadoopJob) GetArchiveUris() []string + func (x *HadoopJob) GetArgs() []string + func (x *HadoopJob) GetFileUris() []string + func (x *HadoopJob) GetJarFileUris() []string + func (x *HadoopJob) GetLoggingConfig() *LoggingConfig + func (x *HadoopJob) GetMainClass() string + func (x *HadoopJob) GetMainJarFileUri() string + func (x *HadoopJob) GetProperties() map[string]string + func (x *HadoopJob) ProtoReflect() protoreflect.Message + func (x *HadoopJob) Reset() + func (x *HadoopJob) String() string + type HadoopJob_MainClass struct + MainClass string + type HadoopJob_MainJarFileUri struct + MainJarFileUri string + type HiveJob struct + ContinueOnFailure bool + JarFileUris []string + Properties map[string]string + Queries isHiveJob_Queries + ScriptVariables map[string]string + func (*HiveJob) Descriptor() ([]byte, []int) + func (*HiveJob) ProtoMessage() + func (m *HiveJob) GetQueries() isHiveJob_Queries + func (x *HiveJob) GetContinueOnFailure() bool + func (x *HiveJob) GetJarFileUris() []string + func (x *HiveJob) GetProperties() map[string]string + func (x *HiveJob) GetQueryFileUri() string + func (x *HiveJob) GetQueryList() *QueryList + func (x *HiveJob) GetScriptVariables() map[string]string + func (x *HiveJob) ProtoReflect() protoreflect.Message + func (x *HiveJob) Reset() + func (x *HiveJob) String() string + type HiveJob_QueryFileUri struct + QueryFileUri string + type HiveJob_QueryList struct + QueryList *QueryList + type IdentityConfig struct + UserServiceAccountMapping map[string]string + func (*IdentityConfig) Descriptor() ([]byte, []int) + func (*IdentityConfig) ProtoMessage() + func (x *IdentityConfig) GetUserServiceAccountMapping() map[string]string + func (x *IdentityConfig) ProtoReflect() protoreflect.Message + func (x *IdentityConfig) Reset() + func (x *IdentityConfig) String() string + type InstanceGroupAutoscalingPolicyConfig struct + MaxInstances int32 + MinInstances int32 + Weight int32 + func (*InstanceGroupAutoscalingPolicyConfig) Descriptor() ([]byte, []int) + func (*InstanceGroupAutoscalingPolicyConfig) ProtoMessage() + func (x *InstanceGroupAutoscalingPolicyConfig) GetMaxInstances() int32 + func (x *InstanceGroupAutoscalingPolicyConfig) GetMinInstances() int32 + func (x *InstanceGroupAutoscalingPolicyConfig) GetWeight() int32 + func (x *InstanceGroupAutoscalingPolicyConfig) ProtoReflect() protoreflect.Message + func (x *InstanceGroupAutoscalingPolicyConfig) Reset() + func (x *InstanceGroupAutoscalingPolicyConfig) String() string + type InstanceGroupConfig struct + Accelerators []*AcceleratorConfig + DiskConfig *DiskConfig + ImageUri string + InstanceNames []string + IsPreemptible bool + MachineTypeUri string + ManagedGroupConfig *ManagedGroupConfig + MinCpuPlatform string + NumInstances int32 + Preemptibility InstanceGroupConfig_Preemptibility + func (*InstanceGroupConfig) Descriptor() ([]byte, []int) + func (*InstanceGroupConfig) ProtoMessage() + func (x *InstanceGroupConfig) GetAccelerators() []*AcceleratorConfig + func (x *InstanceGroupConfig) GetDiskConfig() *DiskConfig + func (x *InstanceGroupConfig) GetImageUri() string + func (x *InstanceGroupConfig) GetInstanceNames() []string + func (x *InstanceGroupConfig) GetIsPreemptible() bool + func (x *InstanceGroupConfig) GetMachineTypeUri() string + func (x *InstanceGroupConfig) GetManagedGroupConfig() *ManagedGroupConfig + func (x *InstanceGroupConfig) GetMinCpuPlatform() string + func (x *InstanceGroupConfig) GetNumInstances() int32 + func (x *InstanceGroupConfig) GetPreemptibility() InstanceGroupConfig_Preemptibility + func (x *InstanceGroupConfig) ProtoReflect() protoreflect.Message + func (x *InstanceGroupConfig) Reset() + func (x *InstanceGroupConfig) String() string + type InstanceGroupConfig_Preemptibility int32 + const InstanceGroupConfig_NON_PREEMPTIBLE + const InstanceGroupConfig_PREEMPTIBILITY_UNSPECIFIED + const InstanceGroupConfig_PREEMPTIBLE + func (InstanceGroupConfig_Preemptibility) Descriptor() protoreflect.EnumDescriptor + func (InstanceGroupConfig_Preemptibility) EnumDescriptor() ([]byte, []int) + func (InstanceGroupConfig_Preemptibility) Type() protoreflect.EnumType + func (x InstanceGroupConfig_Preemptibility) Enum() *InstanceGroupConfig_Preemptibility + func (x InstanceGroupConfig_Preemptibility) Number() protoreflect.EnumNumber + func (x InstanceGroupConfig_Preemptibility) String() string + type InstantiateInlineWorkflowTemplateRequest struct + Parent string + RequestId string + Template *WorkflowTemplate + func (*InstantiateInlineWorkflowTemplateRequest) Descriptor() ([]byte, []int) + func (*InstantiateInlineWorkflowTemplateRequest) ProtoMessage() + func (x *InstantiateInlineWorkflowTemplateRequest) GetParent() string + func (x *InstantiateInlineWorkflowTemplateRequest) GetRequestId() string + func (x *InstantiateInlineWorkflowTemplateRequest) GetTemplate() *WorkflowTemplate + func (x *InstantiateInlineWorkflowTemplateRequest) ProtoReflect() protoreflect.Message + func (x *InstantiateInlineWorkflowTemplateRequest) Reset() + func (x *InstantiateInlineWorkflowTemplateRequest) String() string + type InstantiateWorkflowTemplateRequest struct + Name string + Parameters map[string]string + RequestId string + Version int32 + func (*InstantiateWorkflowTemplateRequest) Descriptor() ([]byte, []int) + func (*InstantiateWorkflowTemplateRequest) ProtoMessage() + func (x *InstantiateWorkflowTemplateRequest) GetName() string + func (x *InstantiateWorkflowTemplateRequest) GetParameters() map[string]string + func (x *InstantiateWorkflowTemplateRequest) GetRequestId() string + func (x *InstantiateWorkflowTemplateRequest) GetVersion() int32 + func (x *InstantiateWorkflowTemplateRequest) ProtoReflect() protoreflect.Message + func (x *InstantiateWorkflowTemplateRequest) Reset() + func (x *InstantiateWorkflowTemplateRequest) String() string + type Job struct + Done bool + DriverControlFilesUri string + DriverOutputResourceUri string + JobUuid string + Labels map[string]string + Placement *JobPlacement + Reference *JobReference + Scheduling *JobScheduling + Status *JobStatus + StatusHistory []*JobStatus + TypeJob isJob_TypeJob + YarnApplications []*YarnApplication + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (m *Job) GetTypeJob() isJob_TypeJob + func (x *Job) GetDone() bool + func (x *Job) GetDriverControlFilesUri() string + func (x *Job) GetDriverOutputResourceUri() string + func (x *Job) GetHadoopJob() *HadoopJob + func (x *Job) GetHiveJob() *HiveJob + func (x *Job) GetJobUuid() string + func (x *Job) GetLabels() map[string]string + func (x *Job) GetPigJob() *PigJob + func (x *Job) GetPlacement() *JobPlacement + func (x *Job) GetPrestoJob() *PrestoJob + func (x *Job) GetPysparkJob() *PySparkJob + func (x *Job) GetReference() *JobReference + func (x *Job) GetScheduling() *JobScheduling + func (x *Job) GetSparkJob() *SparkJob + func (x *Job) GetSparkRJob() *SparkRJob + func (x *Job) GetSparkSqlJob() *SparkSqlJob + func (x *Job) GetStatus() *JobStatus + func (x *Job) GetStatusHistory() []*JobStatus + func (x *Job) GetYarnApplications() []*YarnApplication + func (x *Job) ProtoReflect() protoreflect.Message + func (x *Job) Reset() + func (x *Job) String() string + type JobControllerClient interface + CancelJob func(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*Job, error) + DeleteJob func(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*empty.Empty, 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) + SubmitJob func(ctx context.Context, in *SubmitJobRequest, opts ...grpc.CallOption) (*Job, error) + SubmitJobAsOperation func(ctx context.Context, in *SubmitJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) + UpdateJob func(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*Job, error) + func NewJobControllerClient(cc grpc.ClientConnInterface) JobControllerClient + type JobControllerServer interface + CancelJob func(context.Context, *CancelJobRequest) (*Job, error) + DeleteJob func(context.Context, *DeleteJobRequest) (*empty.Empty, error) + GetJob func(context.Context, *GetJobRequest) (*Job, error) + ListJobs func(context.Context, *ListJobsRequest) (*ListJobsResponse, error) + SubmitJob func(context.Context, *SubmitJobRequest) (*Job, error) + SubmitJobAsOperation func(context.Context, *SubmitJobRequest) (*longrunning.Operation, error) + UpdateJob func(context.Context, *UpdateJobRequest) (*Job, error) + type JobMetadata struct + JobId string + OperationType string + StartTime *timestamp.Timestamp + Status *JobStatus + func (*JobMetadata) Descriptor() ([]byte, []int) + func (*JobMetadata) ProtoMessage() + func (x *JobMetadata) GetJobId() string + func (x *JobMetadata) GetOperationType() string + func (x *JobMetadata) GetStartTime() *timestamp.Timestamp + func (x *JobMetadata) GetStatus() *JobStatus + func (x *JobMetadata) ProtoReflect() protoreflect.Message + func (x *JobMetadata) Reset() + func (x *JobMetadata) String() string + type JobPlacement struct + ClusterLabels map[string]string + ClusterName string + ClusterUuid string + func (*JobPlacement) Descriptor() ([]byte, []int) + func (*JobPlacement) ProtoMessage() + func (x *JobPlacement) GetClusterLabels() map[string]string + func (x *JobPlacement) GetClusterName() string + func (x *JobPlacement) GetClusterUuid() string + func (x *JobPlacement) ProtoReflect() protoreflect.Message + func (x *JobPlacement) Reset() + func (x *JobPlacement) String() string + type JobReference struct + JobId string + ProjectId string + func (*JobReference) Descriptor() ([]byte, []int) + func (*JobReference) ProtoMessage() + func (x *JobReference) GetJobId() string + func (x *JobReference) GetProjectId() string + func (x *JobReference) ProtoReflect() protoreflect.Message + func (x *JobReference) Reset() + func (x *JobReference) String() string + type JobScheduling struct + MaxFailuresPerHour int32 + MaxFailuresTotal int32 + func (*JobScheduling) Descriptor() ([]byte, []int) + func (*JobScheduling) ProtoMessage() + func (x *JobScheduling) GetMaxFailuresPerHour() int32 + func (x *JobScheduling) GetMaxFailuresTotal() int32 + func (x *JobScheduling) ProtoReflect() protoreflect.Message + func (x *JobScheduling) Reset() + func (x *JobScheduling) String() string + type JobStatus struct + Details string + State JobStatus_State + StateStartTime *timestamp.Timestamp + Substate JobStatus_Substate + func (*JobStatus) Descriptor() ([]byte, []int) + func (*JobStatus) ProtoMessage() + func (x *JobStatus) GetDetails() string + func (x *JobStatus) GetState() JobStatus_State + func (x *JobStatus) GetStateStartTime() *timestamp.Timestamp + func (x *JobStatus) GetSubstate() JobStatus_Substate + func (x *JobStatus) ProtoReflect() protoreflect.Message + func (x *JobStatus) Reset() + func (x *JobStatus) String() string + type JobStatus_State int32 + const JobStatus_ATTEMPT_FAILURE + const JobStatus_CANCELLED + const JobStatus_CANCEL_PENDING + const JobStatus_CANCEL_STARTED + const JobStatus_DONE + const JobStatus_ERROR + const JobStatus_PENDING + const JobStatus_RUNNING + const JobStatus_SETUP_DONE + const JobStatus_STATE_UNSPECIFIED + 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_Substate int32 + const JobStatus_QUEUED + const JobStatus_STALE_STATUS + const JobStatus_SUBMITTED + const JobStatus_UNSPECIFIED + func (JobStatus_Substate) Descriptor() protoreflect.EnumDescriptor + func (JobStatus_Substate) EnumDescriptor() ([]byte, []int) + func (JobStatus_Substate) Type() protoreflect.EnumType + func (x JobStatus_Substate) Enum() *JobStatus_Substate + func (x JobStatus_Substate) Number() protoreflect.EnumNumber + func (x JobStatus_Substate) String() string + type Job_HadoopJob struct + HadoopJob *HadoopJob + type Job_HiveJob struct + HiveJob *HiveJob + type Job_PigJob struct + PigJob *PigJob + type Job_PrestoJob struct + PrestoJob *PrestoJob + type Job_PysparkJob struct + PysparkJob *PySparkJob + type Job_SparkJob struct + SparkJob *SparkJob + type Job_SparkRJob struct + SparkRJob *SparkRJob + type Job_SparkSqlJob struct + SparkSqlJob *SparkSqlJob + type KerberosConfig struct + CrossRealmTrustAdminServer string + CrossRealmTrustKdc string + CrossRealmTrustRealm string + CrossRealmTrustSharedPasswordUri string + EnableKerberos bool + KdcDbKeyUri string + KeyPasswordUri string + KeystorePasswordUri string + KeystoreUri string + KmsKeyUri string + Realm string + RootPrincipalPasswordUri string + TgtLifetimeHours int32 + TruststorePasswordUri string + TruststoreUri string + func (*KerberosConfig) Descriptor() ([]byte, []int) + func (*KerberosConfig) ProtoMessage() + func (x *KerberosConfig) GetCrossRealmTrustAdminServer() string + func (x *KerberosConfig) GetCrossRealmTrustKdc() string + func (x *KerberosConfig) GetCrossRealmTrustRealm() string + func (x *KerberosConfig) GetCrossRealmTrustSharedPasswordUri() string + func (x *KerberosConfig) GetEnableKerberos() bool + func (x *KerberosConfig) GetKdcDbKeyUri() string + func (x *KerberosConfig) GetKeyPasswordUri() string + func (x *KerberosConfig) GetKeystorePasswordUri() string + func (x *KerberosConfig) GetKeystoreUri() string + func (x *KerberosConfig) GetKmsKeyUri() string + func (x *KerberosConfig) GetRealm() string + func (x *KerberosConfig) GetRootPrincipalPasswordUri() string + func (x *KerberosConfig) GetTgtLifetimeHours() int32 + func (x *KerberosConfig) GetTruststorePasswordUri() string + func (x *KerberosConfig) GetTruststoreUri() string + func (x *KerberosConfig) ProtoReflect() protoreflect.Message + func (x *KerberosConfig) Reset() + func (x *KerberosConfig) String() string + type KubernetesClusterConfig struct + Config isKubernetesClusterConfig_Config + KubernetesNamespace string + KubernetesSoftwareConfig *KubernetesSoftwareConfig + func (*KubernetesClusterConfig) Descriptor() ([]byte, []int) + func (*KubernetesClusterConfig) ProtoMessage() + func (m *KubernetesClusterConfig) GetConfig() isKubernetesClusterConfig_Config + func (x *KubernetesClusterConfig) GetGkeClusterConfig() *GkeClusterConfig + func (x *KubernetesClusterConfig) GetKubernetesNamespace() string + func (x *KubernetesClusterConfig) GetKubernetesSoftwareConfig() *KubernetesSoftwareConfig + func (x *KubernetesClusterConfig) ProtoReflect() protoreflect.Message + func (x *KubernetesClusterConfig) Reset() + func (x *KubernetesClusterConfig) String() string + type KubernetesClusterConfig_GkeClusterConfig struct + GkeClusterConfig *GkeClusterConfig + type KubernetesSoftwareConfig struct + ComponentVersion map[string]string + Properties map[string]string + func (*KubernetesSoftwareConfig) Descriptor() ([]byte, []int) + func (*KubernetesSoftwareConfig) ProtoMessage() + func (x *KubernetesSoftwareConfig) GetComponentVersion() map[string]string + func (x *KubernetesSoftwareConfig) GetProperties() map[string]string + func (x *KubernetesSoftwareConfig) ProtoReflect() protoreflect.Message + func (x *KubernetesSoftwareConfig) Reset() + func (x *KubernetesSoftwareConfig) String() string + type LifecycleConfig struct + IdleDeleteTtl *duration.Duration + IdleStartTime *timestamp.Timestamp + Ttl isLifecycleConfig_Ttl + func (*LifecycleConfig) Descriptor() ([]byte, []int) + func (*LifecycleConfig) ProtoMessage() + func (m *LifecycleConfig) GetTtl() isLifecycleConfig_Ttl + func (x *LifecycleConfig) GetAutoDeleteTime() *timestamp.Timestamp + func (x *LifecycleConfig) GetAutoDeleteTtl() *duration.Duration + func (x *LifecycleConfig) GetIdleDeleteTtl() *duration.Duration + func (x *LifecycleConfig) GetIdleStartTime() *timestamp.Timestamp + func (x *LifecycleConfig) ProtoReflect() protoreflect.Message + func (x *LifecycleConfig) Reset() + func (x *LifecycleConfig) String() string + type LifecycleConfig_AutoDeleteTime struct + AutoDeleteTime *timestamp.Timestamp + type LifecycleConfig_AutoDeleteTtl struct + AutoDeleteTtl *duration.Duration + type ListAutoscalingPoliciesRequest struct + PageSize int32 + PageToken string + Parent string + func (*ListAutoscalingPoliciesRequest) Descriptor() ([]byte, []int) + func (*ListAutoscalingPoliciesRequest) ProtoMessage() + func (x *ListAutoscalingPoliciesRequest) GetPageSize() int32 + func (x *ListAutoscalingPoliciesRequest) GetPageToken() string + func (x *ListAutoscalingPoliciesRequest) GetParent() string + func (x *ListAutoscalingPoliciesRequest) ProtoReflect() protoreflect.Message + func (x *ListAutoscalingPoliciesRequest) Reset() + func (x *ListAutoscalingPoliciesRequest) String() string + type ListAutoscalingPoliciesResponse struct + NextPageToken string + Policies []*AutoscalingPolicy + func (*ListAutoscalingPoliciesResponse) Descriptor() ([]byte, []int) + func (*ListAutoscalingPoliciesResponse) ProtoMessage() + func (x *ListAutoscalingPoliciesResponse) GetNextPageToken() string + func (x *ListAutoscalingPoliciesResponse) GetPolicies() []*AutoscalingPolicy + func (x *ListAutoscalingPoliciesResponse) ProtoReflect() protoreflect.Message + func (x *ListAutoscalingPoliciesResponse) Reset() + func (x *ListAutoscalingPoliciesResponse) String() string + type ListBatchesRequest struct + PageSize int32 + PageToken string + Parent string + func (*ListBatchesRequest) Descriptor() ([]byte, []int) + func (*ListBatchesRequest) ProtoMessage() + func (x *ListBatchesRequest) GetPageSize() int32 + func (x *ListBatchesRequest) GetPageToken() string + func (x *ListBatchesRequest) GetParent() string + func (x *ListBatchesRequest) ProtoReflect() protoreflect.Message + func (x *ListBatchesRequest) Reset() + func (x *ListBatchesRequest) String() string + type ListBatchesResponse struct + Batches []*Batch + NextPageToken string + func (*ListBatchesResponse) Descriptor() ([]byte, []int) + func (*ListBatchesResponse) ProtoMessage() + func (x *ListBatchesResponse) GetBatches() []*Batch + func (x *ListBatchesResponse) GetNextPageToken() string + func (x *ListBatchesResponse) ProtoReflect() protoreflect.Message + func (x *ListBatchesResponse) Reset() + func (x *ListBatchesResponse) String() string + type ListClustersRequest struct + Filter string + PageSize int32 + PageToken string + ProjectId string + Region string + func (*ListClustersRequest) Descriptor() ([]byte, []int) + func (*ListClustersRequest) ProtoMessage() + func (x *ListClustersRequest) GetFilter() string + func (x *ListClustersRequest) GetPageSize() int32 + func (x *ListClustersRequest) GetPageToken() string + func (x *ListClustersRequest) GetProjectId() string + func (x *ListClustersRequest) GetRegion() string + func (x *ListClustersRequest) ProtoReflect() protoreflect.Message + func (x *ListClustersRequest) Reset() + func (x *ListClustersRequest) String() string + type ListClustersResponse struct + Clusters []*Cluster + NextPageToken string + func (*ListClustersResponse) Descriptor() ([]byte, []int) + func (*ListClustersResponse) ProtoMessage() + func (x *ListClustersResponse) GetClusters() []*Cluster + func (x *ListClustersResponse) GetNextPageToken() string + func (x *ListClustersResponse) ProtoReflect() protoreflect.Message + func (x *ListClustersResponse) Reset() + func (x *ListClustersResponse) String() string + type ListJobsRequest struct + ClusterName string + Filter string + JobStateMatcher ListJobsRequest_JobStateMatcher + PageSize int32 + PageToken string + ProjectId string + Region string + func (*ListJobsRequest) Descriptor() ([]byte, []int) + func (*ListJobsRequest) ProtoMessage() + func (x *ListJobsRequest) GetClusterName() string + func (x *ListJobsRequest) GetFilter() string + func (x *ListJobsRequest) GetJobStateMatcher() ListJobsRequest_JobStateMatcher + func (x *ListJobsRequest) GetPageSize() int32 + func (x *ListJobsRequest) GetPageToken() string + func (x *ListJobsRequest) GetProjectId() string + func (x *ListJobsRequest) GetRegion() string + func (x *ListJobsRequest) ProtoReflect() protoreflect.Message + func (x *ListJobsRequest) Reset() + func (x *ListJobsRequest) String() string + type ListJobsRequest_JobStateMatcher int32 + const ListJobsRequest_ACTIVE + const ListJobsRequest_ALL + const ListJobsRequest_NON_ACTIVE + func (ListJobsRequest_JobStateMatcher) Descriptor() protoreflect.EnumDescriptor + func (ListJobsRequest_JobStateMatcher) EnumDescriptor() ([]byte, []int) + func (ListJobsRequest_JobStateMatcher) Type() protoreflect.EnumType + func (x ListJobsRequest_JobStateMatcher) Enum() *ListJobsRequest_JobStateMatcher + func (x ListJobsRequest_JobStateMatcher) Number() protoreflect.EnumNumber + func (x ListJobsRequest_JobStateMatcher) String() string + type ListJobsResponse struct + Jobs []*Job + NextPageToken string + func (*ListJobsResponse) Descriptor() ([]byte, []int) + func (*ListJobsResponse) ProtoMessage() + 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 ListWorkflowTemplatesRequest struct + PageSize int32 + PageToken string + Parent string + func (*ListWorkflowTemplatesRequest) Descriptor() ([]byte, []int) + func (*ListWorkflowTemplatesRequest) ProtoMessage() + func (x *ListWorkflowTemplatesRequest) GetPageSize() int32 + func (x *ListWorkflowTemplatesRequest) GetPageToken() string + func (x *ListWorkflowTemplatesRequest) GetParent() string + func (x *ListWorkflowTemplatesRequest) ProtoReflect() protoreflect.Message + func (x *ListWorkflowTemplatesRequest) Reset() + func (x *ListWorkflowTemplatesRequest) String() string + type ListWorkflowTemplatesResponse struct + NextPageToken string + Templates []*WorkflowTemplate + func (*ListWorkflowTemplatesResponse) Descriptor() ([]byte, []int) + func (*ListWorkflowTemplatesResponse) ProtoMessage() + func (x *ListWorkflowTemplatesResponse) GetNextPageToken() string + func (x *ListWorkflowTemplatesResponse) GetTemplates() []*WorkflowTemplate + func (x *ListWorkflowTemplatesResponse) ProtoReflect() protoreflect.Message + func (x *ListWorkflowTemplatesResponse) Reset() + func (x *ListWorkflowTemplatesResponse) String() string + type LoggingConfig struct + DriverLogLevels map[string]LoggingConfig_Level + func (*LoggingConfig) Descriptor() ([]byte, []int) + func (*LoggingConfig) ProtoMessage() + func (x *LoggingConfig) GetDriverLogLevels() map[string]LoggingConfig_Level + func (x *LoggingConfig) ProtoReflect() protoreflect.Message + func (x *LoggingConfig) Reset() + func (x *LoggingConfig) String() string + type LoggingConfig_Level int32 + const LoggingConfig_ALL + const LoggingConfig_DEBUG + const LoggingConfig_ERROR + const LoggingConfig_FATAL + const LoggingConfig_INFO + const LoggingConfig_LEVEL_UNSPECIFIED + const LoggingConfig_OFF + const LoggingConfig_TRACE + const LoggingConfig_WARN + func (LoggingConfig_Level) Descriptor() protoreflect.EnumDescriptor + func (LoggingConfig_Level) EnumDescriptor() ([]byte, []int) + func (LoggingConfig_Level) Type() protoreflect.EnumType + func (x LoggingConfig_Level) Enum() *LoggingConfig_Level + func (x LoggingConfig_Level) Number() protoreflect.EnumNumber + func (x LoggingConfig_Level) String() string + type ManagedCluster struct + ClusterName string + Config *ClusterConfig + Labels map[string]string + func (*ManagedCluster) Descriptor() ([]byte, []int) + func (*ManagedCluster) ProtoMessage() + func (x *ManagedCluster) GetClusterName() string + func (x *ManagedCluster) GetConfig() *ClusterConfig + func (x *ManagedCluster) GetLabels() map[string]string + func (x *ManagedCluster) ProtoReflect() protoreflect.Message + func (x *ManagedCluster) Reset() + func (x *ManagedCluster) String() string + type ManagedGroupConfig struct + InstanceGroupManagerName string + InstanceTemplateName string + func (*ManagedGroupConfig) Descriptor() ([]byte, []int) + func (*ManagedGroupConfig) ProtoMessage() + func (x *ManagedGroupConfig) GetInstanceGroupManagerName() string + func (x *ManagedGroupConfig) GetInstanceTemplateName() string + func (x *ManagedGroupConfig) ProtoReflect() protoreflect.Message + func (x *ManagedGroupConfig) Reset() + func (x *ManagedGroupConfig) String() string + type MetastoreConfig struct + DataprocMetastoreService string + func (*MetastoreConfig) Descriptor() ([]byte, []int) + func (*MetastoreConfig) ProtoMessage() + func (x *MetastoreConfig) GetDataprocMetastoreService() string + func (x *MetastoreConfig) ProtoReflect() protoreflect.Message + func (x *MetastoreConfig) Reset() + func (x *MetastoreConfig) String() string + type NodeGroupAffinity struct + NodeGroupUri string + func (*NodeGroupAffinity) Descriptor() ([]byte, []int) + func (*NodeGroupAffinity) ProtoMessage() + func (x *NodeGroupAffinity) GetNodeGroupUri() string + func (x *NodeGroupAffinity) ProtoReflect() protoreflect.Message + func (x *NodeGroupAffinity) Reset() + func (x *NodeGroupAffinity) String() string + type NodeInitializationAction struct + ExecutableFile string + ExecutionTimeout *duration.Duration + func (*NodeInitializationAction) Descriptor() ([]byte, []int) + func (*NodeInitializationAction) ProtoMessage() + func (x *NodeInitializationAction) GetExecutableFile() string + func (x *NodeInitializationAction) GetExecutionTimeout() *duration.Duration + func (x *NodeInitializationAction) ProtoReflect() protoreflect.Message + func (x *NodeInitializationAction) Reset() + func (x *NodeInitializationAction) String() string + type OrderedJob struct + JobType isOrderedJob_JobType + Labels map[string]string + PrerequisiteStepIds []string + Scheduling *JobScheduling + StepId string + func (*OrderedJob) Descriptor() ([]byte, []int) + func (*OrderedJob) ProtoMessage() + func (m *OrderedJob) GetJobType() isOrderedJob_JobType + func (x *OrderedJob) GetHadoopJob() *HadoopJob + func (x *OrderedJob) GetHiveJob() *HiveJob + func (x *OrderedJob) GetLabels() map[string]string + func (x *OrderedJob) GetPigJob() *PigJob + func (x *OrderedJob) GetPrerequisiteStepIds() []string + func (x *OrderedJob) GetPrestoJob() *PrestoJob + func (x *OrderedJob) GetPysparkJob() *PySparkJob + func (x *OrderedJob) GetScheduling() *JobScheduling + func (x *OrderedJob) GetSparkJob() *SparkJob + func (x *OrderedJob) GetSparkRJob() *SparkRJob + func (x *OrderedJob) GetSparkSqlJob() *SparkSqlJob + func (x *OrderedJob) GetStepId() string + func (x *OrderedJob) ProtoReflect() protoreflect.Message + func (x *OrderedJob) Reset() + func (x *OrderedJob) String() string + type OrderedJob_HadoopJob struct + HadoopJob *HadoopJob + type OrderedJob_HiveJob struct + HiveJob *HiveJob + type OrderedJob_PigJob struct + PigJob *PigJob + type OrderedJob_PrestoJob struct + PrestoJob *PrestoJob + type OrderedJob_PysparkJob struct + PysparkJob *PySparkJob + type OrderedJob_SparkJob struct + SparkJob *SparkJob + type OrderedJob_SparkRJob struct + SparkRJob *SparkRJob + type OrderedJob_SparkSqlJob struct + SparkSqlJob *SparkSqlJob + type ParameterValidation struct + ValidationType isParameterValidation_ValidationType + func (*ParameterValidation) Descriptor() ([]byte, []int) + func (*ParameterValidation) ProtoMessage() + func (m *ParameterValidation) GetValidationType() isParameterValidation_ValidationType + func (x *ParameterValidation) GetRegex() *RegexValidation + func (x *ParameterValidation) GetValues() *ValueValidation + func (x *ParameterValidation) ProtoReflect() protoreflect.Message + func (x *ParameterValidation) Reset() + func (x *ParameterValidation) String() string + type ParameterValidation_Regex struct + Regex *RegexValidation + type ParameterValidation_Values struct + Values *ValueValidation + type PeripheralsConfig struct + MetastoreService string + SparkHistoryServerConfig *SparkHistoryServerConfig + func (*PeripheralsConfig) Descriptor() ([]byte, []int) + func (*PeripheralsConfig) ProtoMessage() + func (x *PeripheralsConfig) GetMetastoreService() string + func (x *PeripheralsConfig) GetSparkHistoryServerConfig() *SparkHistoryServerConfig + func (x *PeripheralsConfig) ProtoReflect() protoreflect.Message + func (x *PeripheralsConfig) Reset() + func (x *PeripheralsConfig) String() string + type PigJob struct + ContinueOnFailure bool + JarFileUris []string + LoggingConfig *LoggingConfig + Properties map[string]string + Queries isPigJob_Queries + ScriptVariables map[string]string + func (*PigJob) Descriptor() ([]byte, []int) + func (*PigJob) ProtoMessage() + func (m *PigJob) GetQueries() isPigJob_Queries + func (x *PigJob) GetContinueOnFailure() bool + func (x *PigJob) GetJarFileUris() []string + func (x *PigJob) GetLoggingConfig() *LoggingConfig + func (x *PigJob) GetProperties() map[string]string + func (x *PigJob) GetQueryFileUri() string + func (x *PigJob) GetQueryList() *QueryList + func (x *PigJob) GetScriptVariables() map[string]string + func (x *PigJob) ProtoReflect() protoreflect.Message + func (x *PigJob) Reset() + func (x *PigJob) String() string + type PigJob_QueryFileUri struct + QueryFileUri string + type PigJob_QueryList struct + QueryList *QueryList + type PrestoJob struct + ClientTags []string + ContinueOnFailure bool + LoggingConfig *LoggingConfig + OutputFormat string + Properties map[string]string + Queries isPrestoJob_Queries + func (*PrestoJob) Descriptor() ([]byte, []int) + func (*PrestoJob) ProtoMessage() + func (m *PrestoJob) GetQueries() isPrestoJob_Queries + func (x *PrestoJob) GetClientTags() []string + func (x *PrestoJob) GetContinueOnFailure() bool + func (x *PrestoJob) GetLoggingConfig() *LoggingConfig + func (x *PrestoJob) GetOutputFormat() string + func (x *PrestoJob) GetProperties() map[string]string + func (x *PrestoJob) GetQueryFileUri() string + func (x *PrestoJob) GetQueryList() *QueryList + func (x *PrestoJob) ProtoReflect() protoreflect.Message + func (x *PrestoJob) Reset() + func (x *PrestoJob) String() string + type PrestoJob_QueryFileUri struct + QueryFileUri string + type PrestoJob_QueryList struct + QueryList *QueryList + type PySparkBatch struct + ArchiveUris []string + Args []string + FileUris []string + JarFileUris []string + MainPythonFileUri string + PythonFileUris []string + func (*PySparkBatch) Descriptor() ([]byte, []int) + func (*PySparkBatch) ProtoMessage() + func (x *PySparkBatch) GetArchiveUris() []string + func (x *PySparkBatch) GetArgs() []string + func (x *PySparkBatch) GetFileUris() []string + func (x *PySparkBatch) GetJarFileUris() []string + func (x *PySparkBatch) GetMainPythonFileUri() string + func (x *PySparkBatch) GetPythonFileUris() []string + func (x *PySparkBatch) ProtoReflect() protoreflect.Message + func (x *PySparkBatch) Reset() + func (x *PySparkBatch) String() string + type PySparkJob struct + ArchiveUris []string + Args []string + FileUris []string + JarFileUris []string + LoggingConfig *LoggingConfig + MainPythonFileUri string + Properties map[string]string + PythonFileUris []string + func (*PySparkJob) Descriptor() ([]byte, []int) + func (*PySparkJob) ProtoMessage() + func (x *PySparkJob) GetArchiveUris() []string + func (x *PySparkJob) GetArgs() []string + func (x *PySparkJob) GetFileUris() []string + func (x *PySparkJob) GetJarFileUris() []string + func (x *PySparkJob) GetLoggingConfig() *LoggingConfig + func (x *PySparkJob) GetMainPythonFileUri() string + func (x *PySparkJob) GetProperties() map[string]string + func (x *PySparkJob) GetPythonFileUris() []string + func (x *PySparkJob) ProtoReflect() protoreflect.Message + func (x *PySparkJob) Reset() + func (x *PySparkJob) String() string + type QueryList struct + Queries []string + func (*QueryList) Descriptor() ([]byte, []int) + func (*QueryList) ProtoMessage() + func (x *QueryList) GetQueries() []string + func (x *QueryList) ProtoReflect() protoreflect.Message + func (x *QueryList) Reset() + func (x *QueryList) String() string + type RegexValidation struct + Regexes []string + func (*RegexValidation) Descriptor() ([]byte, []int) + func (*RegexValidation) ProtoMessage() + func (x *RegexValidation) GetRegexes() []string + func (x *RegexValidation) ProtoReflect() protoreflect.Message + func (x *RegexValidation) Reset() + func (x *RegexValidation) String() string + type ReservationAffinity struct + ConsumeReservationType ReservationAffinity_Type + Key string + Values []string + func (*ReservationAffinity) Descriptor() ([]byte, []int) + func (*ReservationAffinity) ProtoMessage() + func (x *ReservationAffinity) GetConsumeReservationType() ReservationAffinity_Type + func (x *ReservationAffinity) GetKey() string + func (x *ReservationAffinity) GetValues() []string + func (x *ReservationAffinity) ProtoReflect() protoreflect.Message + func (x *ReservationAffinity) Reset() + func (x *ReservationAffinity) String() string + type ReservationAffinity_Type int32 + const ReservationAffinity_ANY_RESERVATION + const ReservationAffinity_NO_RESERVATION + const ReservationAffinity_SPECIFIC_RESERVATION + const ReservationAffinity_TYPE_UNSPECIFIED + func (ReservationAffinity_Type) Descriptor() protoreflect.EnumDescriptor + func (ReservationAffinity_Type) EnumDescriptor() ([]byte, []int) + func (ReservationAffinity_Type) Type() protoreflect.EnumType + func (x ReservationAffinity_Type) Enum() *ReservationAffinity_Type + func (x ReservationAffinity_Type) Number() protoreflect.EnumNumber + func (x ReservationAffinity_Type) String() string + type RuntimeConfig struct + ContainerImage string + Properties map[string]string + Version string + func (*RuntimeConfig) Descriptor() ([]byte, []int) + func (*RuntimeConfig) ProtoMessage() + func (x *RuntimeConfig) GetContainerImage() string + func (x *RuntimeConfig) GetProperties() map[string]string + func (x *RuntimeConfig) GetVersion() string + func (x *RuntimeConfig) ProtoReflect() protoreflect.Message + func (x *RuntimeConfig) Reset() + func (x *RuntimeConfig) String() string + type RuntimeInfo struct + DiagnosticOutputUri string + Endpoints map[string]string + OutputUri string + func (*RuntimeInfo) Descriptor() ([]byte, []int) + func (*RuntimeInfo) ProtoMessage() + func (x *RuntimeInfo) GetDiagnosticOutputUri() string + func (x *RuntimeInfo) GetEndpoints() map[string]string + func (x *RuntimeInfo) GetOutputUri() string + func (x *RuntimeInfo) ProtoReflect() protoreflect.Message + func (x *RuntimeInfo) Reset() + func (x *RuntimeInfo) String() string + type SecurityConfig struct + IdentityConfig *IdentityConfig + KerberosConfig *KerberosConfig + func (*SecurityConfig) Descriptor() ([]byte, []int) + func (*SecurityConfig) ProtoMessage() + func (x *SecurityConfig) GetIdentityConfig() *IdentityConfig + func (x *SecurityConfig) GetKerberosConfig() *KerberosConfig + func (x *SecurityConfig) ProtoReflect() protoreflect.Message + func (x *SecurityConfig) Reset() + func (x *SecurityConfig) String() string + type ShieldedInstanceConfig struct + EnableIntegrityMonitoring bool + EnableSecureBoot bool + EnableVtpm bool + func (*ShieldedInstanceConfig) Descriptor() ([]byte, []int) + func (*ShieldedInstanceConfig) ProtoMessage() + func (x *ShieldedInstanceConfig) GetEnableIntegrityMonitoring() bool + func (x *ShieldedInstanceConfig) GetEnableSecureBoot() bool + func (x *ShieldedInstanceConfig) GetEnableVtpm() bool + func (x *ShieldedInstanceConfig) ProtoReflect() protoreflect.Message + func (x *ShieldedInstanceConfig) Reset() + func (x *ShieldedInstanceConfig) String() string + type SoftwareConfig struct + ImageVersion string + OptionalComponents []Component + Properties map[string]string + func (*SoftwareConfig) Descriptor() ([]byte, []int) + func (*SoftwareConfig) ProtoMessage() + func (x *SoftwareConfig) GetImageVersion() string + func (x *SoftwareConfig) GetOptionalComponents() []Component + func (x *SoftwareConfig) GetProperties() map[string]string + func (x *SoftwareConfig) ProtoReflect() protoreflect.Message + func (x *SoftwareConfig) Reset() + func (x *SoftwareConfig) String() string + type SparkBatch struct + ArchiveUris []string + Args []string + Driver isSparkBatch_Driver + FileUris []string + JarFileUris []string + func (*SparkBatch) Descriptor() ([]byte, []int) + func (*SparkBatch) ProtoMessage() + func (m *SparkBatch) GetDriver() isSparkBatch_Driver + func (x *SparkBatch) GetArchiveUris() []string + func (x *SparkBatch) GetArgs() []string + func (x *SparkBatch) GetFileUris() []string + func (x *SparkBatch) GetJarFileUris() []string + func (x *SparkBatch) GetMainClass() string + func (x *SparkBatch) GetMainJarFileUri() string + func (x *SparkBatch) ProtoReflect() protoreflect.Message + func (x *SparkBatch) Reset() + func (x *SparkBatch) String() string + type SparkBatch_MainClass struct + MainClass string + type SparkBatch_MainJarFileUri struct + MainJarFileUri string + type SparkHistoryServerConfig struct + DataprocCluster string + func (*SparkHistoryServerConfig) Descriptor() ([]byte, []int) + func (*SparkHistoryServerConfig) ProtoMessage() + func (x *SparkHistoryServerConfig) GetDataprocCluster() string + func (x *SparkHistoryServerConfig) ProtoReflect() protoreflect.Message + func (x *SparkHistoryServerConfig) Reset() + func (x *SparkHistoryServerConfig) String() string + type SparkJob struct + ArchiveUris []string + Args []string + Driver isSparkJob_Driver + FileUris []string + JarFileUris []string + LoggingConfig *LoggingConfig + Properties map[string]string + func (*SparkJob) Descriptor() ([]byte, []int) + func (*SparkJob) ProtoMessage() + func (m *SparkJob) GetDriver() isSparkJob_Driver + func (x *SparkJob) GetArchiveUris() []string + func (x *SparkJob) GetArgs() []string + func (x *SparkJob) GetFileUris() []string + func (x *SparkJob) GetJarFileUris() []string + func (x *SparkJob) GetLoggingConfig() *LoggingConfig + func (x *SparkJob) GetMainClass() string + func (x *SparkJob) GetMainJarFileUri() string + func (x *SparkJob) GetProperties() map[string]string + func (x *SparkJob) ProtoReflect() protoreflect.Message + func (x *SparkJob) Reset() + func (x *SparkJob) String() string + type SparkJob_MainClass struct + MainClass string + type SparkJob_MainJarFileUri struct + MainJarFileUri string + type SparkRBatch struct + ArchiveUris []string + Args []string + FileUris []string + MainRFileUri string + func (*SparkRBatch) Descriptor() ([]byte, []int) + func (*SparkRBatch) ProtoMessage() + func (x *SparkRBatch) GetArchiveUris() []string + func (x *SparkRBatch) GetArgs() []string + func (x *SparkRBatch) GetFileUris() []string + func (x *SparkRBatch) GetMainRFileUri() string + func (x *SparkRBatch) ProtoReflect() protoreflect.Message + func (x *SparkRBatch) Reset() + func (x *SparkRBatch) String() string + type SparkRJob struct + ArchiveUris []string + Args []string + FileUris []string + LoggingConfig *LoggingConfig + MainRFileUri string + Properties map[string]string + func (*SparkRJob) Descriptor() ([]byte, []int) + func (*SparkRJob) ProtoMessage() + func (x *SparkRJob) GetArchiveUris() []string + func (x *SparkRJob) GetArgs() []string + func (x *SparkRJob) GetFileUris() []string + func (x *SparkRJob) GetLoggingConfig() *LoggingConfig + func (x *SparkRJob) GetMainRFileUri() string + func (x *SparkRJob) GetProperties() map[string]string + func (x *SparkRJob) ProtoReflect() protoreflect.Message + func (x *SparkRJob) Reset() + func (x *SparkRJob) String() string + type SparkSqlBatch struct + JarFileUris []string + QueryFileUri string + QueryVariables map[string]string + func (*SparkSqlBatch) Descriptor() ([]byte, []int) + func (*SparkSqlBatch) ProtoMessage() + func (x *SparkSqlBatch) GetJarFileUris() []string + func (x *SparkSqlBatch) GetQueryFileUri() string + func (x *SparkSqlBatch) GetQueryVariables() map[string]string + func (x *SparkSqlBatch) ProtoReflect() protoreflect.Message + func (x *SparkSqlBatch) Reset() + func (x *SparkSqlBatch) String() string + type SparkSqlJob struct + JarFileUris []string + LoggingConfig *LoggingConfig + Properties map[string]string + Queries isSparkSqlJob_Queries + ScriptVariables map[string]string + func (*SparkSqlJob) Descriptor() ([]byte, []int) + func (*SparkSqlJob) ProtoMessage() + func (m *SparkSqlJob) GetQueries() isSparkSqlJob_Queries + func (x *SparkSqlJob) GetJarFileUris() []string + func (x *SparkSqlJob) GetLoggingConfig() *LoggingConfig + func (x *SparkSqlJob) GetProperties() map[string]string + func (x *SparkSqlJob) GetQueryFileUri() string + func (x *SparkSqlJob) GetQueryList() *QueryList + func (x *SparkSqlJob) GetScriptVariables() map[string]string + func (x *SparkSqlJob) ProtoReflect() protoreflect.Message + func (x *SparkSqlJob) Reset() + func (x *SparkSqlJob) String() string + type SparkSqlJob_QueryFileUri struct + QueryFileUri string + type SparkSqlJob_QueryList struct + QueryList *QueryList + type StartClusterRequest struct + ClusterName string + ClusterUuid string + ProjectId string + Region string + RequestId string + func (*StartClusterRequest) Descriptor() ([]byte, []int) + func (*StartClusterRequest) ProtoMessage() + func (x *StartClusterRequest) GetClusterName() string + func (x *StartClusterRequest) GetClusterUuid() string + func (x *StartClusterRequest) GetProjectId() string + func (x *StartClusterRequest) GetRegion() string + func (x *StartClusterRequest) GetRequestId() string + func (x *StartClusterRequest) ProtoReflect() protoreflect.Message + func (x *StartClusterRequest) Reset() + func (x *StartClusterRequest) String() string + type StopClusterRequest struct + ClusterName string + ClusterUuid string + ProjectId string + Region string + RequestId string + func (*StopClusterRequest) Descriptor() ([]byte, []int) + func (*StopClusterRequest) ProtoMessage() + func (x *StopClusterRequest) GetClusterName() string + func (x *StopClusterRequest) GetClusterUuid() string + func (x *StopClusterRequest) GetProjectId() string + func (x *StopClusterRequest) GetRegion() string + func (x *StopClusterRequest) GetRequestId() string + func (x *StopClusterRequest) ProtoReflect() protoreflect.Message + func (x *StopClusterRequest) Reset() + func (x *StopClusterRequest) String() string + type SubmitJobRequest struct + Job *Job + ProjectId string + Region string + RequestId string + func (*SubmitJobRequest) Descriptor() ([]byte, []int) + func (*SubmitJobRequest) ProtoMessage() + func (x *SubmitJobRequest) GetJob() *Job + func (x *SubmitJobRequest) GetProjectId() string + func (x *SubmitJobRequest) GetRegion() string + func (x *SubmitJobRequest) GetRequestId() string + func (x *SubmitJobRequest) ProtoReflect() protoreflect.Message + func (x *SubmitJobRequest) Reset() + func (x *SubmitJobRequest) String() string + type TemplateParameter struct + Description string + Fields []string + Name string + Validation *ParameterValidation + func (*TemplateParameter) Descriptor() ([]byte, []int) + func (*TemplateParameter) ProtoMessage() + func (x *TemplateParameter) GetDescription() string + func (x *TemplateParameter) GetFields() []string + func (x *TemplateParameter) GetName() string + func (x *TemplateParameter) GetValidation() *ParameterValidation + func (x *TemplateParameter) ProtoReflect() protoreflect.Message + func (x *TemplateParameter) Reset() + func (x *TemplateParameter) String() string + type UnimplementedAutoscalingPolicyServiceServer struct + func (*UnimplementedAutoscalingPolicyServiceServer) CreateAutoscalingPolicy(context.Context, *CreateAutoscalingPolicyRequest) (*AutoscalingPolicy, error) + func (*UnimplementedAutoscalingPolicyServiceServer) DeleteAutoscalingPolicy(context.Context, *DeleteAutoscalingPolicyRequest) (*empty.Empty, error) + func (*UnimplementedAutoscalingPolicyServiceServer) GetAutoscalingPolicy(context.Context, *GetAutoscalingPolicyRequest) (*AutoscalingPolicy, error) + func (*UnimplementedAutoscalingPolicyServiceServer) ListAutoscalingPolicies(context.Context, *ListAutoscalingPoliciesRequest) (*ListAutoscalingPoliciesResponse, error) + func (*UnimplementedAutoscalingPolicyServiceServer) UpdateAutoscalingPolicy(context.Context, *UpdateAutoscalingPolicyRequest) (*AutoscalingPolicy, error) + type UnimplementedBatchControllerServer struct + func (*UnimplementedBatchControllerServer) CreateBatch(context.Context, *CreateBatchRequest) (*longrunning.Operation, error) + func (*UnimplementedBatchControllerServer) DeleteBatch(context.Context, *DeleteBatchRequest) (*empty.Empty, error) + func (*UnimplementedBatchControllerServer) GetBatch(context.Context, *GetBatchRequest) (*Batch, error) + func (*UnimplementedBatchControllerServer) ListBatches(context.Context, *ListBatchesRequest) (*ListBatchesResponse, error) + type UnimplementedClusterControllerServer struct + func (*UnimplementedClusterControllerServer) CreateCluster(context.Context, *CreateClusterRequest) (*longrunning.Operation, error) + func (*UnimplementedClusterControllerServer) DeleteCluster(context.Context, *DeleteClusterRequest) (*longrunning.Operation, error) + func (*UnimplementedClusterControllerServer) DiagnoseCluster(context.Context, *DiagnoseClusterRequest) (*longrunning.Operation, error) + func (*UnimplementedClusterControllerServer) GetCluster(context.Context, *GetClusterRequest) (*Cluster, error) + func (*UnimplementedClusterControllerServer) ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error) + func (*UnimplementedClusterControllerServer) StartCluster(context.Context, *StartClusterRequest) (*longrunning.Operation, error) + func (*UnimplementedClusterControllerServer) StopCluster(context.Context, *StopClusterRequest) (*longrunning.Operation, error) + func (*UnimplementedClusterControllerServer) UpdateCluster(context.Context, *UpdateClusterRequest) (*longrunning.Operation, error) + type UnimplementedJobControllerServer struct + func (*UnimplementedJobControllerServer) CancelJob(context.Context, *CancelJobRequest) (*Job, error) + func (*UnimplementedJobControllerServer) DeleteJob(context.Context, *DeleteJobRequest) (*empty.Empty, error) + func (*UnimplementedJobControllerServer) GetJob(context.Context, *GetJobRequest) (*Job, error) + func (*UnimplementedJobControllerServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) + func (*UnimplementedJobControllerServer) SubmitJob(context.Context, *SubmitJobRequest) (*Job, error) + func (*UnimplementedJobControllerServer) SubmitJobAsOperation(context.Context, *SubmitJobRequest) (*longrunning.Operation, error) + func (*UnimplementedJobControllerServer) UpdateJob(context.Context, *UpdateJobRequest) (*Job, error) + type UnimplementedWorkflowTemplateServiceServer struct + func (*UnimplementedWorkflowTemplateServiceServer) CreateWorkflowTemplate(context.Context, *CreateWorkflowTemplateRequest) (*WorkflowTemplate, error) + func (*UnimplementedWorkflowTemplateServiceServer) DeleteWorkflowTemplate(context.Context, *DeleteWorkflowTemplateRequest) (*empty.Empty, error) + func (*UnimplementedWorkflowTemplateServiceServer) GetWorkflowTemplate(context.Context, *GetWorkflowTemplateRequest) (*WorkflowTemplate, error) + func (*UnimplementedWorkflowTemplateServiceServer) InstantiateInlineWorkflowTemplate(context.Context, *InstantiateInlineWorkflowTemplateRequest) (*longrunning.Operation, error) + func (*UnimplementedWorkflowTemplateServiceServer) InstantiateWorkflowTemplate(context.Context, *InstantiateWorkflowTemplateRequest) (*longrunning.Operation, error) + func (*UnimplementedWorkflowTemplateServiceServer) ListWorkflowTemplates(context.Context, *ListWorkflowTemplatesRequest) (*ListWorkflowTemplatesResponse, error) + func (*UnimplementedWorkflowTemplateServiceServer) UpdateWorkflowTemplate(context.Context, *UpdateWorkflowTemplateRequest) (*WorkflowTemplate, error) + type UpdateAutoscalingPolicyRequest struct + Policy *AutoscalingPolicy + func (*UpdateAutoscalingPolicyRequest) Descriptor() ([]byte, []int) + func (*UpdateAutoscalingPolicyRequest) ProtoMessage() + func (x *UpdateAutoscalingPolicyRequest) GetPolicy() *AutoscalingPolicy + func (x *UpdateAutoscalingPolicyRequest) ProtoReflect() protoreflect.Message + func (x *UpdateAutoscalingPolicyRequest) Reset() + func (x *UpdateAutoscalingPolicyRequest) String() string + type UpdateClusterRequest struct + Cluster *Cluster + ClusterName string + GracefulDecommissionTimeout *duration.Duration + ProjectId string + Region string + RequestId string + UpdateMask *field_mask.FieldMask + func (*UpdateClusterRequest) Descriptor() ([]byte, []int) + func (*UpdateClusterRequest) ProtoMessage() + func (x *UpdateClusterRequest) GetCluster() *Cluster + func (x *UpdateClusterRequest) GetClusterName() string + func (x *UpdateClusterRequest) GetGracefulDecommissionTimeout() *duration.Duration + func (x *UpdateClusterRequest) GetProjectId() string + func (x *UpdateClusterRequest) GetRegion() string + func (x *UpdateClusterRequest) GetRequestId() string + func (x *UpdateClusterRequest) GetUpdateMask() *field_mask.FieldMask + func (x *UpdateClusterRequest) ProtoReflect() protoreflect.Message + func (x *UpdateClusterRequest) Reset() + func (x *UpdateClusterRequest) String() string + type UpdateJobRequest struct + Job *Job + JobId string + ProjectId string + Region string + UpdateMask *field_mask.FieldMask + func (*UpdateJobRequest) Descriptor() ([]byte, []int) + func (*UpdateJobRequest) ProtoMessage() + func (x *UpdateJobRequest) GetJob() *Job + func (x *UpdateJobRequest) GetJobId() string + func (x *UpdateJobRequest) GetProjectId() string + func (x *UpdateJobRequest) GetRegion() string + func (x *UpdateJobRequest) GetUpdateMask() *field_mask.FieldMask + func (x *UpdateJobRequest) ProtoReflect() protoreflect.Message + func (x *UpdateJobRequest) Reset() + func (x *UpdateJobRequest) String() string + type UpdateWorkflowTemplateRequest struct + Template *WorkflowTemplate + func (*UpdateWorkflowTemplateRequest) Descriptor() ([]byte, []int) + func (*UpdateWorkflowTemplateRequest) ProtoMessage() + func (x *UpdateWorkflowTemplateRequest) GetTemplate() *WorkflowTemplate + func (x *UpdateWorkflowTemplateRequest) ProtoReflect() protoreflect.Message + func (x *UpdateWorkflowTemplateRequest) Reset() + func (x *UpdateWorkflowTemplateRequest) String() string + type ValueValidation struct + Values []string + func (*ValueValidation) Descriptor() ([]byte, []int) + func (*ValueValidation) ProtoMessage() + func (x *ValueValidation) GetValues() []string + func (x *ValueValidation) ProtoReflect() protoreflect.Message + func (x *ValueValidation) Reset() + func (x *ValueValidation) String() string + type VirtualClusterConfig struct + AuxiliaryServicesConfig *AuxiliaryServicesConfig + InfrastructureConfig isVirtualClusterConfig_InfrastructureConfig + StagingBucket string + func (*VirtualClusterConfig) Descriptor() ([]byte, []int) + func (*VirtualClusterConfig) ProtoMessage() + func (m *VirtualClusterConfig) GetInfrastructureConfig() isVirtualClusterConfig_InfrastructureConfig + func (x *VirtualClusterConfig) GetAuxiliaryServicesConfig() *AuxiliaryServicesConfig + func (x *VirtualClusterConfig) GetKubernetesClusterConfig() *KubernetesClusterConfig + func (x *VirtualClusterConfig) GetStagingBucket() string + func (x *VirtualClusterConfig) ProtoReflect() protoreflect.Message + func (x *VirtualClusterConfig) Reset() + func (x *VirtualClusterConfig) String() string + type VirtualClusterConfig_KubernetesClusterConfig struct + KubernetesClusterConfig *KubernetesClusterConfig + type WorkflowGraph struct + Nodes []*WorkflowNode + func (*WorkflowGraph) Descriptor() ([]byte, []int) + func (*WorkflowGraph) ProtoMessage() + func (x *WorkflowGraph) GetNodes() []*WorkflowNode + func (x *WorkflowGraph) ProtoReflect() protoreflect.Message + func (x *WorkflowGraph) Reset() + func (x *WorkflowGraph) String() string + type WorkflowMetadata struct + ClusterName string + ClusterUuid string + CreateCluster *ClusterOperation + DagEndTime *timestamp.Timestamp + DagStartTime *timestamp.Timestamp + DagTimeout *duration.Duration + DeleteCluster *ClusterOperation + EndTime *timestamp.Timestamp + Graph *WorkflowGraph + Parameters map[string]string + StartTime *timestamp.Timestamp + State WorkflowMetadata_State + Template string + Version int32 + func (*WorkflowMetadata) Descriptor() ([]byte, []int) + func (*WorkflowMetadata) ProtoMessage() + func (x *WorkflowMetadata) GetClusterName() string + func (x *WorkflowMetadata) GetClusterUuid() string + func (x *WorkflowMetadata) GetCreateCluster() *ClusterOperation + func (x *WorkflowMetadata) GetDagEndTime() *timestamp.Timestamp + func (x *WorkflowMetadata) GetDagStartTime() *timestamp.Timestamp + func (x *WorkflowMetadata) GetDagTimeout() *duration.Duration + func (x *WorkflowMetadata) GetDeleteCluster() *ClusterOperation + func (x *WorkflowMetadata) GetEndTime() *timestamp.Timestamp + func (x *WorkflowMetadata) GetGraph() *WorkflowGraph + func (x *WorkflowMetadata) GetParameters() map[string]string + func (x *WorkflowMetadata) GetStartTime() *timestamp.Timestamp + func (x *WorkflowMetadata) GetState() WorkflowMetadata_State + func (x *WorkflowMetadata) GetTemplate() string + func (x *WorkflowMetadata) GetVersion() int32 + func (x *WorkflowMetadata) ProtoReflect() protoreflect.Message + func (x *WorkflowMetadata) Reset() + func (x *WorkflowMetadata) String() string + type WorkflowMetadata_State int32 + const WorkflowMetadata_DONE + const WorkflowMetadata_PENDING + const WorkflowMetadata_RUNNING + const WorkflowMetadata_UNKNOWN + func (WorkflowMetadata_State) Descriptor() protoreflect.EnumDescriptor + func (WorkflowMetadata_State) EnumDescriptor() ([]byte, []int) + func (WorkflowMetadata_State) Type() protoreflect.EnumType + func (x WorkflowMetadata_State) Enum() *WorkflowMetadata_State + func (x WorkflowMetadata_State) Number() protoreflect.EnumNumber + func (x WorkflowMetadata_State) String() string + type WorkflowNode struct + Error string + JobId string + PrerequisiteStepIds []string + State WorkflowNode_NodeState + StepId string + func (*WorkflowNode) Descriptor() ([]byte, []int) + func (*WorkflowNode) ProtoMessage() + func (x *WorkflowNode) GetError() string + func (x *WorkflowNode) GetJobId() string + func (x *WorkflowNode) GetPrerequisiteStepIds() []string + func (x *WorkflowNode) GetState() WorkflowNode_NodeState + func (x *WorkflowNode) GetStepId() string + func (x *WorkflowNode) ProtoReflect() protoreflect.Message + func (x *WorkflowNode) Reset() + func (x *WorkflowNode) String() string + type WorkflowNode_NodeState int32 + const WorkflowNode_BLOCKED + const WorkflowNode_COMPLETED + const WorkflowNode_FAILED + const WorkflowNode_NODE_STATE_UNSPECIFIED + const WorkflowNode_RUNNABLE + const WorkflowNode_RUNNING + func (WorkflowNode_NodeState) Descriptor() protoreflect.EnumDescriptor + func (WorkflowNode_NodeState) EnumDescriptor() ([]byte, []int) + func (WorkflowNode_NodeState) Type() protoreflect.EnumType + func (x WorkflowNode_NodeState) Enum() *WorkflowNode_NodeState + func (x WorkflowNode_NodeState) Number() protoreflect.EnumNumber + func (x WorkflowNode_NodeState) String() string + type WorkflowTemplate struct + CreateTime *timestamp.Timestamp + DagTimeout *duration.Duration + Id string + Jobs []*OrderedJob + Labels map[string]string + Name string + Parameters []*TemplateParameter + Placement *WorkflowTemplatePlacement + UpdateTime *timestamp.Timestamp + Version int32 + func (*WorkflowTemplate) Descriptor() ([]byte, []int) + func (*WorkflowTemplate) ProtoMessage() + func (x *WorkflowTemplate) GetCreateTime() *timestamp.Timestamp + func (x *WorkflowTemplate) GetDagTimeout() *duration.Duration + func (x *WorkflowTemplate) GetId() string + func (x *WorkflowTemplate) GetJobs() []*OrderedJob + func (x *WorkflowTemplate) GetLabels() map[string]string + func (x *WorkflowTemplate) GetName() string + func (x *WorkflowTemplate) GetParameters() []*TemplateParameter + func (x *WorkflowTemplate) GetPlacement() *WorkflowTemplatePlacement + func (x *WorkflowTemplate) GetUpdateTime() *timestamp.Timestamp + func (x *WorkflowTemplate) GetVersion() int32 + func (x *WorkflowTemplate) ProtoReflect() protoreflect.Message + func (x *WorkflowTemplate) Reset() + func (x *WorkflowTemplate) String() string + type WorkflowTemplatePlacement struct + Placement isWorkflowTemplatePlacement_Placement + func (*WorkflowTemplatePlacement) Descriptor() ([]byte, []int) + func (*WorkflowTemplatePlacement) ProtoMessage() + func (m *WorkflowTemplatePlacement) GetPlacement() isWorkflowTemplatePlacement_Placement + func (x *WorkflowTemplatePlacement) GetClusterSelector() *ClusterSelector + func (x *WorkflowTemplatePlacement) GetManagedCluster() *ManagedCluster + func (x *WorkflowTemplatePlacement) ProtoReflect() protoreflect.Message + func (x *WorkflowTemplatePlacement) Reset() + func (x *WorkflowTemplatePlacement) String() string + type WorkflowTemplatePlacement_ClusterSelector struct + ClusterSelector *ClusterSelector + type WorkflowTemplatePlacement_ManagedCluster struct + ManagedCluster *ManagedCluster + type WorkflowTemplateServiceClient interface + CreateWorkflowTemplate func(ctx context.Context, in *CreateWorkflowTemplateRequest, ...) (*WorkflowTemplate, error) + DeleteWorkflowTemplate func(ctx context.Context, in *DeleteWorkflowTemplateRequest, ...) (*empty.Empty, error) + GetWorkflowTemplate func(ctx context.Context, in *GetWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error) + InstantiateInlineWorkflowTemplate func(ctx context.Context, in *InstantiateInlineWorkflowTemplateRequest, ...) (*longrunning.Operation, error) + InstantiateWorkflowTemplate func(ctx context.Context, in *InstantiateWorkflowTemplateRequest, ...) (*longrunning.Operation, error) + ListWorkflowTemplates func(ctx context.Context, in *ListWorkflowTemplatesRequest, opts ...grpc.CallOption) (*ListWorkflowTemplatesResponse, error) + UpdateWorkflowTemplate func(ctx context.Context, in *UpdateWorkflowTemplateRequest, ...) (*WorkflowTemplate, error) + func NewWorkflowTemplateServiceClient(cc grpc.ClientConnInterface) WorkflowTemplateServiceClient + type WorkflowTemplateServiceServer interface + CreateWorkflowTemplate func(context.Context, *CreateWorkflowTemplateRequest) (*WorkflowTemplate, error) + DeleteWorkflowTemplate func(context.Context, *DeleteWorkflowTemplateRequest) (*empty.Empty, error) + GetWorkflowTemplate func(context.Context, *GetWorkflowTemplateRequest) (*WorkflowTemplate, error) + InstantiateInlineWorkflowTemplate func(context.Context, *InstantiateInlineWorkflowTemplateRequest) (*longrunning.Operation, error) + InstantiateWorkflowTemplate func(context.Context, *InstantiateWorkflowTemplateRequest) (*longrunning.Operation, error) + ListWorkflowTemplates func(context.Context, *ListWorkflowTemplatesRequest) (*ListWorkflowTemplatesResponse, error) + UpdateWorkflowTemplate func(context.Context, *UpdateWorkflowTemplateRequest) (*WorkflowTemplate, error) + type YarnApplication struct + Name string + Progress float32 + State YarnApplication_State + TrackingUrl string + func (*YarnApplication) Descriptor() ([]byte, []int) + func (*YarnApplication) ProtoMessage() + func (x *YarnApplication) GetName() string + func (x *YarnApplication) GetProgress() float32 + func (x *YarnApplication) GetState() YarnApplication_State + func (x *YarnApplication) GetTrackingUrl() string + func (x *YarnApplication) ProtoReflect() protoreflect.Message + func (x *YarnApplication) Reset() + func (x *YarnApplication) String() string + type YarnApplication_State int32 + const YarnApplication_ACCEPTED + const YarnApplication_FAILED + const YarnApplication_FINISHED + const YarnApplication_KILLED + const YarnApplication_NEW + const YarnApplication_NEW_SAVING + const YarnApplication_RUNNING + const YarnApplication_STATE_UNSPECIFIED + const YarnApplication_SUBMITTED + func (YarnApplication_State) Descriptor() protoreflect.EnumDescriptor + func (YarnApplication_State) EnumDescriptor() ([]byte, []int) + func (YarnApplication_State) Type() protoreflect.EnumType + func (x YarnApplication_State) Enum() *YarnApplication_State + func (x YarnApplication_State) Number() protoreflect.EnumNumber + func (x YarnApplication_State) String() string Other modules containing this package cloud.google.com/go/dataproc/v2
Go to main page