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