Module: OneApm::Agent::Agent::ContainerDataManager

Included in:
OneApm::Agent::Agent
Defined in:
lib/one_apm/agent/agent/container_data_manager.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#agent_command_router ⇒ Object (readonly)

Returns the value of attribute agent_command_router.



11
12
13
 
# File 'lib/one_apm/agent/agent/container_data_manager.rb', line 11

def agent_command_router
  @agent_command_router
end

#custom_event_aggregator ⇒ Object (readonly)

Returns the value of attribute custom_event_aggregator.



13
14
15
 
# File 'lib/one_apm/agent/agent/container_data_manager.rb', line 13

def custom_event_aggregator
  @custom_event_aggregator
end

#error_collector ⇒ Object (readonly)

Returns the value of attribute error_collector.



12
13
14
 
# File 'lib/one_apm/agent/agent/container_data_manager.rb', line 12

def error_collector
  @error_collector
end

#sql_sampler ⇒ Object (readonly)

Returns the value of attribute sql_sampler.



10
11
12
 
# File 'lib/one_apm/agent/agent/container_data_manager.rb', line 10

def sql_sampler
  @sql_sampler
end

#stats_engine ⇒ Object (readonly)

Returns the value of attribute stats_engine.



8
9
10
 
# File 'lib/one_apm/agent/agent/container_data_manager.rb', line 8

def stats_engine
  @stats_engine
end

#transaction_event_aggregator ⇒ Object (readonly)

Returns the value of attribute transaction_event_aggregator.



14
15
16
 
# File 'lib/one_apm/agent/agent/container_data_manager.rb', line 14

def transaction_event_aggregator
  @transaction_event_aggregator
end

#transaction_sampler ⇒ Object (readonly)

Returns the value of attribute transaction_sampler.



9
10
11
 
# File 'lib/one_apm/agent/agent/container_data_manager.rb', line 9

def transaction_sampler
  @transaction_sampler
end

Instance Method Details

#drop_buffered_data ⇒ Object 



24
25
26
27
28
29
30
31
 
# File 'lib/one_apm/agent/agent/container_data_manager.rb', line 24

def drop_buffered_data
  @stats_engine.reset!
  @error_collector.reset!
  @transaction_sampler.reset!
  @transaction_event_aggregator.reset!
  @custom_event_aggregator.reset!
  @sql_sampler.reset!
end

#merge_data_for_endpoint(endpoint, data) ⇒ Object 



16
17
18
19
20
21
22
 
# File 'lib/one_apm/agent/agent/container_data_manager.rb', line 16

def merge_data_for_endpoint(endpoint, data)
  if data && !data.empty?
    container_for_endpoint(endpoint).merge!(data)
  end
rescue => e
  OneApm::Manager.logger.error("Error while merging #{endpoint} data from child: ", e)
end