Package | Description |
---|---|
de.innovationgate.wgpublisher.cluster | |
de.innovationgate.wgpublisher.cluster.tasks |
Modifier and Type | Method and Description |
---|---|
ClusterMember |
SingleNodeClusterService.getLocalMember() |
abstract ClusterMember |
ClusterService.getLocalMember() |
ClusterMember |
ClusterService.getMember(java.lang.String uid) |
Modifier and Type | Method and Description |
---|---|
java.util.Set<ClusterMember> |
SingleNodeClusterService.getMembers() |
abstract java.util.Set<ClusterMember> |
ClusterService.getMembers() |
<V> java.util.Map<ClusterMember,java.util.concurrent.Future<V>> |
ClusterService.submitTo(java.util.Set<ClusterMember> members,
ClusterTask<V> task) |
<V> java.util.Map<ClusterMember,java.util.concurrent.Future<V>> |
ClusterService.submitToAll(ClusterTask<V> task) |
<V> java.util.Map<ClusterMember,java.util.concurrent.Future<V>> |
ClusterService.submitToOthers(ClusterTask<V> task) |
Modifier and Type | Method and Description |
---|---|
java.io.InputStream |
ClusterService.readResource(ClusterMember member,
java.net.URI resource) |
<V> java.util.concurrent.Future<V> |
ClusterService.submitTo(ClusterMember member,
ClusterTask<V> task) |
java.io.OutputStream |
ClusterService.writeResource(ClusterMember member,
java.net.URI resource) |
Modifier and Type | Method and Description |
---|---|
<V> java.util.Map<ClusterMember,java.util.concurrent.Future<V>> |
ClusterService.submitTo(java.util.Set<ClusterMember> members,
ClusterTask<V> task) |
Constructor and Description |
---|
ClusterResourceInputStream(ClusterService clusterService,
ClusterMember member,
java.net.URI resource) |
ClusterResourceOutputStream(ClusterService clusterService,
ClusterMember member,
java.net.URI resource) |
Modifier and Type | Method and Description |
---|---|
ClusterMember |
ClusterTaskContext.getCaller() |
Modifier and Type | Method and Description |
---|---|
void |
ClusterTaskContext.setCaller(ClusterMember caller) |