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

Method readReply

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

Source from the content-addressed store, hash-verified

665}
666
667func (cmd *CFInfoCmd) readReply(rd *proto.Reader) (err error) {
668 n, err := rd.ReadMapLen()
669 if err != nil {
670 return err
671 }
672
673 var key string
674 var result CFInfo
675 for f := 0; f < n; f++ {
676 key, err = rd.ReadString()
677 if err != nil {
678 return err
679 }
680
681 switch key {
682 case "Size":
683 result.Size, err = rd.ReadInt()
684 case "Number of buckets":
685 result.NumBuckets, err = rd.ReadInt()
686 case "Number of filters":
687 result.NumFilters, err = rd.ReadInt()
688 case "Number of items inserted":
689 result.NumItemsInserted, err = rd.ReadInt()
690 case "Number of items deleted":
691 result.NumItemsDeleted, err = rd.ReadInt()
692 case "Bucket size":
693 result.BucketSize, err = rd.ReadInt()
694 case "Expansion rate":
695 result.ExpansionRate, err = rd.ReadInt()
696 case "Max iterations":
697 result.MaxIteration, err = rd.ReadInt()
698
699 default:
700 return fmt.Errorf("redis: CF.INFO unexpected key %s", key)
701 }
702
703 if err != nil {
704 return err
705 }
706 }
707
708 cmd.val = result
709 return nil
710}
711
712func (cmd *CFInfoCmd) Clone() Cmder {
713 return &CFInfoCmd{

Callers

nothing calls this directly

Calls 3

ReadMapLenMethod · 0.80
ReadStringMethod · 0.80
ReadIntMethod · 0.80

Tested by

no test coverage detected