Add google-pubsub input type to Filebeat

CHANGELOG.next.asciidoc

@@ -220,6 +220,7 @@ https://github.com/elastic/beats/compare/v7.0.0-alpha2...master[Check the HEAD d
 - Update Kubernetes deployment manifest to use `container` input. {pull}12632[12632]
 - Use correct OS path separator in `add_kubernetes_metadata` to support Windows nodes. {pull}9205[9205]
 - Add support for client addresses with port in Apache error logs {pull}12695[12695]
+- Add `google-pubsub` input type for consuming messages from a Google Cloud Pub/Sub topic subscription. {pull}12746[12746]
 - Add module for ingesting Cisco IOS logs over syslog. {pull}12748[12748]
 
 *Heartbeat*

dev-tools/generate_notice.py

@@ -114,11 +114,15 @@ def has_license(folder):
 
     There are two cases accepted:
         * The folder contains a LICENSE
+        * The parent folder contains a LICENSE
         * The folder only contains subdirectories AND all these
           subdirectories contain a LICENSE
     """
+
     if len(get_licenses(folder)) > 0:
         return True, ""
+    elif len(get_licenses(os.path.join(folder, os.pardir))) > 0:  # For go.opencensus.io.
+        return True, ""
 
     for subdir in os.listdir(folder):
         if not os.path.isdir(os.path.join(folder, subdir)):

dev-tools/mage/integtest.go

@@ -189,6 +189,9 @@ func runInIntegTestEnv(mageTarget string, test func() error, passThroughEnvVars
 		// Disable strict.perms because we moust host dirs inside containers
 		// and the UID/GID won't meet the strict requirements.
 		"-e", "BEAT_STRICT_PERMS=false",
+		// compose.EnsureUp needs to know the environment type.
+		"-e", "STACK_ENVIRONMENT=" + StackEnvironment,
+		"-e", "TESTING_ENVIRONMENT=" + StackEnvironment,
 	}
 	args, err = addUidGidEnvArgs(args)
 	if err != nil {

filebeat/docs/filebeat-options.asciidoc

@@ -51,7 +51,7 @@ You can configure {beatname_uc} to use the following inputs:
 * <<{beatname_lc}-input-tcp>>
 * <<{beatname_lc}-input-syslog>>
 * <<{beatname_lc}-input-netflow>>
-
+* <<{beatname_lc}-input-google-pubsub>>
 
 
 include::inputs/input-log.asciidoc[]
@@ -71,3 +71,5 @@ include::inputs/input-tcp.asciidoc[]
 include::inputs/input-syslog.asciidoc[]
 
 include::../../x-pack/filebeat/docs/inputs/input-netflow.asciidoc[]
+
+include::../../x-pack/filebeat/docs/inputs/input-google-pubsub.asciidoc[]

libbeat/tests/compose/compose.go

@@ -54,7 +54,7 @@ func EnsureUpWithTimeout(t *testing.T, timeout int, services ...string) {
 	for _, service := range services {
 		err = compose.Start(service)
 		if err != nil {
-			t.Fatal(err)
+			t.Fatal("failed to start service", service, err)
 		}
 	}