redis

Documentation

Index

• Variables
• type Config
• type Redis
  • func New(conf *Config) *Redis
  • func (r *Redis) Close() error
  • func (r *Redis) Do(ctx context.Context, commandName string, args ...interface{}) (interface{}, error)
  • func (r *Redis) ForceUnLock(ctx context.Context, key string) error
  • func (r *Redis) Lock(ctx context.Context, key string) (err error, gotLock bool, lockValue string)
  • func (r *Redis) UnLock(ctx context.Context, key, lockValue string) error

Variables

var (
	ErrUnLockGet = errors.New("lock has already unlocked or expired")
)

Types

type Config

type Config struct {
	DBName        string
	DBIndex       int
	Addr          string
	Password      string
	MaxActive     int
	MaxIdle       int
	IdleTimeout   time.Duration
	DialTimeout   time.Duration
	ReadTimeout   time.Duration
	WriteTimeout  time.Duration
	SlowOpTimeout time.Duration
}

type Redis

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

func New

func New(conf *Config) *Redis

func (*Redis) Close

func (r *Redis) Close() error

func (*Redis) Do

func (r *Redis) Do(ctx context.Context, commandName string, args ...interface{}) (interface{}, error)

func (*Redis) ForceUnLock

func (r *Redis) ForceUnLock(ctx context.Context, key string) error

func (*Redis) Lock

func (r *Redis) Lock(ctx context.Context, key string) (err error, gotLock bool, lockValue string)

func (*Redis) UnLock

func (r *Redis) UnLock(ctx context.Context, key, lockValue string) error