module FirehoseIntegration::KinesisEvent::ClassMethods
Public Instance Methods
firehose_integratable()
click to toggle source
# File lib/firehose_integration/models/concerns/kinesis_event.rb, line 8 def firehose_integratable after_commit :send_kinesis_event, unless: Proc.new { |instance| instance.try(:skip_kinesis_event) || ENV['SKIP_KINESIS_EVENTS'] == 'true' } begin include "#{self.model_name.name}KinesisSerializer".constantize rescue end end
kinesis_stream_name()
click to toggle source
# File lib/firehose_integration/models/concerns/kinesis_event.rb, line 17 def kinesis_stream_name raise(NoMethodError, "Model must define class method kinesis_stream_name") end