org.glowroot.agent.central

Class CentralCollector

java.lang.Object

org.glowroot.agent.central.CentralCollector

All Implemented Interfaces:

Collector

public class CentralCollector
extends Object
implements Collector

Nested Class Summary

Nested classes/interfaces inherited from interface org.glowroot.agent.collector.Collector

Collector.AgentConfigUpdater, Collector.AggregateReader, Collector.AggregateVisitor, Collector.TraceReader, Collector.TraceVisitor

Constructor Summary

Constructors

Constructor and Description
CentralCollector(Map<String,String> properties, String collectorAddress, String collectorAuthority, List<File> confDirs, boolean configReadOnly, LiveJvmServiceImpl liveJvmService, LiveWeavingServiceImpl liveWeavingService, LiveTraceRepositoryImpl liveTraceRepository, Collector.AgentConfigUpdater agentConfigUpdater, ConfigService configService)

Method Summary

Modifier and Type	Method and Description
void	awaitClose()
void	close()
void	collectAggregates(Collector.AggregateReader aggregateReader)
void	collectGaugeValues(List<CollectorServiceOuterClass.GaugeValueMessage.GaugeValue> gaugeValues)
void	collectTrace(Collector.TraceReader traceReader)
void	init(List<File> confDirs, CollectorServiceOuterClass.InitMessage.Environment environment, AgentConfigOuterClass.AgentConfig agentConfig, Collector.AgentConfigUpdater agentConfigUpdater)
void	log(CollectorServiceOuterClass.LogMessage.LogEvent logEvent)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CentralCollector

public CentralCollector(Map<String,String> properties,
                        String collectorAddress,
                        String collectorAuthority,
                        List<File> confDirs,
                        boolean configReadOnly,
                        LiveJvmServiceImpl liveJvmService,
                        LiveWeavingServiceImpl liveWeavingService,
                        LiveTraceRepositoryImpl liveTraceRepository,
                        Collector.AgentConfigUpdater agentConfigUpdater,
                        ConfigService configService)
                 throws Exception

Throws:

Exception

Method Detail

awaitClose

@OnlyUsedByTests
public void awaitClose()
                                  throws InterruptedException

Throws:

InterruptedException

close

@OnlyUsedByTests
public void close()
                             throws InterruptedException

Throws:

InterruptedException

collectAggregates

public void collectAggregates(Collector.AggregateReader aggregateReader)
                       throws InterruptedException

Specified by:

collectAggregates in interface Collector

Throws:

InterruptedException

collectGaugeValues

public void collectGaugeValues(List<CollectorServiceOuterClass.GaugeValueMessage.GaugeValue> gaugeValues)
                        throws InterruptedException

Specified by:

collectGaugeValues in interface Collector

Throws:

InterruptedException

collectTrace

public void collectTrace(Collector.TraceReader traceReader)
                  throws InterruptedException

Specified by:

collectTrace in interface Collector

Throws:

InterruptedException

init

public void init(List<File> confDirs,
                 CollectorServiceOuterClass.InitMessage.Environment environment,
                 AgentConfigOuterClass.AgentConfig agentConfig,
                 Collector.AgentConfigUpdater agentConfigUpdater)
          throws IOException

Specified by:

init in interface Collector

Throws:

IOException

log

public void log(CollectorServiceOuterClass.LogMessage.LogEvent logEvent)
         throws InterruptedException

Specified by:

log in interface Collector

Throws:

InterruptedException