Class ClusterConfig.Builder

java.lang.Object

com.loomcache.common.config.ClusterConfig.Builder

Enclosing class:

ClusterConfig

public static final class ClusterConfig.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
ClusterConfig.Builder	auditEnabled(boolean enabled)
ClusterConfig.Builder	auditQueueCapacity(int capacity)
ClusterConfig.Builder	authConfig(AuthConfig config)
ClusterConfig.Builder	bindAddress(@Nullable String address)
ClusterConfig	build()
ClusterConfig.Builder	clusterDataRecoveryPolicy(ClusterDataRecoveryPolicy policy)
ClusterConfig.Builder	clusterId(String id)
ClusterConfig.Builder	commandExecutorThreads(int commandExecutorThreads)
ClusterConfig.Builder	commandQueueCapacity(int commandQueueCapacity)
ClusterConfig.Builder	dataConnectionConfig(String name, DataConnectionConfig config)
ClusterConfig.Builder	dataConnectionConfigs(Map<String, DataConnectionConfig> dataConnectionConfigs)
ClusterConfig.Builder	dataDir(@Nullable String dir)
ClusterConfig.Builder	discoveryConfig(DiscoveryConfig config)
ClusterConfig.Builder	endpointTlsConfig(EndpointTlsConfig config)
ClusterConfig.Builder	genericMapStoreConfig(String mapName, GenericMapStoreConfig config)
ClusterConfig.Builder	genericMapStoreConfigs(Map<String, GenericMapStoreConfig> genericMapStoreConfigs)
ClusterConfig.Builder	gracefulShutdownDrainMs(long gracefulShutdownDrainMs)
ClusterConfig.Builder	heartbeatIntervalMs(long ms)
ClusterConfig.Builder	heartbeatTimeoutMs(long ms)
ClusterConfig.Builder	host(String h)
ClusterConfig.Builder	icmpFailureDetectorConfig(IcmpFailureDetectorConfig config)
ClusterConfig.Builder	idempotencyTtlMs(long ms)	Set the TTL for idempotency dedup cache entries (milliseconds).
ClusterConfig.Builder	idGeneratorNodeId(int nodeId)
ClusterConfig.Builder	instanceNumber(int n)
ClusterConfig.Builder	mapEvictionPolicy(String policy)
ClusterConfig.Builder	mapMaxEntries(int entries)
ClusterConfig.Builder	maxConnections(int maxConnections)
ClusterConfig.Builder	maxExecutorTaskPayloadBytes(int maxExecutorTaskPayloadBytes)
ClusterConfig.Builder	maxMemoryBytes(long bytes)
ClusterConfig.Builder	maxParallelMigrations(int maxParallelMigrations)
ClusterConfig.Builder	nodeId(String id)
ClusterConfig.Builder	numGroups(int n)	Configure the number of Raft groups (only effective when sharding is enabled).
ClusterConfig.Builder	partitionGroupConfig(PartitionGroupConfig config)
ClusterConfig.Builder	partitionGroupType(PartitionGroupType type)
ClusterConfig.Builder	persistenceBackupDir(@Nullable String dir)
ClusterConfig.Builder	persistenceDataLoadTimeoutSeconds(long seconds)
ClusterConfig.Builder	persistenceHotBackupIntervalSeconds(long seconds)
ClusterConfig.Builder	persistenceRecoveryParallelism(int parallelism)
ClusterConfig.Builder	persistenceValidationTimeoutSeconds(long seconds)
ClusterConfig.Builder	pipelinedExecution(boolean pipelinedExecution)
ClusterConfig.Builder	port(int p)
ClusterConfig.Builder	priorityQueueConfig(String queueName, PriorityQueueConfig config)
ClusterConfig.Builder	priorityQueueConfigs(Map<String, PriorityQueueConfig> priorityQueueConfigs)
ClusterConfig.Builder	queueConfig(String queueName, QueueConfig config)
ClusterConfig.Builder	queueConfigs(Map<String, QueueConfig> queueConfigs)
ClusterConfig.Builder	raftBootstrapServerEntries(String... entries)
ClusterConfig.Builder	raftBootstrapServerEntries(List<String> entries)
ClusterConfig.Builder	raftBootstrapServers(List<ClusterConfig.RaftBootstrapServer> servers)
ClusterConfig.Builder	readBackupData(boolean readBackupData)	Allow local replica reads for read operations on this member.
ClusterConfig.Builder	seeds(String... s)
ClusterConfig.Builder	seeds(List<String> s)
ClusterConfig.Builder	shardingEnabled(boolean enabled)	Enable or disable multi-Raft-group sharding (v2.0).
ClusterConfig.Builder	slowOperationDetectorConfig(SlowOperationDetectorConfig config)
ClusterConfig.Builder	snapshotThreshold(int threshold)
ClusterConfig.Builder	tcpIdleTimeoutMs(long tcpIdleTimeoutMs)
ClusterConfig.Builder	tcpReadTimeoutMs(long tcpReadTimeoutMs)
ClusterConfig.Builder	tlsConfig(TlsConfig config)
ClusterConfig.Builder	wanAcknowledgeType(WanAcknowledgeType type)
ClusterConfig.Builder	wanPersistReplicatedData(boolean persist)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Builder

public Builder()

Method Details

clusterId

public ClusterConfig.Builder clusterId(String id)

nodeId

public ClusterConfig.Builder nodeId(String id)

host

public ClusterConfig.Builder host(String h)

bindAddress

public ClusterConfig.Builder bindAddress(@Nullable String address)

port

public ClusterConfig.Builder port(int p)

instanceNumber

public ClusterConfig.Builder instanceNumber(int n)

idGeneratorNodeId

public ClusterConfig.Builder idGeneratorNodeId(int nodeId)

seeds

public ClusterConfig.Builder seeds(List<String> s)

seeds

public ClusterConfig.Builder seeds(String... s)

raftBootstrapServers

public ClusterConfig.Builder raftBootstrapServers(List<ClusterConfig.RaftBootstrapServer> servers)

raftBootstrapServerEntries

public ClusterConfig.Builder raftBootstrapServerEntries(List<String> entries)

raftBootstrapServerEntries

public ClusterConfig.Builder raftBootstrapServerEntries(String... entries)

discoveryConfig

public ClusterConfig.Builder discoveryConfig(DiscoveryConfig config)

heartbeatIntervalMs

public ClusterConfig.Builder heartbeatIntervalMs(long ms)

heartbeatTimeoutMs

public ClusterConfig.Builder heartbeatTimeoutMs(long ms)

icmpFailureDetectorConfig

public ClusterConfig.Builder icmpFailureDetectorConfig(IcmpFailureDetectorConfig config)

slowOperationDetectorConfig

public ClusterConfig.Builder slowOperationDetectorConfig(SlowOperationDetectorConfig config)

maxMemoryBytes

public ClusterConfig.Builder maxMemoryBytes(long bytes)

mapMaxEntries

public ClusterConfig.Builder mapMaxEntries(int entries)

mapEvictionPolicy

public ClusterConfig.Builder mapEvictionPolicy(String policy)

auditEnabled

public ClusterConfig.Builder auditEnabled(boolean enabled)

auditQueueCapacity

public ClusterConfig.Builder auditQueueCapacity(int capacity)

tlsConfig

public ClusterConfig.Builder tlsConfig(TlsConfig config)

endpointTlsConfig

public ClusterConfig.Builder endpointTlsConfig(EndpointTlsConfig config)

authConfig

public ClusterConfig.Builder authConfig(AuthConfig config)

dataDir

public ClusterConfig.Builder dataDir(@Nullable String dir)

persistenceBackupDir

public ClusterConfig.Builder persistenceBackupDir(@Nullable String dir)

persistenceHotBackupIntervalSeconds

public ClusterConfig.Builder persistenceHotBackupIntervalSeconds(long seconds)

idempotencyTtlMs

public ClusterConfig.Builder idempotencyTtlMs(long ms)

Set the TTL for idempotency dedup cache entries (milliseconds). Must be positive.

Parameters:

ms - TTL in milliseconds (must be > 0)

Returns:

this builder for chaining

shardingEnabled

public ClusterConfig.Builder shardingEnabled(boolean enabled)

Enable or disable multi-Raft-group sharding (v2.0).

Default: disabled. With sharding off, every write goes through the single default Raft group ("raft-0") exactly as in v1.x. Enable only when you intend to run with multiple groups; combine with numGroups(int).

Parameters:

enabled - whether to enable sharding mode

Returns:

this builder for chaining

Since:

2.0

numGroups

public ClusterConfig.Builder numGroups(int n)

Configure the number of Raft groups (only effective when sharding is enabled).

Must be >= 1. When sharding is enabled, must be >= 2 (validated at build).

Parameters:

n - number of Raft groups

Returns:

this builder for chaining

Since:

2.0

partitionGroupType

public ClusterConfig.Builder partitionGroupType(PartitionGroupType type)

partitionGroupConfig

public ClusterConfig.Builder partitionGroupConfig(PartitionGroupConfig config)

wanAcknowledgeType

public ClusterConfig.Builder wanAcknowledgeType(WanAcknowledgeType type)

wanPersistReplicatedData

public ClusterConfig.Builder wanPersistReplicatedData(boolean persist)

clusterDataRecoveryPolicy

public ClusterConfig.Builder clusterDataRecoveryPolicy(ClusterDataRecoveryPolicy policy)

snapshotThreshold

public ClusterConfig.Builder snapshotThreshold(int threshold)

persistenceValidationTimeoutSeconds

public ClusterConfig.Builder persistenceValidationTimeoutSeconds(long seconds)

persistenceDataLoadTimeoutSeconds

public ClusterConfig.Builder persistenceDataLoadTimeoutSeconds(long seconds)

persistenceRecoveryParallelism

public ClusterConfig.Builder persistenceRecoveryParallelism(int parallelism)

maxParallelMigrations

public ClusterConfig.Builder maxParallelMigrations(int maxParallelMigrations)

maxExecutorTaskPayloadBytes

public ClusterConfig.Builder maxExecutorTaskPayloadBytes(int maxExecutorTaskPayloadBytes)

readBackupData

public ClusterConfig.Builder readBackupData(boolean readBackupData)

Allow local replica reads for read operations on this member.

Default false: reads stay linearizable via leader/read-index. When enabled, reads may return stale backup data from the local replica.

Parameters:

readBackupData - whether local backup reads are enabled

Returns:

this builder for chaining

maxConnections

public ClusterConfig.Builder maxConnections(int maxConnections)

tcpReadTimeoutMs

public ClusterConfig.Builder tcpReadTimeoutMs(long tcpReadTimeoutMs)

tcpIdleTimeoutMs

public ClusterConfig.Builder tcpIdleTimeoutMs(long tcpIdleTimeoutMs)

gracefulShutdownDrainMs

public ClusterConfig.Builder gracefulShutdownDrainMs(long gracefulShutdownDrainMs)

pipelinedExecution

public ClusterConfig.Builder pipelinedExecution(boolean pipelinedExecution)

commandQueueCapacity

public ClusterConfig.Builder commandQueueCapacity(int commandQueueCapacity)

commandExecutorThreads

public ClusterConfig.Builder commandExecutorThreads(int commandExecutorThreads)

queueConfigs

public ClusterConfig.Builder queueConfigs(Map<String, QueueConfig> queueConfigs)

queueConfig

public ClusterConfig.Builder queueConfig(String queueName,
 QueueConfig config)

priorityQueueConfigs

public ClusterConfig.Builder priorityQueueConfigs(Map<String, PriorityQueueConfig> priorityQueueConfigs)

priorityQueueConfig

public ClusterConfig.Builder priorityQueueConfig(String queueName,
 PriorityQueueConfig config)

dataConnectionConfigs

public ClusterConfig.Builder dataConnectionConfigs(Map<String, DataConnectionConfig> dataConnectionConfigs)

dataConnectionConfig

public ClusterConfig.Builder dataConnectionConfig(String name,
 DataConnectionConfig config)

genericMapStoreConfigs

public ClusterConfig.Builder genericMapStoreConfigs(Map<String, GenericMapStoreConfig> genericMapStoreConfigs)

genericMapStoreConfig

public ClusterConfig.Builder genericMapStoreConfig(String mapName,
 GenericMapStoreConfig config)

build

public ClusterConfig build()