A supervisor is defined in my redis module but whenever I try to call RedisPool.start_link like this
{:ok, pid} = RedisPool.start_link([])
It shows me this error
** (EXIT from #PID<0.592.0>) shell process exited with reason: shutdown: failed to start child: :redix_poolboy
** (EXIT) already started: #PID<0.570.0>
How do I avoid this?
defmodule Gorm.RedisPool do
use Supervisor
@redis_connection_params host: Application.get_env(:gorm, :redis_host),
password: Application.get_env(:gorm, :redis_password),
port: Application.get_env(:gorm, :redis_port),
database: Application.get_env(:gorm, :redis_database)
def start_link(_args) do
Supervisor.start_link(__MODULE__, [])
end
#Fault Tolerance
# This is just ensuring that phoenix keeps the cache running.
def init([]) do
pool_opts = [
name: {:local, :redix_poolboy},
worker_module: Redix,
size: 10,
max_overflow: 5,
]
children = [
:poolboy.child_spec(:redix_poolboy, pool_opts, @redis_connection_params)
]
Supervisor.init(children, strategy: :one_for_one, name: __MODULE__)
end
def command(command) do
:poolboy.transaction(:redix_poolboy, &Redix.command(&1, command))
end
def pipeline(commands) do
:poolboy.transaction(:redix_poolboy, &Redix.pipeline(&1, commands))
end
def retrieve(key) do
case command(["GET", key]) do
{:ok, result} ->
result
_ ->
{:error, "Could not retreive #{key}"}
end
end
def insert(key, value) do
case command(["SET", key, value]) do
{:ok, result} ->
result
_ ->
{:error, "Error inserting #{key}: #{value}"}
end
end
end
