Package ch.rswk.meta.engine

Interface EngineServices

public interface EngineServices

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	EngineServices.ConfigurableService<C>
static class	EngineServices.ConfigWatcherNotificationConsumer<C>
static interface	EngineServices.InfoProvidingService

Field Summary

Fields

Modifier and Type	Field	Description
static final org.slf4j.Logger	LOG
static final Protocol.ErrorReplyFactory	SEARCH_LIMIT_ERROR
static final com.google.common.base.CharMatcher	WHITESPACE_MATCHER

Method Summary

Static Methods

Modifier and Type	Method	Description
static <T, R> com.google.common.util.concurrent.ListenableFuture<List<R>>	batchRequestsRecursive(int batchSize, Executor executor, int index, Function<T,com.google.common.util.concurrent.ListenableFuture<R>> processor, @Nullable List<R> replyCollector, List<T> requests)
static <C> Class<C>	getConfigClass(Object o)
static <C> Class<C>	getFirstParameterizedTypeClass(Object o)
static @Nullable String	sanitizeString(String s)

Field Details

LOG

static final org.slf4j.Logger LOG

WHITESPACE_MATCHER

static final com.google.common.base.CharMatcher WHITESPACE_MATCHER

SEARCH_LIMIT_ERROR

static final Protocol.ErrorReplyFactory SEARCH_LIMIT_ERROR

Method Details

getConfigClass

static <C> Class<C> getConfigClass(Object o)

getFirstParameterizedTypeClass

static <C> Class<C> getFirstParameterizedTypeClass(Object o)

batchRequestsRecursive

static <T,
R>
com.google.common.util.concurrent.ListenableFuture<List<R>> batchRequestsRecursive(int batchSize,
 Executor executor,
 int index,
 Function<T,com.google.common.util.concurrent.ListenableFuture<R>> processor,
 @Nullable List<R> replyCollector,
 List<T> requests)

sanitizeString

static @Nullable String sanitizeString(String s)