mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2025-03-05 20:59:13 -08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

serverset: extract shard number from serverset data

Browse source
This commit is contained in:
Daniel Lundin 2015-08-26 16:53:37 +02:00 committed by Fabian Reinartz
parent 47ef1e2fdb
commit 103aca942d
1 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
retrieval/discovery/serverset.go
View file

@ -17,6 +17,7 @@ import (
"bytes" "bytes"
"encoding/json" "encoding/json"
"fmt" "fmt"
"strconv"
"strings" "strings"
"sync" "sync"
"time" "time"
@ -36,12 +37,14 @@ const (
serversetStatusLabel = serversetLabelPrefix + "status" serversetStatusLabel = serversetLabelPrefix + "status"
serversetPathLabel = serversetLabelPrefix + "path" serversetPathLabel = serversetLabelPrefix + "path"
serversetEndpointLabelPrefix = serversetLabelPrefix + "endpoint" serversetEndpointLabelPrefix = serversetLabelPrefix + "endpoint"
serversetShardLabel = serversetLabelPrefix + "shard"
) )
type serversetMember struct { type serversetMember struct {
ServiceEndpoint serversetEndpoint ServiceEndpoint serversetEndpoint
AdditionalEndpoints map[string]serversetEndpoint AdditionalEndpoints map[string]serversetEndpoint
Status string `json:"status"` Status string `json:"status"`
Shard int `json:"shard"`
} }
type serversetEndpoint struct { type serversetEndpoint struct {
@ -168,6 +171,7 @@ func parseServersetMember(data []byte, path string) (*model.LabelSet, error) {
} }
labels[serversetStatusLabel] = model.LabelValue(member.Status) labels[serversetStatusLabel] = model.LabelValue(member.Status)
labels[serversetShardLabel] = model.LabelValue(strconv.Itoa(member.Shard))
return &labels, nil return &labels, nil
} }