Class SchedulerClusteredJobDao

    • Constructor Detail

      • SchedulerClusteredJobDao

        public SchedulerClusteredJobDao()
    • Method Detail

      • getNextRunTime

        public @Nullable Date getNextRunTime​(@NonNull com.atlassian.scheduler.config.JobId jobId)
        Specified by:
        getNextRunTime in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao
      • getVersion

        public @Nullable Long getVersion​(@NonNull com.atlassian.scheduler.config.JobId jobId)
        Specified by:
        getVersion in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao
      • find

        public @Nullable com.atlassian.scheduler.caesium.spi.ClusteredJob find​(@NonNull com.atlassian.scheduler.config.JobId jobId)
        Specified by:
        find in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao
      • findByJobRunnerKey

        public @NonNull Collection<com.atlassian.scheduler.caesium.spi.ClusteredJob> findByJobRunnerKey​(@NonNull com.atlassian.scheduler.config.JobRunnerKey jobRunnerKey)
        Specified by:
        findByJobRunnerKey in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao
      • refresh

        public @NonNull Map<com.atlassian.scheduler.config.JobId,​Date> refresh()
        Specified by:
        refresh in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao
      • findAllJobRunnerKeys

        public @NonNull Set<com.atlassian.scheduler.config.JobRunnerKey> findAllJobRunnerKeys()
        Specified by:
        findAllJobRunnerKeys in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao
      • create

        public boolean create​(@NonNull com.atlassian.scheduler.caesium.spi.ClusteredJob clusteredJob)
        Specified by:
        create in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao
      • updateNextRunTime

        public boolean updateNextRunTime​(@NonNull com.atlassian.scheduler.config.JobId jobId,
                                         @Nullable Date nextRunTime,
                                         long expectedVersion)
        Specified by:
        updateNextRunTime in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao
      • delete

        public boolean delete​(@NonNull com.atlassian.scheduler.config.JobId jobId)
        Specified by:
        delete in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao