mirror of https://github.com/prometheus/prometheus
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
98 lines
3.1 KiB
98 lines
3.1 KiB
// Copyright 2017 The Prometheus Authors |
|
// Licensed 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. |
|
|
|
package openstack |
|
|
|
import ( |
|
"context" |
|
"testing" |
|
|
|
"github.com/prometheus/common/model" |
|
"github.com/stretchr/testify/require" |
|
) |
|
|
|
type OpenstackSDHypervisorTestSuite struct { |
|
Mock *SDMock |
|
} |
|
|
|
func (s *OpenstackSDHypervisorTestSuite) SetupTest(t *testing.T) { |
|
s.Mock = NewSDMock(t) |
|
s.Mock.Setup() |
|
|
|
s.Mock.HandleHypervisorListSuccessfully() |
|
s.Mock.HandleVersionsSuccessfully() |
|
s.Mock.HandleAuthSuccessfully() |
|
} |
|
|
|
func (s *OpenstackSDHypervisorTestSuite) openstackAuthSuccess() (refresher, error) { |
|
conf := SDConfig{ |
|
IdentityEndpoint: s.Mock.Endpoint(), |
|
Password: "test", |
|
Username: "test", |
|
DomainName: "12345", |
|
Region: "RegionOne", |
|
Role: "hypervisor", |
|
} |
|
return newRefresher(&conf, nil) |
|
} |
|
|
|
func TestOpenstackSDHypervisorRefresh(t *testing.T) { |
|
mock := &OpenstackSDHypervisorTestSuite{} |
|
mock.SetupTest(t) |
|
|
|
hypervisor, _ := mock.openstackAuthSuccess() |
|
ctx := context.Background() |
|
tgs, err := hypervisor.refresh(ctx) |
|
require.Len(t, tgs, 1) |
|
tg := tgs[0] |
|
require.NoError(t, err) |
|
require.NotNil(t, tg) |
|
require.NotNil(t, tg.Targets) |
|
require.Len(t, tg.Targets, 2) |
|
|
|
for l, v := range map[string]string{ |
|
"__address__": "172.16.70.14:0", |
|
"__meta_openstack_hypervisor_hostname": "nc14.cloud.com", |
|
"__meta_openstack_hypervisor_type": "QEMU", |
|
"__meta_openstack_hypervisor_host_ip": "172.16.70.14", |
|
"__meta_openstack_hypervisor_state": "up", |
|
"__meta_openstack_hypervisor_status": "enabled", |
|
"__meta_openstack_hypervisor_id": "1", |
|
} { |
|
require.Equal(t, model.LabelValue(v), tg.Targets[0][model.LabelName(l)]) |
|
} |
|
|
|
for l, v := range map[string]string{ |
|
"__address__": "172.16.70.13:0", |
|
"__meta_openstack_hypervisor_hostname": "cc13.cloud.com", |
|
"__meta_openstack_hypervisor_type": "QEMU", |
|
"__meta_openstack_hypervisor_host_ip": "172.16.70.13", |
|
"__meta_openstack_hypervisor_state": "up", |
|
"__meta_openstack_hypervisor_status": "enabled", |
|
"__meta_openstack_hypervisor_id": "721", |
|
} { |
|
require.Equal(t, model.LabelValue(v), tg.Targets[1][model.LabelName(l)]) |
|
} |
|
} |
|
|
|
func TestOpenstackSDHypervisorRefreshWithDoneContext(t *testing.T) { |
|
mock := &OpenstackSDHypervisorTestSuite{} |
|
mock.SetupTest(t) |
|
|
|
hypervisor, _ := mock.openstackAuthSuccess() |
|
ctx, cancel := context.WithCancel(context.Background()) |
|
cancel() |
|
_, err := hypervisor.refresh(ctx) |
|
require.Error(t, err) |
|
require.Contains(t, err.Error(), context.Canceled.Error(), "%q doesn't contain %q", err, context.Canceled) |
|
}
|
|
|