MCPcopy
hub / github.com/redis/go-redis / readReply

Method readReply

probabilistic.go:1293–1337  ·  view source on GitHub ↗
(rd *proto.Reader)

Source from the content-addressed store, hash-verified

1291}
1292
1293func (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
1339func (cmd *TDigestInfoCmd) Clone() Cmder {
1340 return &TDigestInfoCmd{

Callers

nothing calls this directly

Calls 3

ReadMapLenMethod · 0.80
ReadStringMethod · 0.80
ReadIntMethod · 0.80

Tested by

no test coverage detected