locker

Documentation

Index

• func ExtendLock(rp *redis.Pool, key string, value string, expiration time.Duration) error
• func GrabLock(rp *redis.Pool, key string, expiration time.Duration, retry time.Duration) (string, error)
• func ReleaseLock(rp *redis.Pool, key string, value string) error

Functions

func ExtendLock

func ExtendLock(rp *redis.Pool, key string, value string, expiration time.Duration) error

ExtendLock extends our lock expiration by the passed in number of seconds

func GrabLock

func GrabLock(rp *redis.Pool, key string, expiration time.Duration, retry time.Duration) (string, error)

GrabLock grabs the passed in lock from redis in an atomic operation. It returns the lock value if successful. It will retry until the retry period, returning empty string if not acquired in that time.

func ReleaseLock

func ReleaseLock(rp *redis.Pool, key string, value string) error

ReleaseLock releases the passed in lock, returning any error encountered while doing so. It is not considered an error to release a lock that is no longer present