emr

package
v0.0.0-...-0b043e4 Latest Latest
Warning

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

 Go to latest Published: Nov 23, 2015 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Product = "Emr"
	Style   = "RPC"
	Version = "2015-09-10"
)

Variables

This section is empty.

Functions

func NewParams 

func NewParams() openapi.Params

Types

type API 

type API struct {
	openapi.Service
}

func New 

func New(accessKeyId, accessKeySecret string) API

func (API) CreateCluster 

func (api API) CreateCluster(ClusterType, EcsOrder, EmrRole4ECS, EmrRole4Oss, EmrVer, Name string, PayType int, optional openapi.M) (*openapi.Response, error)

CreateCluster version 2015-09-10

required parameters: 

name: ClusterType, type: string
name: EcsOrder, type: string
name: EmrRole4ECS, type: string
name: EmrRole4Oss, type: string
name: EmrVer, type: string
name: Name, type: string
name: PayType, type: int, optional values: 1|2

optional parameters: 

name: Install, type: string
name: IsOpenPublicIp, type: bool
name: LogEnable, type: bool
name: LogPath, type: string
name: MasterIndex, type: int
name: Period, type: int
name: SecurityGroup, type: string
name: SecurityGroupName, type: string
name: ZoneId, type: string
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) CreateExecutePlan 

func (api API) CreateExecutePlan(JobId string, optional openapi.M) (*CreateExecutePlanResponse, error)

CreateExecutePlan version 2015-09-10

required parameters: 

name: JobId, type: string

optional parameters: 

name: ClusterId, type: int64
name: Name, type: string
name: StartTime, type: string
name: Strategy, type: int
name: TimeInterval, type: int
name: TimeUnit, type: string
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) CreateExecutePlanWithCluster 

func (api API) CreateExecutePlanWithCluster(ClusterName, ClusterType, EcsOrder, EmrRole4ECS, EmrRole4Oss, EmrVer, JobId string, PayType int, optional openapi.M) (*openapi.Response, error)

CreateExecutePlanWithCluster version 2015-09-10

required parameters: 

name: ClusterName, type: string
name: ClusterType, type: string
name: EcsOrder, type: string
name: EmrRole4ECS, type: string
name: EmrRole4Oss, type: string
name: EmrVer, type: string
name: JobId, type: string
name: PayType, type: int, optional values: 1|2

optional parameters: 

name: Install, type: string
name: IsOpenPublicIp, type: bool
name: LogEnable, type: bool
name: LogPath, type: string
name: MasterIndex, type: int
name: Name, type: string
name: Period, type: int
name: SecurityGroup, type: string
name: SecurityGroupName, type: string
name: StartTime, type: string
name: Strategy, type: int
name: TimeInterval, type: int
name: TimeUnit, type: string
name: ZoneId, type: string
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) CreateJob 

func (api API) CreateJob(JobFailAct int, JobType, Parameter string, optional openapi.M) (*CreateJobResponse, error)

CreateJob version 2015-09-10

required parameters: 

name: JobFailAct, type: int
name: JobType, type: string
name: Parameter, type: string

optional parameters: 

name: JobName, type: string
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) DeleteExecutePlan 

func (api API) DeleteExecutePlan(optional openapi.M) (*openapi.Response, error)

DeleteExecutePlan version 2015-09-10

optional parameters: 

name: Id, type: int64, min value: 1
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) DeleteJob 

func (api API) DeleteJob(Id int64, optional openapi.M) (*openapi.Response, error)

DeleteJob version 2015-09-10

required parameters: 

name: Id, type: int64, min value: 1

optional parameters: 

name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) DescribeCluster 

func (api API) DescribeCluster(ClusterId int64, optional openapi.M) (*DescribeClusterResponse, error)

DescribeCluster version 2015-09-10

required parameters: 

name: ClusterId, type: int64, min value: 1

optional parameters: 

name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) DescribeExecutePlan 

func (api API) DescribeExecutePlan(Id int64, optional openapi.M) (*DescribeExecutePlanResponse, error)

DescribeExecutePlan version 2015-09-10

required parameters: 

name: Id, type: int64, min value: 1

optional parameters: 

name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) DescribeJob 

func (api API) DescribeJob(Id int64, optional openapi.M) (*DescribeJobResponse, error)

DescribeJob version 2015-09-10

required parameters: 

name: Id, type: int64, min value: 1

optional parameters: 

name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) JobResource 

func (api API) JobResource(Bucket string, optional openapi.M) (*JobResourceResponse, error)

JobResource version 2015-09-10

required parameters: 

name: Bucket, type: string

optional parameters: 

name: Path, type: string
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) KillExecutePlanRecordNode 

func (api API) KillExecutePlanRecordNode(ExecutePlanRecordNodeId int64, optional openapi.M) (*openapi.Response, error)

KillExecutePlanRecordNode version 2015-09-10

required parameters: 

name: ExecutePlanRecordNodeId, type: int64, min value: 1

optional parameters: 

name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ListClusters 

func (api API) ListClusters(optional openapi.M) (*ListClustersResponse, error)

ListClusters version 2015-09-10

optional parameters: 

name: ClusterType, type: string
name: IsDesc, type: bool
name: PageNumber, type: int, min value: 1
name: PageSize, type: int, min value: 1, max value: 500
name: PayType, type: string
name: Status, type: string
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ListConfigType 

func (api API) ListConfigType(optional openapi.M) (*ListConfigTypeResponse, error)

ListConfigType version 2015-09-10

optional parameters: 

name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ListExecutePlanExecuteRecordNodes 

func (api API) ListExecutePlanExecuteRecordNodes(optional openapi.M) (*ListExecutePlanExecuteRecordNodesResponse, error)

ListExecutePlanExecuteRecordNodes version 2015-09-10

optional parameters: 

name: ExecutePlanExecRecordId, type: int64
name: IsDesc, type: bool
name: PageNumber, type: int
name: PageSize, type: int, max value: 500
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ListExecutePlanExecuteRecords 

func (api API) ListExecutePlanExecuteRecords(ExecutePlanId int64, optional openapi.M) (*ListExecutePlanExecuteRecordsResponse, error)

ListExecutePlanExecuteRecords version 2015-09-10

required parameters: 

name: ExecutePlanId, type: int64

optional parameters: 

name: IsDesc, type: bool
name: PageNumber, type: int
name: PageSize, type: int, max value: 500
name: Status, type: string
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ListExecutePlanJobs 

func (api API) ListExecutePlanJobs(optional openapi.M) (*ListExecutePlanJobsResponse, error)

ListExecutePlanJobs version 2015-09-10

optional parameters: 

name: ExecutePlanExecRecordId, type: string
name: ExecutePlanExecuteNodeId, type: string
name: IsDesc, type: bool
name: PageNumber, type: int
name: PageSize, type: int, max value: 50
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ListExecutePlanNodeInstances 

func (api API) ListExecutePlanNodeInstances(ExecutePlanWorkNodeId int64, optional openapi.M) (*ListExecutePlanNodeInstancesResponse, error)

ListExecutePlanNodeInstances version 2015-09-10

required parameters: 

name: ExecutePlanWorkNodeId, type: int64

optional parameters: 

name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ListExecutePlans 

func (api API) ListExecutePlans(optional openapi.M) (*ListExecutePlansResponse, error)

ListExecutePlans version 2015-09-10

optional parameters: 

name: IsDesc, type: bool
name: PageNumber, type: int
name: PageSize, type: int, max value: 500
name: Status, type: string
name: Strategy, type: int
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ListJobs 

func (api API) ListJobs(optional openapi.M) (*ListJobsResponse, error)

ListJobs version 2015-09-10

optional parameters: 

name: IsDesc, type: bool
name: PageNumber, type: int
name: PageSize, type: int, max value: 500
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ListRegions 

func (api API) ListRegions(optional openapi.M) (*ListRegionsResponse, error)

ListRegions version 2015-09-10

optional parameters: 

name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ModifyClusterName 

func (api API) ModifyClusterName(ClusterId int64, ClusterName string, optional openapi.M) (*openapi.Response, error)

ModifyClusterName version 2015-09-10

required parameters: 

name: ClusterId, type: int64, min value: 1
name: ClusterName, type: string

optional parameters: 

name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ModifyExecutePlan 

func (api API) ModifyExecutePlan(JobId string, optional openapi.M) (*ModifyExecutePlanResponse, error)

ModifyExecutePlan version 2015-09-10

required parameters: 

name: JobId, type: string

optional parameters: 

name: ClusterId, type: int64
name: ExecutePlanId, type: int64
name: Name, type: string
name: StartTime, type: string
name: Strategy, type: int
name: TimeInterval, type: int
name: TimeUnit, type: string
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ModifyExecutePlanWithCluster 

func (api API) ModifyExecutePlanWithCluster(ClusterName, ClusterType, EcsOrder, EmrRole4ECS, EmrRole4Oss, EmrVer, JobId string, PayType int, optional openapi.M) (*openapi.Response, error)

ModifyExecutePlanWithCluster version 2015-09-10

required parameters: 

name: ClusterName, type: string
name: ClusterType, type: string
name: EcsOrder, type: string
name: EmrRole4ECS, type: string
name: EmrRole4Oss, type: string
name: EmrVer, type: string
name: JobId, type: string
name: PayType, type: int, optional values: 1|2

optional parameters: 

name: ExecutePlanId, type: int64
name: Install, type: string
name: IsOpenPublicIp, type: bool
name: LogEnable, type: bool
name: LogPath, type: string
name: MasterIndex, type: int
name: Name, type: string
name: Period, type: int
name: SecurityGroup, type: string
name: SecurityGroupName, type: string
name: StartTime, type: string
name: Strategy, type: int
name: TimeInterval, type: int
name: TimeUnit, type: string
name: ZoneId, type: string
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ModifyJob 

func (api API) ModifyJob(Id int64, optional openapi.M) (*openapi.Response, error)

ModifyJob version 2015-09-10

required parameters: 

name: Id, type: int64, min value: 1

optional parameters: 

name: EnvParameter, type: string
name: FailAct, type: int
name: Name, type: string
name: Type, type: string
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ReleaseCluster 

func (api API) ReleaseCluster(ClusterId int64, optional openapi.M) (*openapi.Response, error)

ReleaseCluster version 2015-09-10

required parameters: 

name: ClusterId, type: int64, min value: 1

optional parameters: 

name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) ResumeExecutePlan 

func (api API) ResumeExecutePlan(optional openapi.M) (*openapi.Response, error)

ResumeExecutePlan version 2015-09-10

optional parameters: 

name: Id, type: int64, min value: 1
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) RunExecutePlan 

func (api API) RunExecutePlan(optional openapi.M) (*openapi.Response, error)

RunExecutePlan version 2015-09-10

optional parameters: 

name: ExecutePlanId, type: int64, min value: 1
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

func (API) StopExecutePlan 

func (api API) StopExecutePlan(optional openapi.M) (*openapi.Response, error)

StopExecutePlan version 2015-09-10

optional parameters: 

name: Id, type: int64, min value: 1
name: _method, type: string, optional values: GET|POST
name: _region, type: string
name: _scheme, type: string, optional values: http|https

type CreateExecutePlanResponse 

type CreateExecutePlanResponse struct {
	Id int64
}

CreateExecutePlanResponse represents the response of the api CreateExecutePlan.

type CreateJobResponse 

type CreateJobResponse struct {
	Id int64
}

CreateJobResponse represents the response of the api CreateJob.

type DescribeClusterResponse 

type DescribeClusterResponse struct {
	ClusterInfo struct {
		BizId             string
		ClusterId         int64
		ClusterName       string
		EmrRole4ECS       string
		EmrRole4Oss       string
		FailReason        string
		IsOpenOssLog      bool
		IsOpenPublicIp    bool
		LastJobStatus     int
		OssPath           string
		ReleaseSetting    int
		RunningTime       int
		Status            int
		TimeOutEnable     int
		TimeOutOperate    int
		TimeOutTime       string
		TimeOutWarningWay int
		UtcStartTime      string
		UtcStopTime       string
	}
	EcsInfo struct {
		EcsRoles struct {
			EcsRole []struct {
				BandWidth      string
				CpuCore        string
				DiskCapacity   int
				DiskType       int
				EcsPayType     string
				InstanceType   string
				IsMaster       bool
				MemoryCapacity string
				NetPayType     string
				Nodes          struct {
					Node []struct {
						DiskInfo   string
						InnerIp    string
						InstanceId string
						PubIp      string
					}
				}
				Payment string
			}
		}
		ImageId         string
		ImageName       string
		MasterCount     int
		RegionId        string
		SecurityGroupId string
		SlaveCount      int
		SparkVersion    string
		TotalCount      int
		ZoneId          string
	}
	SoftwareInfo struct {
		ClusterType string
		EmrVer      string
		Softwares   string
	}
}

DescribeClusterResponse represents the response of the api DescribeCluster.

type DescribeExecutePlanResponse 

type DescribeExecutePlanResponse struct {
	ClusterInfo struct {
		BizId             string
		ClusterId         int64
		ClusterName       string
		EmrRole4ECS       string
		EmrRole4Oss       string
		FailReason        string
		IsOpenOssLog      bool
		IsOpenPublicIp    bool
		LastJobStatus     int
		OssPath           string
		ReleaseSetting    int
		RunningTime       int
		Status            int
		TimeOutEnable     int
		TimeOutOperate    int
		TimeOutTime       string
		TimeOutWarningWay int
		UtcStartTime      string
		UtcStopTime       string
	}
	EcsInfo struct {
		EcsRoles struct {
			EcsRole []struct {
				BandWidth      string
				CpuCore        string
				DiskCapacity   int
				DiskType       int
				EcsPayType     string
				InstanceType   string
				IsMaster       bool
				MemoryCapacity string
				NetPayType     string
				Nodes          struct {
					Node []struct {
						DiskInfo   string
						InnerIp    string
						InstanceId string
						PubIp      string
					}
				}
				Payment string
			}
		}
		ImageId         string
		ImageName       string
		MasterCount     int
		RegionId        string
		SecurityGroupId string
		SlaveCount      int
		SparkVersion    string
		TotalCount      int
		ZoneId          string
	}
	Id              int64
	IsCreateCluster bool
	JobInfos        struct {
		JobInfo []struct {
			Id int64
		}
	}
	Name         string
	SoftwareInfo struct {
		ClusterType string
		EmrVer      string
		Softwares   string
	}
	StartTime    string
	Strategy     int
	TimeInterval int
	TimeUnit     string
}

DescribeExecutePlanResponse represents the response of the api DescribeExecutePlan.

type DescribeJobResponse 

type DescribeJobResponse struct {
	EnvParam string
	FailAct  int
	Id       int64
	Name     string
	Type     int
}

DescribeJobResponse represents the response of the api DescribeJob.

type JobResourceResponse 

type JobResourceResponse struct {
	JobResourceInfoList struct {
		JobResourceInfo []struct {
			Filename string
			Region   string
			Size     int64
			Type     int
		}
	}
}

JobResourceResponse represents the response of the api JobResource.

type ListClustersResponse 

type ListClustersResponse struct {
	Clusters struct {
		ClusterInfo []struct {
			CreateTime  string
			FailReason  string
			Id          int64
			Name        string
			PayType     int
			RunningTime string
			Status      int
			Type        int
		}
	}
	PageNumber int
	PageSize   int
	TotalCount int
}

ListClustersResponse represents the response of the api ListClusters.

type ListConfigTypeResponse 

type ListConfigTypeResponse struct {
	EmrVerTypes struct {
		EmrVerType []struct {
			Name       string
			SubModules struct {
				SubModule []struct {
					Name     string
					Optional string
					Required string
				}
			}
		}
	}
	InstanceTypes struct {
		InstanceType []struct {
			Classify     string
			CpuCore      string
			HasCloudDisk bool
			HasCloudSSD  bool
			HasLocalDisk bool
			HasLocalSSD  bool
			MemSize      string
			State        string
			Type         string
		}
	} `json:"instanceTypes" xml:"instanceTypes"`
	SecurityGroupTypes struct {
		SecurityGroupType []struct {
			Id    string
			Name  string
			State string
		}
	} `json:"securityGroupTypes" xml:"securityGroupTypes"`
	ZoneTypes struct {
		ZoneType []struct {
			Id   string
			Name string
		}
	}
}

ListConfigTypeResponse represents the response of the api ListConfigType.

type ListExecutePlanExecuteRecordNodesResponse 

type ListExecutePlanExecuteRecordNodesResponse struct {
	ExecutePlanNode struct {
		ExecutePlanNodeInfo []struct {
			ClusterId    int64
			JobId        int64
			JobType      int
			RunTime      int64
			StartTime    string
			Status       int
			WorkNodeId   string
			WorkNodeName string
		}
	} `json:"executePlanNode" xml:"executePlanNode"`
	PageNumber int
	PageSize   int
	TotalCount int
}

ListExecutePlanExecuteRecordNodesResponse represents the response of the api ListExecutePlanExecuteRecordNodes.

type ListExecutePlanExecuteRecordsResponse 

type ListExecutePlanExecuteRecordsResponse struct {
	ExecutePlanExecRecord struct {
		ExecutePlanRecordInfo []struct {
			ClusterId       int64
			ClusterName     string
			ClusterType     int
			ExecutePlanId   int64
			ExecutePlanName string
			Id              int64
			LogEnable       bool
			LogPath         string
			RunTime         int64
			StartTime       string
			Status          int
		}
	}
	PageNumber int
	PageSize   int
	TotalCount int
}

ListExecutePlanExecuteRecordsResponse represents the response of the api ListExecutePlanExecuteRecords.

type ListExecutePlanJobsResponse 

type ListExecutePlanJobsResponse struct {
	ExecutePlanJobs struct {
		ExecutePlanJobInfo []struct {
			ClusterName   string
			Id            string `json:"id" xml:"id"`
			IsMaster      string `json:"isMaster" xml:"isMaster"`
			LastRunStatus string
			RunTime       string
			Status        string
		}
	}
	PageNumber int
	PageSize   int
	TotalCount int
}

ListExecutePlanJobsResponse represents the response of the api ListExecutePlanJobs.

type ListExecutePlanNodeInstancesResponse 

type ListExecutePlanNodeInstancesResponse struct {
	ExecutePlanNodeInstance struct {
		ExecutePlanNodeInstanceInfo []struct {
			ApplicationId string
			ContainerInfo string
			InstanceInfo  string
		}
	}
}

ListExecutePlanNodeInstancesResponse represents the response of the api ListExecutePlanNodeInstances.

type ListExecutePlansResponse 

type ListExecutePlansResponse struct {
	ExecutePlans struct {
		ExecutePlanInfo []struct {
			ClusterName     string
			Id              int64
			IsCreateCluster bool
			LastRunStatus   string
			Name            string
			RunTime         int64
			StartTime       string
			Status          string
			Stragety        int
			TimeInterval    int
			TimeUnit        string
		}
	}
	PageNumber int
	PageSize   int
	TotalCount int
}

ListExecutePlansResponse represents the response of the api ListExecutePlans.

type ListJobsResponse 

type ListJobsResponse struct {
	Jobs struct {
		JobInfo []struct {
			EnvConfig  string
			JobFailAct int
			JobId      int64
			JobName    string
			JobType    int
		}
	}
	PageNumber int
	PageSize   int
	TotalCount int
}

ListJobsResponse represents the response of the api ListJobs.

type ListRegionsResponse 

type ListRegionsResponse struct {
	RegionTypes struct {
		RegionType []struct {
			AsUrl string
			Id    string
			Name  string
		}
	}
}

ListRegionsResponse represents the response of the api ListRegions.

type ModifyExecutePlanResponse 

type ModifyExecutePlanResponse struct {
	ExecutePlanId int64
}

ModifyExecutePlanResponse represents the response of the api ModifyExecutePlan.

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.