2021-11-08 17:08:19 -07:00
|
|
|
defmodule Farside do
|
|
|
|
@service_prefix Application.fetch_env!(:farside, :service_prefix)
|
|
|
|
|
|
|
|
def get_services_map do
|
2021-11-10 10:47:04 -07:00
|
|
|
{:ok, service_list} = Redix.command(:redix, ["KEYS", "#{@service_prefix}*"])
|
2021-11-08 17:08:19 -07:00
|
|
|
|
|
|
|
# Match service name to list of available instances
|
|
|
|
Enum.reduce(service_list, %{}, fn service, acc ->
|
|
|
|
{:ok, instance_list} =
|
|
|
|
Redix.command(
|
|
|
|
:redix,
|
|
|
|
["LRANGE", service, "0", "-1"]
|
|
|
|
)
|
|
|
|
|
|
|
|
Map.put(
|
|
|
|
acc,
|
|
|
|
String.replace_prefix(
|
|
|
|
service,
|
|
|
|
@service_prefix,
|
|
|
|
""
|
|
|
|
),
|
|
|
|
instance_list
|
|
|
|
)
|
|
|
|
end)
|
|
|
|
end
|
|
|
|
|
|
|
|
def get_last_updated do
|
|
|
|
{:ok, last_updated} =
|
|
|
|
Redix.command(
|
|
|
|
:redix,
|
|
|
|
["GET", "last_updated"]
|
|
|
|
)
|
|
|
|
|
|
|
|
last_updated
|
|
|
|
end
|
|
|
|
end
|