redis

Documentation

Index

• Variables
• type Client
  • func NewClient(addr string, auth string, timeout time.Duration) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) Do(cmd string, args ...interface{}) (interface{}, error)
  • func (c *Client) Flush(cmd string, args ...interface{}) error
  • func (c *Client) Info() (map[string]string, error)
  • func (c *Client) InfoFull() (map[string]string, error)
  • func (c *Client) MigrateSlot(slot int, target string) (int, error)
  • func (c *Client) Receive() (interface{}, error)
  • func (c *Client) Role() (string, error)
  • func (c *Client) SetMaster(master string) error
  • func (c *Client) SlotsInfo() (map[int]int, error)
• type Pool
  • func NewPool(auth string, timeout time.Duration) *Pool
  • func (p *Pool) Cleanup() error
  • func (p *Pool) Close() error
  • func (p *Pool) GetClient(addr string) (*Client, error)
  • func (p *Pool) InfoFull(addr string) (map[string]string, error)
  • func (p *Pool) MigrateSlot(slot int, from, dest string) (int, error)
  • func (p *Pool) PutClient(c *Client)
• type Sentinel
  • func NewSentinel(product string) *Sentinel
  • func NewSentinelAuth(product, auth string) *Sentinel
  • func (s *Sentinel) FlushConfig(sentinel string) error
  • func (s *Sentinel) IsCancelled() bool
  • func (s *Sentinel) Masters(groups map[int]bool, timeout time.Duration, sentinels ...string) map[int]string
  • func (s *Sentinel) Monitor(masters map[int]string, quorum int, timeout time.Duration, sentinels ...string) error
  • func (s *Sentinel) Subscribe(timeout time.Duration, sentinels ...string) bool
  • func (s *Sentinel) Unmonitor(groups map[int]bool, timeout time.Duration, sentinels ...string) error
  • func (s *Sentinel) WatchNode(gid int) string

Variables

var ErrClosedPool = errors.New("use of closed redis pool")

Types

type Client

type Client struct {
	LastUse time.Time
	Timeout time.Duration
	// contains filtered or unexported fields
}

func NewClient

func NewClient(addr string, auth string, timeout time.Duration) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) Do

func (c *Client) Do(cmd string, args ...interface{}) (interface{}, error)

func (*Client) Flush

func (c *Client) Flush(cmd string, args ...interface{}) error

func (*Client) Info

func (c *Client) Info() (map[string]string, error)

func (*Client) InfoFull

func (c *Client) InfoFull() (map[string]string, error)

func (*Client) MigrateSlot

func (c *Client) MigrateSlot(slot int, target string) (int, error)

func (*Client) Receive

func (c *Client) Receive() (interface{}, error)

func (*Client) Role

func (c *Client) Role() (string, error)

func (*Client) SetMaster

func (c *Client) SetMaster(master string) error

func (*Client) SlotsInfo

func (c *Client) SlotsInfo() (map[int]int, error)

type Pool

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

func NewPool

func NewPool(auth string, timeout time.Duration) *Pool

func (*Pool) Cleanup

func (p *Pool) Cleanup() error

func (*Pool) Close

func (p *Pool) Close() error

func (*Pool) GetClient

func (p *Pool) GetClient(addr string) (*Client, error)

func (*Pool) InfoFull

func (p *Pool) InfoFull(addr string) (map[string]string, error)

func (*Pool) MigrateSlot

func (p *Pool) MigrateSlot(slot int, from, dest string) (int, error)

func (*Pool) PutClient

func (p *Pool) PutClient(c *Client)

type Sentinel

type Sentinel struct {
	context.Context
	Cancel context.CancelFunc
	// contains filtered or unexported fields
}

func NewSentinel

func NewSentinel(product string) *Sentinel

func NewSentinelAuth

func NewSentinelAuth(product, auth string) *Sentinel

func (*Sentinel) FlushConfig

func (s *Sentinel) FlushConfig(sentinel string) error

func (*Sentinel) IsCancelled

func (s *Sentinel) IsCancelled() bool

func (*Sentinel) Masters

func (s *Sentinel) Masters(groups map[int]bool, timeout time.Duration, sentinels ...string) map[int]string

func (*Sentinel) Monitor

func (s *Sentinel) Monitor(masters map[int]string, quorum int, timeout time.Duration, sentinels ...string) error

func (*Sentinel) Subscribe

func (s *Sentinel) Subscribe(timeout time.Duration, sentinels ...string) bool

func (*Sentinel) Unmonitor

func (s *Sentinel) Unmonitor(groups map[int]bool, timeout time.Duration, sentinels ...string) error

func (*Sentinel) WatchNode

func (s *Sentinel) WatchNode(gid int) string