Package | Description |
---|---|
com.tangosol.net |
Contains basic cluster interfaces and factories.
|
com.tangosol.net.events.partition |
Contains classes related to PartitionedService events within the Coherence
Live Event Model.
|
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 |
DistributedCacheService
A DistributedCacheService is a clustered cache service that partitions its
data across cluster members that provide backing storage.
|
interface |
FederatedCacheService
A FederatedCacheService is a distributed cache service that also replicates
data to other clusters/participants in the Federation.
|
Modifier and Type | Method and Description |
---|---|
PartitionedService |
ConfigurableQuorumPolicy.PartitionedCacheQuorumPolicy.getService()
Return the associated PartitionedService.
|
Modifier and Type | Method and Description |
---|---|
PartitionedService |
PartitionedServiceDispatcher.getService()
Return the
PartitionedService for this dispatcher. |
Modifier and Type | Field and Description |
---|---|
protected PartitionedService |
DefaultKeyAssociator.m_service
The PartitionedService that this DefaultKeyAssociator is bound to.
|
protected PartitionedService |
DefaultKeyPartitioningStrategy.m_service
The PartitionedService that this strategy is bound to.
|
protected PartitionedService |
FailoverAccessPolicy.m_service
The PartitionedService that this quorum policy is bound to.
|
protected PartitionedService |
MirroringAssignmentStrategy.m_service
The associated service that this strategy attempts to co-locate
partitions with.
|
Modifier and Type | Method and Description |
---|---|
protected PartitionedService |
MirroringAssignmentStrategy.bindService(String sService)
Bind this assignment strategy to the specified partitioned service, and
return the bound service.
|
PartitionedService |
MirroringAssignmentStrategy.getAssociatedService()
Return the associated service.
|
PartitionedService |
DistributionManager.getService()
Return the partitioned service for which this DistributionManager
coordinates the distribution.
|
PartitionedService |
MirroringAssignmentStrategy.getService()
Return the partitioned service for which this assignment strategy
controls the distribution.
|
PartitionedService |
PartitionEvent.getService()
Determine the partitioned service that this event originates from.
|
Modifier and Type | Method and Description |
---|---|
static int |
DefaultKeyPartitioningStrategy.calculateBasePartitionHash(PartitionedService service,
Object oKey)
Determine the partition-hash of the given key.
|
static int |
DefaultKeyPartitioningStrategy.calculateKeyPartition(PartitionedService service,
Object oKey)
Determine the partition to which the given key should be assigned for
the specified PartitionService, taking into consideration the associations
provided by the service's KeyAssociator.
|
static int |
DefaultKeyPartitioningStrategy.calculateKeyPartitionHash(PartitionedService service,
Object oKey)
Determine the partition-hash of the given key.
|
static int |
DefaultKeyPartitioningStrategy.calculatePartition(PartitionedService service,
int nHash)
Return the partition associated with the specified hash value in the
specified PartitionedService.
|
void |
BroadKeyPartitioningStrategy.init(PartitionedService service)
Initialize the KeyPartitioningStrategy and bind it to the specified
PartitionedService.
|
void |
DefaultKeyAssociator.init(PartitionedService service)
Initialize the KeyAssociator and bind it to a PartitionedService.
|
void |
DefaultKeyPartitioningStrategy.init(PartitionedService service)
Initialize the KeyPartitioningStrategy and bind it to the specified
PartitionedService.
|
void |
KeyAssociator.init(PartitionedService service)
Initialize the KeyAssociator and bind it to a PartitionedService.
|
void |
KeyPartitioningStrategy.init(PartitionedService service)
Initialize the KeyPartitioningStrategy and bind it to the specified
PartitionedService.
|
protected boolean |
MirroringAssignmentStrategy.isRefinementNeeded(SimpleAssignmentStrategy.AnalysisContext ctx,
PartitionedService serviceThis,
PartitionedService serviceThat)
Return true iff the partition assignments sync'd from the specified
associated service should be further refined/balanced by the local
assignment strategy.
|
protected String |
SimpleAssignmentStrategy.makeMBeanName(PartitionedService service)
Create a name for the MBean representing this strategy.
|
protected void |
MirroringAssignmentStrategy.setAssociatedService(PartitionedService service)
Set the associated service.
|
protected void |
MirroringAssignmentStrategy.syncAssignments(SimpleAssignmentStrategy.AnalysisContext ctx,
PartitionedService serviceThat)
Update the analysis context to reflect the partition assignments of the
specified associated service.
|
protected boolean |
MirroringAssignmentStrategy.validateAssociatedService(PartitionedService service)
Validate that the distribution for the specified service is compatible
with this service.
|
Constructor and Description |
---|
PartitionEvent(PartitionedService svc,
int nId,
PartitionSet setPartitions,
Member memberFrom,
Member memberTo)
Construct a partition event.
|
Modifier and Type | Method and Description |
---|---|
static PartitionSet |
CachePersistenceHelper.getGlobalPartitions(PartitionedService service)
Return a PartitionSet that contains partitions to be used to persist
(meta-)data that is logically "global".
|
static void |
CachePersistenceHelper.seal(com.oracle.datagrid.persistence.PersistentStore<ReadBuffer> store,
PartitionedService service,
Object oToken)
Seal the specified PersistentStore on behalf of the specified service,
indicating that it is fully initialized and eligible to be recovered
from this point forward.
|
static void |
CachePersistenceHelper.validate(com.oracle.datagrid.persistence.PersistentStore store,
PartitionedService service)
Validate the specified store to check that it has been sealed, indicating
that it is eligible to be recovered by the specified service.
|
static Binary |
CachePersistenceHelper.writeQuorum(com.oracle.datagrid.persistence.PersistentStore<ReadBuffer> store,
PartitionedService service)
Write the current membership information to the "META" extent.
|