diff --git a/etc/emq.conf b/etc/emq.conf index 0dac74c77..82209dde7 100644 --- a/etc/emq.conf +++ b/etc/emq.conf @@ -1,4 +1,3 @@ - ##=================================================================== ## EMQ Configuration R2.3 ##=================================================================== @@ -11,7 +10,7 @@ cluster.name = emqcl ## Cluster discovery strategy: manual | static | mcast | dns | etcd | k8s -cluster.discovery = mcast +cluster.discovery = manual ## Cluster Autoheal: on | off cluster.autoheal = on @@ -22,49 +21,49 @@ cluster.autoclean = 5m ##-------------------------------------------------------------------- ## Cluster with static node list -## cluster.static.seeds = ekka1@127.0.0.1,ekka2@127.0.0.1 +## cluster.static.seeds = emq1@127.0.0.1,emq2@127.0.0.1 ##-------------------------------------------------------------------- ## Cluster with multicast -cluster.mcast.addr = 239.192.0.1 +## cluster.mcast.addr = 239.192.0.1 -cluster.mcast.ports = 4369,4370 +## cluster.mcast.ports = 4369,4370 -cluster.mcast.iface = 0.0.0.0 +## cluster.mcast.iface = 0.0.0.0 -cluster.mcast.ttl = 255 +## cluster.mcast.ttl = 255 -cluster.mcast.loop = on +## cluster.mcast.loop = on ##-------------------------------------------------------------------- ## Cluster with DNS -cluster.dns.name = localhost +## cluster.dns.name = localhost -cluster.dns.app = emqx +## cluster.dns.app = emq ##-------------------------------------------------------------------- ## Cluster with Etcd -cluster.etcd.server = http://127.0.0.1:2379 +## cluster.etcd.server = http://127.0.0.1:2379 -cluster.etcd.prefix = emqcluster +## cluster.etcd.prefix = emqcl -cluster.etcd.node_ttl = 1m +## cluster.etcd.node_ttl = 1m ##-------------------------------------------------------------------- ## Cluster with k8s -cluster.k8s.apiserver = http://10.110.111.204:8080 +## cluster.k8s.apiserver = http://10.110.111.204:8080 -cluster.k8s.service_name = emq +## cluster.k8s.service_name = emq ## Address Type: ip | dns -cluster.k8s.address_type = ip +## cluster.k8s.address_type = ip ## The Erlang application name -cluster.k8s.app_name = emq +## cluster.k8s.app_name = emq ##-------------------------------------------------------------------- ## Node Args diff --git a/priv/emq.schema b/priv/emq.schema index 293ec67a4..f4c369b9c 100644 --- a/priv/emq.schema +++ b/priv/emq.schema @@ -7,7 +7,7 @@ %% @doc Cluster name {mapping, "cluster.name", "ekka.cluster_name", [ - {default, ekka}, + {default, emqcl}, {datatype, atom} ]}. @@ -29,14 +29,14 @@ ]}. %%-------------------------------------------------------------------- -%% Cluster with static node list +%% Cluster by static node list {mapping, "cluster.static.seeds", "ekka.cluster_discovery", [ {datatype, string} ]}. %%-------------------------------------------------------------------- -%% Cluster with IP Multicast +%% Cluster by UDP Multicast {mapping, "cluster.mcast.addr", "ekka.cluster_discovery", [ {default, "239.192.0.1"}, @@ -55,7 +55,7 @@ {mapping, "cluster.mcast.ttl", "ekka.cluster_discovery", [ {datatype, integer}, - {default, 1} + {default, 255} ]}. {mapping, "cluster.mcast.loop", "ekka.cluster_discovery", [ @@ -79,7 +79,8 @@ ]}. %%-------------------------------------------------------------------- -%% Cluster with DNS +%% Cluster by DNS A Record + {mapping, "cluster.dns.name", "ekka.cluster_discovery", [ {datatype, string} ]}. @@ -89,7 +90,7 @@ ]}. %%-------------------------------------------------------------------- -%% Cluster with etcd +%% Cluster using etcd {mapping, "cluster.etcd.server", "ekka.cluster_discovery", [ {datatype, string} @@ -105,7 +106,7 @@ ]}. %%-------------------------------------------------------------------- -%% Cluster with K8s +%% Cluster on K8s {mapping, "cluster.k8s.apiserver", "ekka.cluster_discovery", [ {datatype, string} @@ -145,7 +146,7 @@ {app, cuttlefish:conf_get("cluster.dns.app", Conf)}]; (etcd) -> [{server, string:tokens(cuttlefish:conf_get("cluster.etcd.server", Conf), ",")}, - {prefix, cuttlefish:conf_get("cluster.etcd.prefix", Conf, "emq")}, + {prefix, cuttlefish:conf_get("cluster.etcd.prefix", Conf, "emqcl")}, {node_ttl, cuttlefish:conf_get("cluster.etcd.node_ttl", Conf, 60)}]; (k8s) -> [{apiserver, cuttlefish:conf_get("cluster.k8s.apiserver", Conf)},