dsf

type Group interface {
	Do(jobKey string, job Job) (result []byte, shared bool, err error)
	Forget(jobKey string) (err error)
}

type Job func() []byte

type Option interface{}

type OptionBuilder interface {
	Build() Option

	WithContext(ctx context.Context) OptionBuilder
	WithRedisClient(client RedisClient) OptionBuilder
	WithNamespace(namespace string) OptionBuilder

	WithLockExpiration(exp time.Duration) OptionBuilder
	WithDataExpiration(exp time.Duration) OptionBuilder
	KeepLock(flag bool) OptionBuilder
	WithWaitTime(duration time.Duration) OptionBuilder
	WithInterval(makeInterval func(retryTimes int) time.Duration) OptionBuilder
}

type RedisClient interface {
	Context(ctx context.Context) RedisClient

	Nil() interface{}
	Get(key string) ([]byte, error)
	Set(key string, val []byte, exp time.Duration) error
	Del(key string) error
	Eval(script string, keys []string, args ...interface{}) (interface{}, error)
}