common-ext/io.github.caijiang.common.job.scheduler/KubernetesJobScheduler

KubernetesJobScheduler

class KubernetesJobScheduler(client: KubernetesClient = KubernetesClientBuilder().build()) : Scheduler

k8s支持，即 k8s Job. CE_JOB_TYPE= CE_JOB_ARG_[NAME]

Author

CJ

Constructors

Link copied to clipboard
constructor(client: KubernetesClient = KubernetesClientBuilder().build())

Functions

Link copied to clipboard
open override fun cleanPersistentJob(env: String, hostname: String, jobName: String)

清理定时调度任务

Link copied to clipboard
open override fun submitPersistentJob(env: String, hostname: String, cron: String, job: PersistentJob, timezone: TimeZone)

定时调度任务

Link copied to clipboard
open override fun submitTemporaryJob(env: String, hostname: String, job: TemporaryJob)

调度一个可序列化任务