Class: Kaal::Backend::DispatchRegistryAccessor

Inherits:
Object
  • Object
show all
Defined in:
lib/kaal/backend/dispatch_registry_accessor.rb

Overview

Reads dispatch registry state through the configured backend adapter.

Instance Method Summary collapse

Constructor Details

#initialize(configuration:) ⇒ DispatchRegistryAccessor

Returns a new instance of DispatchRegistryAccessor.



11
12
13
 
# File 'lib/kaal/backend/dispatch_registry_accessor.rb', line 11

def initialize(configuration:)
  @configuration = configuration
end

Instance Method Details

#dispatched?(key, fire_time) ⇒ Boolean

Returns:

  • (Boolean) 


15
16
17
18
19
20
21
22
23
 
# File 'lib/kaal/backend/dispatch_registry_accessor.rb', line 15

def dispatched?(key, fire_time)
  registry = fetch_registry
  return false unless registry

  registry.dispatched?(key, fire_time)
rescue StandardError => e
  @configuration.logger&.warn("Error checking dispatch status for #{key}: #{e.message}")
  false
end

#registry ⇒ Object 



25
26
27
28
29
30
 
# File 'lib/kaal/backend/dispatch_registry_accessor.rb', line 25

def registry
  fetch_registry
rescue StandardError => e
  @configuration.logger&.warn("Error accessing dispatch registry: #{e.message}")
  nil
end