RepoMirrors/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus synced 2024-12-26 00:23:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

storage/remote: check errors from ApplyConfig in tests

Browse Source 
So tests do not produce obscure errors when applying configuration
fails.

Signed-off-by: Mateusz Gozdek <mgozdekof@gmail.com>
This commit is contained in:
Mateusz Gozdek 2021-10-25 09:24:33 +02:00 committed by Julien Pivotto
parent 4ef8c7c1d8
commit 116552cc58
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
storage/remote/write_test.go
View File

@ -218,7 +218,7 @@ func TestWriteStorageLifecycle(t *testing.T) {
&config.DefaultRemoteWriteConfig,
},
}
s.ApplyConfig(conf)
require.NoError(t, s.ApplyConfig(conf))
require.Equal(t, 1, len(s.queues))
err = s.Close()
@ -243,14 +243,14 @@ func TestUpdateExternalLabels(t *testing.T) {
}
hash, err := toHash(conf.RemoteWriteConfigs[0])
require.NoError(t, err)
s.ApplyConfig(conf)
require.NoError(t, s.ApplyConfig(conf))
require.Equal(t, 1, len(s.queues))
require.Equal(t, labels.Labels(nil), s.queues[hash].externalLabels)
conf.GlobalConfig.ExternalLabels = externalLabels
hash, err = toHash(conf.RemoteWriteConfigs[0])
require.NoError(t, err)
s.ApplyConfig(conf)
require.NoError(t, s.ApplyConfig(conf))
require.Equal(t, 1, len(s.queues))
require.Equal(t, externalLabels, s.queues[hash].externalLabels)
@ -282,10 +282,10 @@ func TestWriteStorageApplyConfigsIdempotent(t *testing.T) {
hash, err := toHash(conf.RemoteWriteConfigs[0])
require.NoError(t, err)
s.ApplyConfig(conf)
require.NoError(t, s.ApplyConfig(conf))
require.Equal(t, 1, len(s.queues))
s.ApplyConfig(conf)
require.NoError(t, s.ApplyConfig(conf))
require.Equal(t, 1, len(s.queues))
_, hashExists := s.queues[hash]
require.True(t, hashExists, "Queue pointer should have remained the same")
@ -391,7 +391,7 @@ func TestWriteStorageApplyConfigsPartialUpdate(t *testing.T) {
GlobalConfig: config.GlobalConfig{},
RemoteWriteConfigs: []*config.RemoteWriteConfig{c1, c2},
}
s.ApplyConfig(conf)
require.NoError(t, s.ApplyConfig(conf))
require.Equal(t, 2, len(s.queues))
_, hashExists = s.queues[hashes[0]]