org.glowroot.agent.live

Class LiveAggregateRepositoryImpl

java.lang.Object

org.glowroot.agent.live.LiveAggregateRepositoryImpl

All Implemented Interfaces:

LiveAggregateRepository

public class LiveAggregateRepositoryImpl
extends Object
implements LiveAggregateRepository

Nested Class Summary

Nested classes/interfaces inherited from interface org.glowroot.common.live.LiveAggregateRepository

LiveAggregateRepository.AggregateQuery, LiveAggregateRepository.LiveAggregateRepositoryNop, LiveAggregateRepository.LiveResult<T>, LiveAggregateRepository.OverviewAggregate, LiveAggregateRepository.PercentileAggregate, LiveAggregateRepository.SummaryQuery, LiveAggregateRepository.ThroughputAggregate

Constructor Summary

Constructors

Constructor and Description
LiveAggregateRepositoryImpl(TransactionProcessor aggregator)

Method Summary

Modifier and Type	Method and Description
void	clearInMemoryData()
String	getFullQueryText(String agentRollupId, String fullQueryTextSha1)
LiveAggregateRepository.LiveResult<LiveAggregateRepository.OverviewAggregate>	getOverviewAggregates(String agentId, LiveAggregateRepository.AggregateQuery query)
LiveAggregateRepository.LiveResult<LiveAggregateRepository.PercentileAggregate>	getPercentileAggregates(String agentId, LiveAggregateRepository.AggregateQuery query)
LiveAggregateRepository.LiveResult<LiveAggregateRepository.ThroughputAggregate>	getThroughputAggregates(String agentId, LiveAggregateRepository.AggregateQuery query)
Set<String>	getTransactionTypes(String agentId)
long	mergeInAuxThreadProfiles(String agentId, LiveAggregateRepository.AggregateQuery query, ProfileCollector collector)
long	mergeInMainThreadProfiles(String agentId, LiveAggregateRepository.AggregateQuery query, ProfileCollector collector)
long	mergeInOverallErrorSummary(String agentId, LiveAggregateRepository.SummaryQuery query, OverallErrorSummaryCollector collector)
long	mergeInOverallSummary(String agentId, LiveAggregateRepository.SummaryQuery query, OverallSummaryCollector collector)
long	mergeInQueries(String agentId, LiveAggregateRepository.AggregateQuery query, QueryCollector collector)
long	mergeInServiceCalls(String agentId, LiveAggregateRepository.AggregateQuery query, ServiceCallCollector collector)
long	mergeInTransactionNameErrorSummaries(String agentId, LiveAggregateRepository.SummaryQuery query, TransactionNameErrorSummaryCollector collector)
long	mergeInTransactionNameSummaries(String agentId, LiveAggregateRepository.SummaryQuery query, TransactionNameSummaryCollector collector)

Methods inherited from class java.lang.Object

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

Constructor Detail

LiveAggregateRepositoryImpl

public LiveAggregateRepositoryImpl(TransactionProcessor aggregator)

Method Detail

clearInMemoryData

public void clearInMemoryData()

Specified by:

clearInMemoryData in interface LiveAggregateRepository

getFullQueryText

public String getFullQueryText(String agentRollupId,
                               String fullQueryTextSha1)

Specified by:

getFullQueryText in interface LiveAggregateRepository

getOverviewAggregates

public LiveAggregateRepository.LiveResult<LiveAggregateRepository.OverviewAggregate> getOverviewAggregates(String agentId,
                                                                                                           LiveAggregateRepository.AggregateQuery query)

Specified by:

getOverviewAggregates in interface LiveAggregateRepository

getPercentileAggregates

public LiveAggregateRepository.LiveResult<LiveAggregateRepository.PercentileAggregate> getPercentileAggregates(String agentId,
                                                                                                               LiveAggregateRepository.AggregateQuery query)

Specified by:

getPercentileAggregates in interface LiveAggregateRepository

getThroughputAggregates

public LiveAggregateRepository.LiveResult<LiveAggregateRepository.ThroughputAggregate> getThroughputAggregates(String agentId,
                                                                                                               LiveAggregateRepository.AggregateQuery query)

Specified by:

getThroughputAggregates in interface LiveAggregateRepository

getTransactionTypes

public Set<String> getTransactionTypes(String agentId)

Specified by:

getTransactionTypes in interface LiveAggregateRepository

mergeInAuxThreadProfiles

public long mergeInAuxThreadProfiles(String agentId,
                                     LiveAggregateRepository.AggregateQuery query,
                                     ProfileCollector collector)

Specified by:

mergeInAuxThreadProfiles in interface LiveAggregateRepository

mergeInMainThreadProfiles

public long mergeInMainThreadProfiles(String agentId,
                                      LiveAggregateRepository.AggregateQuery query,
                                      ProfileCollector collector)

Specified by:

mergeInMainThreadProfiles in interface LiveAggregateRepository

mergeInOverallErrorSummary

public long mergeInOverallErrorSummary(String agentId,
                                       LiveAggregateRepository.SummaryQuery query,
                                       OverallErrorSummaryCollector collector)

Specified by:

mergeInOverallErrorSummary in interface LiveAggregateRepository

mergeInOverallSummary

public long mergeInOverallSummary(String agentId,
                                  LiveAggregateRepository.SummaryQuery query,
                                  OverallSummaryCollector collector)

Specified by:

mergeInOverallSummary in interface LiveAggregateRepository

mergeInQueries

public long mergeInQueries(String agentId,
                           LiveAggregateRepository.AggregateQuery query,
                           QueryCollector collector)
                    throws IOException

Specified by:

mergeInQueries in interface LiveAggregateRepository

Throws:

IOException

mergeInServiceCalls

public long mergeInServiceCalls(String agentId,
                                LiveAggregateRepository.AggregateQuery query,
                                ServiceCallCollector collector)
                         throws IOException

Specified by:

mergeInServiceCalls in interface LiveAggregateRepository

Throws:

IOException

mergeInTransactionNameErrorSummaries

public long mergeInTransactionNameErrorSummaries(String agentId,
                                                 LiveAggregateRepository.SummaryQuery query,
                                                 TransactionNameErrorSummaryCollector collector)

Specified by:

mergeInTransactionNameErrorSummaries in interface LiveAggregateRepository

mergeInTransactionNameSummaries

public long mergeInTransactionNameSummaries(String agentId,
                                            LiveAggregateRepository.SummaryQuery query,
                                            TransactionNameSummaryCollector collector)

Specified by:

mergeInTransactionNameSummaries in interface LiveAggregateRepository