Packages

Clustering strategy for connecting nodes running on Google App Engine.

Current section

3 Versions

Jump to

Compare versions

4 files changed
+8 additions
-8 deletions
  @@ -60,7 +60,7 @@ Update your release's `vm.args` file to include the following lines.
60 60
61 61 ```
62 62 ## Name of the node
63 - -sname <%= release_name %>@${GAE_INSTANCE}
63 + -name <%= release_name%>@${GAE_INSTANCE}.c.${GOOGLE_CLOUD_PROJECT}.internal
64 64
65 65 ## Limit distributed erlang ports to a single port
66 66 -kernel inet_dist_listen_min 9999
  @@ -16,4 +16,4 @@
16 16 {<<"optional">>,false},
17 17 {<<"repository">>,<<"hexpm">>},
18 18 {<<"requirement">>,<<"~> 3.0">>}]]}.
19 - {<<"version">>,<<"0.1.1">>}.
19 + {<<"version">>,<<"0.1.2">>}.
  @@ -40,7 +40,7 @@ defmodule Cluster.Strategy.GoogleAppEngine do
40 40
41 41 ```
42 42 ## Name of the node
43 - -sname <%= release_name %>@${GAE_INSTANCE}
43 + -name <%= release_name%>@${GAE_INSTANCE}.c.${GOOGLE_CLOUD_PROJECT}.internal
44 44
45 45 ## Limit distributed erlang ports to a single port
46 46 -kernel inet_dist_listen_min 9999
  @@ -113,15 +113,15 @@ defmodule Cluster.Strategy.GoogleAppEngine do
113 113 end
114 114
115 115 defp get_nodes(%State{}) do
116 - instances = get_running_instances()
116 + project_id = System.get_env("GOOGLE_CLOUD_PROJECT")
117 + instances = get_running_instances(project_id)
117 118
118 119 release_name = System.get_env("REL_NAME")
119 120
120 - Enum.map(instances, & :"#{release_name}@#{&1}")
121 + Enum.map(instances, & :"#{release_name}@#{&1}.c.#{project_id}.internal")
121 122 end
122 123
123 - defp get_running_instances do
124 - project_id = System.get_env("GOOGLE_CLOUD_PROJECT")
124 + defp get_running_instances(project_id) do
125 125 service_id = System.get_env("GAE_SERVICE")
126 126
127 127 versions = get_running_versions(project_id, service_id)
  @@ -5,7 +5,7 @@ defmodule LibclusterGae.MixProject do
5 5 [
6 6 app: :libcluster_gae,
7 7 description: "",
8 - version: "0.1.1",
8 + version: "0.1.2",
9 9 elixir: "~> 1.7",
10 10 start_permanent: Mix.env() == :prod,
11 11 deps: deps(),