class AWS::Flow::HistoryHelper
Public Class Methods
new(decision_task_iterator)
click to toggle source
# File lib/aws/decider/history_helper.rb, line 21 def initialize(decision_task_iterator) # TODO make sure we page through correctly @single_decision_events_iterator = SingleDecisionIterator.new(decision_task_iterator) end
Public Instance Methods
get_decision_task()
click to toggle source
# File lib/aws/decider/history_helper.rb, line 41 def get_decision_task @single_decision_events_iterator.get_decision_task end
get_last_non_replay_event_id()
click to toggle source
# File lib/aws/decider/history_helper.rb, line 36 def get_last_non_replay_event_id result = get_decision_task.previous_started_event_id result ||= 0 end
get_replay_current_time_millis()
click to toggle source
# File lib/aws/decider/history_helper.rb, line 31 def get_replay_current_time_millis raise IllegalStateException if @current_decision_data.nil? @current_decision_data.replay_current_time_milliseconds end
get_single_decision_events()
click to toggle source
# File lib/aws/decider/history_helper.rb, line 26 def get_single_decision_events @current_decision_data = @single_decision_events_iterator.next return @current_decision_data.decision_events end