com.lucidworks.apollo.component

Class MetricLoggingComponent

java.lang.Object

ScheduledReporter

com.lucidworks.apollo.component.MetricLoggingComponent

Direct Known Subclasses:

SolrMetricLoggingComponent

public class MetricLoggingComponent
extends ScheduledReporter

This currently handles scheduling internally instead of using the Scheduler service, for 2 reasons: 1.) it was simpler; using scheduler would require exposing a "store metrics in Solr now" web service endpoint for no reason other than to allow Scheduler to use it; 2.) Scheduler always executes on only one machine in the cluster, while we want to execute this on *each* machine in the cluster.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_METRIC_CLUSTER_NAME
static java.lang.String	DEFAULT_METRIC_COLLECTION_NAME
static java.lang.String	DEFAULT_PIPELINE_ID

Constructor Summary

Constructors

Constructor and Description
MetricLoggingComponent(ConfigurationComponent configurationComponent, CollectionManager collectionManager, MetricRegistry metricRegistry, CollectionComponent collectionComponent, ClientComponent clientComponent, CuratorComponent curatorComponent, ScheduledRunnableComponent scheduler, com.lucidworks.apollo.links.LinkManager linkManager)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getMetricCollectionName()
java.lang.String	getMetricSearchClusterName()
java.lang.String	getTaskName()
void	init(com.lucidworks.apollo.client.resources.CollectionClientResource collectionClientResource, com.lucidworks.apollo.client.resources.IndexPipelineClientResource indexPipelineClientResource, com.lucidworks.apollo.client.resources.SchedulerClientResource schedulerClientResource, SearchClusterComponent.DefaultSolrClient solrClient, com.lucidworks.apollo.links.LinkManager linkManager)
void	report(java.util.SortedMap<java.lang.String,Gauge> gauges, java.util.SortedMap<java.lang.String,Counter> counters, java.util.SortedMap<java.lang.String,Histogram> histograms, java.util.SortedMap<java.lang.String,Meter> meters, java.util.SortedMap<java.lang.String,Timer> timers)
void	report(java.util.SortedMap<java.lang.String,Gauge> gauges, java.util.SortedMap<java.lang.String,Counter> counters, java.util.SortedMap<java.lang.String,Histogram> histograms, java.util.SortedMap<java.lang.String,Meter> meters, java.util.SortedMap<java.lang.String,Timer> timers, java.util.Map<java.lang.String,java.lang.Object> extraProperties)
void	report(java.lang.String host, int port, java.util.SortedMap<java.lang.String,Gauge> gauges, java.util.SortedMap<java.lang.String,Counter> counters, java.util.SortedMap<java.lang.String,Histogram> histograms, java.util.SortedMap<java.lang.String,Meter> meters, java.util.SortedMap<java.lang.String,Timer> timers, java.util.Map<java.lang.String,java.lang.Object> extraProperties)
void	shutdown()
void	start(long initialDelay, long period, java.util.concurrent.TimeUnit unit)
void	start(long period, java.util.concurrent.TimeUnit unit)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_METRIC_COLLECTION_NAME

public static final java.lang.String DEFAULT_METRIC_COLLECTION_NAME

See Also:

Constant Field Values

DEFAULT_METRIC_CLUSTER_NAME

public static final java.lang.String DEFAULT_METRIC_CLUSTER_NAME

See Also:

Constant Field Values

DEFAULT_PIPELINE_ID

public static final java.lang.String DEFAULT_PIPELINE_ID

See Also:

Constant Field Values

Constructor Detail

MetricLoggingComponent

public MetricLoggingComponent(ConfigurationComponent configurationComponent,
                              CollectionManager collectionManager,
                              MetricRegistry metricRegistry,
                              CollectionComponent collectionComponent,
                              ClientComponent clientComponent,
                              CuratorComponent curatorComponent,
                              ScheduledRunnableComponent scheduler,
                              com.lucidworks.apollo.links.LinkManager linkManager)

Method Detail

init

@WhenReady
public void init(com.lucidworks.apollo.client.resources.CollectionClientResource collectionClientResource,
                            com.lucidworks.apollo.client.resources.IndexPipelineClientResource indexPipelineClientResource,
                            com.lucidworks.apollo.client.resources.SchedulerClientResource schedulerClientResource,
                            SearchClusterComponent.DefaultSolrClient solrClient,
                            com.lucidworks.apollo.links.LinkManager linkManager)

shutdown

@PreDestroy
public void shutdown()
                          throws java.io.IOException

Throws:

java.io.IOException

start

public void start(long period,
                  java.util.concurrent.TimeUnit unit)

start

public void start(long initialDelay,
                  long period,
                  java.util.concurrent.TimeUnit unit)

getTaskName

public java.lang.String getTaskName()

getMetricCollectionName

public java.lang.String getMetricCollectionName()

getMetricSearchClusterName

public java.lang.String getMetricSearchClusterName()

report

public void report(java.util.SortedMap<java.lang.String,Gauge> gauges,
                   java.util.SortedMap<java.lang.String,Counter> counters,
                   java.util.SortedMap<java.lang.String,Histogram> histograms,
                   java.util.SortedMap<java.lang.String,Meter> meters,
                   java.util.SortedMap<java.lang.String,Timer> timers)

report

public void report(java.util.SortedMap<java.lang.String,Gauge> gauges,
                   java.util.SortedMap<java.lang.String,Counter> counters,
                   java.util.SortedMap<java.lang.String,Histogram> histograms,
                   java.util.SortedMap<java.lang.String,Meter> meters,
                   java.util.SortedMap<java.lang.String,Timer> timers,
                   java.util.Map<java.lang.String,java.lang.Object> extraProperties)

report

public void report(java.lang.String host,
                   int port,
                   java.util.SortedMap<java.lang.String,Gauge> gauges,
                   java.util.SortedMap<java.lang.String,Counter> counters,
                   java.util.SortedMap<java.lang.String,Histogram> histograms,
                   java.util.SortedMap<java.lang.String,Meter> meters,
                   java.util.SortedMap<java.lang.String,Timer> timers,
                   java.util.Map<java.lang.String,java.lang.Object> extraProperties)