Change aerospike plugin server tag to aerospike_host
This is to avoid a conflict with the standard "host" tag that is used everywhere.
This commit is contained in:
parent
13ccf420d7
commit
67faeb5f84
|
@ -250,8 +250,8 @@ func get(key []byte, host string) (map[string]string, error) {
|
||||||
func readAerospikeStats(stats map[string]string, acc plugins.Accumulator, host, namespace string) {
|
func readAerospikeStats(stats map[string]string, acc plugins.Accumulator, host, namespace string) {
|
||||||
for key, value := range stats {
|
for key, value := range stats {
|
||||||
tags := map[string]string{
|
tags := map[string]string{
|
||||||
"host": host,
|
"aerospike_host": host,
|
||||||
"namespace": "_service",
|
"namespace": "_service",
|
||||||
}
|
}
|
||||||
|
|
||||||
if namespace != "" {
|
if namespace != "" {
|
||||||
|
|
|
@ -67,8 +67,8 @@ func TestReadAerospikeStatsNamespace(t *testing.T) {
|
||||||
readAerospikeStats(stats, &acc, "host1", "test")
|
readAerospikeStats(stats, &acc, "host1", "test")
|
||||||
|
|
||||||
tags := map[string]string{
|
tags := map[string]string{
|
||||||
"host": "host1",
|
"aerospike_host": "host1",
|
||||||
"namespace": "test",
|
"namespace": "test",
|
||||||
}
|
}
|
||||||
for k := range stats {
|
for k := range stats {
|
||||||
assert.True(t, acc.ValidateTaggedValue(k, int64(12345), tags) == nil)
|
assert.True(t, acc.ValidateTaggedValue(k, int64(12345), tags) == nil)
|
||||||
|
|
Loading…
Reference in New Issue