Class: SidekiqUniqueJobs::Lock::WhileExecutingReject

Inherits:
WhileExecuting show all
Defined in:
lib/sidekiq_unique_jobs/lock/while_executing_reject.rb

Overview

Locks jobs while executing

Locks from the server process
Unlocks after the server is done processing

See SidekiqUniqueJobs::Lock::WhileExecuting#lock for more information about the client. See SidekiqUniqueJobs::Lock::WhileExecuting#execute for more information about the server

Author:

Constant Summary

Constants inherited from WhileExecuting

SidekiqUniqueJobs::Lock::WhileExecuting::RUN_SUFFIX

Instance Method Summary collapse

Methods inherited from WhileExecuting

#execute, #initialize, #lock

Methods included from SidekiqUniqueJobs::Logging::Middleware

included, #logging_context

Methods included from SidekiqUniqueJobs::Logging

#build_message, included, #log_debug, #log_error, #log_fatal, #log_info, #log_warn, #logger, #logging_context, #with_configured_loggers_context, #with_logging_context

Methods included from OptionsWithFallback

included, #lock_class, #lock_instance, #lock_type, #locks, #options, #unique_disabled?, #unique_enabled?

Methods inherited from BaseLock

#execute, #initialize, #lock, #locksmith, validate_options

Methods included from Reflectable

#reflect

Constructor Details

This class inherits a constructor from SidekiqUniqueJobs::Lock::WhileExecuting

Instance Method Details

#server_strategyOnConflict::Reject

Overridden with a forced OnConflict::Reject strategy

Returns:



16
17
18
# File 'lib/sidekiq_unique_jobs/lock/while_executing_reject.rb', line 16

def server_strategy
  @server_strategy ||= OnConflict.find_strategy(:reject).new(item, redis_pool)
end