@spec blocking_connection(
  connection(),
  keyword()
) :: {:ok, pid()} | {:error, term()}

Creates a dedicated blocking connection for operations like BRPOPLPUSH or BZPOPMIN.

Returns a connection that can be used for blocking operations without affecting the main pool.

Returns a specification to start this module under a supervisor.

See Supervisor.

@spec close_blocking(connection(), pid()) :: :ok

Closes a blocking connection.

@spec command(connection(), command(), keyword()) :: {:ok, term()} | {:error, term()}

Executes a Redis command.

Examples

BullMQ.RedisConnection.command(:my_redis, ["SET", "key", "value"])
#=> {:ok, "OK"}

BullMQ.RedisConnection.command(:my_redis, ["GET", "key"])
#=> {:ok, "value"}

@spec command!(connection(), command(), keyword()) :: term()

Executes a Redis command, raising on error.

@spec disconnect_blocking(pid()) :: :ok

Disconnects a blocking connection for reconnection.

@spec eval(connection(), String.t(), [String.t()], [term()], keyword()) ::
  {:ok, term()} | {:error, term()}

Executes a Lua script.

Examples

BullMQ.RedisConnection.eval(:my_redis, "return KEYS[1]", ["mykey"], [])
#=> {:ok, "mykey"}

@spec evalsha(connection(), String.t(), String.t(), [String.t()], [term()], keyword()) ::
  {:ok, term()} | {:error, term()}

Executes a Lua script using EVALSHA (cached script). Falls back to EVAL if the script is not cached.

@spec get_redis_opts(connection()) :: keyword()

Gets the underlying redis options for creating new connections.

@spec pipeline(connection(), pipeline(), keyword()) ::
  {:ok, [term()]} | {:error, term()}

Executes a pipeline of Redis commands.

Examples

BullMQ.RedisConnection.pipeline(:my_redis, [
  ["SET", "key1", "value1"],
  ["SET", "key2", "value2"],
  ["GET", "key1"]
])
#=> {:ok, ["OK", "OK", "value1"]}

@spec pipeline!(connection(), pipeline(), keyword()) :: [term()]

Executes a pipeline, raising on error.

@spec start_link(keyword()) :: Supervisor.on_start()

Starts the Redis connection pool.

@spec transaction(connection(), pipeline(), keyword()) ::
  {:ok, [term()]} | {:error, term()}

Executes multiple commands in a Redis transaction (MULTI/EXEC).

All commands are executed atomically - either all succeed or none do. Returns {:ok, results} where results is a list of command results, or {:error, reason} if the transaction fails.

Examples

BullMQ.RedisConnection.transaction(:my_redis, [
  ["SET", "key1", "value1"],
  ["SET", "key2", "value2"],
  ["GET", "key1"]
])
#=> {:ok, ["OK", "OK", "value1"]}