src/dma/vendor/github.com/go-redis/redis/cluster_commands.go

   1 package redis
   2
   3 import "sync/atomic"
   4
   5 func (c *ClusterClient) DBSize() *IntCmd {
   6         cmd := NewIntCmd("dbsize")
   7         var size int64
   8         err := c.ForEachMaster(func(master *Client) error {
   9                 n, err := master.DBSize().Result()
  10                 if err != nil {
  11                         return err
  12                 }
  13                 atomic.AddInt64(&size, n)
  14                 return nil
  15         })
  16         if err != nil {
  17                 cmd.setErr(err)
  18                 return cmd
  19         }
  20         cmd.val = size
  21         return cmd
  22 }