Class: AwsSns
Instance Attribute Summary
#cfg
Instance Method Summary
collapse
#initialize, #log
Constructor Details
This class inherits a constructor from Oxidized::Hook
Instance Method Details
#run_hook(ctx) ⇒ Object
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
# File 'lib/oxidized/hook/awssns.rb', line 9
def run_hook(ctx)
sns = Aws::SNS::Resource.new(region: cfg.region)
topic = sns.topic(cfg.topic_arn)
message = {
:event => ctx.event.to_s
}
if ctx.node
message.merge!(
:group => ctx.node.group.to_s,
:model => ctx.node.model.class.name.to_s.downcase,
:node => ctx.node.name.to_s
)
end
topic.publish(
message: message.to_json
)
end
|
#validate_cfg! ⇒ Object
4
5
6
7
|
# File 'lib/oxidized/hook/awssns.rb', line 4
def validate_cfg!
raise KeyError, 'hook.region is required' unless cfg.has_key?('region')
raise KeyError, 'hook.topic_arn is required' unless cfg.has_key?('topic_arn')
end
|