Code Review
/
barometer.git
/ blob
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
history
|
raw
|
HEAD
[ansible][fedora] Update package name
[barometer.git]
/
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
}