Module: Mxrb::Runtime::SchedulerCoordinator

Included in:
MemorySharedStore, SQLiteSharedStore
Defined in:
lib/mxrb/runtime/shared_store.rb

Overview

Injectable scheduled-event claim/lease protocol. Renewal is optional for local coordinators and required for distributed lease implementations.

Instance Method Summary collapse

Instance Method Details

#claim_scheduled_event(event:, slot:, owner:, now:, lease_until:, skip_overlap:) ⇒ Object

Raises:

  • (NotImplementedError) 


24
25
26
 
# File 'lib/mxrb/runtime/shared_store.rb', line 24

def claim_scheduled_event(event:, slot:, owner:, now:, lease_until:, skip_overlap:)
  raise NotImplementedError
end

#complete_scheduled_event(event:, slot:, owner:, now: Time.now.utc) ⇒ Object

Raises:

  • (NotImplementedError) 


28
 
# File 'lib/mxrb/runtime/shared_store.rb', line 28

def complete_scheduled_event(event:, slot:, owner:, now: Time.now.utc) = raise NotImplementedError

#renew_scheduled_event(event:, slot:, owner:, lease_until:) ⇒ Object

Raises:

  • (NotImplementedError) 


29
 
# File 'lib/mxrb/runtime/shared_store.rb', line 29

def renew_scheduled_event(event:, slot:, owner:, lease_until:) = raise NotImplementedError