Current section
Files
Jump to
Current section
Files
lib/firehose.ex
defmodule Firefighter.Firehose do
require Logger
@behaviour Firefighter.Adapter
@default_adapter Firefighter.Adapters.Logger
def pump(stream_name, records, delimiter, opts) do
adapter().pump(stream_name, records, delimiter, opts)
end
defp adapter, do: Application.get_env(:firefighter, :adapter, @default_adapter)
end