Package ch.rswk.meta.engine

Class MetaService

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

ch.rswk.meta.engine.AbstractEngineIdleService<MetaService.MetaServiceConfig>

ch.rswk.meta.engine.MetaService

All Implemented Interfaces:

EngineServices.ConfigurableService<MetaService.MetaServiceConfig>, EngineServices.InfoProvidingService, com.google.common.util.concurrent.Service

@Singleton
public class MetaService
extends AbstractEngineIdleService<MetaService.MetaServiceConfig>

MetaService provides CRUD functionality for all meta model entities. Uses a LuceneService instance to store the meta entities.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	MetaService.CachedMetaAction
static final record	MetaService.CachedMetaType
static final record	MetaService.MetaServiceConfig
private static final record	MetaService.MetaServiceSearchContext
private static final record	MetaService.PartialUpdate

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field	Description
private final Map<String,MetaService.CachedMetaAction>	actionCache
private final BackupService	backupService
private static final Protocol.ErrorReplyFactory	ILLEGAL_TYPE_ERROR
private static final org.slf4j.Logger	LOG
private final LuceneService	luceneService
private static final com.fasterxml.jackson.databind.ObjectReader	META_READER
private static final Protocol.ErrorReplyFactory	NO_META_ERROR
private static final Protocol.ErrorReplyFactory	NO_OBJECT_FOR_UPDATE_ERROR
private static final Protocol.ErrorReplyFactory	NO_QUERY_ERROR
private final MetaSchema	schema
private static final Protocol.ErrorReplyFactory	SEARCH_ERROR
private com.codahale.metrics.Meter	searchMeter
private final Map<String,MetaService.CachedMetaType>	typeCache
private static final Protocol.ErrorReplyFactory	UPDATE_ERROR
private static final Protocol.ErrorReplyFactory	UPDATE_WITHOUT_ID_ERROR
private com.codahale.metrics.Meter	updateMeter
private static final Protocol.ErrorReplyFactory	VALIDATION_ERROR
private com.codahale.metrics.Meter	validationErrorMeter
private final MetaValidator	validator
private static final Protocol.ErrorReplyFactory	WRITE_ERROR
private static final Protocol.ErrorReplyFactory	WRITE_LOG_ERROR
private com.codahale.metrics.Meter	writeErrorMeter
private com.codahale.metrics.Meter	writeMeter

Fields inherited from class ch.rswk.meta.engine.AbstractEngineIdleService

runtime

Constructor Summary

Constructors

Constructor	Description
MetaService(BackupService backupService, MetaService.MetaServiceConfig config, LuceneService luceneService, Set<MetaAction> metaActions, Set<MetaType> metaTypes, EngineRuntime runtime, MetaSchema schema, MetaValidator validator)

Method Summary

Modifier and Type	Method	Description
static com.google.common.util.concurrent.ListenableFuture<Void>	deleteRecursive(@Nullable String channel, @Nullable AtomicInteger counter, @Nullable Consumer<Meta> handler, SearchRequest request, MetaService service)
private LuceneService.SearchResult	executeLuceneSearch(LuceneService.LuceneContext context, @Nullable Function<LuceneService.LuceneContext,MetaService.MetaServiceSearchContext> queryProducer, SearchRequest request)
private MetaService.PartialUpdate	forgePartialUpdate(MetaObject existing, MetaObject update)
Optional<MetaService.CachedMetaAction>	getCachedAction(String actionId)
Optional<MetaService.CachedMetaType>	getCachedType(String typeId)
private MetaService.CachedMetaAction	newCachedMetaAction(MetaAction action)
private MetaService.CachedMetaType	newCachedMetaType(MetaType type)
private org.apache.lucene.document.Document	newMetaDocument(Meta meta)
private SearchReply	newSearchReply(SearchRequest request, LuceneService.SearchResult result)
protected com.google.common.util.concurrent.ListenableFuture<WriteObjectUpdateReply>	processUpdate(@Nullable String logId, WriteObjectUpdateRequest request)
protected com.google.common.util.concurrent.ListenableFuture<WriteReply>	processWrite(@Nullable String logId, String newMetaId, boolean writeLog, WriteRequest request)
com.google.common.util.concurrent.ListenableFuture<SearchReply>	search(SearchRequest request)
com.google.common.util.concurrent.ListenableFuture<SearchReply>	search2(SearchRequest request, org.apache.lucene.search.Query query, @Nullable org.apache.lucene.search.Sort sort)
private com.google.common.util.concurrent.ListenableFuture<SearchReply>	searchInternal(@Nullable Function<LuceneService.LuceneContext,MetaService.MetaServiceSearchContext> queryProducer, SearchRequest request)
static com.google.common.util.concurrent.ListenableFuture<Void>	searchRecursive(Executor executor, Function<SearchReply,com.google.common.util.concurrent.ListenableFuture<?>> replyConsumer, SearchRequest request, Function<SearchRequest,com.google.common.util.concurrent.ListenableFuture<SearchReply>> service)
protected void	shutDown()
protected void	startUp()
private static MetaLogType	toLogType(WriteAction action)
private Optional<ErrorReplyException>	validateMeta(Meta meta)
com.google.common.util.concurrent.ListenableFuture<WriteReply>	write(WriteRequest request)
private void	writeLog(WriteAction action, @Nullable String channel, @Nullable com.fasterxml.jackson.databind.node.ObjectNode data, @Nullable String logId, Meta meta, String metaId, org.apache.lucene.index.IndexWriter writer)
private void	writeMeta(WriteAction action, @Nullable String channel, @Nullable com.fasterxml.jackson.databind.node.ObjectNode data, @Nullable org.apache.lucene.document.Document document, @Nullable String logId, Meta meta, boolean writeLog, org.apache.lucene.index.IndexWriter writer)
com.google.common.util.concurrent.ListenableFuture<WriteObjectUpdateReply>	writeObjectUpdate(WriteObjectUpdateRequest request)

Methods inherited from class ch.rswk.meta.engine.AbstractEngineIdleService

configClass, configReference, serviceName

Methods inherited from class com.google.common.util.concurrent.AbstractIdleService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface ch.rswk.meta.engine.EngineServices.ConfigurableService

config, onConfigChanged

Methods inherited from interface ch.rswk.meta.engine.EngineServices.InfoProvidingService

getServiceInfo

Field Details

LOG

private static final org.slf4j.Logger LOG

ILLEGAL_TYPE_ERROR

private static final Protocol.ErrorReplyFactory ILLEGAL_TYPE_ERROR

META_READER

private static final com.fasterxml.jackson.databind.ObjectReader META_READER

NO_META_ERROR

private static final Protocol.ErrorReplyFactory NO_META_ERROR

NO_OBJECT_FOR_UPDATE_ERROR

private static final Protocol.ErrorReplyFactory NO_OBJECT_FOR_UPDATE_ERROR

NO_QUERY_ERROR

private static final Protocol.ErrorReplyFactory NO_QUERY_ERROR

SEARCH_ERROR

private static final Protocol.ErrorReplyFactory SEARCH_ERROR

UPDATE_ERROR

private static final Protocol.ErrorReplyFactory UPDATE_ERROR

UPDATE_WITHOUT_ID_ERROR

private static final Protocol.ErrorReplyFactory UPDATE_WITHOUT_ID_ERROR

VALIDATION_ERROR

private static final Protocol.ErrorReplyFactory VALIDATION_ERROR

WRITE_ERROR

private static final Protocol.ErrorReplyFactory WRITE_ERROR

WRITE_LOG_ERROR

private static final Protocol.ErrorReplyFactory WRITE_LOG_ERROR

actionCache

private final Map<String,MetaService.CachedMetaAction> actionCache

backupService

private final BackupService backupService

luceneService

private final LuceneService luceneService

schema

private final MetaSchema schema

typeCache

private final Map<String,MetaService.CachedMetaType> typeCache

validator

private final MetaValidator validator

searchMeter

private com.codahale.metrics.Meter searchMeter

updateMeter

private com.codahale.metrics.Meter updateMeter

validationErrorMeter

private com.codahale.metrics.Meter validationErrorMeter

writeErrorMeter

private com.codahale.metrics.Meter writeErrorMeter

writeMeter

private com.codahale.metrics.Meter writeMeter

Constructor Details

MetaService

@Inject
public MetaService(BackupService backupService,
 MetaService.MetaServiceConfig config,
 @Named("Meta")
 LuceneService luceneService,
 Set<MetaAction> metaActions,
 Set<MetaType> metaTypes,
 EngineRuntime runtime,
 MetaSchema schema,
 MetaValidator validator)

Method Details

startUp

protected void startUp()
                throws Exception

Overrides:

startUp in class AbstractEngineIdleService<MetaService.MetaServiceConfig>

Throws:

Exception

newCachedMetaAction

private MetaService.CachedMetaAction newCachedMetaAction(MetaAction action)

newCachedMetaType

private MetaService.CachedMetaType newCachedMetaType(MetaType type)

shutDown

protected void shutDown()
                 throws Exception

Overrides:

shutDown in class AbstractEngineIdleService<MetaService.MetaServiceConfig>

Throws:

Exception

search

public com.google.common.util.concurrent.ListenableFuture<SearchReply> search(SearchRequest request)

search2

public com.google.common.util.concurrent.ListenableFuture<SearchReply> search2(SearchRequest request,
 org.apache.lucene.search.Query query,
 @Nullable org.apache.lucene.search.Sort sort)

searchInternal

private com.google.common.util.concurrent.ListenableFuture<SearchReply> searchInternal(@Nullable Function<LuceneService.LuceneContext,MetaService.MetaServiceSearchContext> queryProducer,
 SearchRequest request)

executeLuceneSearch

private LuceneService.SearchResult executeLuceneSearch(LuceneService.LuceneContext context,
 @Nullable Function<LuceneService.LuceneContext,MetaService.MetaServiceSearchContext> queryProducer,
 SearchRequest request)
                                                throws IOException,
org.apache.lucene.queryparser.flexible.core.QueryNodeException

Throws:

IOException

org.apache.lucene.queryparser.flexible.core.QueryNodeException

newSearchReply

private SearchReply newSearchReply(SearchRequest request,
 LuceneService.SearchResult result)

write

public com.google.common.util.concurrent.ListenableFuture<WriteReply> write(WriteRequest request)

processWrite

protected com.google.common.util.concurrent.ListenableFuture<WriteReply> processWrite(@Nullable String logId,
 String newMetaId,
 boolean writeLog,
 WriteRequest request)

writeObjectUpdate

public com.google.common.util.concurrent.ListenableFuture<WriteObjectUpdateReply> writeObjectUpdate(WriteObjectUpdateRequest request)

processUpdate

protected com.google.common.util.concurrent.ListenableFuture<WriteObjectUpdateReply> processUpdate(@Nullable String logId,
 WriteObjectUpdateRequest request)

forgePartialUpdate

private MetaService.PartialUpdate forgePartialUpdate(MetaObject existing,
 MetaObject update)

validateMeta

private Optional<ErrorReplyException> validateMeta(Meta meta)

newMetaDocument

private org.apache.lucene.document.Document newMetaDocument(Meta meta)

writeMeta

private void writeMeta(WriteAction action,
 @Nullable String channel,
 @Nullable com.fasterxml.jackson.databind.node.ObjectNode data,
 @Nullable org.apache.lucene.document.Document document,
 @Nullable String logId,
 Meta meta,
 boolean writeLog,
 org.apache.lucene.index.IndexWriter writer)

writeLog

private void writeLog(WriteAction action,
 @Nullable String channel,
 @Nullable com.fasterxml.jackson.databind.node.ObjectNode data,
 @Nullable String logId,
 Meta meta,
 String metaId,
 org.apache.lucene.index.IndexWriter writer)

toLogType

private static MetaLogType toLogType(WriteAction action)

getCachedAction

public Optional<MetaService.CachedMetaAction> getCachedAction(String actionId)

getCachedType

public Optional<MetaService.CachedMetaType> getCachedType(String typeId)

deleteRecursive

public static com.google.common.util.concurrent.ListenableFuture<Void> deleteRecursive(@Nullable String channel,
 @Nullable AtomicInteger counter,
 @Nullable Consumer<Meta> handler,
 SearchRequest request,
 MetaService service)

searchRecursive

public static com.google.common.util.concurrent.ListenableFuture<Void> searchRecursive(Executor executor,
 Function<SearchReply,com.google.common.util.concurrent.ListenableFuture<?>> replyConsumer,
 SearchRequest request,
 Function<SearchRequest,com.google.common.util.concurrent.ListenableFuture<SearchReply>> service)