wip

Signed-off-by: Davide Briani <davide.briani@secomind.com>

Author: davidebriani

.env

@@ -19,3 +19,4 @@ VERNEMQ_ENABLE_SSL_LISTENER=true
 
 CLUSTERING_STRATEGY=docker-compose
 RELEASE_COOKIE=astarte-docker-compose
+# DOCKER_VERNEMQ_DISTRIBUTED_COOKIE=vmq

apps/astarte_appengine_api/config/config.exs

@@ -59,6 +59,11 @@ config :astarte_appengine_api, swagger_ui: true
 
 config :astarte_appengine_api, :max_results_limit, 10000
 
+# Nodes will only connect to each other if they were explicitly connected once before
+config :kernel,
+  # dist_auto_connect: :never,
+  prevent_overlapping_partitions: false
+
 # Import environment specific config. This must remain at the bottom
 # of this file so it overrides the configuration defined above.
 import_config "#{config_env()}.exs"

apps/astarte_appengine_api/lib/astarte_appengine_api/config.ex

@@ -289,11 +289,25 @@ defmodule Astarte.AppEngine.API.Config do
               query: "astarte-data-updater-plant",
               node_basename: "astarte_data_updater_plant"
             ]
+          ],
+          vernemq: [
+            strategy: Elixir.Cluster.Strategy.DNSPoll,
+            connect: {__MODULE__, :cluster_vernemq_connect, []},
+            config: [
+              polling_interval: 5_000,
+              query: "vernemq",
+              node_basename: "VerneMQ"
+            ]
           ]
         ]
     end
   end
 
+  def cluster_vernemq_connect(node_name) do
+    Node.set_cookie(node_name, :vmq)
+    Node.connect(node_name)
+  end
+
   @doc """
   Returns cassandra nodes formatted in the Xandra format
   """

apps/astarte_appengine_api/rel/env.sh.eex

@@ -4,8 +4,8 @@ export RELEASE_DISTRIBUTION=name
 
 if [ -z "$MY_POD_IP" ]
 then
-    HOSTNAME=`hostname -i`
-    export RELEASE_NODE="<%= @release.name %>@$HOSTNAME"
+    HOSTNAME=$(hostname -i)
+    export RELEASE_NODE=<%= @release.name %>@${HOSTNAME}
 else
-    export RELEASE_NODE="<%= @release.name %>@$MY_POD_IP"
+    export RELEASE_NODE=<%= @release.name %>@${MY_POD_IP}
 fi

apps/astarte_data_updater_plant/config/config.exs

@@ -23,4 +23,9 @@ config :astarte_data_updater_plant, ecto_repos: [Astarte.DataUpdaterPlant.Repo]
 
 config :astarte_data_updater_plant, Astarte.DataUpdaterPlant.Repo, []
 
+# Nodes will only connect to each other if they were explicitly connected once before
+config :kernel,
+  # dist_auto_connect: :never,
+  prevent_overlapping_partitions: false
+
 import_config "#{config_env()}.exs"

docker-compose.yml

@@ -245,7 +245,9 @@ services:
 
   # VerneMQ
   vernemq:
-    image: astarte/vernemq:1.2.0
+    image: astarte/vernemq:cluster
+    deploy:
+      replicas: 2
     env_file:
       - ./.env
     environment: