Help us shape the future of Go! Take the 2026 Go Developer Survey

emr

package
v1.83.21 Latest Latest
Warning

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

 Go to latest Published: Aug 7, 2026 License: MPL-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EmrInternetStatusCreated int64 = 2
	EmrInternetStatusDeleted int64 = 201
)
View Source 
const (
	EMR_MASTER_WAN_TYPE_NEED_MASTER_WAN     = "NEED_MASTER_WAN"
	EMR_MASTER_WAN_TYPE_NOT_NEED_MASTER_WAN = "NOT_NEED_MASTER_WAN"
)
View Source 
const (
	F_KEY_FLOW_ID  = "FlowId"
	F_KEY_TRACE_ID = "TraceId"
)
View Source 
const (
	DisplayStrategyIsclusterList = "clusterList"
)

Variables

View Source 
var EMR_MASTER_WAN_TYPES = []string{EMR_MASTER_WAN_TYPE_NEED_MASTER_WAN, EMR_MASTER_WAN_TYPE_NOT_NEED_MASTER_WAN}

Functions

func DataSourceTencentCloudEmr 

func DataSourceTencentCloudEmr() *schema.Resource

func DataSourceTencentCloudEmrAutoScaleRecords 

func DataSourceTencentCloudEmrAutoScaleRecords() *schema.Resource

func DataSourceTencentCloudEmrCvmQuota 

func DataSourceTencentCloudEmrCvmQuota() *schema.Resource

func DataSourceTencentCloudEmrJobStatusDetail added in v1.81.169 

func DataSourceTencentCloudEmrJobStatusDetail() *schema.Resource

func DataSourceTencentCloudEmrNodes 

func DataSourceTencentCloudEmrNodes() *schema.Resource

func DataSourceTencentCloudEmrServiceNodeInfos added in v1.81.169 

func DataSourceTencentCloudEmrServiceNodeInfos() *schema.Resource

func DataSourceTencentCloudLiteHbaseInstances added in v1.81.124 

func DataSourceTencentCloudLiteHbaseInstances() *schema.Resource

func DataSourceTencentCloudServerlessHbaseInstances added in v1.81.168 

func DataSourceTencentCloudServerlessHbaseInstances() *schema.Resource

func ParseMultiDisks 

func ParseMultiDisks(_multiDisks []interface{}) []*emr.MultiDisk

func ParseResource 

func ParseResource(_resource map[string]interface{}) *emr.Resource

func ParseTags 

func ParseTags(_tags []map[string]string) []*emr.Tag

func ResourceTencentCloudEmrAutoScaleStrategy added in v1.81.169 

func ResourceTencentCloudEmrAutoScaleStrategy() *schema.Resource

func ResourceTencentCloudEmrBootScript added in v1.82.90 

func ResourceTencentCloudEmrBootScript() *schema.Resource

func ResourceTencentCloudEmrBootScriptConfig added in v1.82.90 

func ResourceTencentCloudEmrBootScriptConfig() *schema.Resource

func ResourceTencentCloudEmrCluster 

func ResourceTencentCloudEmrCluster() *schema.Resource

func ResourceTencentCloudEmrClusterV2 added in v1.82.99 

func ResourceTencentCloudEmrClusterV2() *schema.Resource

func ResourceTencentCloudEmrDeployYarnOperation added in v1.81.169 

func ResourceTencentCloudEmrDeployYarnOperation() *schema.Resource

func ResourceTencentCloudEmrUserManager 

func ResourceTencentCloudEmrUserManager() *schema.Resource

func ResourceTencentCloudEmrYarn added in v1.81.169 

func ResourceTencentCloudEmrYarn() *schema.Resource

func ResourceTencentCloudLiteHbaseInstance added in v1.81.124 

func ResourceTencentCloudLiteHbaseInstance() *schema.Resource

func ResourceTencentCloudServerlessHbaseInstance added in v1.81.150 

func ResourceTencentCloudServerlessHbaseInstance() *schema.Resource

Types

type EMRService 

type EMRService struct {
	// contains filtered or unexported fields
}

func NewEMRService 

func NewEMRService(client *connectivity.TencentCloudClient) EMRService

func (*EMRService) CreateInstance 

func (me *EMRService) CreateInstance(ctx context.Context, d *schema.ResourceData) (id string, err error)

func (*EMRService) DeleteAutoScaleStrategy added in v1.81.169 

func (me *EMRService) DeleteAutoScaleStrategy(ctx context.Context, instanceId, strategyType string, strategyId int64) error

func (*EMRService) DeleteEmrUserManagerById 

func (me *EMRService) DeleteEmrUserManagerById(ctx context.Context, instanceId string, userName string) (errRet error)

func (*EMRService) DeleteInstance 

func (me *EMRService) DeleteInstance(ctx context.Context, d *schema.ResourceData) error

func (*EMRService) DescribeClusterNodes 

func (me *EMRService) DescribeClusterNodes(ctx context.Context, instanceId, nodeFlag, hardwareResourceType string, offset, limit int) (nodes []*emr.NodeHardwareInfo, errRet error)

func (*EMRService) DescribeEmrAutoScaleRecordsByFilter 

func (me *EMRService) DescribeEmrAutoScaleRecordsByFilter(ctx context.Context, param map[string]interface{}) (autoScaleRecords []*emr.AutoScaleRecord, errRet error)

func (*EMRService) DescribeEmrAutoScaleStrategy added in v1.81.169 

func (me *EMRService) DescribeEmrAutoScaleStrategy(ctx context.Context, instanceId, name string) (ret *emr.DescribeAutoScaleStrategiesResponseParams, errRet error)

func (*EMRService) DescribeEmrAutoScaleStrategyById added in v1.81.169 

func (me *EMRService) DescribeEmrAutoScaleStrategyById(ctx context.Context, instanceId string) (ret *emr.DescribeAutoScaleStrategiesResponseParams, errRet error)

func (*EMRService) DescribeEmrBootScript added in v1.82.90 

func (me *EMRService) DescribeEmrBootScript(ctx context.Context, instanceId, bootType string) (ret *emr.DescribeBootScriptRsp, errRet error)

func (*EMRService) DescribeEmrClusterNewById added in v1.81.169 

func (me *EMRService) DescribeEmrClusterNewById(ctx context.Context, instanceId string) (ret *emr.ClusterInstancesInfo, errRet error)

func (*EMRService) DescribeEmrClusterV2ById added in v1.82.99 

func (me *EMRService) DescribeEmrClusterV2ById(ctx context.Context, instanceId string) (cluster *emr.ClusterInstancesInfo, errRet error)

DescribeEmrClusterV2ById wraps the DescribeInstances API for the new tencentcloud_emr_cluster_v2 resource. It returns the first matching cluster, or nil if no cluster is found (including when the API reports ResourceNotFound.ClusterNotFound / InstanceNotFound).

func (*EMRService) DescribeEmrClusterV2Nodes added in v1.82.99 

func (me *EMRService) DescribeEmrClusterV2Nodes(ctx context.Context, instanceId, nodeFlag string) (nodes []*emr.NodeHardwareInfo, errRet error)

DescribeEmrClusterV2Nodes paginates DescribeClusterNodes for the new tencentcloud_emr_cluster_v2 resource. nodeFlag follows the EMR API contract (e.g. "all", "master", "core", "task", "common", "router").

func (*EMRService) DescribeEmrCvmQuotaByFilter 

func (me *EMRService) DescribeEmrCvmQuotaByFilter(ctx context.Context, param map[string]interface{}) (cvmQuota *emr.DescribeCvmQuotaResponseParams, errRet error)

func (*EMRService) DescribeEmrJobStatusDetailByFilter added in v1.81.169 

func (me *EMRService) DescribeEmrJobStatusDetailByFilter(ctx context.Context, param map[string]interface{}) (ret *emr.DescribeClusterFlowStatusDetailResponseParams, errRet error)

func (*EMRService) DescribeEmrNodeDataDisks added in v1.82.99 

func (me *EMRService) DescribeEmrNodeDataDisks(ctx context.Context, clusterId, instanceId string) (cbsList []*emr.CBSInstance, errRet error)

func (*EMRService) DescribeEmrServiceNodeInfosByFilter added in v1.81.169 

func (me *EMRService) DescribeEmrServiceNodeInfosByFilter(ctx context.Context, param map[string]interface{}) (ret *emr.DescribeServiceNodeInfosResponseParams, errRet error)

func (*EMRService) DescribeEmrUserManagerById 

func (me *EMRService) DescribeEmrUserManagerById(ctx context.Context, instanceId string, userName string) (userManager *emr.DescribeUsersForUserManagerResponseParams, errRet error)

func (*EMRService) DescribeEmrYarnById added in v1.81.169 

func (me *EMRService) DescribeEmrYarnById(ctx context.Context, instanceId string) (ret *emr.DescribeGlobalConfigResponseParams, errRet error)

func (*EMRService) DescribeInstances 

func (me *EMRService) DescribeInstances(ctx context.Context, filters map[string]interface{}) (clusters []*emr.ClusterInstancesInfo, errRet error)

func (*EMRService) DescribeInstancesById 

func (me *EMRService) DescribeInstancesById(ctx context.Context, instanceId string, displayStrategy string) (clusters []*emr.ClusterInstancesInfo, errRet error)

func (*EMRService) DescribeLiteHbaseInstancesByFilter added in v1.81.124 

func (me *EMRService) DescribeLiteHbaseInstancesByFilter(ctx context.Context, param map[string]interface{}) (instances []*emr.SLInstanceInfo, errRet error)

func (*EMRService) FlowStatusRefreshFunc added in v1.81.135 

func (me *EMRService) FlowStatusRefreshFunc(instanceId, flowId, flowType string, failStates []string) resource.StateRefreshFunc

func (*EMRService) GetSLInstanceStatus added in v1.81.124 

func (me *EMRService) GetSLInstanceStatus(ctx context.Context, instanceId string) (instanceInfo *emr.SLInstanceInfo, errRet error)

func (*EMRService) ModifyResourcesTags 

func (me *EMRService) ModifyResourcesTags(ctx context.Context, region string, instanceId string, oldTags, newTags map[string]interface{}) error

func (*EMRService) SLInstanceStateRefreshFunc added in v1.81.124 

func (me *EMRService) SLInstanceStateRefreshFunc(instanceId string, failStates []string) resource.StateRefreshFunc

func (*EMRService) ScaleOutInstance added in v1.81.135 

func (me *EMRService) ScaleOutInstance(ctx context.Context, request *emr.ScaleOutInstanceRequest) (traceId string, err error)

func (*EMRService) TerminateClusterNodes added in v1.81.135 

func (me *EMRService) TerminateClusterNodes(ctx context.Context, instanceIds []string, instanceId, nodeFlag string) (flowId int64, errRet error)

func (*EMRService) TerminateInstance added in v1.81.169 

func (me *EMRService) TerminateInstance(ctx context.Context, instanceId string) error

func (*EMRService) UpdateInstance 

func (me *EMRService) UpdateInstance(ctx context.Context, request *emr.ScaleOutInstanceRequest) (id string, err error)

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.