final class CoreServiceImpl extends java.lang.Object implements CoreService
Modifier and Type | Field and Description |
---|---|
private static java.lang.String |
CORE_IDENTIFIER |
private CoreConfiguration |
coreConfiguration |
private static org.slf4j.Logger |
log |
private javax.inject.Provider<CoreAdminRequestBuilder> |
requestBuilderProvider |
private SolrServerLookup |
serverLookup |
Constructor and Description |
---|
CoreServiceImpl(CoreConfiguration coreConfiguration,
SolrServerLookup serverLookup,
javax.inject.Provider<CoreAdminRequestBuilder> requestBuilder) |
Modifier and Type | Method and Description |
---|---|
private CoreInfo |
buildCoreInfoFromResult(CoreIdentifier core,
org.apache.solr.common.util.NamedList<java.lang.Object> result) |
boolean |
create(CoreIdentifier core) |
boolean |
drop(CoreIdentifier core) |
private boolean |
execute(org.apache.solr.client.solrj.request.CoreAdminRequest request,
CoreIdentifier core) |
boolean |
exist(CoreIdentifier core) |
boolean |
exist(CoreInfos coreInfos) |
private java.util.List<org.apache.solr.client.solrj.response.CoreAdminResponse> |
getCoreAdminResponse() |
private org.apache.solr.client.solrj.response.CoreAdminResponse |
getCoreAdminResponse(CoreIdentifier core) |
private org.apache.solr.client.solrj.response.CoreAdminResponse |
getCoreAdminResponse(CoreIdentifier core,
org.apache.solr.client.solrj.SolrServer server) |
private CoreInfos |
getCoreInfos(CoreIdentifier coreIdentifier) |
CoreInfos |
getCores() |
CoreInfos |
getCores(java.lang.String name) |
CoreInfos |
getCores(java.lang.String name,
java.lang.String group) |
CoreInfos |
getOptimizableCores() |
private org.joda.time.DateTime |
getTimeStampFrom(java.lang.Object value) |
private CoreInfos |
obtainValidCoreInfos(java.util.List<org.apache.solr.client.solrj.response.CoreAdminResponse> responses) |
void |
optimize(CoreInfo core) |
boolean |
renameFromTo(CoreIdentifier coreTmp,
CoreIdentifier core) |
private void |
setCoreInfoProperties(CoreInfo coreInfo,
org.apache.solr.common.util.NamedList<java.lang.Object> result) |
boolean |
swap(CoreIdentifier core,
CoreIdentifier coreTmp) |
private static final java.lang.String CORE_IDENTIFIER
private static final org.slf4j.Logger log
private final javax.inject.Provider<CoreAdminRequestBuilder> requestBuilderProvider
private final SolrServerLookup serverLookup
private final CoreConfiguration coreConfiguration
@Inject public CoreServiceImpl(CoreConfiguration coreConfiguration, SolrServerLookup serverLookup, javax.inject.Provider<CoreAdminRequestBuilder> requestBuilder)
public CoreInfos getCores()
getCores
in interface CoreService
public CoreInfos getCores(java.lang.String name)
getCores
in interface CoreService
public CoreInfos getCores(java.lang.String name, java.lang.String group)
getCores
in interface CoreService
private CoreInfos getCoreInfos(CoreIdentifier coreIdentifier)
private org.apache.solr.client.solrj.response.CoreAdminResponse getCoreAdminResponse(CoreIdentifier core)
private java.util.List<org.apache.solr.client.solrj.response.CoreAdminResponse> getCoreAdminResponse()
private org.apache.solr.client.solrj.response.CoreAdminResponse getCoreAdminResponse(CoreIdentifier core, org.apache.solr.client.solrj.SolrServer server)
private CoreInfos obtainValidCoreInfos(java.util.List<org.apache.solr.client.solrj.response.CoreAdminResponse> responses)
private CoreInfo buildCoreInfoFromResult(CoreIdentifier core, org.apache.solr.common.util.NamedList<java.lang.Object> result)
private void setCoreInfoProperties(CoreInfo coreInfo, org.apache.solr.common.util.NamedList<java.lang.Object> result)
private org.joda.time.DateTime getTimeStampFrom(java.lang.Object value)
public boolean exist(CoreIdentifier core)
exist
in interface CoreService
public boolean exist(CoreInfos coreInfos)
public boolean create(CoreIdentifier core)
create
in interface CoreService
public boolean drop(CoreIdentifier core)
drop
in interface CoreService
public boolean swap(CoreIdentifier core, CoreIdentifier coreTmp)
swap
in interface CoreService
public boolean renameFromTo(CoreIdentifier coreTmp, CoreIdentifier core)
renameFromTo
in interface CoreService
public void optimize(CoreInfo core) throws org.apache.solr.client.solrj.SolrServerException, java.io.IOException
optimize
in interface CoreService
org.apache.solr.client.solrj.SolrServerException
java.io.IOException
private boolean execute(org.apache.solr.client.solrj.request.CoreAdminRequest request, CoreIdentifier core)
public CoreInfos getOptimizableCores()
getOptimizableCores
in interface CoreService