client

func (*ShenhaiplatformClient) CopilotChatClear ¶

func (c *ShenhaiplatformClient) CopilotChatClear(request *shenhaiplatform.CopilotChatClearRequest) (*shenhaiplatform.CopilotChatClearResponse, error)

清除对话上下文

func (*ShenhaiplatformClient) CopilotChatDelete ¶

func (c *ShenhaiplatformClient) CopilotChatDelete(request *shenhaiplatform.CopilotChatDeleteRequest) (*shenhaiplatform.CopilotChatDeleteResponse, error)

删除对话

func (*ShenhaiplatformClient) CopilotChatHistory ¶

func (c *ShenhaiplatformClient) CopilotChatHistory(request *shenhaiplatform.CopilotChatHistoryRequest) (*shenhaiplatform.CopilotChatHistoryResponse, error)

获取历史对话列表

func (*ShenhaiplatformClient) CopilotChatNew ¶

func (c *ShenhaiplatformClient) CopilotChatNew(request *shenhaiplatform.CopilotChatNewRequest) (*shenhaiplatform.CopilotChatNewResponse, error)

获取一个新的对话id

func (*ShenhaiplatformClient) CopilotModelList ¶

func (c *ShenhaiplatformClient) CopilotModelList(request *shenhaiplatform.CopilotModelListRequest) (*shenhaiplatform.CopilotModelListResponse, error)

获取可用模型列表

func (*ShenhaiplatformClient) CopilotUtteranceList ¶

func (c *ShenhaiplatformClient) CopilotUtteranceList(request *shenhaiplatform.CopilotUtteranceListRequest) (*shenhaiplatform.CopilotUtteranceListResponse, error)

获取指定对话中的发言记录

func (*ShenhaiplatformClient) CopilotUtteranceRecommend ¶

func (c *ShenhaiplatformClient) CopilotUtteranceRecommend(request *shenhaiplatform.CopilotUtteranceRecommendRequest) (*shenhaiplatform.CopilotUtteranceRecommendResponse, error)

根据对话中的一条发言，推荐可能的prompt

func (*ShenhaiplatformClient) CopilotUtteranceStop ¶

func (c *ShenhaiplatformClient) CopilotUtteranceStop(request *shenhaiplatform.CopilotUtteranceStopRequest) (*shenhaiplatform.CopilotUtteranceStopResponse, error)

停止发言，用于终止模型回复生成

func (*ShenhaiplatformClient) CopilotVerify ¶

func (c *ShenhaiplatformClient) CopilotVerify(request *shenhaiplatform.CopilotVerifyRequest) (*shenhaiplatform.CopilotVerifyResponse, error)

验证当前用户是否有权限访问

func (*ShenhaiplatformClient) DeletePublishObj ¶

func (c *ShenhaiplatformClient) DeletePublishObj(request *shenhaiplatform.DeletePublishObjRequest) (*shenhaiplatform.DeletePublishObjResponse, error)

撤销发布对象

func (*ShenhaiplatformClient) DeletePublishPkg ¶

func (c *ShenhaiplatformClient) DeletePublishPkg(request *shenhaiplatform.DeletePublishPkgRequest) (*shenhaiplatform.DeletePublishPkgResponse, error)

驳回发布包

func (*ShenhaiplatformClient) DescribePublishObj ¶

func (c *ShenhaiplatformClient) DescribePublishObj(request *shenhaiplatform.DescribePublishObjRequest) (*shenhaiplatform.DescribePublishObjResponse, error)

发布对象信息细节查看

func (*ShenhaiplatformClient) DescribePublishObjs ¶

func (c *ShenhaiplatformClient) DescribePublishObjs(request *shenhaiplatform.DescribePublishObjsRequest) (*shenhaiplatform.DescribePublishObjsResponse, error)

分页查询发布对象列表

func (*ShenhaiplatformClient) DescribePublishPkg ¶

func (c *ShenhaiplatformClient) DescribePublishPkg(request *shenhaiplatform.DescribePublishPkgRequest) (*shenhaiplatform.DescribePublishPkgResponse, error)

发布包详情查询

func (*ShenhaiplatformClient) DescribePublishPkgs ¶

func (c *ShenhaiplatformClient) DescribePublishPkgs(request *shenhaiplatform.DescribePublishPkgsRequest) (*shenhaiplatform.DescribePublishPkgsResponse, error)

分页查询发布包列表

func (*ShenhaiplatformClient) DisableLogger ¶

func (c *ShenhaiplatformClient) DisableLogger()

func (*ShenhaiplatformClient) GravityParticleChannelJobInfoDeleteJob ¶

func (c *ShenhaiplatformClient) GravityParticleChannelJobInfoDeleteJob(request *shenhaiplatform.GravityParticleChannelJobInfoDeleteJobRequest) (*shenhaiplatform.GravityParticleChannelJobInfoDeleteJobResponse, error)

删除作业以及子作业和质量作业

func (*ShenhaiplatformClient) GravityParticleConfigUserMatchUser ¶

func (c *ShenhaiplatformClient) GravityParticleConfigUserMatchUser(request *shenhaiplatform.GravityParticleConfigUserMatchUserRequest) (*shenhaiplatform.GravityParticleConfigUserMatchUserResponse, error)

根据类型获取数据字典

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerCalcJobDetail ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerCalcJobDetail(request *shenhaiplatform.GravityParticleDubboJobManagerCalcJobDetailRequest) (*shenhaiplatform.GravityParticleDubboJobManagerCalcJobDetailResponse, error)

获取作业详细信息

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerDeleteAllByWorkspace ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerDeleteAllByWorkspace(request *shenhaiplatform.GravityParticleDubboJobManagerDeleteAllByWorkspaceRequest) (*shenhaiplatform.GravityParticleDubboJobManagerDeleteAllByWorkspaceResponse, error)

工作空间到期后删除该工作空间下的所有作业和日志

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerDeleteJob ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerDeleteJob(request *shenhaiplatform.GravityParticleDubboJobManagerDeleteJobRequest) (*shenhaiplatform.GravityParticleDubboJobManagerDeleteJobResponse, error)

删除作业

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerDeleteJobScript ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerDeleteJobScript(request *shenhaiplatform.GravityParticleDubboJobManagerDeleteJobScriptRequest) (*shenhaiplatform.GravityParticleDubboJobManagerDeleteJobScriptResponse, error)

根据作业id删除作业脚本

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerDeployJob ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerDeployJob(request *shenhaiplatform.GravityParticleDubboJobManagerDeployJobRequest) (*shenhaiplatform.GravityParticleDubboJobManagerDeployJobResponse, error)

发布作业

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerDeployJobEdit ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerDeployJobEdit(request *shenhaiplatform.GravityParticleDubboJobManagerDeployJobEditRequest) (*shenhaiplatform.GravityParticleDubboJobManagerDeployJobEditResponse, error)

编辑作业信息

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerGetEngineTemplate ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerGetEngineTemplate(request *shenhaiplatform.GravityParticleDubboJobManagerGetEngineTemplateRequest) (*shenhaiplatform.GravityParticleDubboJobManagerGetEngineTemplateResponse, error)

根据脚本类型获取模板引擎下载地址

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerGetJobScript ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerGetJobScript(request *shenhaiplatform.GravityParticleDubboJobManagerGetJobScriptRequest) (*shenhaiplatform.GravityParticleDubboJobManagerGetJobScriptResponse, error)

根据作业id获取脚本信息

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerGetMgrJobByJobName ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerGetMgrJobByJobName(request *shenhaiplatform.GravityParticleDubboJobManagerGetMgrJobByJobNameRequest) (*shenhaiplatform.GravityParticleDubboJobManagerGetMgrJobByJobNameResponse, error)

校验作业名称是否存在，true表示不存在，可以新建，false表示已经存在

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerGetMgrJobByJobe ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerGetMgrJobByJobe(request *shenhaiplatform.GravityParticleDubboJobManagerGetMgrJobByJobeRequest) (*shenhaiplatform.GravityParticleDubboJobManagerGetMgrJobByJobeResponse, error)

重新上线接口 根据文件id和版本号

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerGetScriptInfoType ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerGetScriptInfoType(request *shenhaiplatform.GravityParticleDubboJobManagerGetScriptInfoTypeRequest) (*shenhaiplatform.GravityParticleDubboJobManagerGetScriptInfoTypeResponse, error)

获取脚本类型和模板下载地址

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerJobQuery ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerJobQuery(request *shenhaiplatform.GravityParticleDubboJobManagerJobQueryRequest) (*shenhaiplatform.GravityParticleDubboJobManagerJobQueryResponse, error)

根据查询条件返回作业关联的模型信息

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerListJob ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerListJob(request *shenhaiplatform.GravityParticleDubboJobManagerListJobRequest) (*shenhaiplatform.GravityParticleDubboJobManagerListJobResponse, error)

根据作业名模糊查询作业

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerQueryJobByOutputTable ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerQueryJobByOutputTable(request *shenhaiplatform.GravityParticleDubboJobManagerQueryJobByOutputTableRequest) (*shenhaiplatform.GravityParticleDubboJobManagerQueryJobByOutputTableResponse, error)

根据表信息，查询其对应写入作业信息

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerSaveDmrModelJob ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerSaveDmrModelJob(request *shenhaiplatform.GravityParticleDubboJobManagerSaveDmrModelJobRequest) (*shenhaiplatform.GravityParticleDubboJobManagerSaveDmrModelJobResponse, error)

保存作业模型相关信息

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerSaveJobScript ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerSaveJobScript(request *shenhaiplatform.GravityParticleDubboJobManagerSaveJobScriptRequest) (*shenhaiplatform.GravityParticleDubboJobManagerSaveJobScriptResponse, error)

保存作业脚本信息

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerSearchByJobName ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerSearchByJobName(request *shenhaiplatform.GravityParticleDubboJobManagerSearchByJobNameRequest) (*shenhaiplatform.GravityParticleDubboJobManagerSearchByJobNameResponse, error)

根据任务名字模糊查询

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerSearchDmrModelJob ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerSearchDmrModelJob(request *shenhaiplatform.GravityParticleDubboJobManagerSearchDmrModelJobRequest) (*shenhaiplatform.GravityParticleDubboJobManagerSearchDmrModelJobResponse, error)

根据查询条件返回作业关联的模型信息

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerSearchJobId ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerSearchJobId(request *shenhaiplatform.GravityParticleDubboJobManagerSearchJobIdRequest) (*shenhaiplatform.GravityParticleDubboJobManagerSearchJobIdResponse, error)

根据查询条件返回作业Id

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerSearchSchedJob ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerSearchSchedJob(request *shenhaiplatform.GravityParticleDubboJobManagerSearchSchedJobRequest) (*shenhaiplatform.GravityParticleDubboJobManagerSearchSchedJobResponse, error)

根据作业名模糊查询或JobQueryDTO查询

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerValidateJobRules ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerValidateJobRules(request *shenhaiplatform.GravityParticleDubboJobManagerValidateJobRulesRequest) (*shenhaiplatform.GravityParticleDubboJobManagerValidateJobRulesResponse, error)

校验作业规则

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerVerifyScriptFile ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerVerifyScriptFile(request *shenhaiplatform.GravityParticleDubboJobManagerVerifyScriptFileRequest) (*shenhaiplatform.GravityParticleDubboJobManagerVerifyScriptFileResponse, error)

脚本校验

func (*ShenhaiplatformClient) GravityParticleDubboJobManagerVerifyScriptFileList ¶

func (c *ShenhaiplatformClient) GravityParticleDubboJobManagerVerifyScriptFileList(request *shenhaiplatform.GravityParticleDubboJobManagerVerifyScriptFileListRequest) (*shenhaiplatform.GravityParticleDubboJobManagerVerifyScriptFileListResponse, error)

根据作业类型，校验脚本文件扩展名是否合法

func (*ShenhaiplatformClient) GravityParticleJobDepChildJobs ¶

func (c *ShenhaiplatformClient) GravityParticleJobDepChildJobs(request *shenhaiplatform.GravityParticleJobDepChildJobsRequest) (*shenhaiplatform.GravityParticleJobDepChildJobsResponse, error)

获取子作业

func (*ShenhaiplatformClient) GravityParticleJobDepDetail ¶

func (c *ShenhaiplatformClient) GravityParticleJobDepDetail(request *shenhaiplatform.GravityParticleJobDepDetailRequest) (*shenhaiplatform.GravityParticleJobDepDetailResponse, error)

任务关系页面，作业详情

func (*ShenhaiplatformClient) GravityParticleJobDepGetChildChainJobs ¶

func (c *ShenhaiplatformClient) GravityParticleJobDepGetChildChainJobs(request *shenhaiplatform.GravityParticleJobDepGetChildChainJobsRequest) (*shenhaiplatform.GravityParticleJobDepGetChildChainJobsResponse, error)

根据当前作业和目标层级查询子作业链路层级树

func (*ShenhaiplatformClient) GravityParticleJobDepGetChildDependencies ¶

func (c *ShenhaiplatformClient) GravityParticleJobDepGetChildDependencies(request *shenhaiplatform.GravityParticleJobDepGetChildDependenciesRequest) (*shenhaiplatform.GravityParticleJobDepGetChildDependenciesResponse, error)

获取子作业

func (*ShenhaiplatformClient) GravityParticleJobDepGetChildTreed ¶

func (c *ShenhaiplatformClient) GravityParticleJobDepGetChildTreed(request *shenhaiplatform.GravityParticleJobDepGetChildTreedRequest) (*shenhaiplatform.GravityParticleJobDepGetChildTreedResponse, error)

获取作业树

func (*ShenhaiplatformClient) GravityParticleJobDepGetParentChainJobs ¶

func (c *ShenhaiplatformClient) GravityParticleJobDepGetParentChainJobs(request *shenhaiplatform.GravityParticleJobDepGetParentChainJobsRequest) (*shenhaiplatform.GravityParticleJobDepGetParentChainJobsResponse, error)

根据当前作业和目标层级查询父作业链路层级树

func (*ShenhaiplatformClient) GravityParticleJobDepGetParentDependencies ¶

func (c *ShenhaiplatformClient) GravityParticleJobDepGetParentDependencies(request *shenhaiplatform.GravityParticleJobDepGetParentDependenciesRequest) (*shenhaiplatform.GravityParticleJobDepGetParentDependenciesResponse, error)

获取当前作业的父依赖

func (*ShenhaiplatformClient) GravityParticleJobDepParentJobs ¶

func (c *ShenhaiplatformClient) GravityParticleJobDepParentJobs(request *shenhaiplatform.GravityParticleJobDepParentJobsRequest) (*shenhaiplatform.GravityParticleJobDepParentJobsResponse, error)

获取父作业

func (*ShenhaiplatformClient) GravityParticleJobGetScriptExtensions ¶

func (c *ShenhaiplatformClient) GravityParticleJobGetScriptExtensions(request *shenhaiplatform.GravityParticleJobGetScriptExtensionsRequest) (*shenhaiplatform.GravityParticleJobGetScriptExtensionsResponse, error)

获取作业脚本扩展名信息

func (*ShenhaiplatformClient) GravityParticleJobHisRunAddBathTask ¶

func (c *ShenhaiplatformClient) GravityParticleJobHisRunAddBathTask(request *shenhaiplatform.GravityParticleJobHisRunAddBathTaskRequest) (*shenhaiplatform.GravityParticleJobHisRunAddBathTaskResponse, error)

任务批量补数

func (*ShenhaiplatformClient) GravityParticleJobHisRunAddTask ¶

func (c *ShenhaiplatformClient) GravityParticleJobHisRunAddTask(request *shenhaiplatform.GravityParticleJobHisRunAddTaskRequest) (*shenhaiplatform.GravityParticleJobHisRunAddTaskResponse, error)

任务补数

func (*ShenhaiplatformClient) GravityParticleJobHisRunCloseTask ¶

func (c *ShenhaiplatformClient) GravityParticleJobHisRunCloseTask(request *shenhaiplatform.GravityParticleJobHisRunCloseTaskRequest) (*shenhaiplatform.GravityParticleJobHisRunCloseTaskResponse, error)

停止补数

func (*ShenhaiplatformClient) GravityParticleJobHisRunListTask ¶

func (c *ShenhaiplatformClient) GravityParticleJobHisRunListTask(request *shenhaiplatform.GravityParticleJobHisRunListTaskRequest) (*shenhaiplatform.GravityParticleJobHisRunListTaskResponse, error)

补数跟踪列表

func (*ShenhaiplatformClient) GravityParticleJobHisRunListTaskLog ¶

func (c *ShenhaiplatformClient) GravityParticleJobHisRunListTaskLog(request *shenhaiplatform.GravityParticleJobHisRunListTaskLogRequest) (*shenhaiplatform.GravityParticleJobHisRunListTaskLogResponse, error)

查询补数跟踪记录

func (*ShenhaiplatformClient) GravityParticleJobMonitorJobCountInfo ¶

func (c *ShenhaiplatformClient) GravityParticleJobMonitorJobCountInfo(request *shenhaiplatform.GravityParticleJobMonitorJobCountInfoRequest) (*shenhaiplatform.GravityParticleJobMonitorJobCountInfoResponse, error)

统计作业数量

func (*ShenhaiplatformClient) GravityParticleJobMonitorJobDispatchTrend ¶

func (c *ShenhaiplatformClient) GravityParticleJobMonitorJobDispatchTrend(request *shenhaiplatform.GravityParticleJobMonitorJobDispatchTrendRequest) (*shenhaiplatform.GravityParticleJobMonitorJobDispatchTrendResponse, error)

将作业按趋势进行数据量的统计

func (*ShenhaiplatformClient) GravityParticleJobMonitorJobFailCount ¶

func (c *ShenhaiplatformClient) GravityParticleJobMonitorJobFailCount(request *shenhaiplatform.GravityParticleJobMonitorJobFailCountRequest) (*shenhaiplatform.GravityParticleJobMonitorJobFailCountResponse, error)

统计失败作业状态数量

func (*ShenhaiplatformClient) GravityParticleJobMonitorJobSpendTimeRanking ¶

func (c *ShenhaiplatformClient) GravityParticleJobMonitorJobSpendTimeRanking(request *shenhaiplatform.GravityParticleJobMonitorJobSpendTimeRankingRequest) (*shenhaiplatform.GravityParticleJobMonitorJobSpendTimeRankingResponse, error)

统计作业耗时排名

func (*ShenhaiplatformClient) GravityParticleJobMonitorJobStatusCount ¶

func (c *ShenhaiplatformClient) GravityParticleJobMonitorJobStatusCount(request *shenhaiplatform.GravityParticleJobMonitorJobStatusCountRequest) (*shenhaiplatform.GravityParticleJobMonitorJobStatusCountResponse, error)

统计作业状态数量

func (*ShenhaiplatformClient) GravityParticleJobMonitorJobSuccessCount ¶

func (c *ShenhaiplatformClient) GravityParticleJobMonitorJobSuccessCount(request *shenhaiplatform.GravityParticleJobMonitorJobSuccessCountRequest) (*shenhaiplatform.GravityParticleJobMonitorJobSuccessCountResponse, error)

统计成功作业状态数量

func (*ShenhaiplatformClient) GravityParticleJobMonitorJobTypeCount ¶

func (c *ShenhaiplatformClient) GravityParticleJobMonitorJobTypeCount(request *shenhaiplatform.GravityParticleJobMonitorJobTypeCountRequest) (*shenhaiplatform.GravityParticleJobMonitorJobTypeCountResponse, error)

统计不同类型作业的数量

func (*ShenhaiplatformClient) GravityParticleJobMonitorJobTypeList ¶

func (c *ShenhaiplatformClient) GravityParticleJobMonitorJobTypeList(request *shenhaiplatform.GravityParticleJobMonitorJobTypeListRequest) (*shenhaiplatform.GravityParticleJobMonitorJobTypeListResponse, error)

查询作业类型清单

func (*ShenhaiplatformClient) GravityParticleJobMonitorJobUnsuccessRanking ¶

func (c *ShenhaiplatformClient) GravityParticleJobMonitorJobUnsuccessRanking(request *shenhaiplatform.GravityParticleJobMonitorJobUnsuccessRankingRequest) (*shenhaiplatform.GravityParticleJobMonitorJobUnsuccessRankingResponse, error)

统计不成功作业的数量

func (*ShenhaiplatformClient) GravityParticleJobscheForceRunJobInst ¶

func (c *ShenhaiplatformClient) GravityParticleJobscheForceRunJobInst(request *shenhaiplatform.GravityParticleJobscheForceRunJobInstRequest) (*shenhaiplatform.GravityParticleJobscheForceRunJobInstResponse, error)

强制运行作业实例

func (*ShenhaiplatformClient) GravityParticleJobscheIsUpstreamSameFrequency ¶

func (c *ShenhaiplatformClient) GravityParticleJobscheIsUpstreamSameFrequency(request *shenhaiplatform.GravityParticleJobscheIsUpstreamSameFrequencyRequest) (*shenhaiplatform.GravityParticleJobscheIsUpstreamSameFrequencyResponse, error)

判断作业和上游是否完全同频

func (*ShenhaiplatformClient) GravityParticleJobscheProcessJobExeRst ¶

func (c *ShenhaiplatformClient) GravityParticleJobscheProcessJobExeRst(request *shenhaiplatform.GravityParticleJobscheProcessJobExeRstRequest) (*shenhaiplatform.GravityParticleJobscheProcessJobExeRstResponse, error)

解析作业完成信息进行作业实例运行状态更新

func (*ShenhaiplatformClient) GravityParticleJobscheReRunJobInst ¶

func (c *ShenhaiplatformClient) GravityParticleJobscheReRunJobInst(request *shenhaiplatform.GravityParticleJobscheReRunJobInstRequest) (*shenhaiplatform.GravityParticleJobscheReRunJobInstResponse, error)

强制运行作业实例，允许触发作业失败，用于补数，商城触发

func (*ShenhaiplatformClient) GravityParticleJobscheResetJobInstStatus ¶

func (c *ShenhaiplatformClient) GravityParticleJobscheResetJobInstStatus(request *shenhaiplatform.GravityParticleJobscheResetJobInstStatusRequest) (*shenhaiplatform.GravityParticleJobscheResetJobInstStatusResponse, error)

重置作业实例的状态为制定状态

func (*ShenhaiplatformClient) GravityParticleJobscheSetJobEnableFlag ¶

func (c *ShenhaiplatformClient) GravityParticleJobscheSetJobEnableFlag(request *shenhaiplatform.GravityParticleJobscheSetJobEnableFlagRequest) (*shenhaiplatform.GravityParticleJobscheSetJobEnableFlagResponse, error)

更新作业的可用状态

func (*ShenhaiplatformClient) GravityParticleOpenRerun ¶

func (c *ShenhaiplatformClient) GravityParticleOpenRerun(request *shenhaiplatform.GravityParticleOpenRerunRequest) (*shenhaiplatform.GravityParticleOpenRerunResponse, error)

重跑指定任务的指定数据日期

func (*ShenhaiplatformClient) GravityParticleParticleJobGetBasicInfo ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobGetBasicInfo(request *shenhaiplatform.GravityParticleParticleJobGetBasicInfoRequest) (*shenhaiplatform.GravityParticleParticleJobGetBasicInfoResponse, error)

查询作业详细信息

func (*ShenhaiplatformClient) GravityParticleParticleJobGetConditionInfo ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobGetConditionInfo(request *shenhaiplatform.GravityParticleParticleJobGetConditionInfoRequest) (*shenhaiplatform.GravityParticleParticleJobGetConditionInfoResponse, error)

获取作业触发条件信息信息

func (*ShenhaiplatformClient) GravityParticleParticleJobGetJobTypeInfo ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobGetJobTypeInfo(request *shenhaiplatform.GravityParticleParticleJobGetJobTypeInfoRequest) (*shenhaiplatform.GravityParticleParticleJobGetJobTypeInfoResponse, error)

查询作业类型信息

func (*ShenhaiplatformClient) GravityParticleParticleJobGetMgrJobInfo ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobGetMgrJobInfo(request *shenhaiplatform.GravityParticleParticleJobGetMgrJobInfoRequest) (*shenhaiplatform.GravityParticleParticleJobGetMgrJobInfoResponse, error)

查询mgrJob信息

func (*ShenhaiplatformClient) GravityParticleParticleJobGetRunInfos ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobGetRunInfos(request *shenhaiplatform.GravityParticleParticleJobGetRunInfosRequest) (*shenhaiplatform.GravityParticleParticleJobGetRunInfosResponse, error)

查询作业运行信息

func (*ShenhaiplatformClient) GravityParticleParticleJobJobCompletionInfo ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobJobCompletionInfo(request *shenhaiplatform.GravityParticleParticleJobJobCompletionInfoRequest) (*shenhaiplatform.GravityParticleParticleJobJobCompletionInfoResponse, error)

查询作业完成信息

func (*ShenhaiplatformClient) GravityParticleParticleJobListJob ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobListJob(request *shenhaiplatform.GravityParticleParticleJobListJobRequest) (*shenhaiplatform.GravityParticleParticleJobListJobResponse, error)

首页调用-获取所有作业信息

func (*ShenhaiplatformClient) GravityParticleParticleJobListJobInstance ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobListJobInstance(request *shenhaiplatform.GravityParticleParticleJobListJobInstanceRequest) (*shenhaiplatform.GravityParticleParticleJobListJobInstanceResponse, error)

条件查询-作业运行实例列表

func (*ShenhaiplatformClient) GravityParticleParticleJobListOperationRecord ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobListOperationRecord(request *shenhaiplatform.GravityParticleParticleJobListOperationRecordRequest) (*shenhaiplatform.GravityParticleParticleJobListOperationRecordResponse, error)

查询作业操作记录

func (*ShenhaiplatformClient) GravityParticleParticleJobMonitorJobStatusCount ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobMonitorJobStatusCount(request *shenhaiplatform.GravityParticleParticleJobMonitorJobStatusCountRequest) (*shenhaiplatform.GravityParticleParticleJobMonitorJobStatusCountResponse, error)

工作台作业统计接口

func (*ShenhaiplatformClient) GravityParticleParticleJobSchedCancelJob ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobSchedCancelJob(request *shenhaiplatform.GravityParticleParticleJobSchedCancelJobRequest) (*shenhaiplatform.GravityParticleParticleJobSchedCancelJobResponse, error)

下线作业

func (*ShenhaiplatformClient) GravityParticleParticleJobSchedForceJobBatch ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobSchedForceJobBatch(request *shenhaiplatform.GravityParticleParticleJobSchedForceJobBatchRequest) (*shenhaiplatform.GravityParticleParticleJobSchedForceJobBatchResponse, error)

批量强制作业运行

func (*ShenhaiplatformClient) GravityParticleParticleJobSchedGetRunLog ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobSchedGetRunLog(request *shenhaiplatform.GravityParticleParticleJobSchedGetRunLogRequest) (*shenhaiplatform.GravityParticleParticleJobSchedGetRunLogResponse, error)

获取作业分页日志

func (*ShenhaiplatformClient) GravityParticleParticleJobSchedGetSchedJobInfo ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobSchedGetSchedJobInfo(request *shenhaiplatform.GravityParticleParticleJobSchedGetSchedJobInfoRequest) (*shenhaiplatform.GravityParticleParticleJobSchedGetSchedJobInfoResponse, error)

查询作业信息

func (*ShenhaiplatformClient) GravityParticleParticleJobSchedKillJob ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobSchedKillJob(request *shenhaiplatform.GravityParticleParticleJobSchedKillJobRequest) (*shenhaiplatform.GravityParticleParticleJobSchedKillJobResponse, error)

对作业进行查杀

func (*ShenhaiplatformClient) GravityParticleParticleJobSchedResetStsDone ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobSchedResetStsDone(request *shenhaiplatform.GravityParticleParticleJobSchedResetStsDoneRequest) (*shenhaiplatform.GravityParticleParticleJobSchedResetStsDoneResponse, error)

重置作业为done

func (*ShenhaiplatformClient) GravityParticleParticleJobSchedReuseJob ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobSchedReuseJob(request *shenhaiplatform.GravityParticleParticleJobSchedReuseJobRequest) (*shenhaiplatform.GravityParticleParticleJobSchedReuseJobResponse, error)

批量接口上线

func (*ShenhaiplatformClient) GravityParticleParticleJobSchedReuseJobWithDepend ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobSchedReuseJobWithDepend(request *shenhaiplatform.GravityParticleParticleJobSchedReuseJobWithDependRequest) (*shenhaiplatform.GravityParticleParticleJobSchedReuseJobWithDependResponse, error)

批量接口上线

func (*ShenhaiplatformClient) GravityParticleParticleJobSchedUpdateSchedJob ¶

func (c *ShenhaiplatformClient) GravityParticleParticleJobSchedUpdateSchedJob(request *shenhaiplatform.GravityParticleParticleJobSchedUpdateSchedJobRequest) (*shenhaiplatform.GravityParticleParticleJobSchedUpdateSchedJobResponse, error)

作业信息更新

func (*ShenhaiplatformClient) GravityParticleParticleModelCalcCalcJobDetail ¶

func (c *ShenhaiplatformClient) GravityParticleParticleModelCalcCalcJobDetail(request *shenhaiplatform.GravityParticleParticleModelCalcCalcJobDetailRequest) (*shenhaiplatform.GravityParticleParticleModelCalcCalcJobDetailResponse, error)

计算作业详情

func (*ShenhaiplatformClient) GravityParticleParticleModelCalcListJob ¶

func (c *ShenhaiplatformClient) GravityParticleParticleModelCalcListJob(request *shenhaiplatform.GravityParticleParticleModelCalcListJobRequest) (*shenhaiplatform.GravityParticleParticleModelCalcListJobResponse, error)

查询作业清单

func (*ShenhaiplatformClient) GravityParticleSchedDictGetByType ¶

func (c *ShenhaiplatformClient) GravityParticleSchedDictGetByType(request *shenhaiplatform.GravityParticleSchedDictGetByTypeRequest) (*shenhaiplatform.GravityParticleSchedDictGetByTypeResponse, error)

根据类型获取数据字典

func (*ShenhaiplatformClient) GravityParticleSchedDictGetJobTypeR ¶

func (c *ShenhaiplatformClient) GravityParticleSchedDictGetJobTypeR(request *shenhaiplatform.GravityParticleSchedDictGetJobTypeRRequest) (*shenhaiplatform.GravityParticleSchedDictGetJobTypeRResponse, error)

获取作业类型关系

func (*ShenhaiplatformClient) JtlasDestroy ¶

func (c *ShenhaiplatformClient) JtlasDestroy(request *shenhaiplatform.JtlasDestroyRequest) (*shenhaiplatform.JtlasDestroyResponse, error)

表授权接口

func (*ShenhaiplatformClient) JtlasDownloadTableColumns ¶

func (c *ShenhaiplatformClient) JtlasDownloadTableColumns(request *shenhaiplatform.JtlasDownloadTableColumnsRequest) (*shenhaiplatform.JtlasDownloadTableColumnsResponse, error)

查询表DDL脚本

func (*ShenhaiplatformClient) JtlasGetTableDDLScript ¶

func (c *ShenhaiplatformClient) JtlasGetTableDDLScript(request *shenhaiplatform.JtlasGetTableDDLScriptRequest) (*shenhaiplatform.JtlasGetTableDDLScriptResponse, error)

查询表DDL脚本

func (*ShenhaiplatformClient) JtlasGetTableQueryScript ¶

func (c *ShenhaiplatformClient) JtlasGetTableQueryScript(request *shenhaiplatform.JtlasGetTableQueryScriptRequest) (*shenhaiplatform.JtlasGetTableQueryScriptResponse, error)

查询表查看脚本

func (*ShenhaiplatformClient) JtlasGrantTablePrivileges ¶

func (c *ShenhaiplatformClient) JtlasGrantTablePrivileges(request *shenhaiplatform.JtlasGrantTablePrivilegesRequest) (*shenhaiplatform.JtlasGrantTablePrivilegesResponse, error)

表授权接口

func (*ShenhaiplatformClient) JtlasPageSearchTablePartitions ¶

func (c *ShenhaiplatformClient) JtlasPageSearchTablePartitions(request *shenhaiplatform.JtlasPageSearchTablePartitionsRequest) (*shenhaiplatform.JtlasPageSearchTablePartitionsResponse, error)

查询表分区

func (*ShenhaiplatformClient) JtlasPageSearchTablePrivileges ¶

func (c *ShenhaiplatformClient) JtlasPageSearchTablePrivileges(request *shenhaiplatform.JtlasPageSearchTablePrivilegesRequest) (*shenhaiplatform.JtlasPageSearchTablePrivilegesResponse, error)

检索表权限

func (*ShenhaiplatformClient) JtlasPageSearchTables ¶

func (c *ShenhaiplatformClient) JtlasPageSearchTables(request *shenhaiplatform.JtlasPageSearchTablesRequest) (*shenhaiplatform.JtlasPageSearchTablesResponse, error)

检索表

func (*ShenhaiplatformClient) JtlasSearchColumnLineage ¶

func (c *ShenhaiplatformClient) JtlasSearchColumnLineage(request *shenhaiplatform.JtlasSearchColumnLineageRequest) (*shenhaiplatform.JtlasSearchColumnLineageResponse, error)

查询字段血缘

func (*ShenhaiplatformClient) JtlasSearchDetail ¶

func (c *ShenhaiplatformClient) JtlasSearchDetail(request *shenhaiplatform.JtlasSearchDetailRequest) (*shenhaiplatform.JtlasSearchDetailResponse, error)

查询表详情

func (*ShenhaiplatformClient) JtlasSearchTableLineage ¶

func (c *ShenhaiplatformClient) JtlasSearchTableLineage(request *shenhaiplatform.JtlasSearchTableLineageRequest) (*shenhaiplatform.JtlasSearchTableLineageResponse, error)

查询表血缘

func (*ShenhaiplatformClient) JtlasSubscribeTable ¶

func (c *ShenhaiplatformClient) JtlasSubscribeTable(request *shenhaiplatform.JtlasSubscribeTableRequest) (*shenhaiplatform.JtlasSubscribeTableResponse, error)

订阅/收藏表

func (*ShenhaiplatformClient) JtlasWarehouseFuzzyQueryTablesByTableName ¶

func (c *ShenhaiplatformClient) JtlasWarehouseFuzzyQueryTablesByTableName(request *shenhaiplatform.JtlasWarehouseFuzzyQueryTablesByTableNameRequest) (*shenhaiplatform.JtlasWarehouseFuzzyQueryTablesByTableNameResponse, error)

根据租户/项目空间/表名称模糊查询表列表，最多返回1000条

func (*ShenhaiplatformClient) JtlasWarehouseFuzzyQueryTablesUnderSpecifiedUserWithPrivileges ¶

func (c *ShenhaiplatformClient) JtlasWarehouseFuzzyQueryTablesUnderSpecifiedUserWithPrivileges(request *shenhaiplatform.JtlasWarehouseFuzzyQueryTablesUnderSpecifiedUserWithPrivilegesRequest) (*shenhaiplatform.JtlasWarehouseFuzzyQueryTablesUnderSpecifiedUserWithPrivilegesResponse, error)

查询用户指定权限下的表信息,支持表名模糊

func (*ShenhaiplatformClient) JtlasWarehouseQueryTablePrivileges ¶

func (c *ShenhaiplatformClient) JtlasWarehouseQueryTablePrivileges(request *shenhaiplatform.JtlasWarehouseQueryTablePrivilegesRequest) (*shenhaiplatform.JtlasWarehouseQueryTablePrivilegesResponse, error)

根据用户名查询用户权限表列表，最多返回1000条

func (*ShenhaiplatformClient) JtlasWarehouseQueryTablesByDatabaseName ¶

func (c *ShenhaiplatformClient) JtlasWarehouseQueryTablesByDatabaseName(request *shenhaiplatform.JtlasWarehouseQueryTablesByDatabaseNameRequest) (*shenhaiplatform.JtlasWarehouseQueryTablesByDatabaseNameResponse, error)

根据租户/项目空间/数据库名称模糊查询表列表，最多返回1000条

func (*ShenhaiplatformClient) JtlasWarehouseQueryTablesOwnedByUser ¶

func (c *ShenhaiplatformClient) JtlasWarehouseQueryTablesOwnedByUser(request *shenhaiplatform.JtlasWarehouseQueryTablesOwnedByUserRequest) (*shenhaiplatform.JtlasWarehouseQueryTablesOwnedByUserResponse, error)

查询用户创建的表，支持基于表名模糊

func (*ShenhaiplatformClient) JtlasWarehouseQueryTablesUnderSpecifiedUser ¶

func (c *ShenhaiplatformClient) JtlasWarehouseQueryTablesUnderSpecifiedUser(request *shenhaiplatform.JtlasWarehouseQueryTablesUnderSpecifiedUserRequest) (*shenhaiplatform.JtlasWarehouseQueryTablesUnderSpecifiedUserResponse, error)

根据用户名查询用户权限表列表，最多返回1000条

func (*ShenhaiplatformClient) JtlasWarehouseQueryTablesUnderSpecifiedUserWithPrivileges ¶

func (c *ShenhaiplatformClient) JtlasWarehouseQueryTablesUnderSpecifiedUserWithPrivileges(request *shenhaiplatform.JtlasWarehouseQueryTablesUnderSpecifiedUserWithPrivilegesRequest) (*shenhaiplatform.JtlasWarehouseQueryTablesUnderSpecifiedUserWithPrivilegesResponse, error)

根据用户名查询用户权限表列表，最多返回1000条

func (*ShenhaiplatformClient) JtlasWarehouseTableDetail ¶

func (c *ShenhaiplatformClient) JtlasWarehouseTableDetail(request *shenhaiplatform.JtlasWarehouseTableDetailRequest) (*shenhaiplatform.JtlasWarehouseTableDetailResponse, error)

根据租户/项目空间/表名称查询表详情

func (*ShenhaiplatformClient) ManageHubDutyAddWatchman ¶

func (c *ShenhaiplatformClient) ManageHubDutyAddWatchman(request *shenhaiplatform.ManageHubDutyAddWatchmanRequest) (*shenhaiplatform.ManageHubDutyAddWatchmanResponse, error)

增加值班人

func (*ShenhaiplatformClient) ManageHubDutyDeleteWatchman ¶

func (c *ShenhaiplatformClient) ManageHubDutyDeleteWatchman(request *shenhaiplatform.ManageHubDutyDeleteWatchmanRequest) (*shenhaiplatform.ManageHubDutyDeleteWatchmanResponse, error)

删除值班人

func (*ShenhaiplatformClient) ManageHubDutyListRoster ¶

func (c *ShenhaiplatformClient) ManageHubDutyListRoster(request *shenhaiplatform.ManageHubDutyListRosterRequest) (*shenhaiplatform.ManageHubDutyListRosterResponse, error)

列出值班表

func (*ShenhaiplatformClient) ManageHubDutyListWatchman ¶

func (c *ShenhaiplatformClient) ManageHubDutyListWatchman(request *shenhaiplatform.ManageHubDutyListWatchmanRequest) (*shenhaiplatform.ManageHubDutyListWatchmanResponse, error)

列出值班人

func (*ShenhaiplatformClient) ManageHubDutyUpdateRoster ¶

func (c *ShenhaiplatformClient) ManageHubDutyUpdateRoster(request *shenhaiplatform.ManageHubDutyUpdateRosterRequest) (*shenhaiplatform.ManageHubDutyUpdateRosterResponse, error)

修改值班表

func (*ShenhaiplatformClient) ManageHubDutyUpdateWatchman ¶

func (c *ShenhaiplatformClient) ManageHubDutyUpdateWatchman(request *shenhaiplatform.ManageHubDutyUpdateWatchmanRequest) (*shenhaiplatform.ManageHubDutyUpdateWatchmanResponse, error)

更新值班人

func (*ShenhaiplatformClient) ManageHubGravityJobChild ¶

func (c *ShenhaiplatformClient) ManageHubGravityJobChild(request *shenhaiplatform.ManageHubGravityJobChildRequest) (*shenhaiplatform.ManageHubGravityJobChildResponse, error)

分页查询子任务列表

func (*ShenhaiplatformClient) ManageHubGravityJobLog ¶

func (c *ShenhaiplatformClient) ManageHubGravityJobLog(request *shenhaiplatform.ManageHubGravityJobLogRequest) (*shenhaiplatform.ManageHubGravityJobLogResponse, error)

查询计算任务日志

func (*ShenhaiplatformClient) ManageHubGravityJobOperateHistory ¶

func (c *ShenhaiplatformClient) ManageHubGravityJobOperateHistory(request *shenhaiplatform.ManageHubGravityJobOperateHistoryRequest) (*shenhaiplatform.ManageHubGravityJobOperateHistoryResponse, error)

分页查询任务操作历史

func (*ShenhaiplatformClient) ManageHubGravityJobParent ¶

func (c *ShenhaiplatformClient) ManageHubGravityJobParent(request *shenhaiplatform.ManageHubGravityJobParentRequest) (*shenhaiplatform.ManageHubGravityJobParentResponse, error)

分页查询父任务列表

func (*ShenhaiplatformClient) ManageHubGravityJobProperty ¶

func (c *ShenhaiplatformClient) ManageHubGravityJobProperty(request *shenhaiplatform.ManageHubGravityJobPropertyRequest) (*shenhaiplatform.ManageHubGravityJobPropertyResponse, error)

任务属性

func (*ShenhaiplatformClient) ManageHubGravityJobRunHistory ¶

func (c *ShenhaiplatformClient) ManageHubGravityJobRunHistory(request *shenhaiplatform.ManageHubGravityJobRunHistoryRequest) (*shenhaiplatform.ManageHubGravityJobRunHistoryResponse, error)

分页查询任务运行历史

func (*ShenhaiplatformClient) ManageHubGravityJobType ¶

func (c *ShenhaiplatformClient) ManageHubGravityJobType(request *shenhaiplatform.ManageHubGravityJobTypeRequest) (*shenhaiplatform.ManageHubGravityJobTypeResponse, error)

作业父子类型枚举

func (*ShenhaiplatformClient) ManageHubGravityKill ¶

func (c *ShenhaiplatformClient) ManageHubGravityKill(request *shenhaiplatform.ManageHubGravityKillRequest) (*shenhaiplatform.ManageHubGravityKillResponse, error)

终止作业

func (*ShenhaiplatformClient) ManageHubGravityListJob ¶

func (c *ShenhaiplatformClient) ManageHubGravityListJob(request *shenhaiplatform.ManageHubGravityListJobRequest) (*shenhaiplatform.ManageHubGravityListJobResponse, error)

分页查询作业列表

func (*ShenhaiplatformClient) ManageHubGravityListTxDateStatus ¶

func (c *ShenhaiplatformClient) ManageHubGravityListTxDateStatus(request *shenhaiplatform.ManageHubGravityListTxDateStatusRequest) (*shenhaiplatform.ManageHubGravityListTxDateStatusResponse, error)

分页查询作业数据日期状态列表

func (*ShenhaiplatformClient) ManageHubGravityOneClickRerun ¶

func (c *ShenhaiplatformClient) ManageHubGravityOneClickRerun(request *shenhaiplatform.ManageHubGravityOneClickRerunRequest) (*shenhaiplatform.ManageHubGravityOneClickRerunResponse, error)

一键重跑

func (*ShenhaiplatformClient) ManageHubGravityOneClickRerunBatches ¶

func (c *ShenhaiplatformClient) ManageHubGravityOneClickRerunBatches(request *shenhaiplatform.ManageHubGravityOneClickRerunBatchesRequest) (*shenhaiplatform.ManageHubGravityOneClickRerunBatchesResponse, error)

一键重跑批次记录

func (*ShenhaiplatformClient) ManageHubGravityOneClickRerunPreview ¶

func (c *ShenhaiplatformClient) ManageHubGravityOneClickRerunPreview(request *shenhaiplatform.ManageHubGravityOneClickRerunPreviewRequest) (*shenhaiplatform.ManageHubGravityOneClickRerunPreviewResponse, error)

一键重跑预览

func (*ShenhaiplatformClient) ManageHubGravityOneClickRerunResubmit ¶

func (c *ShenhaiplatformClient) ManageHubGravityOneClickRerunResubmit(request *shenhaiplatform.ManageHubGravityOneClickRerunResubmitRequest) (*shenhaiplatform.ManageHubGravityOneClickRerunResubmitResponse, error)

一键重跑任务重新提交

func (*ShenhaiplatformClient) ManageHubGravityOneClickRerunTasks ¶

func (c *ShenhaiplatformClient) ManageHubGravityOneClickRerunTasks(request *shenhaiplatform.ManageHubGravityOneClickRerunTasksRequest) (*shenhaiplatform.ManageHubGravityOneClickRerunTasksResponse, error)

一键重跑任务详情

func (*ShenhaiplatformClient) ManageHubGravityRerun ¶

func (c *ShenhaiplatformClient) ManageHubGravityRerun(request *shenhaiplatform.ManageHubGravityRerunRequest) (*shenhaiplatform.ManageHubGravityRerunResponse, error)

重跑作业

func (*ShenhaiplatformClient) ManageHubGravityReset ¶

func (c *ShenhaiplatformClient) ManageHubGravityReset(request *shenhaiplatform.ManageHubGravityResetRequest) (*shenhaiplatform.ManageHubGravityResetResponse, error)

重置作业

func (*ShenhaiplatformClient) ManageHubStorageDetails ¶

func (c *ShenhaiplatformClient) ManageHubStorageDetails(request *shenhaiplatform.ManageHubStorageDetailsRequest) (*shenhaiplatform.ManageHubStorageDetailsResponse, error)

租户/库/表存储详情

func (*ShenhaiplatformClient) ManageHubStorageIncrement ¶

func (c *ShenhaiplatformClient) ManageHubStorageIncrement(request *shenhaiplatform.ManageHubStorageIncrementRequest) (*shenhaiplatform.ManageHubStorageIncrementResponse, error)

每日存储增量

func (*ShenhaiplatformClient) ManageHubStoragePartitionList ¶

func (c *ShenhaiplatformClient) ManageHubStoragePartitionList(request *shenhaiplatform.ManageHubStoragePartitionListRequest) (*shenhaiplatform.ManageHubStoragePartitionListResponse, error)

列出分区存储详情

func (*ShenhaiplatformClient) ManageHubStorageSummary ¶

func (c *ShenhaiplatformClient) ManageHubStorageSummary(request *shenhaiplatform.ManageHubStorageSummaryRequest) (*shenhaiplatform.ManageHubStorageSummaryResponse, error)

存储概览

func (*ShenhaiplatformClient) ManageHubStorageTableDDL ¶

func (c *ShenhaiplatformClient) ManageHubStorageTableDDL(request *shenhaiplatform.ManageHubStorageTableDDLRequest) (*shenhaiplatform.ManageHubStorageTableDDLResponse, error)

查询表DDL

func (*ShenhaiplatformClient) PackagePublishObj ¶

func (c *ShenhaiplatformClient) PackagePublishObj(request *shenhaiplatform.PackagePublishObjRequest) (*shenhaiplatform.PackagePublishObjResponse, error)

将发布物打包

func (*ShenhaiplatformClient) PreviewPackage ¶

func (c *ShenhaiplatformClient) PreviewPackage(request *shenhaiplatform.PreviewPackageRequest) (*shenhaiplatform.PreviewPackageResponse, error)

发布包信息预览

func (*ShenhaiplatformClient) PublishPkg ¶

func (c *ShenhaiplatformClient) PublishPkg(request *shenhaiplatform.PublishPkgRequest) (*shenhaiplatform.PublishPkgResponse, error)

发布发布包

func (*ShenhaiplatformClient) QueryList ¶

func (c *ShenhaiplatformClient) QueryList(request *shenhaiplatform.QueryListRequest) (*shenhaiplatform.QueryListResponse, error)

节点发布状态public_status 节点发布变更类型 public_chage_type

func (*ShenhaiplatformClient) SetConfig ¶

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

func (*ShenhaiplatformClient) SetLogger ¶

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

func (*ShenhaiplatformClient) UranusCatalogDelete ¶

func (c *ShenhaiplatformClient) UranusCatalogDelete(request *shenhaiplatform.UranusCatalogDeleteRequest) (*shenhaiplatform.UranusCatalogDeleteResponse, error)

根据父目录CODE删除目录

func (*ShenhaiplatformClient) UranusCatalogQueryList ¶

func (c *ShenhaiplatformClient) UranusCatalogQueryList(request *shenhaiplatform.UranusCatalogQueryListRequest) (*shenhaiplatform.UranusCatalogQueryListResponse, error)

目录根据companyCode查询目录

func (*ShenhaiplatformClient) UranusCatalogSave ¶

func (c *ShenhaiplatformClient) UranusCatalogSave(request *shenhaiplatform.UranusCatalogSaveRequest) (*shenhaiplatform.UranusCatalogSaveResponse, error)

创建新的目录

func (*ShenhaiplatformClient) UranusCatalogUpdate ¶

func (c *ShenhaiplatformClient) UranusCatalogUpdate(request *shenhaiplatform.UranusCatalogUpdateRequest) (*shenhaiplatform.UranusCatalogUpdateResponse, error)

修改目录属性

func (*ShenhaiplatformClient) UranusDataLoadHistory ¶

func (c *ShenhaiplatformClient) UranusDataLoadHistory(request *shenhaiplatform.UranusDataLoadHistoryRequest) (*shenhaiplatform.UranusDataLoadHistoryResponse, error)

数据上传历史任务

func (*ShenhaiplatformClient) UranusDataLoadKill ¶

func (c *ShenhaiplatformClient) UranusDataLoadKill(request *shenhaiplatform.UranusDataLoadKillRequest) (*shenhaiplatform.UranusDataLoadKillResponse, error)

终止数据上传任务

func (*ShenhaiplatformClient) UranusDataLoadLog ¶

func (c *ShenhaiplatformClient) UranusDataLoadLog(request *shenhaiplatform.UranusDataLoadLogRequest) (*shenhaiplatform.UranusDataLoadLogResponse, error)

获取数据上传任务日志

func (*ShenhaiplatformClient) UranusDataLoadPreview ¶

func (c *ShenhaiplatformClient) UranusDataLoadPreview(request *shenhaiplatform.UranusDataLoadPreviewRequest) (*shenhaiplatform.UranusDataLoadPreviewResponse, error)

数据预览

func (*ShenhaiplatformClient) UranusDictQuerySysParam ¶

func (c *ShenhaiplatformClient) UranusDictQuerySysParam(request *shenhaiplatform.UranusDictQuerySysParamRequest) (*shenhaiplatform.UranusDictQuerySysParamResponse, error)

查询系统参数

func (*ShenhaiplatformClient) UranusDictTableCode ¶

func (c *ShenhaiplatformClient) UranusDictTableCode(request *shenhaiplatform.UranusDictTableCodeRequest) (*shenhaiplatform.UranusDictTableCodeResponse, error)

建表的列类型查询

func (*ShenhaiplatformClient) UranusExtraRunnerParamParse ¶

func (c *ShenhaiplatformClient) UranusExtraRunnerParamParse(request *shenhaiplatform.UranusExtraRunnerParamParseRequest) (*shenhaiplatform.UranusExtraRunnerParamParseResponse, error)

解析脚本中参数

func (*ShenhaiplatformClient) UranusExtraRunnerResult ¶

func (c *ShenhaiplatformClient) UranusExtraRunnerResult(request *shenhaiplatform.UranusExtraRunnerResultRequest) (*shenhaiplatform.UranusExtraRunnerResultResponse, error)

获取查询结果

func (*ShenhaiplatformClient) UranusExtraRunnerResultList ¶

func (c *ShenhaiplatformClient) UranusExtraRunnerResultList(request *shenhaiplatform.UranusExtraRunnerResultListRequest) (*shenhaiplatform.UranusExtraRunnerResultListResponse, error)

获取查询结果文件列表

func (*ShenhaiplatformClient) UranusExtraRunnerStart ¶

func (c *ShenhaiplatformClient) UranusExtraRunnerStart(request *shenhaiplatform.UranusExtraRunnerStartRequest) (*shenhaiplatform.UranusExtraRunnerStartResponse, error)

执行查询

func (*ShenhaiplatformClient) UranusExtraRunnerStop ¶

func (c *ShenhaiplatformClient) UranusExtraRunnerStop(request *shenhaiplatform.UranusExtraRunnerStopRequest) (*shenhaiplatform.UranusExtraRunnerStopResponse, error)

停止查询

func (*ShenhaiplatformClient) UranusFunctionCheck ¶

func (c *ShenhaiplatformClient) UranusFunctionCheck(request *shenhaiplatform.UranusFunctionCheckRequest) (*shenhaiplatform.UranusFunctionCheckResponse, error)

判断目录/函数是否存在

func (*ShenhaiplatformClient) UranusFunctionCreate ¶

func (c *ShenhaiplatformClient) UranusFunctionCreate(request *shenhaiplatform.UranusFunctionCreateRequest) (*shenhaiplatform.UranusFunctionCreateResponse, error)

新建函数

func (*ShenhaiplatformClient) UranusFunctionCreateCatalog ¶

func (c *ShenhaiplatformClient) UranusFunctionCreateCatalog(request *shenhaiplatform.UranusFunctionCreateCatalogRequest) (*shenhaiplatform.UranusFunctionCreateCatalogResponse, error)

创建函数分类目录

func (*ShenhaiplatformClient) UranusFunctionDelete ¶

func (c *ShenhaiplatformClient) UranusFunctionDelete(request *shenhaiplatform.UranusFunctionDeleteRequest) (*shenhaiplatform.UranusFunctionDeleteResponse, error)

删除函数

func (*ShenhaiplatformClient) UranusFunctionDeleteCatalog ¶

func (c *ShenhaiplatformClient) UranusFunctionDeleteCatalog(request *shenhaiplatform.UranusFunctionDeleteCatalogRequest) (*shenhaiplatform.UranusFunctionDeleteCatalogResponse, error)

删除函数分类目录

func (*ShenhaiplatformClient) UranusFunctionGetById ¶

func (c *ShenhaiplatformClient) UranusFunctionGetById(request *shenhaiplatform.UranusFunctionGetByIdRequest) (*shenhaiplatform.UranusFunctionGetByIdResponse, error)

根据函数id查询函数

func (*ShenhaiplatformClient) UranusFunctionListCatalog ¶

func (c *ShenhaiplatformClient) UranusFunctionListCatalog(request *shenhaiplatform.UranusFunctionListCatalogRequest) (*shenhaiplatform.UranusFunctionListCatalogResponse, error)

获取所有分类目录

func (*ShenhaiplatformClient) UranusFunctionPublish ¶

func (c *ShenhaiplatformClient) UranusFunctionPublish(request *shenhaiplatform.UranusFunctionPublishRequest) (*shenhaiplatform.UranusFunctionPublishResponse, error)

发布函数到发布中心

func (*ShenhaiplatformClient) UranusFunctionUpdate ¶

func (c *ShenhaiplatformClient) UranusFunctionUpdate(request *shenhaiplatform.UranusFunctionUpdateRequest) (*shenhaiplatform.UranusFunctionUpdateResponse, error)

更新函数

func (*ShenhaiplatformClient) UranusQueryFileTree ¶

func (c *ShenhaiplatformClient) UranusQueryFileTree(request *shenhaiplatform.UranusQueryFileTreeRequest) (*shenhaiplatform.UranusQueryFileTreeResponse, error)

获取目录树

func (*ShenhaiplatformClient) UranusQueryJarManagementTree ¶

func (c *ShenhaiplatformClient) UranusQueryJarManagementTree(request *shenhaiplatform.UranusQueryJarManagementTreeRequest) (*shenhaiplatform.UranusQueryJarManagementTreeResponse, error)

根据空间code获取jar包目录树

func (*ShenhaiplatformClient) UranusQueryList ¶

func (c *ShenhaiplatformClient) UranusQueryList(request *shenhaiplatform.UranusQueryListRequest) (*shenhaiplatform.UranusQueryListResponse, error)

工作流目录树

func (*ShenhaiplatformClient) UranusResourceAppendFile ¶

func (c *ShenhaiplatformClient) UranusResourceAppendFile(request *shenhaiplatform.UranusResourceAppendFileRequest) (*shenhaiplatform.UranusResourceAppendFileResponse, error)

上传资源

func (*ShenhaiplatformClient) UranusResourceCloseFile ¶

func (c *ShenhaiplatformClient) UranusResourceCloseFile(request *shenhaiplatform.UranusResourceCloseFileRequest) (*shenhaiplatform.UranusResourceCloseFileResponse, error)

完成并关闭资源上传

func (*ShenhaiplatformClient) UranusResourceCreate ¶

func (c *ShenhaiplatformClient) UranusResourceCreate(request *shenhaiplatform.UranusResourceCreateRequest) (*shenhaiplatform.UranusResourceCreateResponse, error)

新建资源（包含资源目录和资源文件）

func (*ShenhaiplatformClient) UranusResourceDelete ¶

func (c *ShenhaiplatformClient) UranusResourceDelete(request *shenhaiplatform.UranusResourceDeleteRequest) (*shenhaiplatform.UranusResourceDeleteResponse, error)

删除资源

func (*ShenhaiplatformClient) UranusResourceDownloadUrl ¶

func (c *ShenhaiplatformClient) UranusResourceDownloadUrl(request *shenhaiplatform.UranusResourceDownloadUrlRequest) (*shenhaiplatform.UranusResourceDownloadUrlResponse, error)

获取资源下载链接

func (*ShenhaiplatformClient) UranusResourceGetBriefByCodes ¶

func (c *ShenhaiplatformClient) UranusResourceGetBriefByCodes(request *shenhaiplatform.UranusResourceGetBriefByCodesRequest) (*shenhaiplatform.UranusResourceGetBriefByCodesResponse, error)

获取资源简要信息（根据资源codes）

func (*ShenhaiplatformClient) UranusResourceGetBriefByPrefix ¶

func (c *ShenhaiplatformClient) UranusResourceGetBriefByPrefix(request *shenhaiplatform.UranusResourceGetBriefByPrefixRequest) (*shenhaiplatform.UranusResourceGetBriefByPrefixResponse, error)

获取资源简要信息(前缀匹配资源名称)

func (*ShenhaiplatformClient) UranusResourceGetDetailByPrefix ¶

func (c *ShenhaiplatformClient) UranusResourceGetDetailByPrefix(request *shenhaiplatform.UranusResourceGetDetailByPrefixRequest) (*shenhaiplatform.UranusResourceGetDetailByPrefixResponse, error)

获取资源简要信息(前缀匹配资源名称)

func (*ShenhaiplatformClient) UranusResourceListDirectory ¶

func (c *ShenhaiplatformClient) UranusResourceListDirectory(request *shenhaiplatform.UranusResourceListDirectoryRequest) (*shenhaiplatform.UranusResourceListDirectoryResponse, error)

列出所有目录(只包含目录)

func (*ShenhaiplatformClient) UranusResourceListRoot ¶

func (c *ShenhaiplatformClient) UranusResourceListRoot(request *shenhaiplatform.UranusResourceListRootRequest) (*shenhaiplatform.UranusResourceListRootResponse, error)

列出所有根目录(只包含根目录)

func (*ShenhaiplatformClient) UranusResourceListRootResources ¶

func (c *ShenhaiplatformClient) UranusResourceListRootResources(request *shenhaiplatform.UranusResourceListRootResourcesRequest) (*shenhaiplatform.UranusResourceListRootResourcesResponse, error)

列出根目录下所有资源

func (*ShenhaiplatformClient) UranusResourcePublish ¶

func (c *ShenhaiplatformClient) UranusResourcePublish(request *shenhaiplatform.UranusResourcePublishRequest) (*shenhaiplatform.UranusResourcePublishResponse, error)

发布资源

func (*ShenhaiplatformClient) UranusResourceStatus ¶

func (c *ShenhaiplatformClient) UranusResourceStatus(request *shenhaiplatform.UranusResourceStatusRequest) (*shenhaiplatform.UranusResourceStatusResponse, error)

获取资源状态

func (*ShenhaiplatformClient) UranusResourceUpdate ¶

func (c *ShenhaiplatformClient) UranusResourceUpdate(request *shenhaiplatform.UranusResourceUpdateRequest) (*shenhaiplatform.UranusResourceUpdateResponse, error)

更新资源

func (*ShenhaiplatformClient) UranusScriptGetScriptRunResult ¶

func (c *ShenhaiplatformClient) UranusScriptGetScriptRunResult(request *shenhaiplatform.UranusScriptGetScriptRunResultRequest) (*shenhaiplatform.UranusScriptGetScriptRunResultResponse, error)

获取运行脚本结果

func (*ShenhaiplatformClient) UranusScriptGetScriptRunResultList ¶

func (c *ShenhaiplatformClient) UranusScriptGetScriptRunResultList(request *shenhaiplatform.UranusScriptGetScriptRunResultListRequest) (*shenhaiplatform.UranusScriptGetScriptRunResultListResponse, error)

获取运行脚本结果列表

func (*ShenhaiplatformClient) UranusScriptParams ¶

func (c *ShenhaiplatformClient) UranusScriptParams(request *shenhaiplatform.UranusScriptParamsRequest) (*shenhaiplatform.UranusScriptParamsResponse, error)

脚本参数保存/更新

func (*ShenhaiplatformClient) UranusScriptQueries ¶

func (c *ShenhaiplatformClient) UranusScriptQueries(request *shenhaiplatform.UranusScriptQueriesRequest) (*shenhaiplatform.UranusScriptQueriesResponse, error)

获得脚本详情

func (*ShenhaiplatformClient) UranusScriptQueryParams ¶

func (c *ShenhaiplatformClient) UranusScriptQueryParams(request *shenhaiplatform.UranusScriptQueryParamsRequest) (*shenhaiplatform.UranusScriptQueryParamsResponse, error)

查询脚本参数或任务参数

func (*ShenhaiplatformClient) UranusScriptRunLogContent ¶

func (c *ShenhaiplatformClient) UranusScriptRunLogContent(request *shenhaiplatform.UranusScriptRunLogContentRequest) (*shenhaiplatform.UranusScriptRunLogContentResponse, error)

获得脚本运行的内容

func (*ShenhaiplatformClient) UranusScriptRunLogDetail ¶

func (c *ShenhaiplatformClient) UranusScriptRunLogDetail(request *shenhaiplatform.UranusScriptRunLogDetailRequest) (*shenhaiplatform.UranusScriptRunLogDetailResponse, error)

获得脚本运行记录详情

func (*ShenhaiplatformClient) UranusScriptRunLogList ¶

func (c *ShenhaiplatformClient) UranusScriptRunLogList(request *shenhaiplatform.UranusScriptRunLogListRequest) (*shenhaiplatform.UranusScriptRunLogListResponse, error)

脚本运行列表

func (*ShenhaiplatformClient) UranusScriptRunLogLogContent ¶

func (c *ShenhaiplatformClient) UranusScriptRunLogLogContent(request *shenhaiplatform.UranusScriptRunLogLogContentRequest) (*shenhaiplatform.UranusScriptRunLogLogContentResponse, error)

获得脚本运行日志

func (*ShenhaiplatformClient) UranusScriptSaveContent ¶

func (c *ShenhaiplatformClient) UranusScriptSaveContent(request *shenhaiplatform.UranusScriptSaveContentRequest) (*shenhaiplatform.UranusScriptSaveContentResponse, error)

脚本内容更新

func (*ShenhaiplatformClient) UranusScriptStarters ¶

func (c *ShenhaiplatformClient) UranusScriptStarters(request *shenhaiplatform.UranusScriptStartersRequest) (*shenhaiplatform.UranusScriptStartersResponse, error)

执行脚本

func (*ShenhaiplatformClient) UranusScriptStop ¶

func (c *ShenhaiplatformClient) UranusScriptStop(request *shenhaiplatform.UranusScriptStopRequest) (*shenhaiplatform.UranusScriptStopResponse, error)

停止脚本

func (*ShenhaiplatformClient) UranusScriptSyntaxCheck ¶

func (c *ShenhaiplatformClient) UranusScriptSyntaxCheck(request *shenhaiplatform.UranusScriptSyntaxCheckRequest) (*shenhaiplatform.UranusScriptSyntaxCheckResponse, error)

sql语法检测

func (*ShenhaiplatformClient) UranusScriptVerifyScriptFileDepend ¶

func (c *ShenhaiplatformClient) UranusScriptVerifyScriptFileDepend(request *shenhaiplatform.UranusScriptVerifyScriptFileDependRequest) (*shenhaiplatform.UranusScriptVerifyScriptFileDependResponse, error)

脚本检测依赖

func (*ShenhaiplatformClient) UranusTableAlterSqlView ¶

func (c *ShenhaiplatformClient) UranusTableAlterSqlView(request *shenhaiplatform.UranusTableAlterSqlViewRequest) (*shenhaiplatform.UranusTableAlterSqlViewResponse, error)

发布，保存发布，更新发布等等

func (*ShenhaiplatformClient) UranusTableCheckTableName ¶

func (c *ShenhaiplatformClient) UranusTableCheckTableName(request *shenhaiplatform.UranusTableCheckTableNameRequest) (*shenhaiplatform.UranusTableCheckTableNameResponse, error)

查询授权表

func (*ShenhaiplatformClient) UranusTableColumn ¶

func (c *ShenhaiplatformClient) UranusTableColumn(request *shenhaiplatform.UranusTableColumnRequest) (*shenhaiplatform.UranusTableColumnResponse, error)

查询授权表的列数据

func (*ShenhaiplatformClient) UranusTableDDL ¶

func (c *ShenhaiplatformClient) UranusTableDDL(request *shenhaiplatform.UranusTableDDLRequest) (*shenhaiplatform.UranusTableDDLResponse, error)

获取具体表的建表语句

func (*ShenhaiplatformClient) UranusTableDataDownload ¶

func (c *ShenhaiplatformClient) UranusTableDataDownload(request *shenhaiplatform.UranusTableDataDownloadRequest) (*shenhaiplatform.UranusTableDataDownloadResponse, error)

数据下载

func (*ShenhaiplatformClient) UranusTableDataLoad ¶

func (c *ShenhaiplatformClient) UranusTableDataLoad(request *shenhaiplatform.UranusTableDataLoadRequest) (*shenhaiplatform.UranusTableDataLoadResponse, error)

数据上传

func (*ShenhaiplatformClient) UranusTableDdlAnalyze ¶

func (c *ShenhaiplatformClient) UranusTableDdlAnalyze(request *shenhaiplatform.UranusTableDdlAnalyzeRequest) (*shenhaiplatform.UranusTableDdlAnalyzeResponse, error)

DDL语句解析

func (*ShenhaiplatformClient) UranusTableDelete ¶

func (c *ShenhaiplatformClient) UranusTableDelete(request *shenhaiplatform.UranusTableDeleteRequest) (*shenhaiplatform.UranusTableDeleteResponse, error)

删除表

func (*ShenhaiplatformClient) UranusTableDelimiters ¶

func (c *ShenhaiplatformClient) UranusTableDelimiters(request *shenhaiplatform.UranusTableDelimitersRequest) (*shenhaiplatform.UranusTableDelimitersResponse, error)

表分隔符信息

func (*ShenhaiplatformClient) UranusTableLike ¶

func (c *ShenhaiplatformClient) UranusTableLike(request *shenhaiplatform.UranusTableLikeRequest) (*shenhaiplatform.UranusTableLikeResponse, error)

查询授权表

func (*ShenhaiplatformClient) UranusTablePublish ¶

func (c *ShenhaiplatformClient) UranusTablePublish(request *shenhaiplatform.UranusTablePublishRequest) (*shenhaiplatform.UranusTablePublishResponse, error)

发布，保存发布，更新发布等等

func (*ShenhaiplatformClient) UranusTablePublishToPublishCenter ¶

func (c *ShenhaiplatformClient) UranusTablePublishToPublishCenter(request *shenhaiplatform.UranusTablePublishToPublishCenterRequest) (*shenhaiplatform.UranusTablePublishToPublishCenterResponse, error)

发布表变更信息

func (*ShenhaiplatformClient) UranusTableUnpublishedInfo ¶

func (c *ShenhaiplatformClient) UranusTableUnpublishedInfo(request *shenhaiplatform.UranusTableUnpublishedInfoRequest) (*shenhaiplatform.UranusTableUnpublishedInfoResponse, error)

查询未发布的表变更信息

func (*ShenhaiplatformClient) UranusTaskAddRelation ¶

func (c *ShenhaiplatformClient) UranusTaskAddRelation(request *shenhaiplatform.UranusTaskAddRelationRequest) (*shenhaiplatform.UranusTaskAddRelationResponse, error)

任务节点保存-多节点关系

func (*ShenhaiplatformClient) UranusTaskDependExportParamList ¶

func (c *ShenhaiplatformClient) UranusTaskDependExportParamList(request *shenhaiplatform.UranusTaskDependExportParamListRequest) (*shenhaiplatform.UranusTaskDependExportParamListResponse, error)

任务依赖节点的输出参数查询

func (*ShenhaiplatformClient) UranusTaskDetail ¶

func (c *ShenhaiplatformClient) UranusTaskDetail(request *shenhaiplatform.UranusTaskDetailRequest) (*shenhaiplatform.UranusTaskDetailResponse, error)

任务单节点-详情

func (*ShenhaiplatformClient) UranusTaskElementDelimiters ¶

func (c *ShenhaiplatformClient) UranusTaskElementDelimiters(request *shenhaiplatform.UranusTaskElementDelimitersRequest) (*shenhaiplatform.UranusTaskElementDelimitersResponse, error)

分隔符信息

func (*ShenhaiplatformClient) UranusTaskExportParamList ¶

func (c *ShenhaiplatformClient) UranusTaskExportParamList(request *shenhaiplatform.UranusTaskExportParamListRequest) (*shenhaiplatform.UranusTaskExportParamListResponse, error)

任务节点输出参数查询

func (*ShenhaiplatformClient) UranusTaskFlowCheck ¶

func (c *ShenhaiplatformClient) UranusTaskFlowCheck(request *shenhaiplatform.UranusTaskFlowCheckRequest) (*shenhaiplatform.UranusTaskFlowCheckResponse, error)

检查工作流名称

func (*ShenhaiplatformClient) UranusTaskFlowCollection ¶

func (c *ShenhaiplatformClient) UranusTaskFlowCollection(request *shenhaiplatform.UranusTaskFlowCollectionRequest) (*shenhaiplatform.UranusTaskFlowCollectionResponse, error)

工作流收藏和取消收藏

func (*ShenhaiplatformClient) UranusTaskFlowDelete ¶

func (c *ShenhaiplatformClient) UranusTaskFlowDelete(request *shenhaiplatform.UranusTaskFlowDeleteRequest) (*shenhaiplatform.UranusTaskFlowDeleteResponse, error)

工作流删除

func (*ShenhaiplatformClient) UranusTaskFlowDetail ¶

func (c *ShenhaiplatformClient) UranusTaskFlowDetail(request *shenhaiplatform.UranusTaskFlowDetailRequest) (*shenhaiplatform.UranusTaskFlowDetailResponse, error)

工作流详情

func (*ShenhaiplatformClient) UranusTaskFlowListTree ¶

func (c *ShenhaiplatformClient) UranusTaskFlowListTree(request *shenhaiplatform.UranusTaskFlowListTreeRequest) (*shenhaiplatform.UranusTaskFlowListTreeResponse, error)

工作流目录树

func (*ShenhaiplatformClient) UranusTaskFlowQueryList ¶

func (c *ShenhaiplatformClient) UranusTaskFlowQueryList(request *shenhaiplatform.UranusTaskFlowQueryListRequest) (*shenhaiplatform.UranusTaskFlowQueryListResponse, error)

目录下工作流列表

func (*ShenhaiplatformClient) UranusTaskFlowSave ¶

func (c *ShenhaiplatformClient) UranusTaskFlowSave(request *shenhaiplatform.UranusTaskFlowSaveRequest) (*shenhaiplatform.UranusTaskFlowSaveResponse, error)

工作流新建

func (*ShenhaiplatformClient) UranusTaskFlowUpdate ¶

func (c *ShenhaiplatformClient) UranusTaskFlowUpdate(request *shenhaiplatform.UranusTaskFlowUpdateRequest) (*shenhaiplatform.UranusTaskFlowUpdateResponse, error)

工作流更新

func (*ShenhaiplatformClient) UranusTaskGetRelation ¶

func (c *ShenhaiplatformClient) UranusTaskGetRelation(request *shenhaiplatform.UranusTaskGetRelationRequest) (*shenhaiplatform.UranusTaskGetRelationResponse, error)

任务节点详情-多节点关系

func (*ShenhaiplatformClient) UranusTaskInfoAnalysisDependJob ¶

func (c *ShenhaiplatformClient) UranusTaskInfoAnalysisDependJob(request *shenhaiplatform.UranusTaskInfoAnalysisDependJobRequest) (*shenhaiplatform.UranusTaskInfoAnalysisDependJobResponse, error)

根据脚本内容解析父任务依赖

func (*ShenhaiplatformClient) UranusTaskInfoAnalysisOutputTable ¶

func (c *ShenhaiplatformClient) UranusTaskInfoAnalysisOutputTable(request *shenhaiplatform.UranusTaskInfoAnalysisOutputTableRequest) (*shenhaiplatform.UranusTaskInfoAnalysisOutputTableResponse, error)

根据脚本内容解析输出表

func (*ShenhaiplatformClient) UranusTaskInfoDetail ¶

func (c *ShenhaiplatformClient) UranusTaskInfoDetail(request *shenhaiplatform.UranusTaskInfoDetailRequest) (*shenhaiplatform.UranusTaskInfoDetailResponse, error)

任务详情

func (*ShenhaiplatformClient) UranusTaskInfoFuzzyListJobName ¶

func (c *ShenhaiplatformClient) UranusTaskInfoFuzzyListJobName(request *shenhaiplatform.UranusTaskInfoFuzzyListJobNameRequest) (*shenhaiplatform.UranusTaskInfoFuzzyListJobNameResponse, error)

模糊查询作业信息

func (*ShenhaiplatformClient) UranusTaskInfoGetTaskCode ¶

func (c *ShenhaiplatformClient) UranusTaskInfoGetTaskCode(request *shenhaiplatform.UranusTaskInfoGetTaskCodeRequest) (*shenhaiplatform.UranusTaskInfoGetTaskCodeResponse, error)

获取taskCode

func (*ShenhaiplatformClient) UranusTaskInfoHistoryList ¶

func (c *ShenhaiplatformClient) UranusTaskInfoHistoryList(request *shenhaiplatform.UranusTaskInfoHistoryListRequest) (*shenhaiplatform.UranusTaskInfoHistoryListResponse, error)

任务节点版本查看

func (*ShenhaiplatformClient) UranusTaskInfoJobPublishType ¶

func (c *ShenhaiplatformClient) UranusTaskInfoJobPublishType(request *shenhaiplatform.UranusTaskInfoJobPublishTypeRequest) (*shenhaiplatform.UranusTaskInfoJobPublishTypeResponse, error)

作业发布类型 新增或更新 参数为流程画布节点主键

func (*ShenhaiplatformClient) UranusTaskInfoLockDetail ¶

func (c *ShenhaiplatformClient) UranusTaskInfoLockDetail(request *shenhaiplatform.UranusTaskInfoLockDetailRequest) (*shenhaiplatform.UranusTaskInfoLockDetailResponse, error)

抢锁时获取任务信息

func (*ShenhaiplatformClient) UranusTaskInfoOnLineConfig ¶

func (c *ShenhaiplatformClient) UranusTaskInfoOnLineConfig(request *shenhaiplatform.UranusTaskInfoOnLineConfigRequest) (*shenhaiplatform.UranusTaskInfoOnLineConfigResponse, error)

使用线上配置

func (*ShenhaiplatformClient) UranusTaskInfoPrePublish ¶

func (c *ShenhaiplatformClient) UranusTaskInfoPrePublish(request *shenhaiplatform.UranusTaskInfoPrePublishRequest) (*shenhaiplatform.UranusTaskInfoPrePublishResponse, error)

任务预发布

func (*ShenhaiplatformClient) UranusTaskInfoPublish ¶

func (c *ShenhaiplatformClient) UranusTaskInfoPublish(request *shenhaiplatform.UranusTaskInfoPublishRequest) (*shenhaiplatform.UranusTaskInfoPublishResponse, error)

任务发布

func (*ShenhaiplatformClient) UranusTaskInfoRePublish ¶

func (c *ShenhaiplatformClient) UranusTaskInfoRePublish(request *shenhaiplatform.UranusTaskInfoRePublishRequest) (*shenhaiplatform.UranusTaskInfoRePublishResponse, error)

任务重新发布

func (*ShenhaiplatformClient) UranusTaskInfoSave ¶

func (c *ShenhaiplatformClient) UranusTaskInfoSave(request *shenhaiplatform.UranusTaskInfoSaveRequest) (*shenhaiplatform.UranusTaskInfoSaveResponse, error)

任务保存

func (*ShenhaiplatformClient) UranusTaskInfoSparkVersion ¶

func (c *ShenhaiplatformClient) UranusTaskInfoSparkVersion(request *shenhaiplatform.UranusTaskInfoSparkVersionRequest) (*shenhaiplatform.UranusTaskInfoSparkVersionResponse, error)

获取spark版本

func (*ShenhaiplatformClient) UranusTaskNodeCheckJobName ¶

func (c *ShenhaiplatformClient) UranusTaskNodeCheckJobName(request *shenhaiplatform.UranusTaskNodeCheckJobNameRequest) (*shenhaiplatform.UranusTaskNodeCheckJobNameResponse, error)

任务单节点-校验作业名称

func (*ShenhaiplatformClient) UranusTaskNodeDelete ¶

func (c *ShenhaiplatformClient) UranusTaskNodeDelete(request *shenhaiplatform.UranusTaskNodeDeleteRequest) (*shenhaiplatform.UranusTaskNodeDeleteResponse, error)

任务单节点-删除

func (*ShenhaiplatformClient) UranusTaskNodeList ¶

func (c *ShenhaiplatformClient) UranusTaskNodeList(request *shenhaiplatform.UranusTaskNodeListRequest) (*shenhaiplatform.UranusTaskNodeListResponse, error)

流程画布-节点管理列表

func (*ShenhaiplatformClient) UranusTaskNodeSave ¶

func (c *ShenhaiplatformClient) UranusTaskNodeSave(request *shenhaiplatform.UranusTaskNodeSaveRequest) (*shenhaiplatform.UranusTaskNodeSaveResponse, error)

任务单节点-新建

func (*ShenhaiplatformClient) UranusTaskNodeUpdateJobName ¶

func (c *ShenhaiplatformClient) UranusTaskNodeUpdateJobName(request *shenhaiplatform.UranusTaskNodeUpdateJobNameRequest) (*shenhaiplatform.UranusTaskNodeUpdateJobNameResponse, error)

任务单节点-更新作业名称

func (*ShenhaiplatformClient) UranusTaskNodeUpdateNodeData ¶

func (c *ShenhaiplatformClient) UranusTaskNodeUpdateNodeData(request *shenhaiplatform.UranusTaskNodeUpdateNodeDataRequest) (*shenhaiplatform.UranusTaskNodeUpdateNodeDataResponse, error)

任务单节点-更新节点位置信息

func (*ShenhaiplatformClient) UranusTaskPageList ¶

func (c *ShenhaiplatformClient) UranusTaskPageList(request *shenhaiplatform.UranusTaskPageListRequest) (*shenhaiplatform.UranusTaskPageListResponse, error)

节点分页列表

func (*ShenhaiplatformClient) UranusTaskPagePublish ¶

func (c *ShenhaiplatformClient) UranusTaskPagePublish(request *shenhaiplatform.UranusTaskPagePublishRequest) (*shenhaiplatform.UranusTaskPagePublishResponse, error)

工作流画布-作业预发布

func (*ShenhaiplatformClient) UranusTaskPrePublish ¶

func (c *ShenhaiplatformClient) UranusTaskPrePublish(request *shenhaiplatform.UranusTaskPrePublishRequest) (*shenhaiplatform.UranusTaskPrePublishResponse, error)

工作流-预发布

func (*ShenhaiplatformClient) UranusTaskPublishOne ¶

func (c *ShenhaiplatformClient) UranusTaskPublishOne(request *shenhaiplatform.UranusTaskPublishOneRequest) (*shenhaiplatform.UranusTaskPublishOneResponse, error)

工作流-发布一

func (*ShenhaiplatformClient) UranusTaskSparkParamKeys ¶

func (c *ShenhaiplatformClient) UranusTaskSparkParamKeys(request *shenhaiplatform.UranusTaskSparkParamKeysRequest) (*shenhaiplatform.UranusTaskSparkParamKeysResponse, error)

spark参数keys

func (*ShenhaiplatformClient) UranusTaskUpdateStatus ¶

func (c *ShenhaiplatformClient) UranusTaskUpdateStatus(request *shenhaiplatform.UranusTaskUpdateStatusRequest) (*shenhaiplatform.UranusTaskUpdateStatusResponse, error)

任务单节点-上下线更新/撤销删除

func (*ShenhaiplatformClient) UranusTaskUpdateStatusList ¶

func (c *ShenhaiplatformClient) UranusTaskUpdateStatusList(request *shenhaiplatform.UranusTaskUpdateStatusListRequest) (*shenhaiplatform.UranusTaskUpdateStatusListResponse, error)

批量任务单节点-上下线更新

func (*ShenhaiplatformClient) UranusUdfListFunction ¶

func (c *ShenhaiplatformClient) UranusUdfListFunction(request *shenhaiplatform.UranusUdfListFunctionRequest) (*shenhaiplatform.UranusUdfListFunctionResponse, error)

查询函数接口

func (*ShenhaiplatformClient) UranusWorkFlowDirCreate ¶

func (c *ShenhaiplatformClient) UranusWorkFlowDirCreate(request *shenhaiplatform.UranusWorkFlowDirCreateRequest) (*shenhaiplatform.UranusWorkFlowDirCreateResponse, error)

创建文件夹

func (*ShenhaiplatformClient) UranusWorkFlowDirDelete ¶

func (c *ShenhaiplatformClient) UranusWorkFlowDirDelete(request *shenhaiplatform.UranusWorkFlowDirDeleteRequest) (*shenhaiplatform.UranusWorkFlowDirDeleteResponse, error)

删除文件夹

func (*ShenhaiplatformClient) UranusWorkFlowDirFileDelete ¶

func (c *ShenhaiplatformClient) UranusWorkFlowDirFileDelete(request *shenhaiplatform.UranusWorkFlowDirFileDeleteRequest) (*shenhaiplatform.UranusWorkFlowDirFileDeleteResponse, error)

删除文件

func (*ShenhaiplatformClient) UranusWorkFlowDirFileExists ¶

func (c *ShenhaiplatformClient) UranusWorkFlowDirFileExists(request *shenhaiplatform.UranusWorkFlowDirFileExistsRequest) (*shenhaiplatform.UranusWorkFlowDirFileExistsResponse, error)

校验文件是否存在

func (*ShenhaiplatformClient) UranusWorkFlowDirIfChildrenPath ¶

func (c *ShenhaiplatformClient) UranusWorkFlowDirIfChildrenPath(request *shenhaiplatform.UranusWorkFlowDirIfChildrenPathRequest) (*shenhaiplatform.UranusWorkFlowDirIfChildrenPathResponse, error)

判断是否有子目录

func (*ShenhaiplatformClient) UranusWorkFlowInitUpload ¶

func (c *ShenhaiplatformClient) UranusWorkFlowInitUpload(request *shenhaiplatform.UranusWorkFlowInitUploadRequest) (*shenhaiplatform.UranusWorkFlowInitUploadResponse, error)

分片上传初始化

func (*ShenhaiplatformClient) UranusWorkSpaceDown ¶

func (c *ShenhaiplatformClient) UranusWorkSpaceDown(request *shenhaiplatform.UranusWorkSpaceDownRequest) (*shenhaiplatform.UranusWorkSpaceDownResponse, error)

工作空间删除

func (*ShenhaiplatformClient) WorkspaceAddMember ¶

func (c *ShenhaiplatformClient) WorkspaceAddMember(request *shenhaiplatform.WorkspaceAddMemberRequest) (*shenhaiplatform.WorkspaceAddMemberResponse, error)

添加工作空间成员

func (*ShenhaiplatformClient) WorkspaceBundleOrUnBundleResource ¶

func (c *ShenhaiplatformClient) WorkspaceBundleOrUnBundleResource(request *shenhaiplatform.WorkspaceBundleOrUnBundleResourceRequest) (*shenhaiplatform.WorkspaceBundleOrUnBundleResourceResponse, error)

获取工作空间列表

func (*ShenhaiplatformClient) WorkspaceBundleProject ¶

func (c *ShenhaiplatformClient) WorkspaceBundleProject(request *shenhaiplatform.WorkspaceBundleProjectRequest) (*shenhaiplatform.WorkspaceBundleProjectResponse, error)

工作空间绑定云仓项目

func (*ShenhaiplatformClient) WorkspaceCreatProduct ¶

func (c *ShenhaiplatformClient) WorkspaceCreatProduct(request *shenhaiplatform.WorkspaceCreatProductRequest) (*shenhaiplatform.WorkspaceCreatProductResponse, error)

工作空间开通接口

func (*ShenhaiplatformClient) WorkspaceCreate ¶

func (c *ShenhaiplatformClient) WorkspaceCreate(request *shenhaiplatform.WorkspaceCreateRequest) (*shenhaiplatform.WorkspaceCreateResponse, error)

创建工作空间

func (*ShenhaiplatformClient) WorkspaceDelete ¶

func (c *ShenhaiplatformClient) WorkspaceDelete(request *shenhaiplatform.WorkspaceDeleteRequest) (*shenhaiplatform.WorkspaceDeleteResponse, error)

删除工作空间

func (*ShenhaiplatformClient) WorkspaceDeleteMember ¶

func (c *ShenhaiplatformClient) WorkspaceDeleteMember(request *shenhaiplatform.WorkspaceDeleteMemberRequest) (*shenhaiplatform.WorkspaceDeleteMemberResponse, error)

删除工作空间成员

func (*ShenhaiplatformClient) WorkspaceExpiredInfo ¶

func (c *ShenhaiplatformClient) WorkspaceExpiredInfo(request *shenhaiplatform.WorkspaceExpiredInfoRequest) (*shenhaiplatform.WorkspaceExpiredInfoResponse, error)

判断当前租户的产品是否已过期

func (*ShenhaiplatformClient) WorkspaceGetCurrentUserInfo ¶

func (c *ShenhaiplatformClient) WorkspaceGetCurrentUserInfo(request *shenhaiplatform.WorkspaceGetCurrentUserInfoRequest) (*shenhaiplatform.WorkspaceGetCurrentUserInfoResponse, error)

获取当前登录用户信息

func (*ShenhaiplatformClient) WorkspaceGetInfo ¶

func (c *ShenhaiplatformClient) WorkspaceGetInfo(request *shenhaiplatform.WorkspaceGetInfoRequest) (*shenhaiplatform.WorkspaceGetInfoResponse, error)

获取工作空间基本信息

func (*ShenhaiplatformClient) WorkspaceGetList ¶

func (c *ShenhaiplatformClient) WorkspaceGetList(request *shenhaiplatform.WorkspaceGetListRequest) (*shenhaiplatform.WorkspaceGetListResponse, error)

获取工作空间列表

func (*ShenhaiplatformClient) WorkspaceGetMembers ¶

func (c *ShenhaiplatformClient) WorkspaceGetMembers(request *shenhaiplatform.WorkspaceGetMembersRequest) (*shenhaiplatform.WorkspaceGetMembersResponse, error)

获取工作空间的成员列表

func (*ShenhaiplatformClient) WorkspaceGetProject ¶

func (c *ShenhaiplatformClient) WorkspaceGetProject(request *shenhaiplatform.WorkspaceGetProjectRequest) (*shenhaiplatform.WorkspaceGetProjectResponse, error)

获取工作空间绑定的云仓项目

func (*ShenhaiplatformClient) WorkspaceGetProjectBundle ¶

func (c *ShenhaiplatformClient) WorkspaceGetProjectBundle(request *shenhaiplatform.WorkspaceGetProjectBundleRequest) (*shenhaiplatform.WorkspaceGetProjectBundleResponse, error)

获取云仓项目被绑定的工作空间

func (*ShenhaiplatformClient) WorkspaceGetResources ¶

func (c *ShenhaiplatformClient) WorkspaceGetResources(request *shenhaiplatform.WorkspaceGetResourcesRequest) (*shenhaiplatform.WorkspaceGetResourcesResponse, error)

获取工作空间的资源组列表

func (*ShenhaiplatformClient) WorkspaceGetUcUserByPin ¶

func (c *ShenhaiplatformClient) WorkspaceGetUcUserByPin(request *shenhaiplatform.WorkspaceGetUcUserByPinRequest) (*shenhaiplatform.WorkspaceGetUcUserByPinResponse, error)

根据用户pin查询uc用户信息

func (*ShenhaiplatformClient) WorkspaceGetUcUsers ¶

func (c *ShenhaiplatformClient) WorkspaceGetUcUsers(request *shenhaiplatform.WorkspaceGetUcUsersRequest) (*shenhaiplatform.WorkspaceGetUcUsersResponse, error)

获取可添加的成员列表

func (*ShenhaiplatformClient) WorkspaceGetUserRoles ¶

func (c *ShenhaiplatformClient) WorkspaceGetUserRoles(request *shenhaiplatform.WorkspaceGetUserRolesRequest) (*shenhaiplatform.WorkspaceGetUserRolesResponse, error)

获取当前登录用户的所有角色

func (*ShenhaiplatformClient) WorkspaceHadCreatWsProduct ¶

func (c *ShenhaiplatformClient) WorkspaceHadCreatWsProduct(request *shenhaiplatform.WorkspaceHadCreatWsProductRequest) (*shenhaiplatform.WorkspaceHadCreatWsProductResponse, error)

判断工作空间是否开通过工作空间产品接口

func (*ShenhaiplatformClient) WorkspaceSaveInfo ¶

func (c *ShenhaiplatformClient) WorkspaceSaveInfo(request *shenhaiplatform.WorkspaceSaveInfoRequest) (*shenhaiplatform.WorkspaceSaveInfoResponse, error)

编辑工作空间

func (*ShenhaiplatformClient) WorkspaceStopExpireOrDelete ¶

func (c *ShenhaiplatformClient) WorkspaceStopExpireOrDelete(request *shenhaiplatform.WorkspaceStopExpireOrDeleteRequest) (*shenhaiplatform.WorkspaceStopExpireOrDeleteResponse, error)

同步工作空间续费消息

func (*ShenhaiplatformClient) WorkspaceSyncRecharge ¶

func (c *ShenhaiplatformClient) WorkspaceSyncRecharge(request *shenhaiplatform.WorkspaceSyncRechargeRequest) (*shenhaiplatform.WorkspaceSyncRechargeResponse, error)

同步工作空间续费消息

func (*ShenhaiplatformClient) WorkspaceSyncWsProductOrder ¶

func (c *ShenhaiplatformClient) WorkspaceSyncWsProductOrder(request *shenhaiplatform.WorkspaceSyncWsProductOrderRequest) (*shenhaiplatform.WorkspaceSyncWsProductOrderResponse, error)

同步工作空间开通信息接口

func (*ShenhaiplatformClient) WorkspaceUnbundleProject ¶

func (c *ShenhaiplatformClient) WorkspaceUnbundleProject(request *shenhaiplatform.WorkspaceUnbundleProjectRequest) (*shenhaiplatform.WorkspaceUnbundleProjectResponse, error)

工作空间解绑云仓项目

func (*ShenhaiplatformClient) WorkspaceUpdateUserRole ¶

func (c *ShenhaiplatformClient) WorkspaceUpdateUserRole(request *shenhaiplatform.WorkspaceUpdateUserRoleRequest) (*shenhaiplatform.WorkspaceUpdateUserRoleResponse, error)

更改用户角色

func (*ShenhaiplatformClient) WorkspaceVerifyAuth ¶

func (c *ShenhaiplatformClient) WorkspaceVerifyAuth(request *shenhaiplatform.WorkspaceVerifyAuthRequest) (*shenhaiplatform.WorkspaceVerifyAuthResponse, error)

判断用户pin和工作空间code校验是否有工作空间权限

func (*ShenhaiplatformClient) WorkspaceVerifyUserIsManager ¶

func (c *ShenhaiplatformClient) WorkspaceVerifyUserIsManager(request *shenhaiplatform.WorkspaceVerifyUserIsManagerRequest) (*shenhaiplatform.WorkspaceVerifyUserIsManagerResponse, error)

校验当前用户是否是该工作空间的管理员

func (*ShenhaiplatformClient) WorkspacegetUcUserByUserName ¶

func (c *ShenhaiplatformClient) WorkspacegetUcUserByUserName(request *shenhaiplatform.WorkspacegetUcUserByUserNameRequest) (*shenhaiplatform.WorkspacegetUcUserByUserNameResponse, error)

根据用户名称模糊查询当前工作空间下的用户