lock.go

package dcron

import "time"

// UnlockScript use lua for redis use
const UnlockScript = `
if redis.call("get",KEYS[1]) == ARGV[1] then
    return redis.call("del",KEYS[1])
else
    return 0
end`

const ExpireScript = `if redis.call("GET", KEYS[1]) == ARGV[1] then
		return redis.call("PEXPIRE", KEYS[1], ARGV[2])
	else
		return 0
	end`

type LockHasExpired interface {
	Lock(key string, value interface{}, expiration time.Duration) (bool, error)
	UnLock(key string, value interface{}) (interface{}, error)
	ExpireWithVal(key string, value interface{}, expiration time.Duration) (interface{}, error)
	TTL(key string) (time.Duration, error)
}

type WithoutLock struct {
}

func (d *WithoutLock) Lock(string, interface{}, time.Duration) (bool, error) {
	return true, nil
}

func (d *WithoutLock) UnLock(string, interface{}) (interface{}, error) {
	return nil, nil
}

func (d *WithoutLock) ExpireWithVal(key string, value interface{}, expiration time.Duration) (interface{}, error) {
	return true, nil
}

func (d *WithoutLock) TTL(string) (time.Duration, error) {
	return 0, nil
}