| Package | Description |
|---|---|
| com.hazelcast.enterprise.wan |
This package contains the enterprise WAN implementation
|
| com.hazelcast.enterprise.wan.replication |
This package contains WAN replication implementations
|
| com.hazelcast.enterprise.wan.sync |
This package contains WAN sync related classes.
|
| Modifier and Type | Method and Description |
|---|---|
void |
EnterpriseWanReplicationService.publishAntiEntropyEvent(String wanReplicationName,
String wanPublisherId,
WanAntiEntropyEvent event)
Publishes an anti-entropy event for the given
wanReplicationName
and wanPublisherId. |
| Modifier and Type | Method and Description |
|---|---|
void |
WanBatchReplication.publishAntiEntropyEvent(WanAntiEntropyEvent event)
Publishes an anti-entropy event.
|
abstract void |
AbstractWanPublisher.publishAntiEntropyEvent(WanAntiEntropyEvent event)
Publishes a WAN anti-entropy event.
|
| Modifier and Type | Class and Description |
|---|---|
class |
WanConsistencyCheckEvent
A marker event to compare merkle tree roots for a single map.
|
class |
WanSyncEvent
A marker event to initiate WAN sync for map entries.
|
| Modifier and Type | Method and Description |
|---|---|
WanAntiEntropyEvent |
WanSyncEvent.cloneWithoutPartitionKeys() |
WanAntiEntropyEvent |
WanConsistencyCheckEvent.cloneWithoutPartitionKeys() |
abstract WanAntiEntropyEvent |
WanAntiEntropyEvent.cloneWithoutPartitionKeys()
Clones this object with all data except the partition keys the event
applies to.
|
| Modifier and Type | Method and Description |
|---|---|
void |
WanSyncManager.initiateAntiEntropyRequest(String wanReplicationName,
String targetGroupName,
WanAntiEntropyEvent event)
Initiates a WAN anti-entropy event and designates this member as the
coordinator to broadcast the event to other cluster members.
|
void |
WanSyncManager.publishAntiEntropyEventOnMembers(String wanReplicationName,
String targetGroupName,
WanAntiEntropyEvent event)
Keeps broadcasting the WAN anti-entropy event to all members until it
has been triggered for all partitions or some partitions have failed for
times.
|
| Constructor and Description |
|---|
WanAntiEntropyEventPublishOperation(String wanReplicationName,
String targetGroupName,
WanAntiEntropyEvent event) |
WanAntiEntropyEventStarterOperation(String wanReplicationName,
String targetGroupName,
WanAntiEntropyEvent event) |
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.