Package | Description |
---|---|
com.hazelcast.config |
Provides classes for configuring HazelcastInstance.
|
Modifier and Type | Method and Description |
---|---|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setAcknowledgeType(WanAcknowledgeType acknowledgeType)
Sets the strategy for when the target cluster should acknowledge that
a WAN event batch has been processed.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setAwsConfig(AwsConfig awsConfig)
Sets the
AwsConfig used by the discovery mechanism for this
WAN publisher. |
WanBatchPublisherConfig |
WanBatchPublisherConfig.setAzureConfig(AzureConfig azureConfig)
Sets the
AzureConfig used by the discovery mechanism for this
WAN publisher. |
WanBatchPublisherConfig |
WanBatchPublisherConfig.setBatchMaxDelayMillis(int batchMaxDelayMillis)
Sets the maximum amount of time in milliseconds to wait before sending a
batch of events to target cluster, if
getBatchSize() of events
have not arrived within this duration. |
WanBatchPublisherConfig |
WanBatchPublisherConfig.setBatchSize(int batchSize)
Sets the maximum batch size that can be sent to target cluster.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setClassName(String className) |
WanBatchPublisherConfig |
WanBatchPublisherConfig.setClusterName(String clusterName)
Sets the cluster name used as an endpoint group password for authentication
on the target endpoint.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setDiscoveryConfig(DiscoveryConfig discoveryConfig)
Sets the
DiscoveryConfig used by the discovery mechanism for
this WAN publisher. |
WanBatchPublisherConfig |
WanBatchPublisherConfig.setDiscoveryPeriodSeconds(int discoveryPeriodSeconds)
Sets the period in seconds in which WAN tries to discover new target
endpoints and reestablish connections to failed endpoints.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setEndpoint(String endpoint)
Sets the WAN endpoint configuration qualifier.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setEurekaConfig(EurekaConfig eurekaConfig)
Sets the
EurekaConfig used by the discovery mechanism for this
WAN publisher. |
WanBatchPublisherConfig |
WanBatchPublisherConfig.setGcpConfig(GcpConfig gcpConfig)
Sets the
GcpConfig used by the discovery mechanism for this
WAN publisher. |
WanBatchPublisherConfig |
WanBatchPublisherConfig.setIdleMaxParkNs(long idleMaxParkNs)
Sets the maximum duration in nanoseconds that the WAN replication thread
will be parked if there are no events to replicate.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setIdleMinParkNs(long idleMinParkNs)
Sets the minimum duration in nanoseconds that the WAN replication thread
will be parked if there are no events to replicate.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setImplementation(WanPublisher implementation)
No-op method as the implementation cannot be changed for this publisher.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setInitialPublisherState(WanPublisherState initialPublisherState)
Sets the initial publisher state.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setKubernetesConfig(KubernetesConfig kubernetesConfig)
Sets the
KubernetesConfig used by the discovery mechanism for this
WAN publisher. |
WanBatchPublisherConfig |
WanBatchPublisherConfig.setMaxConcurrentInvocations(int maxConcurrentInvocations)
Sets the maximum number of WAN event batches being sent to the target
cluster concurrently.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setMaxTargetEndpoints(int maxTargetEndpoints)
Sets the maximum number of endpoints that WAN will connect to when
using a discovery mechanism to define endpoints.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setProperties(Map<String,Comparable> properties) |
WanBatchPublisherConfig |
WanBatchPublisherConfig.setPublisherId(String publisherId) |
WanBatchPublisherConfig |
WanBatchPublisherConfig.setQueueCapacity(int queueCapacity)
Sets the capacity of the primary and backup queue for WAN replication events.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setQueueFullBehavior(WanQueueFullBehavior queueFullBehavior)
Sets the configured behaviour of this WAN publisher when the WAN queue is
full.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setResponseTimeoutMillis(int responseTimeoutMillis)
Sets the duration in milliseconds for the waiting time before retrying to
send the events to target cluster again in case of acknowledgement
is not arrived.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setSnapshotEnabled(boolean snapshotEnabled)
Sets if key-based coalescing is configured for this WAN publisher.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setSyncConfig(WanSyncConfig syncConfig)
Sets the config for the WAN sync mechanism.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setTargetEndpoints(String targetEndpoints)
Sets the comma separated list of target cluster members,
e.g.
|
WanBatchPublisherConfig |
WanBatchPublisherConfig.setUseEndpointPrivateAddress(boolean useEndpointPrivateAddress)
Sets whether the WAN connection manager should connect to the
endpoint on the private address returned by the discovery SPI.
|
Modifier and Type | Method and Description |
---|---|
List<WanBatchPublisherConfig> |
WanReplicationConfig.getBatchPublisherConfigs()
Returns the list of WAN publisher configurations using the built-in
batching WAN implementation for this WAN replication.
|
Modifier and Type | Method and Description |
---|---|
WanReplicationConfig |
WanReplicationConfig.addBatchReplicationPublisherConfig(WanBatchPublisherConfig config)
Adds a WAN publisher configuration using the built-in batching WAN
implementation to this WAN replication.
|
Modifier and Type | Method and Description |
---|---|
WanReplicationConfig |
WanReplicationConfig.setBatchPublisherConfigs(List<WanBatchPublisherConfig> batchPublisherConfigs)
Sets the list of WAN publisher configurations using the built-in
batching WAN implementation for this WAN replication.
|
Copyright © 2023 Hazelcast, Inc.. All rights reserved.