| Package | Description |
|---|---|
| com.caucho.cloud.bam | |
| com.caucho.cloud.network | |
| com.caucho.cloud.topology | |
| com.caucho.distcache.cluster | |
| com.caucho.jms.cluster | |
| com.caucho.server.distcache |
| Modifier and Type | Method and Description |
|---|---|
<T> T |
BamCloudManager.createGlobalTriadFirstProxy(java.lang.Class<T> api,
java.lang.String uid,
TriadOwner owner) |
<T> T |
BamCloudManager.createTriad(java.lang.Class<T> api,
java.lang.String uid,
CloudPod pod,
TriadOwner owner) |
<T> T |
BamCloudManager.createTriadFirstProxy(java.lang.Class<T> api,
java.lang.String uid,
CloudPod pod,
TriadOwner owner,
BamTriadDispatcher.RemoteEnum isRemote,
BamCloudManager.ResultEnum isResult,
long timeout) |
<T> T |
BamCloudManager.createTriadFirstProxy(java.lang.Class<T> api,
java.lang.String uid,
TriadOwner owner,
BamTriadDispatcher.RemoteEnum isRemote,
BamCloudManager.ResultEnum isResult,
long timeout) |
java.lang.String |
BamTriadDispatcher.getActiveAddress(TriadOwner owner)
Returns the address of the first active server.
|
java.lang.String |
BamTriadDispatcher.getActiveAddress(TriadOwner owner,
java.lang.String oldAddress)
Returns the address of the first active backup server.
|
java.lang.String |
BamTriadDispatcher.getActiveOrSelfAddress(TriadOwner owner)
Returns the address of the first active server.
|
ClusterServer |
BamTriadDispatcher.getActiveOrSelfServer(TriadOwner owner)
Returns the address of the first active server.
|
java.lang.String |
BamTriadDispatcher.getPrimaryActiveAddress(TriadOwner owner)
Returns the address of the primary, or null if the server doesn't exist.
|
java.lang.String |
BamTriadDispatcher.getPrimaryAddress(TriadOwner owner)
Returns the address of the primary, or null if the server doesn't exist.
|
java.lang.String |
BamTriadSender.getPrimaryAddress(TriadOwner owner) |
java.lang.String |
ClusterRouteManager.getPrimaryAddress(TriadOwner owner) |
java.lang.String |
BamTriadDispatcher.getSecondaryActiveAddress(TriadOwner owner)
Returns the address of the secondary, or null if the server doesn't exist.
|
java.lang.String |
BamTriadDispatcher.getSecondaryAddress(TriadOwner owner)
Returns the address of the secondary, or null if the server doesn't exist.
|
java.lang.String |
BamTriadSender.getSecondaryAddress(TriadOwner owner) |
java.lang.String |
ClusterRouteManager.getSecondaryAddress(TriadOwner owner) |
java.lang.String |
BamTriadDispatcher.getTertiaryActiveAddress(TriadOwner owner)
Returns the address of the tertiary, or null if the server doesn't exist.
|
java.lang.String |
BamTriadDispatcher.getTertiaryAddress(TriadOwner owner)
Returns the address of the tertiary, or null if the server doesn't exist.
|
java.lang.String |
BamTriadSender.getTertiaryAddress(TriadOwner owner) |
java.lang.String |
ClusterRouteManager.getTertiaryAddress(TriadOwner owner) |
boolean |
BamTriadDispatcher.isPrimarySelf(TriadOwner owner)
Returns the address of the primary, or null if the server doesn't exist.
|
boolean |
BamTriadSender.isPrimarySelf(TriadOwner owner) |
boolean |
ClusterRouteManager.isPrimarySelf(TriadOwner owner) |
java.lang.String |
BamTriadSender.messageActiveOrSelf(java.io.Serializable msg,
TriadOwner owner)
Sends a message to one of the triad members, including the server itself.
|
java.lang.String |
ClusterRouteManager.messageActiveOrSelf(java.lang.String uid,
java.io.Serializable msg,
TriadOwner owner)
Sends a message to one of the triad members, including the server itself.
|
void |
BamTriadSender.messageBackup(java.io.Serializable msg,
TriadOwner owner) |
void |
ClusterRouteManager.messageBackup(java.lang.String uid,
java.io.Serializable msg,
TriadOwner owner) |
java.lang.String |
BamTriadSender.messageFirstTriad(java.io.Serializable msg,
TriadOwner owner,
BamTriadDispatcher.RemoteEnum remote)
Sends a message to the first active remote triad server.
|
java.lang.String |
ClusterRouteManager.messageFirstTriad(java.lang.String uid,
java.io.Serializable msg,
TriadOwner owner,
BamTriadDispatcher.RemoteEnum remote)
Sends a message to the first active remote triad server.
|
java.lang.String |
BamTriadSender.messageFirstTriadActive(java.io.Serializable msg,
TriadOwner owner)
Sends a message to the first active remote triad server.
|
java.lang.String |
ClusterRouteManager.messageFirstTriadActive(java.lang.String uid,
java.io.Serializable msg,
TriadOwner owner)
Sends a message to the first active remote triad server.
|
java.lang.String |
BamTriadSender.messageFirstTriadRemote(java.io.Serializable msg,
TriadOwner owner)
Sends a message to the first active remote triad server.
|
java.lang.String |
ClusterRouteManager.messageFirstTriadRemote(java.lang.String uid,
java.io.Serializable msg,
TriadOwner owner)
Sends a message to the first active remote triad server.
|
void |
BamTriadSender.messageTriadRemote(java.io.Serializable msg,
TriadOwner owner) |
void |
ClusterRouteManager.messageTriadRemote(java.lang.String uid,
java.io.Serializable msg,
TriadOwner owner) |
com.caucho.cloud.bam.BamTriadDispatcher.BamServer |
BamTriadDispatcher.primary(TriadOwner owner) |
void |
ClusterRouteManager.queryGlobalTriadFirstRemote(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload,
QueryCallback cb)
Sends a query to each server.
|
boolean |
BamTriadDispatcher.queryPrimary(java.lang.String uid,
TriadOwner owner,
QuerySender sender,
java.io.Serializable payload,
QueryCallback callback,
BamTriadDispatcher.RemoteEnum remote,
BamTriadDispatcher.ActiveEnum active)
Query the primary server, returning true if the query was sent or false
if the server doesn't exist or doesn't match the predicates.
|
boolean |
ClusterRouteManager.queryPrimary(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload,
QueryCallback callback,
BamTriadDispatcher.RemoteEnum remote,
BamTriadDispatcher.ActiveEnum active)
Query the primary server, returning true if the query was sent or false
if the server doesn't exist or doesn't match the predicates.
|
boolean |
BamTriadDispatcher.querySecondary(java.lang.String uid,
TriadOwner owner,
QuerySender sender,
java.io.Serializable payload,
QueryCallback callback,
BamTriadDispatcher.RemoteEnum remote,
BamTriadDispatcher.ActiveEnum active)
Query the primary server, returning true if the query was sent or false
if the server doesn't exist or doesn't match the predicates.
|
boolean |
ClusterRouteManager.querySecondary(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload,
QueryCallback callback,
BamTriadDispatcher.RemoteEnum remote,
BamTriadDispatcher.ActiveEnum active)
Query the primary server, returning true if the query was sent or false
if the server doesn't exist or doesn't match the predicates.
|
boolean |
BamTriadSender.querySecondary(TriadOwner owner,
java.io.Serializable payload,
QueryCallback callback,
BamTriadDispatcher.RemoteEnum remote,
BamTriadDispatcher.ActiveEnum active)
Query the primary server, returning true if the query was sent or false
if the server doesn't exist or doesn't match the predicates.
|
boolean |
BamTriadDispatcher.queryTertiary(java.lang.String uid,
TriadOwner owner,
QuerySender sender,
java.io.Serializable payload,
QueryCallback callback,
BamTriadDispatcher.RemoteEnum remote,
BamTriadDispatcher.ActiveEnum active)
Query the primary server, returning true if the query was sent or false
if the server doesn't exist or doesn't match the predicates.
|
boolean |
ClusterRouteManager.queryTertiary(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload,
QueryCallback callback,
BamTriadDispatcher.RemoteEnum remote,
BamTriadDispatcher.ActiveEnum active)
Query the primary server, returning true if the query was sent or false
if the server doesn't exist or doesn't match the predicates.
|
boolean |
BamTriadSender.queryTertiary(TriadOwner owner,
java.io.Serializable payload,
QueryCallback callback,
BamTriadDispatcher.RemoteEnum remote,
BamTriadDispatcher.ActiveEnum active)
Query the primary server, returning true if the query was sent or false
if the server doesn't exist or doesn't match the predicates.
|
boolean |
ClusterRouteManager.queryTriad(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload,
QueryCallback callback)
Sends a query to the first active server in the triad.
|
boolean |
BamTriadSender.queryTriad(TriadOwner owner,
java.io.Serializable payload,
QueryCallback callback)
Sends a query to the first active server in the triad.
|
java.lang.Object |
ClusterRouteManager.queryTriadActiveOrSelf(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload)
Load a file from the remote servers.
|
void |
ClusterRouteManager.queryTriadActiveOrSelf(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload,
QueryCallback cb)
Load a file from the remote servers.
|
void |
ClusterRouteManager.queryTriadAll(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload,
QueryCallback cb,
BamTriadDispatcher.RemoteEnum remote,
BamTriadDispatcher.ActiveEnum active)
Load a file from the remote servers.
|
void |
BamTriadSender.queryTriadAll(TriadOwner owner,
java.io.Serializable payload,
QueryCallback cb,
BamTriadDispatcher.RemoteEnum remote,
BamTriadDispatcher.ActiveEnum active)
Load a file from the remote servers.
|
void |
ClusterRouteManager.queryTriadFirst(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload,
QueryCallback cb,
BamTriadDispatcher.RemoteEnum isRemote)
Load a file from the remote servers.
|
void |
ClusterRouteManager.queryTriadFirstActive(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload,
QueryCallback cb)
Load a file from the remote servers.
|
void |
BamTriadSender.queryTriadFirstActive(TriadOwner owner,
java.io.Serializable payload,
QueryCallback cb)
Load a file from the remote servers.
|
java.lang.Object |
ClusterRouteManager.queryTriadFirstRemote(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload)
Load a file from the remote servers.
|
java.lang.Object |
BamTriadSender.queryTriadFirstRemote(TriadOwner owner,
java.io.Serializable payload)
Load a file from the remote servers.
|
com.caucho.cloud.bam.BamTriadDispatcher.BamServer |
BamTriadDispatcher.secondary(TriadOwner owner) |
com.caucho.cloud.bam.BamTriadDispatcher.BamServer |
BamTriadDispatcher.tertiary(TriadOwner owner) |
| Constructor and Description |
|---|
GlobalTriadFirstRouter(java.lang.String uid,
ClusterRouteManager routeManager,
TriadOwner owner,
Broker broker) |
TriadAllRouter(java.lang.String uid,
ClusterRouteManager routeManager,
TriadOwner owner,
Broker broker) |
TriadFirstRouter(java.lang.String uid,
ClusterRouteManager routeManager,
TriadOwner owner,
Broker broker,
BamTriadDispatcher.RemoteEnum isRemote) |
| Modifier and Type | Method and Description |
|---|---|
TriadOwner |
ClusterServer.getTriadOwner()
Returns the pod owner
|
| Modifier and Type | Field and Description |
|---|---|
static TriadOwner[] |
TriadOwner.OWNER_VALUES |
| Modifier and Type | Method and Description |
|---|---|
static TriadOwner |
TriadOwner.getHashOwner(byte[] hash) |
static TriadOwner |
TriadOwner.getHashOwner(java.lang.String value) |
static TriadOwner |
TriadOwner.getOwner(long index)
Returns the owner for an index
|
TriadOwner |
CloudServer.getTriadOwner()
Returns the pod owner
|
static TriadOwner |
TriadOwner.valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static TriadOwner[] |
TriadOwner.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
X |
TriadShard.get(TriadOwner owner)
Returns the primary server.
|
X |
TriadDispatcherDouble.primary(TriadOwner owner)
Returns the primary server.
|
X |
TriadDispatcher.primary(TriadOwner owner)
Returns the primary server.
|
X |
TriadDispatcherTriple.primary(TriadOwner owner)
Returns the primary server.
|
X |
TriadDispatcherSingle.primary(TriadOwner owner)
Returns the primary server.
|
X |
TriadDispatcherDouble.secondary(TriadOwner owner)
Returns the primary server.
|
X |
TriadDispatcher.secondary(TriadOwner owner)
Returns the secondary server.
|
X |
TriadDispatcherTriple.secondary(TriadOwner owner)
Returns the primary server.
|
X |
TriadDispatcherSingle.secondary(TriadOwner owner)
Returns the secondary server.
|
X |
TriadDispatcherDouble.tertiary(TriadOwner owner)
Returns the tertiary server.
|
X |
TriadDispatcher.tertiary(TriadOwner owner)
Returns the tertiary server.
|
X |
TriadDispatcherTriple.tertiary(TriadOwner owner)
Returns the tertiary server.
|
X |
TriadDispatcherSingle.tertiary(TriadOwner owner)
Returns the tertiary server.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
CacheMnodeActor.localNotifyLeaseChange(HashKey key,
HashKey cacheKey,
TriadOwner keyOwner,
int leaseOwner)
Notify the lease owner of a change in the value.
|
| Modifier and Type | Method and Description |
|---|---|
protected TriadOwner |
ClusterQueueImpl.getQueueOwner(byte[] queueHash) |
| Modifier and Type | Method and Description |
|---|---|
void |
ClusterQueueSender.sendSubscribeTopicMessage(SubscribeTopic subscribeMessage,
TriadOwner topicOwner)
Topic Publishers use this API for registering themself
with the Topic running on the Triad Pod.
|
| Modifier and Type | Method and Description |
|---|---|
TriadOwner |
DistCacheEntry.getOwner()
Returns the owner
|