Redis transport (kombu.transport.redis.Transport).
Manages Redix and Redix.PubSub connections (or custom backends for unit tests),
channel creation, health checks (PING), and event polling.
Summary
Functions
Builds Redix.start_link/1 options from Kombu connection options.
Closes a Kombu.Transport.Redis.Channel process.
Closes the Redis connection and stops owned Redix / Redix.PubSub processes.
Checks whether the Redis connection is viable by sending PING.
Creates a new Kombu.Transport.Redis.Channel process on connection (or directly from opts).
Establishes a Redis transport connection (starting Redix and Redix.PubSub processes,
or wrapping an injected :conn backend for unit testing).
Parses a virtual_host string ("/", "/0", "2", 2) into a Redis integer database index.
Functions
Builds Redix.start_link/1 options from Kombu connection options.
@spec close_channel(pid()) :: :ok
Closes a Kombu.Transport.Redis.Channel process.
@spec close_connection(map()) :: :ok
Closes the Redis connection and stops owned Redix / Redix.PubSub processes.
@spec connection_viable?(map() | Kombu.Transport.Redis.PrefixedClient.t()) :: boolean()
Checks whether the Redis connection is viable by sending PING.
Creates a new Kombu.Transport.Redis.Channel process on connection (or directly from opts).
Establishes a Redis transport connection (starting Redix and Redix.PubSub processes,
or wrapping an injected :conn backend for unit testing).
@spec parse_db_number(term()) :: non_neg_integer()
Parses a virtual_host string ("/", "/0", "2", 2) into a Redis integer database index.