Package ch.rswk.meta.engine

Class EngineUpdater.UpdateTaskContext

java.lang.Object

ch.rswk.meta.engine.EngineUpdater.UpdateTaskContext

Enclosing class:

EngineUpdater

public static class EngineUpdater.UpdateTaskContext
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
final String[]	args
private static final org.slf4j.Logger	LOG
final Set<EngineUpdater.MetaUpdater>	metaUpdaters
final EngineUpdater.UpdaterServices	newServices
final EngineUpdater.UpdaterServices	oldServices
private final EngineUpdater.UpdaterContext	updaterContext
final Set<EngineUpdater.MetaUserUpdater>	userUpdaters

Constructor Summary

Constructors

Constructor	Description
UpdateTaskContext(String[] args, Set<EngineUpdater.MetaUpdater> metaUpdaters, EngineUpdater.UpdaterServices newServices, EngineUpdater.UpdaterServices oldServices, Set<EngineUpdater.MetaUserUpdater> userUpdaters)

Method Summary

Modifier and Type	Method	Description
void	createConfigs(@Nullable Iterable<MetaUserConfig> configs)
void	createGroups(@Nullable Iterable<MetaUserGroup> groups)
<T extends Meta> void	createMetas(@Nullable List<T> metas)
void	createUsers(boolean hashed, @Nullable Iterable<MetaUser> users)
void	searchAndCreateConfigs(@Nullable String query, Function<UserConfigSearchRequest,com.google.common.util.concurrent.ListenableFuture<UserConfigSearchReply>> service)
void	searchAndCreateFiles(FileService fileService, @Nullable String query, Function<FileSearchRequest,com.google.common.util.concurrent.ListenableFuture<FileSearchReply>> service)
void	searchAndCreateGroups(@Nullable String query, Function<UserGroupSearchRequest,com.google.common.util.concurrent.ListenableFuture<UserGroupSearchReply>> service)
void	searchAndCreateMetas(String query, Function<SearchRequest,com.google.common.util.concurrent.ListenableFuture<SearchReply>> service)
void	searchAndCreateUsers(@Nullable String query, Function<UserSearchRequest,com.google.common.util.concurrent.ListenableFuture<UserSearchReply>> service)
void	searchFiles(@Nullable String query, Consumer<FileSearchReply> replyConsumer, Function<FileSearchRequest,com.google.common.util.concurrent.ListenableFuture<FileSearchReply>> service)
void	searchMetas(Executor executor, @Nullable Set<String> purge, String query, Consumer<SearchReply> replyConsumer, Function<SearchRequest,com.google.common.util.concurrent.ListenableFuture<SearchReply>> service)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

args

public final String[] args

metaUpdaters

public final Set<EngineUpdater.MetaUpdater> metaUpdaters

newServices

public final EngineUpdater.UpdaterServices newServices

oldServices

public final EngineUpdater.UpdaterServices oldServices

userUpdaters

public final Set<EngineUpdater.MetaUserUpdater> userUpdaters

updaterContext

private final EngineUpdater.UpdaterContext updaterContext

Constructor Details

UpdateTaskContext

public UpdateTaskContext(String[] args,
 Set<EngineUpdater.MetaUpdater> metaUpdaters,
 EngineUpdater.UpdaterServices newServices,
 EngineUpdater.UpdaterServices oldServices,
 Set<EngineUpdater.MetaUserUpdater> userUpdaters)

Method Details

searchAndCreateConfigs

public void searchAndCreateConfigs(@Nullable String query,
 Function<UserConfigSearchRequest,com.google.common.util.concurrent.ListenableFuture<UserConfigSearchReply>> service)
                            throws Exception

Throws:

Exception

createConfigs

public void createConfigs(@Nullable Iterable<MetaUserConfig> configs)
                   throws Exception

Throws:

Exception

searchAndCreateFiles

public void searchAndCreateFiles(FileService fileService,
 @Nullable String query,
 Function<FileSearchRequest,com.google.common.util.concurrent.ListenableFuture<FileSearchReply>> service)
                          throws Exception

Throws:

Exception

searchFiles

public void searchFiles(@Nullable String query,
 Consumer<FileSearchReply> replyConsumer,
 Function<FileSearchRequest,com.google.common.util.concurrent.ListenableFuture<FileSearchReply>> service)
                 throws Exception

Throws:

Exception

searchAndCreateGroups

public void searchAndCreateGroups(@Nullable String query,
 Function<UserGroupSearchRequest,com.google.common.util.concurrent.ListenableFuture<UserGroupSearchReply>> service)
                           throws Exception

Throws:

Exception

createGroups

public void createGroups(@Nullable Iterable<MetaUserGroup> groups)
                  throws Exception

Throws:

Exception

searchAndCreateMetas

public void searchAndCreateMetas(String query,
 Function<SearchRequest,com.google.common.util.concurrent.ListenableFuture<SearchReply>> service)
                          throws Exception

Throws:

Exception

searchMetas

public void searchMetas(Executor executor,
 @Nullable Set<String> purge,
 String query,
 Consumer<SearchReply> replyConsumer,
 Function<SearchRequest,com.google.common.util.concurrent.ListenableFuture<SearchReply>> service)
                 throws Exception

Throws:

Exception

createMetas

public <T extends Meta> void createMetas(@Nullable List<T> metas)
                                  throws Exception

Throws:

Exception

searchAndCreateUsers

public void searchAndCreateUsers(@Nullable String query,
 Function<UserSearchRequest,com.google.common.util.concurrent.ListenableFuture<UserSearchReply>> service)
                          throws Exception

Throws:

Exception

createUsers

public void createUsers(boolean hashed,
 @Nullable Iterable<MetaUser> users)
                 throws Exception

Throws:

Exception