public class DrReceiverConfiguration extends Object
Modifier and Type | Field and Description |
---|---|
static boolean |
DFLT_DIRECT_BUF
Default value of direct buffer allocation.
|
static long |
DFLT_FLUSH_FREQ
Default flush frequency DR data loader.
|
static long |
DFLT_IDLE_TIMEOUT
Default server socket idle timeout.
|
static int |
DFLT_LOCAL_PORT
Default server port.
|
static int |
DFLT_MSG_QUEUE_LIMIT
Default message queue limit per connection (for incoming and outgoing .
|
static int |
DFLT_PARALLEL_LOAD_OPS
Default per node parallel operations for DR data loader.
|
static int |
DFLT_PER_NODE_BUF_SIZE
Default per node buffer buffer size for DR data loader.
|
static int |
DFLT_SELECTOR_CNT
Default quantity of NIO threads responsible for sender hub connections processing.
|
static boolean |
DFLT_TCP_NODELAY
Default TCP_NODELAY flag value for server sockets.
|
static boolean |
DFLT_USE_IGNITE_SSL_CTX_FACTORY
Default value of whether to use Ignite SSL context factory.
|
static int |
DFLT_WORKER_THREAD_CNT
Default number of threads responsible for sender hub requests processing.
|
static long |
DFLT_WRITE_TIMEOUT
Default server socket write timeout.
|
Constructor and Description |
---|
DrReceiverConfiguration()
Default constructor.
|
DrReceiverConfiguration(DrReceiverConfiguration cfg)
Copying constructor.
|
Modifier and Type | Method and Description |
---|---|
long |
getFlushFrequency()
Gets data flush frequency.
|
long |
getIdleTimeout()
Gets idle timeout for receiver hub's TCP server connection.
|
String |
getLocalInboundHost()
Gets local host name receiver hub TCP server is bound to.
|
int |
getLocalInboundPort()
Gets local port receiver hub TCP server is bound to.
|
int |
getMessageQueueLimit()
Gets message queue limit for incoming and outgoing messages in receiver hub's TCP server.
|
int |
getPerNodeBufferSize()
Gets per-node data buffer size.
|
int |
getPerNodeParallelLoadOperations()
Gets per-node parallel load operations.
|
int |
getSelectorCount()
Gets amount of selector threads in receiver hub's TCP server.
|
int |
getSocketReceiveBufferSize()
Gets socket receive buffer size in bytes.
|
int |
getSocketSendBufferSize()
Gets socket send buffer size in bytes.
|
javax.cache.configuration.Factory<SSLContext> |
getSslContextFactory()
Gets SSL context factory.
|
int |
getWorkerThreads()
Gets amount of threads responsible for sender hub batches processing.
|
long |
getWriteTimeout()
Gets write timeout for receiver hub's TCP server connection.
|
boolean |
isDirectBuffer()
Gets direct buffer flag in receiver hub's TCP server.
|
boolean |
isLazyBinaryMetadataRegistration()
Gets metadata registration mode flag:
-
true metadata is registered on the received cluster only when data that is replicated;
- false all metadata received from the master cluster are registered. |
boolean |
isTcpNodelay()
Gets TCP_NODELAY flag in receiver hub's TCP server.
|
boolean |
isUseIgniteSslContextFactory()
Gets whether to use Ignite SSL context factory configured through
IgniteConfiguration.getSslContextFactory() if getSslContextFactory() is not set. |
DrReceiverConfiguration |
setDirectBuffer(boolean directBuf)
Sets direct buffer flag in receiver hub's TCP server.
|
DrReceiverConfiguration |
setFlushFrequency(long flushFreq)
Sets data flush frequency.
|
DrReceiverConfiguration |
setIdleTimeout(long idleTimeout)
Sets idle timeout for receiver hub's TCP server connection.
|
void |
setLazyBinaryMetadataRegistration(boolean lazyBinaryMetadataRegistration)
Sets register metadata mode:
-
true metadata is registered on the received cluster only when data that is replicated;
- false all metadata received from the master cluster are registered. |
DrReceiverConfiguration |
setLocalInboundHost(String locInboundHost)
Sets local host name receiver hub TCP server is bound to.
|
DrReceiverConfiguration |
setLocalInboundPort(int locInboundPort)
Sets local port receiver hub TCP server is bound to.
|
DrReceiverConfiguration |
setMessageQueueLimit(int msgQueueLimit)
Sets message queue limit for incoming and outgoing messages in receiver hub's TCP server.
|
DrReceiverConfiguration |
setPerNodeBufferSize(int perNodeBufSize)
Sets per-node data buffer size.
|
DrReceiverConfiguration |
setPerNodeParallelLoadOperations(int perNodeParallelLoadOps)
Sets per-node parallel load operations.
|
DrReceiverConfiguration |
setSelectorCount(int selectorCnt)
Sets amount of selector threads in receiver hub's TCP server.
|
DrReceiverConfiguration |
setSocketReceiveBufferSize(int sockRcvBufSize)
Sets socket receive buffer size in bytes.
|
DrReceiverConfiguration |
setSocketSendBufferSize(int sockSndBufSize)
Sets socket send buffer size in bytes.
|
DrReceiverConfiguration |
setSslContextFactory(javax.cache.configuration.Factory<SSLContext> sslCtxFactory)
Sets SSL context factory.
|
DrReceiverConfiguration |
setTcpNodelay(boolean tcpNodelay)
Sets TCP_NODELAY flag in receiver hub's TCP server.
|
DrReceiverConfiguration |
setUseIgniteSslContextFactory(boolean useIgniteSslCtxFactory)
Sets whether to use Ignite SSL context factory.
|
DrReceiverConfiguration |
setWorkerThreads(int workerCnt)
Sets amount of threads responsible for sender hub batches processing.
|
DrReceiverConfiguration |
setWriteTimeout(long writeTimeout)
Sets write timeout for receiver hub's TCP server connection.
|
String |
toString() |
public static final int DFLT_LOCAL_PORT
public static final int DFLT_SELECTOR_CNT
public static final int DFLT_WORKER_THREAD_CNT
public static final int DFLT_MSG_QUEUE_LIMIT
public static final boolean DFLT_TCP_NODELAY
public static final boolean DFLT_DIRECT_BUF
public static final long DFLT_IDLE_TIMEOUT
public static final long DFLT_WRITE_TIMEOUT
public static final long DFLT_FLUSH_FREQ
public static final int DFLT_PER_NODE_BUF_SIZE
public static final int DFLT_PARALLEL_LOAD_OPS
public static final boolean DFLT_USE_IGNITE_SSL_CTX_FACTORY
public DrReceiverConfiguration()
public DrReceiverConfiguration(DrReceiverConfiguration cfg)
cfg
- Configuration to copy.public String getLocalInboundHost()
If not set, IgniteConfiguration.getLocalHost()
will be used.
Defaults to null
.
public DrReceiverConfiguration setLocalInboundHost(String locInboundHost)
getLocalInboundHost()
for more
information.locInboundHost
- Local host name receiver hub TCP server is bound to.this
for chaining.public int getLocalInboundPort()
Defaults to DFLT_LOCAL_PORT
.
public DrReceiverConfiguration setLocalInboundPort(int locInboundPort)
getLocalInboundPort()
for more information.locInboundPort
- Local port receiver hub TCP server is bound to.this
for chaining.public int getSelectorCount()
Defaults to DFLT_SELECTOR_CNT
.
public DrReceiverConfiguration setSelectorCount(int selectorCnt)
getSelectorCount()
for more
information.selectorCnt
- Amount of selector threads in receiver hub's TCP server.this
for chaining.public int getWorkerThreads()
Defaults to DFLT_WORKER_THREAD_CNT
.
public DrReceiverConfiguration setWorkerThreads(int workerCnt)
getWorkerThreads()
for
more information.workerCnt
- Amount of threads responsible for sender hub batches processing.this
for chaining.public int getMessageQueueLimit()
Defaults to DFLT_MSG_QUEUE_LIMIT
.
public DrReceiverConfiguration setMessageQueueLimit(int msgQueueLimit)
getMessageQueueLimit()
for more information.msgQueueLimit
- Message queue limit for incoming and outgoing messages in receiver hub's TCP server.this
for chaining.public boolean isTcpNodelay()
Defaults to DFLT_TCP_NODELAY
.
public DrReceiverConfiguration setTcpNodelay(boolean tcpNodelay)
isTcpNodelay()
for more information.tcpNodelay
- TCP_NODELAY flag in receiver hub's TCP server.this
for chaining.public boolean isDirectBuffer()
Defaults to DFLT_DIRECT_BUF
.
public DrReceiverConfiguration setDirectBuffer(boolean directBuf)
isDirectBuffer()
for more information.directBuf
- Direct buffer flag in receiver hub's TCP server.this
for chaining.public long getIdleTimeout()
Defaults to DFLT_IDLE_TIMEOUT
.
public DrReceiverConfiguration setIdleTimeout(long idleTimeout)
getWriteTimeout()
for more information.idleTimeout
- Idle timeout for receiver hub's TCP server connection.this
for chaining.public long getWriteTimeout()
Defaults to DFLT_WRITE_TIMEOUT
.
public DrReceiverConfiguration setWriteTimeout(long writeTimeout)
getWriteTimeout()
for more
information.writeTimeout
- Write timeout for receiver hub's TCP server connection.this
for chaining.public long getFlushFrequency()
Defaults to DFLT_FLUSH_FREQ
.
public DrReceiverConfiguration setFlushFrequency(long flushFreq)
getFlushFrequency()
for more information.flushFreq
- Data flush frequency.this
for chaining.public int getPerNodeBufferSize()
Defaults to DFLT_PER_NODE_BUF_SIZE
.
public DrReceiverConfiguration setPerNodeBufferSize(int perNodeBufSize)
getPerNodeBufferSize()
for more information.perNodeBufSize
- Per-node data buffer size.this
for chaining.public int getPerNodeParallelLoadOperations()
Defaults DFLT_PARALLEL_LOAD_OPS
.
public DrReceiverConfiguration setPerNodeParallelLoadOperations(int perNodeParallelLoadOps)
getPerNodeParallelLoadOperations()
for more information.perNodeParallelLoadOps
- Per-node parallel load operationsthis
for chaining.public javax.cache.configuration.Factory<SSLContext> getSslContextFactory()
isUseIgniteSslContextFactory()
flag will be evaluated. If set to true
and IgniteConfiguration.getSslContextFactory()
exists, then Ignite SSL context factory will be used
to establish secure connection.public DrReceiverConfiguration setSslContextFactory(javax.cache.configuration.Factory<SSLContext> sslCtxFactory)
getSslContextFactory()
for more information.sslCtxFactory
- SSL context factory. Passing null
will clear previously set SSL context factory.this
for chaining.public boolean isUseIgniteSslContextFactory()
IgniteConfiguration.getSslContextFactory()
if getSslContextFactory()
is not set.True
if Ignite SSL context factory can be used.public DrReceiverConfiguration setUseIgniteSslContextFactory(boolean useIgniteSslCtxFactory)
isUseIgniteSslContextFactory()
for more information.useIgniteSslCtxFactory
- Whether to use Ignite SSL context factorythis
for chaining.public int getSocketSendBufferSize()
Defaults to 0
, what means that OS default value will be used.
public DrReceiverConfiguration setSocketSendBufferSize(int sockSndBufSize)
getSocketSendBufferSize()
for more information.sockSndBufSize
- Socket send buffer size in bytes.this
for chaining.public int getSocketReceiveBufferSize()
Defaults to 0
, what means that OS default value will be used.
public DrReceiverConfiguration setSocketReceiveBufferSize(int sockRcvBufSize)
getSocketReceiveBufferSize()
for more information.sockRcvBufSize
- Socket receive buffer size in bytes.this
for chaining.public boolean isLazyBinaryMetadataRegistration()
true
metadata is registered on the received cluster only when data that is replicated;
- false
all metadata received from the master cluster are registered.public void setLazyBinaryMetadataRegistration(boolean lazyBinaryMetadataRegistration)
true
metadata is registered on the received cluster only when data that is replicated;
- false
all metadata received from the master cluster are registered.lazyBinaryMetadataRegistration
- metadata registration mode flag.
GridGain In-Memory Computing Platform : ver. 8.9.14 Release Date : November 5 2024