Class: Stackify::LogsSenderWorker

Inherits:
Worker show all
Defined in:
lib/stackify/workers/logs_sender_worker.rb

Instance Attribute Summary

Attributes inherited from Worker

#name, #type

Instance Method Summary collapse

Methods inherited from Worker

#alive?, #async_perform, #backtrace, #id, #perform, #shutdown!, #status

Constructor Details

#initialize(name = 'LogsSender worker') ⇒ LogsSenderWorker

Returns a new instance of LogsSenderWorker.



4
5
6
7
8
9
10
11
12
13
14
15
16
17
 
# File 'lib/stackify/workers/logs_sender_worker.rb', line 4

def initialize name = 'LogsSender worker'
  super
  case Stackify.configuration.transport
  when Stackify::DEFAULT
    name = 'LogsSender worker'
  when Stackify::UNIX_SOCKET
    name = 'UnixSocketSender worker'
  when Stackify::AGENT_HTTP
    name = 'AgentHTTPSender worker'
  end
  @name = name
  @name += " ##{self.id}"
  @type = :logs_send
end

Instance Method Details

#after_perform(result) ⇒ Object 



19
20
21
22
23
24
25
 
# File 'lib/stackify/workers/logs_sender_worker.rb', line 19

def after_perform result
  if result.try(:status) == 200
    Stackify.internal_log :info, "#{@name}: Sending batch of msgs is successfully completed"
  else
    Stackify.log_internal_error "#{@name}: Sending batch of msgs is failed: #{result.try(:msg)}"
  end
end