emr

package
v1.81.139 Latest Latest
Warning

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

 Go to latest Published: Nov 8, 2024 License: MPL-2.0 Imports: 18 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 DataSourceTencentCloudEmrNodes 

func DataSourceTencentCloudEmrNodes() *schema.Resource

func DataSourceTencentCloudLiteHbaseInstances added in v1.81.124 

func DataSourceTencentCloudLiteHbaseInstances() *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 ResourceTencentCloudEmrCluster 

func ResourceTencentCloudEmrCluster() *schema.Resource

func ResourceTencentCloudEmrUserManager 

func ResourceTencentCloudEmrUserManager() *schema.Resource

func ResourceTencentCloudLiteHbaseInstance added in v1.81.124 

func ResourceTencentCloudLiteHbaseInstance() *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) 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) DescribeEmrCvmQuotaByFilter 

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

func (*EMRService) DescribeEmrUserManagerById 

func (me *EMRService) DescribeEmrUserManagerById(ctx context.Context, instanceId string, userName string) (userManager *emr.DescribeUsersForUserManagerResponseParams, 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) 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.