OffBroadwayRedis

v0.4.1

OffBroadwayRedis v0.4.1 OffBroadway.Redis.RedisClient behaviour View Source

A generic behaviour to implement Redis Clients for OffBroadway.Redis.Producer.

This module defines callbacks to normalize options and receive items from a Redis list.

Modules that implement this behaviour should be passed as the :redis_client option from OffBroadway.Redis.Producer.

Link to this section Summary

Types

messages()

Callbacks

init(opts)
receive_messages(demand, opts)

Link to this section Types

Link to this type

messages()

View Source 
messages() :: [Broadway.Message.t()]

Link to this section Callbacks

Link to this callback

init(opts)

View Source 
init(opts :: any()) ::
  {:ok, normalized_opts :: any()} | {:error, message :: binary()}
Link to this callback

receive_messages(demand, opts)

View Source 
receive_messages(demand :: pos_integer(), opts :: any()) :: messages()