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
Method
delJobCron
(String jobUuid, String projectCode)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/ScheduleServiceImpl.java:358
Method
delTaskWaiting
(String taskUuid, String projectCode)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/ScheduleServiceImpl.java:370
Method
deleteByJobUuidAndProjectCode
删除未来等待推送的作业 通过JobUuid和projectCode @param jobUuid @param projectCode @param prefix @return
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskWaitingMapper.java:135
Method
deleteExpiredTask
(@Param("jobUuid") String jobUuid, @Param("lastGenerateTriggerTime") Long lastGenera
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskWaitingMapper.java:89
Method
deleteProjectUser
(String projectCode, String id)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/ManagerServiceImpl.java:50
Method
deserialize
(byte[] bytes)
client/spring/src/main/java/com/ke/schedule/client/spring/core/ClientContext.java:77
Method
destroy
()
client/spring/src/main/java/com/ke/schedule/client/spring/core/ClientProcessor.java:60
Method
digits62system
(Integer int10)
basic/src/main/java/com/ke/schedule/basic/support/KobUtils.java:45
Method
doFilter
(ServletRequest request, ServletResponse response, FilterChain chain)
server/console/src/main/java/com/ke/schedule/server/console/configuration/OperationFilter.java:40
Function
each
(data, callback)
server/console/src/main/resources/static/plugins/artTemplate/template-debug.js:155
Function
eb
(a,b,c)
server/console/src/main/resources/static/plugins/jquery/jquery.min.js:3
Method
editJobCron
(JobCron editJobCron)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/ScheduleServiceImpl.java:380
Method
end
(TaskRecord record)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/QWAlarmServiceImpl.java:59
Method
error500
(String error)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:17
Method
error501
(String taskContext)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:27
Method
error504
(String projectCode)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:41
Method
error505
(String clz)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:45
Method
error506
()
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:50
Method
error509
(Integer taskRecordState, LogLevel lv, String errMsg)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:64
Method
error9102
(String s)
server/core/src/main/java/com/ke/schedule/server/core/common/AdminLogConstant.java:24
Method
error9103
(String s)
server/core/src/main/java/com/ke/schedule/server/core/common/AdminLogConstant.java:29
Method
error9104
()
server/core/src/main/java/com/ke/schedule/server/core/common/AdminLogConstant.java:34
Function
escapeFn
(s)
server/console/src/main/resources/static/plugins/artTemplate/template-debug.js:140
Function
escapeHTML
(content)
server/console/src/main/resources/static/plugins/artTemplate/template-debug.js:144
Function
escaper
(match)
server/console/src/main/resources/static/plugins/bootstrap-select/js/bootstrap-select.js:283
Method
existProject
(String projectCode)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/IndexServiceImpl.java:49
Function
f
(t,e)
server/console/src/main/resources/static/plugins/raphael/raphael.min.js:1
Method
findRunningCronJob
(String mp)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/ScheduleServiceImpl.java:101
Method
findTriggerTaskInLimit
查询可以出发的任务,限定条数 @param prefix 集群名称 @param triggerTime 触发时间 @param limit 限定条数 @return 可以出发任务list
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskWaitingMapper.java:48
Method
findTriggerTaskInLimit
(long triggerTime, int limit, String mp)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/ScheduleServiceImpl.java:96
Method
fireOverstockTask
(List<TaskContext.Path> overstockTask)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/ScheduleServiceImpl.java:177
Function
ge
()
server/console/src/main/resources/static/plugins/sweetalert2/sweetalert2.min.js:1
Method
getClientNodes
(String projectCode)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/NodeServiceImpl.java:50
Method
getClientPaths
(String projectCode)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/NodeServiceImpl.java:73
Method
getExpressionSummary
()
server/core/src/main/java/com/ke/schedule/server/core/common/CronExpression.java:839
Method
getFinalFireTime
NOT YET IMPLEMENTED: Returns the final time that the <code>CronExpression</code> will match.
server/core/src/main/java/com/ke/schedule/server/core/common/CronExpression.java:1582
Method
getInnerParamsBean
()
server/core/src/main/java/com/ke/schedule/server/core/model/db/TaskWaiting.java:73
Method
getNextInvalidTimeAfter
Returns the next date/time <I>after</I> the given date/time which does <I>not</I> satisfy the expression @param date the date/time at which to begin
server/core/src/main/java/com/ke/schedule/server/core/common/CronExpression.java:336
Method
getNextValidTimeAfter
Returns the next date/time <I>after</I> the given date/time which satisfies the cron expression. @param date the date/time at which to begin the sear
server/core/src/main/java/com/ke/schedule/server/core/common/CronExpression.java:324
Method
getNodeServerList
()
server/core/src/main/java/com/ke/schedule/server/core/service/impl/NodeServiceImpl.java:32
Function
getParent
(node, source, field)
server/console/src/main/resources/static/plugins/tree/bootstraptable-treeview.js:90
Method
getTaskSize
()
basic/src/main/java/com/ke/schedule/basic/model/ClientPath.java:24
Method
getTasksDesc
()
basic/src/main/java/com/ke/schedule/basic/model/ClientPath.java:28
Method
getTimeBefore
NOT YET IMPLEMENTED: Returns the time before the given time that the <code>CronExpression</code> matches.
server/core/src/main/java/com/ke/schedule/server/core/common/CronExpression.java:1573
Method
getUserParam
获取自定义参数 这里不建议 因为你要是使用key的话 需要判空 @return 自定义参数对象
basic/src/main/java/com/ke/schedule/basic/model/TaskContext.java:106
Method
getUserParamValue
获取自定义参数中key的value值 @param key key @return value
basic/src/main/java/com/ke/schedule/basic/model/TaskContext.java:117
Function
h
()
server/console/src/main/resources/static/plugins/bootstrap/bootstrap.min.js:6
Method
handleExpireTask
(TaskRecord taskExpire, String cluster)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/ScheduleServiceImpl.java:199
Method
handleLogger
(LogContext context)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/CollectServiceImpl.java:37
Method
handleTaskLog
(LogContext context, TaskRecord taskRecord)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/ScheduleServiceImpl.java:205
Function
he
()
server/console/src/main/resources/static/plugins/raphael/raphael.min.js:2
Method
heartbeat
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/Heartbeat.java:40
Method
helloWorld
(TaskContext context)
demo/monitor/src/main/java/com/ke/schedule/demo/monitor/task/TaskClz.java:18
Function
i
()
server/console/src/main/resources/static/plugins/footable/footable.paginate.min.js:1
Function
includes
(search)
server/console/src/main/resources/static/plugins/bootstrap-select/js/bootstrap-select.js:43
Method
info103
(String jobCn, String taskKey, Integer state)
client/spring/src/main/java/com/ke/schedule/client/spring/constant/ClientLogConstant.java:148
Method
init
()
client/spring/src/main/java/com/ke/schedule/client/spring/core/ClientProcessor.java:40
Method
initProject
(String userCode, String userName, String configuration, String projectCode, String projectName)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/IndexServiceImpl.java:35
Method
initialize
()
server/core/src/main/java/com/ke/schedule/server/core/model/oz/CoreProperties.java:23
Method
initialize
()
server/core/src/main/java/com/ke/schedule/server/core/model/oz/ProcessorProperties.java:32
Method
initialize
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/Heartbeat.java:36
Method
initialize
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/WaitingTask.java:54
Method
initialize
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/ExpireTask.java:39
Method
initializeCornTask
()
server/processor/src/main/java/com/ke/schedule/server/processor/component/CornJob.java:51
Method
insertOne
保存日志 @param logCollect 收集日志 @param prefix 集群 @return 影响行数
server/core/src/main/java/com/ke/schedule/server/core/mapper/LogCollectMapper.java:32
Method
insertOne
插入等待执行任务表 @param tw @param prefix @return
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskWaitingMapper.java:26
Method
insertOne
单条保存cron类型作业 @param jobCron cron类型作业 @param prefix 集群名称 @return 影响结果集条数
server/core/src/main/java/com/ke/schedule/server/core/mapper/JobCronMapper.java:30
Method
insertOne
(@Param("tr") TaskRecord taskRecord, @Param("prefix") String prefix)
server/core/src/main/java/com/ke/schedule/server/core/mapper/TaskRecordMapper.java:28
Method
insertOne
初始化项目用户 @param projectUser 项目用户信息 @param prefix 集群 @return 影响行数
server/core/src/main/java/com/ke/schedule/server/core/mapper/ProjectUserMapper.java:28
Method
insertProjectUser
(ProjectUser projectUser)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/ManagerServiceImpl.java:45
Method
isSatisfiedBy
Indicates whether the given date satisfies the cron expression. Note that milliseconds are ignored, so two Dates falling on different milliseconds of
server/core/src/main/java/com/ke/schedule/server/core/common/CronExpression.java:303
Method
jobAdd
()
server/console/src/main/java/com/ke/schedule/server/console/controller/ScheduleController.java:73
Method
jobDelOpt
()
server/console/src/main/java/com/ke/schedule/server/console/controller/ScheduleController.java:242
Method
jobInitPage
(Model model)
server/console/src/main/java/com/ke/schedule/server/console/controller/ScheduleController.java:46
Method
jobSuspendOpt
()
server/console/src/main/java/com/ke/schedule/server/console/controller/ScheduleController.java:227
Function
k
(a)
server/console/src/main/resources/static/plugins/artTemplate/template.js:2
Function
ke
()
server/console/src/main/resources/static/plugins/sweetalert2/sweetalert2.min.js:1
Function
kt
(t,e)
server/console/src/main/resources/static/plugins/raphael/raphael.min.js:1
Function
l
(b,c)
server/console/src/main/resources/static/plugins/bootstrap-select/js/bootstrap-select.min.js:7
Method
lockPushTask
(TaskWaiting tw, String cluster, String serverIdentification)
server/core/src/main/java/com/ke/schedule/server/core/service/ScheduleService.java:28
Method
lockPushTask
(TaskWaiting tw, String cluster, String serverIdentification)
server/core/src/main/java/com/ke/schedule/server/core/service/impl/ScheduleServiceImpl.java:172
Method
logCollect
任务记录view @param model @return
server/console/src/main/java/com/ke/schedule/server/console/controller/LoggerController.java:105
Method
logCollectList
任务记录List @return
server/console/src/main/java/com/ke/schedule/server/console/controller/LoggerController.java:119
Method
logOptList
操作记录List @return
server/console/src/main/java/com/ke/schedule/server/console/controller/LoggerController.java:156
Method
login
登陆页面post方法,官方版本会校验 code、pwd,若接公司的统一登录请针对性的修改
server/console/src/main/java/com/ke/schedule/server/console/controller/IndexController.java:59
Method
logout
()
server/console/src/main/java/com/ke/schedule/server/console/controller/IndexController.java:84
Function
m
(a,b)
server/console/src/main/resources/static/plugins/artTemplate/template.js:2
Method
main
(String[] args)
server/console/src/main/java/com/ke/schedule/server/console/BootConsole.java:21
Method
main
(String[] args)
server/processor/src/main/java/com/ke/schedule/server/processor/BootProcessor.java:19
Method
main
(String[] args)
demo/monitor/src/main/java/com/ke/schedule/demo/monitor/BootDemoMonitor.java:19
Method
newThread
(Runnable runnable)
basic/src/main/java/com/ke/schedule/basic/support/NamedThreadFactory.java:38
Function
o
()
server/console/src/main/resources/static/plugins/footable/footable.bookmarkable.min.js:1
Function
objectKeys
()
server/console/src/main/resources/static/plugins/tree/bootstrap-table.js:224
Method
optLog
操作记录view @param model @return
server/console/src/main/java/com/ke/schedule/server/console/controller/LoggerController.java:145
Method
personConfig
(Model model)
server/console/src/main/java/com/ke/schedule/server/console/controller/ManagerController.java:186
Method
personConfigSave
()
server/console/src/main/java/com/ke/schedule/server/console/controller/ManagerController.java:195
Method
ping
ping @return pong
server/processor/src/main/java/com/ke/schedule/server/processor/controller/CollectController.java:57
Method
ping
()
demo/monitor/src/main/java/com/ke/schedule/demo/monitor/BootDemoMonitor.java:32
Method
projectAccess
项目接入 view入口 @param model ui.Model @return FtlPath.PROJECT_ACCESS_PATH
server/console/src/main/java/com/ke/schedule/server/console/controller/ManagerController.java:61
Method
projectUser
人员管理 view入口 @param model ui.Model @return FtlPath.PROJECT_USER_PATH
server/console/src/main/java/com/ke/schedule/server/console/controller/ManagerController.java:111
← previous
next →
501–600 of 688, ranked by callers