module Nandi::TimeoutPolicies

Constants

CONCURRENT_OPERATIONS

Public Class Methods

policy_for(instruction) click to toggle source
# File lib/nandi/timeout_policies.rb, line 21
def self.policy_for(instruction)
  case instruction.lock
  when Nandi::Migration::LockWeights::ACCESS_EXCLUSIVE
    AccessExclusive
  else
    share_policy_for(instruction)
  end
end
share_policy_for(instruction) click to toggle source
# File lib/nandi/timeout_policies.rb, line 30
def self.share_policy_for(instruction)
  if CONCURRENT_OPERATIONS.include?(instruction.procedure)
    Concurrent
  else
    Noop
  end
end