Packages
exq
0.8.5
0.23.0
0.22.0
0.21.0
0.20.0
0.19.0
0.18.0
0.17.0
0.16.2
0.16.1
0.16.0
0.15.0
0.14.0
0.13.5
0.13.4
0.13.3
0.13.2
0.13.1
0.13.0
0.12.2
0.12.1
0.12.0
0.11.0
0.10.1
0.10.0
0.9.1
0.9.0
0.8.7
0.8.6
0.8.5
0.8.4
0.8.3
0.8.2
0.8.1
0.8.0
0.7.3
0.7.2
0.7.1
0.7.0
0.6.5
0.6.4
0.6.3
0.6.2
0.6.1
0.6.0
0.5.0
0.4.4
0.4.3
0.4.2
0.4.1
0.4.0
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.2
Exq is a job processing library compatible with Resque / Sidekiq for the Elixir language.
Current section
Files
Jump to
Current section
Files
test/config_test.exs
defmodule Exq.ConfigTest do
use ExUnit.Case
require Mix.Config
setup_all do
ExqTestUtil.reset_config
:ok
end
setup do
on_exit fn -> ExqTestUtil.reset_config end
end
test "Mix.Config should change the host." do
assert Exq.Support.Config.get(:host) != "127.1.1.1"
Mix.Config.persist([exq: [host: "127.1.1.1"]])
assert Exq.Support.Config.get(:host) == "127.1.1.1"
end
test "redis_opts" do
Mix.Config.persist([exq: [host: '127.0.0.1', port: 6379, password: '', database: 0, reconnect_on_sleep: 100, redis_timeout: 5000]])
{[host: host, port: port, database: database, password: password],
[backoff: reconnect_on_sleep, timeout: timeout, name: client_name]}
= Exq.Support.Opts.redis_opts
assert host == '127.0.0.1'
assert port == 6379
assert password == ''
assert database == 0
assert reconnect_on_sleep == 100
assert timeout == 5000
assert client_name == nil
Mix.Config.persist([exq: [host: '127.1.1.1', password: 'password']])
{redis_opts, _} = Exq.Support.Opts.redis_opts
assert redis_opts[:host] == '127.1.1.1'
assert redis_opts[:password] == 'password'
Mix.Config.persist([exq: [password: "binary_password"]])
{redis_opts, _} = Exq.Support.Opts.redis_opts
assert redis_opts[:password] == "binary_password"
Mix.Config.persist([exq: [password: nil]])
{redis_opts, _} = Exq.Support.Opts.redis_opts
assert redis_opts[:password] == nil
Mix.Config.persist([exq: [url: "redis_url"]])
{redis_opts, _} = Exq.Support.Opts.redis_opts
assert redis_opts == "redis_url"
end
test "default conform_opts" do
Mix.Config.persist([
exq: [
queues: ["default"],
scheduler_enable: true,
namespace: "exq",
concurrency: 100,
scheduler_poll_timeout: 200,
poll_timeout: 100,
redis_timeout: 5000,
shutdown_timeout: 7000,
]
])
{_redis_opts, _connection_opts, server_opts} = Exq.Support.Opts.conform_opts([mode: :default])
[scheduler_enable: scheduler_enable, namespace: namespace, scheduler_poll_timeout: scheduler_poll_timeout,
workers_sup: workers_sup, poll_timeout: poll_timeout, enqueuer: enqueuer, metadata: metadata, stats: stats,
name: name, scheduler: scheduler, queues: queues, redis: redis, concurrency: concurrency, middleware: middleware,
default_middleware: default_middleware, mode: mode, shutdown_timeout: shutdown_timeout]
= server_opts
assert scheduler_enable == true
assert namespace == "exq"
assert scheduler_poll_timeout == 200
assert workers_sup == Exq.Worker.Sup
assert poll_timeout == 100
assert shutdown_timeout == 7000
assert enqueuer == Exq.Enqueuer
assert stats == Exq.Stats
assert name == nil
assert scheduler == Exq.Scheduler
assert metadata == Exq.Worker.Metadata
assert queues == ["default"]
assert redis == Exq.Redis.Client
assert concurrency == [{"default", 100, 0}]
assert middleware == Exq.Middleware.Server
assert default_middleware == [Exq.Middleware.Stats, Exq.Middleware.Job, Exq.Middleware.Manager]
assert mode == :default
Mix.Config.persist([exq: [queues: [{"default", 1000}, {"test1", 2000}]]])
{_redis_opts, _connection_opts, server_opts} = Exq.Support.Opts.conform_opts([mode: :default])
assert server_opts[:queues] == ["default", "test1"]
assert server_opts[:concurrency] == [{"default", 1000, 0}, {"test1", 2000, 0}]
end
test "api conform_opts" do
Mix.Config.persist([exq: []])
{_redis_opts, _connection_opts, server_opts} = Exq.Support.Opts.conform_opts([mode: :api])
[name: name, namespace: namespace, redis: redis, mode: mode] = server_opts
assert namespace == "test"
assert name == nil
assert redis == Exq.Redis.Client
assert mode == :api
end
end