util

func Scan ¶

func Scan(r *redis.Client, ch chan string, cmd, key, pattern string) error

Scan is a helper function for performing any of the redis *SCAN functions. It takes in a channel which keys returned by redis will be written to, and returns an error should any occur. The input channel will always be closed when Scan returns, and *must* be read until it is closed.

The key argument is only needed if cmd isn't SCAN

Example SCAN command

ch := make(chan string)
var err error
go func() {
	err = util.Scan(r, ch, "SCAN", "", "*")
}()
for key := range ch {
	// do something with key
}
if err != nil {
	// handle error
}

Example HSCAN command

ch := make(chan string)
var err error
go func() {
	err = util.Scan(r, ch, "HSCAN", "somekey", "*")
}()
for key := range ch {
	// do something with key
}
if err != nil {
	// handle error
}

func ScanCluster ¶

func ScanCluster(c *cluster.Cluster, ch chan string, pattern string) error

ScanCluster is like Scan except it operates over a whole cluster. Unlike Scan it only works with SCAN and as such only takes in a pattern string.