Sha256: f9dc394cdada6f821e1913c83fd5e29ffef49533f1b1d92ca2250ec0f0b99d6d

Contents?: true

Size: 256 Bytes

Versions: 15

Compression:

Stored size: 256 Bytes

Contents

<% module_namespacing do -%>
class <%= class_name %>Job < ApplicationJob
  kinesis_event "my-stream" # existing stream
  def <%= options[:name] %>
    puts "event #{JSON.dump(event)}"
    puts "kinesis_data #{JSON.dump(kinesis_data)}"
  end
end
<% end -%>

Version data entries

15 entries across 15 versions & 1 rubygems

Version Path
jets-5.0.13 lib/jets/generators/job/templates/event_types/kinesis.rb.tt
jets-5.0.12 lib/jets/generators/job/templates/event_types/kinesis.rb.tt
jets-5.0.11 lib/jets/generators/job/templates/event_types/kinesis.rb.tt
jets-5.0.10 lib/jets/generators/job/templates/event_types/kinesis.rb.tt
jets-5.0.9 lib/jets/generators/job/templates/event_types/kinesis.rb.tt
jets-5.0.8 lib/jets/generators/job/templates/event_types/kinesis.rb.tt
jets-5.0.7 lib/jets/generators/job/templates/event_types/kinesis.rb.tt
jets-5.0.6 lib/jets/generators/job/templates/event_types/kinesis.rb.tt
jets-5.0.5 lib/jets/generators/job/templates/event_types/kinesis.rb.tt
jets-5.0.4 lib/jets/generators/job/templates/event_types/kinesis.rb.tt
jets-5.0.3 lib/jets/generators/job/templates/event_types/kinesis.rb.tt
jets-5.0.2 lib/jets/generators/job/templates/event_types/kinesis.rb.tt
jets-5.0.1 lib/jets/generators/job/templates/event_types/kinesis.rb.tt
jets-5.0.0 lib/jets/generators/job/templates/event_types/kinesis.rb.tt
jets-5.0.0.beta1 lib/jets/generators/job/templates/event_types/kinesis.rb.tt