com.lucidworks.apollo.pipeline.index

Class IndexPipelineDefinitionStore

java.lang.Object

<any>

com.lucidworks.apollo.component.ItemStore<T>

com.lucidworks.apollo.pipeline.impl.AbstractPipelineDefinitionStore<IndexPipelineDefinition>

com.lucidworks.apollo.pipeline.index.IndexPipelineDefinitionStore

All Implemented Interfaces:

com.lucidworks.apollo.pipeline.index.api.IndexPipelineDefinitionReadWriteStore, com.lucidworks.apollo.pipeline.index.api.IndexPipelineDefinitionRegistry, PipelineDefinitionRegistry<IndexPipelineDefinition>

public class IndexPipelineDefinitionStore
extends com.lucidworks.apollo.pipeline.impl.AbstractPipelineDefinitionStore<IndexPipelineDefinition>
implements com.lucidworks.apollo.pipeline.index.api.IndexPipelineDefinitionRegistry, com.lucidworks.apollo.pipeline.index.api.IndexPipelineDefinitionReadWriteStore

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ZK_PATH

Constructor Summary

Constructors

Constructor and Description
IndexPipelineDefinitionStore(CuratorComponent curator, MetricRegistry metricRegistry, ObjectMapper mapper, StringDecryptor decryptor, StringEncryptor encryptor)

Method Summary

Methods inherited from class com.lucidworks.apollo.pipeline.impl.AbstractPipelineDefinitionStore

get, getCached, init, list, register, shutdown, unregister, update

Methods inherited from class com.lucidworks.apollo.component.ItemStore

init

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.lucidworks.apollo.pipeline.PipelineDefinitionRegistry

get, getCached, list, register, unregister, update

Field Detail

ZK_PATH

public static final java.lang.String ZK_PATH

See Also:

Constant Field Values

Constructor Detail

IndexPipelineDefinitionStore

public IndexPipelineDefinitionStore(CuratorComponent curator,
                                    MetricRegistry metricRegistry,
                                    ObjectMapper mapper,
                                    StringDecryptor decryptor,
                                    StringEncryptor encryptor)