Versions in this module Expand all Collapse all v0 v0.5.1 Nov 23, 2018 Changes in this version + const CLUSTER + const FILE_UPDATE + const MIRROR_FILE_UPDATE + const MIRROR_UPDATE + const PUBSUB_RECONNECTED + var ErrAlreadyLocked = errors.New("lock already acquired") + var ErrInvalidLockName = errors.New("invalid lock name") + var ErrRedisUpgradeRequired = errors.New("unsupported Redis version") + var ErrUnreachable = errors.New("redis endpoint unreachable") + var ErrUnsupportedVersion = errors.New("unsupported database version, please upgrade mirrorbits") + func Publish(r redis.Conn, event pubsubEvent, message string) error + func RedisIsLoading(err error) bool + func SendPublish(r redis.Conn, event pubsubEvent, message string) error + type Lock struct + func (l *Lock) Held() bool + func (l *Lock) Release() + type NetReadyError struct + func NewNetTemporaryError() NetReadyError + func (n *NetReadyError) Temporary() bool + func (n *NetReadyError) Timeout() bool + type NotReadyError struct + func (e *NotReadyError) Close() error + func (e *NotReadyError) Do(commandName string, args ...interface{}) (reply interface{}, err error) + func (e *NotReadyError) Err() error + func (e *NotReadyError) Flush() error + func (e *NotReadyError) Receive() (reply interface{}, err error) + func (e *NotReadyError) Send(commandName string, args ...interface{}) error + type Pubsub struct + func NewPubsub(r *Redis) *Pubsub + func (p *Pubsub) Close() + func (p *Pubsub) SubscribeEvent(event pubsubEvent, channel chan string) + type Redis struct + Pubsub *Pubsub + func NewRedis() *Redis + func NewRedisCustomPool(pool redisPool) *Redis + func (r *Redis) AcquireLock(name string) (*Lock, error) + func (r *Redis) CheckVersion() error + func (r *Redis) Close() + func (r *Redis) Connect() (redis.Conn, error) + func (r *Redis) ConnectPubsub() + func (r *Redis) Failure() bool + func (r *Redis) Get() redis.Conn + func (r *Redis) GetDBFormatVersion() (int, error) + func (r *Redis) GetListOfMirrors() (map[int]string, error) + func (r *Redis) UnblockedGet() redis.Conn + func (r *Redis) Upgrade() error + func (r *Redis) UpgradeNeeded() (bool, error)
Go to main page