public class NodeProviderInDb extends java.lang.Object implements NodeProvider, ReadOnlyStatus.IsAware
Node
objects which is responsible for persisting and
populating such entities.
Used by Blitz's ome.services.blitz.fire.Ring
.Modifier and Type | Field and Description |
---|---|
java.lang.String |
uuid
UUID for this cluster node.
|
Constructor and Description |
---|
NodeProviderInDb(java.lang.String uuid,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
ome.model.meta.Node |
addManager(java.lang.String managerUuid,
java.lang.String proxyString)
Adds a manager node.
|
int |
closeSessionsForManager(java.lang.String managerUuid)
Assumes that the given manager is no longer available and so will not
attempt to call cache.removeSession() since that requires the session to
be in memory.
|
ome.model.meta.Node |
getManagerByUuid(java.lang.String managerUuid,
ome.system.ServiceFactory sf)
Retrieves a given manager node.
|
long |
getManagerIdByUuid(java.lang.String managerUuid,
ome.util.SqlAction sql)
Retrieves a given manager node ID.
|
java.util.Set<java.lang.String> |
getManagerList(boolean onlyActive) |
boolean |
isReadOnly(ReadOnlyStatus readOnly) |
ome.system.Principal |
principal()
Retrieves the current active principal.
|
void |
setManagerDown(java.lang.String managerUuid)
Sets a given manager node as down.
|
public final java.lang.String uuid
public NodeProviderInDb(java.lang.String uuid, Executor executor)
public ome.system.Principal principal()
NodeProvider
principal
in interface NodeProvider
public long getManagerIdByUuid(java.lang.String managerUuid, ome.util.SqlAction sql)
NodeProvider
getManagerIdByUuid
in interface NodeProvider
managerUuid
- manager node UUID to retrievesql
- active SQL context which can be used to make queriespublic ome.model.meta.Node getManagerByUuid(java.lang.String managerUuid, ome.system.ServiceFactory sf)
NodeProvider
getManagerByUuid
in interface NodeProvider
managerUuid
- manager node UUID to retrievesf
- current session's service factorypublic java.util.Set<java.lang.String> getManagerList(boolean onlyActive)
getManagerList
in interface NodeProvider
public int closeSessionsForManager(java.lang.String managerUuid)
closeSessionsForManager
in interface NodeProvider
managerUuid
- manager node UUID to close sessions forpublic void setManagerDown(java.lang.String managerUuid)
NodeProvider
setManagerDown
in interface NodeProvider
managerUuid
- manager node UUID to set as downpublic ome.model.meta.Node addManager(java.lang.String managerUuid, java.lang.String proxyString)
NodeProvider
addManager
in interface NodeProvider
managerUuid
- manager node UUID to addproxyString
- manager node proxy connection stringpublic boolean isReadOnly(ReadOnlyStatus readOnly)
isReadOnly
in interface ReadOnlyStatus.IsAware
readOnly
- a read-only status, typically the current one