public interface WanReplicationService extends CoreService, StatisticsAwareService<LocalWanStats>
WanReplicationPublisher
instances to replicate
values to other clusters over the wide area network, so it has to deal
with long delays, slow uploads and higher latencies.Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME
Service name.
|
Modifier and Type | Method and Description |
---|---|
AddWanConfigResult |
addWanReplicationConfig(WanReplicationConfig wanConfig)
Adds a new
WanReplicationConfig to the cluster. |
void |
addWanReplicationConfigLocally(WanReplicationConfig wanConfig)
Adds a new
WanReplicationConfig to this member and creates the
WanReplicationPublisher s specified in the config. |
UUID |
consistencyCheck(String wanReplicationName,
String wanPublisherId,
String mapName)
Initiate WAN consistency check for a specific map.
|
DistributedServiceWanEventCounters |
getReceivedEventCounters(String serviceName)
Returns a counter of received and processed WAN replication events.
|
DistributedServiceWanEventCounters |
getSentEventCounters(String wanReplicationName,
String wanPublisherId,
String serviceName)
Returns a counter of sent and processed WAN replication events.
|
List<Version> |
getSupportedWanProtocolVersions()
Returns an immutable collection of all WAN protocol versions supported by
this instance.
|
DelegatingWanReplicationScheme |
getWanReplicationPublishers(String name)
Creates a new
WanReplicationPublisher by the given name. |
WanSyncState |
getWanSyncState()
Returns current status of WAN sync operation or
null when there
is no status. |
void |
pause(String wanReplicationName,
String wanPublisherId)
Pauses WAN replication for the given
wanReplicationName and
wanPublisherId on this hazelcast instance. |
void |
removeWanEventCounters(String serviceName,
String dataStructureName)
Removes all WAN event counters for the given
serviceName and
dataStructureName . |
void |
removeWanEvents(String wanReplicationName,
String wanPublisherId)
Removes all WAN events awaiting replication for the given wanReplicationName
for the given target.
|
void |
resume(String wanReplicationName,
String wanPublisherId)
Resumes WAN replication for the given
wanReplicationName and
wanPublisherId on this hazelcast instance. |
void |
shutdown()
Starts the shutdown process of the WAN replication service.
|
void |
stop(String wanReplicationName,
String wanPublisherId)
Stops WAN replication for the given
wanReplicationName and
wanPublisherId on this hazelcast instance. |
UUID |
syncAllMaps(String wanReplicationName,
String wanPublisherId)
Initiate wan sync for all maps.
|
UUID |
syncMap(String wanReplicationName,
String wanPublisherId,
String mapName)
Initiate wan sync for a specific map.
|
getStats
static final String SERVICE_NAME
DelegatingWanReplicationScheme getWanReplicationPublishers(String name)
WanReplicationPublisher
by the given name. If
the name already exists, returns the previous instance.name
- name of the WAN replication configurationvoid shutdown()
void pause(String wanReplicationName, String wanPublisherId)
wanReplicationName
and
wanPublisherId
on this hazelcast instance.wanReplicationName
- name of WAN replication configurationwanPublisherId
- ID of the WAN replication publisherUnsupportedOperationException
- if called on an OS instancevoid stop(String wanReplicationName, String wanPublisherId)
wanReplicationName
and
wanPublisherId
on this hazelcast instance.wanReplicationName
- name of WAN replication configurationwanPublisherId
- ID of the WAN replication publisherUnsupportedOperationException
- if called on an OS instancevoid resume(String wanReplicationName, String wanPublisherId)
wanReplicationName
and
wanPublisherId
on this hazelcast instance.wanReplicationName
- name of WAN replication configurationwanPublisherId
- ID of the WAN replication publisherUnsupportedOperationException
- if called on an OS instanceUUID syncMap(String wanReplicationName, String wanPublisherId, String mapName)
wanReplicationName
- the name of the wan replication configwanPublisherId
- ID of the WAN replication publishermapName
- the map nameUnsupportedOperationException
- if the operation is not supported (not EE)InvalidConfigurationException
- if there is no WAN replication
config for wanReplicationName
UUID syncAllMaps(String wanReplicationName, String wanPublisherId)
wanReplicationName
- the name of the wan replication configwanPublisherId
- ID of the WAN replication publisherUnsupportedOperationException
- if the operation is not supported (not EE)InvalidConfigurationException
- if there is no WAN replication config for
wanReplicationName
UUID consistencyCheck(String wanReplicationName, String wanPublisherId, String mapName)
wanReplicationName
- the name of the wan replication configwanPublisherId
- ID of the WAN replication publishermapName
- the map namenull
if consistency check is ignored because of the configurationUnsupportedOperationException
- if the operation is not supported (not EE)InvalidConfigurationException
- if there is no WAN replication config for wanReplicationName
void removeWanEvents(String wanReplicationName, String wanPublisherId)
wanReplicationName
- the name of the wan replication configwanPublisherId
- ID of the WAN replication publisherUnsupportedOperationException
- if invoked on OSvoid addWanReplicationConfigLocally(WanReplicationConfig wanConfig)
WanReplicationConfig
to this member and creates the
WanReplicationPublisher
s specified in the config.
This method can also accept WAN configs with an existing WAN replication
name. Such configs will be merged into the existing WAN replication
config by adding publishers with publisher IDs which are not already part
of the existing configuration.UnsupportedOperationException
- if invoked on OSAddWanConfigResult addWanReplicationConfig(WanReplicationConfig wanConfig)
WanReplicationConfig
to the cluster.
This method can also accept WAN configs with an existing WAN replication
name. Such configs will be merged into the existing WAN replication
config by adding publishers with publisher IDs which are not already part
of the existing configuration.
The return value is a best-effort guess at the result of adding WAN
replication config based on the existing local WAN replication config.
An exact result is difficult to calculate since not all members might
have the same existing configuration and there might be a concurrent
request to add overlapping WAN replication config.wanConfig
- the WAN replication config to addUnsupportedOperationException
- if invoked on OSaddWanReplicationConfigLocally(WanReplicationConfig)
WanSyncState getWanSyncState()
null
when there
is no status.DistributedServiceWanEventCounters getReceivedEventCounters(String serviceName)
serviceName
- the name of the service for the WAN eventsDistributedServiceWanEventCounters getSentEventCounters(String wanReplicationName, String wanPublisherId, String serviceName)
wanReplicationName
- the name of the wan replication configwanPublisherId
- WAN replication publisher IDserviceName
- the name of the service for the WAN eventsvoid removeWanEventCounters(String serviceName, String dataStructureName)
serviceName
and
dataStructureName
.serviceName
- the name of the service for the WAN eventsdataStructureName
- the distributed object nameCopyright © 2019 Hazelcast, Inc.. All rights reserved.