client

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Dec 28, 2018 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type JmrClient 

type JmrClient struct {
	core.JDCloudClient
}

func NewJmrClient 

func NewJmrClient(credential *core.Credential) *JmrClient

func (*JmrClient) CalculateClusterPrice added in v1.0.9 

func (c *JmrClient) CalculateClusterPrice(request *jmr.CalculateClusterPriceRequest) (*jmr.CalculateClusterPriceResponse, error)

计算集群价格

func (*JmrClient) CalculateExpansionPrice added in v1.0.9 

func (c *JmrClient) CalculateExpansionPrice(request *jmr.CalculateExpansionPriceRequest) (*jmr.CalculateExpansionPriceResponse, error)

计算集群扩容的价格

func (*JmrClient) ClusterExpansion added in v1.0.9 

func (c *JmrClient) ClusterExpansion(request *jmr.ClusterExpansionRequest) (*jmr.ClusterExpansionResponse, error)

集群扩容

func (*JmrClient) CreateAndExcuteJob added in v1.0.9 

func (c *JmrClient) CreateAndExcuteJob(request *jmr.CreateAndExcuteJobRequest) (*jmr.CreateAndExcuteJobResponse, error)

创建作业并执行

func (*JmrClient) CreateClusterInNewNetwork 

func (c *JmrClient) CreateClusterInNewNetwork(request *jmr.CreateClusterInNewNetworkRequest) (*jmr.CreateClusterInNewNetworkResponse, error)

创建新集群

func (*JmrClient) CreateCronJob added in v1.0.9 

func (c *JmrClient) CreateCronJob(request *jmr.CreateCronJobRequest) (*jmr.CreateCronJobResponse, error)

新建或更新调度配置

func (*JmrClient) CreateJob added in v1.0.9 

func (c *JmrClient) CreateJob(request *jmr.CreateJobRequest) (*jmr.CreateJobResponse, error)

创建作业

func (*JmrClient) DeleteCluster added in v1.0.9 

func (c *JmrClient) DeleteCluster(request *jmr.DeleteClusterRequest) (*jmr.DeleteClusterResponse, error)

逻辑删除

func (*JmrClient) DeleteCronJob added in v1.0.9 

func (c *JmrClient) DeleteCronJob(request *jmr.DeleteCronJobRequest) (*jmr.DeleteCronJobResponse, error)

删除定时任务

func (*JmrClient) DeleteHdfsFile added in v1.0.9 

func (c *JmrClient) DeleteHdfsFile(request *jmr.DeleteHdfsFileRequest) (*jmr.DeleteHdfsFileResponse, error)

删除集群的hdfs文件

func (*JmrClient) DeleteJob added in v1.0.9 

func (c *JmrClient) DeleteJob(request *jmr.DeleteJobRequest) (*jmr.DeleteJobResponse, error)

删除作业

func (*JmrClient) DeleteWorkFlow added in v1.0.9 

func (c *JmrClient) DeleteWorkFlow(request *jmr.DeleteWorkFlowRequest) (*jmr.DeleteWorkFlowResponse, error)

删除工作流

func (*JmrClient) DeleteWorkFlowTracker added in v1.0.9 

func (c *JmrClient) DeleteWorkFlowTracker(request *jmr.DeleteWorkFlowTrackerRequest) (*jmr.DeleteWorkFlowTrackerResponse, error)

删除运行记录

func (*JmrClient) ExecuteJob added in v1.0.9 

func (c *JmrClient) ExecuteJob(request *jmr.ExecuteJobRequest) (*jmr.ExecuteJobResponse, error)

执行task

func (*JmrClient) GetAccessKeys added in v1.0.9 

func (c *JmrClient) GetAccessKeys(request *jmr.GetAccessKeysRequest) (*jmr.GetAccessKeysResponse, error)

根据userpin获取accessKey和accessKeySecret

func (*JmrClient) GetAvaliableNum added in v1.0.9 

func (c *JmrClient) GetAvaliableNum(request *jmr.GetAvaliableNumRequest) (*jmr.GetAvaliableNumResponse, error)

获取剩余可创建资源数

func (*JmrClient) GetClusterCronJobCount added in v1.0.9 

func (c *JmrClient) GetClusterCronJobCount(request *jmr.GetClusterCronJobCountRequest) (*jmr.GetClusterCronJobCountResponse, error)

获取集群的部署作业数

func (*JmrClient) GetClusterDetailInfo added in v1.0.9 

func (c *JmrClient) GetClusterDetailInfo(request *jmr.GetClusterDetailInfoRequest) (*jmr.GetClusterDetailInfoResponse, error)

集群扩容时，显示集群details

func (*JmrClient) GetClusterJobCount added in v1.0.9 

func (c *JmrClient) GetClusterJobCount(request *jmr.GetClusterJobCountRequest) (*jmr.GetClusterJobCountResponse, error)

获取集群的作业数

func (*JmrClient) GetCronJobDetail added in v1.0.9 

func (c *JmrClient) GetCronJobDetail(request *jmr.GetCronJobDetailRequest) (*jmr.GetCronJobDetailResponse, error)

获取定时任务详情

func (*JmrClient) GetCronJobList added in v1.0.9 

func (c *JmrClient) GetCronJobList(request *jmr.GetCronJobListRequest) (*jmr.GetCronJobListResponse, error)

获取执行计划列表

func (*JmrClient) GetCronJobTaskList added in v1.0.9 

func (c *JmrClient) GetCronJobTaskList(request *jmr.GetCronJobTaskListRequest) (*jmr.GetCronJobTaskListResponse, error)

获取定时任务的运行记录

func (*JmrClient) GetCronJobTaskListByJobId added in v1.0.9 

func (c *JmrClient) GetCronJobTaskListByJobId(request *jmr.GetCronJobTaskListByJobIdRequest) (*jmr.GetCronJobTaskListByJobIdResponse, error)

查询某一执行计划的某一个job的运行记录

func (*JmrClient) GetFirstServerVncUrl added in v1.0.9 

func (c *JmrClient) GetFirstServerVncUrl(request *jmr.GetFirstServerVncUrlRequest) (*jmr.GetFirstServerVncUrlResponse, error)

通过clusterId得到远程连接集群主节点的VNC URL

func (*JmrClient) GetHardwareStack added in v1.0.9 

func (c *JmrClient) GetHardwareStack(request *jmr.GetHardwareStackRequest) (*jmr.GetHardwareStackResponse, error)

硬件配置信息列表

func (*JmrClient) GetInstanceList added in v1.0.9 

func (c *JmrClient) GetInstanceList(request *jmr.GetInstanceListRequest) (*jmr.GetInstanceListResponse, error)

获取主机规格列表(过滤掉低内存的规格, 低于4核全部去掉。)

func (*JmrClient) GetJmrVersionList added in v1.0.9 

func (c *JmrClient) GetJmrVersionList(request *jmr.GetJmrVersionListRequest) (*jmr.GetJmrVersionListResponse, error)

返回jmr版本列表

func (*JmrClient) GetJobList added in v1.0.9 

func (c *JmrClient) GetJobList(request *jmr.GetJobListRequest) (*jmr.GetJobListResponse, error)

获取作业列表

func (*JmrClient) GetJobTypeList added in v1.0.9 

func (c *JmrClient) GetJobTypeList(request *jmr.GetJobTypeListRequest) (*jmr.GetJobTypeListResponse, error)

获取作业类型列表

func (*JmrClient) GetKey added in v1.0.9 

func (c *JmrClient) GetKey(request *jmr.GetKeyRequest) (*jmr.GetKeyResponse, error)

获取用户appKey和secretKey

func (*JmrClient) GetLastCronJobTask added in v1.0.9 

func (c *JmrClient) GetLastCronJobTask(request *jmr.GetLastCronJobTaskRequest) (*jmr.GetLastCronJobTaskResponse, error)

获取定时任务的某个作业的最后一次运行记录

func (*JmrClient) GetPropertyValue added in v1.0.9 

func (c *JmrClient) GetPropertyValue(request *jmr.GetPropertyValueRequest) (*jmr.GetPropertyValueResponse, error)

软件配置信息列表

func (*JmrClient) GetSoftwareAndVersionInfo added in v1.0.9 

func (c *JmrClient) GetSoftwareAndVersionInfo(request *jmr.GetSoftwareAndVersionInfoRequest) (*jmr.GetSoftwareAndVersionInfoResponse, error)

获取软件清单信息

func (*JmrClient) GetSoftwareInfo added in v1.0.9 

func (c *JmrClient) GetSoftwareInfo(request *jmr.GetSoftwareInfoRequest) (*jmr.GetSoftwareInfoResponse, error)

获取软件清单信息

func (*JmrClient) GetTaskList added in v1.0.9 

func (c *JmrClient) GetTaskList(request *jmr.GetTaskListRequest) (*jmr.GetTaskListResponse, error)

获取某一作业的运行记录

func (*JmrClient) GetWorkFlowList added in v1.0.9 

func (c *JmrClient) GetWorkFlowList(request *jmr.GetWorkFlowListRequest) (*jmr.GetWorkFlowListResponse, error)

获取工作流列表

func (*JmrClient) GetWorkFlowTrackerList added in v1.0.9 

func (c *JmrClient) GetWorkFlowTrackerList(request *jmr.GetWorkFlowTrackerListRequest) (*jmr.GetWorkFlowTrackerListResponse, error)

获取工作流运行记录列表

func (*JmrClient) IdataCluster added in v1.0.9 

func (c *JmrClient) IdataCluster(request *jmr.IdataClusterRequest) (*jmr.IdataClusterResponse, error)

查询用户集群列表及相关服务的一些信息

func (*JmrClient) IsValidJobName added in v1.0.9 

func (c *JmrClient) IsValidJobName(request *jmr.IsValidJobNameRequest) (*jmr.IsValidJobNameResponse, error)

校验作业名称是否有效

func (*JmrClient) IsValidPlanName added in v1.0.9 

func (c *JmrClient) IsValidPlanName(request *jmr.IsValidPlanNameRequest) (*jmr.IsValidPlanNameResponse, error)

校验执行计划名称是否可用

func (*JmrClient) ModifyCronJob added in v1.0.9 

func (c *JmrClient) ModifyCronJob(request *jmr.ModifyCronJobRequest) (*jmr.ModifyCronJobResponse, error)

修改执行计划

func (*JmrClient) ModifyJob added in v1.0.9 

func (c *JmrClient) ModifyJob(request *jmr.ModifyJobRequest) (*jmr.ModifyJobResponse, error)

修改作业信息

func (*JmrClient) MonitorDetails added in v1.0.9 

func (c *JmrClient) MonitorDetails(request *jmr.MonitorDetailsRequest) (*jmr.MonitorDetailsResponse, error)

服务存活状态监控明细数据

func (*JmrClient) MonitorServiceList added in v1.0.9 

func (c *JmrClient) MonitorServiceList(request *jmr.MonitorServiceListRequest) (*jmr.MonitorServiceListResponse, error)

当前监控的服务列表

func (*JmrClient) PauseCronJob added in v1.0.9 

func (c *JmrClient) PauseCronJob(request *jmr.PauseCronJobRequest) (*jmr.PauseCronJobResponse, error)

暂停定时任务

func (*JmrClient) QueryExecutingJobList added in v1.0.9 

func (c *JmrClient) QueryExecutingJobList(request *jmr.QueryExecutingJobListRequest) (*jmr.QueryExecutingJobListResponse, error)

获取计划中的任务(已经添加到quartz调度器的任务)

func (*JmrClient) QueryFloatingIp added in v1.0.9 

func (c *JmrClient) QueryFloatingIp(request *jmr.QueryFloatingIpRequest) (*jmr.QueryFloatingIpResponse, error)

查询集群随机码

func (*JmrClient) QueryServerQuota added in v1.0.9 

func (c *JmrClient) QueryServerQuota(request *jmr.QueryServerQuotaRequest) (*jmr.QueryServerQuotaResponse, error)

查询server的剩余配额

func (*JmrClient) QueryVpcSubnets added in v1.0.9 

func (c *JmrClient) QueryVpcSubnets(request *jmr.QueryVpcSubnetsRequest) (*jmr.QueryVpcSubnetsResponse, error)

查询VpcSubnet集合

func (*JmrClient) QueryVpcs added in v1.0.9 

func (c *JmrClient) QueryVpcs(request *jmr.QueryVpcsRequest) (*jmr.QueryVpcsResponse, error)

获取vpc集合

func (*JmrClient) ReleaseCluster 

func (c *JmrClient) ReleaseCluster(request *jmr.ReleaseClusterRequest) (*jmr.ReleaseClusterResponse, error)

释放集群

func (*JmrClient) RenewBillingOrder added in v1.0.9 

func (c *JmrClient) RenewBillingOrder(request *jmr.RenewBillingOrderRequest) (*jmr.RenewBillingOrderResponse, error)

续费

func (*JmrClient) ResumeCronJob added in v1.0.9 

func (c *JmrClient) ResumeCronJob(request *jmr.ResumeCronJobRequest) (*jmr.ResumeCronJobResponse, error)

恢复定时任务

func (*JmrClient) RunCronJobOnce added in v1.0.9 

func (c *JmrClient) RunCronJobOnce(request *jmr.RunCronJobOnceRequest) (*jmr.RunCronJobOnceResponse, error)

立即执行

func (*JmrClient) RunWorkFlow added in v1.0.9 

func (c *JmrClient) RunWorkFlow(request *jmr.RunWorkFlowRequest) (*jmr.RunWorkFlowResponse, error)

运行工作流

func (*JmrClient) SaveWorkFlow added in v1.0.9 

func (c *JmrClient) SaveWorkFlow(request *jmr.SaveWorkFlowRequest) (*jmr.SaveWorkFlowResponse, error)

保存工作流

func (*JmrClient) SetConfig 

func (c *JmrClient) SetConfig(config *core.Config)

func (*JmrClient) SetLogger 

func (c *JmrClient) SetLogger(logger core.Logger)

func (*JmrClient) ShowClusterDetails 

func (c *JmrClient) ShowClusterDetails(request *jmr.ShowClusterDetailsRequest) (*jmr.ShowClusterDetailsResponse, error)

查询集群详情

func (*JmrClient) ShowJobDetails added in v1.0.9 

func (c *JmrClient) ShowJobDetails(request *jmr.ShowJobDetailsRequest) (*jmr.ShowJobDetailsResponse, error)

查看作业明细

func (*JmrClient) ValidateName added in v1.0.9 

func (c *JmrClient) ValidateName(request *jmr.ValidateNameRequest) (*jmr.ValidateNameResponse, error)

验证输入的集群名称是否重复

func (*JmrClient) ValidateUser added in v1.0.9 

func (c *JmrClient) ValidateUser(request *jmr.ValidateUserRequest) (*jmr.ValidateUserResponse, error)

用户名校验

func (*JmrClient) WfInstanceDetail added in v1.0.9 

func (c *JmrClient) WfInstanceDetail(request *jmr.WfInstanceDetailRequest) (*jmr.WfInstanceDetailResponse, 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.