0
0
Fork 0
mirror of https://github.com/go-gitea/gitea synced 2024-12-24 22:44:47 +01:00
gitea/vendor/github.com/go-redis/redis/v7/cluster_commands.go

23 lines
376 B
Go
Raw Normal View History

package redis
import "sync/atomic"
func (c *ClusterClient) DBSize() *IntCmd {
cmd := NewIntCmd("dbsize")
var size int64
err := c.ForEachMaster(func(master *Client) error {
n, err := master.DBSize().Result()
if err != nil {
return err
}
atomic.AddInt64(&size, n)
return nil
})
if err != nil {
cmd.SetErr(err)
return cmd
}
cmd.val = size
return cmd
}