Skip to content

Commit

Permalink
Adding integration test for kibana Metricbeat module, xpack code path (
Browse files Browse the repository at this point in the history
…#15965)

* Adding integration test for kibana MB module, xpack code path

* Fixing imports formatting

* Adding missing import

* Replace assert.* with require.*
  • Loading branch information
ycombinator authored Feb 13, 2020
1 parent 833fc29 commit 4795676
Showing 1 changed file with 65 additions and 0 deletions.
65 changes: 65 additions & 0 deletions metricbeat/module/kibana/kibana_integration_test.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,65 @@
// Licensed to Elasticsearch B.V. under one or more contributor
// license agreements. See the NOTICE file distributed with
// this work for additional information regarding copyright
// ownership. Elasticsearch B.V. licenses this file to you under
// the Apache License, Version 2.0 (the "License"); you may
// not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.

// +build integration

package kibana_test

import (
"testing"

"github.com/stretchr/testify/require"

"github.com/elastic/beats/libbeat/tests/compose"
mbtest "github.com/elastic/beats/metricbeat/mb/testing"
"github.com/elastic/beats/metricbeat/module/kibana"
_ "github.com/elastic/beats/metricbeat/module/kibana/stats"
)

var xpackMetricSets = []string{
"stats",
}

func TestXPackEnabled(t *testing.T) {
service := compose.EnsureUpWithTimeout(t, 300, "kibana")

metricSetToTypeMap := map[string]string{
"stats": "kibana_stats",
}

config := getXPackConfig(service.Host())

metricSets := mbtest.NewReportingMetricSetV2Errors(t, config)
for _, metricSet := range metricSets {
events, errs := mbtest.ReportingFetchV2Error(metricSet)
require.Empty(t, errs)
require.NotEmpty(t, events)

event := events[0]
require.Equal(t, metricSetToTypeMap[metricSet.Name()], event.RootFields["type"])
require.Regexp(t, `^.monitoring-kibana-\d-mb`, event.Index)
}
}

func getXPackConfig(host string) map[string]interface{} {
return map[string]interface{}{
"module": kibana.ModuleName,
"metricsets": xpackMetricSets,
"hosts": []string{host},
"xpack.enabled": true,
}
}

0 comments on commit 4795676

Please sign in to comment.