goredis

README

goredis

Redis有单机、哨兵、集群3种部署方式。不同部署，使用的Redis库不一样，造成一定的不便。

因此，本库集成网络上一些比较流行的库，使之能够在3种部署方式下，使用统一的API。

本库只是简单的把redigo、go-sentinel、redisc做下集成。

这些库都是以redigo为基础，返回 redigo.pool 对象操纵数据库。

如何使用redigo.pool，请参考 https://github.com/garyburd/redigo

依赖的库

https://github.com/garyburd/redigo

https://github.com/FZambia/go-sentinel

https://github.com/mna/redisc

例子

package main

import (
	"fmt"

	"github.com/fananchong/goredis"
	"github.com/garyburd/redigo/redis"
)

func testUnknow() {

	fmt.Println("test cluster =========================================")
	{
		option := goredis.NewDefaultOption()
		addrs := []string{"192.168.1.4:39379", "192.168.1.4:39381", "192.168.1.4:39383"}
		db, err0 := goredis.NewClient("", addrs, option)
		if err0 != nil {
			fmt.Println(err0)
			return
		}
		_, err1 := db.Do("SET", "cc", "cc")
		if err1 != nil {
			fmt.Println(err1)
			return
		}
		cc, err2 := redis.String(db.Do("GET", "cc"))
		if err2 != nil {
			fmt.Println(err2)
			return
		}
		fmt.Println("cc =", cc)
	}

	fmt.Println("test sentinel =========================================")
	{
		option := goredis.NewDefaultOption()
		addrs := []string{"192.168.1.4:46379", "192.168.1.4:46380", "192.168.1.4:46381"}
		db, err0 := goredis.NewClient("mysentinel", addrs, option) //dbname: mysentinel
		if err0 != nil {
			fmt.Println(err0)
			return
		}
		_, err1 := db.Do("SET", "bb", "bb")
		if err1 != nil {
			fmt.Println(err1)
			return
		}
		bb, err2 := redis.String(db.Do("GET", "bb"))
		if err2 != nil {
			fmt.Println(err2)
			return
		}
		fmt.Println("bb =", bb)
	}

	fmt.Println("test standalone =========================================")
	{
		option := goredis.NewDefaultOption()
		addrs := []string{"192.168.1.4:16379"}
		db, err0 := goredis.NewClient("", addrs, option)
		if err0 != nil {
			fmt.Println(err0)
			return
		}
		_, err1 := db.Do("SET", "aa", "aa")
		if err1 != nil {
			fmt.Println(err1)
			return
		}
		aa, err2 := redis.String(db.Do("GET", "aa"))
		if err2 != nil {
			fmt.Println(err2)
			return
		}
		fmt.Println("aa =", aa)
	}
}

Documentation

Index

• type Client
  • func NewClient(dbName string, addrs []string, option *Option) (*Client, error)
  • func (this *Client) Do(commandName string, args ...interface{}) (reply interface{}, err error)
  • func (this *Client) Init(dbName string, addrs []string, option *Option) error
• type ClusterClient
  • func NewClusterClient(dbName string, addrs []string, option *Option) (*ClusterClient, error)
  • func (this *ClusterClient) Do(commandName string, args ...interface{}) (reply interface{}, err error)
  • func (this *ClusterClient) Init(dbName string, addrs []string, option *Option) error
• type IClient
• type Option
  • func NewDefaultOption() *Option
• type RedisType
• type SentinelClient
  • func NewSentinelClient(masterName string, addrs []string, option *Option) *SentinelClient
  • func (this *SentinelClient) Do(commandName string, args ...interface{}) (reply interface{}, err error)
  • func (this *SentinelClient) Init(masterName string, addrs []string, option *Option)
• type StandaloneClient
  • func NewStandaloneClient(dbName string, addr string, option *Option) *StandaloneClient
  • func (this *StandaloneClient) Do(commandName string, args ...interface{}) (reply interface{}, err error)
  • func (this *StandaloneClient) Init(dbName string, addr string, option *Option)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(dbName string, addrs []string, option *Option) (*Client, error)

func (*Client) Do

func (this *Client) Do(commandName string, args ...interface{}) (reply interface{}, err error)

func (*Client) Init

func (this *Client) Init(dbName string, addrs []string, option *Option) error

type ClusterClient

type ClusterClient struct {
	// contains filtered or unexported fields
}

func NewClusterClient

func NewClusterClient(dbName string, addrs []string, option *Option) (*ClusterClient, error)

func (*ClusterClient) Do

func (this *ClusterClient) Do(commandName string, args ...interface{}) (reply interface{}, err error)

func (*ClusterClient) Init

func (this *ClusterClient) Init(dbName string, addrs []string, option *Option) error

type IClient

type IClient interface {
	Do(commandName string, args ...interface{}) (reply interface{}, err error)
}

type Option

type Option struct {
	Type            RedisType
	Password        string
	DBIndex         int
	PoolMaxIdle     int
	PoolMaxActive   int
	PoolWait        bool
	PoolIdleTimeout time.Duration
}

func NewDefaultOption

func NewDefaultOption() *Option

type RedisType

type RedisType int

const (
	Unknow RedisType = iota
	Standalone
	Sentinel
	Cluster
)

type SentinelClient

type SentinelClient struct {
	// contains filtered or unexported fields
}

func NewSentinelClient

func NewSentinelClient(masterName string, addrs []string, option *Option) *SentinelClient

func (*SentinelClient) Do

func (this *SentinelClient) Do(commandName string, args ...interface{}) (reply interface{}, err error)

func (*SentinelClient) Init

func (this *SentinelClient) Init(masterName string, addrs []string, option *Option)

type StandaloneClient

type StandaloneClient struct {
	// contains filtered or unexported fields
}

func NewStandaloneClient

func NewStandaloneClient(dbName string, addr string, option *Option) *StandaloneClient

func (*StandaloneClient) Do

func (this *StandaloneClient) Do(commandName string, args ...interface{}) (reply interface{}, err error)

func (*StandaloneClient) Init

func (this *StandaloneClient) Init(dbName string, addr string, option *Option)