Class: Fluent::Tranquility::PusherFactory

Inherits:
Object
  • Object
show all
Defined in:
lib/fluent/tranquility/pusher_factory.rb

Constant Summary collapse

EXCEPTIONS = 
%w(Errno::ETIMEDOUT
Faraday::TimeoutError
Faraday::Error::TimeoutError
Net::ReadTimeout).freeze

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.call(*args) ⇒ Object 



9
10
11
 
# File 'lib/fluent/tranquility/pusher_factory.rb', line 9

def self.call(*args)
  new.call(*args)
end

Instance Method Details

#call(params = {}) ⇒ Object 



13
14
15
16
 
# File 'lib/fluent/tranquility/pusher_factory.rb', line 13

def call(params = {})
  connection = connection_for(params[:url], params[:retries])
  Pusher.new(connection, params[:dataset])
end