(rd *proto.Reader)
| 1291 | } |
| 1292 | |
| 1293 | func (cmd *TDigestInfoCmd) readReply(rd *proto.Reader) (err error) { |
| 1294 | n, err := rd.ReadMapLen() |
| 1295 | if err != nil { |
| 1296 | return err |
| 1297 | } |
| 1298 | |
| 1299 | var key string |
| 1300 | var result TDigestInfo |
| 1301 | for f := 0; f < n; f++ { |
| 1302 | key, err = rd.ReadString() |
| 1303 | if err != nil { |
| 1304 | return err |
| 1305 | } |
| 1306 | |
| 1307 | switch key { |
| 1308 | case "Compression": |
| 1309 | result.Compression, err = rd.ReadInt() |
| 1310 | case "Capacity": |
| 1311 | result.Capacity, err = rd.ReadInt() |
| 1312 | case "Merged nodes": |
| 1313 | result.MergedNodes, err = rd.ReadInt() |
| 1314 | case "Unmerged nodes": |
| 1315 | result.UnmergedNodes, err = rd.ReadInt() |
| 1316 | case "Merged weight": |
| 1317 | result.MergedWeight, err = rd.ReadInt() |
| 1318 | case "Unmerged weight": |
| 1319 | result.UnmergedWeight, err = rd.ReadInt() |
| 1320 | case "Observations": |
| 1321 | result.Observations, err = rd.ReadInt() |
| 1322 | case "Total compressions": |
| 1323 | result.TotalCompressions, err = rd.ReadInt() |
| 1324 | case "Memory usage": |
| 1325 | result.MemoryUsage, err = rd.ReadInt() |
| 1326 | default: |
| 1327 | return fmt.Errorf("redis: tdigest.info unexpected key %s", key) |
| 1328 | } |
| 1329 | |
| 1330 | if err != nil { |
| 1331 | return err |
| 1332 | } |
| 1333 | } |
| 1334 | |
| 1335 | cmd.val = result |
| 1336 | return nil |
| 1337 | } |
| 1338 | |
| 1339 | func (cmd *TDigestInfoCmd) Clone() Cmder { |
| 1340 | return &TDigestInfoCmd{ |
nothing calls this directly
no test coverage detected