Interface | Description |
---|---|
ClientFactory | |
ClientFactory.ContextAwareRESTErrorListener | |
ClientFactory.RemoteFunction<T,R> | |
ClientFactory.RemoteRunnable<T> | |
CollectionComponent.CollectionChangeAware | |
CrudComponent.CrudBiFunction<T,U,R> | |
CrudComponent.CrudConsumer<T> | |
CrudComponent.CrudFunction<T,R> | |
CrudComponent.CrudSupplier<R> | |
DefaultSearchClusterRegistrar.DefaultSearchCluster | |
ResourceLoader | |
SearchClusterComponent.DefaultSolrClient |
Represents the solrClient for the "Default" solr cluster.
|
SearchClusterComponent.SolrClientAvailableCallback | |
SolrClientFactory |
Represents a component that can return SolrClients.
|
SolrSchemaLoader |
Class | Description |
---|---|
AbstractCollectionRegistrar |
TODO: document me.
|
AbstractCollectionRegistrar.CollectionToCreate | |
AuthContextComponent | |
BlobStoreResourceLoader | |
BufferingSolrServer |
Simple class that wraps
SolrClient instance and adds a simple buffer on top of it. |
ClasspathResourceLoader | |
ClientComponent | |
CollectionComponent |
Does basic data reading involving collections.
|
CollectionManager | |
CollectionManager.IdPathCheckUpdateStrategy | |
CollectionManager.IdValidatingUpdateStrategy | |
CollectionManager.PipelineCreatingUpdateStrategy | |
CollectionMetricHelper |
Encapsulates various interesting statistics involving collections.
|
CollectionMetricHelper.RequestsAndTime | |
CollectionStore |
Store collection metadata in ZooKeeper
|
ConfigurationComponent |
This component defines the configuration for a given service.
|
CrudComponent<E extends com.lucidworks.apollo.common.objects.Entity> |
Encapsulate our REST CRUD semantics in a composeable way.
|
CuratorComponent |
Manages CuratorFramework instances for the application.
|
CuratorDependencyComponent |
Created to push CuratorFramework dependency into DependencyManager
|
CuratorServiceRegistryComponent | |
DefaultSearchClusterRegistrar |
Responsible only for registering the default SearchCluster based on default parameters in the config file, if it
doesn't already exist.
|
EphemeralItemStore<T> |
Guice component version of
com.lucidworks.apollo.store.EphemeralItemStore that has
WhenReady and PreDestroy lifecycle methods. |
ExecutorComponent |
A convenience class for creating executor services.
|
ExecutorComponent.AbortPolicy |
Just like the java.util.concurrent.ThreadPoolExecutor.AbortPolicy, but with a better error message.
|
FeatureStore | |
FusionClientProvider | |
HistoryStore | |
IgniteClientComponent |
Bind this instead of IgniteComponent if you want to use a client-mode connection to Ignite (that is, connect and read, but do not cache things locally).
|
IgniteComponent |
Manages a global reference to Apache Ignite.
|
IgniteModule |
Simple module to register Ignite
|
ItemCache<T> |
Guice component version of
com.lucidworks.apollo.store.ItemCache that has
WhenReady and PreDestroy lifecycle methods. |
ItemStore<T> |
Guice component version of
com.lucidworks.apollo.store.ItemStore that has
WhenReady lifecycle method. |
JettyAvailableWatcher |
Polls for when Jetty is available and listening on the base URI (/api/v1).
|
JettyAvailableWatcher.JettyServer | |
LicenseComponent | |
LinkExtractingUpdateStrategy<T extends com.lucidworks.apollo.common.objects.Entity> |
Create links for pipeline stage properties which refer to other resources.
|
MetricLoggingComponent |
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.
|
MetricSchedulesRegistrar |
Responsible for registering aggregations and schedules that process data in
system_metrics collection.
|
NodeIdComponent |
Manages a persistent identifier for this node.
|
ObjectMapperProvider | |
PipelineDocumentUtils | |
ScheduledRunnableComponent |
A simple component to centralize the various scheduled tasks we have in the system.
|
SearchClusterComponent |
Provides access to the Solr servers associated with a given collectionId.
|
SearchClusterComponent.OverrideCollectionAndDelegateSolrClient | |
SearchClusterStore |
Stores records about search clusters -- i.e.
|
SearchClusterValidator | |
ServiceIdComponent |
Create a consistent (persisted) ID for this service (or application -- connectors, or API, etc.)
The ID can either be set in a system property, or written to a file.
|
ServiceProviderCacheComponent |
Simple singleton wrapper around ServiceProviderCache
|
SignalTypeStore | |
SimpleCachingSolrSchemaLoader |
Caches Solr schema in a guava cache with configurable cache size and expiration time
|
SolrDocumentValidator | |
SolrHistoryStore | |
SolrMetricLoggingComponent |
Log statistics coming from Solr back into a Solr collection
|
SolrSchemaLoader.SolrDynField | |
SolrSchemaLoader.SolrSchema | |
SystemAppRegistrar |
Creates system app that will link all system objects
to prevent them from being deleted by cascade deletes.
|
SystemLogCollectionRegistrar | |
ZkAwareCachingSolrSchemaLoader |
Invalidates
SimpleCachingSolrSchemaLoader 's cache on Zk's watcher events |
ZKImportExportComponent |
Provides CRUD access to the data inside Zookeeper.
|
ZooKeeperConfigurationComponent |
Creates ZK-backed configuration objects, via Netflix Archaius and Apache Commons Configuration.
|
ZooKeeperConfigurationSource |
This extends Archaius's ZooKeeperConfigurationSource because it depends on an old version of Guava and throws
exceptions on close.
|
Exception | Description |
---|---|
ClientComponent.ClientResourceNotReady |