com.lucidworks.apollo.component

Class SearchClusterComponent

java.lang.Object

com.lucidworks.apollo.component.SearchClusterComponent

All Implemented Interfaces:

CollectionComponent.CollectionChangeAware, SolrClientFactory

public class SearchClusterComponent
extends java.lang.Object
implements SolrClientFactory, CollectionComponent.CollectionChangeAware

Provides access to the Solr servers associated with a given collectionId.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	SearchClusterComponent.DefaultSolrClient Represents the solrClient for the "Default" solr cluster.
static class	SearchClusterComponent.OverrideCollectionAndDelegateSolrClient
static interface	SearchClusterComponent.SolrClientAvailableCallback

Constructor Summary

Constructors

Constructor and Description
SearchClusterComponent(SearchClusterStore.Cache searchClusterCache, CollectionStore collectionStore, CollectionComponent collectionComponent, ClientComponent clientComponent, ConfigurationComponent configurationComponent, MetricRegistry metricRegistry, ScheduledRunnableComponent scheduler, Ignite ignite, AuthContextComponent authContextComponent)

Method Summary

Modifier and Type	Method and Description
void	flushBuffers()
void	flushCaches() Clears all of the internal caches.
void	flushCollectionId(java.lang.String collectionId)
void	flushSearchClusterId(java.lang.String searchClusterId)
com.lucidworks.apollo.common.auth.AuthContext	getAuthContext(com.lucidworks.apollo.common.models.SearchCluster searchCluster)
BufferingSolrServer	getBufferingSolrServer(java.lang.String collectionId)
com.lucidworks.apollo.common.models.Collection	getCollection(java.lang.String collectionId)
int	getCommitWithin(java.lang.String collectionId)
CuratorFramework	getCurator(java.lang.String collectionId)
com.lucidworks.apollo.partitioning.DocumentAssignmentStrategy	getDocumentAssignmentStrategy(java.lang.String collectionId)
HttpSolrClient	getHttpSolrClient(com.lucidworks.apollo.common.models.SearchCluster searchCluster)
HttpSolrClient	getHttpSolrClient(java.lang.String collectionId)
com.lucidworks.apollo.common.models.SearchCluster	getSearchCluster(com.lucidworks.apollo.common.models.Collection col)
com.lucidworks.apollo.common.models.SearchCluster	getSearchCluster(java.lang.String collectionId)
SearchClusterStore.Cache	getSearchClusterCache()
SolrClient	getSolrClientForCollection(java.lang.String collectionId)
SolrClient	getSolrClientForSearchCluster(java.lang.String clusterId)
org.apache.solr.client.solrj.SolrClient	getSolrServer(java.lang.String collectionId)
void	init(DefaultSearchClusterRegistrar.DefaultSearchCluster dsc, com.lucidworks.apollo.startup.DependencyManager dependencyManager, CollectionStore collectionStore)
void	onCollectionAdded(java.lang.String collectionId)
void	onCollectionRemoved(java.lang.String collectionId)
void	onCollectionUpdated(java.lang.String collectionId)
void	onSearchClusterAvailable(java.lang.String searchClusterId, SearchClusterComponent.SolrClientAvailableCallback callback)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

SearchClusterComponent

public SearchClusterComponent(SearchClusterStore.Cache searchClusterCache,
                              CollectionStore collectionStore,
                              CollectionComponent collectionComponent,
                              ClientComponent clientComponent,
                              ConfigurationComponent configurationComponent,
                              MetricRegistry metricRegistry,
                              ScheduledRunnableComponent scheduler,
                              Ignite ignite,
                              AuthContextComponent authContextComponent)

Method Detail

init

@WhenReady
public void init(DefaultSearchClusterRegistrar.DefaultSearchCluster dsc,
                            com.lucidworks.apollo.startup.DependencyManager dependencyManager,
                            CollectionStore collectionStore)

getSolrClientForSearchCluster

public SolrClient getSolrClientForSearchCluster(java.lang.String clusterId)

Specified by:

getSolrClientForSearchCluster in interface SolrClientFactory

getSolrClientForCollection

public SolrClient getSolrClientForCollection(java.lang.String collectionId)

Specified by:

getSolrClientForCollection in interface SolrClientFactory

getSolrServer

public org.apache.solr.client.solrj.SolrClient getSolrServer(java.lang.String collectionId)

Specified by:

getSolrServer in interface SolrClientFactory

getBufferingSolrServer

public BufferingSolrServer getBufferingSolrServer(java.lang.String collectionId)

Specified by:

getBufferingSolrServer in interface SolrClientFactory

getCollection

public com.lucidworks.apollo.common.models.Collection getCollection(java.lang.String collectionId)

getCommitWithin

public int getCommitWithin(java.lang.String collectionId)

Specified by:

getCommitWithin in interface SolrClientFactory

getSearchCluster

public com.lucidworks.apollo.common.models.SearchCluster getSearchCluster(java.lang.String collectionId)

getSearchCluster

public com.lucidworks.apollo.common.models.SearchCluster getSearchCluster(com.lucidworks.apollo.common.models.Collection col)

getCurator

public CuratorFramework getCurator(java.lang.String collectionId)

getSearchClusterCache

public SearchClusterStore.Cache getSearchClusterCache()

getHttpSolrClient

public HttpSolrClient getHttpSolrClient(com.lucidworks.apollo.common.models.SearchCluster searchCluster)

getHttpSolrClient

public HttpSolrClient getHttpSolrClient(java.lang.String collectionId)

getAuthContext

public com.lucidworks.apollo.common.auth.AuthContext getAuthContext(com.lucidworks.apollo.common.models.SearchCluster searchCluster)

flushBuffers

public void flushBuffers()

flushCaches

public void flushCaches()

Clears all of the internal caches. Useful for testing.

flushSearchClusterId

public void flushSearchClusterId(java.lang.String searchClusterId)

flushCollectionId

public void flushCollectionId(java.lang.String collectionId)

onSearchClusterAvailable

public void onSearchClusterAvailable(java.lang.String searchClusterId,
                                     SearchClusterComponent.SolrClientAvailableCallback callback)

shutdown

@PreDestroy
public void shutdown()

getDocumentAssignmentStrategy

public com.lucidworks.apollo.partitioning.DocumentAssignmentStrategy getDocumentAssignmentStrategy(java.lang.String collectionId)

onCollectionRemoved

public void onCollectionRemoved(java.lang.String collectionId)

Specified by:

onCollectionRemoved in interface CollectionComponent.CollectionChangeAware

onCollectionAdded

public void onCollectionAdded(java.lang.String collectionId)

Specified by:

onCollectionAdded in interface CollectionComponent.CollectionChangeAware

onCollectionUpdated

public void onCollectionUpdated(java.lang.String collectionId)

Specified by:

onCollectionUpdated in interface CollectionComponent.CollectionChangeAware