redis

README

redis support

Documentation

Overview

Работа с redis

Index

• Constants
• type Config
  • func (x *Config) Check(cfg interface{}) (err error)
• type Connection
  • func New(cfg *Config) *Connection
  • func (r *Connection) Close()
  • func (r *Connection) DeleteTable(key string) error
  • func (r *Connection) HDel(key string, list []string) error
  • func (r *Connection) HLen(key string) (int, error)
  • func (r *Connection) HLoad(key string) (misc.StringMap, error)
  • func (r *Connection) HLoadSelected(key string, list []string) (misc.StringMap, error)
  • func (r *Connection) HSave(key string, data []string) error
  • func (r *Connection) Ping() error
  • func (r *Connection) QLen(key string) (int, error)
  • func (r *Connection) QPop(key string) (interface{}, error)
  • func (r *Connection) QPopWithTimeout(timeout time.Duration, key ...string) (interface{}, error)
  • func (r *Connection) QPush(key string, data interface{}) error
  • func (r *Connection) QRead(key string) (interface{}, error)
  • func (r *Connection) ZRangeByScore(key string, min int64, max int64, offset int64, count int64) ([]string, error)
  • func (r *Connection) ZSave(key string, members ZMembers) error
  • func (r *Connection) ZScan(key string, match string, count int64) ([]string, error)
• type ZMembers

Constants

const (
	// Максимальное количество строк, сохраняемых за один раз (ограничение redis)
	MaxHSaveSize = 512*1024 - 1
)

Types

type Config

type Config struct {
	Host     string          `toml:"host"`     // Хост
	Password string          `toml:"password"` // Пароль
	DB       int             `toml:"db"`       // База (номер)
	Timeout  config.Duration `toml:"timeout"`  // Таймаут

}

Конфигурация

func (*Config) Check

func (x *Config) Check(cfg interface{}) (err error)

Проверка валидности Config

type Connection

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

Соединение

func New

func New(cfg *Config) *Connection

Создать соединение

func (*Connection) Close

func (r *Connection) Close()

Закрыть соединение

func (*Connection) DeleteTable

func (r *Connection) DeleteTable(key string) error

Удалить таблицу (ключ)

func (*Connection) HDel

func (r *Connection) HDel(key string, list []string) error

Удалить из hashtable данные по списку

func (*Connection) HLen

func (r *Connection) HLen(key string) (int, error)

Длина hashtable

func (*Connection) HLoad

func (r *Connection) HLoad(key string) (misc.StringMap, error)

Загрузить все данные из hashtable

func (*Connection) HLoadSelected

func (r *Connection) HLoadSelected(key string, list []string) (misc.StringMap, error)

Загрузить из hashtable данные по списку

func (*Connection) HSave

func (r *Connection) HSave(key string, data []string) error

Сохранить данные в hashtable

func (*Connection) Ping

func (r *Connection) Ping() error

Проверка соединения

func (*Connection) QLen

func (r *Connection) QLen(key string) (int, error)

Длина очереди (списка)

func (*Connection) QPop

func (r *Connection) QPop(key string) (interface{}, error)

Получить из начала очереди с удалением

func (*Connection) QPopWithTimeout

func (r *Connection) QPopWithTimeout(timeout time.Duration, key ...string) (interface{}, error)

Получить из очереди с таймаутом

func (*Connection) QPush

func (r *Connection) QPush(key string, data interface{}) error

Добавить в конец очереди BDRV-2440: Максимальный размер строки в data 536870912 (2**29, полгига)

func (*Connection) QRead

func (r *Connection) QRead(key string) (interface{}, error)

Получить из начала очереди без уделения

func (*Connection) ZRangeByScore

func (r *Connection) ZRangeByScore(key string, min int64, max int64, offset int64, count int64) ([]string, error)

Получить из сортированного списока по указанным параметрам

func (*Connection) ZSave

func (r *Connection) ZSave(key string, members ZMembers) error

Сохранить в сортированный список

func (*Connection) ZScan

func (r *Connection) ZScan(key string, match string, count int64) ([]string, error)

Получить из сортированного списока по шаблону

type ZMembers

type ZMembers []*redis.Z

zrange