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