Streams commands observed by Redis' MONITOR command.

Redis.Monitor owns a dedicated connection because a connection in monitor mode cannot be used for ordinary commands. Each record is parsed into a Redis.Monitor.Entry and sent to subscribers:

{:ok, monitor} = Redis.Monitor.start_link(port: 6379)
:ok = Redis.Monitor.subscribe(monitor)

receive do
  {:redis_monitor, %Redis.Monitor.Entry{} = entry} ->
    IO.inspect(entry)
end

A Redis URI can be passed instead of connection options:

Redis.Monitor.start_link("redis://:secret@localhost:6379/2")

Subscriber filters

Filters are applied independently for each subscriber:

Redis.Monitor.subscribe(monitor,
  commands: ["SET", "DEL"],
  database: 0,
  client: ~r/^127.0.0.1:/
)

Supported filters are:

• :commands - a command or list of commands, matched case-insensitively
• :database - a database number or list of database numbers
• :client - an exact client identifier or a regular expression

Connection options

The connection options mirror Redis.Connection where they apply: :host, :port, :password, :username, :database, :ssl, :ssl_opts, :socket, :client_name, :credential_provider, :timeout, :sync_connect, :backoff_initial, and :backoff_max.

MONITOR exposes live application traffic and has a measurable performance cost. It should be protected and used deliberately in production.