import { AbstractClient } from "../../../common/abstract_client"; import { ClientConfig } from "../../../common/interface"; import { ParseConnectorRequest, CreateResourceRequest, ModifyFolderRequest, DescribeJobSubmissionLogResponse, DeleteJobsRequest, ModifyWorkSpaceRequest, ModifyJobResponse, CreateJobConfigResponse, CreateResourceConfigResponse, CreateJobConfigRequest, DescribeTreeJobsResponse, CopyJobsRequest, CopyJobsResponse, CreateConnectorResponse, TriggerJobSavepointRequest, DescribeJobConfigsRequest, RunSqlGatewayStatementRequest, DescribeFolderResponse, ModifyConnectorRequest, DescribeWorkSpacesRequest, DescribeTreeResourcesRequest, DescribeResourceConfigsResponse, DescribeClustersRequest, CreateWorkSpaceResponse, CreateJobResponse, DescribeVariablesRequest, DescribeJobRuntimeInfoResponse, CreateFolderRequest, DeleteJobConfigsResponse, DeleteTableConfigRequest, DeleteResourcesResponse, DeleteTableConfigResponse, GetMetaTableResponse, FetchSqlGatewayStatementResultResponse, DescribeJobSavepointResponse, CreateWorkSpaceRequest, DeleteResourceConfigsRequest, DescribeVariablesResponse, DeleteFoldersRequest, DeleteWorkSpaceRequest, DescribeJobRuntimeInfoRequest, DescribeWorkSpacesResponse, CreateResourceResponse, DescribeSystemResourcesRequest, CreateFolderResponse, DescribeResourcesResponse, DescribeResourceRelatedJobsResponse, DescribeClustersResponse, CheckConnectorNameResponse, DescribeSystemResourcesResponse, CheckSavepointRequest, DeleteJobConfigsRequest, StopJobsRequest, RunJobsRequest, DeleteWorkSpaceResponse, TriggerJobSavepointResponse, DeleteJobsResponse, DescribeResourceRelatedJobsRequest, CreateVariableResponse, DeleteResourcesRequest, RunJobsResponse, DescribeJobSavepointRequest, ModifyJobRequest, GetMetaTableRequest, DeleteResourceConfigsResponse, CreateVariableRequest, DescribeJobSubmissionLogRequest, DescribeJobsRequest, DescribeResourceConfigsRequest, ModifyFolderResponse, ModifyWorkSpaceResponse, RunSqlGatewayStatementResponse, CreateJobRequest, DescribeFolderRequest, DeleteFoldersResponse, ParseConnectorResponse, CreateResourceConfigRequest, ModifyConnectorResponse, CheckConnectorNameRequest, StopJobsResponse, DescribeResourcesRequest, DescribeJobEventsRequest, CheckSavepointResponse, DescribeJobsResponse, DescribeTreeResourcesResponse, CreateConnectorRequest, DescribeTreeJobsRequest, DescribeJobConfigsResponse, FetchSqlGatewayStatementResultRequest, DescribeJobEventsResponse } from "./oceanus_models"; /** * oceanus client * @class */ export declare class Client extends AbstractClient { constructor(clientConfig: ClientConfig); /** * 生成树状作业显示结构 */ DescribeTreeJobs(req: DescribeTreeJobsRequest, cb?: (error: string, rep: DescribeTreeJobsResponse) => void): Promise; /** * 查询树状结构资源列表 */ DescribeTreeResources(req: DescribeTreeResourcesRequest, cb?: (error: string, rep: DescribeTreeResourcesResponse) => void): Promise; /** * 单条和批量复制作业 */ CopyJobs(req: CopyJobsRequest, cb?: (error: string, rep: CopyJobsResponse) => void): Promise; /** * 通过Sql gateway执行satement */ RunSqlGatewayStatement(req: RunSqlGatewayStatementRequest, cb?: (error: string, rep: RunSqlGatewayStatementResponse) => void): Promise; /** * 删除资源版本 */ DeleteResourceConfigs(req: DeleteResourceConfigsRequest, cb?: (error: string, rep: DeleteResourceConfigsResponse) => void): Promise; /** * 创建工作空间 */ CreateWorkSpace(req: CreateWorkSpaceRequest, cb?: (error: string, rep: CreateWorkSpaceResponse) => void): Promise; /** * 创建资源配置接口 */ CreateResourceConfig(req: CreateResourceConfigRequest, cb?: (error: string, rep: CreateResourceConfigResponse) => void): Promise; /** * 删除作业表配置 */ DeleteTableConfig(req: DeleteTableConfigRequest, cb?: (error: string, rep: DeleteTableConfigResponse) => void): Promise; /** * 查询指定文件夹及其相应的子文件夹信息 */ DescribeFolder(req: DescribeFolderRequest, cb?: (error: string, rep: DescribeFolderResponse) => void): Promise; /** * 删除工作空间 */ DeleteWorkSpace(req: DeleteWorkSpaceRequest, cb?: (error: string, rep: DeleteWorkSpaceResponse) => void): Promise; /** * 创建Connector */ CreateConnector(req: CreateConnectorRequest, cb?: (error: string, rep: CreateConnectorResponse) => void): Promise; /** * 自定义树状结构页面拖拽文件夹 */ ModifyFolder(req: ModifyFolderRequest, cb?: (error: string, rep: ModifyFolderResponse) => void): Promise; /** * 查找Savepoint列表 */ DescribeJobSavepoint(req: DescribeJobSavepointRequest, cb?: (error: string, rep: DescribeJobSavepointResponse) => void): Promise; /** * 查询作业实例启动日志 */ DescribeJobSubmissionLog(req: DescribeJobSubmissionLogRequest, cb?: (error: string, rep: DescribeJobSubmissionLogResponse) => void): Promise; /** * 描述资源接口 */ DescribeResources(req: DescribeResourcesRequest, cb?: (error: string, rep: DescribeResourcesResponse) => void): Promise; /** * 获取作业运行时的信息 */ DescribeJobRuntimeInfo(req: DescribeJobRuntimeInfoRequest, cb?: (error: string, rep: DescribeJobRuntimeInfoResponse) => void): Promise; /** * 查询Sql Gateway的Statement执行结果 */ FetchSqlGatewayStatementResult(req: FetchSqlGatewayStatementResultRequest, cb?: (error: string, rep: FetchSqlGatewayStatementResultResponse) => void): Promise; /** * 批量启动或者恢复作业,批量操作数量上限20 */ RunJobs(req: RunJobsRequest, cb?: (error: string, rep: RunJobsResponse) => void): Promise; /** * 请求参数不包含 "RunningOrderIds"时,接口获取指定作业的事件,包括作业启动停止、运行失败、快照失败、作业异常等各种事件类型;请求参数不包含 "RunningOrderIds"时,接口为查询作业实例ID接口,获取作业实例 */ DescribeJobEvents(req: DescribeJobEventsRequest, cb?: (error: string, rep: DescribeJobEventsResponse) => void): Promise; /** * 描述资源配置接口 */ DescribeResourceConfigs(req: DescribeResourceConfigsRequest, cb?: (error: string, rep: DescribeResourceConfigsResponse) => void): Promise; /** * 创建变量 */ CreateVariable(req: CreateVariableRequest, cb?: (error: string, rep: CreateVariableResponse) => void): Promise; /** * 作业列表删除文件夹 */ DeleteFolders(req: DeleteFoldersRequest, cb?: (error: string, rep: DeleteFoldersResponse) => void): Promise; /** * 授权工作空间列表 */ DescribeWorkSpaces(req: DescribeWorkSpacesRequest, cb?: (error: string, rep: DescribeWorkSpacesResponse) => void): Promise; /** * 新建作业接口,一个 AppId 最多允许创建1000个作业 */ CreateJob(req: CreateJobRequest, cb?: (error: string, rep: CreateJobResponse) => void): Promise; /** * 触发Savepoint */ TriggerJobSavepoint(req: TriggerJobSavepointRequest, cb?: (error: string, rep: TriggerJobSavepointResponse) => void): Promise; /** * 解析用户上传connector */ ParseConnector(req: ParseConnectorRequest, cb?: (error: string, rep: ParseConnectorResponse) => void): Promise; /** * 查询资源名是否重复 */ CheckConnectorName(req: CheckConnectorNameRequest, cb?: (error: string, rep: CheckConnectorNameResponse) => void): Promise; /** * 批量删除作业接口,批量操作数量上限20 */ DeleteJobs(req: DeleteJobsRequest, cb?: (error: string, rep: DeleteJobsResponse) => void): Promise; /** * 作业列表页面新建文件夹请求 */ CreateFolder(req: CreateFolderRequest, cb?: (error: string, rep: CreateFolderResponse) => void): Promise; /** * 检查快照是否可用 */ CheckSavepoint(req: CheckSavepointRequest, cb?: (error: string, rep: CheckSavepointResponse) => void): Promise; /** * 创建作业配置,一个作业最多有100个配置版本 */ CreateJobConfig(req: CreateJobConfigRequest, cb?: (error: string, rep: CreateJobConfigResponse) => void): Promise; /** * 查询集群 */ DescribeClusters(req: DescribeClustersRequest, cb?: (error: string, rep: DescribeClustersResponse) => void): Promise; /** * 删除作业配置 */ DeleteJobConfigs(req: DeleteJobConfigsRequest, cb?: (error: string, rep: DeleteJobConfigsResponse) => void): Promise; /** * 批量停止作业,批量操作数量上限为20 */ StopJobs(req: StopJobsRequest, cb?: (error: string, rep: StopJobsResponse) => void): Promise; /** * 获取资源关联作业信息 */ DescribeResourceRelatedJobs(req: DescribeResourceRelatedJobsRequest, cb?: (error: string, rep: DescribeResourceRelatedJobsResponse) => void): Promise; /** * 修改工作空间 */ ModifyWorkSpace(req: ModifyWorkSpaceRequest, cb?: (error: string, rep: ModifyWorkSpaceResponse) => void): Promise; /** * 删除资源接口 */ DeleteResources(req: DeleteResourcesRequest, cb?: (error: string, rep: DeleteResourcesResponse) => void): Promise; /** * 变量列表展示 */ DescribeVariables(req: DescribeVariablesRequest, cb?: (error: string, rep: DescribeVariablesResponse) => void): Promise; /** * 查询作业 */ DescribeJobs(req: DescribeJobsRequest, cb?: (error: string, rep: DescribeJobsResponse) => void): Promise; /** * 更新作业属性,仅允许以下3种操作,不支持组合操作: (1) 更新作业名称 (2) 更新作业备注 (3) 更新作业最大并行度 变更前提:WorkerCuNum<=MaxParallelism 如果MaxParallelism变小,不重启作业,待下一次重启生效 如果MaxParallelism变大,则要求入参RestartAllowed必须为True 假设作业运行状态,则先停止作业,再启动作业,中间状态丢失 假设作业暂停状态,则将作业更改为停止状态,中间状态丢失 */ ModifyJob(req: ModifyJobRequest, cb?: (error: string, rep: ModifyJobResponse) => void): Promise; /** * 修改Connector */ ModifyConnector(req: ModifyConnectorRequest, cb?: (error: string, rep: ModifyConnectorResponse) => void): Promise; /** * 创建资源接口 */ CreateResource(req: CreateResourceRequest, cb?: (error: string, rep: CreateResourceResponse) => void): Promise; /** * 描述系统资源接口 */ DescribeSystemResources(req: DescribeSystemResourcesRequest, cb?: (error: string, rep: DescribeSystemResourcesResponse) => void): Promise; /** * 查询元数据表 */ GetMetaTable(req: GetMetaTableRequest, cb?: (error: string, rep: GetMetaTableResponse) => void): Promise; /** * 查询作业配置列表,一次最多查询100个 */ DescribeJobConfigs(req: DescribeJobConfigsRequest, cb?: (error: string, rep: DescribeJobConfigsResponse) => void): Promise; }