Package net.carcdr.yhocuspocus.redis

Class LettuceRedisClient

java.lang.Object

net.carcdr.yhocuspocus.redis.LettuceRedisClient

All Implemented Interfaces:

AutoCloseable, RedisClient

public class LettuceRedisClient
extends Object
implements RedisClient

Redis client implementation using Lettuce.

Uses binary codec for values to support Y-CRDT state storage.

Constructor Summary

Constructors

Constructor	Description
LettuceRedisClient(io.lettuce.core.RedisClient lettuceClient)	Creates a new Lettuce-based Redis client from an existing Lettuce client.
LettuceRedisClient(io.lettuce.core.RedisURI uri)	Creates a new Lettuce-based Redis client.
LettuceRedisClient(String host, int port)	Creates a new Lettuce-based Redis client.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the client and releases resources.
CompletableFuture<Void>	delete(String key)	Deletes a key.
CompletableFuture<byte[]>	get(String key)	Gets a binary value by key.
boolean	isConnected()	Checks if the client is connected.
CompletableFuture<Void>	publish(String channel, byte[] message)	Publishes a message to a channel.
CompletableFuture<Void>	set(String key, byte[] value)	Sets a binary value by key.
CompletableFuture<Void>	subscribe(String channel, BiConsumer<String,byte[]> handler)	Subscribes to a channel.
CompletableFuture<Void>	unsubscribe(String channel)	Unsubscribes from a channel.

Methods inherited from class java.lang.Object

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

Constructor Details

LettuceRedisClient

public LettuceRedisClient(String host,
 int port)

Creates a new Lettuce-based Redis client.

Parameters:

host - Redis host

port - Redis port

LettuceRedisClient

public LettuceRedisClient(io.lettuce.core.RedisURI uri)

Creates a new Lettuce-based Redis client.

Parameters:

uri - Redis URI

LettuceRedisClient

public LettuceRedisClient(io.lettuce.core.RedisClient lettuceClient)

Creates a new Lettuce-based Redis client from an existing Lettuce client.

This constructor is useful for Spring integration where the client is already configured.

Parameters:

lettuceClient - the existing Lettuce client

Method Details

publish

public CompletableFuture<Void> publish(String channel,
 byte[] message)

Description copied from interface: RedisClient

Publishes a message to a channel.

Specified by:

publish in interface RedisClient

Parameters:

channel - the channel to publish to

message - the message bytes

Returns:

a future that completes when the message is sent

subscribe

public CompletableFuture<Void> subscribe(String channel,
 BiConsumer<String,byte[]> handler)

Description copied from interface: RedisClient

Subscribes to a channel.

Specified by:

subscribe in interface RedisClient

Parameters:

channel - the channel to subscribe to

handler - callback for received messages (channel, message)

Returns:

a future that completes when subscribed

unsubscribe

public CompletableFuture<Void> unsubscribe(String channel)

Description copied from interface: RedisClient

Unsubscribes from a channel.

Specified by:

unsubscribe in interface RedisClient

Parameters:

channel - the channel to unsubscribe from

Returns:

a future that completes when unsubscribed

get

public CompletableFuture<byte[]> get(String key)

Description copied from interface: RedisClient

Gets a binary value by key.

Specified by:

get in interface RedisClient

Parameters:

key - the key

Returns:

a future containing the value, or null if not found

set

public CompletableFuture<Void> set(String key,
 byte[] value)

Description copied from interface: RedisClient

Sets a binary value by key.

Specified by:

set in interface RedisClient

Parameters:

key - the key

value - the value

Returns:

a future that completes when set

delete

public CompletableFuture<Void> delete(String key)

Description copied from interface: RedisClient

Deletes a key.

Specified by:

delete in interface RedisClient

Parameters:

key - the key to delete

Returns:

a future that completes when deleted

isConnected

public boolean isConnected()

Description copied from interface: RedisClient

Checks if the client is connected.

Specified by:

isConnected in interface RedisClient

Returns:

true if connected

close

public void close()

Description copied from interface: RedisClient

Closes the client and releases resources.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface RedisClient