redis

Documentation

Index

• type Notify
• type Observer
  • func NewObserver(addr, pass string) (*Observer, error)
  • func (o *Observer) Subscribe(db int, pattern string, interval time.Duration, notify Notify) map[string]string
  • func (o *Observer) Unsubscribe(db int, pattern string)

Types

type Notify

type Notify func(k, v string)

type Observer

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

func NewObserver

func NewObserver(addr, pass string) (*Observer, error)

func (*Observer) Subscribe

func (o *Observer) Subscribe(db int, pattern string, interval time.Duration, notify Notify) map[string]string

Подписывается на изменение строкового ключа в редисе db: номер базы редиса pattern: ключ в редисе interval: интервал проверок значения notify: функция обратного вызова при изменении ключа

func (*Observer) Unsubscribe

func (o *Observer) Unsubscribe(db int, pattern string)