Source file src/github.com/go-redis/redis/cluster_commands.go

Documentation: github.com/go-redis/redis

     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  }
    23  

View as plain text