Package | Description |
---|---|
com.tangosol.io.journal |
Contains classes related to the journaling services.
|
com.tangosol.net.partition |
Contains interfaces and classes related to partitioned services.
|
com.tangosol.persistence |
Contains classes and helpers for implementing various types of persistence.
|
Modifier and Type | Interface and Description |
---|---|
interface |
JournalMBean
A
JournalMBean is an MBean interface providing statistics for a Journal Resource Manager as implemented by either FlashJournalRM or RamJournalRM implementations. |
Modifier and Type | Method and Description |
---|---|
void |
JournalMBean.compact(boolean fRegular)
Execute either a regular or exhaustive compaction on the journal based on the provided parameter.
|
int |
JournalMBean.getBacklogCount()
Determine the number of serialized values that have not yet been persisted to disk.
|
int |
JournalMBean.getBacklogSize()
Determine the total size in bytes of the serialized values that have not yet been persisted to disk.
|
int |
JournalMBean.getBinaryStoreCount()
Determine the number of active BinaryStore objects that are using this Journal.
|
int |
JournalMBean.getBufferSize()
Determine the size of the buffers used to write a chunk of data at a time to an underlying journal file.
|
double |
JournalMBean.getCollectorLoadFactor()
Determine the load factor threshold at which files become eligible for garbage collection (compaction).
|
int |
JournalMBean.getCompactionCount()
Determine the number of compactions (garbage collections) performed by this journal.
|
double |
JournalMBean.getCurrentCollectorLoadFactor()
Determine the current load factor threshold for the journal.
|
int |
JournalMBean.getExhaustiveCompactionCount()
Determine the total number of exhaustive compactions performed by the collector.
|
long |
JournalMBean.getExhaustiveCompactionTime()
Return the total amount time spent performing exhaustive compaction.
|
int |
JournalMBean.getFileCount()
Determine the number of Journal files used by this Journal.
|
double |
JournalMBean.getHighestLoadFactor()
Determine the high-water mark load factor for the entire journal.
|
int |
JournalMBean.getHighFileCount()
Determine the high file count for this Journal.
|
int |
JournalMBean.getMaxBacklogSize()
Determine the maximum allowable size, in bytes, of the backlog; when the backlog reaches this level, writes are delayed until the backlog drops below its maximum.
|
long |
JournalMBean.getMaxFileSize()
Determine the maximum allowable size, in bytes, of each individual file used to hold Journal data.
|
int |
JournalMBean.getMaxJournalFilesNumber()
Determine the maximum number of Journal files.
|
long |
JournalMBean.getMaxPoolSize()
Determine the maximum size (in bytes) of the buffers that can be held by the pool.
|
long |
JournalMBean.getMaxTotalRam()
Determine the total amount, in bytes, of RAM that will be used for the Journal.
|
int |
JournalMBean.getMaxValueSize()
Determine the maximum allowable size, in bytes, of a Binary value.
|
int |
JournalMBean.getPoolSize()
Determine the size (in bytes) of the buffers that are currently available in the pool.
|
long |
JournalMBean.getTotalDataSize()
Determine the amount of data currently stored by this Journal.
|
long |
JournalMBean.getTotalFileSize()
Determine the number of bytes in the Journal files for this Journal.
|
boolean |
JournalMBean.isNioRam()
Determine if the journal will use direct buffers (NIO RAM) instead of on-heap buffers (byte arrays).
|
void |
JournalMBean.resetStatistics()
Reset the journal statistics.
|
Modifier and Type | Method and Description |
---|---|
void |
JournalMBean.compact(boolean fRegular)
Execute either a regular or exhaustive compaction on the journal based on the provided parameter.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SimpleStrategyMBean
Standard MBean interface that exposes management attributes and operations for a
SimpleAssignmentStrategy used by a PartitionedService . |
Modifier and Type | Method and Description |
---|---|
long |
SimpleStrategyMBean.getAveragePartitionSizeKB()
Get the average partition storage size.
|
long |
SimpleStrategyMBean.getAverageStorageSizeKB()
Get the average node storage size.
|
int |
SimpleStrategyMBean.getBackupCount()
Get the configured number of backups.
|
int |
SimpleStrategyMBean.getCoordinatorId()
Get the node id of the ownership distribution coordinator.
|
int |
SimpleStrategyMBean.getFairShareBackup()
Get the number of backup partitions per storage-enabled service member that this strategy will currently attempt to maintain.
|
int |
SimpleStrategyMBean.getFairSharePrimary()
Get the number of primary partitions per storage-enabled service member that this strategy will currently attempt to maintain.
|
String |
SimpleStrategyMBean.getHAStatus()
The High Availability status for the service.
|
String |
SimpleStrategyMBean.getHATarget()
The High Availability status that this strategy attempts to achieve.
|
Date |
SimpleStrategyMBean.getLastAnalysisTime()
Get the last time a partition distribution analysis was performed.
|
int |
SimpleStrategyMBean.getMaxLoadNodeId()
Get the node id with the maximum storage size.
|
long |
SimpleStrategyMBean.getMaxPartitionSizeKB()
Get the maximum partition storage size.
|
long |
SimpleStrategyMBean.getMaxStorageSizeKB()
Get maximum node storage size.
|
int |
SimpleStrategyMBean.getPartitionCount()
Get the configured number of partitions for the service.
|
int |
SimpleStrategyMBean.getRemainingDistributionCount()
Get the number of distributions (partition transfers) that remain to be completed before the service achieves the goals set by this strategy.
|
int |
SimpleStrategyMBean.getServiceMachineCount()
Get the number of machines that host storage-enabled nodes running this service.
|
int |
SimpleStrategyMBean.getServiceNodeCount()
Get the number of storage-enabled nodes running this service.
|
int |
SimpleStrategyMBean.getServiceRackCount()
Get the number of racks that host storage-enabled nodes running this service.
|
int |
SimpleStrategyMBean.getServiceSiteCount()
Get the number of sites that host storage-enabled nodes running this service.
|
String |
SimpleStrategyMBean.getStrategyName()
Get name of the PartitionAssignmentStrategy in use.
|
String |
SimpleStrategyMBean.reportScheduledDistributions(boolean fVerbose)
Report partitions that storage-enabled members are waiting to receive or still need to send in order to achieve distribution goal set by the strategy.
|
Modifier and Type | Method and Description |
---|---|
String |
SimpleStrategyMBean.reportScheduledDistributions(boolean fVerbose)
Report partitions that storage-enabled members are waiting to receive or still need to send in order to achieve distribution goal set by the strategy.
|
Modifier and Type | Method and Description |
---|---|
void |
PersistenceManagerMBean.archiveSnapshot(String sName)
Archive the snapshot to a centralized location.
|
void |
PersistenceManagerMBean.createSnapshot(String sName)
Create a snapshot of the service with the specified name.
|
int |
PersistenceManagerMBean.getCoordinatorId()
Return the node id of the persistence coordinator.
|
String |
PersistenceManagerMBean.getOperationStatus()
Return the status of the current operation issued by the persistence coordinator.
|
String[] |
PersistenceManagerMBean.getSnapshots()
Return a list of snapshots that are available for recovery.
|
boolean |
PersistenceManagerMBean.isIdle()
Specifies whether or not the persistence coordinator is idle.
|
String[] |
PersistenceManagerMBean.listArchivedSnapshots()
Return a list of archived snapshots that the configured archiver knows about.
|
String[] |
PersistenceManagerMBean.listArchivedSnapshotStores(String sName)
Return a list of stores for a given archived snapshot.
|
void |
PersistenceManagerMBean.recoverSnapshot(String sName)
Recover the snapshot that was previously created with the specified name.
|
void |
PersistenceManagerMBean.removeArchivedSnapshot(String sName)
Purge the archived snapshot from a centralized location.
|
void |
PersistenceManagerMBean.removeSnapshot(String sName)
Remove the snapshot that was previously created with the specified name.
|
void |
PersistenceManagerMBean.retrieveArchivedSnapshot(String sName)
Retrieve the archived snapshot from a centralized location.
|
Modifier and Type | Method and Description |
---|---|
void |
PersistenceManagerMBean.archiveSnapshot(String sName)
Archive the snapshot to a centralized location.
|
void |
PersistenceManagerMBean.createSnapshot(String sName)
Create a snapshot of the service with the specified name.
|
String[] |
PersistenceManagerMBean.listArchivedSnapshotStores(String sName)
Return a list of stores for a given archived snapshot.
|
void |
PersistenceManagerMBean.recoverSnapshot(String sName)
Recover the snapshot that was previously created with the specified name.
|
void |
PersistenceManagerMBean.removeArchivedSnapshot(String sName)
Purge the archived snapshot from a centralized location.
|
void |
PersistenceManagerMBean.removeSnapshot(String sName)
Remove the snapshot that was previously created with the specified name.
|
void |
PersistenceManagerMBean.retrieveArchivedSnapshot(String sName)
Retrieve the archived snapshot from a centralized location.
|