Class: Moonshot::StackEventsPoller

Inherits:
Object
  • Object
show all
Defined in:
lib/moonshot/stack_events_poller.rb

Overview

The StackEventsPoller queries DescribeStackEvents every time #latest_events is invoked, filtering out events that have already been returned. It can also, optionally, filter all non-error events (@see #show_errors_only).

Instance Method Summary collapse

Constructor Details

#initialize(cf_client, stack_name) ⇒ StackEventsPoller

Returns a new instance of StackEventsPoller.



6
7
8
9
10
11
12
 
# File 'lib/moonshot/stack_events_poller.rb', line 6

def initialize(cf_client, stack_name)
  @cf_client = cf_client
  @stack_name = stack_name

  # Start showing events from now.
  @last_time = Time.now
end

Instance Method Details

#filter_events(events) ⇒ Object 



32
33
34
35
36
37
38
39
40
 
# File 'lib/moonshot/stack_events_poller.rb', line 32

def filter_events(events)
  if @errors_only
    events.select do |event|
      %w(CREATE_FAILED UPDATE_FAILED DELETE_FAILED).include?(event.resource_status)
    end
  else
    events
  end
end

#get_stack_events(token = nil) ⇒ Object 



42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/moonshot/stack_events_poller.rb', line 42

def get_stack_events(token = nil)
  opts = {
    stack_name: @stack_name
  }

  opts[:next_token] = token if token

  result = @cf_client.describe_stack_events(**opts)
  events = result.stack_events
  events += get_stack_events(result.next_token) if result.next_token

  events
end

#latest_events ⇒ Array<Aws::CloudFormation::Event>

Build a list of events that have occurred since the last call to this method.

Returns:

  • (Array<Aws::CloudFormation::Event>) 


22
23
24
25
26
27
28
29
30
 
# File 'lib/moonshot/stack_events_poller.rb', line 22

def latest_events
  events = get_stack_events.select do |event|
    event.timestamp > @last_time
  end

  @last_time = Time.now

  filter_events(events.sort_by(&:timestamp))
end

#show_only_errors ⇒ Object 



14
15
16
 
# File 'lib/moonshot/stack_events_poller.rb', line 14

def show_only_errors
  @errors_only = true
end