Support setting the Elasticsearch protocol

elastic · May 9, 2014 · 912a462 · 912a462
1 parent 58b4b9e
commit 912a462
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 1 deletion.
diff --git a/README.md b/README.md
@@ -172,6 +172,9 @@ First, set the IP address and port where the agent can find the Elasticsearch in
     host = "192.168.1.42"
     port = 9200
 
+    # Optional protocol
+    # protocol = "https"
+
     # Optional basic auth credentials
     # username = "admin"
     # password = "s3cr3t"

diff --git a/packetbeat.conf b/packetbeat.conf
@@ -13,6 +13,9 @@
 host = "localhost"
 port = 9200
 
+# Optional protocol
+# protocol = "https"
+
 # Optional basic auth credentials
 # username = "admin"
 # password = "s3cr3t"

diff --git a/publish.go b/publish.go
@@ -29,6 +29,7 @@ type tomlAgent struct {
 type tomlMothership struct {
     Host     string
     Port     int
+    Protocol string
     Username string
     Password string
 }
@@ -269,7 +270,11 @@ func (publisher *PublisherType) Init() error {
     api.Username = _Config.Elasticsearch.Username
     api.Password = _Config.Elasticsearch.Password
 
-    INFO("Use %s:%s as publisher", api.Domain, api.Port)
+    if _Config.Elasticsearch.Protocol != "" {
+        api.Protocol = _Config.Elasticsearch.Protocol
+    }
+
+    INFO("Use %s://%s:%s as publisher", api.Protocol, api.Domain, api.Port)
 
     publisher.name = _Config.Agent.Name
     if len(publisher.name) == 0 {