Constructor and Description |
---|
WorkerCuratorCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
IndexerZkConfig indexerZkConfig,
RemoteTaskRunnerConfig config,
org.apache.curator.framework.CuratorFramework curatorFramework,
Worker worker) |
Modifier and Type | Method and Description |
---|---|
List<TaskAnnouncement> |
getAnnouncements() |
String |
getAnnouncementsPathForWorker() |
String |
getPath(Iterable<String> parts) |
String |
getStatusPathForId(String statusId) |
String |
getStatusPathForWorker() |
String |
getTaskPathForId(String taskId) |
String |
getTaskPathForWorker() |
Worker |
getWorker() |
void |
start() |
void |
stop() |
void |
unannounceTask(String taskId) |
void |
updateAnnouncement(TaskAnnouncement announcement) |
void |
updateWorkerAnnouncement(Worker newWorker) |
@Inject public WorkerCuratorCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, IndexerZkConfig indexerZkConfig, RemoteTaskRunnerConfig config, org.apache.curator.framework.CuratorFramework curatorFramework, Worker worker)
public String getAnnouncementsPathForWorker()
public String getTaskPathForWorker()
public String getStatusPathForWorker()
public Worker getWorker()
public void unannounceTask(String taskId)
public void updateAnnouncement(TaskAnnouncement announcement)
public List<TaskAnnouncement> getAnnouncements()
Copyright © 2011–2016. All rights reserved.