Class KubernetesJobScheduler
-
- All Implemented Interfaces:
-
io.github.caijiang.common.job.scheduler.Scheduler
public final class KubernetesJobScheduler implements Scheduler
k8s支持,即 k8s Job. CE_JOB_TYPE= CE_JOB_ARG_
[NAME]CJ
-
-
Constructor Summary
Constructors Constructor Description KubernetesJobScheduler(KubernetesClient client)
-
Method Summary
Modifier and Type Method Description UnitsubmitTemporaryJob(String env, String hostname, TemporaryJob job)调度一个可序列化任务 UnitsubmitPersistentJob(String env, String hostname, String cron, PersistentJob job, TimeZone timezone)定时调度任务 UnitcleanPersistentJob(String env, String hostname, String jobName)清理定时调度任务 -
-
Method Detail
-
submitTemporaryJob
Unit submitTemporaryJob(String env, String hostname, TemporaryJob job)
调度一个可序列化任务
- Parameters:
env- 机器所在环境,缺省为default
-
submitPersistentJob
Unit submitPersistentJob(String env, String hostname, String cron, PersistentJob job, TimeZone timezone)
定时调度任务
- Parameters:
env- 机器所在环境,缺省为default
-
cleanPersistentJob
Unit cleanPersistentJob(String env, String hostname, String jobName)
清理定时调度任务
- Parameters:
env- 机器所在环境,缺省为default
-
-
-
-