public abstract class ClusterService
extends java.lang.Object
Constructor and Description |
---|
ClusterService(WGACore core) |
Modifier and Type | Method and Description |
---|---|
void |
checkHealth() |
java.lang.String |
getLBRoute() |
abstract ClusterMember |
getLocalMember() |
ClusterMember |
getMember(java.lang.String uid) |
abstract java.util.Set<ClusterMember> |
getMembers() |
abstract java.lang.String |
getName() |
boolean |
isDebug() |
abstract boolean |
isInitialized() |
java.io.InputStream |
readResource(ClusterMember member,
java.net.URI resource) |
void |
setDebug(boolean debug) |
abstract void |
shutdown() |
void |
startup() |
<V> java.util.concurrent.Future<V> |
submitTo(ClusterMember member,
ClusterTask<V> task) |
<V> java.util.Map<ClusterMember,java.util.concurrent.Future<V>> |
submitTo(java.util.Set<ClusterMember> members,
ClusterTask<V> task) |
<V> java.util.Map<ClusterMember,java.util.concurrent.Future<V>> |
submitToAll(ClusterTask<V> task) |
<V> java.util.Map<ClusterMember,java.util.concurrent.Future<V>> |
submitToOthers(ClusterTask<V> task) |
java.io.OutputStream |
writeResource(ClusterMember member,
java.net.URI resource) |
public ClusterService(WGACore core)
public void startup() throws java.lang.Exception
java.lang.Exception
public abstract void shutdown()
public abstract java.util.Set<ClusterMember> getMembers()
public abstract ClusterMember getLocalMember()
public <V> java.util.Map<ClusterMember,java.util.concurrent.Future<V>> submitTo(java.util.Set<ClusterMember> members, ClusterTask<V> task)
public <V> java.util.Map<ClusterMember,java.util.concurrent.Future<V>> submitToOthers(ClusterTask<V> task)
public <V> java.util.Map<ClusterMember,java.util.concurrent.Future<V>> submitToAll(ClusterTask<V> task)
public <V> java.util.concurrent.Future<V> submitTo(ClusterMember member, ClusterTask<V> task)
public abstract java.lang.String getName()
public java.io.InputStream readResource(ClusterMember member, java.net.URI resource)
public java.io.OutputStream writeResource(ClusterMember member, java.net.URI resource)
public ClusterMember getMember(java.lang.String uid)
public abstract boolean isInitialized()
public boolean isDebug()
public void setDebug(boolean debug)
public java.lang.String getLBRoute()
public void checkHealth()