class

Echo::Redis(Message)

Inherits Reference / Object

The Stream is a new data type introduced with Redis 5.0, which models a log data structure in a more abstract way, however the essence of the log is still intact: like a log file, often implemented as a file open in append only mode, Redis streams are primarily an append only data structure. At least conceptually, because being Redis Streams an abstract data type represented in memory, they implement more powerful operations, to overcome the limits of the log file itself.

Constants

ERROR_PARSING_XREAD = "Error parsing XREAD"
FROM = (Time.utc.to_unix_ms - 1).to_s
ID = "*"
MESSAGE_KEY = "payload"
REGUALR_EXP = /\d{13}-\d{1}/
TIMEOUT = "0"

Instance methods

publish(message : Message)
Source
subscribe(consumer : Consumer)
Source

Nested types