Support Elasticsearch Basic Auth

README.md

@@ -171,6 +171,10 @@ First, set the IP address and port where the agent can find the Elasticsearch in
     # Set the host and port where to find Elasticsearch.
     host = "192.168.1.42"
     port = 9200
+
+    # Optional basic auth credentials
+    # username = "admin"
+    # password = "s3cr3t"
 ```
 
 Select the network interface from which to capture the traffic. Packetbeat supports capturing all messages sent or received by the server on which it is installed. For this, use "any" as the device: 

packetbeat.conf

@@ -13,6 +13,10 @@
 host = "localhost"
 port = 9200
 
+# Optional basic auth credentials
+# username = "admin"
+# password = "s3cr3t"
+
 [interfaces]
 # Select on which network interfaces to sniff. You can use the "any"
 # keyword to sniff on all connected interfaces.

publish.go

@@ -27,8 +27,10 @@ type tomlAgent struct {
     Refresh_topology_freq int
 }
 type tomlMothership struct {
-    Host string
-    Port int
+    Host     string
+    Port     int
+    Username string
+    Password string
 }
 
 type Event struct {
@@ -264,6 +266,8 @@ func (publisher *PublisherType) Init() error {
     // Set the Elasticsearch Host to Connect to
     api.Domain = _Config.Elasticsearch.Host
     api.Port = fmt.Sprintf("%d", _Config.Elasticsearch.Port)
+    api.Username = _Config.Elasticsearch.Username
+    api.Password = _Config.Elasticsearch.Password
 
     INFO("Use %s:%s as publisher", api.Domain, api.Port)