Packages

pixie

0.1.3
0.3.9 0.3.8 0.3.7 0.3.6 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.3 0.2.2 0.2.1 0.2.0 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0 0.0.3 0.0.2 0.0.1

Bayeux compatible server written in Elixir.

HexDocs

Current section

Files

Jump to
Readme
22 Versions
9 Dependencies
Dependants
Files
Activity
pixie lib pixie backends redis channel_subscriptions.ex
Raw

lib/pixie/backends/redis/channel_subscriptions.ex 

defmodule Pixie.Backend.Redis.ChannelSubscriptions do

  import Pixie.Backend.Redis.Connection



  def get channel_name do

    {:ok, client_ids} = query ["SMEMBERS", key(channel_name)]

    client_ids

  end



  def subscriber_count channel_name do

    {:ok, size} = query ["SCARD", key(channel_name)]

    String.to_integer size

  end



  def subscribe channel_name, client_id do

    {ok, _} = query ["SADD", key(channel_name), client_id]

    ok

  end



  def unsubscribe channel_name, client_id do

    {ok, _} = query ["SREM", key(channel_name), client_id]

    ok

  end



  defp key channel_name do

    cluster_namespace("channel_subscriptions:#{channel_name}")

  end

end