Documentation
¶
Index ¶
- type AddMemberReq
- type AddWatchmanParam
- type BindInfo
- type BundleOrUnBundleResourceReq
- type BundleProjectReq
- type CancelPublishObjParam
- type ChangeWorkspaceStatusReq
- type ChatVo
- type CheckFunctionInfoReq
- type CreateFunctionCatalogReq
- type CreateFunctionReq
- type CreateProjectResourceParam
- type CreateWorkspaceProductParam
- type DataDownloadParam
- type DataLoadHistory
- type DataLoadHistoryParam
- type DataLoadHistoryResult
- type DataLoadKillParam
- type DataLoadLogParam
- type DataLoadParam
- type DataLoadPreviewParam
- type DefinedFunctionVo
- type DeleteFunctionCatalogReq
- type DeleteFunctionReq
- type DeleteMemberReq
- type DeleteWatchmanParam
- type EditWorkspaceReq
- type ExtraRunnerParamReq
- type ExtraRunnerReq
- type FunctionCatalogVo
- type GpdjmcCalcJobDTO
- type GpdjmcCalcJobResultDTO
- type GpdjmcConfPairStringString
- type GpdjmcDelAllReqDTO
- type GpdjmcDeleteScriptReq
- type GpdjmcDmrModelDTO
- type GpdjmcDmrModelJobQueryDTO
- type GpdjmcDmrModelJobRDTO
- type GpdjmcDmrScriptInfoDTO
- type GpdjmcEngineTemplateDTO
- type GpdjmcGitFileDTO
- type GpdjmcInputParam
- type GpdjmcJobDeleteDTO
- type GpdjmcJobNaRemarkDTO
- type GpdjmcJobNameDTO
- type GpdjmcJobQueryDTO
- type GpdjmcLoopListParam
- type GpdjmcLoopParam
- type GpdjmcMgrDictDTO
- type GpdjmcOutputParam
- type GpdjmcRpcResponseBoolean
- type GpdjmcRpcResponseCalcJobResultDTO
- type GpdjmcRpcResponseDmrScriptInfoDTO
- type GpdjmcRpcResponseInteger
- type GpdjmcRpcResponseListDmrModelJobRDTO
- type GpdjmcRpcResponseListEngineTemplateDTO
- type GpdjmcRpcResponseListInteger
- type GpdjmcRpcResponseListSchedJobDTO
- type GpdjmcRpcResponseListSchedJobDepDTO
- type GpdjmcRpcResponseListSchedJobResDTO
- type GpdjmcRpcResponseListString
- type GpdjmcRpcResponseScriptInfoTypeDTO
- type GpdjmcSchedJobDTO
- type GpdjmcSchedJobDepDTO
- type GpdjmcSchedJobResDTO
- type GpdjmcScriptFileDTO
- type GpdjmcScriptInfoTemplateDTO
- type GpdjmcScriptInfoTypeDTO
- type GpdjmcTableInfoDTO
- type GpdjmcTriggerConfigDTO
- type GpdjmcWorkspaceInfoDTO
- type GpdpJobDepChainReq
- type GpdpJobDependenceReq
- type GpdpJobDependencyResultDTO
- type GpdpJobDetailResultDTO
- type GpdpPageInfoJobDependencyResultDTO
- type GpdpSchedTriggerDependTree
- type GpdrAfreshAddLogVo
- type GpdrAfreshAddParam
- type GpdrCloseTaskReq
- type GpdrListHisRunTaskResDTO
- type GpdrListTaskLogReq
- type GpdrListTaskReq
- type GpdrOpenApiRespInteger
- type GpdrOpenApiRespString
- type GpdrOpenApiResponsePageInfoAfreshAddLogVo
- type GpdrOpenApiResponsePageInfoListHisRunTaskResDTO
- type GpdrPageInfoAfreshAddLogVo
- type GpdrPageInfoListHisRunTaskResDTO
- type GpjmConditionInfo
- type GpjmConditionType
- type GpjmJobBasicInfoDTO
- type GpjmJobBasicInfoResultDTO
- type GpjmJobCommonInfoDTO
- type GpjmJobCompletionResultDTO
- type GpjmJobInfoReq
- type GpjmJobMonitorInfoDTO
- type GpjmJobOperationRecordReq
- type GpjmJobQueryReq
- type GpjmJobRunInfoResultDTO
- type GpjmJobTypeInfoDto
- type GpjmListJobInstanceReq
- type GpjmListJobInstanceResultDTO
- type GpjmListJobReq
- type GpjmListJobResultDTO
- type GpjmMgrJob
- type GpjmMgrOperationRecords
- type GpjmPageInfoJobRunInfoResultDTO
- type GpjmPageInfoListJobInstanceResultDTO
- type GpjmPageInfoListJobResultDTO
- type GpjmPageInfoMgrOperationRecords
- type GpjmRunRoleInfoDTO
- type GpjmobQueryReq
- type GpjsClusterInfoReq
- type GpjsIsUpstreamSameFrequencyDTO
- type GpjsJobDelInfoReq
- type GpjsJobEnableReq
- type GpjsJobExeResultReq
- type GpjsResetJobInstReq
- type GpjsSchedJobRunVo
- type GpjsSchedQueuePendingDto
- type GpjsScriptExtensionDto
- type GpmdCalcJobResultDTO
- type GpmdConfPairStringString
- type GpmdJobQueryReq
- type GpmdOpenApiResponseCalcJobResultDTO
- type GpmdSchedJobDTO
- type GpmdTriggerConfigDTO
- type GpmnJobCountDto
- type GpmnJobSpendTimeRankingVo
- type GpmnJobUnsuccessRankingVo
- type GpmnLineData
- type GpmnLineDataVo
- type GpmnLineStringDataVo
- type GpmnPieData
- type GpmnWorkTableJobStatusDto
- type GpmnWorkTableJobStatusReq
- type GpsdSchedDict
- type GpsdSchedDictRelationDto
- type GpsdalueDict
- type GpsmArrayObjectRequestResetJobInstReq
- type GpsmDownloadJobLogReq
- type GpsmJobAllqueryInfoDto
- type GpsmJobLogInfoPageQryReq
- type GpsmJobNameDTO
- type GpsmJobQueryReq
- type GpsmJobStateBatchReq
- type GpsmKillJobInstReq
- type GpsmMgrJob
- type GpsmOpenApiResponsePageInfoObject
- type GpsmPageInfoObject
- type GpsmReRunJobBatchReq
- type GpsmResetJobInstReq
- type GpsmSchedJob
- type GpsmSchedJobWithLogDto
- type GpuserMatchUserReq
- type GpuserMatchUserResDto
- type JcwSpaceDetailRequest
- type JcwSpaceIncreUsedByDayVo
- type JcwSpacePartUsedVo
- type JcwSpaceSummaryVo
- type JcwSpaceUsedDetailVo
- type JobBasicInfoVo
- type JobCommonInfoVo
- type JobInfoVo
- type JobKillParam
- type JobLogParam
- type JobMonitorInfoVo
- type JobNameDO
- type JobOperateHistoryVo
- type JobPropertyVo
- type JobRelationVo
- type JobRerunFailedReason
- type JobRerunParam
- type JobRerunResult
- type JobResetDO
- type JobResetParam
- type JobRunHistoryParam
- type JobRunHistoryVo
- type JobRunInfoVo
- type JobTxDateStatusVo
- type JobTypeVo
- type JtlasDestroyRequestReq
- type JtlasDestroyResp
- type JtlasDownloadTableColumnsResp
- type JtlasFuzzyQueryTablesByDatabaseNameResp
- type JtlasFuzzyQueryTablesByTableNameReq
- type JtlasFuzzyQueryTablesByTableNameResp
- type JtlasGetTableDDLScriptResp
- type JtlasGetTableQueryScriptResp
- type JtlasGrantTablePrivilegesReq
- type JtlasGrantTablePrivilegesResp
- type JtlasPageSearchTablePartitionsReq
- type JtlasPageSearchTablePartitionsResp
- type JtlasPageSearchTablePrivilegeReq
- type JtlasPageSearchTablePrivilegesResp
- type JtlasPageSearchTableReq
- type JtlasPageSearchTableResp
- type JtlasSearchAggregation
- type JtlasSearchColumnLineageReq
- type JtlasSearchColumnLineageResp
- type JtlasSearchDetailResp
- type JtlasSearchEdge
- type JtlasSearchNode
- type JtlasSearchTable
- type JtlasSearchTableColumn
- type JtlasSearchTableDoc
- type JtlasSearchTableLineageReq
- type JtlasSearchTableLineageResp
- type JtlasSearchTableParam
- type JtlasSearchTablePartition
- type JtlasSearchTablePrivilege
- type JtlasSubscribeTableReq
- type JtlasSubscribeTableResp
- type JtlasTableDetailReq
- type JtlasTableDetailResp
- type JtlasTableFuuzyUnderSpecifiedUserWithPrivilegesReq
- type JtlasTableFuuzyUnderSpecifiedUserWithPrivilegesResp
- type JtlasTableOwnedByUserReq
- type JtlasTableOwnedByUserResp
- type JtlasTablePrivilegesReq
- type JtlasTablePrivilegesResp
- type JtlasTableUnderSpecifiedUserReq
- type JtlasTableUnderSpecifiedUserResp
- type JtlasTableUnderSpecifiedUserWithPrivilegesReq
- type JtlasTableUnderSpecifiedUserWithPrivilegesResp
- type JtlasWarehouseTable
- type JtlasWarehouseTableColumn
- type JtlasWarehouseTableParam
- type JtlasWarehouseTablePartition
- type JtlasWarehouseTablePrivilege
- type ListJobOperateHistoryParam
- type ListJobParam
- type ListJobRelationParam
- type ListPublishObjByPageParam
- type ListPublishPkgByPageParam
- type ListTxDateStatusParam
- type LoopParam
- type ModelVo
- type OneClickRerunParam
- type OneClickRerunPreviewVo
- type OrderUniqueKey
- type OwnerIntegrationResource
- type PackagePublishObjParam
- type PageInfoResourceResp
- type PageInfoUcUsersResp
- type PageInfoWorkspaceListResp
- type PageInfoWorkspaceUserResp
- type PageVoJcwSpacePartUsedVo
- type PageVoJobInfoVo
- type PageVoJobOperateHistoryVo
- type PageVoJobRelationVo
- type PageVoJobRunHistoryVo
- type PageVoJobTxDateStatusVo
- type PageVoRerunBatchVo
- type PageVoRerunTaskVo
- type PageVoStorageSpaceUsedDetailVo
- type PageVoString
- type PartitionInfo
- type PreviewPackageParam
- type PreviewPackageVo
- type ProjectResp
- type PublishObjDetailVo
- type PublishObjPageVo
- type PublishObjVo
- type PublishPkgDetailVo
- type PublishPkgPageVo
- type PublishPkgParam
- type PublishPkgVo
- type QueryPublishObjDetailParam
- type QueryPublishPkgDetailParam
- type QueryWorkspaceInfoReq
- type QueryWorkspaceListReq
- type RejectPublishPkgParam
- type RerunBatchParam
- type RerunBatchVo
- type RerunTaskParam
- type RerunTaskReSubmitParam
- type RerunTaskVo
- type ResourceBriefInfoVo
- type ResourceCloseReq
- type ResourceCreateReq
- type ResourceDeleteReq
- type ResourceInfo
- type ResourceResp
- type ResourceUpdateReq
- type RosterDO
- type RosterVo
- type Row
- type SparkJarRunParams
- type StopExpireOrDeleteReq
- type SyncWsProductOrderReq
- type TableBriefInfo
- type TableDelimiterVo
- type TableDelimitersVo
- type TaskDependPageListReq
- type TaskInfoLoopReq
- type TaskInfoSparkJarReq
- type TaskLoopElementDelimiterVo
- type UcUsersResp
- type UnbundleProjectReq
- type UpdateFunctionReq
- type UpdateRosterParam
- type UpdateUserRoleReq
- type UpdateWatchmanParam
- type UploaderInitRes
- type UranusAnalysisScriptReq
- type UranusAnalysisScriptRes
- type UranusCatalogInfo
- type UranusCatalogInfoCode
- type UranusCatalogInfoList
- type UranusColumnReq
- type UranusColumnSaveOrUpdate
- type UranusDdlAnalyzeReq
- type UranusDictRes
- type UranusDictVO
- type UranusFileManagerRes
- type UranusFunctionManagerRes
- type UranusNodePublishChildReq
- type UranusPageResultContentSchedTaskInfoHistoryRes
- type UranusPageResultContentScriptRunLogRes
- type UranusPageResultContentTaskNodePageRes
- type UranusParamReq
- type UranusPublishChangeTypeRes
- type UranusResourceVo
- type UranusResultBoolean
- type UranusResultDefinedFunctionVo
- type UranusResultFunctionCatalogVoList
- type UranusResultInteger
- type UranusResultLinkedHashMapObjectObject
- type UranusResultListAnalysisScriptRes
- type UranusResultListCatalogInfoCode
- type UranusResultListCatalogInfoList
- type UranusResultListColumnReq
- type UranusResultListDictRes
- type UranusResultListDictVO
- type UranusResultListElementDelimiters
- type UranusResultListFileManagerRes
- type UranusResultListFunctionManagerRes
- type UranusResultListObject
- type UranusResultListSchedJobDTO
- type UranusResultListSparkJarManagerRes
- type UranusResultListString
- type UranusResultListTaskFlowDetailRes
- type UranusResultListTaskFlowListRes
- type UranusResultListTaskInfoRes
- type UranusResultListTaskNodePreRes
- type UranusResultListTaskNodeRes
- type UranusResultListTaskParamReq
- type UranusResultPageResultContentSchedTaskInfoHistoryRes
- type UranusResultPageResultContentScriptRunLogRes
- type UranusResultPageResultContentTaskNodePageRes
- type UranusResultRes
- type UranusResultResListString
- type UranusResultResourceBriefInfoVo
- type UranusResultResourceVo
- type UranusResultScriptRunLogRes
- type UranusResultString
- type UranusResultTableBriefInfoRes
- type UranusResultTableDelimitersVo
- type UranusResultTableQuery
- type UranusResultTableSaveOrUpdate
- type UranusResultTaskFlowDetailRes
- type UranusResultTaskInfo
- type UranusResultTaskInfoPrePublishRes
- type UranusResultTaskNodeDetailRes
- type UranusResultTaskNodeParamRes
- type UranusResultTaskNodeRSaveReq
- type UranusResultUploaderChunkCheckerRes
- type UranusResultUploaderInitRes
- type UranusRunnerReq
- type UranusRunnerResultReq
- type UranusSchedJobDTO
- type UranusSchedTaskInfoHistoryRes
- type UranusScriptFileVerifyReq
- type UranusScriptParamReq
- type UranusScriptRunLogListReq
- type UranusScriptRunLogRes
- type UranusSparkJarManagerRes
- type UranusTableQuery
- type UranusTableSaveOrUpdate
- type UranusTaskFlowCheckReq
- type UranusTaskFlowCollectionReq
- type UranusTaskFlowDelReq
- type UranusTaskFlowDetailRes
- type UranusTaskFlowInfo
- type UranusTaskFlowListRes
- type UranusTaskFlowTreeReq
- type UranusTaskFlowUpdateReq
- type UranusTaskFuzzyReq
- type UranusTaskInfo
- type UranusTaskInfoDTO
- type UranusTaskInfoFileReq
- type UranusTaskInfoHistoryReq
- type UranusTaskInfoNodeReq
- type UranusTaskInfoPrePublishRes
- type UranusTaskInfoPublishReq
- type UranusTaskInfoRePublishReq
- type UranusTaskInfoRes
- type UranusTaskNodeChangeRes
- type UranusTaskNodeDetailRes
- type UranusTaskNodePagePublishReq
- type UranusTaskNodePageReq
- type UranusTaskNodePageRes
- type UranusTaskNodeParamRes
- type UranusTaskNodePreRes
- type UranusTaskNodePublishOReq
- type UranusTaskNodeRSaveReq
- type UranusTaskNodeRes
- type UranusTaskNodeSaveReq
- type UranusTaskNodeUpdateReq
- type UranusTaskNodeUpdateStatusListReq
- type UranusTaskNodeUpdateStatusReq
- type UranusTaskParamDTO
- type UranusTaskParamReq
- type UranusTriggerConfigDTO
- type UranusUploaderChunkCheckerRes
- type UranusUploaderChunkReq
- type UranusUploaderPartETag
- type UranusUploaderReq
- type UserRoleInfo
- type UtteranceVo
- type WatchmanVo
- type WorkspaceBundleProjectReq
- type WorkspaceCreateReq
- type WorkspaceInfoResp
- type WorkspaceListResp
- type WorkspaceResourcesReq
- type WorkspaceUserReq
- type WorkspaceUserResp
- type WorkspaceUserRoleResp
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddMemberReq ¶
type AddWatchmanParam ¶
type BundleOrUnBundleResourceReq ¶
type BundleOrUnBundleResourceReq struct {
/* 工作空间code (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* (Optional) */
UserPin string `json:"userPin"`
/* (Optional) */
CalculateResourceCode []string `json:"calculateResourceCode"`
/* (Optional) */
IntegrationResourceCode []string `json:"integrationResourceCode"`
/* (Optional) */
BundleResource bool `json:"bundleResource"`
}
type BundleProjectReq ¶
type CancelPublishObjParam ¶
type ChangeWorkspaceStatusReq ¶
type ChangeWorkspaceStatusReq struct {
/* (Optional) */
Id int64 `json:"id"`
}
type CheckFunctionInfoReq ¶
type CreateFunctionReq ¶
type CreateFunctionReq struct {
/* 租户code (Optional) */
CompanyCode string `json:"companyCode"`
/* 命名空间code (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 函数名称(支持字母、数字、下划线,不超过50个字符) (Optional) */
FunctionName string `json:"functionName"`
/* 分类目录id (Optional) */
FunctionCatalogId int `json:"functionCatalogId"`
/* 函数主类全路径 (Optional) */
ClassName string `json:"className"`
/* 负责人 (Optional) */
Managers []string `json:"managers"`
/* 依赖的资源code(包括资源文件/资源目录) (Optional) */
ResourceCodes []string `json:"resourceCodes"`
/* 函数格式 (Optional) */
FunctionFormat string `json:"functionFormat"`
/* 函数使用说明 (Optional) */
FunctionUsage string `json:"functionUsage"`
/* 关联引擎 (Optional) */
RelativeEngine string `json:"relativeEngine"`
}
type CreateProjectResourceParam ¶
type CreateProjectResourceParam struct {
/* (Optional) */
Region *string `json:"region"`
/* (Optional) */
ResourceType *string `json:"resourceType"`
/* (Optional) */
Az *string `json:"az"`
/* (Optional) */
ResourceName *string `json:"resourceName"`
/* (Optional) */
ResourceDescription *string `json:"resourceDescription"`
/* (Optional) */
PurchaseDuration *int `json:"purchaseDuration"`
/* (Optional) */
AutoRenewal *bool `json:"autoRenewal"`
/* (Optional) */
ResourceSpec *string `json:"resourceSpec"`
/* (Optional) */
PurchaseMode *string `json:"purchaseMode"`
/* (Optional) */
PayResourceNum *int `json:"payResourceNum"`
}
type CreateWorkspaceProductParam ¶
type CreateWorkspaceProductParam struct {
/* (Optional) */
Region string `json:"region"`
/* (Optional) */
Az string `json:"az"`
/* (Optional) */
OwnerIntegrationResource OwnerIntegrationResource `json:"ownerIntegrationResource"`
/* (Optional) */
PayPlan string `json:"payPlan"`
/* (Optional) */
BillingVersion string `json:"billingVersion"`
/* (Optional) */
BillingModel string `json:"billingModel"`
/* (Optional) */
AutoRenewal bool `json:"autoRenewal"`
/* (Optional) */
PurchaseDuration int `json:"purchaseDuration"`
/* (Optional) */
ProjectResourceReq CreateProjectResourceParam `json:"projectResourceReq"`
/* (Optional) */
ReturnUrl string `json:"returnUrl"`
}
type DataDownloadParam ¶
type DataLoadHistory ¶
type DataLoadHistory struct {
/* 主键ID */
Id int `json:"id"`
/* 文件名称 */
FileName string `json:"fileName"`
/* 项目编码 */
ProjectCode string `json:"projectCode"`
/* 目标表名 */
TableName string `json:"tableName"`
/* 任务id */
ApplicationId string `json:"applicationId"`
/* 任务状态 */
State string `json:"state"`
/* 任务状态描述 */
StateDesc string `json:"stateDesc"`
/* 创建时间 */
CreatedDate int `json:"createdDate"`
}
type DataLoadHistoryParam ¶
type DataLoadHistoryParam struct {
/* 页号 (Optional) */
PageNum int `json:"pageNum"`
/* 页面容量 (Optional) */
PageSize int `json:"pageSize"`
/* 表名 (Optional) */
TableName string `json:"tableName"`
/* 状态过滤: SUBMITTED 已提交、ACCEPTED 等待执行、RUNNING 上传中、FINISHED 成功、FAILED 上传失败、KILLED 终止、UNKNOWN 未知 (Optional) */
States []string `json:"states"`
}
type DataLoadHistoryResult ¶
type DataLoadHistoryResult struct {
/* 总条数 */
Total int `json:"total"`
/* 历史上传记录 */
List []DataLoadHistory `json:"list"`
}
type DataLoadKillParam ¶
type DataLoadKillParam struct {
/* 任务id */
ApplicationId string `json:"applicationId"`
}
type DataLoadLogParam ¶
type DataLoadLogParam struct {
/* 任务id */
ApplicationId string `json:"applicationId"`
}
type DataLoadParam ¶
type DataLoadParam struct {
/* 文件路径(key) */
FileKey string `json:"fileKey"`
/* 文件类型:csv、text、xls、xlsx */
FileType string `json:"fileType"`
/* 分隔符: en-comma 英文逗号,en-semicolon 英文分号,space 空格,pipe 竖线,hash 井号,and 与号,line-feed-lf 换行符(UNIX),line-feed-crlf 换行符(Windows) (Optional) */
Delimiter string `json:"delimiter"`
/* 字符集: GBK、UTF-8、ISO-8859-1 (Optional) */
CharacterSet string `json:"characterSet"`
/* 导入起始行 (Optional) */
StartRow int `json:"startRow"`
/* 项目环境: prod 生产环境、dev开发环境 */
ProjectEnv string `json:"projectEnv"`
/* 项目编码 */
ProjectCode string `json:"projectCode"`
/* 目标表名 */
TableName string `json:"tableName"`
/* 导入分区,如果是分区表则必传 (Optional) */
PartitionInfos []PartitionInfo `json:"partitionInfos"`
/* 导入策略:append 追加、overwrite 覆盖 */
ImportStrategy string `json:"importStrategy"`
/* 资源组编码 */
ResourceCode string `json:"resourceCode"`
}
type DataLoadPreviewParam ¶
type DataLoadPreviewParam struct {
/* 文件类型:csv、text、xls、xlsx */
FileType string `json:"fileType"`
/* 文件路径(key) */
FileKey string `json:"fileKey"`
/* 分隔符: en-comma 英文逗号,en-semicolon 英文分号,space 空格,pipe 竖线,hash 井号,and 与号,line-feed-lf 换行符(UNIX),line-feed-crlf 换行符(Windows) (Optional) */
Delimiter string `json:"delimiter"`
/* 导入起始行 (Optional) */
StartRow int `json:"startRow"`
/* 字符集: GBK、UTF-8、ISO-8859-1,默认为 (Optional) */
CharacterSet string `json:"characterSet"`
}
type DefinedFunctionVo ¶
type DefinedFunctionVo struct {
/* 函数id (Optional) */
Id int `json:"id"`
/* 租户code (Optional) */
CompanyCode string `json:"companyCode"`
/* 命名空间code (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 函数名称(支持字母、数字、下划线,不超过50个字符) (Optional) */
FunctionName string `json:"functionName"`
/* 分类目录id (Optional) */
FunctionCatalogId int `json:"functionCatalogId"`
/* 函数主类全路径 (Optional) */
ClassName string `json:"className"`
/* 负责人 (Optional) */
Managers []string `json:"managers"`
/* 依赖的资源code(包括资源文件/资源目录) (Optional) */
ResourceCodes []string `json:"resourceCodes"`
/* 函数格式 (Optional) */
FunctionFormat string `json:"functionFormat"`
/* 函数使用说明 (Optional) */
FunctionUsage string `json:"functionUsage"`
/* 关联引擎 (Optional) */
RelativeEngine string `json:"relativeEngine"`
/* 环境信息,dev、prod (Optional) */
Env string `json:"env"`
}
type DeleteFunctionCatalogReq ¶
type DeleteFunctionCatalogReq struct {
/* 分类目录code (Optional) */
FunctionCatalogId int `json:"functionCatalogId"`
}
type DeleteFunctionReq ¶
type DeleteFunctionReq struct {
/* 函数id (Optional) */
FunctionId int `json:"functionId"`
}
type DeleteMemberReq ¶
type DeleteWatchmanParam ¶
type DeleteWatchmanParam struct {
/* 值班人id (Optional) */
Id int `json:"id"`
}
type EditWorkspaceReq ¶
type ExtraRunnerParamReq ¶
type ExtraRunnerReq ¶
type ExtraRunnerReq struct {
/* 流程code (Optional) */
FlowCode string `json:"flowCode"`
/* 脚本内容 (Optional) */
Content string `json:"content"`
/* 执行引擎MapReduce,Spark,Tez,presto,Python2,Python3,auto,默认spark (Optional) */
ExecEngine string `json:"execEngine"`
/* 脚本内容的变量参数配置 (Optional) */
Args UranusTaskParamReq `json:"args"`
/* 资源组名称 (Optional) */
ResourceName string `json:"resourceName"`
/* 资源组code (Optional) */
ResourceCode string `json:"resourceCode"`
}
type FunctionCatalogVo ¶
type FunctionCatalogVo struct {
/* 分类目录名称 (Optional) */
FunctionCatalogName string `json:"functionCatalogName"`
/* 分类目录id (Optional) */
FunctionCatalogId int `json:"functionCatalogId"`
/* 是否有子目录 (Optional) */
HasChildren bool `json:"hasChildren"`
/* 子目录 (Optional) */
Children []FunctionCatalogVo `json:"children"`
}
type GpdjmcCalcJobDTO ¶
type GpdjmcCalcJobDTO struct {
/* (Optional) */
ProjectId int `json:"projectId"`
/* (Optional) */
ProjectName string `json:"projectName"`
/* (Optional) */
ProjectNameMatch bool `json:"projectNameMatch"`
/* (Optional) */
NameKeyWord string `json:"nameKeyWord"`
/* (Optional) */
RelationType string `json:"relationType"`
/* (Optional) */
ModelId int `json:"modelId"`
/* (Optional) */
ModelName string `json:"modelName"`
/* (Optional) */
ModelNameMatch bool `json:"modelNameMatch"`
/* (Optional) */
GitUrl string `json:"gitUrl"`
/* (Optional) */
TableId int `json:"tableId"`
/* (Optional) */
DatabaseName string `json:"databaseName"`
/* (Optional) */
MarketId int `json:"marketId"`
/* (Optional) */
MarketCode string `json:"marketCode"`
/* (Optional) */
MarketName string `json:"marketName"`
/* (Optional) */
RedirectType string `json:"redirectType"`
/* (Optional) */
TableName string `json:"tableName"`
/* (Optional) */
TableNameMatch bool `json:"tableNameMatch"`
/* (Optional) */
JobName string `json:"jobName"`
/* (Optional) */
JobSystem string `json:"jobSystem"`
/* (Optional) */
TriggerType string `json:"triggerType"`
/* (Optional) */
TriggerConfig GpdjmcTriggerConfigDTO `json:"triggerConfig"`
/* (Optional) */
ZipCommand string `json:"zipCommand"`
/* (Optional) */
ZipFileName string `json:"zipFileName"`
/* (Optional) */
ZipParams string `json:"zipParams"`
/* (Optional) */
Dependencies string `json:"dependencies"`
/* (Optional) */
Manager string `json:"manager"`
/* (Optional) */
Cooperator string `json:"cooperator"`
/* 优先级,l1 - l4 (Optional) */
Priority string `json:"priority"`
/* (Optional) */
JobDesc string `json:"jobDesc"`
/* (Optional) */
ScriptType string `json:"scriptType"`
/* (Optional) */
RunScript string `json:"runScript"`
/* (Optional) */
ScriptContent []string `json:"scriptContent"`
/* (Optional) */
Cycle string `json:"cycle"`
/* (Optional) */
Sequence string `json:"sequence"`
/* (Optional) */
LifeCycle string `json:"lifeCycle"`
/* (Optional) */
Retry bool `json:"retry"`
/* (Optional) */
RetryCount int `json:"retryCount"`
/* (Optional) */
RetryInterval int `json:"retryInterval"`
/* (Optional) */
NotifyOccasion string `json:"notifyOccasion"`
/* (Optional) */
NotifyTime string `json:"notifyTime"`
/* (Optional) */
NotifyPattern string `json:"notifyPattern"`
/* (Optional) */
Notifier string `json:"notifier"`
/* (Optional) */
StartRunTime string `json:"startRunTime"`
/* (Optional) */
EndRunTime string `json:"endRunTime"`
/* (Optional) */
RunTime string `json:"runTime"`
/* (Optional) */
RunDate string `json:"runDate"`
/* (Optional) */
FlowId string `json:"flowId"`
/* (Optional) */
TaskId string `json:"taskId"`
/* (Optional) */
UserAccount string `json:"userAccount"`
/* (Optional) */
UserPwd string `json:"userPwd"`
/* (Optional) */
MarkIds string `json:"markIds"`
/* (Optional) */
RunTimeOut int `json:"runTimeOut"`
/* (Optional) */
ScriptSourceType string `json:"scriptSourceType"`
/* (Optional) */
ScriptTemplate string `json:"scriptTemplate"`
/* (Optional) */
DmrTableIds []int `json:"dmrTableIds"`
/* (Optional) */
DmrTables []GpdjmcDmrModelDTO `json:"dmrTables"`
/* (Optional) */
GitFilesList []GpdjmcGitFileDTO `json:"gitFilesList"`
/* (Optional) */
IsDeploy bool `json:"isDeploy"`
/* (Optional) */
ScriptPath string `json:"scriptPath"`
/* (Optional) */
ScriptByte []string `json:"scriptByte"`
/* (Optional) */
FileId int `json:"fileId"`
/* (Optional) */
PublishDesc string `json:"publishDesc"`
/* (Optional) */
ScriptInfo string `json:"scriptInfo"`
/* (Optional) */
Version int `json:"version"`
/* (Optional) */
Channel string `json:"channel"`
/* (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* (Optional) */
SequenceInterval int `json:"sequenceInterval"`
/* (Optional) */
RunParams string `json:"runParams"`
/* (Optional) */
RunQueue string `json:"runQueue"`
/* (Optional) */
SparkJarRunParams SparkJarRunParams `json:"sparkJarRunParams"`
/* (Optional) */
SubmitConf []GpdjmcConfPairStringString `json:"submitConf"`
/* (Optional) */
JobStatus int `json:"jobStatus"`
/* 计算资源组code (Optional) */
ResourceCode string `json:"resourceCode"`
/* 工作空间code (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 客户作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* (Optional) */
FromGravity bool `json:"fromGravity"`
/* 处理类型 (Optional) */
ProcessType string `json:"processType"`
/* 租户code (Optional) */
CompanyCode string `json:"companyCode"`
/* 窗口期开始时间 (Optional) */
WindowStartTime string `json:"windowStartTime"`
/* 窗口期结束时间 (Optional) */
WindowEndTime string `json:"windowEndTime"`
/* 脚本存储路径 (Optional) */
ScriptUrl string `json:"scriptUrl"`
/* 计算资源组名称 (Optional) */
ResourceName string `json:"resourceName"`
/* 数据源ID,在一些要访问外部源的任务中,需要指定该数据源ID (Optional) */
DatasourceId string `json:"datasourceId"`
/* 输入参数列表 (Optional) */
InputParams []GpdjmcInputParam `json:"inputParams"`
/* 输出参数列表 (Optional) */
OutputParams []GpdjmcOutputParam `json:"outputParams"`
/* 循环任务参数 (Optional) */
LoopParam GpdjmcLoopParam `json:"loopParam"`
}
type GpdjmcCalcJobResultDTO ¶
type GpdjmcCalcJobResultDTO struct {
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 表id (Optional) */
TableId int `json:"tableId"`
/* 数据库名称 (Optional) */
DatabaseName string `json:"databaseName"`
/* 工作空间 (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 模型表名 (Optional) */
TableName string `json:"tableName"`
/* 客户作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 作业系统 (Optional) */
JobSystem string `json:"jobSystem"`
/* 任务类型(触发类型) (Optional) */
TriggerType string `json:"triggerType"`
/* (Optional) */
TriggerConfig GpdjmcTriggerConfigDTO `json:"triggerConfig"`
/* zip命令行 (Optional) */
ZipCommand string `json:"zipCommand"`
/* zip名称 (Optional) */
ZipFileName string `json:"zipFileName"`
/* zip参数 (Optional) */
ZipParams string `json:"zipParams"`
/* 依赖任务列表 (Optional) */
Dependencies string `json:"dependencies"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* 协作人 (Optional) */
Cooperator string `json:"cooperator"`
/* 优先级 (Optional) */
Priority int `json:"priority"`
/* 任务描述 (Optional) */
JobDesc string `json:"jobDesc"`
/* 脚本类型 (Optional) */
ScriptType string `json:"scriptType"`
/* 脚本模板 (Optional) */
ScriptTemplate string `json:"scriptTemplate"`
/* 运行频率(运行周期) (Optional) */
Cycle string `json:"cycle"`
/* 运行频率(运行周期内序列) (Optional) */
Sequence string `json:"sequence"`
/* 生命周期 (Optional) */
LifeCycle string `json:"lifeCycle"`
/* 失败后是否重试 (Optional) */
Retry bool `json:"retry"`
/* 定时、一次任务(开始运行时间) (Optional) */
RunTime string `json:"runTime"`
/* 定时、一次任务(开始运行时间) (Optional) */
RunDate string `json:"runDate"`
/* 超时时间 (Optional) */
RunTimeOut int `json:"runTimeOut"`
/* 脚本来源类型(本地或者git) (Optional) */
ScriptSourceType string `json:"scriptSourceType"`
/* 开始运行时间 (Optional) */
StartRunTime string `json:"startRunTime"`
/* 结束运行时间 (Optional) */
EndRunTime string `json:"endRunTime"`
/* 运行脚本 (Optional) */
RunScript string `json:"runScript"`
/* 通知事件 (Optional) */
NotifyOccasion string `json:"notifyOccasion"`
/* 通知时间 (Optional) */
NotifyTime string `json:"notifyTime"`
/* 通知模式 (Optional) */
NotifyPattern string `json:"notifyPattern"`
/* 通知者 (Optional) */
Notifier string `json:"notifier"`
/* 是否拥有模型 (Optional) */
HasModel bool `json:"hasModel"`
/* 脚本文件字节数组,是将脚本文件内容转换为byte数组 (Optional) */
ScriptByte []string `json:"scriptByte"`
/* 根据版本号,判断是重新发布还是新建,如果新建添加版本号,不是新建,更新历史表作业状态状态 (Optional) */
Version int `json:"version"`
/* 判断是否是运维中心调用编辑接口1,运维中心 (Optional) */
Core int `json:"core"`
/* 数据渠道来源:新模型(MODEL),老模型(OLD_MODEL)、集成开发(IDE)、数据管道(PIPE)、数据质量(DQ)、AI(KUAI) (Optional) */
Channel string `json:"channel"`
/* 周期开始时间 (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 周期结束时间 (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 时间间隔 (Optional) */
SequenceInterval int `json:"sequenceInterval"`
/* 启用状态 (Optional) */
Enable string `json:"enable"`
/* 脚本运行引擎 枚举值 "TEZ、MR、SPARK" (Optional) */
RunParams string `json:"runParams"`
/* 提交配置(仅HiveSQL在Spark引擎下支持指定) (Optional) */
SubmitConf []GpdjmcConfPairStringString `json:"submitConf"`
/* 审计日志信息 (Optional) */
UpdateInfo interface{} `json:"updateInfo"`
}
type GpdjmcDelAllReqDTO ¶
type GpdjmcDeleteScriptReq ¶
type GpdjmcDeleteScriptReq struct {
/* 作业id列表 (Optional) */
JobIds []int `json:"jobIds"`
}
type GpdjmcDmrModelDTO ¶
type GpdjmcDmrModelDTO struct {
/* (Optional) */
TableId *int `json:"tableId"`
/* (Optional) */
TableName *string `json:"tableName"`
/* (Optional) */
TableNameCh *string `json:"tableNameCh"`
/* (Optional) */
DatabaseName *string `json:"databaseName"`
/* (Optional) */
ModelId *int `json:"modelId"`
/* (Optional) */
ModelName *string `json:"modelName"`
/* (Optional) */
ModelCode *string `json:"modelCode"`
/* (Optional) */
ProjectCode *string `json:"projectCode"`
/* (Optional) */
MarketName *string `json:"marketName"`
/* (Optional) */
WorkspaceCode *string `json:"workspaceCode"`
/* (Optional) */
MarketPre *string `json:"marketPre"`
/* (Optional) */
PmarketName *string `json:"pmarketName"`
}
type GpdjmcDmrModelJobRDTO ¶
type GpdjmcDmrModelJobRDTO struct {
/* 主键Id,为空时保存,不为空时更新 (Optional) */
Id int `json:"id"`
/* 作业Id (Optional) */
JobId int `json:"jobId"`
/* 模型Id (Optional) */
ModelTableId int `json:"modelTableId"`
/* 删除标识 (Optional) */
DeleteFlag int `json:"deleteFlag"`
/* 更新时间 (Optional) */
UpdateTime string `json:"updateTime"`
/* 表名 (Optional) */
TableName string `json:"tableName"`
/* 表中文名称 (Optional) */
TableNameCh string `json:"tableNameCh"`
/* 数据库名称 (Optional) */
DatabaseName string `json:"databaseName"`
/* 工作空间code (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 数据来源渠道 (Optional) */
Channel string `json:"channel"`
}
type GpdjmcDmrScriptInfoDTO ¶
type GpdjmcDmrScriptInfoDTO struct {
/* 主键Id,为空时保存,不为空时更新 (Optional) */
Id int `json:"id"`
/* 脚本名称 (Optional) */
ScriptName string `json:"scriptName"`
/* 脚本类型 (Optional) */
ScriptType string `json:"scriptType"`
/* 脚本描述 (Optional) */
ScriptDesc string `json:"scriptDesc"`
/* 脚本来源, LOCAL(本地) GIT(git) SKYDRIVE(网盘) (Optional) */
ScriptSourceType string `json:"scriptSourceType"`
/* 任务id (Optional) */
JobId int `json:"jobId"`
/* 删除标识 (Optional) */
DeleteFlag int `json:"deleteFlag"`
/* 创建人 (Optional) */
Creator string `json:"creator"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 修改人 (Optional) */
UpdateUser string `json:"updateUser"`
/* 修改时间 (Optional) */
UpdateTime string `json:"updateTime"`
/* 脚本内容 (Optional) */
Content string `json:"content"`
}
type GpdjmcEngineTemplateDTO ¶
type GpdjmcEngineTemplateDTO struct {
/* (Optional) */
Id int `json:"id"`
/* (Optional) */
DictCode string `json:"dictCode"`
/* (Optional) */
DictName string `json:"dictName"`
/* (Optional) */
Bak string `json:"bak"`
/* (Optional) */
Enabled string `json:"enabled"`
/* (Optional) */
DictDesc string `json:"dictDesc"`
/* (Optional) */
Template []GpdjmcMgrDictDTO `json:"template"`
/* (Optional) */
PdictCode string `json:"pdictCode"`
}
type GpdjmcGitFileDTO ¶
type GpdjmcGitFileDTO struct {
/* (Optional) */
Id *int `json:"id"`
/* (Optional) */
FileName *string `json:"fileName"`
/* (Optional) */
FileType *string `json:"fileType"`
/* (Optional) */
FilePath *string `json:"filePath"`
/* (Optional) */
FileVers *string `json:"fileVers"`
/* (Optional) */
GitUrl *string `json:"gitUrl"`
/* (Optional) */
DeleteFlag *int `json:"deleteFlag"`
/* (Optional) */
Creator *string `json:"creator"`
/* (Optional) */
CreateTime *string `json:"createTime"`
/* (Optional) */
UpdateUser *string `json:"updateUser"`
/* (Optional) */
UpdateTime *string `json:"updateTime"`
/* (Optional) */
StartupFlag *int `json:"startupFlag"`
/* (Optional) */
Level *int `json:"level"`
}
type GpdjmcInputParam ¶
type GpdjmcInputParam struct {
/* 参数名称 (Optional) */
ParamName *string `json:"paramName"`
/* 参数值(支持表达式);如果是从上游继承的参数,则此处应为上游参数名 (Optional) */
ParamValue *string `json:"paramValue"`
/* 是否为从上游任务继承的参数 (Optional) */
Inherited *bool `json:"inherited"`
/* 继承的作业名 (Optional) */
InheritedJobName *string `json:"inheritedJobName"`
}
type GpdjmcJobDeleteDTO ¶
type GpdjmcJobDeleteDTO struct {
/* 作业名 (Optional) */
JobName string `json:"jobName"`
}
type GpdjmcJobNaRemarkDTO ¶
type GpdjmcJobNaRemarkDTO struct {
/* (Optional) */
UserName string `json:"userName"`
/* (Optional) */
Remark string `json:"remark"`
/* (Optional) */
JobNames []string `json:"jobNames"`
/* (Optional) */
FileId int `json:"fileId"`
/* (Optional) */
Version int `json:"version"`
/* (Optional) */
PublishDesc string `json:"publishDesc"`
/* (Optional) */
Manager bool `json:"manager"`
/* (Optional) */
JobManager bool `json:"jobManager"`
}
type GpdjmcJobNameDTO ¶
type GpdjmcJobNameDTO struct {
/* 登录用户名 (Optional) */
UserName string `json:"userName"`
/* 作业名 (Optional) */
JobName string `json:"jobName"`
/* 客户作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 是否启用 (Optional) */
Enable string `json:"enable"`
/* 工作空间code (Optional) */
WorkspaceCode string `json:"workspaceCode"`
}
type GpdjmcJobQueryDTO ¶
type GpdjmcLoopListParam ¶
type GpdjmcLoopParam ¶
type GpdjmcLoopParam struct {
/* 循环类型 (Optional) */
LoopType *string `json:"loopType"`
/* 循环间隔 (Optional) */
LoopInterval *int `json:"loopInterval"`
/* 循环次数(仅迭代类型需要) (Optional) */
LoopTimes *int `json:"loopTimes"`
/* 批次大小 (Optional) */
BatchSize *int `json:"batchSize"`
/* 循环列表参数(仅列表类型需要) (Optional) */
LoopListParams []GpdjmcLoopListParam `json:"loopListParams"`
}
type GpdjmcMgrDictDTO ¶
type GpdjmcMgrDictDTO struct {
/* (Optional) */
Id int `json:"id"`
/* (Optional) */
DictCode string `json:"dictCode"`
/* (Optional) */
GetpDictCode string `json:"getpDictCode"`
/* (Optional) */
DictName string `json:"dictName"`
/* (Optional) */
Sort int `json:"sort"`
/* (Optional) */
Bak string `json:"bak"`
/* (Optional) */
Enabled string `json:"enabled"`
/* (Optional) */
DictDesc string `json:"dictDesc"`
}
type GpdjmcOutputParam ¶
type GpdjmcRpcResponseCalcJobResultDTO ¶
type GpdjmcRpcResponseCalcJobResultDTO struct {
/* (Optional) */
Success int `json:"success"`
/* (Optional) */
Code string `json:"code"`
/* (Optional) */
Msg string `json:"msg"`
/* (Optional) */
Result GpdjmcCalcJobResultDTO `json:"result"`
}
type GpdjmcRpcResponseDmrScriptInfoDTO ¶
type GpdjmcRpcResponseDmrScriptInfoDTO struct {
/* (Optional) */
Success int `json:"success"`
/* (Optional) */
Code string `json:"code"`
/* (Optional) */
Msg string `json:"msg"`
/* (Optional) */
Result GpdjmcDmrScriptInfoDTO `json:"result"`
}
type GpdjmcRpcResponseListDmrModelJobRDTO ¶
type GpdjmcRpcResponseListDmrModelJobRDTO struct {
/* (Optional) */
Success int `json:"success"`
/* (Optional) */
Code string `json:"code"`
/* (Optional) */
Msg string `json:"msg"`
/* (Optional) */
Result []GpdjmcDmrModelJobRDTO `json:"result"`
}
type GpdjmcRpcResponseListEngineTemplateDTO ¶
type GpdjmcRpcResponseListEngineTemplateDTO struct {
/* (Optional) */
Success int `json:"success"`
/* (Optional) */
Code string `json:"code"`
/* (Optional) */
Msg string `json:"msg"`
/* (Optional) */
Result []GpdjmcEngineTemplateDTO `json:"result"`
}
type GpdjmcRpcResponseListSchedJobDTO ¶
type GpdjmcRpcResponseListSchedJobDTO struct {
/* (Optional) */
Success int `json:"success"`
/* (Optional) */
Code string `json:"code"`
/* (Optional) */
Msg string `json:"msg"`
/* (Optional) */
Result []GpdjmcSchedJobDTO `json:"result"`
}
type GpdjmcRpcResponseListSchedJobDepDTO ¶
type GpdjmcRpcResponseListSchedJobDepDTO struct {
/* (Optional) */
Success int `json:"success"`
/* (Optional) */
Code string `json:"code"`
/* (Optional) */
Msg string `json:"msg"`
/* (Optional) */
Result []GpdjmcSchedJobDepDTO `json:"result"`
}
type GpdjmcRpcResponseListSchedJobResDTO ¶
type GpdjmcRpcResponseListSchedJobResDTO struct {
/* (Optional) */
Success int `json:"success"`
/* (Optional) */
Code string `json:"code"`
/* (Optional) */
Msg string `json:"msg"`
/* (Optional) */
Result []GpdjmcSchedJobResDTO `json:"result"`
}
type GpdjmcRpcResponseScriptInfoTypeDTO ¶
type GpdjmcRpcResponseScriptInfoTypeDTO struct {
/* (Optional) */
Success int `json:"success"`
/* (Optional) */
Code string `json:"code"`
/* (Optional) */
Msg string `json:"msg"`
/* (Optional) */
Result GpdjmcScriptInfoTypeDTO `json:"result"`
}
type GpdjmcSchedJobDTO ¶
type GpdjmcSchedJobDTO struct {
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 客户作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 老作业兼容字段 (Optional) */
JobSystem string `json:"jobSystem"`
/* 作业描述 (Optional) */
JobDesc string `json:"jobDesc"`
/* 最后一次运行状态,Pending、Ready、Running、Done、Failed、Clean (Optional) */
LastStatus string `json:"lastStatus"`
/* 最后依次执行日期 (Optional) */
LastTxDate string `json:"lastTxDate"`
/* 最后一次运行开始时间 (Optional) */
LastStartTime string `json:"lastStartTime"`
/* 最后一次运行结束时间 (Optional) */
LastEndTime string `json:"lastEndTime"`
/* 最后一次运行服务器 (Optional) */
LastServer string `json:"lastServer"`
/* Session ID (Optional) */
LastSessionid int `json:"lastSessionid"`
/* 最后返回编码 (Optional) */
LastReturnCode int `json:"lastReturnCode"`
/* 当前作业状态信息 (Optional) */
CurrentStatusMsg string `json:"currentStatusMsg"`
/* 触发类型:dependency 依赖、time 时间、file 文件、manual 手工、once 一次性 (Optional) */
TriggerType string `json:"triggerType"`
/* 运行周期 ,D 天、W 周、M 月、O 一次性运行、N 无周期 (Optional) */
Cycle string `json:"cycle"`
/* 周期具体日期 (Optional) */
Sequence string `json:"sequence"`
/* T+N,偏移量 (Optional) */
TxDateOffset int `json:"txDateOffset"`
/* 作业优先级,数字越小优先级越高 (Optional) */
Priority int `json:"priority"`
/* 作业超时时间,单位分钟 (Optional) */
Timeout int `json:"timeout"`
/* 窗口期开始时间 (Optional) */
WindowStartTime string `json:"windowStartTime"`
/* 窗口期结束时间 (Optional) */
WindowEndTime string `json:"windowEndTime"`
/* 失败后次日是否自动运行,1是、0否 (Optional) */
MorrowAutoExec string `json:"morrowAutoExec"`
/* 抽空之后的处理 0 无操作 1 作业失败 2发出警告 (Optional) */
DataZeroKillEnable int `json:"dataZeroKillEnable"`
/* 重试次数 (Optional) */
RetryCount int `json:"retryCount"`
/* 间隔/秒 (Optional) */
RetryInterval int `json:"retryInterval"`
/* 当期已经跑成功过,是否可以再跑,1启用、0关闭 (Optional) */
FlagAgain string `json:"flagAgain"`
/* 是否可以跨周期跑,1启用、0关闭 (Optional) */
FlagAcross string `json:"flagAcross"`
/* 是否可以自身并行,1启用、0关闭 (Optional) */
FlagParallel string `json:"flagParallel"`
/* 是否级联触发,父任务重跑后是否被强制触发重跑,1是、0否 (Optional) */
FlagCascadedTrigger string `json:"flagCascadedTrigger"`
/* 命名空间名称 (Optional) */
NsName string `json:"nsName"`
/* 服务器资源消耗值 (Optional) */
ServerResourVal int `json:"serverResourVal"`
/* 指定运行服务器 (Optional) */
RunServers string `json:"runServers"`
/* 需要的运行环境 (Optional) */
RequiredRunEnv string `json:"requiredRunEnv"`
/* 运行脚本 (Optional) */
RunScript string `json:"runScript"`
/* 是否启用,0未上线、1已上线、2已下线 (Optional) */
Enable string `json:"enable"`
/* 负责人,不超过10个 (Optional) */
Manager string `json:"manager"`
ShareUser string `json:"shareUser"`
/* 失效时间 (Optional) */
ExpireTime string `json:"expireTime"`
/* zip命令行 (Optional) */
Commands string `json:"commands"`
/* 创建人 (Optional) */
CreateUser string `json:"createUser"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 更新时间 (Optional) */
UpdateTime string `json:"updateTime"`
/* 实时结点名称 (Optional) */
NodeName string `json:"nodeName"`
/* 实时主题 (Optional) */
Topic string `json:"topic"`
/* 作业执行方式 0离线 1双写 2实时 (Optional) */
JobRunWay string `json:"jobRunWay"`
/* 作业运行参数 (Optional) */
RunParams string `json:"runParams"`
/* 所属系统 (Optional) */
BelongSys string `json:"belongSys"`
/* 周期开始时间 (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 周期结束时间 (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 周期间隔 (Optional) */
SequenceInterval int `json:"sequenceInterval"`
/* 开始时间 (Optional) */
StartTime string `json:"startTime"`
/* 计划执行时间 (Optional) */
PlanExecTime string `json:"planExecTime"`
/* 主从同步延迟处理方式。0:警告无处理,1:作业延迟启动 (Optional) */
MsDelayDealWay string `json:"msDelayDealWay"`
}
type GpdjmcSchedJobDepDTO ¶
type GpdjmcSchedJobResDTO ¶
type GpdjmcScriptFileDTO ¶
type GpdjmcScriptInfoTypeDTO ¶
type GpdjmcScriptInfoTypeDTO struct {
/* (Optional) */
OtherInfoList []GpdjmcScriptInfoTemplateDTO `json:"otherInfoList"`
/* (Optional) */
MgrDictListScript []GpdjmcMgrDictDTO `json:"mgrDictListScript"`
}
type GpdjmcTableInfoDTO ¶
type GpdjmcTriggerConfigDTO ¶
type GpdjmcTriggerConfigDTO struct {
/* 条件类型 (Optional) */
ConditionType *string `json:"conditionType"`
/* 次要类型 (Optional) */
SecondaryType *string `json:"secondaryType"`
/* 服务器域名 (Optional) */
ServerDomain *string `json:"serverDomain"`
/* 服务器端口 (Optional) */
ServerPort *string `json:"serverPort"`
/* 用户名 (Optional) */
Username *string `json:"username"`
/* 用户密码 (Optional) */
UsernamePwd *string `json:"usernamePwd"`
/* 协议 (Optional) */
Protocol *string `json:"protocol"`
/* 数据库名称 (Optional) */
DatabaseName *string `json:"databaseName"`
/* 数据源 (Optional) */
DataSource *string `json:"dataSource"`
/* 对象信息 (Optional) */
Object *string `json:"object"`
/* 条件配置 (Optional) */
ConditionConfig *string `json:"conditionConfig"`
/* 触发时间 (Optional) */
TriggerTime *string `json:"triggerTime"`
/* 触发间隔 (Optional) */
TriggerInterval *int `json:"triggerInterval"`
/* 开始时间 (Optional) */
BeginTime *string `json:"beginTime"`
/* 结束时间 (Optional) */
EndTime *string `json:"endTime"`
}
type GpdjmcWorkspaceInfoDTO ¶
type GpdjmcWorkspaceInfoDTO struct {
/* 工作空间名称 (Optional) */
WorkspaceCode string `json:"workspaceCode"`
}
type GpdpJobDepChainReq ¶
type GpdpJobDependenceReq ¶
type GpdpJobDependencyResultDTO ¶
type GpdpJobDependencyResultDTO struct {
/* 作业名 (Optional) */
JobName string `json:"jobName"`
/* 客户作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 最后以此执行日期 (Optional) */
LastTxDate string `json:"lastTxDate"`
/* 最后一次运行开始时间 (Optional) */
LastStartTime string `json:"lastStartTime"`
/* 最后一次结束时间 (Optional) */
LastEndTime string `json:"lastEndTime"`
/* 最后一次运行状态,Pending、Ready、Running、Done、Failed、Clean (Optional) */
LastStatus string `json:"lastStatus"`
/* 是否可以自身并行,1启用、0关闭 (Optional) */
FlagParallel string `json:"flagParallel"`
/* 当前作业状态信息 (Optional) */
CurrentStatusMsg string `json:"currentStatusMsg"`
/* 周期开始时间(适用小时分钟) (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 周期结束时间(适用小时分钟) (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 周期间隔(适用小时分钟,当周期为小时,含义为间隔小时数,当周期为分钟,含义为间隔分钟数) (Optional) */
SequenceInterval string `json:"sequenceInterval"`
/* 是否启用,1启用、0关闭 (Optional) */
Enable string `json:"enable"`
/* 负责人,不超过10个 (Optional) */
Manager string `json:"manager"`
/* 作业所属系统,G gravity版本、A automation版本,用于迁移字段 (Optional) */
JobBelong string `json:"jobBelong"`
/* 是否强依赖,1启用、0关闭 (Optional) */
Necessary string `json:"necessary"`
/* 是否可以上下游并行,1启用、0关闭 (Optional) */
DepFlagParallel string `json:"depFlagParallel"`
/* 触发类型:dependency 依赖、time 时间、file 文件、manual 手工、once 一次性 (Optional) */
TriggerType string `json:"triggerType"`
/* 运行周期 ,F 分钟、H 小时、D 天、W 周、M 月、O 一次性运行、N 无周期 (Optional) */
Cycle string `json:"cycle"`
/* 周期具体日期 (Optional) */
Sequence string `json:"sequence"`
}
type GpdpJobDetailResultDTO ¶
type GpdpJobDetailResultDTO struct {
/* 数据日期 (Optional) */
TxDate string `json:"txDate"`
/* 计划执行时间 (Optional) */
PlanExecTime string `json:"planExecTime"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 最后一次运行结束时间 (Optional) */
LastEndTime string `json:"lastEndTime"`
/* 最后一次运行开始时间 (Optional) */
LastStartTime string `json:"lastStartTime"`
/* 作业运行耗时/秒 (Optional) */
CostTime int `json:"costTime"`
/* 表名 (Optional) */
TargetTable int `json:"targetTable"`
}
type GpdpPageInfoJobDependencyResultDTO ¶
type GpdpPageInfoJobDependencyResultDTO struct {
/* (Optional) */
Total int64 `json:"total"`
/* (Optional) */
List []GpdpJobDependencyResultDTO `json:"list"`
/* (Optional) */
PageNum int `json:"pageNum"`
/* (Optional) */
PageSize int `json:"pageSize"`
/* (Optional) */
Size int `json:"size"`
/* (Optional) */
StartRow int `json:"startRow"`
/* (Optional) */
EndRow int `json:"endRow"`
/* (Optional) */
Pages int `json:"pages"`
/* (Optional) */
PrePage int `json:"prePage"`
/* (Optional) */
NextPage int `json:"nextPage"`
/* (Optional) */
IsFirstPage bool `json:"isFirstPage"`
/* (Optional) */
IsLastPage bool `json:"isLastPage"`
/* (Optional) */
HasPreviousPage bool `json:"hasPreviousPage"`
/* (Optional) */
HasNextPage bool `json:"hasNextPage"`
NavigatePages int `json:"navigatePages"`
NavigatepageNums []int `json:"navigatepageNums"`
NavigateFirstPage int `json:"navigateFirstPage"`
NavigateLastPage int `json:"navigateLastPage"`
}
type GpdpSchedTriggerDependTree ¶
type GpdpSchedTriggerDependTree struct {
/* (Optional) */
Id int `json:"id"`
/* (Optional) */
JobName string `json:"jobName"`
/* (Optional) */
DependName string `json:"dependName"`
/* 作业所属系统,G gravity版本、A automation版本,废弃字段 (Optional) */
JobBelong string `json:"jobBelong"`
/* 是否可以上下游并行,1启用、0关闭 (Optional) */
FlagParallel string `json:"flagParallel"`
/* 是否强依赖,1启用、0关闭 (Optional) */
Necessary string `json:"necessary"`
/* 依赖偏移量,0当天,-1昨天 (Optional) */
DayOffset string `json:"dayOffset"`
/* 依赖作业所属系统,G gravity版本、A automation版本,废弃字段 (Optional) */
DependJobBelong string `json:"dependJobBelong"`
/* 是否启用,1启用、0关闭 (Optional) */
Enable string `json:"enable"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 更新时间 (Optional) */
UpdateTime string `json:"updateTime"`
/* 客户作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 最后状态 (Optional) */
LastStatus string `json:"lastStatus"`
/* 最后数据日期 (Optional) */
LastTxDate string `json:"lastTxDate"`
/* 计划执行时间 (Optional) */
PlanExeTime string `json:"planExeTime"`
/* 作业表名 (Optional) */
TableName string `json:"tableName"`
/* manager作业负责人 (Optional) */
Manager string `json:"manager"`
/* 作业描述 (Optional) */
JobDesc string `json:"jobDesc"`
/* 显示信息 (Optional) */
Display string `json:"display"`
/* 最后开始时间 (Optional) */
LastStartTime string `json:"lastStartTime"`
/* 最后结束时间 (Optional) */
LastEndTime string `json:"lastEndTime"`
/* 是否含有父类 (Optional) */
Parent bool `json:"parent"`
/* 是否有子类 (Optional) */
Child bool `json:"child"`
/* 依赖父作业清单 (Optional) */
DependList []GpdpSchedTriggerDependTree `json:"dependList"`
}
type GpdrAfreshAddLogVo ¶
type GpdrAfreshAddLogVo struct {
/* 查询补数跟踪记录id (Optional) */
Id int `json:"id"`
/* 作业名 (Optional) */
EtlJob string `json:"etlJob"`
/* 客户作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 补数任务ID (Optional) */
TaskId int `json:"taskId"`
/* 数据日期 (Optional) */
TxDate string `json:"txDate"`
/* 计划执行时间 (Optional) */
PlanExeTime string `json:"planExeTime"`
/* 任务状态 (Optional) */
JobStatus string `json:"jobStatus"`
/* 任务开始运行时间 (Optional) */
StartTime string `json:"startTime"`
/* 任务开始运行时间 (Optional) */
EndTime string `json:"endTime"`
/* 补数任务ID (Optional) */
AfreshAddId int `json:"afreshAddId"`
}
type GpdrAfreshAddParam ¶
type GpdrCloseTaskReq ¶
type GpdrCloseTaskReq struct {
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
}
type GpdrListHisRunTaskResDTO ¶
type GpdrListHisRunTaskResDTO struct {
/* 作业补数信息主键id (Optional) */
Id int `json:"id"`
/* 当前补数日期 (Optional) */
Txdate string `json:"txdate"`
/* 任务状态 (Optional) */
Statu string `json:"statu"`
/* 补数任务是否关闭 (Optional) */
Enable string `json:"enable"`
/* 补数当前状态信息 (Optional) */
CurrentMsg string `json:"currentMsg"`
/* 任务名称 (Optional) */
JobName string `json:"jobName"`
/* 补数开始日期 (Optional) */
JobStartDate string `json:"jobStartDate"`
/* 补数结束日期 (Optional) */
JobEndDate string `json:"jobEndDate"`
/* 作业描述 (Optional) */
Description string `json:"description"`
/* 周期具体日期 (Optional) */
Cycle string `json:"cycle"`
/* 处理类型 (Optional) */
ProcessType string `json:"processType"`
/* 执行类型 (Optional) */
ExeType string `json:"exeType"`
/* 创建时间 (Optional) */
CreateDate string `json:"createDate"`
/* calc:数据计算,extract:数据抽取,ods:ODS加工,load:数据推送,hdfs:数据同步,dqim:质量作业 (Optional) */
ProcessTypeLabel string `json:"processTypeLabel"`
/* 作业负责人 (Optional) */
Manager string `json:"manager"`
/* 状态 (Optional) */
StatusLabel string `json:"statusLabel"`
/* 作业类型 (Optional) */
JobType string `json:"jobType"`
/* 作业子类型 (Optional) */
JobChildType string `json:"jobChildType"`
/* 当前用户是否为当前作业的管理员 (Optional) */
ManagerFlag bool `json:"managerFlag"`
/* 客户作业名 (Optional) */
CstJobName string `json:"cstJobName"`
}
type GpdrListTaskLogReq ¶
type GpdrListTaskReq ¶
type GpdrListTaskReq struct {
/* 页面大小 */
PageSize int `json:"pageSize"`
/* 页码 */
PageNum int `json:"pageNum"`
/* 补数任务是否关闭 (Optional) */
Enable string `json:"enable"`
/* 任务名称 (Optional) */
JobName string `json:"jobName"`
/* 客户作业名 (Optional) */
CstJobName string `json:"cstJobName"`
/* 任务类型 (Optional) */
JobType string `json:"jobType"`
/* 处理类型 (Optional) */
ProcessType string `json:"processType"`
/* 处理类型列表 (Optional) */
ProcessTypeList []string `json:"processTypeList"`
/* 执行类型列表 (Optional) */
ExeTypeList []string `json:"exeTypeList"`
/* 周期具体日期 (Optional) */
Cycle string `json:"cycle"`
/* 作业负责人 (Optional) */
Manager string `json:"manager"`
/* 任务状态 (Optional) */
Statu string `json:"statu"`
/* 补数开始日期 (Optional) */
JobStartDate string `json:"jobStartDate"`
/* 补数结束日期 (Optional) */
JobEndDate string `json:"jobEndDate"`
/* 创建时间结束区间 (Optional) */
CreateDateBefore string `json:"createDateBefore"`
/* 工作空间code (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* (Optional) */
JobChildType string `json:"jobChildType"`
}
type GpdrOpenApiRespInteger ¶
type GpdrOpenApiRespString ¶
type GpdrOpenApiResponsePageInfoAfreshAddLogVo ¶
type GpdrOpenApiResponsePageInfoAfreshAddLogVo struct {
/* 成功标识,1成功,0失败 (Optional) */
Success int `json:"success"`
/* (Optional) */
Result GpdrPageInfoAfreshAddLogVo `json:"result"`
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 返回状态信息 (Optional) */
Msg string `json:"msg"`
// contains filtered or unexported fields
}
type GpdrOpenApiResponsePageInfoListHisRunTaskResDTO ¶
type GpdrOpenApiResponsePageInfoListHisRunTaskResDTO struct {
/* 成功标识,1成功,0失败 (Optional) */
Success int `json:"success"`
/* (Optional) */
Result GpdrPageInfoListHisRunTaskResDTO `json:"result"`
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 返回状态信息 (Optional) */
Msg string `json:"msg"`
// contains filtered or unexported fields
}
type GpdrPageInfoAfreshAddLogVo ¶
type GpdrPageInfoAfreshAddLogVo struct {
/* (Optional) */
Total int64 `json:"total"`
/* (Optional) */
List []GpdrAfreshAddLogVo `json:"list"`
/* (Optional) */
PageNum int `json:"pageNum"`
/* (Optional) */
PageSize int `json:"pageSize"`
/* (Optional) */
Size int `json:"size"`
/* (Optional) */
StartRow int `json:"startRow"`
/* (Optional) */
EndRow int `json:"endRow"`
/* (Optional) */
Pages int `json:"pages"`
/* (Optional) */
PrePage int `json:"prePage"`
/* (Optional) */
NextPage int `json:"nextPage"`
/* (Optional) */
IsFirstPage bool `json:"isFirstPage"`
/* (Optional) */
IsLastPage bool `json:"isLastPage"`
/* (Optional) */
HasPreviousPage bool `json:"hasPreviousPage"`
/* (Optional) */
HasNextPage bool `json:"hasNextPage"`
NavigatePages int `json:"navigatePages"`
NavigatepageNums []int `json:"navigatepageNums"`
NavigateFirstPage int `json:"navigateFirstPage"`
NavigateLastPage int `json:"navigateLastPage"`
}
type GpdrPageInfoListHisRunTaskResDTO ¶
type GpdrPageInfoListHisRunTaskResDTO struct {
/* (Optional) */
Total int64 `json:"total"`
/* (Optional) */
List []GpdrListHisRunTaskResDTO `json:"list"`
/* (Optional) */
PageNum int `json:"pageNum"`
/* (Optional) */
PageSize int `json:"pageSize"`
/* (Optional) */
Size int `json:"size"`
/* (Optional) */
StartRow int `json:"startRow"`
/* (Optional) */
EndRow int `json:"endRow"`
/* (Optional) */
Pages int `json:"pages"`
/* (Optional) */
PrePage int `json:"prePage"`
/* (Optional) */
NextPage int `json:"nextPage"`
/* (Optional) */
IsFirstPage bool `json:"isFirstPage"`
/* (Optional) */
IsLastPage bool `json:"isLastPage"`
/* (Optional) */
HasPreviousPage bool `json:"hasPreviousPage"`
/* (Optional) */
HasNextPage bool `json:"hasNextPage"`
NavigatePages int `json:"navigatePages"`
NavigatepageNums []int `json:"navigatepageNums"`
NavigateFirstPage int `json:"navigateFirstPage"`
NavigateLastPage int `json:"navigateLastPage"`
}
type GpjmConditionInfo ¶
type GpjmConditionInfo struct {
/* 具体的类型的类型列表 (Optional) */
ConditionType []GpjmConditionType `json:"conditionType"`
/* 触发类型: condition, 后续可能包括时间触发等原来的类型 (Optional) */
TriggerType string `json:"triggerType"`
/* 类型的中文名: 条件触发、时间触发等 (Optional) */
TriggerTypeCh string `json:"triggerTypeCh"`
}
type GpjmConditionType ¶
type GpjmJobBasicInfoDTO ¶
type GpjmJobBasicInfoDTO struct {
/* 作业id (Optional) */
JobId int `json:"jobId"`
/* 作业名 (Optional) */
EtlJob string `json:"etlJob"`
/* 处理类型 (Optional) */
ProcessType string `json:"processType"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 更新时间 (Optional) */
UpdateTime string `json:"updateTime"`
/* 作业执行类型 (Optional) */
ExeType string `json:"exeType"`
/* 工作空间code (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 运行周期 ,F 分钟、H 小时、D 天、W 周、M 月、O 一次性运行、N 无周期 (Optional) */
JobType string `json:"jobType"`
/* 周期具体日期 (Optional) */
Frequency string `json:"frequency"`
/* 负责人 (Optional) */
UserName string `json:"userName"`
ShareUser string `json:"shareUser"`
/* 作业描述 (Optional) */
JobDesc string `json:"jobDesc"`
/* 失效时间 (Optional) */
ExpireTime string `json:"expireTime"`
/* 是否启用,0未上线、1已上线、2已下线 (Optional) */
Enable string `json:"enable"`
/* 作业优先级,数字越小优先级越高 (Optional) */
Priority int `json:"priority"`
/* 作业优先级按照等级分,L1-L4,数字越小优先级越高 (Optional) */
PriorityLevel string `json:"priorityLevel"`
/* 模型表名 (Optional) */
TableName string `json:"tableName"`
/* 数据渠道来源:新模型(MODEL),老模型(OLD_MODEL)、集成开发(IDE)、数据管道(PIPE)、数据质量(DQ)、AI(KUAI) (Optional) */
Channel string `json:"channel"`
/* 处理类型 (Optional) */
ProcessTypeCode string `json:"processTypeCode"`
/* 创建人 (Optional) */
Operator string `json:"operator"`
/* 客户作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
}
type GpjmJobBasicInfoResultDTO ¶
type GpjmJobBasicInfoResultDTO struct {
/* (Optional) */
JobCommonInfo GpjmJobCommonInfoDTO `json:"jobCommonInfo"`
/* (Optional) */
JobBasicInfo GpjmJobBasicInfoDTO `json:"jobBasicInfo"`
/* (Optional) */
RunRoleInfo GpjmRunRoleInfoDTO `json:"runRoleInfo"`
/* (Optional) */
JobMonitorInfo GpjmJobMonitorInfoDTO `json:"jobMonitorInfo"`
/* flowStatus (Optional) */
FlowStatus string `json:"flowStatus"`
}
type GpjmJobCommonInfoDTO ¶
type GpjmJobCommonInfoDTO struct {
/* 作业名 (Optional) */
JobName string `json:"jobName"`
/* 作业描述 (Optional) */
JobDesc string `json:"jobDesc"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
ShareUser string `json:"shareUser"`
/* 数据日期 (Optional) */
LastTxdate string `json:"lastTxdate"`
/* 最后一次运行状态,Pending、Ready、Running、Done、Failed、Clean (Optional) */
LastStatus string `json:"lastStatus"`
/* 当前作业状态信息 (Optional) */
CurrentStatusMsg string `json:"currentStatusMsg"`
/* 周期结束时间(适用小时分钟) (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 周期间隔(适用小时分钟,当周期为小时,含义为间隔小时数,当周期为分钟,含义为间隔分钟数) (Optional) */
SequenceInterval int `json:"sequenceInterval"`
/* 周期开始时间(适用小时分钟) (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 触发类型:dependency 依赖、time 时间、file 文件、manual 手工、once 一次性 (Optional) */
TriggerType string `json:"triggerType"`
/* 作业id (Optional) */
JobId int `json:"jobId"`
/* 处理类型 (Optional) */
ProcessType string `json:"processType"`
/* 作业执行类型 (Optional) */
ExeType string `json:"exeType"`
/* 关联类型:1:一对一 2:一对多 3:多对一 (Optional) */
RelationType string `json:"relationType"`
/* 作业管理员或者空间管理员 (Optional) */
ManagerFlag bool `json:"managerFlag"`
}
type GpjmJobCompletionResultDTO ¶
type GpjmJobCompletionResultDTO struct {
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 客户作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 模型表名 (Optional) */
TableName string `json:"tableName"`
/* 最后一次运行状态 (Optional) */
LastStatus string `json:"lastStatus"`
/* 最后依次执行日期 (Optional) */
LastTxDate string `json:"lastTxDate"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* Session ID (Optional) */
LastSessionid int `json:"lastSessionid"`
/* 最后一次运行开始时间 (Optional) */
LastStartTime string `json:"lastStartTime"`
/* 最后一次运行结束时间 (Optional) */
LastEndTime string `json:"lastEndTime"`
/* 当前作业状态信息 (Optional) */
CurrentStatusMsg string `json:"currentStatusMsg"`
/* 作业描述 (Optional) */
JobDesc string `json:"jobDesc"`
/* 运行周期 ,F 分钟、H 小时、D 天、W 周、M 月、O 一次性运行、N 无周期 (Optional) */
Cycle string `json:"cycle"`
/* 周期具体日期 (Optional) */
Sequence string `json:"sequence"`
/* 周期开始时间 (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 周期结束时间 (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 周期间隔 (Optional) */
SequenceInterval string `json:"sequenceInterval"`
/* 触发类型:dependency 依赖、time 时间、file 文件、manual 手工、once 一次性 (Optional) */
TriggerType string `json:"triggerType"`
/* 运行时间 (Optional) */
RunTime string `json:"runTime"`
/* 作业运行耗时/秒 (Optional) */
CostTime int `json:"costTime"`
/* 计划执行时间 (Optional) */
PlanExecTime string `json:"planExecTime"`
}
type GpjmJobInfoReq ¶
type GpjmJobMonitorInfoDTO ¶
type GpjmJobMonitorInfoDTO struct {
/* 告警类型 (Optional) */
WarningType string `json:"warningType"`
/* 通知接收人 (Optional) */
Notifiers string `json:"notifiers"`
/* 启动延迟时间 (Optional) */
StartDeadlineTime string `json:"startDeadlineTime"`
/* 结束延迟时间 (Optional) */
EndDeadlineTime string `json:"endDeadlineTime"`
/* 通知事件类型 (Optional) */
EventType string `json:"eventType"`
/* 通知事件类型描述 (Optional) */
EventTypeDesc string `json:"eventTypeDesc"`
}
type GpjmJobQueryReq ¶
type GpjmJobRunInfoResultDTO ¶
type GpjmJobRunInfoResultDTO struct {
/* 作业名 (Optional) */
EtlJob string `json:"etlJob"`
/* 数据日期 (Optional) */
TxDate string `json:"txDate"`
/* 运行开始时间 (Optional) */
StartTime string `json:"startTime"`
/* 运行结束时间 (Optional) */
EndTime string `json:"endTime"`
/* 运行状态 (Optional) */
JobStatus string `json:"jobStatus"`
/* Session ID (Optional) */
JobSessionId string `json:"jobSessionId"`
/* 运行时间 (Optional) */
RunTime string `json:"runTime"`
/* 返回编码 (Optional) */
ReturnCode string `json:"returnCode"`
/* 返回信息 (Optional) */
ReturnMsg string `json:"returnMsg"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 是否补数任务 (Optional) */
IsComplement string `json:"isComplement"`
/* 计划执行时间 (Optional) */
PlanExecTime string `json:"planExecTime"`
}
type GpjmJobTypeInfoDto ¶
type GpjmJobTypeInfoDto struct {
/* 作业基础类型编码 (Optional) */
JobBaseType string `json:"jobBaseType"`
/* 作业基础类型描述 (Optional) */
JobBaseTypeDesc string `json:"jobBaseTypeDesc"`
/* 作业子类型编码 (Optional) */
JobChildType string `json:"jobChildType"`
/* 作业子类型描述 (Optional) */
JobChildTypeDesc string `json:"jobChildTypeDesc"`
}
type GpjmListJobInstanceReq ¶
type GpjmListJobInstanceReq struct {
/* 页面大小 */
PageSize int `json:"pageSize"`
/* 页码 */
PageNum int `json:"pageNum"`
/* 运行状态 (Optional) */
StatusList []string `json:"statusList"`
/* 作业上上线下线状态 (Optional) */
Enable string `json:"enable"`
/* 运行周期 (Optional) */
Cycle string `json:"cycle"`
/* 处理类型 (Optional) */
ProcessType string `json:"processType"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* 作业名 (Optional) */
JobName string `json:"jobName"`
/* 任务类型 (Optional) */
JobType string `json:"jobType"`
/* 任务创建日期-结束 (Optional) */
CreateTimeBefore string `json:"createTimeBefore"`
/* 任务创建日期-开始 (Optional) */
CreateTimeAfter string `json:"createTimeAfter"`
/* 运行开始时间范围 (Optional) */
StartTimeBefore string `json:"startTimeBefore"`
/* 运行开始时间范围 (Optional) */
StartTimeAfter string `json:"startTimeAfter"`
/* 运行结束时间范围 (Optional) */
EndTimeAfter string `json:"endTimeAfter"`
/* 运行结束时间范围 (Optional) */
EndTimeBefore string `json:"endTimeBefore"`
/* 数据日期 (Optional) */
TxDate string `json:"txDate"`
/* (Optional) */
JobChildType string `json:"jobChildType"`
/* 客户作业名 (Optional) */
CstJobName string `json:"cstJobName"`
}
type GpjmListJobInstanceResultDTO ¶
type GpjmListJobInstanceResultDTO struct {
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 运行开始时间 (Optional) */
StartTime string `json:"startTime"`
/* 运行结束时间 (Optional) */
EndTime string `json:"endTime"`
/* 数据日期 (Optional) */
TxDate string `json:"txDate"`
/* 返回信息 (Optional) */
CurrentStatusMsg string `json:"currentStatusMsg"`
/* 返回编码 (Optional) */
LastReturnCode string `json:"lastReturnCode"`
/* 运行时间 (Optional) */
RunTime string `json:"runTime"`
/* Session ID (Optional) */
Sessionid string `json:"sessionid"`
/* 状态 (Optional) */
Status string `json:"status"`
/* 是否补数任务:Y 是 N 否 (Optional) */
IsComplement string `json:"isComplement"`
/* 计划执行时间 (Optional) */
PlanExecTime string `json:"planExecTime"`
/* 运行周期 ,F 分钟、H 小时、D 天、W 周、M 月、O 一次性运行、N 无周期 (Optional) */
JobId string `json:"jobId"`
/* 作业描述 (Optional) */
Description string `json:"description"`
/* 处理类型(calc:数据计算,extract:数据抽取,ods:ODS加工,load:数据推送,hdfs:数据同步,dqim:质量作业) (Optional) */
ProcessType string `json:"processType"`
/* 执行类型(fusing:熔断,warning:预警) (Optional) */
ExeType string `json:"exeType"`
/* 是否启用,0未上线、1已上线、2已下线 (Optional) */
Enable string `json:"enable"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* 数据渠道来源:新模型(MODEL),老模型(OLD_MODEL)、集成开发(IDE)、数据管道(PIPE)、数据质量(DQ)、AI(KUAI) (Optional) */
Channel string `json:"channel"`
/* 任务类型 (Optional) */
JobType string `json:"jobType"`
/* 作业子类型 (Optional) */
JobChildType string `json:"jobChildType"`
/* (Optional) */
ManagerFlag bool `json:"managerFlag"`
/* 客户作业名 (Optional) */
CstJobName string `json:"cstJobName"`
}
type GpjmListJobReq ¶
type GpjmListJobReq struct {
/* 页面大小 */
PageSize int `json:"pageSize"`
/* 页码 */
PageNum int `json:"pageNum"`
/* 最后一次运行状态 (Optional) */
LastJobStatus []string `json:"lastJobStatus"`
/* 处理类型 (Optional) */
ExcludeJobTypes []string `json:"excludeJobTypes"`
/* (Optional) */
MarketJobsAll string `json:"marketJobsAll"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* 任务类型 (Optional) */
QueryMode string `json:"queryMode"`
/* 作业上上线下线状态 (Optional) */
Enable string `json:"enable"`
/* 作业名 (Optional) */
JobName string `json:"jobName"`
/* (Optional) */
CurrentStatus string `json:"currentStatus"`
/* 处理类型 (Optional) */
ProcessType string `json:"processType"`
/* 数据日期 (Optional) */
LastTxdate string `json:"lastTxdate"`
/* 运行周期 (Optional) */
Cycle string `json:"cycle"`
/* 任务执行时间开始 (Optional) */
JobStartRunTime string `json:"jobStartRunTime"`
/* 任务执行时间- 结束 (Optional) */
JobEndRunTime string `json:"jobEndRunTime"`
/* 任务创建日期-结束 (Optional) */
CreateTimeBefore string `json:"createTimeBefore"`
/* 任务创建日期-开始 (Optional) */
CreateTimeAfter string `json:"createTimeAfter"`
/* 任务修改日期-结束 (Optional) */
UpdateTimeBefore string `json:"updateTimeBefore"`
/* 任务修改日期-开始 (Optional) */
UpdateTimeAfter string `json:"updateTimeAfter"`
/* 任务类型 (Optional) */
JobType string `json:"jobType"`
/* (Optional) */
MarkClassifyCode string `json:"markClassifyCode"`
/* (Optional) */
MarkName string `json:"markName"`
/* (Optional) */
JobChildType string `json:"jobChildType"`
/* 客户作业名 (Optional) */
CstJobName string `json:"cstJobName"`
}
type GpjmListJobResultDTO ¶
type GpjmListJobResultDTO struct {
/* 作业id (Optional) */
Id int `json:"id"`
/* 作业名称 (Optional) */
EtlJob string `json:"etlJob"`
/* 处理类型(calc:数据计算,extract:数据抽取,ods:ODS加工,load:数据推送,hdfs:数据同步,dqim:质量作业) (Optional) */
ProcessType string `json:"processType"`
/* 作业执行类型 (Optional) */
ExeType string `json:"exeType"`
/* 最后一次运行服务器 (Optional) */
EtlServer string `json:"etlServer"`
/* 作业描述 (Optional) */
Description string `json:"description"`
/* 周期具体日期 (Optional) */
Frequency string `json:"frequency"`
/* 最后一次运行开始时间 (Optional) */
LastStartTime string `json:"lastStartTime"`
/* 最后一次运行结束时间 (Optional) */
LastEndTime string `json:"lastEndTime"`
/* 运行时间 (Optional) */
RunTime string `json:"runTime"`
/* 最后一次运行状态 (Optional) */
LastJobStatus string `json:"lastJobStatus"`
/* 最后一次执行日期 (Optional) */
LastTxDate string `json:"lastTxDate"`
/* 最后返回编码 (Optional) */
LastReturnCode int `json:"lastReturnCode"`
/* 当前作业状态信息 (Optional) */
CurrentStatusMsg string `json:"currentStatusMsg"`
/* 是否启用,0未上线、1已上线、2已下线 (Optional) */
Enable string `json:"enable"`
/* Session ID (Optional) */
JobSessionID int `json:"jobSessionID"`
/* 失效时间 (Optional) */
ExpireTime string `json:"expireTime"`
/* 触发类型:dependency 依赖、time 时间、file 文件、manual 手工、once 一次性 (Optional) */
TriggerType string `json:"triggerType"`
/* 触发时间 (Optional) */
TriggerTime string `json:"triggerTime"`
/* 运行周期 ,F 分钟、H 小时、D 天、W 周、M 月、O 一次性运行、N 无周期 (Optional) */
Cycle string `json:"cycle"`
/* 周期具体日期 (Optional) */
Sequence string `json:"sequence"`
/* 作业优先级,数字越小优先级越高 (Optional) */
Priority int `json:"priority"`
/* 创建人 (Optional) */
CreateUser string `json:"createUser"`
/* 负责人,不超过10个 (Optional) */
UserName string `json:"userName"`
/* 重试次数 (Optional) */
RetryCount int `json:"retryCount"`
/* 周期开始时间(适用小时分钟) (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 周期结束时间(适用小时分钟) (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 周期间隔(适用小时分钟,当周期为小时,含义为间隔小时数,当周期为分钟,含义为间隔分钟数) (Optional) */
SequenceInterval int `json:"sequenceInterval"`
/* 是否重试过 (Optional) */
FlagRetry string `json:"flagRetry"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 更新时间 (Optional) */
UpdateTime string `json:"updateTime"`
/* 周期中文名 ,F 分钟、H 小时、D 天、W 周、M 月、O 一次性运行、N 无周期 (Optional) */
CycleLabel string `json:"cycleLabel"`
/* 触发方式中文名:dependency 依赖、time 时间、file 文件、manual 手工、once 一次性 (Optional) */
TriggerTypeLabel string `json:"triggerTypeLabel"`
/* 处理类型中文名(数据计算,数据抽取,ODS加工,数据推送,数据同步, 质量作业) (Optional) */
ProcessTypeCn string `json:"processTypeCn"`
/* 数据来源渠道,集成开发(IDE)、数据管道(PIPE) (Optional) */
Channel string `json:"channel"`
/* 任务类型 (Optional) */
JobType string `json:"jobType"`
/* 是否为作业管理员或者工作空间管理员 (Optional) */
ManagerFlag bool `json:"managerFlag"`
/* (Optional) */
JobChildType string `json:"jobChildType"`
/* 客户作业名 (Optional) */
CstJobName string `json:"cstJobName"`
}
type GpjmMgrJob ¶
type GpjmMgrJob struct {
/* 作业id (Optional) */
Id int `json:"id"`
/* 作业名称 (Optional) */
EtlJob string `json:"etlJob"`
/* 客户作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 租户编码 (Optional) */
CompanyCode string `json:"companyCode"`
/* 工作空间编码 (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 处理类型(calc:数据计算,extract:数据抽取,ods:ODS加工,load:数据推送,hdfs:数据同步,dqim:质量作业) (Optional) */
ProcessType string `json:"processType"`
/* 作业执行类型 (Optional) */
ExeType string `json:"exeType"`
/* 删除标识,1 删除,0 非删除 (Optional) */
DeleteFlag int `json:"deleteFlag"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 更新时间 (Optional) */
UpdateTime string `json:"updateTime"`
/* 作业名称关键词 (Optional) */
NameKeyWord string `json:"nameKeyWord"`
/* 关联类型:1:一对一 2:一对多 3:多对一 (Optional) */
RelationType string `json:"relationType"`
}
type GpjmMgrOperationRecords ¶
type GpjmMgrOperationRecords struct {
/* id (Optional) */
Id int `json:"id"`
/* 作业id (Optional) */
JobId int `json:"jobId"`
/* 操作类型 (Optional) */
OperateType string `json:"operateType"`
/* 操作人 (Optional) */
Operator string `json:"operator"`
/* 操作时间 (Optional) */
OperateTime string `json:"operateTime"`
/* 表id (Optional) */
TableId int `json:"tableId"`
/* 备注 (Optional) */
Memo string `json:"memo"`
}
type GpjmPageInfoJobRunInfoResultDTO ¶
type GpjmPageInfoJobRunInfoResultDTO struct {
/* (Optional) */
Total int64 `json:"total"`
/* (Optional) */
List []GpjmJobRunInfoResultDTO `json:"list"`
/* (Optional) */
PageNum int `json:"pageNum"`
/* (Optional) */
PageSize int `json:"pageSize"`
/* (Optional) */
Size int `json:"size"`
/* (Optional) */
StartRow int `json:"startRow"`
/* (Optional) */
EndRow int `json:"endRow"`
/* (Optional) */
Pages int `json:"pages"`
/* (Optional) */
PrePage int `json:"prePage"`
/* (Optional) */
NextPage int `json:"nextPage"`
/* (Optional) */
IsFirstPage bool `json:"isFirstPage"`
/* (Optional) */
IsLastPage bool `json:"isLastPage"`
/* (Optional) */
HasPreviousPage bool `json:"hasPreviousPage"`
/* (Optional) */
HasNextPage bool `json:"hasNextPage"`
NavigatePages int `json:"navigatePages"`
NavigatepageNums []int `json:"navigatepageNums"`
NavigateFirstPage int `json:"navigateFirstPage"`
NavigateLastPage int `json:"navigateLastPage"`
}
type GpjmPageInfoListJobInstanceResultDTO ¶
type GpjmPageInfoListJobInstanceResultDTO struct {
/* (Optional) */
Total int64 `json:"total"`
/* (Optional) */
List []GpjmListJobInstanceResultDTO `json:"list"`
/* (Optional) */
PageNum int `json:"pageNum"`
/* (Optional) */
PageSize int `json:"pageSize"`
/* (Optional) */
Size int `json:"size"`
/* (Optional) */
StartRow int `json:"startRow"`
/* (Optional) */
EndRow int `json:"endRow"`
/* (Optional) */
Pages int `json:"pages"`
/* (Optional) */
PrePage int `json:"prePage"`
/* (Optional) */
NextPage int `json:"nextPage"`
/* (Optional) */
IsFirstPage bool `json:"isFirstPage"`
/* (Optional) */
IsLastPage bool `json:"isLastPage"`
/* (Optional) */
HasPreviousPage bool `json:"hasPreviousPage"`
/* (Optional) */
HasNextPage bool `json:"hasNextPage"`
NavigatePages int `json:"navigatePages"`
NavigatepageNums []int `json:"navigatepageNums"`
NavigateFirstPage int `json:"navigateFirstPage"`
NavigateLastPage int `json:"navigateLastPage"`
}
type GpjmPageInfoListJobResultDTO ¶
type GpjmPageInfoListJobResultDTO struct {
/* (Optional) */
Total int64 `json:"total"`
/* (Optional) */
List []GpjmListJobResultDTO `json:"list"`
/* (Optional) */
PageNum int `json:"pageNum"`
/* (Optional) */
PageSize int `json:"pageSize"`
/* (Optional) */
Size int `json:"size"`
/* (Optional) */
StartRow int `json:"startRow"`
/* (Optional) */
EndRow int `json:"endRow"`
/* (Optional) */
Pages int `json:"pages"`
/* (Optional) */
PrePage int `json:"prePage"`
/* (Optional) */
NextPage int `json:"nextPage"`
/* (Optional) */
IsFirstPage bool `json:"isFirstPage"`
/* (Optional) */
IsLastPage bool `json:"isLastPage"`
/* (Optional) */
HasPreviousPage bool `json:"hasPreviousPage"`
/* (Optional) */
HasNextPage bool `json:"hasNextPage"`
NavigatePages int `json:"navigatePages"`
NavigatepageNums []int `json:"navigatepageNums"`
NavigateFirstPage int `json:"navigateFirstPage"`
NavigateLastPage int `json:"navigateLastPage"`
}
type GpjmPageInfoMgrOperationRecords ¶
type GpjmPageInfoMgrOperationRecords struct {
/* (Optional) */
Total int64 `json:"total"`
/* (Optional) */
List []GpjmMgrOperationRecords `json:"list"`
/* (Optional) */
PageNum int `json:"pageNum"`
/* (Optional) */
PageSize int `json:"pageSize"`
/* (Optional) */
Size int `json:"size"`
/* (Optional) */
StartRow int `json:"startRow"`
/* (Optional) */
EndRow int `json:"endRow"`
/* (Optional) */
Pages int `json:"pages"`
/* (Optional) */
PrePage int `json:"prePage"`
/* (Optional) */
NextPage int `json:"nextPage"`
/* (Optional) */
IsFirstPage bool `json:"isFirstPage"`
/* (Optional) */
IsLastPage bool `json:"isLastPage"`
/* (Optional) */
HasPreviousPage bool `json:"hasPreviousPage"`
/* (Optional) */
HasNextPage bool `json:"hasNextPage"`
NavigatePages int `json:"navigatePages"`
NavigatepageNums []int `json:"navigatepageNums"`
NavigateFirstPage int `json:"navigateFirstPage"`
NavigateLastPage int `json:"navigateLastPage"`
}
type GpjmRunRoleInfoDTO ¶
type GpjmRunRoleInfoDTO struct {
/* 作业超时时间,单位分钟 (Optional) */
RunTimeOut int `json:"runTimeOut"`
/* 触发类型:dependency 依赖、time 时间、file 文件、manual 手工、once 一次性 (Optional) */
TriggerType string `json:"triggerType"`
/* 触发时间 (Optional) */
TriggerTime string `json:"triggerTime"`
/* 是否重试过 (Optional) */
FlagRetry string `json:"flagRetry"`
/* 重试次数 (Optional) */
RetryCount string `json:"retryCount"`
/* 间隔/秒 (Optional) */
RetryInterval string `json:"retryInterval"`
/* 运行周期 ,F 分钟、H 小时、D 天、W 周、M 月、O 一次性运行、N 无周期 (Optional) */
Cycle string `json:"cycle"`
/* 周期具体日期 (Optional) */
Sequence string `json:"sequence"`
/* 周期间隔 (Optional) */
SequenceInterval string `json:"sequenceInterval"`
/* 周期开始时间 (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 周期结束时间 (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 作业优先级 (Optional) */
Priority int `json:"priority"`
/* 作业超时时间,单位分钟 (Optional) */
Timeout string `json:"timeout"`
/* 是否可以并行运行 (Optional) */
FlagParallel string `json:"flagParallel"`
/* 是否可以跨周期运行 (Optional) */
FlagAcross string `json:"flagAcross"`
/* 是否级联触发,父任务重跑后是否被强制触发重跑 (Optional) */
FlagCascadedTrigger string `json:"flagCascadedTrigger"`
/* 运行周期 (Optional) */
CycleLabel string `json:"cycleLabel"`
/* 触发类型 (Optional) */
TriggerTypeLabel string `json:"triggerTypeLabel"`
}
type GpjmobQueryReq ¶
type GpjsClusterInfoReq ¶
type GpjsClusterInfoReq struct {
/* 集群代码 (Optional) */
ClusterCode string `json:"clusterCode"`
}
type GpjsIsUpstreamSameFrequencyDTO ¶
type GpjsIsUpstreamSameFrequencyDTO struct {
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 依赖作业名称清单 (Optional) */
DependJobName []string `json:"dependJobName"`
/* 作业开始时间 (Optional) */
StartTime string `json:"startTime"`
/* 作业结束时间 (Optional) */
EndTime string `json:"endTime"`
/* 作业时间间隔 (Optional) */
Interval int `json:"interval"`
/* 作业运行周期 (Optional) */
Cycle string `json:"cycle"`
}
type GpjsJobDelInfoReq ¶
type GpjsJobDelInfoReq struct {
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 是否删除子作业 1删除 0不删 (Optional) */
IsDelSonJob string `json:"isDelSonJob"`
/* 是否删除质量作业 1删除 0不删 (Optional) */
IsDelQualityJob string `json:"isDelQualityJob"`
/* 用户角色列表 (Optional) */
User_roles string `json:"user_roles"`
/* 作业负责人 (Optional) */
Username string `json:"username"`
}
type GpjsJobEnableReq ¶
type GpjsJobExeResultReq ¶
type GpjsJobExeResultReq struct {
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 数据日期 (Optional) */
TxDate string `json:"txDate"`
/* 作业执行会话ID (Optional) */
SessionId int `json:"sessionId"`
/* 运行服务器名称 (Optional) */
ServerName string `json:"serverName"`
/* 作业运行开始时间 (Optional) */
StartTime string `json:"startTime"`
/* 作业运行结束时间 (Optional) */
EndTime string `json:"endTime"`
/* 作业执行状态 (Optional) */
JobStatus string `json:"jobStatus"`
/* 作业返回码 (Optional) */
ReturnCode int `json:"returnCode"`
/* 作业执行影响记录条数 (Optional) */
AffectRows int64 `json:"affectRows"`
/* 作业执行警告代码 (Optional) */
WarningCode int `json:"warningCode"`
/* 作业执行集群job app id (Optional) */
Pids []string `json:"pids"`
}
type GpjsResetJobInstReq ¶
type GpjsSchedJobRunVo ¶
type GpjsSchedJobRunVo struct {
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 数据日期 (Optional) */
TxDate string `json:"txDate"`
/* sessionId (Optional) */
SessionId int `json:"sessionId"`
/* 是否清理之前的实例 (Optional) */
IsCleanBeforeInst string `json:"isCleanBeforeInst"`
/* 调用系统 (Optional) */
System string `json:"system"`
/* 是否完成 (Optional) */
IsComplement string `json:"isComplement"`
// contains filtered or unexported fields
}
type GpjsSchedQueuePendingDto ¶
type GpjsSchedQueuePendingDto struct {
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 数据日期 (Optional) */
TxDate string `json:"txDate"`
/* sessionid (Optional) */
Sessionid int `json:"sessionid"`
/* 作业优先级 (Optional) */
Priority int `json:"priority"`
/* 超时时间 (Optional) */
Timeout int `json:"timeout"`
/* 进入队列的类型 (Optional) */
EqType string `json:"eqType"`
/* 命名空间,已经废弃 (Optional) */
NsName string `json:"nsName"`
/* 服务器资源消耗,已经废弃 (Optional) */
ServerResourVal int `json:"serverResourVal"`
/* 运行参数 (Optional) */
RunParams string `json:"runParams"`
/* 调度时间 (Optional) */
SchedTime string `json:"schedTime"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 更新时间 (Optional) */
UpdateTime string `json:"updateTime"`
}
type GpjsScriptExtensionDto ¶
type GpmdCalcJobResultDTO ¶
type GpmdCalcJobResultDTO struct {
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 表id (Optional) */
TableId int `json:"tableId"`
/* 数据库名称 (Optional) */
DatabaseName string `json:"databaseName"`
/* 集市编码 (Optional) */
MarketCode string `json:"marketCode"`
/* 集市名称 (Optional) */
MarketName string `json:"marketName"`
/* 模型表名 (Optional) */
TableName string `json:"tableName"`
/* 作业系统 (Optional) */
JobSystem string `json:"jobSystem"`
/* 任务类型(触发类型) (Optional) */
TriggerType string `json:"triggerType"`
/* (Optional) */
TriggerConfig GpmdTriggerConfigDTO `json:"triggerConfig"`
/* zip命令行 (Optional) */
ZipCommand string `json:"zipCommand"`
/* zip名称 (Optional) */
ZipFileName string `json:"zipFileName"`
/* zip参数 (Optional) */
ZipParams string `json:"zipParams"`
/* 依赖任务列表 (Optional) */
Dependencies string `json:"dependencies"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* 协作人 (Optional) */
Cooperator string `json:"cooperator"`
/* 优先级 (Optional) */
Priority int `json:"priority"`
/* 任务描述 (Optional) */
JobDesc string `json:"jobDesc"`
/* 脚本类型 (Optional) */
ScriptType string `json:"scriptType"`
/* 脚本模板 (Optional) */
ScriptTemplate string `json:"scriptTemplate"`
/* 运行频率(运行周期) (Optional) */
Cycle string `json:"cycle"`
/* 运行频率(运行周期内序列) (Optional) */
Sequence string `json:"sequence"`
/* 生命周期 (Optional) */
LifeCycle string `json:"lifeCycle"`
/* 失败后是否重试 (Optional) */
Retry bool `json:"retry"`
/* 定时、一次任务(开始运行时间) (Optional) */
RunTime string `json:"runTime"`
/* 定时、一次任务(开始运行时间) (Optional) */
RunDate string `json:"runDate"`
/* 超时时间 (Optional) */
RunTimeOut int `json:"runTimeOut"`
/* 脚本来源类型(本地或者git) (Optional) */
ScriptSourceType string `json:"scriptSourceType"`
/* 开始运行时间 (Optional) */
StartRunTime string `json:"startRunTime"`
/* 结束运行时间 (Optional) */
EndRunTime string `json:"endRunTime"`
/* 运行脚本 (Optional) */
RunScript string `json:"runScript"`
/* 通知事件 (Optional) */
NotifyOccasion string `json:"notifyOccasion"`
/* 通知时间 (Optional) */
NotifyTime string `json:"notifyTime"`
/* 通知模式 (Optional) */
NotifyPattern string `json:"notifyPattern"`
/* 通知者 (Optional) */
Notifier string `json:"notifier"`
/* 是否拥有模型 (Optional) */
HasModel bool `json:"hasModel"`
/* 脚本文件字节数组,是将脚本文件内容转换为byte数组 (Optional) */
ScriptByte []string `json:"scriptByte"`
/* 根据版本号,判断是重新发布还是新建,如果新建添加版本号,不是新建,更新历史表作业状态状态 (Optional) */
Version int `json:"version"`
/* 判断是否是运维中心调用编辑接口1,运维中心 (Optional) */
Core int `json:"core"`
/* 数据渠道来源:新模型(MODEL),老模型(OLD_MODEL)、集成开发(IDE)、数据管道(PIPE)、数据质量(DQ)、AI(KUAI) (Optional) */
Channel string `json:"channel"`
/* 周期开始时间 (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 周期结束时间 (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 时间间隔 (Optional) */
SequenceInterval int `json:"sequenceInterval"`
/* 启用状态 (Optional) */
Enable string `json:"enable"`
/* 脚本运行引擎 枚举值 "TEZ、MR、SPARK" (Optional) */
RunParams string `json:"runParams"`
/* 提交配置(仅HiveSQL在Spark引擎下支持指定) (Optional) */
SubmitConf []GpmdConfPairStringString `json:"submitConf"`
/* 审计日志信息 (Optional) */
UpdateInfo interface{} `json:"updateInfo"`
}
type GpmdJobQueryReq ¶
type GpmdOpenApiResponseCalcJobResultDTO ¶
type GpmdOpenApiResponseCalcJobResultDTO struct {
/* 成功标识,1成功,0失败 (Optional) */
Success int `json:"success"`
/* (Optional) */
Result GpmdCalcJobResultDTO `json:"result"`
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 返回状态信息 (Optional) */
Msg string `json:"msg"`
// contains filtered or unexported fields
}
type GpmdSchedJobDTO ¶
type GpmdSchedJobDTO struct {
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 老作业兼容字段 (Optional) */
JobSystem string `json:"jobSystem"`
/* 作业描述 (Optional) */
JobDesc string `json:"jobDesc"`
/* 最后一次运行状态,Pending、Ready、Running、Done、Failed、Clean (Optional) */
LastStatus string `json:"lastStatus"`
/* 最后依次执行日期 (Optional) */
LastTxDate string `json:"lastTxDate"`
/* 最后一次运行开始时间 (Optional) */
LastStartTime string `json:"lastStartTime"`
/* 最后一次运行结束时间 (Optional) */
LastEndTime string `json:"lastEndTime"`
/* 最后一次运行服务器 (Optional) */
LastServer string `json:"lastServer"`
/* Session ID (Optional) */
LastSessionid int `json:"lastSessionid"`
/* 最后返回编码 (Optional) */
LastReturnCode int `json:"lastReturnCode"`
/* 当前作业状态信息 (Optional) */
CurrentStatusMsg string `json:"currentStatusMsg"`
/* 触发类型:dependency 依赖、time 时间、file 文件、manual 手工、once 一次性 (Optional) */
TriggerType string `json:"triggerType"`
/* 运行周期 ,D 天、W 周、M 月、O 一次性运行、N 无周期 (Optional) */
Cycle string `json:"cycle"`
/* 周期具体日期 (Optional) */
Sequence string `json:"sequence"`
/* T+N,偏移量 (Optional) */
TxDateOffset int `json:"txDateOffset"`
/* 作业优先级,数字越小优先级越高 (Optional) */
Priority int `json:"priority"`
/* 作业超时时间,单位分钟 (Optional) */
Timeout int `json:"timeout"`
/* 窗口期开始时间 (Optional) */
WindowStartTime string `json:"windowStartTime"`
/* 窗口期结束时间 (Optional) */
WindowEndTime string `json:"windowEndTime"`
/* 失败后次日是否自动运行,1是、0否 (Optional) */
MorrowAutoExec string `json:"morrowAutoExec"`
/* 抽空之后的处理 0 无操作 1 作业失败 2发出警告 (Optional) */
DataZeroKillEnable int `json:"dataZeroKillEnable"`
/* 重试次数 (Optional) */
RetryCount int `json:"retryCount"`
/* 间隔/秒 (Optional) */
RetryInterval int `json:"retryInterval"`
/* 当期已经跑成功过,是否可以再跑,1启用、0关闭 (Optional) */
FlagAgain string `json:"flagAgain"`
/* 是否可以跨周期跑,1启用、0关闭 (Optional) */
FlagAcross string `json:"flagAcross"`
/* 是否可以自身并行,1启用、0关闭 (Optional) */
FlagParallel string `json:"flagParallel"`
/* 是否级联触发,父任务重跑后是否被强制触发重跑,1是、0否 (Optional) */
FlagCascadedTrigger string `json:"flagCascadedTrigger"`
/* 命名空间名称 (Optional) */
NsName string `json:"nsName"`
/* 服务器资源消耗值 (Optional) */
ServerResourVal int `json:"serverResourVal"`
/* 指定运行服务器 (Optional) */
RunServers string `json:"runServers"`
/* 需要的运行环境 (Optional) */
RequiredRunEnv string `json:"requiredRunEnv"`
/* 运行脚本 (Optional) */
RunScript string `json:"runScript"`
/* 是否启用,0未上线、1已上线、2已下线 (Optional) */
Enable string `json:"enable"`
/* 负责人,不超过10个 (Optional) */
Manager string `json:"manager"`
ShareUser string `json:"shareUser"`
/* 失效时间 (Optional) */
ExpireTime string `json:"expireTime"`
/* zip命令行 (Optional) */
Commands string `json:"commands"`
/* 创建人 (Optional) */
CreateUser string `json:"createUser"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 更新时间 (Optional) */
UpdateTime string `json:"updateTime"`
/* 实时结点名称 (Optional) */
NodeName string `json:"nodeName"`
/* 实时主题 (Optional) */
Topic string `json:"topic"`
/* 作业执行方式 0离线 1双写 2实时 (Optional) */
JobRunWay string `json:"jobRunWay"`
/* 作业运行参数 (Optional) */
RunParams string `json:"runParams"`
/* 所属系统 (Optional) */
BelongSys string `json:"belongSys"`
/* 周期开始时间 (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 周期结束时间 (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 周期间隔 (Optional) */
SequenceInterval int `json:"sequenceInterval"`
/* 开始时间 (Optional) */
StartTime string `json:"startTime"`
/* 计划执行时间 (Optional) */
PlanExecTime string `json:"planExecTime"`
/* 主从同步延迟处理方式。0:警告无处理,1:作业延迟启动 (Optional) */
MsDelayDealWay string `json:"msDelayDealWay"`
}
type GpmdTriggerConfigDTO ¶
type GpmdTriggerConfigDTO struct {
/* 条件类型 (Optional) */
ConditionType string `json:"conditionType"`
/* 次要类型 (Optional) */
SecondaryType string `json:"secondaryType"`
/* 服务器域名 (Optional) */
ServerDomain string `json:"serverDomain"`
/* 服务器端口 (Optional) */
ServerPort string `json:"serverPort"`
/* 用户名 (Optional) */
Username string `json:"username"`
/* 用户密码 (Optional) */
UsernamePwd string `json:"usernamePwd"`
/* 协议 (Optional) */
Protocol string `json:"protocol"`
/* 数据库名称 (Optional) */
DatabaseName string `json:"databaseName"`
/* 数据源 (Optional) */
DataSource string `json:"dataSource"`
/* 对象信息 (Optional) */
Object string `json:"object"`
/* 条件配置 (Optional) */
ConditionConfig string `json:"conditionConfig"`
/* 触发时间 (Optional) */
TriggerTime string `json:"triggerTime"`
/* 触发间隔 (Optional) */
TriggerInterval int `json:"triggerInterval"`
/* 开始时间 (Optional) */
BeginTime string `json:"beginTime"`
/* 结束时间 (Optional) */
EndTime string `json:"endTime"`
}
type GpmnJobCountDto ¶
type GpmnJobCountDto struct {
/* 实例总数 (Optional) */
JobTotal int `json:"jobTotal"`
/* 运行结束实例数量 (Optional) */
JobEnd int `json:"jobEnd"`
/* 等待中实例数量 (Optional) */
JobPending int `json:"jobPending"`
/* 运行成功实例数量 (Optional) */
JobSuccess int `json:"jobSuccess"`
/* 运行超时实例数量 (Optional) */
JobTimeout int `json:"jobTimeout"`
/* 运行不成功实例数量 (Optional) */
JobUnsuccess int `json:"jobUnsuccess"`
}
type GpmnJobSpendTimeRankingVo ¶
type GpmnJobSpendTimeRankingVo struct {
/* 排名 (Optional) */
Order int `json:"order"`
/* 作业名 (Optional) */
JobName string `json:"jobName"`
/* 作业类型描述 (Optional) */
JobType string `json:"jobType"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* 平均运行时长,形如hh:mm:ss (Optional) */
SpendTimeAvg string `json:"spendTimeAvg"`
/* 运行最大时长,形如 hh:mm:ss (Optional) */
SpendTimeLongest string `json:"spendTimeLongest"`
/* 客户作业名 (Optional) */
CstJobName string `json:"cstJobName"`
}
type GpmnJobUnsuccessRankingVo ¶
type GpmnJobUnsuccessRankingVo struct {
/* 排名 (Optional) */
Order int `json:"order"`
/* 作业名 (Optional) */
JobName string `json:"jobName"`
/* 作业类型描述 (Optional) */
JobType string `json:"jobType"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* 失败次数 (Optional) */
FailedTime int `json:"failedTime"`
/* 客户作业名 (Optional) */
CstJobName string `json:"cstJobName"`
}
type GpmnLineData ¶
type GpmnLineDataVo ¶
type GpmnLineDataVo struct {
/* 数据日期 (Optional) */
TxDate []int `json:"txDate"`
/* 成功作业统计列表 (Optional) */
JobSuccessList []GpmnLineData `json:"jobSuccessList"`
/* (Optional) */
Xdata []int `json:"xdata"`
}
type GpmnLineStringDataVo ¶
type GpmnLineStringDataVo struct {
/* 统计信息清单 (Optional) */
CountInfoList []GpmnLineData `json:"countInfoList"`
/* (Optional) */
Xdata []string `json:"xdata"`
}
type GpmnPieData ¶
type GpmnWorkTableJobStatusDto ¶
type GpmnWorkTableJobStatusDto struct {
/* 上线总数 (Optional) */
Total int `json:"total"`
/* (Optional) */
Ready int `json:"ready"`
/* (Optional) */
Clean int `json:"clean"`
/* (Optional) */
Done int `json:"done"`
/* (Optional) */
Timeout int `json:"timeout"`
/* (Optional) */
Pending int `json:"pending"`
/* (Optional) */
Running int `json:"running"`
/* (Optional) */
Failed int `json:"failed"`
}
type GpsdSchedDict ¶
type GpsdSchedDict struct {
/* 数据字典id (Optional) */
Id int64 `json:"id"`
/* 数据字典code (Optional) */
DictCode string `json:"dictCode"`
/* 数据字典父级code (Optional) */
PDictCode string `json:"pDictCode"`
/* 数据字典名称 (Optional) */
DictName string `json:"dictName"`
/* 数据字典排序 (Optional) */
DictSort int `json:"dictSort"`
/* 数据字典备份 (Optional) */
DictBak string `json:"dictBak"`
/* 数据字典描述 (Optional) */
DictDesc string `json:"dictDesc"`
/* 是否有效 1: 有效, 0: 无效 (Optional) */
IsValid string `json:"isValid"`
/* 是否删除 1: 删除, 0: 未删除 (Optional) */
IsDel string `json:"isDel"`
/* 创建时间 (Optional) */
CreatedTime string `json:"createdTime"`
/* 修改时间 (Optional) */
ModifiedTime string `json:"modifiedTime"`
}
type GpsdSchedDictRelationDto ¶
type GpsdSchedDictRelationDto struct {
/* 字典类型 (Optional) */
DictType string `json:"dictType"`
/* 字典值 (Optional) */
DictCode string `json:"dictCode"`
/* 字典描述 (Optional) */
DictName string `json:"dictName"`
/* 字典子节点信息 (Optional) */
ChildDictList []GpsdSchedDictRelationDto `json:"childDictList"`
}
type GpsdalueDict ¶
type GpsdalueDict struct {
/* 数据字典类型 (Optional) */
DictType string `json:"dictType"`
/* 数据字典描述 (Optional) */
DictDesc string `json:"dictDesc"`
/* 数据字典排序 (Optional) */
DictSort int `json:"dictSort"`
/* 数据字典值 (Optional) */
Value string `json:"value"`
/* (Optional) */
Valid bool `json:"valid"`
/* (Optional) */
Delete bool `json:"delete"`
}
type GpsmArrayObjectRequestResetJobInstReq ¶
type GpsmArrayObjectRequestResetJobInstReq struct {
/* (Optional) */
ArrayObjectParam []GpsmResetJobInstReq `json:"arrayObjectParam"`
}
type GpsmDownloadJobLogReq ¶
type GpsmJobAllqueryInfoDto ¶
type GpsmJobAllqueryInfoDto struct {
/* (Optional) */
SchedJob GpsmSchedJob `json:"schedJob"`
/* (Optional) */
MgrJob GpsmMgrJob `json:"mgrJob"`
}
type GpsmJobLogInfoPageQryReq ¶
type GpsmJobLogInfoPageQryReq struct {
/* 页面大小 */
PageSize int `json:"pageSize"`
/* 页码 */
PageNum int `json:"pageNum"`
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* job 运行session id (Optional) */
JobSessionId string `json:"jobSessionId"`
/* job运行日期 (Optional) */
TxDate string `json:"txDate"`
}
type GpsmJobNameDTO ¶
type GpsmJobQueryReq ¶
type GpsmJobStateBatchReq ¶
type GpsmKillJobInstReq ¶
type GpsmMgrJob ¶
type GpsmMgrJob struct {
/* 作业id (Optional) */
Id int `json:"id"`
/* 作业名称 (Optional) */
EtlJob string `json:"etlJob"`
/* 客户作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 租户编码 (Optional) */
CompanyCode string `json:"companyCode"`
/* 工作空间编码 (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 处理类型(calc:数据计算,extract:数据抽取,ods:ODS加工,load:数据推送,hdfs:数据同步,dqim:质量作业) (Optional) */
ProcessType string `json:"processType"`
/* 作业执行类型 (Optional) */
ExeType string `json:"exeType"`
/* 删除标识,1 删除,0 非删除 (Optional) */
DeleteFlag int `json:"deleteFlag"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 更新时间 (Optional) */
UpdateTime string `json:"updateTime"`
/* 作业名称关键词 (Optional) */
NameKeyWord string `json:"nameKeyWord"`
/* 关联类型:1:一对一 2:一对多 3:多对一 (Optional) */
RelationType string `json:"relationType"`
}
type GpsmOpenApiResponsePageInfoObject ¶
type GpsmOpenApiResponsePageInfoObject struct {
/* 成功标识,1成功,0失败 (Optional) */
Success int `json:"success"`
/* (Optional) */
Result GpsmPageInfoObject `json:"result"`
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 返回状态信息 (Optional) */
Msg string `json:"msg"`
// contains filtered or unexported fields
}
type GpsmPageInfoObject ¶
type GpsmPageInfoObject struct {
/* (Optional) */
Total int64 `json:"total"`
/* (Optional) */
List []interface{} `json:"list"`
/* (Optional) */
PageNum int `json:"pageNum"`
/* (Optional) */
PageSize int `json:"pageSize"`
/* (Optional) */
Size int `json:"size"`
/* (Optional) */
StartRow int `json:"startRow"`
/* (Optional) */
EndRow int `json:"endRow"`
/* (Optional) */
Pages int `json:"pages"`
/* (Optional) */
PrePage int `json:"prePage"`
/* (Optional) */
NextPage int `json:"nextPage"`
/* (Optional) */
IsFirstPage bool `json:"isFirstPage"`
/* (Optional) */
IsLastPage bool `json:"isLastPage"`
/* (Optional) */
HasPreviousPage bool `json:"hasPreviousPage"`
/* (Optional) */
HasNextPage bool `json:"hasNextPage"`
NavigatePages int `json:"navigatePages"`
NavigatepageNums []int `json:"navigatepageNums"`
NavigateFirstPage int `json:"navigateFirstPage"`
NavigateLastPage int `json:"navigateLastPage"`
}
type GpsmReRunJobBatchReq ¶
type GpsmReRunJobBatchReq struct {
/* 数据日期 (Optional) */
TxDate string `json:"txDate"`
/* 作业名称列表 (Optional) */
JobNames []GpsmJobNameDTO `json:"jobNames"`
}
type GpsmResetJobInstReq ¶
type GpsmSchedJob ¶
type GpsmSchedJob struct {
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 唯一id (Optional) */
Id int `json:"id"`
/* 客户作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 租户code (Optional) */
CompanyCode string `json:"companyCode"`
/* 工作空间code (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 计算资源组code (Optional) */
ResourceCode string `json:"resourceCode"`
/* 作业描述 (Optional) */
JobDesc string `json:"jobDesc"`
/* 最后一次运行状态,Pending、Ready、Running、Done、Failed、Clean (Optional) */
LastStatus string `json:"lastStatus"`
/* 最后一次执行日期 (Optional) */
LastTxDate string `json:"lastTxDate"`
/* 最后一次运行开始时间 (Optional) */
LastStartTime string `json:"lastStartTime"`
/* 最后一次运行结束时间 (Optional) */
LastEndTime string `json:"lastEndTime"`
/* 最后一次运行服务器 (Optional) */
LastServer string `json:"lastServer"`
/* Session ID (Optional) */
LastSessionid int `json:"lastSessionid"`
/* 最后返回编码 (Optional) */
LastReturnCode int `json:"lastReturnCode"`
/* 当前作业状态信息 (Optional) */
CurrentStatusMsg string `json:"currentStatusMsg"`
/* 触发类型:dependency 依赖、time 时间、file 文件、manual 手工、once 一次性 (Optional) */
TriggerType string `json:"triggerType"`
/* 运行周期 ,F 分钟、H 小时、D 天、W 周、M 月、O 一次性运行、N 无周期 (Optional) */
Cycle string `json:"cycle"`
/* 周期具体日期 (Optional) */
Sequence string `json:"sequence"`
/* T+N,偏移量 (Optional) */
TxDateOffset int `json:"txDateOffset"`
/* 作业优先级,数字越小优先级越高 (Optional) */
Priority int `json:"priority"`
/* 作业超时时间,单位分钟 (Optional) */
Timeout int `json:"timeout"`
/* 窗口期开始时间 (Optional) */
WindowStartTime string `json:"windowStartTime"`
/* 窗口期结束时间 (Optional) */
WindowEndTime string `json:"windowEndTime"`
/* 失败后次日是否自动运行,1是、0否 (Optional) */
MorrowAutoExec string `json:"morrowAutoExec"`
/* 抽空之后的处理 0 无操作 1 作业失败 2发出警告 (Optional) */
DataZeroKillEnable int `json:"dataZeroKillEnable"`
/* 重试次数 (Optional) */
RetryCount int `json:"retryCount"`
/* 间隔/秒 (Optional) */
RetryInterval int `json:"retryInterval"`
/* 当期已经跑成功过,是否可以再跑,1启用、0关闭 (Optional) */
FlagAgain string `json:"flagAgain"`
/* 是否可以跨周期跑,1启用、0关闭 (Optional) */
FlagAcross string `json:"flagAcross"`
/* 是否可以自身并行,1启用、0关闭 (Optional) */
FlagParallel string `json:"flagParallel"`
/* 是否级联触发,父任务重跑后是否被强制触发重跑,1是、0否 (Optional) */
FlagCascadedTrigger string `json:"flagCascadedTrigger"`
/* 需要的运行环境 (Optional) */
RequiredRunEnv string `json:"requiredRunEnv"`
/* 运行脚本 (Optional) */
RunScript string `json:"runScript"`
/* 是否启用,0未上线、1已上线、2已下线 (Optional) */
Enable string `json:"enable"`
/* 负责人,不超过10个 (Optional) */
Manager string `json:"manager"`
ShareUser string `json:"shareUser"`
/* 失效时间 (Optional) */
ExpireTime string `json:"expireTime"`
/* zip命令行 (Optional) */
Commands string `json:"commands"`
/* 创建人 (Optional) */
CreateUser string `json:"createUser"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 更新时间 (Optional) */
UpdateTime string `json:"updateTime"`
/* 实时结点名称 (Optional) */
NodeName string `json:"nodeName"`
/* 实时主题 (Optional) */
Topic string `json:"topic"`
/* 作业执行方式 0离线 1双写 2实时 (Optional) */
JobRunWay string `json:"jobRunWay"`
/* 所属系统 (Optional) */
BelongSys string `json:"belongSys"`
/* 主从同步延迟处理方式。0:警告无处理,1:作业延迟启动 (Optional) */
MsDelayDealWay string `json:"msDelayDealWay"`
/* 周期开始时间(适用小时分钟) (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 周期结束时间(适用小时分钟) (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 周期间隔(适用小时分钟,当周期为小时,含义为间隔小时数,当周期为分钟,含义为间隔分钟数) (Optional) */
SequenceInterval int `json:"sequenceInterval"`
/* 作业运行参数 (Optional) */
RunParams string `json:"runParams"`
}
type GpsmSchedJobWithLogDto ¶
type GpsmSchedJobWithLogDto struct {
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 客户作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 租户code (Optional) */
CompanyCode string `json:"companyCode"`
/* 工作空间code (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 计算资源组code (Optional) */
ResourceCode string `json:"resourceCode"`
/* 作业描述 (Optional) */
JobDesc string `json:"jobDesc"`
/* 最后一次运行状态,Pending、Ready、Running、Done、Failed、Clean (Optional) */
LastStatus string `json:"lastStatus"`
/* 最后一次执行日期 (Optional) */
LastTxDate string `json:"lastTxDate"`
/* 最后一次运行开始时间 (Optional) */
LastStartTime string `json:"lastStartTime"`
/* 最后一次运行结束时间 (Optional) */
LastEndTime string `json:"lastEndTime"`
/* 最后一次运行服务器 (Optional) */
LastServer string `json:"lastServer"`
/* Session ID (Optional) */
LastSessionid int `json:"lastSessionid"`
/* 最后返回编码 (Optional) */
LastReturnCode int `json:"lastReturnCode"`
/* 当前作业状态信息 (Optional) */
CurrentStatusMsg string `json:"currentStatusMsg"`
/* 触发类型:dependency 依赖、time 时间、file 文件、manual 手工、once 一次性 (Optional) */
TriggerType string `json:"triggerType"`
/* 运行周期 ,F 分钟、H 小时、D 天、W 周、M 月、O 一次性运行、N 无周期 (Optional) */
Cycle string `json:"cycle"`
/* 周期具体日期 (Optional) */
Sequence string `json:"sequence"`
/* T+N,偏移量 (Optional) */
TxDateOffset int `json:"txDateOffset"`
/* 作业优先级,数字越小优先级越高 (Optional) */
Priority int `json:"priority"`
/* 作业超时时间,单位分钟 (Optional) */
Timeout int `json:"timeout"`
/* 窗口期开始时间 (Optional) */
WindowStartTime string `json:"windowStartTime"`
/* 窗口期结束时间 (Optional) */
WindowEndTime string `json:"windowEndTime"`
/* 失败后次日是否自动运行,1是、0否 (Optional) */
MorrowAutoExec string `json:"morrowAutoExec"`
/* 抽空之后的处理 0 无操作 1 作业失败 2发出警告 (Optional) */
DataZeroKillEnable int `json:"dataZeroKillEnable"`
/* 重试次数 (Optional) */
RetryCount int `json:"retryCount"`
/* 间隔/秒 (Optional) */
RetryInterval int `json:"retryInterval"`
/* 当期已经跑成功过,是否可以再跑,1启用、0关闭 (Optional) */
FlagAgain string `json:"flagAgain"`
/* 是否可以跨周期跑,1启用、0关闭 (Optional) */
FlagAcross string `json:"flagAcross"`
/* 是否可以自身并行,1启用、0关闭 (Optional) */
FlagParallel string `json:"flagParallel"`
/* 是否级联触发,父任务重跑后是否被强制触发重跑,1是、0否 (Optional) */
FlagCascadedTrigger string `json:"flagCascadedTrigger"`
/* 需要的运行环境 (Optional) */
RequiredRunEnv string `json:"requiredRunEnv"`
/* 运行脚本 (Optional) */
RunScript string `json:"runScript"`
/* 是否启用,0未上线、1已上线、2已下线 (Optional) */
Enable string `json:"enable"`
/* 负责人,不超过10个 (Optional) */
Manager string `json:"manager"`
ShareUser string `json:"shareUser"`
/* 失效时间 (Optional) */
ExpireTime string `json:"expireTime"`
/* zip命令行 (Optional) */
Commands string `json:"commands"`
/* 创建人 (Optional) */
CreateUser string `json:"createUser"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 更新时间 (Optional) */
UpdateTime string `json:"updateTime"`
/* 实时结点名称 (Optional) */
NodeName string `json:"nodeName"`
/* 实时主题 (Optional) */
Topic string `json:"topic"`
/* 作业执行方式 0离线 1双写 2实时 (Optional) */
JobRunWay string `json:"jobRunWay"`
/* 所属系统 (Optional) */
BelongSys string `json:"belongSys"`
/* 主从同步延迟处理方式。0:警告无处理,1:作业延迟启动 (Optional) */
MsDelayDealWay string `json:"msDelayDealWay"`
/* 周期开始时间(适用小时分钟) (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 周期结束时间(适用小时分钟) (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 周期间隔(适用小时分钟,当周期为小时,含义为间隔小时数,当周期为分钟,含义为间隔分钟数) (Optional) */
SequenceInterval int `json:"sequenceInterval"`
/* 作业运行参数 (Optional) */
RunParams string `json:"runParams"`
}
type GpuserMatchUserReq ¶
type GpuserMatchUserReq struct {
/* 用户code (Optional) */
UserCode string `json:"userCode"`
}
type GpuserMatchUserResDto ¶
type GpuserMatchUserResDto struct {
/* 用户名称 (Optional) */
UserName string `json:"userName"`
/* 用户代码 (Optional) */
UserCode string `json:"userCode"`
/* 用户名称 (Optional) */
RealName string `json:"realName"`
/* 用户别名 (Optional) */
NikeName string `json:"nikeName"`
/* 组织名称 (Optional) */
OrganizationName string `json:"organizationName"`
}
type JcwSpaceDetailRequest ¶
type JcwSpaceDetailRequest struct {
/* 分页-页码 (Optional) */
PageNum int `json:"pageNum"`
/* 分页-每页数量 (Optional) */
PageSize int `json:"pageSize"`
/* 租户编码 (Optional) */
CompanyCode string `json:"companyCode"`
/* 租户主账号 (Optional) */
Account string `json:"account"`
/* 数据库名称 (Optional) */
DatabaseName string `json:"databaseName"`
/* 查询类型,租户、数据库、表 (Optional) */
ObjectType string `json:"objectType"`
/* 排序字段,租户/库/表存储空间总使用量、数据库数量、表数量、每日增量、创建时间 (Optional) */
OrderFieldType string `json:"orderFieldType"`
/* 排序方式,升序、降序 (Optional) */
OrderType string `json:"orderType"`
}
type JcwSpacePartUsedVo ¶
type JcwSpaceSummaryVo ¶
type JcwSpaceSummaryVo struct {
/* 集群每日存储空间增量 (Optional) */
IncrementalUsedByDay string `json:"incrementalUsedByDay"`
/* 总使用量 (Optional) */
TotalUsed string `json:"totalUsed"`
/* 总剩余空间 (Optional) */
TotalFree string `json:"totalFree"`
/* 使用率 (Optional) */
UsedPercent string `json:"usedPercent"`
/* 采集时间 (Optional) */
CollectTime string `json:"collectTime"`
}
type JcwSpaceUsedDetailVo ¶
type JcwSpaceUsedDetailVo struct {
/* 租户code (Optional) */
CompanyCode string `json:"companyCode"`
/* 租户主PIN (Optional) */
Account string `json:"account"`
/* 租户存储空间使用量(GB)浮点数 (Optional) */
CompanyUsed string `json:"companyUsed"`
/* 租户存储空间使用每日增量(GB)浮点数 (Optional) */
CompanyIncreUsed string `json:"companyIncreUsed"`
/* 数据库空间使用量(GB)浮点数 (Optional) */
DatabaseUsed string `json:"databaseUsed"`
/* 数据库名称 (Optional) */
DatabaseName string `json:"databaseName"`
/* 表空间使用量(GB)浮点数 (Optional) */
TableUsed string `json:"tableUsed"`
/* 表名称 (Optional) */
TableName string `json:"tableName"`
/* 租户下数据库数量 (Optional) */
DatabaseCount int `json:"databaseCount"`
/* 租户/数据库下表数量 (Optional) */
TableCount int `json:"tableCount"`
/* 分区表下分区数量 (Optional) */
PartitionCount int `json:"partitionCount"`
}
type JobBasicInfoVo ¶
type JobBasicInfoVo struct {
/* 作业id (Optional) */
JobId int `json:"jobId"`
/* 作业编码 (Optional) */
EtlJob string `json:"etlJob"`
/* 处理类型-展示 (Optional) */
ProcessType string `json:"processType"`
/* 创建时间: yyyy-MM-dd HH:mm:ss (Optional) */
CreateTime string `json:"createTime"`
/* 更新时间: yyyy-MM-dd HH:mm:ss (Optional) */
UpdateTime string `json:"updateTime"`
/* 执行类型 (Optional) */
ExeType string `json:"exeType"`
/* 工作空间代码 (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 作业类型 (Optional) */
JobType string `json:"jobType"`
/* 周期细节 (Optional) */
Frequency string `json:"frequency"`
/* 用户名 (Optional) */
UserName string `json:"userName"`
ShareUser string `json:"shareUser"`
/* 作业描述 (Optional) */
JobDesc string `json:"jobDesc"`
/* 过期时间 (Optional) */
ExpireTime string `json:"expireTime"`
/* 上线状态 (Optional) */
Enable string `json:"enable"`
/* 优先级 (Optional) */
Priority int `json:"priority"`
/* 优先级等级 (Optional) */
PriorityLevel string `json:"priorityLevel"`
/* 渠道 (Optional) */
Channel string `json:"channel"`
/* 处理类型代码 (Optional) */
ProcessTypeCode string `json:"processTypeCode"`
/* 操作人 (Optional) */
Operator string `json:"operator"`
/* 作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
}
type JobCommonInfoVo ¶
type JobCommonInfoVo struct {
/* 作业编码 (Optional) */
JobName string `json:"jobName"`
/* 作业描述 (Optional) */
JobDesc string `json:"jobDesc"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
ShareUser string `json:"shareUser"`
/* 最后运行数据日期 (Optional) */
LastTxDate string `json:"lastTxDate"`
/* 最后运行状态 (Optional) */
LastStatus string `json:"lastStatus"`
/* 当前状态信息 (Optional) */
CurrentStatusMsg string `json:"currentStatusMsg"`
/* 小时分钟-结束时间 (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 小时分钟-间隔 (Optional) */
SequenceInterval string `json:"sequenceInterval"`
/* 小时分钟-开始时间 (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 触发类型 (Optional) */
TriggerType string `json:"triggerType"`
/* 作业ID (Optional) */
JobId int `json:"jobId"`
/* 处理类型 (Optional) */
ProcessType string `json:"processType"`
/* 执行类型 (Optional) */
ExeType string `json:"exeType"`
/* 关联类型 (Optional) */
RelationType string `json:"relationType"`
/* 调度负责人标识 (Optional) */
SchedulerManagerFlag string `json:"schedulerManagerFlag"`
/* 负责人标识标志 (Optional) */
ManagerFlag bool `json:"managerFlag"`
/* 作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
}
type JobInfoVo ¶
type JobInfoVo struct {
/* 任务id (Optional) */
EtlId int `json:"etlId"`
/* 任务名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 任务编码 (Optional) */
EtlJob string `json:"etlJob"`
/* 处理类型 (Optional) */
ProcessType string `json:"processType"`
/* 任务执行类型 (Optional) */
ExeType string `json:"exeType"`
/* 任务描述 (Optional) */
Description string `json:"description"`
/* 周期具体日期 (Optional) */
Frequency string `json:"frequency"`
/* 最后一次运行开始时间 (Optional) */
LastStartTime string `json:"lastStartTime"`
/* 最后一次运行结束时间 (Optional) */
LastEndTime string `json:"lastEndTime"`
/* 运行时间 (Optional) */
RunTime string `json:"runTime"`
/* 最后一次运行状态 (Optional) */
LastJobStatus string `json:"lastJobStatus"`
/* 最后一次执行日期 (Optional) */
LastTxDate string `json:"lastTxDate"`
/* 最后返回编码 (Optional) */
LastReturnCode int `json:"lastReturnCode"`
/* 当前任务状态信息 (Optional) */
CurrentStatusMsg string `json:"currentStatusMsg"`
/* 是否上线,1-上线、2-下线 (Optional) */
Enable string `json:"enable"`
/* 触发类型:dependency 依赖、time 时间、file 文件、manual 手工、once 一次性 (Optional) */
TriggerType string `json:"triggerType"`
/* 触发时间 (Optional) */
TriggerTime string `json:"triggerTime"`
/* 运行周期 ,F 分钟、H 小时、D 天、W 周、M 月、O 一次性运行、N 无周期 (Optional) */
Cycle string `json:"cycle"`
/* 周期具体日期 (Optional) */
Sequence string `json:"sequence"`
/* 创建人 (Optional) */
CreateUser string `json:"createUser"`
/* 负责人 (Optional) */
UserName string `json:"userName"`
/* 重试次数 (Optional) */
RetryCount int `json:"retryCount"`
/* 周期开始时间(适用小时分钟) (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 周期结束时间(适用小时分钟) (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 周期间隔(适用小时分钟,当周期为小时,含义为间隔小时数,当周期为分钟,含义为间隔分钟数) (Optional) */
SequenceInterval int `json:"sequenceInterval"`
/* 是否重试过 (Optional) */
FlagRetry string `json:"flagRetry"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 更新时间 (Optional) */
UpdateTime string `json:"updateTime"`
/* 周期中文名 ,F 分钟、H 小时、D 天、W 周、M 月、O 一次性运行、N 无周期 (Optional) */
CycleLabel string `json:"cycleLabel"`
/* 触发方式中文名:dependency 依赖、time 时间、file 文件、manual 手工、once 一次性 (Optional) */
TriggerTypeLabel string `json:"triggerTypeLabel"`
/* 处理类型中文名(数据计算,数据抽取,ODS加工,数据推送,数据同步, 质量任务) (Optional) */
ProcessTypeCn string `json:"processTypeCn"`
/* 数据来源渠道,集成开发(IDE)、数据管道(PIPE) (Optional) */
Channel string `json:"channel"`
/* 任务类型 (Optional) */
JobType string `json:"jobType"`
/* 任务子类型 (Optional) */
JobChildType string `json:"jobChildType"`
/* 任务优先级,数字越小优先级越高 (Optional) */
Priority int `json:"priority"`
/* 任务优先级按照等级分,L1-L4,数字越小优先级越高 (Optional) */
PriorityLevel string `json:"priorityLevel"`
/* 租户编码 (Optional) */
CompanyCode string `json:"companyCode"`
/* 工作空间编码 (Optional) */
WorkspaceCode string `json:"workspaceCode"`
}
type JobKillParam ¶
type JobLogParam ¶
type JobLogParam struct {
/* 分页-页码 (Optional) */
PageNum int `json:"pageNum"`
/* 分页-每页数量 (Optional) */
PageSize int `json:"pageSize"`
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* session id (Optional) */
JobSessionId string `json:"jobSessionId"`
/* 数据日期 (Optional) */
TxDate string `json:"txDate"`
}
type JobMonitorInfoVo ¶
type JobMonitorInfoVo struct {
/* 告警类型 (Optional) */
WarningType string `json:"warningType"`
/* 告警通知人 (Optional) */
Notifiers string `json:"notifiers"`
/* 启动延迟告警-截止时间 (Optional) */
StartDeadlineTime string `json:"startDeadlineTime"`
/* 结束延迟告警-截止时间 (Optional) */
EndDeadlineTime string `json:"endDeadlineTime"`
/* 告警时机编码 (Optional) */
EventType string `json:"eventType"`
/* 告警时机-展示 (Optional) */
EventTypeDesc string `json:"eventTypeDesc"`
}
type JobOperateHistoryVo ¶
type JobOperateHistoryVo struct {
/* id (Optional) */
Id int `json:"id"`
/* 作业id (Optional) */
JobId int `json:"jobId"`
/* 操作类型 (Optional) */
OperateType string `json:"operateType"`
/* 操作人 (Optional) */
Operator string `json:"operator"`
/* 操作时间 (Optional) */
OperateTime string `json:"operateTime"`
/* 表id (Optional) */
TableId int `json:"tableId"`
/* 备注 (Optional) */
Memo string `json:"memo"`
}
type JobPropertyVo ¶
type JobPropertyVo struct {
/* 作业基础信息 (Optional) */
JobBasicInfo JobBasicInfoVo `json:"jobBasicInfo"`
/* 作业公共信息 (Optional) */
JobCommonInfo JobCommonInfoVo `json:"jobCommonInfo"`
/* 作业监控信息 (Optional) */
JobMonitorInfo JobMonitorInfoVo `json:"jobMonitorInfo"`
/* 作业运行配置信息 (Optional) */
RunRoleInfo JobRunInfoVo `json:"runRoleInfo"`
}
type JobRelationVo ¶
type JobRelationVo struct {
/* 作业名 (Optional) */
JobName string `json:"jobName"`
/* 客户作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 最后以此执行日期 (Optional) */
LastTxDate string `json:"lastTxDate"`
/* 最后一次运行开始时间 (Optional) */
LastStartTime string `json:"lastStartTime"`
/* 最后一次结束时间 (Optional) */
LastEndTime string `json:"lastEndTime"`
/* 最后一次运行状态,Pending、Ready、Running、Done、Failed、Clean (Optional) */
LastStatus string `json:"lastStatus"`
/* 是否可以自身并行,1启用、0关闭 (Optional) */
FlagParallel string `json:"flagParallel"`
/* 当前作业状态信息 (Optional) */
CurrentStatusMsg string `json:"currentStatusMsg"`
/* 周期开始时间(适用小时分钟) (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 周期结束时间(适用小时分钟) (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 周期间隔(适用小时分钟,当周期为小时,含义为间隔小时数,当周期为分钟,含义为间隔分钟数) (Optional) */
SequenceInterval string `json:"sequenceInterval"`
/* 是否启用,1启用、0关闭 (Optional) */
Enable string `json:"enable"`
/* 负责人,不超过10个 (Optional) */
Manager string `json:"manager"`
/* 作业所属系统,G gravity版本、A automation版本,用于迁移字段 (Optional) */
JobBelong string `json:"jobBelong"`
/* 是否强依赖,1启用、0关闭 (Optional) */
Necessary string `json:"necessary"`
/* 是否可以上下游并行,1启用、0关闭 (Optional) */
DepFlagParallel string `json:"depFlagParallel"`
/* 触发类型:dependency 依赖、time 时间、file 文件、manual 手工、once 一次性 (Optional) */
TriggerType string `json:"triggerType"`
/* 运行周期 ,F 分钟、H 小时、D 天、W 周、M 月、O 一次性运行、N 无周期 (Optional) */
Cycle string `json:"cycle"`
/* 周期具体日期 (Optional) */
Sequence string `json:"sequence"`
}
type JobRerunFailedReason ¶
type JobRerunParam ¶
type JobRerunResult ¶
type JobRerunResult struct {
/* 重跑成功的作业ID列表 (Optional) */
SuccessJobIdList []string `json:"successJobIdList"`
/* (Optional) */
FailedReasons []JobRerunFailedReason `json:"failedReasons"`
}
type JobResetDO ¶
type JobResetParam ¶
type JobResetParam struct {
/* 重置作业参数列表 (Optional) */
ArrayObjectParam []JobResetDO `json:"arrayObjectParam"`
}
type JobRunHistoryParam ¶
type JobRunHistoryVo ¶
type JobRunHistoryVo struct {
/* 作业名 (Optional) */
EtlJob string `json:"etlJob"`
/* 数据日期 (Optional) */
TxDate string `json:"txDate"`
/* 运行开始时间 (Optional) */
StartTime string `json:"startTime"`
/* 运行结束时间 (Optional) */
EndTime string `json:"endTime"`
/* 运行状态 (Optional) */
JobStatus string `json:"jobStatus"`
/* Session ID (Optional) */
JobSessionId string `json:"jobSessionId"`
/* 运行时间 (Optional) */
RunTime string `json:"runTime"`
/* 返回编码 (Optional) */
ReturnCode string `json:"returnCode"`
/* 返回信息 (Optional) */
ReturnMsg string `json:"returnMsg"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 是否补数任务 (Optional) */
IsComplement string `json:"isComplement"`
/* 计划执行时间 (Optional) */
PlanExecTime string `json:"planExecTime"`
/* 云仓调度作业id (Optional) */
ApplicationId string `json:"applicationId"`
}
type JobRunInfoVo ¶
type JobRunInfoVo struct {
/* 运行超时时间(秒) (Optional) */
RunTimeOut int `json:"runTimeOut"`
/* 触发类型 (Optional) */
TriggerType string `json:"triggerType"`
/* 触发时间 (Optional) */
TriggerTime string `json:"triggerTime"`
/* 是否重试-展示 (Optional) */
FlagRetry string `json:"flagRetry"`
/* 重试次数 (Optional) */
RetryCount string `json:"retryCount"`
/* 重试间隔 (Optional) */
RetryInterval string `json:"retryInterval"`
/* 周期 (Optional) */
Cycle string `json:"cycle"`
/* 周期序列 (Optional) */
Sequence string `json:"sequence"`
/* 小时分钟-结束时间 (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* 小时分钟-间隔 (Optional) */
SequenceInterval string `json:"sequenceInterval"`
/* 小时分钟-开始时间 (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* 优先级 (Optional) */
Priority int `json:"priority"`
/* 超时时间 (Optional) */
Timeout string `json:"timeout"`
/* 是否并行-展示 (Optional) */
FlagParallel string `json:"flagParallel"`
/* 是否跨周期-展示 (Optional) */
FlagAcross string `json:"flagAcross"`
/* 是否级联触发-展示 (Optional) */
FlagCascadedTrigger string `json:"flagCascadedTrigger"`
/* 周期-展示 (Optional) */
CycleLabel string `json:"cycleLabel"`
/* 触发类型-展示 (Optional) */
TriggerTypeLabel string `json:"triggerTypeLabel"`
}
type JobTxDateStatusVo ¶
type JobTxDateStatusVo struct {
/* 数据日期 (Optional) */
TxDate string `json:"txDate"`
/* 作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 作业编码 (Optional) */
JobName string `json:"jobName"`
/* 作业类型 (Optional) */
JobType string `json:"jobType"`
/* 作业类型-展示 (Optional) */
JobTypeLabel string `json:"jobTypeLabel"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* 状态 (Optional) */
Status string `json:"status"`
/* 状态-展示 (Optional) */
StatusLabel string `json:"statusLabel"`
/* 运行开始时间 (Optional) */
StartTime string `json:"startTime"`
/* 运行结束时间 (Optional) */
EndTime string `json:"endTime"`
/* 运行频率 (Optional) */
Cycle string `json:"cycle"`
/* 运行频率-展示 (Optional) */
CycleLabel string `json:"cycleLabel"`
/* 工作空间编码 (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 租户编码 (Optional) */
CompanyCode string `json:"companyCode"`
}
type JtlasDestroyRequestReq ¶
type JtlasDestroyRequestReq struct {
/* 租户编码 */
CompanyCode string `json:"companyCode"`
}
type JtlasDestroyResp ¶
type JtlasFuzzyQueryTablesByDatabaseNameResp ¶
type JtlasFuzzyQueryTablesByDatabaseNameResp struct {
/* 业务响应码 (Optional) */
Code string `json:"code"`
/* 响应消息 (Optional) */
Message string `json:"message"`
/* (Optional) */
Result []JtlasWarehouseTable `json:"result"`
}
type JtlasFuzzyQueryTablesByTableNameResp ¶
type JtlasFuzzyQueryTablesByTableNameResp struct {
/* 业务响应码 (Optional) */
Code string `json:"code"`
/* 响应消息 (Optional) */
Message string `json:"message"`
/* (Optional) */
Result []JtlasWarehouseTable `json:"result"`
}
type JtlasPageSearchTableReq ¶
type JtlasPageSearchTableReq struct {
/* 是否是过滤请求(必填),如果是则返回aggregate结果 */
FilterQuery bool `json:"filterQuery"`
/* 搜索模式(必填),准确和模糊检索 */
SearchMode string `json:"searchMode"`
/* (Optional) */
SearchKeyword string `json:"searchKeyword"`
/* 工作空间(必填) */
WorkspaceCode string `json:"workspaceCode"`
/* dev或prod空字符串代表所有环境 */
Env string `json:"env"`
/* 检索范围(必填) */
SearchRange string `json:"searchRange"`
/* 检索指定用户下的表的时候,需要传递(可选) (Optional) */
PersonInCharge string `json:"personInCharge"`
/* 返回结果的排列方式(必填),按照点击/创建时间升降/相关度 */
Sort string `json:"sort"`
/* 分页页码(必填) (Optional) */
PageNum int `json:"pageNum"`
/* 分页大小(必填) (Optional) */
PageSize int `json:"pageSize"`
}
type JtlasSearchAggregation ¶
type JtlasSearchDetailResp ¶
type JtlasSearchDetailResp struct {
/* 业务响应码 (Optional) */
Code string `json:"code"`
/* 响应消息 (Optional) */
Message string `json:"message"`
/* 节点数据 (Optional) */
Result JtlasSearchTable `json:"result"`
}
type JtlasSearchEdge ¶
type JtlasSearchNode ¶
type JtlasSearchTable ¶
type JtlasSearchTable struct {
/* 表id (Optional) */
Id string `json:"id"`
/* 项目id (Optional) */
ProjectCode string `json:"projectCode"`
/* 数据库名称 (Optional) */
Database string `json:"database"`
/* 表名称 (Optional) */
TableName string `json:"tableName"`
/* 表别名 (Optional) */
TableAlias string `json:"tableAlias"`
/* 表类型:MANAGED_TABLE,EXTERNAL_TABLE (Optional) */
TableType string `json:"tableType"`
/* 创建人 (Optional) */
Creator string `json:"creator"`
/* 元数据类型:HIVE,MYSQL (Optional) */
MetaType string `json:"metaType"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 最后修改时间 (Optional) */
LastModifyTime string `json:"lastModifyTime"`
/* 表存储路径 (Optional) */
Location string `json:"location"`
/* 输入格式 (Optional) */
InputFormat string `json:"inputFormat"`
/* 输出格式 (Optional) */
OutputFormat string `json:"outputFormat"`
/* 用户打标 (Optional) */
UserDefineTags []string `json:"userDefineTags"`
/* 负责人 (Optional) */
CollectPersons []string `json:"collectPersons"`
/* 是否收藏 (Optional) */
HasCollected bool `json:"hasCollected"`
/* 点击数 (Optional) */
ClickCount int `json:"clickCount"`
/* 最近一次分区 (Optional) */
LatestPartition JtlasSearchTablePartition `json:"latestPartition"`
/* (Optional) */
Columns []JtlasSearchTableColumn `json:"columns"`
/* (Optional) */
Privileges []JtlasSearchTablePrivilege `json:"privileges"`
/* (Optional) */
Params []JtlasSearchTableParam `json:"params"`
/* 分桶字段名称 (Optional) */
BucketCols []string `json:"bucketCols"`
/* 分桶个数 (Optional) */
BucketNum string `json:"bucketNum"`
}
type JtlasSearchTableColumn ¶
type JtlasSearchTableColumn struct {
/* 字段id (Optional) */
Id string `json:"id"`
/* 字段名称 (Optional) */
Name string `json:"name"`
/* 字段描述 (Optional) */
Comment string `json:"comment"`
/* 字段类型 (Optional) */
Type string `json:"type"`
/* 是否是分区字段 (Optional) */
IsPartition bool `json:"isPartition"`
/* 字段长度 (Optional) */
Length int `json:"length"`
/* 字段位置 (Optional) */
Position int `json:"position"`
}
type JtlasSearchTableDoc ¶
type JtlasSearchTableDoc struct {
/* 表id (Optional) */
Id string `json:"id"`
/* 项目id (Optional) */
ProjectCode string `json:"projectCode"`
/* 数据库名称 (Optional) */
Database string `json:"database"`
/* 表名称 (Optional) */
TableName string `json:"tableName"`
/* 表别名 (Optional) */
TableAlias string `json:"tableAlias"`
/* 表类型:MANAGED_TABLE,EXTERNAL_TABLE (Optional) */
TableType string `json:"tableType"`
/* 创建人 (Optional) */
Creator string `json:"creator"`
/* 元数据类型:HIVE,MYSQL (Optional) */
MetaType string `json:"metaType"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 最后修改时间 (Optional) */
LastModifyTime string `json:"lastModifyTime"`
/* 表存储路径 (Optional) */
Location string `json:"location"`
/* 输入格式 (Optional) */
InputFormat string `json:"inputFormat"`
/* 输出格式 (Optional) */
OutputFormat string `json:"outputFormat"`
/* 用户打标 (Optional) */
UserDefineTags []string `json:"userDefineTags"`
/* 负责人 (Optional) */
CollectPersons []string `json:"collectPersons"`
/* 是否收藏 (Optional) */
HasCollected bool `json:"hasCollected"`
/* 点击数 (Optional) */
ClickCount int `json:"clickCount"`
/* 是否热门文章 (Optional) */
FireFlag bool `json:"fireFlag"`
/* 环境信息dev或prod (Optional) */
Env string `json:"env"`
/* 分桶字段名称 (Optional) */
BucketCols []string `json:"bucketCols"`
/* 分桶个数 (Optional) */
BucketNum string `json:"bucketNum"`
}
type JtlasSearchTableParam ¶
type JtlasSearchTablePartition ¶
type JtlasSearchTablePartition struct {
/* 分区名称 (Optional) */
PartName string `json:"partName"`
/* 分区存储路径 (Optional) */
Location string `json:"location"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 分区大小 (Optional) */
TotalSize int64 `json:"totalSize"`
/* 分区行数 (Optional) */
NumRow int64 `json:"numRow"`
/* 原始数据大小 (Optional) */
RawDataSize int64 `json:"rawDataSize"`
}
type JtlasSubscribeTableReq ¶
type JtlasSubscribeTableResp ¶
type JtlasTableDetailReq ¶
type JtlasTableDetailResp ¶
type JtlasTableDetailResp struct {
/* 业务响应码 (Optional) */
Code string `json:"code"`
/* 响应消息 (Optional) */
Message string `json:"message"`
/* 数据或者是分页 (Optional) */
Result JtlasWarehouseTable `json:"result"`
}
type JtlasTableFuuzyUnderSpecifiedUserWithPrivilegesReq ¶
type JtlasTableFuuzyUnderSpecifiedUserWithPrivilegesReq struct {
/* 数据库(工作空间编码) */
Database string `json:"database"`
/* 账户信息 */
PrincipalName string `json:"principalName"`
/* 模糊表名称 (Optional) */
FuzzyTableName string `json:"fuzzyTableName"`
/* 权限信息 */
PrivilegeTypes []string `json:"privilegeTypes"`
}
type JtlasTableFuuzyUnderSpecifiedUserWithPrivilegesResp ¶
type JtlasTableFuuzyUnderSpecifiedUserWithPrivilegesResp struct {
/* 业务响应码 (Optional) */
Code string `json:"code"`
/* 响应消息 (Optional) */
Message string `json:"message"`
/* (Optional) */
Result []JtlasWarehouseTable `json:"result"`
}
type JtlasTableOwnedByUserResp ¶
type JtlasTableOwnedByUserResp struct {
/* 业务响应码 (Optional) */
Code string `json:"code"`
/* 响应消息 (Optional) */
Message string `json:"message"`
/* (Optional) */
Result []JtlasWarehouseTable `json:"result"`
}
type JtlasTablePrivilegesReq ¶
type JtlasTablePrivilegesResp ¶
type JtlasTablePrivilegesResp struct {
/* 业务响应码 (Optional) */
Code string `json:"code"`
/* 响应消息 (Optional) */
Message string `json:"message"`
/* (Optional) */
Result []JtlasWarehouseTablePrivilege `json:"result"`
}
type JtlasTableUnderSpecifiedUserResp ¶
type JtlasTableUnderSpecifiedUserResp struct {
/* 业务响应码 (Optional) */
Code string `json:"code"`
/* 响应消息 (Optional) */
Message string `json:"message"`
/* (Optional) */
Result []JtlasWarehouseTable `json:"result"`
}
type JtlasTableUnderSpecifiedUserWithPrivilegesResp ¶
type JtlasTableUnderSpecifiedUserWithPrivilegesResp struct {
/* 业务响应码 (Optional) */
Code string `json:"code"`
/* 响应消息 (Optional) */
Message string `json:"message"`
/* (Optional) */
Result []JtlasWarehouseTable `json:"result"`
}
type JtlasWarehouseTable ¶
type JtlasWarehouseTable struct {
/* 表id (Optional) */
Id string `json:"id"`
/* 项目id (Optional) */
ProjectCode string `json:"projectCode"`
/* 数据库名称 (Optional) */
Database string `json:"database"`
/* 表名称 (Optional) */
TableName string `json:"tableName"`
/* 表别名 (Optional) */
TableAlias string `json:"tableAlias"`
/* 表类型:MANAGED_TABLE,EXTERNAL_TABLE (Optional) */
TableType string `json:"tableType"`
/* 创建人 (Optional) */
Creator string `json:"creator"`
/* 元数据类型:HIVE,MYSQL (Optional) */
MetaType string `json:"metaType"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 最后修改时间 (Optional) */
LastModifyTime string `json:"lastModifyTime"`
/* 表存储路径 (Optional) */
Location string `json:"location"`
/* 输入格式 (Optional) */
InputFormat string `json:"inputFormat"`
/* 输出格式 (Optional) */
OutputFormat string `json:"outputFormat"`
/* 用户打标 (Optional) */
UserDefineTags []string `json:"userDefineTags"`
/* 负责人 (Optional) */
CollectPersons []string `json:"collectPersons"`
/* 点击数 (Optional) */
ClickCount int `json:"clickCount"`
/* 最近一次分区 (Optional) */
LatestPartition JtlasWarehouseTablePartition `json:"latestPartition"`
/* (Optional) */
Columns []JtlasWarehouseTableColumn `json:"columns"`
/* (Optional) */
Privileges []JtlasWarehouseTablePrivilege `json:"privileges"`
/* 表信息额外参数 (Optional) */
Params []JtlasWarehouseTableParam `json:"params"`
/* 分桶字段 (Optional) */
BucketCols []string `json:"bucketCols"`
/* 分桶个数 (Optional) */
BucketNum int `json:"bucketNum"`
}
type JtlasWarehouseTableColumn ¶
type JtlasWarehouseTableColumn struct {
/* 字段名称 (Optional) */
Name string `json:"name"`
/* 字段描述 (Optional) */
Comment string `json:"comment"`
/* 字段类型 (Optional) */
Type string `json:"type"`
/* 是否是分区字段 (Optional) */
IsPartition bool `json:"isPartition"`
/* 字段长度 (Optional) */
Length int `json:"length"`
/* 字段位置 (Optional) */
Position int `json:"position"`
}
type JtlasWarehouseTablePartition ¶
type JtlasWarehouseTablePartition struct {
/* 分区名称 (Optional) */
PartName string `json:"partName"`
/* 分区存储路径 (Optional) */
Location string `json:"location"`
/* 创建时间 (Optional) */
CreateTime string `json:"createTime"`
/* 分区大小 (Optional) */
TotalSize int64 `json:"totalSize"`
/* 分区行数 (Optional) */
NumRow int64 `json:"numRow"`
/* 原始数据大小 (Optional) */
RawDataSize int64 `json:"rawDataSize"`
}
type ListJobParam ¶
type ListJobParam struct {
/* 分页-页码 (Optional) */
PageNum int `json:"pageNum"`
/* 分页-每页数量 (Optional) */
PageSize int `json:"pageSize"`
/* 任务名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 任务编码 (Optional) */
JobName string `json:"jobName"`
/* 租户编码 (Optional) */
CompanyCode string `json:"companyCode"`
/* 负责人pin (Optional) */
ManagerPin string `json:"managerPin"`
/* 工作空间编码 (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 任务创建-开始日期: yyyy-MM-dd (Optional) */
CreateTimeAfter string `json:"createTimeAfter"`
/* 任务创建-结束日期: yyyy-MM-dd (Optional) */
CreateTimeBefore string `json:"createTimeBefore"`
/* 任务更新-开始日期: yyyy-MM-dd (Optional) */
UpdateTimeAfter string `json:"updateTimeAfter"`
/* 任务更新-结束日期: yyyy-MM-dd (Optional) */
UpdateTimeBefore string `json:"updateTimeBefore"`
/* 任务运行-开始时间: yyyy-MM-dd HH:mm (Optional) */
JobStartRunTime string `json:"jobStartRunTime"`
/* 任务运行-结束时间: yyyy-MM-dd HH:mm (Optional) */
JobEndRunTime string `json:"jobEndRunTime"`
/* 任务上下线状态: 1-上线 2-下线 (Optional) */
Enable int `json:"enable"`
/* 任务周期 (Optional) */
Cycle string `json:"cycle"`
/* 任务父类型 (Optional) */
JobType string `json:"jobType"`
/* 任务子类型 (Optional) */
JobChildType string `json:"jobChildType"`
/* 任务最后状态: not,Done,Pending,Running,Failed,Timeout,Clean,Ready (Optional) */
LastJobStatus []string `json:"lastJobStatus"`
/* 任务最后数据日期 (Optional) */
LastTxdate string `json:"lastTxdate"`
/* 任务负责人 (Optional) */
Manager string `json:"manager"`
/* 过滤模式: exact-精确过滤,否则为模糊过滤 (Optional) */
QueryMode string `json:"queryMode"`
}
type ListJobRelationParam ¶
type ListPublishObjByPageParam ¶
type ListPublishObjByPageParam struct {
/* 页面容量 (Optional) */
PageSize int `json:"pageSize"`
/* 页号 (Optional) */
PageNum int `json:"pageNum"`
/* 对象ID (Optional) */
ObjUk string `json:"objUk"`
/* 对象名称 (Optional) */
ObjName string `json:"objName"`
/* 对象类型编码 (Optional) */
ObjTypeCode string `json:"objTypeCode"`
/* 变更类型编码 (Optional) */
ObjChangeTypeCode string `json:"objChangeTypeCode"`
/* 提交人 (Optional) */
SubmitterPin string `json:"submitterPin"`
/* 提交开始时间 (Optional) */
SubmitTimeStart int64 `json:"submitTimeStart"`
/* 提交结束时间 (Optional) */
SubmitTimeEnd int64 `json:"submitTimeEnd"`
}
type ListPublishPkgByPageParam ¶
type ListPublishPkgByPageParam struct {
/* 页面容量 (Optional) */
PageSize int `json:"pageSize"`
/* 页号 (Optional) */
PageNum int `json:"pageNum"`
/* 发布包名称 (Optional) */
PkgName string `json:"pkgName"`
/* 发布包ID (Optional) */
PkgId int64 `json:"pkgId"`
/* 发布人 (Optional) */
Publisher string `json:"publisher"`
/* 发布包状态 (Optional) */
PkgStatus string `json:"pkgStatus"`
/* 发布时间开始 (Optional) */
PkgPublishTimeStart int64 `json:"pkgPublishTimeStart"`
/* 发布时间结束 (Optional) */
PkgPublishTimeEnd int64 `json:"pkgPublishTimeEnd"`
/* 打包人 (Optional) */
PkgCreator string `json:"pkgCreator"`
/* 打包时间开始 (Optional) */
PkgCreateTimeStart int64 `json:"pkgCreateTimeStart"`
/* 打包时间结束 (Optional) */
PkgCreateTimeEnd int64 `json:"pkgCreateTimeEnd"`
}
type ListTxDateStatusParam ¶
type ListTxDateStatusParam struct {
/* 页码 (Optional) */
PageNum *int `json:"pageNum"`
/* 页大小 (Optional) */
PageSize *int `json:"pageSize"`
/* 任务编码 (Optional) */
CompanyCode *string `json:"companyCode"`
/* 负责人pin (Optional) */
ManagerPin *string `json:"managerPin"`
/* 工作空间编码 (Optional) */
WorkspaceCode *string `json:"workspaceCode"`
/* 任务名称 (Optional) */
CstJobName *string `json:"cstJobName"`
/* 数据日期 (Optional) */
TxDate *string `json:"txDate"`
/* 任务运行开始-开始时间: yyyy-MM-dd HH:mm (Optional) */
JobStartAfterTime *string `json:"jobStartAfterTime"`
/* 任务运行开始-结束时间: yyyy-MM-dd HH:mm (Optional) */
JobStartBeforeTime *string `json:"jobStartBeforeTime"`
/* 任务运行结束-开始时间: yyyy-MM-dd HH:mm (Optional) */
JobEndAfterTime *string `json:"jobEndAfterTime"`
/* 任务运行结束-结束时间: yyyy-MM-dd HH:mm (Optional) */
JobEndBeforeTime *string `json:"jobEndBeforeTime"`
/* 任务类型 (Optional) */
JobType *string `json:"jobType"`
/* 运行频率 (Optional) */
Cycle *string `json:"cycle"`
/* 运行状态 (Optional) */
Status *string `json:"status"`
}
type LoopParam ¶
type LoopParam struct {
/* 元素名称 (Optional) */
ElementName *string `json:"elementName"`
/* 元素取值列表 (Optional) */
ElementValues *string `json:"elementValues"`
/* 元素取值列表分隔符 (Optional) */
Delimiter *TaskLoopElementDelimiterVo `json:"delimiter"`
}
type OneClickRerunParam ¶
type OneClickRerunParam struct {
/* (Optional) */
FilterParam ListTxDateStatusParam `json:"filterParam"`
/* 备注 (Optional) */
Remark string `json:"remark"`
}
type OneClickRerunPreviewVo ¶
type OrderUniqueKey ¶
type OwnerIntegrationResource ¶
type OwnerIntegrationResource struct {
/* (Optional) */
Region *string `json:"region"`
/* (Optional) */
ResourceType *string `json:"resourceType"`
/* (Optional) */
Az *string `json:"az"`
/* (Optional) */
ResourceName *string `json:"resourceName"`
/* (Optional) */
ResourceDescription *string `json:"resourceDescription"`
/* (Optional) */
PurchaseDuration *int `json:"purchaseDuration"`
/* (Optional) */
AutoRenewal *bool `json:"autoRenewal"`
/* (Optional) */
ResourceSpec *string `json:"resourceSpec"`
/* (Optional) */
PurchaseMode *string `json:"purchaseMode"`
/* (Optional) */
PayResourceNum *int `json:"payResourceNum"`
}
type PackagePublishObjParam ¶
type PageInfoResourceResp ¶
type PageInfoResourceResp struct {
/* 总数量 (Optional) */
Total int `json:"total"`
/* 分页页数 (Optional) */
PageNum int `json:"pageNum"`
/* 页面容量 (Optional) */
PageSize int `json:"pageSize"`
/* 工作空间的资源组列表 (Optional) */
List []ResourceResp `json:"list"`
}
type PageInfoUcUsersResp ¶
type PageInfoUcUsersResp struct {
/* 总数量 (Optional) */
Total int `json:"total"`
/* 分页页数 (Optional) */
PageNum int `json:"pageNum"`
/* 页面容量 (Optional) */
PageSize int `json:"pageSize"`
/* 项目成员列表 (Optional) */
List []UcUsersResp `json:"list"`
}
type PageInfoWorkspaceListResp ¶
type PageInfoWorkspaceListResp struct {
/* 总数量 (Optional) */
Total int `json:"total"`
/* 分页页数 (Optional) */
PageNum int `json:"pageNum"`
/* 页面容量 (Optional) */
PageSize int `json:"pageSize"`
/* 工作空间的资源组列表 (Optional) */
List []WorkspaceListResp `json:"list"`
}
type PageInfoWorkspaceUserResp ¶
type PageInfoWorkspaceUserResp struct {
/* 总数量 (Optional) */
Total int `json:"total"`
/* 分页页数 (Optional) */
PageNum int `json:"pageNum"`
/* 页面容量 (Optional) */
PageSize int `json:"pageSize"`
/* 项目成员列表 (Optional) */
List []WorkspaceUserResp `json:"list"`
}
type PageVoJcwSpacePartUsedVo ¶
type PageVoJcwSpacePartUsedVo struct {
/* 总数量 (Optional) */
Total int `json:"total"`
/* 页号 (Optional) */
PageNum int `json:"pageNum"`
/* 页面容量 (Optional) */
PageSize int `json:"pageSize"`
/* 数据列表 (Optional) */
List []JcwSpacePartUsedVo `json:"list"`
}
type PageVoJobInfoVo ¶
type PageVoJobOperateHistoryVo ¶
type PageVoJobOperateHistoryVo struct {
/* 总条数 (Optional) */
Total int64 `json:"total"`
/* 每页条数 (Optional) */
PageSize int `json:"pageSize"`
/* 当前页 (Optional) */
PageNum int `json:"pageNum"`
/* 数据列表 (Optional) */
List []JobOperateHistoryVo `json:"list"`
}
type PageVoJobRelationVo ¶
type PageVoJobRelationVo struct {
/* 总条数 (Optional) */
Total int64 `json:"total"`
/* 每页条数 (Optional) */
PageSize int `json:"pageSize"`
/* 当前页 (Optional) */
PageNum int `json:"pageNum"`
/* 数据列表 (Optional) */
List []JobRelationVo `json:"list"`
}
type PageVoJobRunHistoryVo ¶
type PageVoJobRunHistoryVo struct {
/* 总条数 (Optional) */
Total int64 `json:"total"`
/* 每页条数 (Optional) */
PageSize int `json:"pageSize"`
/* 当前页 (Optional) */
PageNum int `json:"pageNum"`
/* 数据列表 (Optional) */
List []JobRunHistoryVo `json:"list"`
}
type PageVoJobTxDateStatusVo ¶
type PageVoJobTxDateStatusVo struct {
/* 总条数 (Optional) */
Total int64 `json:"total"`
/* 每页条数 (Optional) */
PageSize int `json:"pageSize"`
/* 当前页 (Optional) */
PageNum int `json:"pageNum"`
/* 数据列表 (Optional) */
List []JobTxDateStatusVo `json:"list"`
}
type PageVoRerunBatchVo ¶
type PageVoRerunBatchVo struct {
/* 总条数 (Optional) */
Total int64 `json:"total"`
/* 每页条数 (Optional) */
PageSize int `json:"pageSize"`
/* 当前页 (Optional) */
PageNum int `json:"pageNum"`
/* 数据列表 (Optional) */
List []RerunBatchVo `json:"list"`
}
type PageVoRerunTaskVo ¶
type PageVoRerunTaskVo struct {
/* 总条数 (Optional) */
Total int64 `json:"total"`
/* 每页条数 (Optional) */
PageSize int `json:"pageSize"`
/* 当前页 (Optional) */
PageNum int `json:"pageNum"`
/* 数据列表 (Optional) */
List []RerunTaskVo `json:"list"`
}
type PageVoStorageSpaceUsedDetailVo ¶
type PageVoStorageSpaceUsedDetailVo struct {
/* 总数量 (Optional) */
Total int `json:"total"`
/* 页号 (Optional) */
PageNum int `json:"pageNum"`
/* 页面容量 (Optional) */
PageSize int `json:"pageSize"`
/* 数据列表 (Optional) */
List []JcwSpaceUsedDetailVo `json:"list"`
}
type PageVoString ¶
type PartitionInfo ¶
type PreviewPackageParam ¶
type PreviewPackageVo ¶
type ProjectResp ¶
type ProjectResp struct {
/* (Optional) */
ProjectCode string `json:"projectCode"`
/* (Optional) */
ProjectName string `json:"projectName"`
/* (Optional) */
ProjectStatus string `json:"projectStatus"`
/* (Optional) */
Msg string `json:"msg"`
/* 绑定时间 (Optional) */
BundleTime string `json:"bundleTime"`
/* 环境类型 (Optional) */
Env string `json:"env"`
}
type PublishObjDetailVo ¶
type PublishObjDetailVo struct {
/* ID (Optional) */
ObjId int64 `json:"objId"`
/* 发布对象类型 (Optional) */
ObjType string `json:"objType"`
/* 对象名称 (Optional) */
ObjName string `json:"objName"`
/* 对象ID (Optional) */
ObjUk string `json:"objUk"`
/* 提交人 (Optional) */
Submitter string `json:"submitter"`
/* 版本号 (Optional) */
VersionPretty string `json:"versionPretty"`
/* 提交时间 (Optional) */
SubmitTimestamp int64 `json:"submitTimestamp"`
/* 脚本内容,[数据开发]和[数据表]类型有该值 (Optional) */
ScriptContent string `json:"scriptContent"`
/* 配置内容,[数据开发]和[数据集成]类型有该值 (Optional) */
ConfigContent string `json:"configContent"`
}
type PublishObjPageVo ¶
type PublishObjPageVo struct {
/* 总数量 (Optional) */
Total int `json:"total"`
/* 页号 (Optional) */
PageNum int `json:"pageNum"`
/* 页面容量 (Optional) */
PageSize int `json:"pageSize"`
/* 发布对象列表 (Optional) */
List []PublishObjVo `json:"list"`
}
type PublishObjVo ¶
type PublishObjVo struct {
/* ID (Optional) */
ObjId int64 `json:"objId"`
/* 对象名称 (Optional) */
ObjName string `json:"objName"`
/* 对象ID (Optional) */
ObjUk string `json:"objUk"`
/* 对象发布失败信息 (Optional) */
ObjMsg string `json:"objMsg"`
/* 版本号 (Optional) */
VersionPretty string `json:"versionPretty"`
/* 提交人 (Optional) */
Submitter string `json:"submitter"`
/* 提交人Pin (Optional) */
SubmitterPin string `json:"submitterPin"`
/* 对象类型 (Optional) */
ObjTypeDesc string `json:"objTypeDesc"`
/* 变更类型 (Optional) */
ChangeTypeDesc string `json:"changeTypeDesc"`
/* 提交时间 (Optional) */
SubmitTimestamp int64 `json:"submitTimestamp"`
}
type PublishPkgDetailVo ¶
type PublishPkgDetailVo struct {
/* 发布对象列表 (Optional) */
PublishObjVoList []PublishObjVo `json:"publishObjVoList"`
}
type PublishPkgPageVo ¶
type PublishPkgPageVo struct {
/* 总数量 (Optional) */
Total int `json:"total"`
/* 页号 (Optional) */
PageNum int `json:"pageNum"`
/* 页面容量 (Optional) */
PageSize int `json:"pageSize"`
/* 发布对象列表 (Optional) */
List []PublishPkgVo `json:"list"`
}
type PublishPkgParam ¶
type PublishPkgVo ¶
type PublishPkgVo struct {
/* ID (Optional) */
PkgId int64 `json:"pkgId"`
/* 发布包名称 (Optional) */
PkgName string `json:"pkgName"`
/* 发布包状态 (Optional) */
PkgStatusDesc string `json:"pkgStatusDesc"`
/* 打包人 (Optional) */
PkgCreator string `json:"pkgCreator"`
/* 打包人Pin (Optional) */
PkgCreatorPin string `json:"pkgCreatorPin"`
/* 发布人 (Optional) */
PkgPublisher string `json:"pkgPublisher"`
/* 发布人Pin (Optional) */
PkgPublisherPin string `json:"pkgPublisherPin"`
/* 打包时间 (Optional) */
PkgCreateTimestamp int64 `json:"pkgCreateTimestamp"`
/* 发布时间 (Optional) */
PkgPublishTimestamp int64 `json:"pkgPublishTimestamp"`
}
type QueryPublishObjDetailParam ¶
type QueryPublishObjDetailParam struct {
/* ID (Optional) */
ObjId int64 `json:"objId"`
}
type QueryPublishPkgDetailParam ¶
type QueryPublishPkgDetailParam struct {
/* ID (Optional) */
PkgId int64 `json:"pkgId"`
}
type QueryWorkspaceInfoReq ¶
type QueryWorkspaceListReq ¶
type QueryWorkspaceListReq struct {
/* (Optional) */
PageNum int `json:"pageNum"`
/* (Optional) */
PageSize int `json:"pageSize"`
/* (Optional) */
WorkspaceName string `json:"workspaceName"`
/* (Optional) */
WorkspaceId string `json:"workspaceId"`
/* (Optional) */
Manager string `json:"manager"`
/* (Optional) */
ImProjectManager bool `json:"imProjectManager"`
/* (Optional) */
ImInProject bool `json:"imInProject"`
}
type RejectPublishPkgParam ¶
type RerunBatchParam ¶
type RerunBatchParam struct {
/* 页号 (Optional) */
PageNum int `json:"pageNum"`
/* 页大小 (Optional) */
PageSize int `json:"pageSize"`
/* 操作人 (Optional) */
Operator string `json:"operator"`
/* 操作时间-开始 (Optional) */
OperateTimeAfter int64 `json:"operateTimeAfter"`
/* 操作时间-结束 (Optional) */
OperateTimeBefore int64 `json:"operateTimeBefore"`
}
type RerunBatchVo ¶
type RerunBatchVo struct {
/* 批次id (Optional) */
Id int `json:"id"`
/* 重跑原因 (Optional) */
Remark string `json:"remark"`
/* 操作人员 (Optional) */
Operator string `json:"operator"`
/* 状态 (Optional) */
Status string `json:"status"`
/* 状态-展示 (Optional) */
StatusLabel string `json:"statusLabel"`
/* 提交成功数量 (Optional) */
SubmitSuccessCount int `json:"submitSuccessCount"`
/* 提交失败数量 (Optional) */
SubmitFailCount int `json:"submitFailCount"`
/* 提交待处理数量 (Optional) */
SubmitPendingCount int `json:"submitPendingCount"`
/* 提交中数量 (Optional) */
SubmitSubmittingCount int `json:"submitSubmittingCount"`
/* 提交总数 (Optional) */
SubmitTotalCount int `json:"submitTotalCount"`
/* 操作时间 (Optional) */
CreateTime int64 `json:"createTime"`
}
type RerunTaskParam ¶
type RerunTaskReSubmitParam ¶
type RerunTaskReSubmitParam struct {
/* 任务id (Optional) */
TaskId int `json:"taskId"`
}
type RerunTaskVo ¶
type RerunTaskVo struct {
/* 任务id (Optional) */
Id int `json:"id"`
/* 作业编码 (Optional) */
JobName string `json:"jobName"`
/* 作业名称 (Optional) */
CstJobName string `json:"cstJobName"`
/* 数据日期 (Optional) */
TxDate string `json:"txDate"`
/* 作业类型 (Optional) */
JobType string `json:"jobType"`
/* 作业类型-展示 (Optional) */
JobTypeLabel string `json:"jobTypeLabel"`
/* 提交状态 (Optional) */
Status string `json:"status"`
/* 提交状态-展示 (Optional) */
StatusLabel string `json:"statusLabel"`
/* 原因 (Optional) */
Detail string `json:"detail"`
/* 提交时间 (Optional) */
SubmitTime int64 `json:"submitTime"`
/* 运行频率 (Optional) */
Cycle string `json:"cycle"`
/* 运行频率-展示 (Optional) */
CycleLabel string `json:"cycleLabel"`
/* 工作空间编码 (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 租户编码 (Optional) */
CompanyCode string `json:"companyCode"`
}
type ResourceBriefInfoVo ¶
type ResourceBriefInfoVo struct {
/* 资源code (Optional) */
ResourceCode *string `json:"resourceCode"`
/* 资源名称 (Optional) */
ResourceName *string `json:"resourceName"`
/* 资源类型 (Optional) */
ResourceType *string `json:"resourceType"`
/* 资源文件相对路径 (Optional) */
RelativePath *string `json:"relativePath"`
/* 资源文件挂载路径 (Optional) */
MountPath *string `json:"mountPath"`
}
type ResourceCloseReq ¶
type ResourceCreateReq ¶
type ResourceCreateReq struct {
/* 资源名称(支持中文、字母、数字、下划线,不超过50个字符) (Optional) */
ResourceName string `json:"resourceName"`
/* 原始资源名称(上传的原始文件在本地客户端的文件名称) (Optional) */
OriginalName string `json:"originalName"`
/* 父资源code(目录的根目录的父资源code为ROOT) (Optional) */
ParentCode string `json:"parentCode"`
/* 资源类型(DIRECTORY:目录;JAR:java的jar文件;FILE:其他普通文件;ARCHIVE:其他压缩文件/归档文件) (Optional) */
ResourceType string `json:"resourceType"`
/* 关联引擎(默认为JCW) (Optional) */
RelativeEngine string `json:"relativeEngine"`
/* 文件上传方式(默认为本地上传) (Optional) */
UploadMode string `json:"uploadMode"`
/* 环境信息(prod:生产环境;dev:开发环境),简单模式默认为prod (Optional) */
Env string `json:"env"`
/* 负责人 (Optional) */
Managers []string `json:"managers"`
}
type ResourceDeleteReq ¶
type ResourceDeleteReq struct {
/* 资源code (Optional) */
ResourceCode string `json:"resourceCode"`
}
type ResourceInfo ¶
type ResourceResp ¶
type ResourceResp struct {
/* (Optional) */
ResourceType string `json:"resourceType"`
/* (Optional) */
ResourceName string `json:"resourceName"`
/* (Optional) */
ResourceCode string `json:"resourceCode"`
/* (Optional) */
ResourceStatus string `json:"resourceStatus"`
/* (Optional) */
ResourceFlag string `json:"resourceFlag"`
/* (Optional) */
Az string `json:"az"`
/* (Optional) */
PrivateId string `json:"privateId"`
/* (Optional) */
Ipv4Cidr string `json:"ipv4Cidr"`
/* (Optional) */
SubnetId string `json:"subnetId"`
/* (Optional) */
SubnetCidr string `json:"subnetCidr"`
/* (Optional) */
NatSubnetId string `json:"natSubnetId"`
/* (Optional) */
SecurityGroup string `json:"securityGroup"`
/* (Optional) */
PayMethod string `json:"payMethod"`
/* (Optional) */
Id int64 `json:"id"`
/* (Optional) */
EffectiveStartTime string `json:"effectiveStartTime"`
}
type ResourceUpdateReq ¶
type ResourceUpdateReq struct {
/* 资源code (Optional) */
ResourceCode string `json:"resourceCode"`
/* 原始资源名称(上传的原始文件在本地客户端的文件名称) (Optional) */
OriginalName string `json:"originalName"`
/* 文件上传方式(默认为本地上传) (Optional) */
UploadMode string `json:"uploadMode"`
/* 负责人 (Optional) */
Managers []string `json:"managers"`
/* 资源状态 (Optional) */
Status string `json:"status"`
/* 环境信息(prod:生产环境;dev:开发环境),简单模式默认为prod (Optional) */
Env string `json:"env"`
}
type RosterVo ¶
type RosterVo struct {
/* 值班日期,取值1-7,对应星期一至星期日 (Optional) */
Day int `json:"day"`
/* 值班日期展示,取值星期一至星期日 (Optional) */
DayLabel string `json:"dayLabel"`
/* 主值班人列表 (Optional) */
PrimaryWatchmanIdList []WatchmanVo `json:"primaryWatchmanIdList"`
/* 备值班人列表 (Optional) */
BackupWatchmanIdList []WatchmanVo `json:"backupWatchmanIdList"`
}
type SparkJarRunParams ¶
type SparkJarRunParams struct {
/* 主函数路径 (Optional) */
MainClassPath *string `json:"mainClassPath"`
/* 主函数名称 (Optional) */
MainClassName *string `json:"mainClassName"`
/* spark版本 (Optional) */
SparkVersion *string `json:"sparkVersion"`
/* 依赖jar包路径 (Optional) */
DependJarPathList []string `json:"dependJarPathList"`
/* spark提交参数 (Optional) */
SparkSubmitConf []GpdjmcConfPairStringString `json:"sparkSubmitConf"`
}
type StopExpireOrDeleteReq ¶
type StopExpireOrDeleteReq struct {
/* (Optional) */
CompanyCode string `json:"companyCode"`
/* 主账户pin (Optional) */
Account string `json:"account"`
/* 类型:过期停服 或 过期删除 (Optional) */
HandleStatus string `json:"handleStatus"`
/* 地区 (Optional) */
Region string `json:"region"`
/* (Optional) */
SourceId string `json:"sourceId"`
/* (Optional) */
ResourceId string `json:"resourceId"`
}
type SyncWsProductOrderReq ¶
type SyncWsProductOrderReq struct {
/* (Optional) */
Region string `json:"region"`
/* (Optional) */
BillingVersion string `json:"billingVersion"`
/* (Optional) */
BillingModel string `json:"billingModel"`
/* (Optional) */
Az string `json:"az"`
/* (Optional) */
Account string `json:"account"`
/* (Optional) */
CompanyId string `json:"companyId"`
/* (Optional) */
PayPlan string `json:"payPlan"`
/* (Optional) */
AutoRenewal bool `json:"autoRenewal"`
/* (Optional) */
PurchaseDuration int `json:"purchaseDuration"`
/* (Optional) */
OrderUniqueKey OrderUniqueKey `json:"orderUniqueKey"`
}
type TableBriefInfo ¶
type TableBriefInfo struct {
/* 表名 */
TableName string `json:"tableName"`
/* 表操作类型 CREATE:新建 ALTER:修改 GRANT_PRIV:赋权 (Optional) */
OperationType string `json:"operationType"`
/* 发布阶段 UNPUBLISH:未发布、PUBLISHING:待发布、PUBLISHED:已发布 (Optional) */
PublishStage string `json:"publishStage"`
/* 环境信息 dev:开发 prod:生产 (Optional) */
Env string `json:"env"`
/* 表负责人 (Optional) */
Owner string `json:"owner"`
/* 表协作人,多个以逗号分隔 (Optional) */
Managers string `json:"managers"`
}
type TableDelimiterVo ¶
type TableDelimitersVo ¶
type TableDelimitersVo struct {
/* 字段分隔符 (Optional) */
FieldDelimiters []TableDelimiterVo `json:"fieldDelimiters"`
/* 行分隔符 (Optional) */
LineDelimiters []TableDelimiterVo `json:"lineDelimiters"`
}
type TaskDependPageListReq ¶
type TaskInfoLoopReq ¶
type TaskInfoLoopReq struct {
/* 循环节点类型 ITERATION:迭代, LIST:列表 (Optional) */
LoopType *string `json:"loopType"`
/* 循环参数列表,只对应LIST类型 (Optional) */
LoopParamList []LoopParam `json:"loopParamList"`
/* 迭代次数,只对应ITERATION类型 (Optional) */
LoopTimes *int `json:"loopTimes"`
/* 每次循环批次 (Optional) */
LoopBatchSize *int `json:"loopBatchSize"`
/* 每批次执行的时间间隔,单位秒 (Optional) */
LoopBatchInterval *int `json:"loopBatchInterval"`
}
type TaskInfoSparkJarReq ¶
type TaskInfoSparkJarReq struct {
/* 支持跑SparkJar的spark版本 (Optional) */
SparkVersion *string `json:"sparkVersion"`
/* sparkJar的开发语言 (Optional) */
Language *string `json:"language"`
/* spark程序主类所在的jar包文件 (Optional) */
MainJar *ResourceBriefInfoVo `json:"mainJar"`
/* spark程序主类 (Optional) */
MainClass *string `json:"mainClass"`
/* 依赖其他jar包(除主程序jar) (Optional) */
DependentResources []ResourceBriefInfoVo `json:"dependentResources"`
/* sparkJar运行的其他参数(Map<String,String>) (Optional) */
Params *interface{} `json:"params"`
}
type UcUsersResp ¶
type UcUsersResp struct {
/* (Optional) */
UserName string `json:"userName"`
/* (Optional) */
NickName string `json:"nickName"`
/* (Optional) */
UserPin string `json:"userPin"`
/* (Optional) */
Account string `json:"account"`
/* (Optional) */
Email string `json:"email"`
/* (Optional) */
IsAccount bool `json:"isAccount"`
}
type UnbundleProjectReq ¶
type UpdateFunctionReq ¶
type UpdateFunctionReq struct {
/* 租户code (Optional) */
CompanyCode string `json:"companyCode"`
/* 命名空间code (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 函数id (Optional) */
FunctionId int `json:"functionId"`
/* 函数主类全路径 (Optional) */
ClassName string `json:"className"`
/* 负责人 (Optional) */
Managers []string `json:"managers"`
/* 分类目录id (Optional) */
FunctionCatalogId int `json:"functionCatalogId"`
/* 依赖的资源code(包括资源文件/资源目录) (Optional) */
ResourceCodes []string `json:"resourceCodes"`
/* 函数格式 (Optional) */
FunctionFormat string `json:"functionFormat"`
/* 函数使用说明 (Optional) */
FunctionUsage string `json:"functionUsage"`
}
type UpdateRosterParam ¶
type UpdateRosterParam struct {
/* 全部值班表信息 (Optional) */
RosterList []RosterDO `json:"rosterList"`
}
type UpdateUserRoleReq ¶
type UpdateUserRoleReq struct {
/* (Optional) */
WorkspaceId int64 `json:"workspaceId"`
/* (Optional) */
UpdateRoleReq []UserRoleInfo `json:"updateRoleReq"`
}
type UpdateWatchmanParam ¶
type UpdateWatchmanParam struct {
/* 值班人id (Optional) */
Id int64 `json:"id"`
/* 值班人名称 (Optional) */
Name string `json:"name"`
/* 值班人Pin (Optional) */
Pin string `json:"pin"`
/* 值班人Erp (Optional) */
Erp string `json:"erp"`
/* 值班人手机号 (Optional) */
PhoneNumber string `json:"phoneNumber"`
/* 值班人邮箱地址 (Optional) */
Email string `json:"email"`
}
type UploaderInitRes ¶
type UploaderInitRes struct {
/* bucket名称 (Optional) */
Bucket string `json:"bucket"`
/* 文件Code (Optional) */
FileCode string `json:"fileCode"`
/* 文件名称 (Optional) */
FileName string `json:"fileName"`
/* 任务流Code (Optional) */
FlowCode string `json:"flowCode"`
/* 文件夹上传的时候文件的路径 (Optional) */
Prefix string `json:"prefix"`
/* 区域 (Optional) */
Region string `json:"region"`
}
type UranusAnalysisScriptReq ¶
type UranusAnalysisScriptRes ¶
type UranusAnalysisScriptRes struct {
/* 输出表名称 (Optional) */
TableName string `json:"tableName"`
/* 依赖任务名称 (Optional) */
DependJobName string `json:"dependJobName"`
/* 依赖任务Code (Optional) */
DependTaskCode string `json:"dependTaskCode"`
/* 表描述 (Optional) */
TableDesc string `json:"tableDesc"`
/* 作业运行规则 (Optional) */
Cycle string `json:"cycle"`
/* 资产id (Optional) */
AssetsId int `json:"assetsId"`
/* 表中文名 (Optional) */
TableCnName string `json:"tableCnName"`
/* 表英文名 (Optional) */
TableEnName string `json:"tableEnName"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* 负责人 (Optional) */
ManagerName string `json:"managerName"`
/* 创建人 (Optional) */
Creator string `json:"creator"`
}
type UranusCatalogInfo ¶
type UranusCatalogInfoCode ¶
type UranusCatalogInfoCode struct {
/* 前端排序唯一ID (Optional) */
UnrealId string `json:"unrealId"`
/* 目录code */
CatalogCode string `json:"catalogCode"`
/* 目录名称 (Optional) */
CatalogName string `json:"catalogName"`
/* 0:非叶子目录, 1:叶子目录 (Optional) */
CatalogType int `json:"catalogType"`
/* 父目录code (Optional) */
ParentCode string `json:"parentCode"`
/* 子节点数量 (Optional) */
ChildrenNum int `json:"childrenNum"`
}
type UranusCatalogInfoList ¶
type UranusCatalogInfoList struct {
/* 前端排序唯一ID (Optional) */
UnrealId string `json:"unrealId"`
/* 目录code */
CatalogCode string `json:"catalogCode"`
/* 目录名称 (Optional) */
CatalogName string `json:"catalogName"`
/* 0:非叶子目录, 1:叶子目录 (Optional) */
CatalogType int `json:"catalogType"`
/* 父目录code (Optional) */
ParentCode string `json:"parentCode"`
/* 子节点数量 (Optional) */
ChildrenNum int `json:"childrenNum"`
/* 流程列表 (Optional) */
TaskFlowList []UranusTaskFlowListRes `json:"taskFlowList"`
}
type UranusColumnReq ¶
type UranusColumnSaveOrUpdate ¶
type UranusColumnSaveOrUpdate struct {
/* 序号 (Optional) */
FieldSort *int `json:"fieldSort"`
/* 字段英文名称 (Optional) */
FieldEnName *string `json:"fieldEnName"`
/* 字段中文名称 (Optional) */
FieldCnName *string `json:"fieldCnName"`
/* 字段类型 (Optional) */
FieldType *string `json:"fieldType"`
/* 字段长度 当字段类型为 bigdecimal 类型时配合字段精度一起使用 (Optional) */
FieldLen *int `json:"fieldLen"`
/* 字段精度 (Optional) */
FiledAccuracy *int `json:"filedAccuracy"`
/* 是否是分区字段(y/n) (Optional) */
IsPartition *string `json:"isPartition"`
}
type UranusDdlAnalyzeReq ¶
type UranusDdlAnalyzeReq struct {
/* sql 文本 */
SqlContent string `json:"sqlContent"`
}
type UranusDictRes ¶
type UranusDictRes struct {
/* id (Optional) */
Id int `json:"id"`
/* 字典编码 (Optional) */
DictCode string `json:"dictCode"`
/* 父编码 (Optional) */
PDictCode string `json:"pDictCode"`
/* 字典名称 (Optional) */
DictName string `json:"dictName"`
/* 备份信息 (Optional) */
Bak string `json:"bak"`
/* 序号 (Optional) */
DictSort int `json:"dictSort"`
/* 描述 (Optional) */
DictDesc string `json:"dictDesc"`
}
type UranusDictVO ¶
type UranusDictVO struct {
/* 类型id (Optional) */
Id int64 `json:"id"`
/* 字典编码 (Optional) */
DictCode string `json:"dictCode"`
/* 父编码 (Optional) */
PDictCode string `json:"pDictCode"`
/* 字典名称 (Optional) */
DictName string `json:"dictName"`
/* 备份信息 (Optional) */
Bak string `json:"bak"`
/* 序号 (Optional) */
Sort int64 `json:"sort"`
/* 描述 (Optional) */
DictDesc string `json:"dictDesc"`
}
type UranusFileManagerRes ¶
type UranusFileManagerRes struct {
/* 文件code (Optional) */
Code string `json:"code"`
/* 工作流code (Optional) */
FlowCode string `json:"flowCode"`
/* 相对路径 (Optional) */
RelativePath string `json:"relativePath"`
/* 实际路径 (Optional) */
RealPath string `json:"realPath"`
/* 名称 (Optional) */
Name string `json:"name"`
/* 是否是文件 (Optional) */
Dir bool `json:"dir"`
/* 节点标识 (Optional) */
NodeIcon string `json:"nodeIcon"`
/* 父目录code (Optional) */
ParentCode string `json:"parentCode"`
/* 子文件信息 (Optional) */
Children []UranusFileManagerRes `json:"children"`
}
type UranusFunctionManagerRes ¶
type UranusFunctionManagerRes struct {
/* 类型id (Optional) */
Id int64 `json:"id"`
/* 类型名称 (Optional) */
TypeName string `json:"typeName"`
/* 是否是目录 (Optional) */
Dir bool `json:"dir"`
/* 环境信息(prod:生产;dev:开发) (Optional) */
Env string `json:"env"`
/* 子集 (Optional) */
Children []interface{} `json:"children"`
/* (Optional) */
Pid int64 `json:"pid"`
}
type UranusPageResultContentSchedTaskInfoHistoryRes ¶
type UranusPageResultContentSchedTaskInfoHistoryRes struct {
/* (Optional) */
TotalPage int `json:"totalPage"`
/* (Optional) */
TotalRecords int `json:"totalRecords"`
/* (Optional) */
List []UranusSchedTaskInfoHistoryRes `json:"list"`
}
type UranusPageResultContentScriptRunLogRes ¶
type UranusPageResultContentScriptRunLogRes struct {
/* (Optional) */
TotalPage int `json:"totalPage"`
/* (Optional) */
TotalRecords int `json:"totalRecords"`
/* (Optional) */
List []UranusScriptRunLogRes `json:"list"`
}
type UranusPageResultContentTaskNodePageRes ¶
type UranusPageResultContentTaskNodePageRes struct {
/* (Optional) */
TotalPage int `json:"totalPage"`
/* (Optional) */
TotalRecords int `json:"totalRecords"`
/* (Optional) */
List []UranusTaskNodePageRes `json:"list"`
}
type UranusParamReq ¶
type UranusResourceVo ¶
type UranusResourceVo struct {
/* 显示id (Optional) */
ViewId string `json:"viewId"`
/* 租户code (Optional) */
CompanyCode string `json:"companyCode"`
/* 命名空间code (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 资源code,资源唯一标识 (Optional) */
ResourceCode string `json:"resourceCode"`
/* 资源名称 (Optional) */
ResourceName string `json:"resourceName"`
/* 原始资源名称(上传的原始文件在本地客户端的文件名称) (Optional) */
OriginalName string `json:"originalName"`
/* 资源类型 (Optional) */
ResourceType string `json:"resourceType"`
/* 是否有子资源 (Optional) */
HasChildren bool `json:"hasChildren"`
/* 显示图标(bigdataos-folder:资源根目录;bigdataos-folder:普通目录;bigdataos-file-jar:jar文件;bigdataos-file:普通文件;bigdataos-file-zip:归档文件) (Optional) */
Icon string `json:"icon"`
/* 父资源code (Optional) */
ParentCode string `json:"parentCode"`
/* 挂载目录(供shell、python、spark jar访问使用),复制路径时使用该路径 (Optional) */
MountPath string `json:"mountPath"`
/* 该项目空间下的相对路径 (Optional) */
RelativePath string `json:"relativePath"`
/* 子资源 (Optional) */
Children []UranusResourceVo `json:"children"`
/* 负责人 (Optional) */
Managers []string `json:"managers"`
/* 关联引擎 (Optional) */
RelativeEngine string `json:"relativeEngine"`
/* 上传文件方式 (Optional) */
UploadMode string `json:"uploadMode"`
/* 环境 (Optional) */
Env string `json:"env"`
/* 发布状态(只有dev环境需要该字段) (Optional) */
PublishStage string `json:"publishStage"`
/* 待发布的操作类型 (Optional) */
OperationType string `json:"operationType"`
}
type UranusResultBoolean ¶
type UranusResultBoolean struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result bool `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultDefinedFunctionVo ¶
type UranusResultDefinedFunctionVo struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result DefinedFunctionVo `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultFunctionCatalogVoList ¶
type UranusResultFunctionCatalogVoList struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result []FunctionCatalogVo `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultInteger ¶
type UranusResultInteger struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result int `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultLinkedHashMapObjectObject ¶
type UranusResultLinkedHashMapObjectObject struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result interface{} `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListAnalysisScriptRes ¶
type UranusResultListAnalysisScriptRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusAnalysisScriptRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListCatalogInfoCode ¶
type UranusResultListCatalogInfoCode struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusCatalogInfoCode `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListCatalogInfoList ¶
type UranusResultListCatalogInfoList struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusCatalogInfoList `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListColumnReq ¶
type UranusResultListColumnReq struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusColumnReq `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListDictRes ¶
type UranusResultListDictRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusDictRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListDictVO ¶
type UranusResultListDictVO struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusDictVO `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListElementDelimiters ¶
type UranusResultListElementDelimiters struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result []TaskLoopElementDelimiterVo `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListFileManagerRes ¶
type UranusResultListFileManagerRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusFileManagerRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListFunctionManagerRes ¶
type UranusResultListFunctionManagerRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusFunctionManagerRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListObject ¶
type UranusResultListObject struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []interface{} `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListSchedJobDTO ¶
type UranusResultListSchedJobDTO struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusSchedJobDTO `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListSparkJarManagerRes ¶
type UranusResultListSparkJarManagerRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusSparkJarManagerRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListString ¶
type UranusResultListString struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []string `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListTaskFlowDetailRes ¶
type UranusResultListTaskFlowDetailRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusTaskFlowDetailRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListTaskFlowListRes ¶
type UranusResultListTaskFlowListRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusTaskFlowListRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListTaskInfoRes ¶
type UranusResultListTaskInfoRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusTaskInfoRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListTaskNodePreRes ¶
type UranusResultListTaskNodePreRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusTaskNodePreRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListTaskNodeRes ¶
type UranusResultListTaskNodeRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusTaskNodeRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultListTaskParamReq ¶
type UranusResultListTaskParamReq struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []UranusTaskParamReq `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultPageResultContentSchedTaskInfoHistoryRes ¶
type UranusResultPageResultContentSchedTaskInfoHistoryRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result UranusPageResultContentSchedTaskInfoHistoryRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultPageResultContentScriptRunLogRes ¶
type UranusResultPageResultContentScriptRunLogRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result UranusPageResultContentScriptRunLogRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultPageResultContentTaskNodePageRes ¶
type UranusResultPageResultContentTaskNodePageRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result UranusPageResultContentTaskNodePageRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultRes ¶
type UranusResultRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result interface{} `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultResListString ¶
type UranusResultResListString struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []string `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultResourceBriefInfoVo ¶
type UranusResultResourceBriefInfoVo struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result ResourceBriefInfoVo `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultResourceVo ¶
type UranusResultResourceVo struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result UranusResourceVo `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultScriptRunLogRes ¶
type UranusResultScriptRunLogRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result UranusScriptRunLogRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultString ¶
type UranusResultString struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result string `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultTableBriefInfoRes ¶
type UranusResultTableBriefInfoRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* Object (Optional) */
Result []TableBriefInfo `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultTableDelimitersVo ¶
type UranusResultTableDelimitersVo struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result TableDelimitersVo `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultTableQuery ¶
type UranusResultTableQuery struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result UranusTableQuery `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultTableSaveOrUpdate ¶
type UranusResultTableSaveOrUpdate struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result UranusTableSaveOrUpdate `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultTaskFlowDetailRes ¶
type UranusResultTaskFlowDetailRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result UranusTaskFlowDetailRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultTaskInfo ¶
type UranusResultTaskInfo struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result UranusTaskInfo `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultTaskInfoPrePublishRes ¶
type UranusResultTaskInfoPrePublishRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result UranusTaskInfoPrePublishRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultTaskNodeDetailRes ¶
type UranusResultTaskNodeDetailRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result UranusTaskNodeDetailRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultTaskNodeParamRes ¶
type UranusResultTaskNodeParamRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result []UranusTaskNodeParamRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultTaskNodeRSaveReq ¶
type UranusResultTaskNodeRSaveReq struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result UranusTaskNodeRSaveReq `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultUploaderChunkCheckerRes ¶
type UranusResultUploaderChunkCheckerRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result UranusUploaderChunkCheckerRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusResultUploaderInitRes ¶
type UranusResultUploaderInitRes struct {
/* 返回状态码 (Optional) */
Code string `json:"code"`
/* 错误Title (Optional) */
ErrorTitle string `json:"errorTitle"`
/* 返回状态信息 (Optional) */
ErrorMsg string `json:"errorMsg"`
/* (Optional) */
Result UploaderInitRes `json:"result"`
/* 业务码 (Optional) */
SubCode string `json:"subCode"`
/* (Optional) */
Successed bool `json:"successed"`
}
type UranusRunnerReq ¶
type UranusRunnerReq struct {
/* 流程code */
FlowCode string `json:"flowCode"`
/* 数据源code */
DataSourceCode string `json:"dataSourceCode"`
/* 文件code */
FileCode string `json:"fileCode"`
/* 文件名称 */
FileName string `json:"fileName"`
/* 文件类型 SQL,SHELL,PYTHON,PERL,R,SparkJar,StarRocks,MySQL */
FileType string `json:"fileType"`
/* 脚本内容 */
Content string `json:"content"`
/* sql执行引擎 apReduce,Spark,Tez,presto,Python2,Python3,auto,StarRocks,MySQL */
ExecEngine string `json:"execEngine"`
/* 脚本参数配置 (Optional) */
Args []UranusTaskParamReq `json:"args"`
/* sql脚本是否全部执行 是false,否true */
Segment bool `json:"segment"`
/* 队列名称 (Optional) */
ResourceName string `json:"resourceName"`
/* 队列code (Optional) */
ResourceCode string `json:"resourceCode"`
/* 循环节点信息 (Optional) */
LoopInfo []TaskInfoLoopReq `json:"loopInfo"`
}
type UranusRunnerResultReq ¶
type UranusRunnerResultReq struct {
/* 文件名称 taskId_${结果集数字} 第一个结果就是:1_1,第二个结果集就是:1_2 (Optional) */
FileName string `json:"fileName"`
/* 文件业务code (Optional) */
FileCode string `json:"fileCode"`
/* 文件偏移量 (Optional) */
Pos int64 `json:"pos"`
/* 读取结果条数 (Optional) */
Lines int64 `json:"lines"`
/* 运行ID (Optional) */
HistoryId int `json:"historyId"`
}
type UranusSchedJobDTO ¶
type UranusSchedJobDTO struct {
/* (Optional) */
JobCode string `json:"jobCode"`
/* (Optional) */
TaskInfo UranusTaskInfoDTO `json:"taskInfo"`
/* (Optional) */
TaskCode string `json:"taskCode"`
/* (Optional) */
FileCode string `json:"fileCode"`
/* (Optional) */
Content string `json:"content"`
/* (Optional) */
Manager string `json:"manager"`
/* (Optional) */
ValidResult int `json:"validResult"`
/* (Optional) */
ValidResultDesc string `json:"validResultDesc"`
/* (Optional) */
PublicChangeType int `json:"publicChangeType"`
/* (Optional) */
PublicChangeTypeDesc string `json:"publicChangeTypeDesc"`
/* (Optional) */
Reason string `json:"reason"`
/* (Optional) */
FileType string `json:"fileType"`
/* (Optional) */
JobName string `json:"jobName"`
/* (Optional) */
TriggerType string `json:"triggerType"`
/* (Optional) */
Cycle string `json:"cycle"`
/* (Optional) */
TaskParamList []UranusTaskParamDTO `json:"taskParamList"`
/* (Optional) */
CreatedTime int64 `json:"createdTime"`
/* (Optional) */
FlowCode string `json:"flowCode"`
/* (Optional) */
LockStatus int `json:"lockStatus"`
/* (Optional) */
LockUser string `json:"lockUser"`
/* (Optional) */
TaskRelease int `json:"taskRelease"`
}
type UranusSchedTaskInfoHistoryRes ¶
type UranusSchedTaskInfoHistoryRes struct {
/* 发布版本 ID (Optional) */
Id int `json:"id"`
/* 节点的CODE (Optional) */
TaskCode string `json:"taskCode"`
/* 工作流CODE (Optional) */
FlowCode string `json:"flowCode"`
/* 发布类型 1上线、2下线 3删除 (Optional) */
SchedType int `json:"schedType"`
/* 作业状态 0未发布 1已发布 (Optional) */
SchedStatus int `json:"schedStatus"`
/* 作业名称 (Optional) */
TaskName string `json:"taskName"`
/* 作业描述 (Optional) */
TaskDesc string `json:"taskDesc"`
/* 运维中心当前版本 (Optional) */
TaskRelease int `json:"taskRelease"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* 共享人,不超过10个 (Optional) */
WorkUser string `json:"workUser"`
/* 作业信息 (Optional) */
JobInfo string `json:"jobInfo"`
/* 脚本信息 (Optional) */
ScriptInfo string `json:"scriptInfo"`
/* 队列code (Optional) */
ResourceCode string `json:"resourceCode"`
/* 队列名称 (Optional) */
ResourceName string `json:"resourceName"`
/* 原因 (Optional) */
Reason string `json:"reason"`
/* 创建人 (Optional) */
CreateUser string `json:"createUser"`
/* 创建时间 (Optional) */
CreatedTime string `json:"createdTime"`
/* 更新时间 (Optional) */
UpdateTime string `json:"updateTime"`
/* 1:有效,0:无效 (Optional) */
Valid int `json:"valid"`
/* 作业状态 (Optional) */
JobStatus int `json:"jobStatus"`
/* 输入参数 (Optional) */
TaskParamList []UranusTaskParamReq `json:"taskParamList"`
/* 输出参数 (Optional) */
ExportParamList []UranusTaskParamReq `json:"exportParamList"`
/* (Optional) */
FromGravity bool `json:"fromGravity"`
/* 作业读写数据源主id,数据源的主ID (Optional) */
DatasourcePrimaryId string `json:"datasourcePrimaryId"`
/* 数据源名称 (Optional) */
DatasourceName string `json:"datasourceName"`
/* 作业读写数据源使用环境类型,dev:开发环境,prod:生产环境 (Optional) */
DatasourceUseEnvType string `json:"datasourceUseEnvType"`
/* (Optional) */
LoopInfo TaskInfoLoopReq `json:"loopInfo"`
}
type UranusScriptFileVerifyReq ¶
type UranusScriptFileVerifyReq struct {
/* 脚本内容 */
Content string `json:"content"`
/* 文件Code */
FileCode string `json:"fileCode"`
/* 文件类型 */
FileType int `json:"fileType"`
/* 脚本名称 (Optional) */
ScriptName string `json:"scriptName"`
/* 脚本字节 (Optional) */
ScriptByte []string `json:"scriptByte"`
/* 任务名称 (Optional) */
JobName string `json:"jobName"`
/* 依赖任务名称 (Optional) */
Dependencies string `json:"dependencies"`
/* 脚本类型 (Optional) */
ScriptType string `json:"scriptType"`
/* 目标表 (Optional) */
TargetTables string `json:"targetTables"`
/* 是否保存脚本中解析出来的表相关信息 (Optional) */
SaveRelFlag string `json:"saveRelFlag"`
}
type UranusScriptParamReq ¶
type UranusScriptParamReq struct {
/* 文件Code */
FileCode string `json:"fileCode"`
/* 脚本参数 list */
Params []UranusTaskParamReq `json:"params"`
}
type UranusScriptRunLogListReq ¶
type UranusScriptRunLogListReq struct {
/* 业务线Code (Optional) */
FileCode string `json:"fileCode"`
/* 运行状态列表 (Optional) */
StatusList []string `json:"statusList"`
/* 启动时间起点 (Optional) */
StartTimeFrom string `json:"startTimeFrom"`
/* 启动时间截至 (Optional) */
StartTimeTo string `json:"startTimeTo"`
/* 结束时间起点 (Optional) */
EndTimeFrom string `json:"endTimeFrom"`
/* 结束时间截至 (Optional) */
EndTimeTo string `json:"endTimeTo"`
/* 文件路径 (Optional) */
FilePath string `json:"filePath"`
/* 第几页 (Optional) */
Page int `json:"page"`
/* 分页大小 (Optional) */
PageSize int `json:"pageSize"`
}
type UranusScriptRunLogRes ¶
type UranusScriptRunLogRes struct {
/* 运行id (Optional) */
Id int `json:"id"`
/* code (Optional) */
Code string `json:"code"`
/* 数据源主ID (Optional) */
DatasourcePrimaryId string `json:"datasourcePrimaryId"`
/* 数据源名称 (Optional) */
DatasourceName string `json:"datasourceName"`
/* 数据源使用环境类型,dev:开发环境,prod:生产环境 (Optional) */
DatasourceUseEnvType string `json:"datasourceUseEnvType"`
/* 文件业务线code (Optional) */
FileCode string `json:"fileCode"`
/* 开始时间 (Optional) */
StartTime string `json:"startTime"`
/* 结束时间 (Optional) */
EndTime string `json:"endTime"`
/* 状态,0:等待执行,1:执行中,2:成功,3:失败, 4:中止 (Optional) */
Status string `json:"status"`
/* 文件类型 (Optional) */
FileType string `json:"fileType"`
/* 文件路径,相对路径 (Optional) */
FilePath string `json:"filePath"`
/* 0:全文执行, 1:选中执行 (Optional) */
ExecMode string `json:"execMode"`
/* 运行脚本的快照文件 (Optional) */
SnapshotMd5 string `json:"snapshotMd5"`
/* 运行参数 (Optional) */
Args string `json:"args"`
/* 执行引擎 (Optional) */
ExecEngine string `json:"execEngine"`
/* 操作人 (Optional) */
Operator string `json:"operator"`
/* 日志路径 (Optional) */
LogPath string `json:"logPath"`
/* 结果索引 (Optional) */
ResultIndex int `json:"resultIndex"`
/* (Optional) */
LoopInfo TaskInfoLoopReq `json:"loopInfo"`
}
type UranusSparkJarManagerRes ¶
type UranusSparkJarManagerRes struct {
/* 相对路径 (Optional) */
RelativePath string `json:"relativePath"`
/* 实际路径 (Optional) */
RealPath string `json:"realPath"`
/* 名称 (Optional) */
Name string `json:"name"`
/* 是否是目录 (Optional) */
Dir bool `json:"dir"`
/* 子节点 sparkJarManagerRes (Optional) */
Children []UranusSparkJarManagerRes `json:"children"`
}
type UranusTableQuery ¶
type UranusTableQuery struct {
/* 图谱ID (Optional) */
Id string `json:"id"`
/* 表英文名称 (Optional) */
TableEnName string `json:"tableEnName"`
/* 表中文名 (Optional) */
TableCnName string `json:"tableCnName"`
/* 负责人 (Optional) */
Owner string `json:"owner"`
/* 协助人 (Optional) */
Manager string `json:"manager"`
/* 表的普通字段信息 (Optional) */
Columns []UranusColumnSaveOrUpdate `json:"columns"`
/* 表的分区字段信息 (Optional) */
Partitions []UranusColumnSaveOrUpdate `json:"partitions"`
/* 0 非分区表 1 分区表 (Optional) */
IsPartition int `json:"isPartition"`
/* 表存储格式 (Optional) */
StorageType string `json:"storageType"`
/* 表字段分隔符(只有TEXTFILE类型表需要该字段) (Optional) */
FieldDelim string `json:"fieldDelim"`
/* 表行分隔符(只有TEXTFILE类型表需要该字段) (Optional) */
LineDelim string `json:"lineDelim"`
/* 分桶字段 (Optional) */
BucketCols []string `json:"bucketCols"`
/* 分桶个数 (Optional) */
BucketNum int `json:"bucketNum"`
}
type UranusTableSaveOrUpdate ¶
type UranusTableSaveOrUpdate struct {
/* 表英文名称 */
TableEnName string `json:"tableEnName"`
/* 表中文名 (Optional) */
TableCnName string `json:"tableCnName"`
/* 负责人 (Optional) */
Owner string `json:"owner"`
/* 协助人 (Optional) */
Manager string `json:"manager"`
/* 表的普通字段信息 */
Columns []UranusColumnSaveOrUpdate `json:"columns"`
/* 表的分区字段信息 (Optional) */
Partitions []UranusColumnSaveOrUpdate `json:"partitions"`
/* 0 非分区表 1 分区表 (Optional) */
IsPartition int `json:"isPartition"`
/* 0 新建表 1 修改表 (Optional) */
UpdateTable int `json:"updateTable"`
/* 表存储格式 (Optional) */
StorageType string `json:"storageType"`
/* 表字段分隔符(只有TEXTFILE类型表需要该字段) (Optional) */
FieldDelim string `json:"fieldDelim"`
/* 表行分隔符(只有TEXTFILE类型表需要该字段) (Optional) */
LineDelim string `json:"lineDelim"`
/* 分桶字段 (Optional) */
BucketCols []string `json:"bucketCols"`
/* 分桶字段 (Optional) */
BucketNum int `json:"bucketNum"`
}
type UranusTaskFlowCheckReq ¶
type UranusTaskFlowCheckReq struct {
/* 工作流名称 */
FlowName string `json:"flowName"`
}
type UranusTaskFlowDelReq ¶
type UranusTaskFlowDelReq struct {
/* 工作流code list */
FlowCodes []string `json:"flowCodes"`
}
type UranusTaskFlowDetailRes ¶
type UranusTaskFlowDetailRes struct {
/* 工作流名称 */
FlowName string `json:"flowName"`
/* 工作流描述 (Optional) */
FlowDesc string `json:"flowDesc"`
/* 工作流所属目录 */
CatalogCode string `json:"catalogCode"`
/* 工作流协同人 (Optional) */
Workers []string `json:"workers"`
/* 工作流code (Optional) */
FlowCode string `json:"flowCode"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* 0 未发布 1 已发布 (Optional) */
FlowStatus int `json:"flowStatus"`
/* 工作流状态描述 (Optional) */
FlowStatusDesc string `json:"flowStatusDesc"`
/* 0 未收藏 1 已收藏 (Optional) */
Collection int `json:"collection"`
/* 创建时间 (Optional) */
CreatedTime string `json:"createdTime"`
}
type UranusTaskFlowInfo ¶
type UranusTaskFlowListRes ¶
type UranusTaskFlowListRes struct {
/* 节点类型id (Optional) */
NodeCode int `json:"nodeCode"`
/* 节点名称 (Optional) */
NodeName string `json:"nodeName"`
/* 0 未发布 1 已发布 (Optional) */
FlowStatus int `json:"flowStatus"`
/* Script节点的时候用到 (Optional) */
FlowCode string `json:"flowCode"`
/* 0 未发布 1 已发布 (Optional) */
FlowStatusDesc string `json:"flowStatusDesc"`
/* '1:有效,0:无效 (Optional) */
FlowValid int `json:"flowValid"`
/* 是否收藏 0 否 1 是 (Optional) */
Collection int `json:"collection"`
/* 是否协同人 0 否 1 是 (Optional) */
IsWorker int `json:"isWorker"`
/* 是否是 owner 0 否 1 是 (Optional) */
IsOwner int `json:"isOwner"`
/* 前端排序唯一ID (Optional) */
UnrealId string `json:"unrealId"`
/* 图标 (Optional) */
NodeIcon string `json:"nodeIcon"`
/* 集合 因为存在 更新(未发布) 和 上下线未发布 组合的情况 (Optional) */
TaskChangeStatus []int `json:"taskChangeStatus"`
/* 发布变更状态描述 (Optional) */
TaskChangeStatusDesc []string `json:"taskChangeStatusDesc"`
/* 作业状态 (Optional) */
GravityStatus int `json:"gravityStatus"`
/* 作业状态描述 (Optional) */
GravityStatusDesc string `json:"gravityStatusDesc"`
/* 节点类型 FLOW 工作流 SCRIPT脚本 (Optional) */
NodeType string `json:"nodeType"`
/* 任务负责人 (Optional) */
IsManager int `json:"isManager"`
/* 子节点 级 节点管理和文件管理 (Optional) */
Children []UranusTaskFlowListRes `json:"children"`
/* 任务节点的taskCode (Optional) */
TaskCode string `json:"taskCode"`
/* 文件信息 (Optional) */
RelativePath string `json:"relativePath"`
/* 名称 (Optional) */
Name string `json:"name"`
/* 是否是目录 (Optional) */
Dir bool `json:"dir"`
/* 父节点code (Optional) */
ParentCode string `json:"parentCode"`
/* 脚本文件的业务cdoe (Optional) */
FileCode string `json:"fileCode"`
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 文件真实路径 (Optional) */
RealPath string `json:"realPath"`
/* 锁状态 (Optional) */
LockStatus int `json:"lockStatus"`
/* 活得锁的用户 (Optional) */
LockUser string `json:"lockUser"`
}
type UranusTaskFlowTreeReq ¶
type UranusTaskFlowTreeReq struct {
/* 关键字查询 (Optional) */
KeyWord string `json:"keyWord"`
/* 目录code (Optional) */
CatalogCode string `json:"catalogCode"`
/* 工作流code (Optional) */
FlowCode string `json:"flowCode"`
/* 查询过滤条件 all 全部、recent 最近使用、join 参数、collection 收藏 (Optional) */
SearchType string `json:"searchType"`
}
type UranusTaskFlowUpdateReq ¶
type UranusTaskFlowUpdateReq struct {
/* 工作流名称 */
FlowName string `json:"flowName"`
/* 工作流描述 (Optional) */
FlowDesc *string `json:"flowDesc"`
/* 工作流所属目录 */
CatalogCode string `json:"catalogCode"`
/* 工作流协同人 (Optional) */
Workers []string `json:"workers"`
/* 工作流code */
FlowCode string `json:"flowCode"`
/* 负责人 (Optional) */
Manager *string `json:"manager"`
}
type UranusTaskFuzzyReq ¶
type UranusTaskFuzzyReq struct {
/* 模糊作业名称 (Optional) */
JobName string `json:"jobName"`
/* 当前作业Code (Optional) */
CurrentTaskCode string `json:"currentTaskCode"`
/* 已选作业名称 (Optional) */
DependJobNameList []string `json:"dependJobNameList"`
/* 解析出父依赖任务 (Optional) */
AnalysisDependJobNameList []string `json:"analysisDependJobNameList"`
}
type UranusTaskInfo ¶
type UranusTaskInfo struct {
/* (Optional) */
TaskInfo UranusTaskInfoRes `json:"taskInfo"`
/* (Optional) */
TaskNodeInfo UranusTaskInfoNodeReq `json:"taskNodeInfo"`
/* (Optional) */
FileInfo UranusTaskInfoFileReq `json:"fileInfo"`
/* (Optional) */
SparkJarInfo TaskInfoSparkJarReq `json:"sparkJarInfo"`
/* (Optional) */
LoopInfo TaskInfoLoopReq `json:"loopInfo"`
}
type UranusTaskInfoDTO ¶
type UranusTaskInfoDTO struct {
/* (Optional) */
FlowUuid string `json:"flowUuid"`
/* (Optional) */
NameKeyWord string `json:"nameKeyWord"`
/* (Optional) */
RelationType string `json:"relationType"`
/* (Optional) */
TableId int `json:"tableId"`
/* (Optional) */
RedirectType string `json:"redirectType"`
/* (Optional) */
TableName string `json:"tableName"`
/* (Optional) */
TableNameMatch bool `json:"tableNameMatch"`
/* (Optional) */
JobName string `json:"jobName"`
/* (Optional) */
JobSystem string `json:"jobSystem"`
/* (Optional) */
TriggerType string `json:"triggerType"`
/* (Optional) */
TriggerConfig UranusTriggerConfigDTO `json:"triggerConfig"`
/* (Optional) */
ZipCommand string `json:"zipCommand"`
/* (Optional) */
ZipFileName string `json:"zipFileName"`
/* (Optional) */
ZipParams string `json:"zipParams"`
/* (Optional) */
Dependencies string `json:"dependencies"`
/* (Optional) */
Manager string `json:"manager"`
/* (Optional) */
Priority string `json:"priority"`
/* (Optional) */
JobDesc string `json:"jobDesc"`
/* (Optional) */
ScriptType string `json:"scriptType"`
/* (Optional) */
RunScript string `json:"runScript"`
/* (Optional) */
ScriptContent []string `json:"scriptContent"`
/* (Optional) */
Cycle string `json:"cycle"`
/* (Optional) */
Sequence string `json:"sequence"`
/* (Optional) */
LifeCycle string `json:"lifeCycle"`
/* (Optional) */
Retry bool `json:"retry"`
/* (Optional) */
NotifyOccasion string `json:"notifyOccasion"`
/* (Optional) */
NotifyTime string `json:"notifyTime"`
/* (Optional) */
NotifyPattern string `json:"notifyPattern"`
/* (Optional) */
Notifier string `json:"notifier"`
/* (Optional) */
StartRunTime string `json:"startRunTime"`
/* (Optional) */
EndRunTime string `json:"endRunTime"`
/* (Optional) */
RunTime string `json:"runTime"`
/* (Optional) */
RunDate string `json:"runDate"`
/* (Optional) */
FlowId string `json:"flowId"`
/* (Optional) */
TaskId string `json:"taskId"`
/* (Optional) */
UserAccount string `json:"userAccount"`
/* (Optional) */
UserPwd string `json:"userPwd"`
/* (Optional) */
MarkIds string `json:"markIds"`
/* (Optional) */
RunTimeOut int `json:"runTimeOut"`
/* (Optional) */
ScriptSourceType string `json:"scriptSourceType"`
/* (Optional) */
ScriptTemplate string `json:"scriptTemplate"`
/* (Optional) */
IsDeploy bool `json:"isDeploy"`
/* (Optional) */
ScriptPath string `json:"scriptPath"`
/* (Optional) */
ScriptByte []string `json:"scriptByte"`
/* (Optional) */
FileId int `json:"fileId"`
/* (Optional) */
PublishDesc string `json:"publishDesc"`
/* (Optional) */
ScriptInfo string `json:"scriptInfo"`
/* (Optional) */
Version int `json:"version"`
/* (Optional) */
Channel string `json:"channel"`
/* (Optional) */
SequenceStartTime string `json:"sequenceStartTime"`
/* (Optional) */
SequenceEndTime string `json:"sequenceEndTime"`
/* (Optional) */
SequenceInterval int `json:"sequenceInterval"`
/* (Optional) */
RunParams string `json:"runParams"`
/* (Optional) */
RunQueue string `json:"runQueue"`
/* (Optional) */
Cooperator string `json:"cooperator"`
/* (Optional) */
FromGravity bool `json:"fromGravity"`
}
type UranusTaskInfoFileReq ¶
type UranusTaskInfoFileReq struct {
/* 文件Code */
FileCode string `json:"fileCode"`
/* 文件内容 */
Content string `json:"content"`
/* 文件类型 后缀名 */
FileType string `json:"fileType"`
/* 创建时间 (Optional) */
CreatedTime *string `json:"createdTime"`
/* 锁状态 */
LockStatus int `json:"lockStatus"`
/* 获得锁的用户 */
LockUser string `json:"lockUser"`
}
type UranusTaskInfoNodeReq ¶
type UranusTaskInfoNodeReq struct {
/* 节点code (Optional) */
TaskCode *string `json:"taskCode"`
/* 状态 集合 (Optional) */
TaskChangeStatus []int `json:"taskChangeStatus"`
/* 发布变更状态描述 (Optional) */
TaskChangeStatusDesc []string `json:"taskChangeStatusDesc"`
/* 作业状态 (Optional) */
GravityStatus *int `json:"gravityStatus"`
/* 作业状态描述 (Optional) */
GravityStatusDesc *string `json:"gravityStatusDesc"`
}
type UranusTaskInfoPrePublishRes ¶
type UranusTaskInfoPrePublishRes struct {
/* 检测结果 (Optional) */
ValidResult int `json:"validResult"`
/* 检测结果描述 (Optional) */
ValidResultDesc string `json:"validResultDesc"`
/* 发布变更类型 (Optional) */
PublicChangeType int `json:"publicChangeType"`
/* 发布变更类型描述 (Optional) */
PublicChangeTypeDesc string `json:"publicChangeTypeDesc"`
/* 发布变更类型集合 (Optional) */
ChangeTypeResList []UranusPublishChangeTypeRes `json:"changeTypeResList"`
}
type UranusTaskInfoRePublishReq ¶
type UranusTaskInfoRePublishReq struct {
/* 发布历史id (Optional) */
HistoryId int `json:"historyId"`
}
type UranusTaskInfoRes ¶
type UranusTaskInfoRes struct {
/* 新模型(MODEL),老模型(OLD_MODEL)、数据开发(IDE)、数据集成(PIPE)、数据质量(DQ) */
FlowCode string `json:"flowCode"`
/* projectNameMatch (Optional) */
ProjectNameMatch *bool `json:"projectNameMatch"`
/* nameKeyWord (Optional) */
NameKeyWord *string `json:"nameKeyWord"`
/* 关联类型 JobRelationEnum (Optional) */
RelationType *string `json:"relationType"`
/* 操作类型 (Optional) */
RedirectType *string `json:"redirectType"`
/* 表名 (Optional) */
TableName *string `json:"tableName"`
/* tableNameMatch (Optional) */
TableNameMatch *bool `json:"tableNameMatch"`
/* 任务名称 (Optional) */
JobName *string `json:"jobName"`
/* 所属系统 (Optional) */
JobSystem *string `json:"jobSystem"`
/* 触发类型 (Optional) */
TriggerType *string `json:"triggerType"`
/* 依赖任务 (Optional) */
Dependencies *string `json:"dependencies"`
/* 负责人 (Optional) */
Manager *string `json:"manager"`
/* 优先级 (Optional) */
Priority *string `json:"priority"`
/* 任务描述 (Optional) */
JobDesc *string `json:"jobDesc"`
/* 脚本类型,JCW为purl_sql,注意所有都是小写 (Optional) */
ScriptType *string `json:"scriptType"`
/* 脚本名称 (Optional) */
RunScript *string `json:"runScript"`
/* 脚本内容 (Optional) */
ScriptContent []string `json:"scriptContent"`
/* 运行频率 (Optional) */
Cycle *string `json:"cycle"`
/* 运行频率 (Optional) */
Sequence *string `json:"sequence"`
/* 生命周期 (Optional) */
LifeCycle *string `json:"lifeCycle"`
/* 失败后是否重试 (Optional) */
Retry *bool `json:"retry"`
/* 预警时机 (Optional) */
NotifyOccasion *string `json:"notifyOccasion"`
/* 预警时间 (Optional) */
NotifyTime *string `json:"notifyTime"`
/* 预警方式 (Optional) */
NotifyPattern *string `json:"notifyPattern"`
/* 预警通知人 (Optional) */
Notifier *string `json:"notifier"`
/* 开始运行时间(HH:mm) (Optional) */
StartRunTime *string `json:"startRunTime"`
/* 结束运行时间(HH:mm) (Optional) */
EndRunTime *string `json:"endRunTime"`
/* 定时、一次任务(开始运行时间) (Optional) */
RunTime *string `json:"runTime"`
/* 定时、一次任务(开始运行时间) (Optional) */
RunDate *string `json:"runDate"`
/* 节点Code */
TaskCode string `json:"taskCode"`
/* markIds (Optional) */
MarkIds *string `json:"markIds"`
/* 超时时间 (Optional) */
RunTimeOut *int `json:"runTimeOut"`
/* 脚本来源类型 (Optional) */
ScriptSourceType *string `json:"scriptSourceType"`
/* isDeploy (Optional) */
IsDeploy *bool `json:"isDeploy"`
/* 脚本路径 (Optional) */
ScriptPath *string `json:"scriptPath"`
/* 脚本文件字节数组,是将脚本文件内容转换为byte数组 (Optional) */
ScriptByte []string `json:"scriptByte"`
/* 脚本文件Code (Optional) */
FileCode *string `json:"fileCode"`
/* 作业发布描述 (Optional) */
PublishDesc *string `json:"publishDesc"`
/* 脚本内容 (Optional) */
ScriptInfo *string `json:"scriptInfo"`
/* 根据版本号,判断是重新发布还是新建,如果新建添加版本号,不是新建,更新历史表作业状态状态 (Optional) */
Version *int `json:"version"`
/* 周期开始时间(小时分钟任务用) (Optional) */
SequenceStartTime *string `json:"sequenceStartTime"`
/* 周期结束时间(小时分钟任务用) (Optional) */
SequenceEndTime *string `json:"sequenceEndTime"`
/* 时间间隔(小时分钟任务用) (Optional) */
SequenceInterval *int `json:"sequenceInterval"`
/* 脚本运行引擎 (Optional) */
RunEngine *string `json:"runEngine"`
/* 队列code (Optional) */
ResourceCode *string `json:"resourceCode"`
/* 队列Name (Optional) */
ResourceName *string `json:"resourceName"`
/* 协作人 (Optional) */
Cooperator *string `json:"cooperator"`
/* 输入参数 (Optional) */
TaskParamList []UranusTaskParamReq `json:"taskParamList"`
/* 输出参数 (Optional) */
ExportParamList []UranusTaskParamReq `json:"exportParamList"`
/* (Optional) */
FromGravity *bool `json:"fromGravity"`
/* 作业读写数据源主id,数据源的主ID (Optional) */
DatasourcePrimaryId *string `json:"datasourcePrimaryId"`
/* 作业读写数据源使用环境类型,dev:开发环境,prod:生产环境 (Optional) */
DatasourceUseEnvType *string `json:"datasourceUseEnvType"`
}
type UranusTaskNodeChangeRes ¶
type UranusTaskNodeDetailRes ¶
type UranusTaskNodeDetailRes struct {
/* 节点名称 */
TaskName string `json:"taskName"`
/* 子节点code List (Optional) */
ChildrenCode []string `json:"childrenCode"`
/* 父节点code List (Optional) */
ParentCode []string `json:"parentCode"`
/* 节点描述 (Optional) */
TaskDesc *string `json:"taskDesc"`
/* 任务类型 */
TaskNodeId int `json:"taskNodeId"`
/* 节点CODE */
TaskCode string `json:"taskCode"`
/* 负责人 */
Manager string `json:"manager"`
/* 节点数据 以下前端需要用到的数据 (Optional) */
TaskData *string `json:"taskData"`
/* 节点名称 以下前端需要用到的数据 (Optional) */
NodeName *string `json:"nodeName"`
/* 节点类型 (Optional) */
NodeTypeName *string `json:"nodeTypeName"`
/* 节点图标 以下前端需要用到的数据 (Optional) */
NodeIcon *string `json:"nodeIcon"`
/* 工作流Code */
FlowCode string `json:"flowCode"`
/* 脚本文件的业务Code (Optional) */
FileCode *string `json:"fileCode"`
/* 作业名称 (Optional) */
JobName *string `json:"jobName"`
/* 是否工作流任务 (Optional) */
IsUranus *int `json:"isUranus"`
/* 是否当前工作流任务 (Optional) */
IsCurrentFlow *int `json:"isCurrentFlow"`
/* 给前端用到的 (Optional) */
Parent []UranusTaskNodeSaveReq `json:"parent"`
/* 是否有子任务依赖前端用到 (Optional) */
HaveChildren *int `json:"haveChildren"`
/* 协作人 (Optional) */
Worker *string `json:"worker"`
/* 发布变更状态 (Optional) */
TaskChangeStatus []int `json:"taskChangeStatus"`
/* 发布变更状态描述 (Optional) */
TaskChangeStatusDesc []string `json:"taskChangeStatusDesc"`
/* 作业状态 (Optional) */
GravityStatus *int `json:"gravityStatus"`
/* 作业状态描述 (Optional) */
GravityStatusDesc *string `json:"gravityStatusDesc"`
/* 锁定状态 0 无锁 1 锁定 默认 为 1 (Optional) */
LockStatus *int `json:"lockStatus"`
/* 解锁人员 (Optional) */
LockUser *string `json:"lockUser"`
}
type UranusTaskNodePagePublishReq ¶
type UranusTaskNodePagePublishReq struct {
/* 节点列表 */
Ids []UranusNodePublishChildReq `json:"ids"`
/* 流程Code (Optional) */
FlowCode string `json:"flowCode"`
}
type UranusTaskNodePageReq ¶
type UranusTaskNodePageReq struct {
/* 分页 (Optional) */
Page int `json:"page"`
/* 分页 (Optional) */
PageSize int `json:"pageSize"`
/* 作业名称 (Optional) */
TaskName string `json:"taskName"`
/* 任务类型 (Optional) */
JobType []int `json:"jobType"`
/* 子任务类型 (Optional) */
JobChildType []int `json:"jobChildType"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* 作业状态 (Optional) */
JobStatus []int `json:"jobStatus"`
/* 修改状态 (Optional) */
UpdateStatus []int `json:"updateStatus"`
/* 创建时间 (Optional) */
CreateTimeBefore string `json:"createTimeBefore"`
/* 创建时间 (Optional) */
CreateTimeAfter string `json:"createTimeAfter"`
/* 更新时间 (Optional) */
UpdateTimeBefore string `json:"updateTimeBefore"`
/* 更新时间 (Optional) */
UpdateTimeAfter string `json:"updateTimeAfter"`
/* 流程Code (Optional) */
FlowCode string `json:"flowCode"`
}
type UranusTaskNodePageRes ¶
type UranusTaskNodePageRes struct {
/* 节点Code (Optional) */
TaskCode string `json:"taskCode"`
/* 节点名称 (Optional) */
TaskName string `json:"taskName"`
/* 作业类型 (Optional) */
JobType int `json:"jobType"`
/* 作业类型描述 (Optional) */
JobTypeDesc string `json:"jobTypeDesc"`
/* 子节点类型 (Optional) */
JobChildType int `json:"jobChildType"`
/* 子节点类型描述 (Optional) */
JobChildTypeDesc string `json:"jobChildTypeDesc"`
/* 流程唯一code (Optional) */
FlowCode string `json:"flowCode"`
/* 流程名称 (Optional) */
FlowName string `json:"flowName"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* 节点名称 (Optional) */
NodeName string `json:"nodeName"`
/* 节点图标 (Optional) */
NodeIcon string `json:"nodeIcon"`
/* 文件code (Optional) */
FileCode string `json:"fileCode"`
/* 节点类型名称 (Optional) */
NodeTypeName string `json:"nodeTypeName"`
/* 发布变更状态 (Optional) */
TaskNodeChangeResList []UranusTaskNodeChangeRes `json:"taskNodeChangeResList"`
/* 作业状态 (Optional) */
GravityStatus int `json:"gravityStatus"`
/* 作业状态描述 (Optional) */
GravityStatusDesc string `json:"gravityStatusDesc"`
/* 创建时间 (Optional) */
CreatedTime string `json:"createdTime"`
/* 修改时间 (Optional) */
ModifiedTime string `json:"modifiedTime"`
}
type UranusTaskNodeParamRes ¶
type UranusTaskNodeParamRes struct {
/* 展示用的序号 (Optional) */
Sort int `json:"sort"`
/* 租户code (Optional) */
CompanyCode string `json:"companyCode"`
/* 工作空间code (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 工作流code (Optional) */
FlowCode string `json:"flowCode"`
/* 任务code (Optional) */
TaskCode string `json:"taskCode"`
/* 任务名称 (Optional) */
TaskName string `json:"taskName"`
/* 负责人 (Optional) */
Manager string `json:"manager"`
/* key (Optional) */
ParamKey string `json:"paramKey"`
/* value (Optional) */
ParamValue string `json:"paramValue"`
/* 描述 (Optional) */
ParamDesc string `json:"paramDesc"`
/* 参数类型 ORDINARY:普通参数,VARIABLE_IMPORT:变量输入参数,VARIABLE_EXPORT:变量输出参数 (Optional) */
ParamType string `json:"paramType"`
}
type UranusTaskNodePreRes ¶
type UranusTaskNodePreRes struct {
/* 总排序 (Optional) */
Sort int `json:"sort"`
/* 分组里面的顺序 (Optional) */
TaskSort int `json:"taskSort"`
/* 分组 (Optional) */
TaskGroup int `json:"taskGroup"`
/* 是否存在同级 (Optional) */
HasLevel int `json:"hasLevel"`
/* 作业名称 (Optional) */
TaskName string `json:"taskName"`
/* 作业描述 (Optional) */
TaskDesc string `json:"taskDesc"`
/* 作业Code (Optional) */
TaskCode string `json:"taskCode"`
/* 发布变更类型描述 (Optional) */
PublicChangeType string `json:"publicChangeType"`
}
type UranusTaskNodePublishOReq ¶
type UranusTaskNodePublishOReq struct {
/* 节点列表 */
Ids []UranusNodePublishChildReq `json:"ids"`
/* 发布原因 */
Reason string `json:"reason"`
}
type UranusTaskNodeRSaveReq ¶
type UranusTaskNodeRSaveReq struct {
/* */
WorkFlowInfo UranusTaskFlowUpdateReq `json:"workFlowInfo"`
/* 节点信息 */
Nodes []UranusTaskNodeDetailRes `json:"nodes"`
/* 节点之间关系 */
GraphStr string `json:"graphStr"`
}
type UranusTaskNodeRes ¶
type UranusTaskNodeRes struct {
/* (Optional) */
Id int `json:"id"`
/* 父节点id 根节点为 uranus (Optional) */
ParentId int `json:"parentId"`
/* 节点类型 0 不可拖拽,1,可以拖拽 (Optional) */
NodeType int `json:"nodeType"`
/* 节点描述 (Optional) */
NodeDesc string `json:"nodeDesc"`
/* 节点名称 (Optional) */
NodeName string `json:"nodeName"`
/* 节点名称图标 (Optional) */
NodeIcon string `json:"nodeIcon"`
/* 排序字段 (Optional) */
NodeSort int `json:"nodeSort"`
/* 子节点集合 (Optional) */
Children []UranusTaskNodeRes `json:"children"`
}
type UranusTaskNodeSaveReq ¶
type UranusTaskNodeSaveReq struct {
/* 节点名称 (Optional) */
TaskName *string `json:"taskName"`
/* 子节点code List (Optional) */
ChildrenCode []string `json:"childrenCode"`
/* 父节点code List (Optional) */
ParentCode []string `json:"parentCode"`
/* 节点描述 (Optional) */
TaskDesc *string `json:"taskDesc"`
/* 任务类型 (Optional) */
TaskNodeId *int `json:"taskNodeId"`
/* 节点CODE (Optional) */
TaskCode *string `json:"taskCode"`
/* 负责人 (Optional) */
Manager *string `json:"manager"`
/* 节点数据 以下前端需要用到的数据 (Optional) */
TaskData *string `json:"taskData"`
/* 节点名称 以下前端需要用到的数据 (Optional) */
NodeName *string `json:"nodeName"`
/* 节点类型 (Optional) */
NodeTypeName *string `json:"nodeTypeName"`
/* 节点图标 以下前端需要用到的数据 (Optional) */
NodeIcon *string `json:"nodeIcon"`
/* 工作流Code (Optional) */
FlowCode *string `json:"flowCode"`
/* 脚本文件的业务Code (Optional) */
FileCode *string `json:"fileCode"`
/* 作业名称 (Optional) */
JobName *string `json:"jobName"`
/* 是否工作流任务 (Optional) */
IsUranus *int `json:"isUranus"`
/* 是否当前工作流任务 (Optional) */
IsCurrentFlow *int `json:"isCurrentFlow"`
/* 给前端用到的 (Optional) */
Parent []UranusTaskNodeSaveReq `json:"parent"`
/* 是否有子任务依赖前端用到 (Optional) */
HaveChildren *int `json:"haveChildren"`
/* 协作人 (Optional) */
Cooperator *string `json:"cooperator"`
}
type UranusTaskNodeUpdateReq ¶
type UranusTaskNodeUpdateReq struct {
/* 节点名称 */
TaskName string `json:"taskName"`
/* 子节点code List (Optional) */
ChildrenCode []string `json:"childrenCode"`
/* 父节点code List (Optional) */
ParentCode []string `json:"parentCode"`
/* 节点描述 (Optional) */
TaskDesc string `json:"taskDesc"`
/* 任务类型 */
TaskNodeId int `json:"taskNodeId"`
/* 节点CODE */
TaskCode string `json:"taskCode"`
/* 负责人 */
Manager string `json:"manager"`
/* 节点数据 以下前端需要用到的数据 (Optional) */
TaskData string `json:"taskData"`
/* 节点名称 以下前端需要用到的数据 (Optional) */
NodeName string `json:"nodeName"`
/* 节点类型 (Optional) */
NodeTypeName string `json:"nodeTypeName"`
/* 节点图标 以下前端需要用到的数据 (Optional) */
NodeIcon string `json:"nodeIcon"`
/* 工作流Code */
FlowCode string `json:"flowCode"`
/* 脚本文件的业务Code (Optional) */
FileCode string `json:"fileCode"`
/* 作业名称 (Optional) */
JobName string `json:"jobName"`
/* 是否工作流任务 (Optional) */
IsUranus int `json:"isUranus"`
/* 是否当前工作流任务 (Optional) */
IsCurrentFlow int `json:"isCurrentFlow"`
/* 给前端用到的 (Optional) */
Parent []UranusTaskNodeSaveReq `json:"parent"`
/* 是否有子任务依赖前端用到 (Optional) */
HaveChildren int `json:"haveChildren"`
/* 协作人 (Optional) */
Cooperator string `json:"cooperator"`
}
type UranusTaskParamDTO ¶
type UranusTaskParamReq ¶
type UranusTaskParamReq struct {
/* 排序 (Optional) */
ParamSort *int `json:"paramSort"`
/* key (Optional) */
ParamKey *string `json:"paramKey"`
/* value (Optional) */
ParamValue *string `json:"paramValue"`
/* 描述 (Optional) */
ParamDesc *string `json:"paramDesc"`
/* 参数类型 ORDINARY:普通参数,VARIABLE_IMPORT:变量输入参数,VARIABLE_EXPORT:变量输出参数 (Optional) */
ParamType *string `json:"paramType"`
}
type UranusTriggerConfigDTO ¶
type UranusTriggerConfigDTO struct {
/* (Optional) */
ConditionType string `json:"conditionType"`
/* (Optional) */
SecondaryType string `json:"secondaryType"`
/* (Optional) */
ServerDomain string `json:"serverDomain"`
/* (Optional) */
ServerPort string `json:"serverPort"`
/* (Optional) */
Username string `json:"username"`
/* (Optional) */
UsernamePwd string `json:"usernamePwd"`
/* (Optional) */
Protocol string `json:"protocol"`
/* (Optional) */
DatabaseName string `json:"databaseName"`
/* (Optional) */
DataSource string `json:"dataSource"`
/* (Optional) */
Object string `json:"object"`
/* (Optional) */
ConditionConfig string `json:"conditionConfig"`
/* (Optional) */
TriggerTime string `json:"triggerTime"`
/* (Optional) */
TriggerInterval int `json:"triggerInterval"`
/* (Optional) */
BeginTime string `json:"beginTime"`
/* (Optional) */
EndTime string `json:"endTime"`
}
type UranusUploaderChunkReq ¶
type UranusUploaderChunkReq struct {
/* 文件类型 (Optional) */
FileTypeCode int `json:"fileTypeCode"`
/* 是否spark-jar的管理模块,spark-jar操作hdfs通过字段区分 (Optional) */
IsJarManagement bool `json:"isJarManagement"`
/* 任务流Code */
FlowCode string `json:"flowCode"`
/* 文件夹上传的时候文件的相对路径属性 (Optional) */
RelativePath string `json:"relativePath"`
/* 文件唯一标识 (Optional) */
UploadId string `json:"uploadId"`
/* 当前块的次序,第一个块是 1,注意不是从 0 开始的 (Optional) */
ChunkNumber int `json:"chunkNumber"`
/* 文件被分成块的总数 (Optional) */
TotalChunks int `json:"totalChunks"`
/* 分块大小,根据 totalSize 和这个值你就可以计算出总共的块数。注意最后一块的大小可能会比这个要大 (Optional) */
ChunkSize int64 `json:"chunkSize"`
/* 当前块的大小,实际大小 (Optional) */
CurrentChunkSize int64 `json:"currentChunkSize"`
/* 文件总大小 (Optional) */
TotalSize int64 `json:"totalSize"`
/* 文件名 */
Filename string `json:"filename"`
/* (Optional) */
File string `json:"file"`
/* 文件字节数组 (Optional) */
FileBytes []string `json:"fileBytes"`
/* partETagList (Optional) */
PartETagList []UranusUploaderPartETag `json:"partETagList"`
}
type UranusUploaderPartETag ¶
type UranusUploaderReq ¶
type UranusUploaderReq struct {
/* 文件类型 (Optional) */
FileType int `json:"fileType"`
/* 是否spark-jar的管理模块,spark-jar操作hdfs通过字段区分 (Optional) */
IsJarManagement bool `json:"isJarManagement"`
/* 文件Code (Optional) */
FileCode string `json:"fileCode"`
/* 父节点 Code (Optional) */
ParentCode string `json:"parentCode"`
/* 文件名称 (Optional) */
FileName string `json:"fileName"`
/* 任务流Code */
FlowCode string `json:"flowCode"`
/* 文件夹上传的时候文件的相对路径属性 (Optional) */
RelativePath string `json:"relativePath"`
/* 是否上传完成 0 上传取消 1 上传完成 (Optional) */
IsUpload int `json:"isUpload"`
}
type UserRoleInfo ¶
type UtteranceVo ¶
type UtteranceVo struct {
/* 发言id (Optional) */
UtteranceId string `json:"utteranceId"`
/* 对话id (Optional) */
ChatId string `json:"chatId"`
/* 发言角色 (Optional) */
UtteranceRole string `json:"utteranceRole"`
/* 发言内容 (Optional) */
Content string `json:"content"`
/* 创建时间 (Optional) */
CreateTime int64 `json:"createTime"`
}
type WatchmanVo ¶
type WatchmanVo struct {
/* 值班人id (Optional) */
Id int64 `json:"id"`
/* 值班人名称 (Optional) */
Name string `json:"name"`
/* 值班人Pin (Optional) */
Pin string `json:"pin"`
/* 值班人Erp (Optional) */
Erp string `json:"erp"`
/* 值班人手机号 (Optional) */
PhoneNumber string `json:"phoneNumber"`
/* 值班人邮箱地址 (Optional) */
Email string `json:"email"`
/* 创建时间 (Optional) */
CreateTime int64 `json:"createTime"`
/* 更新时间 (Optional) */
UpdateTime int64 `json:"updateTime"`
}
type WorkspaceBundleProjectReq ¶
type WorkspaceBundleProjectReq struct {
/* 工作空间code (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* 引擎类型 (Optional) */
EngineType string `json:"engineType"`
/* (Optional) */
BundleDevProjectReq BundleProjectReq `json:"bundleDevProjectReq"`
/* (Optional) */
BundleProdProjectReq BundleProjectReq `json:"bundleProdProjectReq"`
}
type WorkspaceCreateReq ¶
type WorkspaceCreateReq struct {
/* (Optional) */
UserPin string `json:"userPin"`
/* (Optional) */
WorkspaceId string `json:"workspaceId"`
/* (Optional) */
WorkspaceName string `json:"workspaceName"`
/* (Optional) */
Manager []string `json:"manager"`
/* (Optional) */
WorkspaceDescription string `json:"workspaceDescription"`
/* (Optional) */
WorkspaceModel string `json:"workspaceModel"`
/* (Optional) */
EngineType string `json:"engineType"`
/* (Optional) */
CalculateResourceCode []string `json:"calculateResourceCode"`
/* (Optional) */
IntegrationResourceCode []string `json:"integrationResourceCode"`
/* (Optional) */
NeedBundleProject bool `json:"needBundleProject"`
/* (Optional) */
BundleDevProjectReq BundleProjectReq `json:"bundleDevProjectReq"`
/* (Optional) */
BundleProdProjectReq BundleProjectReq `json:"bundleProdProjectReq"`
}
type WorkspaceInfoResp ¶
type WorkspaceInfoResp struct {
/* (Optional) */
Id int `json:"id"`
/* (Optional) */
WorkspaceName string `json:"workspaceName"`
/* (Optional) */
WorkspaceDescription string `json:"workspaceDescription"`
/* (Optional) */
WorkspaceModel string `json:"workspaceModel"`
/* (Optional) */
WorkspaceId string `json:"workspaceId"`
/* (Optional) */
AccountId string `json:"accountId"`
}
type WorkspaceListResp ¶
type WorkspaceListResp struct {
/* (Optional) */
Id int `json:"id"`
/* (Optional) */
WorkspaceName string `json:"workspaceName"`
/* (Optional) */
WorkspaceDescription string `json:"workspaceDescription"`
/* (Optional) */
WorkspaceModel string `json:"workspaceModel"`
/* (Optional) */
WorkspaceId string `json:"workspaceId"`
/* (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* (Optional) */
Managers []string `json:"managers"`
/* (Optional) */
ManagerPins []string `json:"managerPins"`
/* (Optional) */
MemberNum int `json:"memberNum"`
/* (Optional) */
CreatedDate string `json:"createdDate"`
/* (Optional) */
ModifiedDate string `json:"modifiedDate"`
}
type WorkspaceResourcesReq ¶
type WorkspaceUserReq ¶
type WorkspaceUserReq struct {
/* (Optional) */
PageNum int `json:"pageNum"`
/* (Optional) */
PageSize int `json:"pageSize"`
/* (Optional) */
Id int64 `json:"id"`
/* (Optional) */
UserName string `json:"userName"`
/* (Optional) */
NickName string `json:"nickName"`
/* (Optional) */
UserPin string `json:"userPin"`
/* (Optional) */
WorkspaceCode string `json:"workspaceCode"`
/* (Optional) */
CompanyCode string `json:"companyCode"`
}
type WorkspaceUserResp ¶
type WorkspaceUserResp struct {
/* (Optional) */
Id int64 `json:"id"`
/* (Optional) */
UserPin string `json:"userPin"`
/* (Optional) */
UserName string `json:"userName"`
/* (Optional) */
NickName string `json:"nickName"`
/* (Optional) */
UserRoleList []string `json:"userRoleList"`
/* (Optional) */
UpdateDate string `json:"updateDate"`
}
Source Files
¶
- AddMemberReq.go
- AddWatchmanParam.go
- BindInfo.go
- BundleOrUnBundleResourceReq.go
- BundleProjectReq.go
- CancelPublishObjParam.go
- ChangeWorkspaceStatusReq.go
- ChatVo.go
- CheckFunctionInfoReq.go
- CreateFunctionCatalogReq.go
- CreateFunctionReq.go
- CreateProjectResourceParam.go
- CreateWorkspaceProductParam.go
- DataDownloadParam.go
- DataLoadHistory.go
- DataLoadHistoryParam.go
- DataLoadHistoryResult.go
- DataLoadKillParam.go
- DataLoadLogParam.go
- DataLoadParam.go
- DataLoadPreviewParam.go
- DefinedFunctionVo.go
- DeleteFunctionCatalogReq.go
- DeleteFunctionReq.go
- DeleteMemberReq.go
- DeleteWatchmanParam.go
- EditWorkspaceReq.go
- ExtraRunnerParamReq.go
- ExtraRunnerReq.go
- FunctionCatalogVo.go
- GpdjmcCalcJobDTO.go
- GpdjmcCalcJobResultDTO.go
- GpdjmcConfPairStringString.go
- GpdjmcDelAllReqDTO.go
- GpdjmcDeleteScriptReq.go
- GpdjmcDmrModelDTO.go
- GpdjmcDmrModelJobQueryDTO.go
- GpdjmcDmrModelJobRDTO.go
- GpdjmcDmrScriptInfoDTO.go
- GpdjmcEngineTemplateDTO.go
- GpdjmcGitFileDTO.go
- GpdjmcInputParam.go
- GpdjmcJobDeleteDTO.go
- GpdjmcJobNaRemarkDTO.go
- GpdjmcJobNameDTO.go
- GpdjmcJobQueryDTO.go
- GpdjmcLoopListParam.go
- GpdjmcLoopParam.go
- GpdjmcMgrDictDTO.go
- GpdjmcOutputParam.go
- GpdjmcRpcResponseBoolean.go
- GpdjmcRpcResponseCalcJobResultDTO.go
- GpdjmcRpcResponseDmrScriptInfoDTO.go
- GpdjmcRpcResponseInteger.go
- GpdjmcRpcResponseListDmrModelJobRDTO.go
- GpdjmcRpcResponseListEngineTemplateDTO.go
- GpdjmcRpcResponseListInteger.go
- GpdjmcRpcResponseListSchedJobDTO.go
- GpdjmcRpcResponseListSchedJobDepDTO.go
- GpdjmcRpcResponseListSchedJobResDTO.go
- GpdjmcRpcResponseListString.go
- GpdjmcRpcResponseScriptInfoTypeDTO.go
- GpdjmcSchedJobDTO.go
- GpdjmcSchedJobDepDTO.go
- GpdjmcSchedJobResDTO.go
- GpdjmcScriptFileDTO.go
- GpdjmcScriptInfoTemplateDTO.go
- GpdjmcScriptInfoTypeDTO.go
- GpdjmcTableInfoDTO.go
- GpdjmcTriggerConfigDTO.go
- GpdjmcWorkspaceInfoDTO.go
- GpdpJobDepChainReq.go
- GpdpJobDependenceReq.go
- GpdpJobDependencyResultDTO.go
- GpdpJobDetailResultDTO.go
- GpdpPageInfoJobDependencyResultDTO.go
- GpdpSchedTriggerDependTree.go
- GpdrAfreshAddLogVo.go
- GpdrAfreshAddParam.go
- GpdrCloseTaskReq.go
- GpdrListHisRunTaskResDTO.go
- GpdrListTaskLogReq.go
- GpdrListTaskReq.go
- GpdrOpenApiRespInteger.go
- GpdrOpenApiRespString.go
- GpdrOpenApiResponsePageInfoAfreshAddLogVo.go
- GpdrOpenApiResponsePageInfoListHisRunTaskResDTO.go
- GpdrPageInfoAfreshAddLogVo.go
- GpdrPageInfoListHisRunTaskResDTO.go
- GpjmConditionInfo.go
- GpjmConditionType.go
- GpjmJobBasicInfoDTO.go
- GpjmJobBasicInfoResultDTO.go
- GpjmJobCommonInfoDTO.go
- GpjmJobCompletionResultDTO.go
- GpjmJobInfoReq.go
- GpjmJobMonitorInfoDTO.go
- GpjmJobOperationRecordReq.go
- GpjmJobQueryReq.go
- GpjmJobRunInfoResultDTO.go
- GpjmJobTypeInfoDto.go
- GpjmListJobInstanceReq.go
- GpjmListJobInstanceResultDTO.go
- GpjmListJobReq.go
- GpjmListJobResultDTO.go
- GpjmMgrJob.go
- GpjmMgrOperationRecords.go
- GpjmPageInfoJobRunInfoResultDTO.go
- GpjmPageInfoListJobInstanceResultDTO.go
- GpjmPageInfoListJobResultDTO.go
- GpjmPageInfoMgrOperationRecords.go
- GpjmRunRoleInfoDTO.go
- GpjmobQueryReq.go
- GpjsClusterInfoReq.go
- GpjsIsUpstreamSameFrequencyDTO.go
- GpjsJobDelInfoReq.go
- GpjsJobEnableReq.go
- GpjsJobExeResultReq.go
- GpjsResetJobInstReq.go
- GpjsSchedJobRunVo.go
- GpjsSchedQueuePendingDto.go
- GpjsScriptExtensionDto.go
- GpmdCalcJobResultDTO.go
- GpmdConfPairStringString.go
- GpmdJobQueryReq.go
- GpmdOpenApiResponseCalcJobResultDTO.go
- GpmdSchedJobDTO.go
- GpmdTriggerConfigDTO.go
- GpmnJobCountDto.go
- GpmnJobSpendTimeRankingVo.go
- GpmnJobUnsuccessRankingVo.go
- GpmnLineData.go
- GpmnLineDataVo.go
- GpmnLineStringDataVo.go
- GpmnPieData.go
- GpmnWorkTableJobStatusDto.go
- GpmnWorkTableJobStatusReq.go
- GpsdSchedDict.go
- GpsdSchedDictRelationDto.go
- GpsdalueDict.go
- GpsmArrayObjectRequestResetJobInstReq.go
- GpsmDownloadJobLogReq.go
- GpsmJobAllqueryInfoDto.go
- GpsmJobLogInfoPageQryReq.go
- GpsmJobNameDTO.go
- GpsmJobQueryReq.go
- GpsmJobStateBatchReq.go
- GpsmKillJobInstReq.go
- GpsmMgrJob.go
- GpsmOpenApiResponsePageInfoObject.go
- GpsmPageInfoObject.go
- GpsmReRunJobBatchReq.go
- GpsmResetJobInstReq.go
- GpsmSchedJob.go
- GpsmSchedJobWithLogDto.go
- GpuserMatchUserReq.go
- GpuserMatchUserResDto.go
- JcwSpaceDetailRequest.go
- JcwSpaceIncreUsedByDayVo.go
- JcwSpacePartUsedVo.go
- JcwSpaceSummaryVo.go
- JcwSpaceUsedDetailVo.go
- JobBasicInfoVo.go
- JobCommonInfoVo.go
- JobInfoVo.go
- JobKillParam.go
- JobLogParam.go
- JobMonitorInfoVo.go
- JobNameDO.go
- JobOperateHistoryVo.go
- JobPropertyVo.go
- JobRelationVo.go
- JobRerunFailedReason.go
- JobRerunParam.go
- JobRerunResult.go
- JobResetDO.go
- JobResetParam.go
- JobRunHistoryParam.go
- JobRunHistoryVo.go
- JobRunInfoVo.go
- JobTxDateStatusVo.go
- JobTypeVo.go
- JtlasDestroyRequestReq.go
- JtlasDestroyResp.go
- JtlasDownloadTableColumnsResp.go
- JtlasFuzzyQueryTablesByDatabaseNameResp.go
- JtlasFuzzyQueryTablesByTableNameReq.go
- JtlasFuzzyQueryTablesByTableNameResp.go
- JtlasGetTableDDLScriptResp.go
- JtlasGetTableQueryScriptResp.go
- JtlasGrantTablePrivilegesReq.go
- JtlasGrantTablePrivilegesResp.go
- JtlasPageSearchTablePartitionsReq.go
- JtlasPageSearchTablePartitionsResp.go
- JtlasPageSearchTablePrivilegeReq.go
- JtlasPageSearchTablePrivilegesResp.go
- JtlasPageSearchTableReq.go
- JtlasPageSearchTableResp.go
- JtlasSearchAggregation.go
- JtlasSearchColumnLineageReq.go
- JtlasSearchColumnLineageResp.go
- JtlasSearchDetailResp.go
- JtlasSearchEdge.go
- JtlasSearchNode.go
- JtlasSearchTable.go
- JtlasSearchTableColumn.go
- JtlasSearchTableDoc.go
- JtlasSearchTableLineageReq.go
- JtlasSearchTableLineageResp.go
- JtlasSearchTableParam.go
- JtlasSearchTablePartition.go
- JtlasSearchTablePrivilege.go
- JtlasSubscribeTableReq.go
- JtlasSubscribeTableResp.go
- JtlasTableDetailReq.go
- JtlasTableDetailResp.go
- JtlasTableFuuzyUnderSpecifiedUserWithPrivilegesReq.go
- JtlasTableFuuzyUnderSpecifiedUserWithPrivilegesResp.go
- JtlasTableOwnedByUserReq.go
- JtlasTableOwnedByUserResp.go
- JtlasTablePrivilegesReq.go
- JtlasTablePrivilegesResp.go
- JtlasTableUnderSpecifiedUserReq.go
- JtlasTableUnderSpecifiedUserResp.go
- JtlasTableUnderSpecifiedUserWithPrivilegesReq.go
- JtlasTableUnderSpecifiedUserWithPrivilegesResp.go
- JtlasWarehouseTable.go
- JtlasWarehouseTableColumn.go
- JtlasWarehouseTableParam.go
- JtlasWarehouseTablePartition.go
- JtlasWarehouseTablePrivilege.go
- ListJobOperateHistoryParam.go
- ListJobParam.go
- ListJobRelationParam.go
- ListPublishObjByPageParam.go
- ListPublishPkgByPageParam.go
- ListTxDateStatusParam.go
- LoopParam.go
- ModelVo.go
- OneClickRerunParam.go
- OneClickRerunPreviewVo.go
- OrderUniqueKey.go
- OwnerIntegrationResource.go
- PackagePublishObjParam.go
- PageInfoResourceResp.go
- PageInfoUcUsersResp.go
- PageInfoWorkspaceListResp.go
- PageInfoWorkspaceUserResp.go
- PageVoJcwSpacePartUsedVo.go
- PageVoJobInfoVo.go
- PageVoJobOperateHistoryVo.go
- PageVoJobRelationVo.go
- PageVoJobRunHistoryVo.go
- PageVoJobTxDateStatusVo.go
- PageVoRerunBatchVo.go
- PageVoRerunTaskVo.go
- PageVoStorageSpaceUsedDetailVo.go
- PageVoString.go
- PartitionInfo.go
- PreviewPackageParam.go
- PreviewPackageVo.go
- ProjectResp.go
- PublishObjDetailVo.go
- PublishObjPageVo.go
- PublishObjVo.go
- PublishPkgDetailVo.go
- PublishPkgPageVo.go
- PublishPkgParam.go
- PublishPkgVo.go
- QueryPublishObjDetailParam.go
- QueryPublishPkgDetailParam.go
- QueryWorkspaceInfoReq.go
- QueryWorkspaceListReq.go
- RejectPublishPkgParam.go
- RerunBatchParam.go
- RerunBatchVo.go
- RerunTaskParam.go
- RerunTaskReSubmitParam.go
- RerunTaskVo.go
- ResourceBriefInfoVo.go
- ResourceCloseReq.go
- ResourceCreateReq.go
- ResourceDeleteReq.go
- ResourceInfo.go
- ResourceResp.go
- ResourceUpdateReq.go
- RosterDO.go
- RosterVo.go
- Row.go
- SparkJarRunParams.go
- StopExpireOrDeleteReq.go
- SyncWsProductOrderReq.go
- TableBriefInfo.go
- TableDelimiterVo.go
- TableDelimitersVo.go
- TaskDependPageListReq.go
- TaskInfoLoopReq.go
- TaskInfoSparkJarReq.go
- TaskLoopElementDelimiterVo.go
- UcUsersResp.go
- UnbundleProjectReq.go
- UpdateFunctionReq.go
- UpdateRosterParam.go
- UpdateUserRoleReq.go
- UpdateWatchmanParam.go
- UploaderInitRes.go
- UranusAnalysisScriptReq.go
- UranusAnalysisScriptRes.go
- UranusCatalogInfo.go
- UranusCatalogInfoCode.go
- UranusCatalogInfoList.go
- UranusColumnReq.go
- UranusColumnSaveOrUpdate.go
- UranusDdlAnalyzeReq.go
- UranusDictRes.go
- UranusDictVO.go
- UranusFileManagerRes.go
- UranusFunctionManagerRes.go
- UranusNodePublishChildReq.go
- UranusPageResultContentSchedTaskInfoHistoryRes.go
- UranusPageResultContentScriptRunLogRes.go
- UranusPageResultContentTaskNodePageRes.go
- UranusParamReq.go
- UranusPublishChangeTypeRes.go
- UranusResourceVo.go
- UranusResultBoolean.go
- UranusResultDefinedFunctionVo.go
- UranusResultFunctionCatalogVoList.go
- UranusResultInteger.go
- UranusResultLinkedHashMapObjectObject.go
- UranusResultListAnalysisScriptRes.go
- UranusResultListCatalogInfoCode.go
- UranusResultListCatalogInfoList.go
- UranusResultListColumnReq.go
- UranusResultListDictRes.go
- UranusResultListDictVO.go
- UranusResultListElementDelimiters.go
- UranusResultListFileManagerRes.go
- UranusResultListFunctionManagerRes.go
- UranusResultListObject.go
- UranusResultListSchedJobDTO.go
- UranusResultListSparkJarManagerRes.go
- UranusResultListString.go
- UranusResultListTaskFlowDetailRes.go
- UranusResultListTaskFlowListRes.go
- UranusResultListTaskInfoRes.go
- UranusResultListTaskNodePreRes.go
- UranusResultListTaskNodeRes.go
- UranusResultListTaskParamReq.go
- UranusResultPageResultContentSchedTaskInfoHistoryRes.go
- UranusResultPageResultContentScriptRunLogRes.go
- UranusResultPageResultContentTaskNodePageRes.go
- UranusResultRes.go
- UranusResultResListString.go
- UranusResultResourceBriefInfoVo.go
- UranusResultResourceVo.go
- UranusResultScriptRunLogRes.go
- UranusResultString.go
- UranusResultTableBriefInfoRes.go
- UranusResultTableDelimitersVo.go
- UranusResultTableQuery.go
- UranusResultTableSaveOrUpdate.go
- UranusResultTaskFlowDetailRes.go
- UranusResultTaskInfo.go
- UranusResultTaskInfoPrePublishRes.go
- UranusResultTaskNodeDetailRes.go
- UranusResultTaskNodeParamRes.go
- UranusResultTaskNodeRSaveReq.go
- UranusResultUploaderChunkCheckerRes.go
- UranusResultUploaderInitRes.go
- UranusRunnerReq.go
- UranusRunnerResultReq.go
- UranusSchedJobDTO.go
- UranusSchedTaskInfoHistoryRes.go
- UranusScriptFileVerifyReq.go
- UranusScriptParamReq.go
- UranusScriptRunLogListReq.go
- UranusScriptRunLogRes.go
- UranusSparkJarManagerRes.go
- UranusTableQuery.go
- UranusTableSaveOrUpdate.go
- UranusTaskFlowCheckReq.go
- UranusTaskFlowCollectionReq.go
- UranusTaskFlowDelReq.go
- UranusTaskFlowDetailRes.go
- UranusTaskFlowInfo.go
- UranusTaskFlowListRes.go
- UranusTaskFlowTreeReq.go
- UranusTaskFlowUpdateReq.go
- UranusTaskFuzzyReq.go
- UranusTaskInfo.go
- UranusTaskInfoDTO.go
- UranusTaskInfoFileReq.go
- UranusTaskInfoHistoryReq.go
- UranusTaskInfoNodeReq.go
- UranusTaskInfoPrePublishRes.go
- UranusTaskInfoPublishReq.go
- UranusTaskInfoRePublishReq.go
- UranusTaskInfoRes.go
- UranusTaskNodeChangeRes.go
- UranusTaskNodeDetailRes.go
- UranusTaskNodePagePublishReq.go
- UranusTaskNodePageReq.go
- UranusTaskNodePageRes.go
- UranusTaskNodeParamRes.go
- UranusTaskNodePreRes.go
- UranusTaskNodePublishOReq.go
- UranusTaskNodeRSaveReq.go
- UranusTaskNodeRes.go
- UranusTaskNodeSaveReq.go
- UranusTaskNodeUpdateReq.go
- UranusTaskNodeUpdateStatusListReq.go
- UranusTaskNodeUpdateStatusReq.go
- UranusTaskParamDTO.go
- UranusTaskParamReq.go
- UranusTriggerConfigDTO.go
- UranusUploaderChunkCheckerRes.go
- UranusUploaderChunkReq.go
- UranusUploaderPartETag.go
- UranusUploaderReq.go
- UserRoleInfo.go
- UtteranceVo.go
- WatchmanVo.go
- WorkspaceBundleProjectReq.go
- WorkspaceCreateReq.go
- WorkspaceInfoResp.go
- WorkspaceListResp.go
- WorkspaceResourcesReq.go
- WorkspaceUserReq.go
- WorkspaceUserResp.go
- WorkspaceUserRoleResp.go
Click to show internal directories.
Click to hide internal directories.