Class: Katello::EventDaemon::Services::AgentEventReceiver

Inherits:
Object
  • Object
show all
Defined in:
app/lib/katello/event_daemon/services/agent_event_receiver.rb

Defined Under Namespace

Classes: Handler

Class Method Summary collapse

Class Method Details

.close ⇒ Object 



40
41
42
43
 
# File 'app/lib/katello/event_daemon/services/agent_event_receiver.rb', line 40

def self.close
  @agent_connection&.close
  @thread&.join
end

.logger ⇒ Object 



26
27
28
 
# File 'app/lib/katello/event_daemon/services/agent_event_receiver.rb', line 26

def self.logger
  ::Foreman::Logging.logger('katello/agent')
end

.run ⇒ Object 



30
31
32
33
34
35
36
37
38
 
# File 'app/lib/katello/event_daemon/services/agent_event_receiver.rb', line 30

def self.run
  fail("Katello agent event receiver already started") if running?

  @thread = Thread.new do
    @handler = Handler.new
    @agent_connection = ::Katello::Agent::Connection.new
    @agent_connection.fetch_agent_messages(@handler)
  end
end

.running? ⇒ Boolean

Returns:

  • (Boolean) 


45
46
47
 
# File 'app/lib/katello/event_daemon/services/agent_event_receiver.rb', line 45

def self.running?
  @agent_connection&.open? && @thread&.status.present?
end

.status ⇒ Object 



49
50
51
52
53
54
55
 
# File 'app/lib/katello/event_daemon/services/agent_event_receiver.rb', line 49

def self.status
  {
    running: running?,
    processed_count: @handler&.processed || 0,
    failed_count: @handler&.failed || 0
  }
end