Class RedisReplicationConnectOptions

java.lang.Object

io.vertx.redis.client.RedisConnectOptions

io.vertx.redis.client.RedisReplicationConnectOptions

public class RedisReplicationConnectOptions
extends RedisConnectOptions

Constructor Summary

Constructors

Constructor	Description
RedisReplicationConnectOptions()
RedisReplicationConnectOptions(JsonObject json)
RedisReplicationConnectOptions(RedisOptions options)
RedisReplicationConnectOptions(RedisReplicationConnectOptions other)

Method Summary

Modifier and Type	Method	Description
RedisReplicationConnectOptions	addConnectionString(String connectionString)	Adds a connection string (endpoint) to use while connecting to the redis server.
RedisTopology	getTopology()	Get how the topology should be obtained.
RedisReplicas	getUseReplicas()	Get whether to use replica nodes for read only queries.
RedisReplicationConnectOptions	setConnectionString(String connectionString)	Sets a single connection string (endpoint) to use while connecting to the redis server.
RedisReplicationConnectOptions	setEndpoints(List<String> endpoints)	Set the endpoints to use while connecting to the redis server.
RedisReplicationConnectOptions	setMaxNestedArrays(int maxNestedArrays)	Tune how much nested arrays are allowed on a redis response.
RedisReplicationConnectOptions	setMaxWaitingHandlers(int maxWaitingHandlers)	The client will always work on pipeline mode, this means that messages can start queueing.
RedisReplicationConnectOptions	setPassword(String password)	Set the default password for Redis connections.
RedisReplicationConnectOptions	setPreferredProtocolVersion(ProtocolVersion preferredProtocolVersion)	Sets the preferred protocol version to be used during protocol negotiation.
RedisReplicationConnectOptions	setProtocolNegotiation(boolean protocolNegotiation)	Should the client perform REST protocol negotiation during the connection acquire.
RedisReplicationConnectOptions	setTopology(RedisTopology topology)	Set how the topology should be obtained.
RedisReplicationConnectOptions	setUser(String user)	Set the default username for Redis connections.
RedisReplicationConnectOptions	setUseReplicas(RedisReplicas useReplicas)	Set whether to use replica nodes for read only queries.
JsonObject	toJson()	Converts this object to JSON notation.

Methods inherited from class RedisConnectOptions

getEndpoint, getEndpoints, getMaxNestedArrays, getMaxWaitingHandlers, getPassword, getPreferredProtocolVersion, getUser, isProtocolNegotiation

Methods inherited from class Object

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

Constructor Details

RedisReplicationConnectOptions

public RedisReplicationConnectOptions()

RedisReplicationConnectOptions

public RedisReplicationConnectOptions(RedisOptions options)

RedisReplicationConnectOptions

public RedisReplicationConnectOptions(RedisReplicationConnectOptions other)

RedisReplicationConnectOptions

public RedisReplicationConnectOptions(JsonObject json)

Method Details

getTopology

public RedisTopology getTopology()

Get how the topology should be obtained. By default, the topology is discovered automatically.

Returns:

the topology mode

setTopology

public RedisReplicationConnectOptions setTopology(RedisTopology topology)

Set how the topology should be obtained. By default, the topology is discovered automatically.

Parameters:

topology - the topology mode

Returns:

fluent self

getUseReplicas

public RedisReplicas getUseReplicas()

Get whether to use replica nodes for read only queries.

Returns:

the cluster replica node use mode.

setUseReplicas

public RedisReplicationConnectOptions setUseReplicas(RedisReplicas useReplicas)

Set whether to use replica nodes for read only queries.

Parameters:

useReplicas - the cluster replica use mode.

Returns:

fluent self.

setMaxNestedArrays

public RedisReplicationConnectOptions setMaxNestedArrays(int maxNestedArrays)

Description copied from class: RedisConnectOptions

Tune how much nested arrays are allowed on a redis response. This affects the parser performance.

Overrides:

setMaxNestedArrays in class RedisConnectOptions

Parameters:

maxNestedArrays - the configured max nested arrays allowance.

Returns:

fluent self.

setProtocolNegotiation

public RedisReplicationConnectOptions setProtocolNegotiation(boolean protocolNegotiation)

Description copied from class: RedisConnectOptions

Should the client perform REST protocol negotiation during the connection acquire. By default this is true, but there are situations when using broken servers it may be useful to skip this and always fallback to RESP2 without using the HELLO command.

Overrides:

setProtocolNegotiation in class RedisConnectOptions

Parameters:

protocolNegotiation - false to disable HELLO (not recommended) unless reasons...

Returns:

fluent self

setPreferredProtocolVersion

public RedisReplicationConnectOptions setPreferredProtocolVersion(ProtocolVersion preferredProtocolVersion)

Description copied from class: RedisConnectOptions

Sets the preferred protocol version to be used during protocol negotiation. When not set, defaults to RESP 3. When protocol negotiation is disabled, this setting has no effect.

Overrides:

setPreferredProtocolVersion in class RedisConnectOptions

Parameters:

preferredProtocolVersion - preferred protocol version

Returns:

fluent self

setUser

public RedisReplicationConnectOptions setUser(String user)

Description copied from class: RedisConnectOptions

Set the default username for Redis connections.

Overrides:

setUser in class RedisConnectOptions

Parameters:

user - the default username

Returns:

fluent self

setPassword

public RedisReplicationConnectOptions setPassword(String password)

Description copied from class: RedisConnectOptions

Set the default password for Redis connections.

Overrides:

setPassword in class RedisConnectOptions

Parameters:

password - the default password

Returns:

fluent self

setEndpoints

public RedisReplicationConnectOptions setEndpoints(List<String> endpoints)

Description copied from class: RedisConnectOptions

Set the endpoints to use while connecting to the redis server. Only the cluster mode will consider more than 1 element. If more are provided, they are not considered by the client when in single server mode.

Overrides:

setEndpoints in class RedisConnectOptions

Parameters:

endpoints - list of socket addresses.

Returns:

fluent self.

addConnectionString

public RedisReplicationConnectOptions addConnectionString(String connectionString)

Description copied from class: RedisConnectOptions

Adds a connection string (endpoint) to use while connecting to the redis server. Only the cluster mode will consider more than 1 element. If more are provided, they are not considered by the client when in single server mode.

Overrides:

addConnectionString in class RedisConnectOptions

Parameters:

connectionString - a string URI following the scheme: redis://[username:password@][host][:port][/database]

Returns:

fluent self.

See Also:

• Redis scheme on iana.org

setConnectionString

public RedisReplicationConnectOptions setConnectionString(String connectionString)

Description copied from class: RedisConnectOptions

Sets a single connection string (endpoint) to use while connecting to the redis server. Will replace the previously configured connection strings.

Overrides:

setConnectionString in class RedisConnectOptions

Parameters:

connectionString - a string following the scheme: redis://[username:password@][host][:port][/[database].

Returns:

fluent self.

See Also:

• Redis scheme on iana.org

setMaxWaitingHandlers

public RedisReplicationConnectOptions setMaxWaitingHandlers(int maxWaitingHandlers)

Description copied from class: RedisConnectOptions

The client will always work on pipeline mode, this means that messages can start queueing. You can control how much backlog you're willing to accept. This methods sets how much handlers is the client willing to queue.

Overrides:

setMaxWaitingHandlers in class RedisConnectOptions

Parameters:

maxWaitingHandlers - max allowed queued waiting handlers.

Returns:

fluent self.

toJson

public JsonObject toJson()

Converts this object to JSON notation.

Overrides:

toJson in class RedisConnectOptions

Returns:

JSON