public class ClientOptions extends Object implements Serializable
RedisClient
.Modifier and Type | Class and Description |
---|---|
static class |
ClientOptions.Builder
Builder for
ClientOptions . |
static class |
ClientOptions.DisconnectedBehavior
Behavior of connections in disconnected state.
|
Modifier and Type | Field and Description |
---|---|
static boolean |
DEFAULT_AUTO_RECONNECT |
static int |
DEFAULT_BUFFER_USAGE_RATIO |
static boolean |
DEFAULT_CANCEL_CMD_RECONNECT_FAIL |
static ClientOptions.DisconnectedBehavior |
DEFAULT_DISCONNECTED_BEHAVIOR |
static boolean |
DEFAULT_PING_BEFORE_ACTIVATE_CONNECTION |
static boolean |
DEFAULT_PUBLISH_ON_SCHEDULER |
static int |
DEFAULT_REQUEST_QUEUE_SIZE |
static SocketOptions |
DEFAULT_SOCKET_OPTIONS |
static SslOptions |
DEFAULT_SSL_OPTIONS |
static boolean |
DEFAULT_SUSPEND_RECONNECT_PROTO_FAIL |
static TimeoutOptions |
DEFAULT_TIMEOUT_OPTIONS |
Modifier | Constructor and Description |
---|---|
protected |
ClientOptions(ClientOptions.Builder builder) |
protected |
ClientOptions(ClientOptions original) |
Modifier and Type | Method and Description |
---|---|
static ClientOptions.Builder |
builder()
Returns a new
ClientOptions.Builder to construct ClientOptions . |
static ClientOptions |
copyOf(ClientOptions options)
Create a copy of options
|
static ClientOptions |
create()
Create a new instance of
ClientOptions with default settings. |
int |
getBufferUsageRatio()
Buffer usage ratio for
CommandHandler . |
ClientOptions.DisconnectedBehavior |
getDisconnectedBehavior()
Behavior for command invocation when connections are in a disconnected state.
|
int |
getRequestQueueSize()
Request queue size for a connection.
|
SocketOptions |
getSocketOptions()
Returns the
SocketOptions . |
SslOptions |
getSslOptions()
Returns the
SslOptions . |
TimeoutOptions |
getTimeoutOptions()
Returns the
TimeoutOptions . |
boolean |
isAutoReconnect()
Controls auto-reconnect behavior on connections.
|
boolean |
isCancelCommandsOnReconnectFailure()
If this flag is true any queued commands will be canceled when a reconnect fails within the activation
sequence.
|
boolean |
isPingBeforeActivateConnection()
Deprecated.
since 5.2. PING during connection handshake becomes mandatory with RESP3. This method will be removed with
Lettuce 6.
|
boolean |
isPublishOnScheduler()
Use a dedicated
Scheduler to emit reactive data signals. |
boolean |
isSuspendReconnectOnProtocolFailure()
If this flag is true the reconnect will be suspended on protocol errors.
|
ClientOptions.Builder |
mutate()
Returns a builder to create new
ClientOptions whose settings are replicated from the current
ClientOptions . |
public static final boolean DEFAULT_PING_BEFORE_ACTIVATE_CONNECTION
public static final boolean DEFAULT_AUTO_RECONNECT
public static final boolean DEFAULT_CANCEL_CMD_RECONNECT_FAIL
public static final boolean DEFAULT_PUBLISH_ON_SCHEDULER
public static final boolean DEFAULT_SUSPEND_RECONNECT_PROTO_FAIL
public static final int DEFAULT_REQUEST_QUEUE_SIZE
public static final ClientOptions.DisconnectedBehavior DEFAULT_DISCONNECTED_BEHAVIOR
public static final SocketOptions DEFAULT_SOCKET_OPTIONS
public static final SslOptions DEFAULT_SSL_OPTIONS
public static final TimeoutOptions DEFAULT_TIMEOUT_OPTIONS
public static final int DEFAULT_BUFFER_USAGE_RATIO
protected ClientOptions(ClientOptions.Builder builder)
protected ClientOptions(ClientOptions original)
public static ClientOptions copyOf(ClientOptions options)
options
- the originalClientOptions
containing the values of optionspublic static ClientOptions.Builder builder()
ClientOptions.Builder
to construct ClientOptions
.ClientOptions.Builder
to construct ClientOptions
.public static ClientOptions create()
ClientOptions
with default settings.ClientOptions
with default settingspublic ClientOptions.Builder mutate()
ClientOptions
whose settings are replicated from the current
ClientOptions
.ClientOptions.Builder
to create new ClientOptions
whose settings are replicated from the
current ClientOptions
.@Deprecated public boolean isPingBeforeActivateConnection()
public boolean isAutoReconnect()
public boolean isCancelCommandsOnReconnectFailure()
public boolean isPublishOnScheduler()
Scheduler
to emit reactive data signals. Enabling this option can be
useful for reactive sequences that require a significant amount of processing with a single/a few Redis connections.
A single Redis connection operates on a single thread. Operations that require a significant amount of processing can
lead to a single-threaded-like behavior for all consumers of the Redis connection. When enabled, data signals will be
emitted using a different thread served by ClientResources.eventExecutorGroup()
. Defaults to false ,
see DEFAULT_PUBLISH_ON_SCHEDULER
.
Scheduler
public boolean isSuspendReconnectOnProtocolFailure()
public int getRequestQueueSize()
RedisException
if the queue size is exceeded and a new command is requested. Defaults to
Integer.MAX_VALUE
.public ClientOptions.DisconnectedBehavior getDisconnectedBehavior()
true
. See DEFAULT_DISCONNECTED_BEHAVIOR
.public SocketOptions getSocketOptions()
SocketOptions
.SocketOptions
.public SslOptions getSslOptions()
SslOptions
.SslOptions
.public TimeoutOptions getTimeoutOptions()
TimeoutOptions
.TimeoutOptions
.public int getBufferUsageRatio()
CommandHandler
. This ratio controls how often bytes are discarded
during decoding. In particular, when buffer usage reaches bufferUsageRatio / bufferUsageRatio + 1
. E.g. setting
bufferUsageRatio
to 3, will discard read bytes once the buffer usage reaches 75 percent.Copyright © 2019 lettuce.io. All rights reserved.