Class DelegatingCloudManager
- java.lang.Object
-
- org.apache.solr.client.solrj.cloud.autoscaling.DelegatingCloudManager
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
,SolrCloudManager
,SolrCloseable
public class DelegatingCloudManager extends Object implements SolrCloudManager
Base class for overriding some behavior ofSolrCloudManager
.
-
-
Field Summary
Fields Modifier and Type Field Description protected SolrCloudManager
delegate
-
Constructor Summary
Constructors Constructor Description DelegatingCloudManager(SolrCloudManager delegate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
ClusterStateProvider
getClusterStateProvider()
DistribStateManager
getDistribStateManager()
DistributedQueueFactory
getDistributedQueueFactory()
NodeStateProvider
getNodeStateProvider()
ObjectCache
getObjectCache()
TimeSource
getTimeSource()
byte[]
httpRequest(String url, SolrRequest.METHOD method, Map<String,String> headers, String payload, int timeout, boolean followRedirects)
boolean
isClosed()
SolrResponse
request(SolrRequest req)
-
-
-
Field Detail
-
delegate
protected final SolrCloudManager delegate
-
-
Constructor Detail
-
DelegatingCloudManager
public DelegatingCloudManager(SolrCloudManager delegate)
-
-
Method Detail
-
getClusterStateProvider
public ClusterStateProvider getClusterStateProvider()
- Specified by:
getClusterStateProvider
in interfaceSolrCloudManager
-
getNodeStateProvider
public NodeStateProvider getNodeStateProvider()
- Specified by:
getNodeStateProvider
in interfaceSolrCloudManager
-
getDistribStateManager
public DistribStateManager getDistribStateManager()
- Specified by:
getDistribStateManager
in interfaceSolrCloudManager
-
getDistributedQueueFactory
public DistributedQueueFactory getDistributedQueueFactory()
- Specified by:
getDistributedQueueFactory
in interfaceSolrCloudManager
-
getObjectCache
public ObjectCache getObjectCache()
- Specified by:
getObjectCache
in interfaceSolrCloudManager
-
isClosed
public boolean isClosed()
- Specified by:
isClosed
in interfaceSolrCloseable
-
getTimeSource
public TimeSource getTimeSource()
- Specified by:
getTimeSource
in interfaceSolrCloudManager
-
request
public SolrResponse request(SolrRequest req) throws IOException
- Specified by:
request
in interfaceSolrCloudManager
- Throws:
IOException
-
httpRequest
public byte[] httpRequest(String url, SolrRequest.METHOD method, Map<String,String> headers, String payload, int timeout, boolean followRedirects) throws IOException
- Specified by:
httpRequest
in interfaceSolrCloudManager
- Throws:
IOException
-
close
public void close() throws IOException
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Throws:
IOException
-
-