exredis v0.1.1 → Overview → Exredis → Sub

Exredis.Sub

Subscribe functions for exredis

Source

Summary
↑

psubscribe(client, channel, term)

Subscribe to a channel by pattern
start(host \\ '127.0.0.1', port \\ 6379, password \\ [], reconnect \\ :no_reconnect, max_queue \\ :infinity, behaviour \\ :drop)

Connect to the Redis server for subscribe to a channel
start_link(host \\ '127.0.0.1', port \\ 6379, password \\ [], reconnect \\ :no_reconnect, max_queue \\ :infinity, behaviour \\ :drop)

Connect to the Redis server for subscribe to a channel
stop(client)

Disconnect from the Redis server:
subscribe(client, channel, term)

Subscribe to a channel

Types ↑

reconnect :: :no_reconnect | integer

max_queue :: :infinity | integer

behaviour :: :drop | :exit

start_link :: {:ok, pid} | {:error, term}

Functions

psubscribe(client, channel, term)
(function) # ↑

Specs:

  • psubscribe(pid, binary, term) :: any

Subscribe to a channel by pattern

  • psubscribe(client, "some_channel_*", fn(msg) -> ... end)
Source
start(host \\ '127.0.0.1', port \\ 6379, password \\ [], reconnect \\ :no_reconnect, max_queue \\ :infinity, behaviour \\ :drop)
(function) # ↑

Specs:

Connect to the Redis server for subscribe to a channel

  • start
  • start('127.0.0.1', 6379)
  • start('127.0.0.1', 6379, 'with_password')
Source
start_link(host \\ '127.0.0.1', port \\ 6379, password \\ [], reconnect \\ :no_reconnect, max_queue \\ :infinity, behaviour \\ :drop)
(function) # ↑

Specs:

Connect to the Redis server for subscribe to a channel

  • start_link
  • start_link('127.0.0.1', 6379)
  • start_link('127.0.0.1', 6379, 'with_password')
Source
stop(client)
(function) # ↑

Specs:

  • stop(pid) :: :ok

Disconnect from the Redis server:

  • stop(client)

Client is a pid getting from start command

Source
subscribe(client, channel, term)
(function) # ↑

Specs:

  • subscribe(pid, binary, term) :: any

Subscribe to a channel

  • subscribe(client, "some_channel", fn(msg) -> ... end)
Source