redis

README

redis support

Documentation

Overview

Работа с redis

Index

• Constants
• type Config
  • func (x *Config) Check(cfg any) (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) (any, error)
  • func (r *Connection) QPopWithTimeout(timeout time.Duration, key ...string) (any, error)
  • func (r *Connection) QPush(key string, data any) error
  • func (r *Connection) QRead(key string) (any, 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"`       // Таймаут
	Failover      bool            `toml:"failover"`      // with sentinel
	MasterName    string          `toml:"masterName"`    // The master name
	SentinelAddrs []string        `toml:"sentinelAddrs"` // A seed list of host:port addresses of sentinel nodes
}

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

func (*Config) Check

func (x *Config) Check(cfg any) (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) (any, error)

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

func (*Connection) QPopWithTimeout

func (r *Connection) QPopWithTimeout(timeout time.Duration, key ...string) (any, error)

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

func (*Connection) QPush

func (r *Connection) QPush(key string, data any) error

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

func (*Connection) QRead

func (r *Connection) QRead(key string) (any, 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