Package com.lucidworks.apollo.pipeline.impl

Class AbstractPipelineDefinitionStore<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>>

java.lang.Object

com.lucidworks.apollo.store.AbstractItemReadStore<T>

com.lucidworks.apollo.store.AbstractItemStore<T>

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

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

All Implemented Interfaces:

PipelineDefinitionRegistry<T>, com.lucidworks.apollo.store.ItemReadStore<T>, com.lucidworks.apollo.store.ItemReadWriteStore<T>, com.lucidworks.apollo.store.ItemWriteStore<T>

public abstract class AbstractPipelineDefinitionStore<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>>
extends com.lucidworks.apollo.store.ItemStore<T>
implements PipelineDefinitionRegistry<T>

Bridge between PipelineDefinitionRegistry and ItemStore

Nested Class Summary

Nested classes/interfaces inherited from interface com.lucidworks.apollo.store.ItemReadStore

com.lucidworks.apollo.store.ItemReadStore.ItemAndVersion<T extends Object>

Field Summary

Fields inherited from class com.lucidworks.apollo.store.ItemStore

createMode, curatorFramework

Fields inherited from class com.lucidworks.apollo.store.AbstractItemStore

itemWriter, notFound, putItemTimer, serializeTimer, storePath

Fields inherited from class com.lucidworks.apollo.store.AbstractItemReadStore

CHARSET, deserializeTimer, getItemTimer, itemPath, itemReader, listItemsTimer, LOG, metricRegistry

Constructor Summary

Constructors

Constructor	Description
AbstractPipelineDefinitionStore(org.apache.curator.framework.CuratorFramework curator, com.codahale.metrics.MetricRegistry metricRegistry, String storePath, com.lucidworks.apollo.store.ItemReader<T> itemReader, com.lucidworks.apollo.store.ItemWriter<T> itemWriter)

Method Summary

Modifier and Type	Method	Description
Optional<T>	get(String pipelineId)
Optional<T>	getCached(String pipelineId)
List<T>	list()
T	register(T pipelineDefinition)
void	shutdown()
boolean	unregister(String pipelineId)
T	update(String pipelineId, T pipelineDefinition)

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

checkDataLengthError, createItem, createItemOp, deleteAllItems, deleteItem, deleteItemOp, getCreateMode, getItem, getItemBytes, getItems, hasItem, listItems, putItem, putItem, replaceItem, replaceItemOp

Methods inherited from class com.lucidworks.apollo.store.AbstractItemStore

asBytes

Methods inherited from class com.lucidworks.apollo.store.AbstractItemReadStore

convert, getPath, metricName

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.lucidworks.apollo.store.ItemWriteStore

deleteItem, putItem

Constructor Details

AbstractPipelineDefinitionStore

public AbstractPipelineDefinitionStore(org.apache.curator.framework.CuratorFramework curator,
 com.codahale.metrics.MetricRegistry metricRegistry,
 String storePath,
 com.lucidworks.apollo.store.ItemReader<T> itemReader,
 com.lucidworks.apollo.store.ItemWriter<T> itemWriter)
                                throws Exception

Throws:

Exception

Method Details

shutdown

@PreDestroy
public void shutdown()
              throws IOException

Throws:

IOException

register

public T register(T pipelineDefinition)

Specified by:

register in interface PipelineDefinitionRegistry<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>>

getCached

public Optional<T> getCached(String pipelineId)

Specified by:

getCached in interface PipelineDefinitionRegistry<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>>

get

public Optional<T> get(String pipelineId)

Specified by:

get in interface PipelineDefinitionRegistry<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>>

update

public T update(String pipelineId,
 T pipelineDefinition)

Specified by:

update in interface PipelineDefinitionRegistry<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>>

unregister

public boolean unregister(String pipelineId)

Specified by:

unregister in interface PipelineDefinitionRegistry<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>>

list

public List<T> list()

Specified by:

list in interface PipelineDefinitionRegistry<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>>