lock

type BoolResult struct {
	Result
}

type Config struct {
	Timeout        time.Duration //lock Timeout for acquiring locks
	Expire         time.Duration //lock expiration time
	EnableWatchdog bool          //Whether to enable the watchdog to renew the lock
	Logger         Logger
}

type DefaultLogger struct {
	Level LogLevel
	Log   *zap.Logger
}

type LockContext context.Context

type LockOperator interface {
	GetLock(key string, config Config) (lock Locker, err error)
	Lock(key string, ctx LockContext) error
	TryLock(key string, ctx LockContext, timeout time.Duration) error
	Unlock(key string) (bool, error)
}

type Locker interface {
	Lock(ctx LockContext) error
	TryLock(ctx LockContext, time time.Duration) error //Attempt to lock for a fixed duration
	Unlock() (bool, error)
}

type LogLevel uint8

type Logger interface {
	Debug(msg string, data ...interface{})
	Info(msg string, data ...interface{})
	Warn(msg string, data ...interface{})
	Error(msg string, data ...interface{})
}

type RedisClientAdapter interface {
	RedisOps
}

type RedisLock struct {
	// contains filtered or unexported fields
}

type RedisLockOperator struct {
	// contains filtered or unexported fields
}

type RedisOps interface {
	Expire(ctx context.Context, key string, expiration time.Duration) *BoolResult
	Eval(ctx context.Context, script string, keys []string, args ...interface{}) *Result
	HGet(ctx context.Context, key, field string) *StringResult
}

type Result struct {
	Val interface{}
	Err error
}

type StringResult struct {
	Result
}