RedisCluster.Monitor.Message (redis_cluster v0.8.0)

View Source

A module for parsing Redis monitor messages.

Summary

Functions

Parses a Redis monitor message and returns a RedisCluster.Monitor.Message struct.

Types

t()

@type t() :: %RedisCluster.Monitor.Message{
  command: String.t(),
  host: String.t(),
  port: integer(),
  timestamp: float()
}

Functions

parse(message, host, port)

@spec parse(message :: String.t(), host :: String.t(), port :: integer()) :: t() | nil

Parses a Redis monitor message and returns a RedisCluster.Monitor.Message struct.

Example message format:

+1753982630.550143 [0 127.0.0.1:53194] "GET" "key"
iex> RedisCluster.Monitor.Message.parse(~s(+1753982630.550143 [0 127.0.0.1:53194] "GET" "key"), "127.0.0.1", 6379)
%RedisCluster.Monitor.Message{
  timestamp: 1753982630.550143,
  command: ~s("GET" "key"),
  host: "127.0.0.1",
  port: 6379
}