Packages

Amazon Kinesis Data Firehose configurable queue supporting arbitrary adapters

Current section

Files

Jump to
firefighter lib firehose.ex
Raw

lib/firehose.ex

defmodule Firefighter.Firehose do
require Logger
@behaviour Firefighter.Adapter
@default_adapter Firefighter.Adapters.Logger
def pump(stream_name, records, opts) do
adapter().pump(stream_name, records, opts)
end
defp adapter, do: Application.get_env(:firefighter, :adapter, @default_adapter)
end