Class: Sidekiq::LimitFetch::Global::SemaphoreBase

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq/limit_fetch/global/semaphore.rb

Overview

Base class for Redis-backed semaphores that track queue concurrency. Provides common initialization and Redis access for subclasses.

Direct Known Subclasses

CapsuleSemaphor, QueueSemaphore

Constant Summary collapse

PREFIX =

Redis key prefix for all limit_fetch data.

"sidekiq:limit_fetch"

Instance Method Summary collapse

Constructor Details

#initialize(capsule) ⇒ SemaphoreBase

Returns a new instance of SemaphoreBase.

Parameters:

  • capsule (Sidekiq::Capsule) 


13
14
15
16
17
 
# File 'lib/sidekiq/limit_fetch/global/semaphore.rb', line 13

def initialize(capsule)
  @capsule = capsule
  @capsule_meta = Global.capsule[capsule.name]
  @capsule_uuid = @capsule_meta.uuid
end