Documentation ¶
Overview ¶
Copyright (c) HashiCorp, Inc. SPDX-License-Identifier: MPL-2.0
Copyright (c) HashiCorp, Inc. SPDX-License-Identifier: MPL-2.0
Copyright (c) HashiCorp, Inc. SPDX-License-Identifier: MPL-2.0
Copyright (c) HashiCorp, Inc. SPDX-License-Identifier: MPL-2.0
Copyright (c) HashiCorp, Inc. SPDX-License-Identifier: MPL-2.0
Copyright (c) HashiCorp, Inc. SPDX-License-Identifier: MPL-2.0
Copyright (c) HashiCorp, Inc. SPDX-License-Identifier: MPL-2.0
Copyright (c) HashiCorp, Inc. SPDX-License-Identifier: MPL-2.0
Copyright (c) HashiCorp, Inc. SPDX-License-Identifier: MPL-2.0
Index ¶
- Variables
- func CloudDataprocBatchRuntimeConfigVersionDiffSuppress(_, old, new string, d *schema.ResourceData) bool
- func CloudDataprocBatchRuntimeConfigVersionDiffSuppressFunc(old, new string) bool
- func DataprocAutoscalingPolicyIamUpdaterProducer(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (tpgiamresource.ResourceIamUpdater, error)
- func DataprocAutoscalingPolicyIdParseFunc(d *schema.ResourceData, config *transport_tpg.Config) error
- func DataprocClusterIdParseFunc(d *schema.ResourceData, config *transport_tpg.Config) error
- func DataprocClusterOperationWait(config *transport_tpg.Config, op *dataproc.Operation, ...) error
- func DataprocDeleteOperationWait(config *transport_tpg.Config, ...) error
- func DataprocJobIdParseFunc(d *schema.ResourceData, config *transport_tpg.Config) error
- func DataprocJobOperationWait(config *transport_tpg.Config, ...) error
- func DataprocOperationWaitTime(config *transport_tpg.Config, op map[string]interface{}, ...) error
- func DataprocOperationWaitTimeWithResponse(config *transport_tpg.Config, op map[string]interface{}, ...) error
- func DataprocWorkflowTemplateJobsHadoopJobLoggingConfigSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsHadoopJobLoggingConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsHadoopJobSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsHadoopJobSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsHiveJobQueryListSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsHiveJobQueryListSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsHiveJobSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsHiveJobSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsPigJobLoggingConfigSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsPigJobLoggingConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsPigJobQueryListSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsPigJobQueryListSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsPigJobSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsPigJobSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsPrestoJobLoggingConfigSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsPrestoJobLoggingConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsPrestoJobQueryListSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsPrestoJobQueryListSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsPrestoJobSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsPrestoJobSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsPysparkJobLoggingConfigSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsPysparkJobLoggingConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsPysparkJobSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsPysparkJobSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsSchedulingSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsSchedulingSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsSparkJobLoggingConfigSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsSparkJobLoggingConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsSparkJobSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsSparkJobSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsSparkRJobLoggingConfigSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsSparkRJobLoggingConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsSparkRJobSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsSparkRJobSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsSparkSqlJobLoggingConfigSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsSparkSqlJobLoggingConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsSparkSqlJobQueryListSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsSparkSqlJobQueryListSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateJobsSparkSqlJobSchema() *schema.Resource
- func DataprocWorkflowTemplateJobsSparkSqlJobSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateParametersSchema() *schema.Resource
- func DataprocWorkflowTemplateParametersSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateParametersValidationRegexSchema() *schema.Resource
- func DataprocWorkflowTemplateParametersValidationRegexSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateParametersValidationSchema() *schema.Resource
- func DataprocWorkflowTemplateParametersValidationSchemaV0() *schema.Resource
- func DataprocWorkflowTemplateParametersValidationValuesSchema() *schema.Resource
- func DataprocWorkflowTemplateParametersValidationValuesSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementClusterSelectorSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementClusterSelectorSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigAutoscalingConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigAutoscalingConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigEncryptionConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigEncryptionConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigEndpointConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigEndpointConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigNodeGroupAffinitySchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigNodeGroupAffinitySchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigReservationAffinitySchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigReservationAffinitySchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigShieldedInstanceConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigShieldedInstanceConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigGkeClusterConfigNamespacedGkeDeploymentTargetSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigGkeClusterConfigNamespacedGkeDeploymentTargetSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigGkeClusterConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigGkeClusterConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigInitializationActionsSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigInitializationActionsSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigLifecycleConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigLifecycleConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigAcceleratorsSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigAcceleratorsSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigDiskConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigDiskConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigManagedGroupConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigManagedGroupConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigMetastoreConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigMetastoreConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigAcceleratorsSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigAcceleratorsSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigDiskConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigDiskConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigManagedGroupConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigManagedGroupConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSecurityConfigKerberosConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSecurityConfigKerberosConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSecurityConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSecurityConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSoftwareConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigSoftwareConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigAcceleratorsSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigAcceleratorsSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigDiskConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigDiskConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigManagedGroupConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigManagedGroupConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementManagedClusterSchemaV0() *schema.Resource
- func DataprocWorkflowTemplatePlacementSchema() *schema.Resource
- func DataprocWorkflowTemplatePlacementSchemaV0() *schema.Resource
- func LocationDiffSuppress(k, old, new string, d *schema.ResourceData) bool
- func LocationDiffSuppressHelper(a, b string) bool
- func NewDataprocClusterUpdater(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (tpgiamresource.ResourceIamUpdater, error)
- func NewDataprocJobUpdater(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (tpgiamresource.ResourceIamUpdater, error)
- func ResourceDataprocAutoscalingPolicy() *schema.Resource
- func ResourceDataprocBatch() *schema.Resource
- func ResourceDataprocCluster() *schema.Resource
- func ResourceDataprocClusterStateUpgradeV0(_ context.Context, rawState map[string]interface{}, meta interface{}) (map[string]interface{}, error)
- func ResourceDataprocJob() *schema.Resource
- func ResourceDataprocWorkflowTemplate() *schema.Resource
- func ResourceDataprocWorkflowTemplateUpgradeV0(_ context.Context, rawState map[string]interface{}, meta interface{}) (map[string]interface{}, error)
- type DataprocAutoscalingPolicyIamUpdater
- func (u *DataprocAutoscalingPolicyIamUpdater) DescribeResource() string
- func (u *DataprocAutoscalingPolicyIamUpdater) GetMutexKey() string
- func (u *DataprocAutoscalingPolicyIamUpdater) GetResourceIamPolicy() (*cloudresourcemanager.Policy, error)
- func (u *DataprocAutoscalingPolicyIamUpdater) GetResourceId() string
- func (u *DataprocAutoscalingPolicyIamUpdater) SetResourceIamPolicy(policy *cloudresourcemanager.Policy) error
- type DataprocClusterIamUpdater
- func (u *DataprocClusterIamUpdater) DescribeResource() string
- func (u *DataprocClusterIamUpdater) GetMutexKey() string
- func (u *DataprocClusterIamUpdater) GetResourceIamPolicy() (*cloudresourcemanager.Policy, error)
- func (u *DataprocClusterIamUpdater) GetResourceId() string
- func (u *DataprocClusterIamUpdater) SetResourceIamPolicy(policy *cloudresourcemanager.Policy) error
- type DataprocClusterOperationWaiter
- type DataprocDeleteJobOperationWaiter
- type DataprocJobIamUpdater
- func (u *DataprocJobIamUpdater) DescribeResource() string
- func (u *DataprocJobIamUpdater) GetMutexKey() string
- func (u *DataprocJobIamUpdater) GetResourceIamPolicy() (*cloudresourcemanager.Policy, error)
- func (u *DataprocJobIamUpdater) GetResourceId() string
- func (u *DataprocJobIamUpdater) SetResourceIamPolicy(policy *cloudresourcemanager.Policy) error
- type DataprocJobOperationWaiter
- func (w *DataprocJobOperationWaiter) Error() error
- func (w *DataprocJobOperationWaiter) IsRetryable(error) bool
- func (w *DataprocJobOperationWaiter) OpName() string
- func (w *DataprocJobOperationWaiter) PendingStates() []string
- func (w *DataprocJobOperationWaiter) QueryOp() (interface{}, error)
- func (w *DataprocJobOperationWaiter) SetOp(job interface{}) error
- func (w *DataprocJobOperationWaiter) State() string
- func (w *DataprocJobOperationWaiter) TargetStates() []string
- type DataprocOperationWaiter
Constants ¶
This section is empty.
Variables ¶
var DataprocAutoscalingPolicyIamSchema = map[string]*schema.Schema{ "project": { Type: schema.TypeString, Computed: true, Optional: true, ForceNew: true, }, "location": { Type: schema.TypeString, Computed: true, Optional: true, ForceNew: true, }, "policy_id": { Type: schema.TypeString, Required: true, ForceNew: true, DiffSuppressFunc: tpgresource.CompareSelfLinkOrResourceName, }, }
var IamDataprocClusterSchema = map[string]*schema.Schema{ "cluster": { Type: schema.TypeString, Required: true, ForceNew: true, }, "project": { Type: schema.TypeString, Optional: true, Computed: true, ForceNew: true, }, "region": { Type: schema.TypeString, Optional: true, Computed: true, ForceNew: true, }, }
var IamDataprocJobSchema = map[string]*schema.Schema{ "job_id": { Type: schema.TypeString, Required: true, ForceNew: true, }, "project": { Type: schema.TypeString, Optional: true, Computed: true, ForceNew: true, }, "region": { Type: schema.TypeString, Optional: true, Computed: true, ForceNew: true, }, }
Functions ¶
func CloudDataprocBatchRuntimeConfigVersionDiffSuppress ¶
func CloudDataprocBatchRuntimeConfigVersionDiffSuppress(_, old, new string, d *schema.ResourceData) bool
func CloudDataprocBatchRuntimeConfigVersionDiffSuppressFunc ¶
* Dataproc Batch api apends subminor version to the provided * version. We are suppressing this server generated subminor.
func DataprocAutoscalingPolicyIamUpdaterProducer ¶
func DataprocAutoscalingPolicyIamUpdaterProducer(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (tpgiamresource.ResourceIamUpdater, error)
func DataprocAutoscalingPolicyIdParseFunc ¶
func DataprocAutoscalingPolicyIdParseFunc(d *schema.ResourceData, config *transport_tpg.Config) error
func DataprocClusterIdParseFunc ¶
func DataprocClusterIdParseFunc(d *schema.ResourceData, config *transport_tpg.Config) error
func DataprocJobIdParseFunc ¶
func DataprocJobIdParseFunc(d *schema.ResourceData, config *transport_tpg.Config) error
func DataprocOperationWaitTimeWithResponse ¶
func DataprocOperationWaitTimeWithResponse(config *transport_tpg.Config, op map[string]interface{}, response *map[string]interface{}, project, activity, userAgent string, timeout time.Duration) error
nolint: deadcode,unused
func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigNodeGroupAffinitySchemaV0 ¶
func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigReservationAffinitySchema ¶
func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigReservationAffinitySchemaV0 ¶
func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigShieldedInstanceConfigSchema ¶
func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigShieldedInstanceConfigSchemaV0 ¶
func DataprocWorkflowTemplatePlacementManagedClusterConfigGkeClusterConfigNamespacedGkeDeploymentTargetSchema ¶
func DataprocWorkflowTemplatePlacementManagedClusterConfigGkeClusterConfigNamespacedGkeDeploymentTargetSchemaV0 ¶
func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigAcceleratorsSchemaV0 ¶
func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigManagedGroupConfigSchema ¶
func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigManagedGroupConfigSchemaV0 ¶
func LocationDiffSuppress ¶
func LocationDiffSuppress(k, old, new string, d *schema.ResourceData) bool
Suppress diffs for values that are equivalent except for their use of the words "location" compared to "region" or "zone"
func NewDataprocClusterUpdater ¶
func NewDataprocClusterUpdater(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (tpgiamresource.ResourceIamUpdater, error)
func NewDataprocJobUpdater ¶
func NewDataprocJobUpdater(d tpgresource.TerraformResourceData, config *transport_tpg.Config) (tpgiamresource.ResourceIamUpdater, error)
func ResourceDataprocBatch ¶
func ResourceDataprocCluster ¶
func ResourceDataprocJob ¶
Types ¶
type DataprocAutoscalingPolicyIamUpdater ¶
type DataprocAutoscalingPolicyIamUpdater struct { Config *transport_tpg.Config // contains filtered or unexported fields }
func (*DataprocAutoscalingPolicyIamUpdater) DescribeResource ¶
func (u *DataprocAutoscalingPolicyIamUpdater) DescribeResource() string
func (*DataprocAutoscalingPolicyIamUpdater) GetMutexKey ¶
func (u *DataprocAutoscalingPolicyIamUpdater) GetMutexKey() string
func (*DataprocAutoscalingPolicyIamUpdater) GetResourceIamPolicy ¶
func (u *DataprocAutoscalingPolicyIamUpdater) GetResourceIamPolicy() (*cloudresourcemanager.Policy, error)
func (*DataprocAutoscalingPolicyIamUpdater) GetResourceId ¶
func (u *DataprocAutoscalingPolicyIamUpdater) GetResourceId() string
func (*DataprocAutoscalingPolicyIamUpdater) SetResourceIamPolicy ¶
func (u *DataprocAutoscalingPolicyIamUpdater) SetResourceIamPolicy(policy *cloudresourcemanager.Policy) error
type DataprocClusterIamUpdater ¶
type DataprocClusterIamUpdater struct { Config *transport_tpg.Config // contains filtered or unexported fields }
func (*DataprocClusterIamUpdater) DescribeResource ¶
func (u *DataprocClusterIamUpdater) DescribeResource() string
func (*DataprocClusterIamUpdater) GetMutexKey ¶
func (u *DataprocClusterIamUpdater) GetMutexKey() string
func (*DataprocClusterIamUpdater) GetResourceIamPolicy ¶
func (u *DataprocClusterIamUpdater) GetResourceIamPolicy() (*cloudresourcemanager.Policy, error)
func (*DataprocClusterIamUpdater) GetResourceId ¶
func (u *DataprocClusterIamUpdater) GetResourceId() string
func (*DataprocClusterIamUpdater) SetResourceIamPolicy ¶
func (u *DataprocClusterIamUpdater) SetResourceIamPolicy(policy *cloudresourcemanager.Policy) error
type DataprocClusterOperationWaiter ¶
type DataprocClusterOperationWaiter struct { Service *dataproc.Service tpgresource.CommonOperationWaiter }
func (*DataprocClusterOperationWaiter) QueryOp ¶
func (w *DataprocClusterOperationWaiter) QueryOp() (interface{}, error)
type DataprocDeleteJobOperationWaiter ¶
type DataprocDeleteJobOperationWaiter struct {
DataprocJobOperationWaiter
}
func (*DataprocDeleteJobOperationWaiter) PendingStates ¶
func (w *DataprocDeleteJobOperationWaiter) PendingStates() []string
func (*DataprocDeleteJobOperationWaiter) QueryOp ¶
func (w *DataprocDeleteJobOperationWaiter) QueryOp() (interface{}, error)
func (*DataprocDeleteJobOperationWaiter) TargetStates ¶
func (w *DataprocDeleteJobOperationWaiter) TargetStates() []string
type DataprocJobIamUpdater ¶
type DataprocJobIamUpdater struct { Config *transport_tpg.Config // contains filtered or unexported fields }
func (*DataprocJobIamUpdater) DescribeResource ¶
func (u *DataprocJobIamUpdater) DescribeResource() string
func (*DataprocJobIamUpdater) GetMutexKey ¶
func (u *DataprocJobIamUpdater) GetMutexKey() string
func (*DataprocJobIamUpdater) GetResourceIamPolicy ¶
func (u *DataprocJobIamUpdater) GetResourceIamPolicy() (*cloudresourcemanager.Policy, error)
func (*DataprocJobIamUpdater) GetResourceId ¶
func (u *DataprocJobIamUpdater) GetResourceId() string
func (*DataprocJobIamUpdater) SetResourceIamPolicy ¶
func (u *DataprocJobIamUpdater) SetResourceIamPolicy(policy *cloudresourcemanager.Policy) error
type DataprocJobOperationWaiter ¶
type DataprocJobOperationWaiter struct { Service *dataproc.Service Region string ProjectId string JobId string Status string }
func (*DataprocJobOperationWaiter) Error ¶
func (w *DataprocJobOperationWaiter) Error() error
func (*DataprocJobOperationWaiter) IsRetryable ¶
func (w *DataprocJobOperationWaiter) IsRetryable(error) bool
func (*DataprocJobOperationWaiter) OpName ¶
func (w *DataprocJobOperationWaiter) OpName() string
func (*DataprocJobOperationWaiter) PendingStates ¶
func (w *DataprocJobOperationWaiter) PendingStates() []string
func (*DataprocJobOperationWaiter) QueryOp ¶
func (w *DataprocJobOperationWaiter) QueryOp() (interface{}, error)
func (*DataprocJobOperationWaiter) SetOp ¶
func (w *DataprocJobOperationWaiter) SetOp(job interface{}) error
func (*DataprocJobOperationWaiter) State ¶
func (w *DataprocJobOperationWaiter) State() string
func (*DataprocJobOperationWaiter) TargetStates ¶
func (w *DataprocJobOperationWaiter) TargetStates() []string
type DataprocOperationWaiter ¶
type DataprocOperationWaiter struct { Config *transport_tpg.Config UserAgent string Project string tpgresource.CommonOperationWaiter }
func (*DataprocOperationWaiter) QueryOp ¶
func (w *DataprocOperationWaiter) QueryOp() (interface{}, error)
Source Files ¶
- dataproc_cluster_operation.go
- dataproc_job_operation.go
- dataproc_operation.go
- iam_dataproc_autoscaling_policy.go
- iam_dataproc_cluster.go
- iam_dataproc_job.go
- resource_dataproc_autoscaling_policy.go
- resource_dataproc_autoscaling_policy_sweeper.go
- resource_dataproc_batch.go
- resource_dataproc_batch_sweeper.go
- resource_dataproc_cluster.go
- resource_dataproc_cluster_migrate.go
- resource_dataproc_cluster_sweeper.go
- resource_dataproc_job.go
- resource_dataproc_workflow_template.go
- resource_dataproc_workflow_template_migrate.go
- resource_dataproc_workflow_template_sweeper.go