Class: Stackify::UnixSocketClient

Inherits:
Object
  • Object
show all
Defined in:
lib/stackify/unix_socket_client.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ UnixSocketClient

Returns a new instance of UnixSocketClient.



4
5
6
7
8
 
# File 'lib/stackify/unix_socket_client.rb', line 4

def initialize
  Stackify.internal_log :info, '[UnixSocketClient]: initialize()'
  @@errors_governor = Stackify::ErrorsGovernor.new
  @@sender = Stackify::UnixSocketSender.new
end

Instance Method Details

#get_epoch(msg) ⇒ Object 



37
38
39
 
# File 'lib/stackify/unix_socket_client.rb', line 37

def get_epoch msg
  msg.date_millis
end

#has_error(msg) ⇒ Object 



33
34
35
 
# File 'lib/stackify/unix_socket_client.rb', line 33

def has_error msg
  !msg.error.nil?
end

#log(level, msg, call_trace, task) ⇒ Object 



10
11
12
13
14
15
 
# File 'lib/stackify/unix_socket_client.rb', line 10

def log level, msg, call_trace, task
  if acceptable?(level, msg) && Stackify.working?
    worker = Stackify::AddMsgWorker.new
    worker.async_perform ScheduleDelay.new, task
  end
end

#log_exception(level = :error, ex, task) ⇒ Object 



17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
 
# File 'lib/stackify/unix_socket_client.rb', line 17

def log_exception level= :error, ex, task
  if ex.is_a?(Stackify::StackifiedError)
    if acceptable?(level, ex.message) && Stackify.working?
      if @@errors_governor.can_send? ex
        worker = Stackify::AddMsgWorker.new
        worker.async_perform ScheduleDelay.new, task
      else
        Stackify.internal_log :warn,
        "UnixSocketClient: logging of exception with message \"#{ex.message}\" is skipped - flood_limit is exceeded"
      end
    end
  else
    Stackify.log_internal_error 'UnixSocketClient: log_exception should get StackifiedError object'
  end
end

#log_exception_task(level, ex, trans_id = nil, log_uuid = nil) ⇒ Object 



64
65
66
67
68
 
# File 'lib/stackify/unix_socket_client.rb', line 64

def log_exception_task level, ex, trans_id=nil, log_uuid=nil
  Stackify::ScheduleTask.new ({limit: 1}) do
    Stackify.msgs_queue << Stackify::ProtobufLogObject.new(level, ex.message, caller[0], trans_id, log_uuid, ex).to_obj
  end
end

#log_message_task(level, msg, call_trace, trans_id = nil, log_uuid = nil) ⇒ Object 



45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
 
# File 'lib/stackify/unix_socket_client.rb', line 45

def log_message_task level, msg, call_trace, trans_id=nil, log_uuid=nil
  Stackify::ScheduleTask.new ({limit: 1}) do
    if %w(error fatal).include?(level)
      ex = if ruby_exception?(msg) && msg.class != Class
        msg.set_backtrace(call_trace)
        msg
      else
        e = StringException.new(msg)
        e.set_backtrace(call_trace)
        e
      end
      ex = StackifiedError.new(ex, binding())
      Stackify.msgs_queue << Stackify::ProtobufLogObject.new(level, ex.message, caller[0], trans_id, log_uuid, ex).to_obj
    else
      Stackify.msgs_queue << Stackify::ProtobufLogObject.new(level, msg, caller[0], trans_id, log_uuid).to_obj
    end
  end
end

#send_logs(msgs, attempts = 3) ⇒ Object 



41
42
43
 
# File 'lib/stackify/unix_socket_client.rb', line 41

def send_logs msgs, attempts = 3
  @@sender.send_logs msgs, attempts
end