Sha256: fa7dbd98f297ada57cec4e0ed1854434f49e22885e126d8f305e00625fc7f0e2
Contents?: true
Size: 1008 Bytes
Versions: 17
Compression:
Stored size: 1008 Bytes
Contents
class SNS < Mapper
#
# Returns an array of resources.
#
def collect
resources = []
#
# list_topics
#
@client.list_topics.each_with_index do |response, page|
log(response.context.operation_name, page)
response.topics.each do |topic|
log(response.context.operation_name, topic.topic_arn, page)
# get_topic_attributes
struct = OpenStruct.new(@client.get_topic_attributes({ topic_arn: topic.topic_arn }).attributes.to_h)
struct.type = 'topic'
struct.arn = topic.topic_arn
struct.subscriptions = []
# list_subscriptions_by_topic
@client.list_subscriptions_by_topic({ topic_arn: topic.topic_arn }).each_with_index do |response, page|
log(response.context.operation_name, topic.topic_arn, page)
response.subscriptions.each do |sub|
struct.subscriptions.push(sub.to_h)
end
end
resources.push(struct.to_h)
end
end
resources
end
end
Version data entries
17 entries across 17 versions & 1 rubygems