[Metricbeat] Update Ceph module to support new API

libbeat/tests/compose/project.go

@@ -45,6 +45,8 @@ type UpOptions struct {
 	// use to advertise itself to clients
 	SetupAdvertisedHostEnvFile     bool
 	SetupAdvertisedHostEnvFilePort int
+
+	Environment []string
 }
 
 // UpOption is a modifier for UpOptions
@@ -71,6 +73,11 @@ func UpWithAdvertisedHostEnvFileForPort(port int) UpOption {
 	}
 }
 
+// UpWithEnvironmentVariable adds environment variable.
+func UpWithEnvironmentVariable(keyValue string) UpOption {
+	return func(options *UpOptions) { options.Environment = append(options.Environment, keyValue) }
+}
+
 // Filter options for services
 type Filter struct {
 	State State

libbeat/tests/compose/wrapper.go

@@ -181,6 +181,12 @@ func (d *wrapperDriver) Up(ctx context.Context, opts UpOptions, service string)
 		args = append(args, "--force-recreate")
 	}
 
+	if len(opts.Environment) > 0 {
+		for _, keyValue := range opts.Environment {
+			d.Environment = append(d.Environment, keyValue)
+		}
+	}
+
 	if service != "" {
 		args = append(args, service)
 	}