From 103aca942d882ddfbc1ffad6c3ab1c77bddfe1a2 Mon Sep 17 00:00:00 2001 From: Daniel Lundin Date: Wed, 26 Aug 2015 16:53:37 +0200 Subject: [PATCH] serverset: extract shard number from serverset data --- retrieval/discovery/serverset.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/retrieval/discovery/serverset.go b/retrieval/discovery/serverset.go index c63d066a21..faf9b808f7 100644 --- a/retrieval/discovery/serverset.go +++ b/retrieval/discovery/serverset.go @@ -17,6 +17,7 @@ import ( "bytes" "encoding/json" "fmt" + "strconv" "strings" "sync" "time" @@ -36,12 +37,14 @@ const ( serversetStatusLabel = serversetLabelPrefix + "status" serversetPathLabel = serversetLabelPrefix + "path" serversetEndpointLabelPrefix = serversetLabelPrefix + "endpoint" + serversetShardLabel = serversetLabelPrefix + "shard" ) type serversetMember struct { ServiceEndpoint serversetEndpoint AdditionalEndpoints map[string]serversetEndpoint Status string `json:"status"` + Shard int `json:"shard"` } type serversetEndpoint struct { @@ -168,6 +171,7 @@ func parseServersetMember(data []byte, path string) (*model.LabelSet, error) { } labels[serversetStatusLabel] = model.LabelValue(member.Status) + labels[serversetShardLabel] = model.LabelValue(strconv.Itoa(member.Shard)) return &labels, nil }