Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/LianjiaTech/kob
/ functions
Functions
688 in github.com/LianjiaTech/kob
⨍
Functions
688
◇
Types & classes
109
↓ 1 callers
Method
deleteOne
删除等待执行任务 @param taskUuid @param prefix @return
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskWaitingMapper.java:86
↓ 1 callers
Method
deleteProjectUser
删除用户 @param projectCode 项目标识 @param id 删除id @return 影响行数
server/core/src/main/java/com/ke/schedule/server/core/service/ManagerService.java:59
↓ 1 callers
Method
destroy
()
server/console/src/main/java/com/ke/schedule/server/console/configuration/OperationFilter.java:63
↓ 1 callers
Method
dispatcher
(ClientContext context, String parent, List<String> childs)
client/spring/src/main/java/com/ke/schedule/client/spring/core/TaskDispatcher.java:25
↓ 1 callers
Method
dispatcher0
(ClientContext client, String parentPath, String child)
client/spring/src/main/java/com/ke/schedule/client/spring/core/TaskDispatcher.java:39
↓ 1 callers
Method
dispatcher1
(ClientContext client, TaskContext.Path path, String full)
client/spring/src/main/java/com/ke/schedule/client/spring/core/TaskDispatcher.java:57
↓ 1 callers
Method
doSelect
节点唯一标识hash算法 将字符串变成数字 根据长度取余数形成环装选择进行选取 排序后节点数组 @param nodeList 节点标识列表 @param uuid 作业uuid @return 选取节点
server/core/src/main/java/com/ke/schedule/server/core/common/NodeHashLoadBalance.java:25
↓ 1 callers
Function
e
(i)
server/console/src/main/resources/static/plugins/raphael/raphael.min.js:1
↓ 1 callers
Function
e
()
server/console/src/main/resources/static/plugins/bootstrap/bootstrap.min.js:6
↓ 1 callers
Method
editJobCron
(JobCron editJobCron)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:62
↓ 1 callers
Method
error502
(String taskContext, String clientIdentification)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:32
↓ 1 callers
Method
error503
()
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:37
↓ 1 callers
Method
error507
(String zkServers, Integer timeout)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:54
↓ 1 callers
Method
error508
()
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:60
↓ 1 callers
Method
error510
()
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:69
↓ 1 callers
Method
error9101
(String s)
server/core/src/main/java/com/ke/schedule/server/core/common/AdminLogConstant.java:19
↓ 1 callers
Method
exception2String
(Exception e)
basic/src/main/java/com/ke/schedule/basic/support/KobUtils.java:85
↓ 1 callers
Method
existProject
项目是否存在 @param projectCode 项目标识 @return 项目是否存在
server/core/src/main/java/com/ke/schedule/server/core/service/IndexService.java:43
↓ 1 callers
Function
f
(b)
server/console/src/main/resources/static/plugins/artTemplate/template.js:2
↓ 1 callers
Function
f
()
server/console/src/main/resources/static/plugins/bootstrap/bootstrap.min.js:7
↓ 1 callers
Function
fa
(a)
server/console/src/main/resources/static/plugins/jquery/jquery.min.js:3
↓ 1 callers
Function
fb
(a,b)
server/console/src/main/resources/static/plugins/jquery/jquery.min.js:3
↓ 1 callers
Function
filtered
(js, filter)
server/console/src/main/resources/static/plugins/artTemplate/template-debug.js:597
↓ 1 callers
Method
findByTaskUuid
(@Param("taskUuid") String taskUuid, @Param("prefix") String prefix)
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskRecordMapper.java:47
↓ 1 callers
Method
findCronJobBySuspend
根据状态查询cron类型作业 @param suspend 暂停状态 暂停true|运行false @param prefix 集群名称 @return
server/core/src/main/java/com/ke/schedule/server/core/mapper/JobCronMapper.java:69
↓ 1 callers
Method
findNextWhiteSpace
(int i, String s)
server/core/src/main/java/com/ke/schedule/server/core/common/CronExpression.java:939
↓ 1 callers
Method
findRunningCronJob
(String mp)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:22
↓ 1 callers
Method
fireExpire
()
client/spring/src/main/java/com/ke/schedule/client/spring/core/ClientFunction.java:42
↓ 1 callers
Method
fireExpireTask
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/ExpireTask.java:43
↓ 1 callers
Method
fireExpireTask0
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/ExpireTask.java:47
↓ 1 callers
Method
fireOverstockTask
(List<TaskContext.Path> overstockTask)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:30
↓ 1 callers
Function
g
(b)
server/console/src/main/resources/static/plugins/bootstrap/bootstrap.min.js:6
↓ 1 callers
Function
gb
(a,b,c)
server/console/src/main/resources/static/plugins/jquery/jquery.min.js:3
↓ 1 callers
Method
getClientNodes
(String projectCode)
server/core/src/main/java/com/ke/schedule/server/core/service/NodeService.java:15
↓ 1 callers
Method
getClientPath
()
basic/src/main/java/com/ke/schedule/basic/model/ClientData.java:36
↓ 1 callers
Method
getClientPaths
(String projectCode)
server/core/src/main/java/com/ke/schedule/server/core/service/NodeService.java:17
↓ 1 callers
Function
getFieldIndex
(columns, field)
server/console/src/main/resources/static/plugins/tree/bootstraptable-treeview.js:25
↓ 1 callers
Method
getLocalAddress0
()
basic/src/main/java/com/ke/schedule/basic/support/IpUtils.java:49
↓ 1 callers
Method
getNodeServerList
()
server/core/src/main/java/com/ke/schedule/server/core/service/NodeService.java:13
↓ 1 callers
Method
getNumericValue
(String s, int i)
server/core/src/main/java/com/ke/schedule/server/core/common/CronExpression.java:1119
↓ 1 callers
Function
getSize
()
server/console/src/main/resources/static/plugins/bootstrap-select/js/bootstrap-select.js:991
↓ 1 callers
Method
getUserConfiguration
Json配置信息 @return Json配置信息
server/core/src/main/java/com/ke/schedule/server/core/model/db/ProjectUser.java:68
↓ 1 callers
Function
getVariable
(code)
server/console/src/main/resources/static/plugins/artTemplate/template-debug.js:342
↓ 1 callers
Method
getZkPath
()
basic/src/main/java/com/ke/schedule/basic/model/TaskContext.java:26
↓ 1 callers
Function
h
(a,b)
server/console/src/main/resources/static/plugins/artTemplate/template.js:2
↓ 1 callers
Method
handleExpireTask
(TaskRecord taskExpire, String cluster)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:36
↓ 1 callers
Method
handleLogger
处理日志信息 @param context 上报日志
server/core/src/main/java/com/ke/schedule/server/core/service/CollectService.java:19
↓ 1 callers
Method
handleRetryFailTask
处理失败重试任务 这里代码一把唆了 后期需要方法共用 @param logContext 日志内容 @param taskRecord 任务记录 @param appendRetryTaskUuid 追加重试任务的task_uuid
server/core/src/main/java/com/ke/schedule/server/core/service/impl/ScheduleServiceImpl.java:255
↓ 1 callers
Method
handleTaskLog
(LogContext context, TaskRecord taskRecord)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:38
↓ 1 callers
Method
heartbeat
()
client/spring/src/main/java/com/ke/schedule/client/spring/core/ClientProcessor.java:64
↓ 1 callers
Method
heartbeat0
()
client/spring/src/main/java/com/ke/schedule/client/spring/core/ClientProcessor.java:75
↓ 1 callers
Function
i
(t)
server/console/src/main/resources/static/plugins/footable/footable.grid.min.js:1
↓ 1 callers
Function
i
(i,o,n)
server/console/src/main/resources/static/plugins/footable/footable.min.js:14
↓ 1 callers
Function
i
(e,a)
server/console/src/main/resources/static/plugins/footable/footable.bookmarkable.min.js:1
↓ 1 callers
Function
ie
(e)
server/console/src/main/resources/static/plugins/sweetalert2/sweetalert2.min.js:1
↓ 1 callers
Method
info100
(String taskContext, String clientIdentification)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:112
↓ 1 callers
Method
info101
(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 callers
Method
info102
(Long period, Integer workers, Integer threads)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:143
↓ 1 callers
Method
initDateByDay
()
basic/src/main/java/com/ke/schedule/basic/support/KobUtils.java:76
↓ 1 callers
Method
initProject
初始化项目信息 @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 callers
Method
insertBatch
批量插入等待执行任务表 @param taskWaitingList 待推送作业list @param prefix 集群名称 @return 插入条数
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskWaitingMapper.java:63
↓ 1 callers
Method
insertProjectUser
保存项目用户 @param projectUser 项目标识 @return 影响行数
server/core/src/main/java/com/ke/schedule/server/core/service/ManagerService.java:50
↓ 1 callers
Method
isComplete
(int state)
basic/src/main/java/com/ke/schedule/basic/constant/TaskRecordStateConstant.java:56
↓ 1 callers
Method
isExclude
(String path)
server/console/src/main/java/com/ke/schedule/server/console/configuration/OperationFilter.java:68
↓ 1 callers
Function
isIEBrowser
()
server/console/src/main/resources/static/plugins/tree/bootstrap-table.js:220
↓ 1 callers
Function
j
(a)
server/console/src/main/resources/static/plugins/artTemplate/template.js:2
↓ 1 callers
Method
jobCronGenerateWaitingTask
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/CornJob.java:55
↓ 1 callers
Function
l
(e,t,a)
server/console/src/main/resources/static/plugins/footable/footable.all.min.js:14
↓ 1 callers
Function
l
(e,t,a)
server/console/src/main/resources/static/plugins/footable/footable.grid.min.js:1
↓ 1 callers
Function
logic
(code)
server/console/src/main/resources/static/plugins/artTemplate/template-debug.js:489
↓ 1 callers
Function
n
(t,a,o)
server/console/src/main/resources/static/plugins/footable/footable.all.min.js:14
↓ 1 callers
Function
n
(t,a,o)
server/console/src/main/resources/static/plugins/footable/footable.grid.min.js:1
↓ 1 callers
Function
na
(a)
server/console/src/main/resources/static/plugins/jquery/jquery.min.js:2
↓ 1 callers
Function
o
(t,o)
server/console/src/main/resources/static/plugins/footable/footable.all.min.js:14
↓ 1 callers
Function
o
(t,o)
server/console/src/main/resources/static/plugins/footable/footable.grid.min.js:1
↓ 1 callers
Method
pool
(Integer threads)
client/spring/src/main/java/com/ke/schedule/client/spring/core/ClientContext.java:110
↓ 1 callers
Function
post
(url, params, callback)
server/console/src/main/resources/static/kob/kob.js:139
↓ 1 callers
Method
pushTask
(TaskWaiting tw, String identification)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:66
↓ 1 callers
Method
pushWaitingTask
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/WaitingTask.java:58
↓ 1 callers
Method
pushWaitingTask0
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/WaitingTask.java:62
↓ 1 callers
Function
r
(t)
server/console/src/main/resources/static/plugins/footable/footable.grid.min.js:1
↓ 1 callers
Method
recoveryOverstockTask
(String projectCode)
server/processor/src/main/java/com/ke/schedule/server/processor/component/WaitingTask.java:75
↓ 1 callers
Method
runner
(Map<String, Object> beans)
client/spring/src/main/java/com/ke/schedule/client/spring/core/ClientContext.java:93
↓ 1 callers
Method
saveJobCron
(JobCron jobCron)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:60
↓ 1 callers
Method
saveJobRealTime
(TaskWaiting taskWaiting)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:48
↓ 1 callers
Method
saveLogOpt
保存操作日志 @param logOpt 操作日志 @return 影响行数
server/core/src/main/java/com/ke/schedule/server/core/service/LoggerService.java:63
↓ 1 callers
Method
selectByCodeAndPwd
根据 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 callers
Method
selectByUserCode
获取当前用户所有项目 @param userCode 用户标识 @param prefix 集群名称 @return 项目成员列表
server/core/src/main/java/com/ke/schedule/server/core/mapper/ProjectUserMapper.java:74
↓ 1 callers
Method
selectCountByCostTime
(@Param("costTime") Integer costTime, @Param("prefix") String prefix)
server/core/src/main/java/com/ke/schedule/server/core/mapper/LogOptMapper.java:34
↓ 1 callers
Method
selectCountByParam
(@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 callers
Method
selectCronJobCountByProjectCode
(String projectCode)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:40
↓ 1 callers
Method
selectJobCronPageByProject
(String projectCode, Integer start, Integer limit)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:42
↓ 1 callers
Method
selectLastUndoTaskByJobUuid
(@Param("jobUuid") String jobUuid, @Param("prefix") String prefix)
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskRecordMapper.java:106
↓ 1 callers
Method
selectLogCollectCountByProjectCodeAndTaskUuid
查询日志收集数量 @param projectCode 项目标识 @param taskUuid 任务唯一标识 @return 查询总量
server/core/src/main/java/com/ke/schedule/server/core/service/LoggerService.java:44
↓ 1 callers
Method
selectLogCollectPageByProjectAndTaskUuid
查询日志收集 @param projectCode 项目标识 @param taskUuid 任务唯一标识 @param start 起始位置 @param limit 偏移量 @return 日志收集记录
server/core/src/main/java/com/ke/schedule/server/core/service/LoggerService.java:55
↓ 1 callers
Method
selectLogOptCountByCostTime
根据最小耗时查询操作日志数量 @param costTime 花费时间 @return 查询数量
server/core/src/main/java/com/ke/schedule/server/core/service/LoggerService.java:71
↓ 1 callers
Method
selectLogOptPageByProject
根据最小耗时查询操作日志 @param costTime 花费时间 @param start 起始位置 @param limit 偏移量 @return 操作日志列表
server/core/src/main/java/com/ke/schedule/server/core/service/LoggerService.java:81
↓ 1 callers
Method
selectOneByCode
根据 code 查询用户 @param code 用户标识 @param prefix 集群 @return 用户对象
server/core/src/main/java/com/ke/schedule/server/core/mapper/UserMapper.java:44
↓ 1 callers
Method
selectPageByCostTime
(@Param("costTime") Integer costTime, @Param("start") Integer start,
server/core/src/main/java/com/ke/schedule/server/core/mapper/LogOptMapper.java:41
↓ 1 callers
Method
selectPageByParam
(@Param("param") Map<String, Object> param, @Param("start") Integer sta
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskRecordMapper.java:91
← previous
next →
301–400 of 688, ranked by callers