Module: Upkeep::Runtime::ChangeLog

Defined in:

lib/upkeep/runtime.rb

Constant Summary

THREAD_KEY =

:upkeep_change_log_events

Class Method Summary

• .capture ⇒ Object
• .drain ⇒ Object
• .events ⇒ Object
• .record(event) ⇒ Object
• .reset ⇒ Object

Class Method Details

.capture ⇒ Object

# File 'lib/upkeep/runtime.rb', line 337

def capture
  previous = Thread.current[THREAD_KEY]
  events = []
  Thread.current[THREAD_KEY] = events

  [yield, events.dup]
ensure
  Thread.current[THREAD_KEY] = previous
end

.drain ⇒ Object

# File 'lib/upkeep/runtime.rb', line 323

def drain
  if (events = Thread.current[THREAD_KEY])
    drained = events.dup
    events.clear
    drained
  else
    @mutex.synchronize do
      events = @events
      @events = []
      events
    end
  end
end

.events ⇒ Object

# File 'lib/upkeep/runtime.rb', line 315

def events
  if (events = Thread.current[THREAD_KEY])
    events
  else
    @mutex.synchronize { @events.dup }
  end
end

.record(event) ⇒ Object

# File 'lib/upkeep/runtime.rb', line 307

def record(event)
  if (events = Thread.current[THREAD_KEY])
    events << event
  else
    @mutex.synchronize { @events << event }
  end
end

.reset ⇒ Object

# File 'lib/upkeep/runtime.rb', line 302

def reset
  @mutex.synchronize { @events = [] }
  Thread.current[THREAD_KEY] = nil
end