forked from mirror/redis
557a0f8403 | ||
---|---|---|
README.md | ||
commands.go | ||
pubsub.go | ||
redis.go | ||
redis_test.go | ||
request.go |
README.md
Readme
Redis client for Golang.
Usage
Example:
import "github.com/vmihailenco/redis"
connect := func() (io.ReadWriter, error) {
fmt.Println("Connecting...")
return net.Dial("tcp", "localhost:6379")
}
disconnect := func(conn io.ReadWriter) error {
fmt.Println("Disconnecting...")
conn.Close()
return nil
}
redisClient = redis.NewClient(connect, disconnect)
_, err := redisClient.Set("foo", "bar").Reply()
if err != nil {
panic(err)
}
value, err := redisClient.Get("foo").Reply()
if err != nil {
if err != redis.Nil {
panic(err)
}
}
Multi/Exec
Getting multiClient:
multiClient := redisClient.Multi()
Or:
multiClient = redis.NewMultiClient(connect, disconnect)
Working with multiClient::
futureGet1 := multiClient.Get("foo1")
futureGet2 := multiClient.Get("foo2")
_, err := multiClient.Exec()
if err != nil {
panic(err)
}
value1, err := futureGet1.Reply()
if err != nil {
if err != redis.Nil {
panic(err)
}
}
value2, err := futureGet2.Reply()
if err != nil {
if err != redis.Nil {
panic(err)
}
}
Or:
multiClient := redisClient.Multi()
multiClient.Get("foo1")
multiClient.Get("foo2")
reqs, err := multiClient.Exec()
if err != nil {
panic(err)
}
for req := range reqs {
value, err := req.Reply()
if err != nil {
if err != redis.Nil {
panic(err)
}
}
}
Pub/sub
Publish:
_, err := redisClient.Publish("mychannel", "hello").Reply()
if err != nil {
panic(err)
}
Subscribe:
pubsub := redisClient.PubSubClient()
// pubsub := redis.NewPubSubClient(connect, disconnect)
ch, err := pubsub.Subscribe("mychannel")
if err != nil {
panic(err)
}
go func() {
for msg := range ch {
if msg.Err != nil {
panic(err)
}
fmt.Println(msg.Message)
}
}
Thread safety
Client is thread safe. Internally sync.Mutex is used to synchronize writes and reads.