Sha256: 9f53319d4ccbede2bf57673ed7a91c459cca2a864a7627a2848786a6f9e60af7
Contents?: true
Size: 852 Bytes
Versions: 10
Compression:
Stored size: 852 Bytes
Contents
# frozen_string_literal: true
require 'cyclone_lariat/resources/queue'
module CycloneLariat
module Generators
module Queue
def queue(type = :all, fifo:, dest: nil, content_based_deduplication: nil, kind: :event, **options)
options = CycloneLariat::Options.wrap(options)
options.merge!(config)
Resources::Queue.new(
instance: options.instance,
publisher: options.publisher,
region: options.aws_region,
account_id: options.aws_account_id,
kind: kind,
type: type,
fifo: fifo,
dest: dest,
content_based_deduplication: content_based_deduplication
)
end
def custom_queue(name)
Resources::Queue.from_name(name, account_id: config.aws_account_id, region: config.aws_region)
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems