Class LoomConfig.Builder

java.lang.Object

com.loomcache.server.config.LoomConfig.Builder

Enclosing class:

LoomConfig

public static final class LoomConfig.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
LoomConfig.Builder	addClusterMember(String member)
LoomConfig.Builder	addMapIndex(String mapName, IndexConfig indexConfig)
LoomConfig.Builder	advertisedHost(String advertisedHost)
LoomConfig.Builder	auditEnabled(boolean enabled)
LoomConfig.Builder	auditQueueCapacity(int capacity)
LoomConfig.Builder	authConfig(AuthConfig config)
LoomConfig.Builder	backupDirectory(@Nullable String path)
LoomConfig.Builder	backupDirectory(@Nullable Path path)
LoomConfig.Builder	bindAddress(String bindAddress)	Set the bind address (non-null, non-blank).
LoomConfig	build()
LoomConfig.Builder	clusterDataRecoveryPolicy(ClusterDataRecoveryPolicy policy)
LoomConfig.Builder	clusterId(String clusterId)
LoomConfig.Builder	clusterMembers(List<String> members)
LoomConfig.Builder	commandExecutorThreads(int threads)
LoomConfig.Builder	commandQueueCapacity(int capacity)
LoomConfig.Builder	dataConnectionConfig(String name, DataConnectionConfig config)
LoomConfig.Builder	dataConnectionConfigs(Map<String, DataConnectionConfig> dataConnectionConfigs)
LoomConfig.Builder	discoveryConfig(DiscoveryConfig config)
LoomConfig.Builder	enablePersistence(boolean enable)
LoomConfig.Builder	endpointTlsConfig(EndpointTlsConfig config)
LoomConfig.Builder	evictionPolicy(String policy)
LoomConfig.Builder	genericMapStoreConfig(String mapName, GenericMapStoreConfig config)
LoomConfig.Builder	genericMapStoreConfigs(Map<String, GenericMapStoreConfig> genericMapStoreConfigs)
LoomConfig.Builder	gracefulShutdownDrainMs(long ms)
LoomConfig.Builder	healthCheckIntervalMs(long ms)
LoomConfig.Builder	hotBackupIntervalSeconds(long seconds)
LoomConfig.Builder	icmpFailureDetectorConfig(IcmpFailureDetectorConfig config)
LoomConfig.Builder	idempotencyTtlMs(long ms)	Set the TTL for idempotency dedup cache entries (milliseconds).
LoomConfig.Builder	idGeneratorNodeId(int nodeId)
LoomConfig.Builder	logCompactionThreshold(int threshold)
LoomConfig.Builder	mapIndexes(Map<String, List<IndexConfig>> mapIndexes)
LoomConfig.Builder	maxConnections(int maxConnections)
LoomConfig.Builder	maxEntriesPerAppend(int max)
LoomConfig.Builder	maxExecutorTaskPayloadBytes(int maxExecutorTaskPayloadBytes)
LoomConfig.Builder	maxMapEntries(int maxEntries)
LoomConfig.Builder	maxMemoryBytes(long bytes)
LoomConfig.Builder	maxParallelMigrations(int maxParallelMigrations)
LoomConfig.Builder	metricsPort(int port)
LoomConfig.Builder	nodeHost(String advertisedHost)
LoomConfig.Builder	nodeId(String nodeId)	Set the node ID (non-null, non-blank).
LoomConfig.Builder	partitionGroupConfig(PartitionGroupConfig config)
LoomConfig.Builder	partitionGroupType(PartitionGroupType type)
LoomConfig.Builder	persistenceDataLoadTimeoutSeconds(long seconds)
LoomConfig.Builder	persistenceRecoveryParallelism(int parallelism)
LoomConfig.Builder	persistenceValidationTimeoutSeconds(long seconds)
LoomConfig.Builder	pipelinedExecution(boolean enabled)
LoomConfig.Builder	port(int port)
LoomConfig.Builder	priorityQueueConfig(String queueName, PriorityQueueConfig config)
LoomConfig.Builder	priorityQueueConfigs(Map<String, PriorityQueueConfig> priorityQueueConfigs)
LoomConfig.Builder	queueConfig(String queueName, QueueConfig config)
LoomConfig.Builder	queueConfigs(Map<String, QueueConfig> queueConfigs)
LoomConfig.Builder	raftBootstrapServerEntries(String... entries)
LoomConfig.Builder	raftBootstrapServerEntries(List<String> entries)
LoomConfig.Builder	raftBootstrapServers(List<ClusterConfig.RaftBootstrapServer> servers)
LoomConfig.Builder	raftElectionTimeoutMs(long ms)
LoomConfig.Builder	raftGroupCount(int count)
LoomConfig.Builder	raftHeartbeatIntervalMs(long ms)
LoomConfig.Builder	readBackupData(boolean readBackupData)
LoomConfig.Builder	replicationTimeoutMs(long ms)
LoomConfig.Builder	slowOperationDetectorConfig(SlowOperationDetectorConfig config)
LoomConfig.Builder	snapshotThreshold(int threshold)
LoomConfig.Builder	tcpIdleTimeoutMs(long ms)
LoomConfig.Builder	tcpReadTimeoutMs(long ms)
LoomConfig.Builder	tlsConfig(TlsConfig config)
LoomConfig.Builder	walDirectory(String path)
LoomConfig.Builder	walDirectory(Path path)
LoomConfig.Builder	wanAcknowledgeType(WanAcknowledgeType type)
LoomConfig.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

nodeId

public LoomConfig.Builder nodeId(String nodeId)

Set the node ID (non-null, non-blank).

Parameters:

nodeId - the node identifier

Returns:

this builder for chaining

advertisedHost

public LoomConfig.Builder advertisedHost(String advertisedHost)

nodeHost

public LoomConfig.Builder nodeHost(String advertisedHost)

bindAddress

public LoomConfig.Builder bindAddress(String bindAddress)

Set the bind address (non-null, non-blank).

Parameters:

bindAddress - the IP address to bind to

Returns:

this builder for chaining

port

public LoomConfig.Builder port(int port)

idGeneratorNodeId

public LoomConfig.Builder idGeneratorNodeId(int nodeId)

clusterId

public LoomConfig.Builder clusterId(String clusterId)

clusterMembers

public LoomConfig.Builder clusterMembers(List<String> members)

raftBootstrapServers

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

raftBootstrapServerEntries

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

raftBootstrapServerEntries

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

discoveryConfig

public LoomConfig.Builder discoveryConfig(DiscoveryConfig config)

addClusterMember

public LoomConfig.Builder addClusterMember(String member)

raftElectionTimeoutMs

public LoomConfig.Builder raftElectionTimeoutMs(long ms)

raftHeartbeatIntervalMs

public LoomConfig.Builder raftHeartbeatIntervalMs(long ms)

healthCheckIntervalMs

public LoomConfig.Builder healthCheckIntervalMs(long ms)

icmpFailureDetectorConfig

public LoomConfig.Builder icmpFailureDetectorConfig(IcmpFailureDetectorConfig config)

slowOperationDetectorConfig

public LoomConfig.Builder slowOperationDetectorConfig(SlowOperationDetectorConfig config)

metricsPort

public LoomConfig.Builder metricsPort(int port)

walDirectory

public LoomConfig.Builder walDirectory(Path path)

walDirectory

public LoomConfig.Builder walDirectory(String path)

backupDirectory

public LoomConfig.Builder backupDirectory(@Nullable Path path)

backupDirectory

public LoomConfig.Builder backupDirectory(@Nullable String path)

hotBackupIntervalSeconds

public LoomConfig.Builder hotBackupIntervalSeconds(long seconds)

snapshotThreshold

public LoomConfig.Builder snapshotThreshold(int threshold)

clusterDataRecoveryPolicy

public LoomConfig.Builder clusterDataRecoveryPolicy(ClusterDataRecoveryPolicy policy)

persistenceValidationTimeoutSeconds

public LoomConfig.Builder persistenceValidationTimeoutSeconds(long seconds)

persistenceDataLoadTimeoutSeconds

public LoomConfig.Builder persistenceDataLoadTimeoutSeconds(long seconds)

persistenceRecoveryParallelism

public LoomConfig.Builder persistenceRecoveryParallelism(int parallelism)

maxParallelMigrations

public LoomConfig.Builder maxParallelMigrations(int maxParallelMigrations)

maxExecutorTaskPayloadBytes

public LoomConfig.Builder maxExecutorTaskPayloadBytes(int maxExecutorTaskPayloadBytes)

readBackupData

public LoomConfig.Builder readBackupData(boolean readBackupData)

maxMapEntries

public LoomConfig.Builder maxMapEntries(int maxEntries)

evictionPolicy

public LoomConfig.Builder evictionPolicy(String policy)

maxMemoryBytes

public LoomConfig.Builder maxMemoryBytes(long bytes)

enablePersistence

public LoomConfig.Builder enablePersistence(boolean enable)

auditEnabled

public LoomConfig.Builder auditEnabled(boolean enabled)

auditQueueCapacity

public LoomConfig.Builder auditQueueCapacity(int capacity)

tlsConfig

public LoomConfig.Builder tlsConfig(TlsConfig config)

endpointTlsConfig

public LoomConfig.Builder endpointTlsConfig(EndpointTlsConfig config)

authConfig

public LoomConfig.Builder authConfig(AuthConfig config)

maxConnections

public LoomConfig.Builder maxConnections(int maxConnections)

tcpReadTimeoutMs

public LoomConfig.Builder tcpReadTimeoutMs(long ms)

tcpIdleTimeoutMs

public LoomConfig.Builder tcpIdleTimeoutMs(long ms)

gracefulShutdownDrainMs

public LoomConfig.Builder gracefulShutdownDrainMs(long ms)

maxEntriesPerAppend

public LoomConfig.Builder maxEntriesPerAppend(int max)

replicationTimeoutMs

public LoomConfig.Builder replicationTimeoutMs(long ms)

logCompactionThreshold

public LoomConfig.Builder logCompactionThreshold(int threshold)

pipelinedExecution

public LoomConfig.Builder pipelinedExecution(boolean enabled)

commandQueueCapacity

public LoomConfig.Builder commandQueueCapacity(int capacity)

commandExecutorThreads

public LoomConfig.Builder commandExecutorThreads(int threads)

raftGroupCount

public LoomConfig.Builder raftGroupCount(int count)

partitionGroupType

public LoomConfig.Builder partitionGroupType(PartitionGroupType type)

partitionGroupConfig

public LoomConfig.Builder partitionGroupConfig(PartitionGroupConfig config)

mapIndexes

public LoomConfig.Builder mapIndexes(Map<String, List<IndexConfig>> mapIndexes)

addMapIndex

public LoomConfig.Builder addMapIndex(String mapName,
 IndexConfig indexConfig)

queueConfigs

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

queueConfig

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

priorityQueueConfigs

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

priorityQueueConfig

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

dataConnectionConfigs

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

dataConnectionConfig

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

genericMapStoreConfigs

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

genericMapStoreConfig

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

idempotencyTtlMs

public LoomConfig.Builder idempotencyTtlMs(long ms)

Set the TTL for idempotency dedup cache entries (milliseconds). Must be positive. Default is 60,000 ms (1 minute).

Parameters:

ms - TTL in milliseconds (must be > 0)

Returns:

this builder for chaining

wanAcknowledgeType

public LoomConfig.Builder wanAcknowledgeType(WanAcknowledgeType type)

wanPersistReplicatedData

public LoomConfig.Builder wanPersistReplicatedData(boolean persist)

build

public LoomConfig build()