Package org.apache.solr.handler.component

Class TrackingShardHandlerFactory

java.lang.Object

org.apache.solr.handler.component.ShardHandlerFactory

org.apache.solr.handler.component.HttpShardHandlerFactory

org.apache.solr.handler.component.TrackingShardHandlerFactory

All Implemented Interfaces:

AutoCloseable, org.apache.solr.metrics.SolrMetricProducer, org.apache.solr.util.plugin.PluginInfoInitialized

public class TrackingShardHandlerFactory
extends org.apache.solr.handler.component.HttpShardHandlerFactory

A ShardHandlerFactory that extends HttpShardHandlerFactory and tracks requests made to nodes/shards such that interested parties can watch such requests and make assertions inside tests

This is a test helper only and should *not* be used for production.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TrackingShardHandlerFactory.RequestTrackingQueue	A queue having helper methods to select requests by shard and purpose.
static class	TrackingShardHandlerFactory.ShardRequestAndParams

Field Summary

Fields inherited from class org.apache.solr.handler.component.HttpShardHandlerFactory

commExecutor, defaultClient, httpListenerFactory, loadbalancer, r

Fields inherited from class org.apache.solr.handler.component.ShardHandlerFactory

DEFAULT_SHARDHANDLER_INFO

Fields inherited from interface org.apache.solr.metrics.SolrMetricProducer

CATEGORY_ATTR, HANDLER_ATTR, NAME_ATTR, OPERATION_ATTR, PLUGIN_NAME_ATTR, RESULT_ATTR, TYPE_ATTR

Constructor Summary

Constructors

Constructor	Description
TrackingShardHandlerFactory()

Method Summary

Modifier and Type	Method	Description
void	close()
org.apache.solr.handler.component.ShardHandler	getShardHandler()
Queue<TrackingShardHandlerFactory.ShardRequestAndParams>	getTrackingQueue()
boolean	isTracking()
static void	setTrackingQueue(List<JettySolrRunner> runners, Queue<TrackingShardHandlerFactory.ShardRequestAndParams> queue)	Sets the tracking queue for all nodes participating in this cluster.
void	setTrackingQueue(Queue<TrackingShardHandlerFactory.ShardRequestAndParams> queue)	Set the tracking queue for this factory.
static void	setTrackingQueue(MiniSolrCloudCluster cluster, Queue<TrackingShardHandlerFactory.ShardRequestAndParams> queue)	Sets the tracking queue for all nodes participating in this cluster.

Methods inherited from class org.apache.solr.handler.component.HttpShardHandlerFactory

buildURLList, getClient, getParameter, getReplicaListTransformer, getSolrMetricsContext, init, initializeMetrics, newLBHttpSolrClientReq, setSecurityBuilder

Methods inherited from class org.apache.solr.handler.component.ShardHandlerFactory

newInstance

Methods inherited from class java.lang.Object

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

Constructor Details

TrackingShardHandlerFactory

public TrackingShardHandlerFactory()

Method Details

setTrackingQueue

public void setTrackingQueue(Queue<TrackingShardHandlerFactory.ShardRequestAndParams> queue)

Set the tracking queue for this factory. All the ShardHandler instances created from this factory will share the queue and call Queue.offer(Object) with a TrackingShardHandlerFactory.ShardRequestAndParams instance whenever ShardHandler.submit(ShardRequest, String, org.apache.solr.common.params.ModifiableSolrParams) is called before the request is actually submitted to the wrapped HttpShardHandlerFactory instance.

If a tracking queue is already set then this call will overwrite and replace the previous queue with this one.

Parameters:

queue - the Queue to be used for tracking shard requests

getTrackingQueue

public Queue<TrackingShardHandlerFactory.ShardRequestAndParams> getTrackingQueue()

Returns:

the Queue being used for tracking, null if none has been set

isTracking

public boolean isTracking()

Returns:

true if a tracking queue has been set through setTrackingQueue(java.util.List, java.util.Queue), false otherwise

getShardHandler

public org.apache.solr.handler.component.ShardHandler getShardHandler()

Overrides:

getShardHandler in class org.apache.solr.handler.component.HttpShardHandlerFactory

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.solr.metrics.SolrMetricProducer

Overrides:

close in class org.apache.solr.handler.component.HttpShardHandlerFactory

setTrackingQueue

public static void setTrackingQueue(MiniSolrCloudCluster cluster,
 Queue<TrackingShardHandlerFactory.ShardRequestAndParams> queue)

Sets the tracking queue for all nodes participating in this cluster. Once this method returns, all search and core admin requests distributed to shards will be submitted to the given queue.

This is equivalent to calling: TrackingShardHandlerFactory.setTrackingQueue(cluster.getJettySolrRunners(), queue)

See Also:

• setTrackingQueue(java.util.List, java.util.Queue)

setTrackingQueue

public static void setTrackingQueue(List<JettySolrRunner> runners,
 Queue<TrackingShardHandlerFactory.ShardRequestAndParams> queue)

Sets the tracking queue for all nodes participating in this cluster. Once this method returns, all search and core admin requests distributed to shards will be submitted to the given queue.

Parameters:

runners - a list of JettySolrRunner nodes

queue - an implementation of Queue which accepts TrackingShardHandlerFactory.ShardRequestAndParams instances