redisHelpers

func ConnectionPool ¶

func ConnectionPool(cfg *viper.Viper) *redis.Pool

ConnectionPool reads the configuration and attempts to instantiate a redis connection pool based on the configured hostname and port.

func Count ¶

func Count(ctx context.Context, pool *redis.Pool, key string) (int, error)

Count is a concurrent-safe, context-aware redis SCARD on the input key

func Create ¶

func Create(ctx context.Context, pool *redis.Pool, key string, values map[string]string) (string, error)

Create is a concurrent-safe, context-aware redis SET of the input key to the input value

func Decrement ¶

func Decrement(ctx context.Context, pool *redis.Pool, key string) (interface{}, error)

Decrement decrements a redis value at key.

func Delete ¶

func Delete(ctx context.Context, pool *redis.Pool, key string) error

Delete is a concurrent-safe, context-aware redis DEL on the input key

func DeleteMultiFields ¶

func DeleteMultiFields(ctx context.Context, pool *redis.Pool, keys []string, field string) error

DeleteMultiFields is a concurrent-safe, context-aware Redis DEL of the input field from the input keys

func Increment ¶

func Increment(ctx context.Context, pool *redis.Pool, key string) (interface{}, error)

Increment increments a redis value at key.

func JSONStringToMap ¶

func JSONStringToMap(result string) map[string]interface{}

JSONStringToMap converts a JSON blob (which is how we store many things in redis) to a golang map so the individual properties can be accessed. Useful helper function when debugging.

func Retrieve ¶

func Retrieve(ctx context.Context, pool *redis.Pool, key string) (string, error)

Retrieve is a concurrent-safe, context-aware redis GET on the input key

func RetrieveAll ¶

func RetrieveAll(ctx context.Context, pool *redis.Pool, key string) (map[string]string, error)

RetrieveAll is a concurrent-safe, context-aware redis HGETALL on the input key

func RetrieveField ¶

func RetrieveField(ctx context.Context, pool *redis.Pool, key string, field string) (string, error)

RetrieveField is a concurrent-safe, context-aware redis HGET on the input field of the input key

func Update ¶

func Update(ctx context.Context, pool *redis.Pool, key string, value string) (string, error)

Update is a concurrent-safe, context-aware redis SADD of the input value to the input key's set. (Yes, it is an imperfect mapping, likely rework this at some point)

func UpdateMultiFields ¶

func UpdateMultiFields(ctx context.Context, pool *redis.Pool, kv map[string]string, field string) error

UpdateMultiFields is a concurrent-safe, context-aware Redis HSET of the input field Keys to update and the values to set the field to are passed in the 'kv' map. Example usage is to set multiple player's "assignment" field to various game server connection strings. "field" := "assignment" "kv" := map[string]string{ "player1": "servername:10000", "player2": "otherservername:10002" }

func Watcher ¶

func Watcher(ctx context.Context, pool *redis.Pool, key string) <-chan string

Watcher makes a channel and returns it immediately. It also launches an asynchronous goroutine that watches a redis key and returns the value of that key once it exists on the channel.

The pattern for this function is from 'Go Concurrency Patterns', it is a function that wraps a closure goroutine, and returns a channel. reference: https://talks.golang.org/2012/concurrency.slide#25