MCPcopy Create free account

hub / github.com/LianjiaTech/kob / functions

Functions688 in github.com/LianjiaTech/kob

↓ 1 callersMethoddeleteOne
删除等待执行任务 @param taskUuid @param prefix @return
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskWaitingMapper.java:86
↓ 1 callersMethoddeleteProjectUser
删除用户 @param projectCode 项目标识 @param id 删除id @return 影响行数
server/core/src/main/java/com/ke/schedule/server/core/service/ManagerService.java:59
↓ 1 callersMethoddestroy
()
server/console/src/main/java/com/ke/schedule/server/console/configuration/OperationFilter.java:63
↓ 1 callersMethoddispatcher
(ClientContext context, String parent, List<String> childs)
client/spring/src/main/java/com/ke/schedule/client/spring/core/TaskDispatcher.java:25
↓ 1 callersMethoddispatcher0
(ClientContext client, String parentPath, String child)
client/spring/src/main/java/com/ke/schedule/client/spring/core/TaskDispatcher.java:39
↓ 1 callersMethoddispatcher1
(ClientContext client, TaskContext.Path path, String full)
client/spring/src/main/java/com/ke/schedule/client/spring/core/TaskDispatcher.java:57
↓ 1 callersMethoddoSelect
节点唯一标识hash算法 将字符串变成数字 根据长度取余数形成环装选择进行选取 排序后节点数组 @param nodeList 节点标识列表 @param uuid 作业uuid @return 选取节点
server/core/src/main/java/com/ke/schedule/server/core/common/NodeHashLoadBalance.java:25
↓ 1 callersFunctione
(i)
server/console/src/main/resources/static/plugins/raphael/raphael.min.js:1
↓ 1 callersFunctione
()
server/console/src/main/resources/static/plugins/bootstrap/bootstrap.min.js:6
↓ 1 callersMethodeditJobCron
(JobCron editJobCron)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:62
↓ 1 callersMethoderror502
(String taskContext, String clientIdentification)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:32
↓ 1 callersMethoderror503
()
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:37
↓ 1 callersMethoderror507
(String zkServers, Integer timeout)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:54
↓ 1 callersMethoderror508
()
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:60
↓ 1 callersMethoderror510
()
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:69
↓ 1 callersMethoderror9101
(String s)
server/core/src/main/java/com/ke/schedule/server/core/common/AdminLogConstant.java:19
↓ 1 callersMethodexception2String
(Exception e)
basic/src/main/java/com/ke/schedule/basic/support/KobUtils.java:85
↓ 1 callersMethodexistProject
项目是否存在 @param projectCode 项目标识 @return 项目是否存在
server/core/src/main/java/com/ke/schedule/server/core/service/IndexService.java:43
↓ 1 callersFunctionf
(b)
server/console/src/main/resources/static/plugins/artTemplate/template.js:2
↓ 1 callersFunctionf
()
server/console/src/main/resources/static/plugins/bootstrap/bootstrap.min.js:7
↓ 1 callersFunctionfa
(a)
server/console/src/main/resources/static/plugins/jquery/jquery.min.js:3
↓ 1 callersFunctionfb
(a,b)
server/console/src/main/resources/static/plugins/jquery/jquery.min.js:3
↓ 1 callersFunctionfiltered
(js, filter)
server/console/src/main/resources/static/plugins/artTemplate/template-debug.js:597
↓ 1 callersMethodfindByTaskUuid
(@Param("taskUuid") String taskUuid, @Param("prefix") String prefix)
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskRecordMapper.java:47
↓ 1 callersMethodfindCronJobBySuspend
根据状态查询cron类型作业 @param suspend 暂停状态 暂停true|运行false @param prefix 集群名称 @return
server/core/src/main/java/com/ke/schedule/server/core/mapper/JobCronMapper.java:69
↓ 1 callersMethodfindNextWhiteSpace
(int i, String s)
server/core/src/main/java/com/ke/schedule/server/core/common/CronExpression.java:939
↓ 1 callersMethodfindRunningCronJob
(String mp)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:22
↓ 1 callersMethodfireExpire
()
client/spring/src/main/java/com/ke/schedule/client/spring/core/ClientFunction.java:42
↓ 1 callersMethodfireExpireTask
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/ExpireTask.java:43
↓ 1 callersMethodfireExpireTask0
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/ExpireTask.java:47
↓ 1 callersMethodfireOverstockTask
(List<TaskContext.Path> overstockTask)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:30
↓ 1 callersFunctiong
(b)
server/console/src/main/resources/static/plugins/bootstrap/bootstrap.min.js:6
↓ 1 callersFunctiongb
(a,b,c)
server/console/src/main/resources/static/plugins/jquery/jquery.min.js:3
↓ 1 callersMethodgetClientNodes
(String projectCode)
server/core/src/main/java/com/ke/schedule/server/core/service/NodeService.java:15
↓ 1 callersMethodgetClientPath
()
basic/src/main/java/com/ke/schedule/basic/model/ClientData.java:36
↓ 1 callersMethodgetClientPaths
(String projectCode)
server/core/src/main/java/com/ke/schedule/server/core/service/NodeService.java:17
↓ 1 callersFunctiongetFieldIndex
(columns, field)
server/console/src/main/resources/static/plugins/tree/bootstraptable-treeview.js:25
↓ 1 callersMethodgetLocalAddress0
()
basic/src/main/java/com/ke/schedule/basic/support/IpUtils.java:49
↓ 1 callersMethodgetNodeServerList
()
server/core/src/main/java/com/ke/schedule/server/core/service/NodeService.java:13
↓ 1 callersMethodgetNumericValue
(String s, int i)
server/core/src/main/java/com/ke/schedule/server/core/common/CronExpression.java:1119
↓ 1 callersFunctiongetSize
()
server/console/src/main/resources/static/plugins/bootstrap-select/js/bootstrap-select.js:991
↓ 1 callersMethodgetUserConfiguration
Json配置信息 @return Json配置信息
server/core/src/main/java/com/ke/schedule/server/core/model/db/ProjectUser.java:68
↓ 1 callersFunctiongetVariable
(code)
server/console/src/main/resources/static/plugins/artTemplate/template-debug.js:342
↓ 1 callersMethodgetZkPath
()
basic/src/main/java/com/ke/schedule/basic/model/TaskContext.java:26
↓ 1 callersFunctionh
(a,b)
server/console/src/main/resources/static/plugins/artTemplate/template.js:2
↓ 1 callersMethodhandleExpireTask
(TaskRecord taskExpire, String cluster)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:36
↓ 1 callersMethodhandleLogger
处理日志信息 @param context 上报日志
server/core/src/main/java/com/ke/schedule/server/core/service/CollectService.java:19
↓ 1 callersMethodhandleRetryFailTask
处理失败重试任务 这里代码一把唆了 后期需要方法共用 @param logContext 日志内容 @param taskRecord 任务记录 @param appendRetryTaskUuid 追加重试任务的task_uuid
server/core/src/main/java/com/ke/schedule/server/core/service/impl/ScheduleServiceImpl.java:255
↓ 1 callersMethodhandleTaskLog
(LogContext context, TaskRecord taskRecord)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:38
↓ 1 callersMethodheartbeat
()
client/spring/src/main/java/com/ke/schedule/client/spring/core/ClientProcessor.java:64
↓ 1 callersMethodheartbeat0
()
client/spring/src/main/java/com/ke/schedule/client/spring/core/ClientProcessor.java:75
↓ 1 callersFunctioni
(t)
server/console/src/main/resources/static/plugins/footable/footable.grid.min.js:1
↓ 1 callersFunctioni
(i,o,n)
server/console/src/main/resources/static/plugins/footable/footable.min.js:14
↓ 1 callersFunctioni
(e,a)
server/console/src/main/resources/static/plugins/footable/footable.bookmarkable.min.js:1
↓ 1 callersFunctionie
(e)
server/console/src/main/resources/static/plugins/sweetalert2/sweetalert2.min.js:1
↓ 1 callersMethodinfo100
(String taskContext, String clientIdentification)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:112
↓ 1 callersMethodinfo101
(String projectCode, String ip, String zkServers, String adminUrl, Map<String, String> tasks)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:117
↓ 1 callersMethodinfo102
(Long period, Integer workers, Integer threads)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:143
↓ 1 callersMethodinitDateByDay
()
basic/src/main/java/com/ke/schedule/basic/support/KobUtils.java:76
↓ 1 callersMethodinitProject
初始化项目信息 @param userCode 用户账号 @param userName 用户姓名 @param configuration 用户配置 @param projectCode 项目标识 @param projectName 项目名称
server/core/src/main/java/com/ke/schedule/server/core/service/IndexService.java:35
↓ 1 callersMethodinsertBatch
批量插入等待执行任务表 @param taskWaitingList 待推送作业list @param prefix 集群名称 @return 插入条数
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskWaitingMapper.java:63
↓ 1 callersMethodinsertProjectUser
保存项目用户 @param projectUser 项目标识 @return 影响行数
server/core/src/main/java/com/ke/schedule/server/core/service/ManagerService.java:50
↓ 1 callersMethodisComplete
(int state)
basic/src/main/java/com/ke/schedule/basic/constant/TaskRecordStateConstant.java:56
↓ 1 callersMethodisExclude
(String path)
server/console/src/main/java/com/ke/schedule/server/console/configuration/OperationFilter.java:68
↓ 1 callersFunctionisIEBrowser
()
server/console/src/main/resources/static/plugins/tree/bootstrap-table.js:220
↓ 1 callersFunctionj
(a)
server/console/src/main/resources/static/plugins/artTemplate/template.js:2
↓ 1 callersMethodjobCronGenerateWaitingTask
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/CornJob.java:55
↓ 1 callersFunctionl
(e,t,a)
server/console/src/main/resources/static/plugins/footable/footable.all.min.js:14
↓ 1 callersFunctionl
(e,t,a)
server/console/src/main/resources/static/plugins/footable/footable.grid.min.js:1
↓ 1 callersFunctionlogic
(code)
server/console/src/main/resources/static/plugins/artTemplate/template-debug.js:489
↓ 1 callersFunctionn
(t,a,o)
server/console/src/main/resources/static/plugins/footable/footable.all.min.js:14
↓ 1 callersFunctionn
(t,a,o)
server/console/src/main/resources/static/plugins/footable/footable.grid.min.js:1
↓ 1 callersFunctionna
(a)
server/console/src/main/resources/static/plugins/jquery/jquery.min.js:2
↓ 1 callersFunctiono
(t,o)
server/console/src/main/resources/static/plugins/footable/footable.all.min.js:14
↓ 1 callersFunctiono
(t,o)
server/console/src/main/resources/static/plugins/footable/footable.grid.min.js:1
↓ 1 callersMethodpool
(Integer threads)
client/spring/src/main/java/com/ke/schedule/client/spring/core/ClientContext.java:110
↓ 1 callersFunctionpost
(url, params, callback)
server/console/src/main/resources/static/kob/kob.js:139
↓ 1 callersMethodpushTask
(TaskWaiting tw, String identification)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:66
↓ 1 callersMethodpushWaitingTask
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/WaitingTask.java:58
↓ 1 callersMethodpushWaitingTask0
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/WaitingTask.java:62
↓ 1 callersFunctionr
(t)
server/console/src/main/resources/static/plugins/footable/footable.grid.min.js:1
↓ 1 callersMethodrecoveryOverstockTask
(String projectCode)
server/processor/src/main/java/com/ke/schedule/server/processor/component/WaitingTask.java:75
↓ 1 callersMethodrunner
(Map<String, Object> beans)
client/spring/src/main/java/com/ke/schedule/client/spring/core/ClientContext.java:93
↓ 1 callersMethodsaveJobCron
(JobCron jobCron)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:60
↓ 1 callersMethodsaveJobRealTime
(TaskWaiting taskWaiting)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:48
↓ 1 callersMethodsaveLogOpt
保存操作日志 @param logOpt 操作日志 @return 影响行数
server/core/src/main/java/com/ke/schedule/server/core/service/LoggerService.java:63
↓ 1 callersMethodselectByCodeAndPwd
根据 code & pwd 查询用户 @param code 用户标识 @param pwd 用户密码 @param prefix prefix @return 用户对象
server/core/src/main/java/com/ke/schedule/server/core/mapper/UserMapper.java:32
↓ 1 callersMethodselectByUserCode
获取当前用户所有项目 @param userCode 用户标识 @param prefix 集群名称 @return 项目成员列表
server/core/src/main/java/com/ke/schedule/server/core/mapper/ProjectUserMapper.java:74
↓ 1 callersMethodselectCountByCostTime
(@Param("costTime") Integer costTime, @Param("prefix") String prefix)
server/core/src/main/java/com/ke/schedule/server/core/mapper/LogOptMapper.java:34
↓ 1 callersMethodselectCountByParam
(@Param("param") Map<String, Object> param, @Param("prefix") String prefix)
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskRecordMapper.java:80
↓ 1 callersMethodselectCronJobCountByProjectCode
(String projectCode)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:40
↓ 1 callersMethodselectJobCronPageByProject
(String projectCode, Integer start, Integer limit)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:42
↓ 1 callersMethodselectLastUndoTaskByJobUuid
(@Param("jobUuid") String jobUuid, @Param("prefix") String prefix)
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskRecordMapper.java:106
↓ 1 callersMethodselectLogCollectCountByProjectCodeAndTaskUuid
查询日志收集数量 @param projectCode 项目标识 @param taskUuid 任务唯一标识 @return 查询总量
server/core/src/main/java/com/ke/schedule/server/core/service/LoggerService.java:44
↓ 1 callersMethodselectLogCollectPageByProjectAndTaskUuid
查询日志收集 @param projectCode 项目标识 @param taskUuid 任务唯一标识 @param start 起始位置 @param limit 偏移量 @return 日志收集记录
server/core/src/main/java/com/ke/schedule/server/core/service/LoggerService.java:55
↓ 1 callersMethodselectLogOptCountByCostTime
根据最小耗时查询操作日志数量 @param costTime 花费时间 @return 查询数量
server/core/src/main/java/com/ke/schedule/server/core/service/LoggerService.java:71
↓ 1 callersMethodselectLogOptPageByProject
根据最小耗时查询操作日志 @param costTime 花费时间 @param start 起始位置 @param limit 偏移量 @return 操作日志列表
server/core/src/main/java/com/ke/schedule/server/core/service/LoggerService.java:81
↓ 1 callersMethodselectOneByCode
根据 code 查询用户 @param code 用户标识 @param prefix 集群 @return 用户对象
server/core/src/main/java/com/ke/schedule/server/core/mapper/UserMapper.java:44
↓ 1 callersMethodselectPageByCostTime
(@Param("costTime") Integer costTime, @Param("start") Integer start,
server/core/src/main/java/com/ke/schedule/server/core/mapper/LogOptMapper.java:41
↓ 1 callersMethodselectPageByParam
(@Param("param") Map<String, Object> param, @Param("start") Integer sta
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskRecordMapper.java:91
← previousnext →301–400 of 688, ranked by callers