Sha256: 45b50685aeac2a06e595c4b7d405c90846fa1477134aa8e95458fe873fcc5dca

Contents?: true

Size: 910 Bytes

Versions: 20

Compression:

Stored size: 910 Bytes

Contents

# frozen_string_literal: true
module Puppet::Scheduler
  class Job
    attr_reader :run_interval
    attr_accessor :last_run
    attr_accessor :start_time

    def initialize(run_interval, &block)
      self.run_interval = run_interval
      @last_run = nil
      @run_proc = block
      @enabled = true
    end

    def run_interval=(interval)
      @run_interval = [interval, 0].max
    end

    def ready?(time)
      if @last_run
        @last_run + @run_interval <= time
      else
        true
      end
    end

    def enabled?
      @enabled
    end

    def enable
      @enabled = true
    end

    def disable
      @enabled = false
    end

    def interval_to_next_from(time)
      if ready?(time)
        0
      else
        @run_interval - (time - @last_run)
      end
    end

    def run(now)
      @last_run = now
      if @run_proc
        @run_proc.call(self)
      end
    end
  end
end

Version data entries

20 entries across 20 versions & 1 rubygems

Version Path
puppet-8.3.0 lib/puppet/scheduler/job.rb
puppet-8.3.0-x86-mingw32 lib/puppet/scheduler/job.rb
puppet-8.3.0-x64-mingw32 lib/puppet/scheduler/job.rb
puppet-8.3.0-universal-darwin lib/puppet/scheduler/job.rb
puppet-8.3.1 lib/puppet/scheduler/job.rb
puppet-8.3.1-x86-mingw32 lib/puppet/scheduler/job.rb
puppet-8.3.1-x64-mingw32 lib/puppet/scheduler/job.rb
puppet-8.3.1-universal-darwin lib/puppet/scheduler/job.rb
puppet-8.2.0 lib/puppet/scheduler/job.rb
puppet-8.2.0-x86-mingw32 lib/puppet/scheduler/job.rb
puppet-8.2.0-x64-mingw32 lib/puppet/scheduler/job.rb
puppet-8.2.0-universal-darwin lib/puppet/scheduler/job.rb
puppet-8.1.0 lib/puppet/scheduler/job.rb
puppet-8.1.0-x86-mingw32 lib/puppet/scheduler/job.rb
puppet-8.1.0-x64-mingw32 lib/puppet/scheduler/job.rb
puppet-8.1.0-universal-darwin lib/puppet/scheduler/job.rb
puppet-8.0.1 lib/puppet/scheduler/job.rb
puppet-8.0.1-x86-mingw32 lib/puppet/scheduler/job.rb
puppet-8.0.1-x64-mingw32 lib/puppet/scheduler/job.rb
puppet-8.0.1-universal-darwin lib/puppet/scheduler/job.rb