redisdb

Documentation

Index

• Variables
• func DelayedForceRefreshAutojoin(codeID string, in time.Duration) error
• func ForceRefreshAutojoin(codeID string) error
• func GetOrForceExeIDExecution(exeid, tvsip string, timeoutSec int) (string, bool, error)
• func Init() (err error)
• func JoinOrCreateExecution(codeID, exeid, tvsip string, ...) (string, string, error)
• func LockTryOnce(key string, lockExpiration time.Duration) (bool, error)
• func Unlock(key string) error
• type Client
  • func GetClient() Client

Variables

var ErrNil = redis.Nil

Functions

func DelayedForceRefreshAutojoin

func DelayedForceRefreshAutojoin(codeID string, in time.Duration) error

Same as ForceRefreshAutojoin, but with a delay in case of an error not to overwhelm a TVS

func ForceRefreshAutojoin

func ForceRefreshAutojoin(codeID string) error

Can be used for example after a code update to force new request to start a new updated toaster

func GetOrForceExeIDExecution

func GetOrForceExeIDExecution(exeid, tvsip string, timeoutSec int) (string, bool, error)

func Init

func Init() (err error)

func JoinOrCreateExecution

func JoinOrCreateExecution(codeID, exeid, tvsip string, maxConcurrentJoiners, joinableForSec, timeoutSec int) (string, string, error)

func LockTryOnce

func LockTryOnce(key string, lockExpiration time.Duration) (bool, error)

func Unlock

func Unlock(key string) error

Types

type Client

type Client interface {
	redis.Scripter
	redis.Cmdable
}

func GetClient

func GetClient() Client