dataproc

package
v0.0.0-...-7000f67 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 6, 2023 License: MPL-2.0 Imports: 25 Imported by: 0

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

Index

Constants

This section is empty.

Variables

View Source 
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,
	},
}
View Source 
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,
	},
}
View Source 
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 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 DataprocClusterOperationWait 

func DataprocClusterOperationWait(config *transport_tpg.Config, op *dataproc.Operation, activity, userAgent string, timeout time.Duration) error

func DataprocDeleteOperationWait 

func DataprocDeleteOperationWait(config *transport_tpg.Config, region, projectId, jobId, activity, userAgent string, timeout time.Duration) error

func DataprocJobIdParseFunc 

func DataprocJobIdParseFunc(d *schema.ResourceData, config *transport_tpg.Config) error

func DataprocJobOperationWait 

func DataprocJobOperationWait(config *transport_tpg.Config, region, projectId, jobId, activity, userAgent string, timeout time.Duration) error

func DataprocWorkflowTemplateJobsHadoopJobLoggingConfigSchema 

func DataprocWorkflowTemplateJobsHadoopJobLoggingConfigSchema() *schema.Resource

func DataprocWorkflowTemplateJobsHadoopJobSchema 

func DataprocWorkflowTemplateJobsHadoopJobSchema() *schema.Resource

func DataprocWorkflowTemplateJobsHiveJobQueryListSchema 

func DataprocWorkflowTemplateJobsHiveJobQueryListSchema() *schema.Resource

func DataprocWorkflowTemplateJobsHiveJobSchema 

func DataprocWorkflowTemplateJobsHiveJobSchema() *schema.Resource

func DataprocWorkflowTemplateJobsPigJobLoggingConfigSchema 

func DataprocWorkflowTemplateJobsPigJobLoggingConfigSchema() *schema.Resource

func DataprocWorkflowTemplateJobsPigJobQueryListSchema 

func DataprocWorkflowTemplateJobsPigJobQueryListSchema() *schema.Resource

func DataprocWorkflowTemplateJobsPigJobSchema 

func DataprocWorkflowTemplateJobsPigJobSchema() *schema.Resource

func DataprocWorkflowTemplateJobsPrestoJobLoggingConfigSchema 

func DataprocWorkflowTemplateJobsPrestoJobLoggingConfigSchema() *schema.Resource

func DataprocWorkflowTemplateJobsPrestoJobQueryListSchema 

func DataprocWorkflowTemplateJobsPrestoJobQueryListSchema() *schema.Resource

func DataprocWorkflowTemplateJobsPrestoJobSchema 

func DataprocWorkflowTemplateJobsPrestoJobSchema() *schema.Resource

func DataprocWorkflowTemplateJobsPysparkJobLoggingConfigSchema 

func DataprocWorkflowTemplateJobsPysparkJobLoggingConfigSchema() *schema.Resource

func DataprocWorkflowTemplateJobsPysparkJobSchema 

func DataprocWorkflowTemplateJobsPysparkJobSchema() *schema.Resource

func DataprocWorkflowTemplateJobsSchedulingSchema 

func DataprocWorkflowTemplateJobsSchedulingSchema() *schema.Resource

func DataprocWorkflowTemplateJobsSchema 

func DataprocWorkflowTemplateJobsSchema() *schema.Resource

func DataprocWorkflowTemplateJobsSparkJobLoggingConfigSchema 

func DataprocWorkflowTemplateJobsSparkJobLoggingConfigSchema() *schema.Resource

func DataprocWorkflowTemplateJobsSparkJobSchema 

func DataprocWorkflowTemplateJobsSparkJobSchema() *schema.Resource

func DataprocWorkflowTemplateJobsSparkRJobLoggingConfigSchema 

func DataprocWorkflowTemplateJobsSparkRJobLoggingConfigSchema() *schema.Resource

func DataprocWorkflowTemplateJobsSparkRJobSchema 

func DataprocWorkflowTemplateJobsSparkRJobSchema() *schema.Resource

func DataprocWorkflowTemplateJobsSparkSqlJobLoggingConfigSchema 

func DataprocWorkflowTemplateJobsSparkSqlJobLoggingConfigSchema() *schema.Resource

func DataprocWorkflowTemplateJobsSparkSqlJobQueryListSchema 

func DataprocWorkflowTemplateJobsSparkSqlJobQueryListSchema() *schema.Resource

func DataprocWorkflowTemplateJobsSparkSqlJobSchema 

func DataprocWorkflowTemplateJobsSparkSqlJobSchema() *schema.Resource

func DataprocWorkflowTemplateParametersSchema 

func DataprocWorkflowTemplateParametersSchema() *schema.Resource

func DataprocWorkflowTemplateParametersValidationRegexSchema 

func DataprocWorkflowTemplateParametersValidationRegexSchema() *schema.Resource

func DataprocWorkflowTemplateParametersValidationSchema 

func DataprocWorkflowTemplateParametersValidationSchema() *schema.Resource

func DataprocWorkflowTemplateParametersValidationValuesSchema 

func DataprocWorkflowTemplateParametersValidationValuesSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementClusterSelectorSchema 

func DataprocWorkflowTemplatePlacementClusterSelectorSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigAutoscalingConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigAutoscalingConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigEncryptionConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigEncryptionConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigEndpointConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigEndpointConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigNodeGroupAffinitySchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigNodeGroupAffinitySchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigReservationAffinitySchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigReservationAffinitySchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigShieldedInstanceConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigGceClusterConfigShieldedInstanceConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigGkeClusterConfigNamespacedGkeDeploymentTargetSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigGkeClusterConfigNamespacedGkeDeploymentTargetSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigGkeClusterConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigGkeClusterConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigInitializationActionsSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigInitializationActionsSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigLifecycleConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigLifecycleConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigAcceleratorsSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigAcceleratorsSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigDiskConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigDiskConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigManagedGroupConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigManagedGroupConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigMasterConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigMetastoreConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigMetastoreConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigAcceleratorsSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigAcceleratorsSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigDiskConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigDiskConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigManagedGroupConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigManagedGroupConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigSecondaryWorkerConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigSecurityConfigKerberosConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigSecurityConfigKerberosConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigSecurityConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigSecurityConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigSoftwareConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigSoftwareConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigAcceleratorsSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigAcceleratorsSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigDiskConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigDiskConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigManagedGroupConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigManagedGroupConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigSchema 

func DataprocWorkflowTemplatePlacementManagedClusterConfigWorkerConfigSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementManagedClusterSchema 

func DataprocWorkflowTemplatePlacementManagedClusterSchema() *schema.Resource

func DataprocWorkflowTemplatePlacementSchema 

func DataprocWorkflowTemplatePlacementSchema() *schema.Resource

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 ResourceDataprocAutoscalingPolicy 

func ResourceDataprocAutoscalingPolicy() *schema.Resource

func ResourceDataprocCluster 

func ResourceDataprocCluster() *schema.Resource

func ResourceDataprocJob 

func ResourceDataprocJob() *schema.Resource

func ResourceDataprocWorkflowTemplate 

func ResourceDataprocWorkflowTemplate() *schema.Resource

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.