Merge pull request elastic#253 from monicasarbu/set_defaultscheme_http

Set default scheme to http

CHANGELOG.md

@@ -14,6 +14,7 @@ All notable changes to this project will be documented in this file based on the
 - Limit number of workers for Elasticsearch output. elastic/packetbeat#226
 - On Windows, remove service related error message when running in the console. #242
 - Fix waitRetry no configured in single output mode configuration. elastic/filebeat#144
+- Use http as the default scheme in the elasticsearch hosts #253
 
 ### Added
 - Add Console output plugin. #218

outputs/elasticsearch/url.go

@@ -10,6 +10,11 @@ import (
 // Creates the url based on the url configuration.
 // Adds missing parts with defaults (scheme, host, port)
 func getURL(defaultScheme string, defaultPath string, rawURL string) (string, error) {
+
+	if defaultScheme == "" {
+		defaultScheme = "http"
+	}
+
 	addr, err := url.Parse(rawURL)
 	if err != nil {
 		return "", err

outputs/elasticsearch/url_test.go

@@ -115,7 +115,7 @@ func TestGetUrl(t *testing.T) {
 	}
 
 	for input, output := range inputOutput {
-		urlNew, err := getURL("http", "", input)
+		urlNew, err := getURL("", "", input)
 		assert.Nil(t, err)
 		assert.Equal(t, output, urlNew, fmt.Sprintf("input: %v", input))
 	}