upgrading to beats 7.5.0 (#64)

* upgrading to beats 7.5.0
* Upgrading for filebeat 7.5.0
* fix make and go version
* add inputs

.travis.yml

@@ -1,7 +1,7 @@
 language: go
 
 go:
-  - "1.11"
+  - "1.13"
 
 install:
   - curl https://raw.githubusercontent.com/golang/dep/master/install.sh | sh

Makefile

@@ -2,7 +2,7 @@ MAKE_VARIABLES := $(.VARIABLES)
 
 GO_VERSION=$(shell go version | cut -d ' ' -f 3 | sed -e 's/ /-/g' | sed -e 's/\//-/g' | sed -e 's/^go//g')
 GO_PLATFORM ?= $(shell go version | cut -d ' ' -f 4 | sed -e 's/ /-/g' | sed -e 's/\//-/g')
-BEATS_VERSION ?= "6.5.4"
+BEATS_VERSION ?= "7.5.0"
 BEATS_TAG ?= $(shell echo ${BEATS_VERSION} | sed 's/[^[:digit:]]*\([[:digit:]]*\(\.[[:digit:]]*\)\)/v\1/')
 AWSBEATS_VERSION ?= $(shell script/version)
 BEAT_NAME ?= filebeat

example/firehose/filebeat.yml

@@ -1,4 +1,4 @@
-filebeat.prospectors:
+filebeat.inputs:
 - type: log
 
   # Change to true to enable this prospector configuration.

firehose/client.go

@@ -27,9 +27,12 @@ func newClient(sess *session.Session, config *FirehoseConfig, observer outputs.O
 		firehose:           firehose.New(sess),
 		deliveryStreamName: config.DeliveryStreamName,
 		beatName:           beat.Beat,
-		encoder:            json.New(false, true, beat.Version),
-		timeout:            config.Timeout,
-		observer:           observer,
+		encoder: json.New(beat.Version, json.Config{
+			Pretty:     false,
+			EscapeHTML: false,
+		}),
+		timeout:  config.Timeout,
+		observer: observer,
 	}
 
 	return client, nil

firehose/firehose.go

@@ -14,6 +14,7 @@ var (
 )
 
 func New(
+	_ outputs.IndexManager,
 	beat beat.Info,
 	stats outputs.Observer,
 	cfg *common.Config,

streams/client.go

@@ -35,9 +35,12 @@ func newClient(sess *session.Session, config *StreamsConfig, observer outputs.Ob
 		streamName:           config.DeliveryStreamName,
 		partitionKeyProvider: partitionKeyProvider,
 		beatName:             beat.Beat,
-		encoder:              json.New(false, true, beat.Version),
-		timeout:              config.Timeout,
-		observer:             observer,
+		encoder: json.New(beat.Version, json.Config{
+			Pretty:     false,
+			EscapeHTML: false,
+		}),
+		timeout:  config.Timeout,
+		observer: observer,
 	}
 
 	return client, nil

streams/streams.go

@@ -14,6 +14,7 @@ var (
 )
 
 func New(
+	_ outputs.IndexManager,
 	beat beat.Info,
 	stats outputs.Observer,
 	cfg *common.Config,