Package io.lettuce.core

Class ConnectionBuilder

java.lang.Object

io.lettuce.core.ConnectionBuilder

Direct Known Subclasses:

SslConnectionBuilder

public class ConnectionBuilder
extends Object

Connection builder for connections. This class is part of the internal API.

Author:

Mark Paluch, Bodong Ybd

Field Summary

Fields

Modifier and Type	Field	Description
static AttributeKey<Throwable>	INIT_FAILURE
static AttributeKey<String>	REDIS_URI

Constructor Summary

Constructors

Constructor	Description
ConnectionBuilder()

Method Summary

Modifier and Type	Method	Description
void	apply(RedisURI redisURI)	Apply settings from RedisURI
Bootstrap	bootstrap()
ConnectionBuilder	bootstrap(Bootstrap bootstrap)
ChannelInitializer<Channel>	build(SocketAddress socketAddress)
protected List<ChannelHandler>	buildHandlers()
ConnectionBuilder	channelGroup(ChannelGroup channelGroup)
ClientOptions	clientOptions()
ConnectionBuilder	clientOptions(ClientOptions clientOptions)
ClientResources	clientResources()
ConnectionBuilder	clientResources(ClientResources clientResources)
ConnectionBuilder	commandHandler(Supplier<CommandHandler> supplier)
void	configureBootstrap(boolean domainSocket, Function<Class<? extends EventLoopGroup>,EventLoopGroup> eventLoopGroupProvider)	Initialize the Bootstrap.
RedisChannelHandler<?,?>	connection()
ConnectionBuilder	connection(RedisChannelHandler<?,?> connection)
static ConnectionBuilder	connectionBuilder()
ConnectionBuilder	connectionEvents(ConnectionEvents connectionEvents)
ConnectionBuilder	connectionInitializer(ConnectionInitializer connectionInitializer)
protected ConnectionWatchdog	createConnectionWatchdog()
Endpoint	endpoint()
ConnectionBuilder	endpoint(Endpoint endpoint)
protected ChannelHandler	getHandshakeHandler()
RedisURI	getRedisURI()
Duration	getTimeout()
ConnectionBuilder	reconnectionListener(ReconnectionListener reconnectionListener)
Mono<SocketAddress>	socketAddress()
ConnectionBuilder	socketAddressSupplier(Mono<SocketAddress> socketAddressSupplier)
ConnectionBuilder	timeout(Duration timeout)

Methods inherited from class java.lang.Object

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

Field Detail

REDIS_URI

public static final AttributeKey<String> REDIS_URI

INIT_FAILURE

public static final AttributeKey<Throwable> INIT_FAILURE

Constructor Detail

ConnectionBuilder

public ConnectionBuilder()

Method Detail

connectionBuilder

public static ConnectionBuilder connectionBuilder()

apply

public void apply(RedisURI redisURI)

Apply settings from RedisURI

Parameters:

redisURI -

buildHandlers

protected List<ChannelHandler> buildHandlers()

getHandshakeHandler

protected ChannelHandler getHandshakeHandler()

createConnectionWatchdog

protected ConnectionWatchdog createConnectionWatchdog()

build

public ChannelInitializer<Channel> build(SocketAddress socketAddress)

socketAddressSupplier

public ConnectionBuilder socketAddressSupplier(Mono<SocketAddress> socketAddressSupplier)

socketAddress

public Mono<SocketAddress> socketAddress()

timeout

public ConnectionBuilder timeout(Duration timeout)

getTimeout

public Duration getTimeout()

reconnectionListener

public ConnectionBuilder reconnectionListener(ReconnectionListener reconnectionListener)

clientOptions

public ConnectionBuilder clientOptions(ClientOptions clientOptions)

connectionEvents

public ConnectionBuilder connectionEvents(ConnectionEvents connectionEvents)

connection

public ConnectionBuilder connection(RedisChannelHandler<?,?> connection)

channelGroup

public ConnectionBuilder channelGroup(ChannelGroup channelGroup)

commandHandler

public ConnectionBuilder commandHandler(Supplier<CommandHandler> supplier)

bootstrap

public ConnectionBuilder bootstrap(Bootstrap bootstrap)

endpoint

public ConnectionBuilder endpoint(Endpoint endpoint)

clientResources

public ConnectionBuilder clientResources(ClientResources clientResources)

connectionInitializer

public ConnectionBuilder connectionInitializer(ConnectionInitializer connectionInitializer)

configureBootstrap

public void configureBootstrap(boolean domainSocket,
                               Function<Class<? extends EventLoopGroup>,EventLoopGroup> eventLoopGroupProvider)

Initialize the Bootstrap.

Since:

6.1

connection

public RedisChannelHandler<?,?> connection()

bootstrap

public Bootstrap bootstrap()

clientOptions

public ClientOptions clientOptions()

clientResources

public ClientResources clientResources()

endpoint

public Endpoint endpoint()

getRedisURI

public RedisURI getRedisURI()