redis

Documentation

Index

• func Configure(cfg *config.RedisConfig, dialFunc func() (redis.Conn, error))
• func DefaultDialFunc(cfg *config.RedisConfig) func() (redis.Conn, error)
• func Get() redis.Conn
• func GetString(key string) (string, error)
• func Process(reconnect bool)
• type KeyChan
• type WatchKeyStatus
  • func WatchKey(key, value string, timeout time.Duration) (WatchKeyStatus, error)

Functions

func Configure

func Configure(cfg *config.RedisConfig, dialFunc func() (redis.Conn, error))

Configure redis-connection

func DefaultDialFunc

func DefaultDialFunc(cfg *config.RedisConfig) func() (redis.Conn, error)

DefaultDialFunc should always used. Only exception is for unit-tests.

func Get

func Get() redis.Conn

Get a connection for the Redis-pool

func GetString

func GetString(key string) (string, error)

GetString fetches the value of a key in Redis as a string

func Process

func Process(reconnect bool)

Process redis subscriptions

NOTE: There Can Only Be One! Reconnects is reconnect = true

Types

type KeyChan

type KeyChan struct {
	Key  string
	Chan chan string
}

KeyChan holds a key and a channel

type WatchKeyStatus

type WatchKeyStatus int

WatchKeyStatus is used to tell how WatchKey returned

const (
	// WatchKeyStatusTimeout is returned when the watch timeout provided by the caller was exceeded
	WatchKeyStatusTimeout WatchKeyStatus = iota
	// WatchKeyStatusAlreadyChanged is returned when the value passed by the caller was never observed
	WatchKeyStatusAlreadyChanged
	// WatchKeyStatusSeenChange is returned when we have seen the value passed by the caller get changed
	WatchKeyStatusSeenChange
	// WatchKeyStatusNoChange is returned when the function had to return before observing a change.
	//  Also returned on errors.
	WatchKeyStatusNoChange
)

func WatchKey

func WatchKey(key, value string, timeout time.Duration) (WatchKeyStatus, error)

WatchKey waits for a key to be updated or expired