Class: NewRelic::Agent::InfiniteTracing::RecordStatusHandler

Inherits:
Object
  • Object
show all
Defined in:
lib/infinite_tracing/record_status_handler.rb

Instance Method Summary collapse

Constructor Details

#initialize(client, enumerator) ⇒ RecordStatusHandler 



8
9
10
11
12
13
14
 
# File 'lib/infinite_tracing/record_status_handler.rb', line 8

def initialize(client, enumerator)
  @client = client
  @enumerator = enumerator
  @messages_seen = nil
  @lock = Mutex.new
  @lock.synchronize { @worker = start_handler }
end

Instance Method Details

#messages_seen ⇒ Object 



16
17
18
 
# File 'lib/infinite_tracing/record_status_handler.rb', line 16

def messages_seen
  @messages_seen ? @messages_seen.messages_seen : 0
end

#stop ⇒ Object 



20
21
22
23
24
25
26
27
28
 
# File 'lib/infinite_tracing/record_status_handler.rb', line 20

def stop
  return if @worker.nil?

  @lock.synchronize do
    NewRelic::Agent.logger.debug('gRPC Stopping Response Handler')
    @worker.stop
    @worker = nil
  end
end