numTokens determines the number of tokens owned by the specified address
(c kv.Client, name, ringKey string)
| 98 | // numTokens determines the number of tokens owned by the specified |
| 99 | // address |
| 100 | func numTokens(c kv.Client, name, ringKey string) int { |
| 101 | ringDesc, err := c.Get(context.Background(), ringKey) |
| 102 | |
| 103 | // The ringDesc may be null if the lifecycler hasn't stored the ring |
| 104 | // to the KVStore yet. |
| 105 | if ringDesc == nil || err != nil { |
| 106 | return 0 |
| 107 | } |
| 108 | rd := ringDesc.(*ring.Desc) |
| 109 | return len(rd.Ingesters[name].Tokens) |
| 110 | } |
no test coverage detected