class Echo::Redis(Message)

Overview

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.

Defined in:

echo/streams/redis.cr

Constant Summary

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 Method Summary

Instance Method Detail

def publish(message : Message) #

[View source]
def subscribe(consumer : Consumer) #

[View source]