cache

Documentation

Index

• func CreateCacheInstance() error
• func DeleteCacheInstance() error
• func FindCacheInstance() (*redispb.Instance, error)
• func Get(key string) ([]byte, error)
• func IncrementCounter(key string) (int, error)
• func NewPool(addr string) *redis.Pool
• func PeriodicallyPollForCache()
• func Ping(c redis.Conn) error
• func PreloadCache(keyColumn int) error
• func Set(key string, value []byte) error
• func ValidateMemoryStoreAndCreatePool()

Functions

func CreateCacheInstance

func CreateCacheInstance() error

creates the Memorystore Redis instance

func DeleteCacheInstance

func DeleteCacheInstance() error

deletes the Memorystore Redis instance

func FindCacheInstance

func FindCacheInstance() (*redispb.Instance, error)

using redis sdk try and find instance details i.e. host ip and port (instance might not exist!)

func Get

func Get(key string) ([]byte, error)

get value from redis

func IncrementCounter

func IncrementCounter(key string) (int, error)

func NewPool

func NewPool(addr string) *redis.Pool

create redis connection pools

func PeriodicallyPollForCache

func PeriodicallyPollForCache()

continuously check if memory store is available if not currently working this is incase instances stay live for extended periods while the cache is being created

func Ping

func Ping(c redis.Conn) error

func PreloadCache

func PreloadCache(keyColumn int) error

query BigQuery for all rows in table and put into redis (preloading the cache) keyColumn is the column number which you want to use for your redis key for each row

func Set

func Set(key string, value []byte) error

set value to redis

func ValidateMemoryStoreAndCreatePool

func ValidateMemoryStoreAndCreatePool()

if cache has failed (or first run) poll for redis instance information