cache

func CreateCacheInstance ¶

func CreateCacheInstance() error

creates the Memorystore Redis instance

func DeleteCacheInstance ¶ added in v0.0.2

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