redis

Documentation

Index

• Constants
• Variables
• func NewInner() (gone.Goner, gone.GonerId)
• func NewRedisCache() (gone.Goner, gone.GonerId)
• func NewRedisLocker() (gone.Goner, gone.GonerId)
• func NewRedisPool() (gone.Angel, gone.GonerId)
• func Priest(cemetery gone.Cemetery) error
• type Cache
• type Conn
• type Locker
• type Pool
• type Unlock

Constants

const IdGoneRedisInner = "gone-redis-inner"

Variables

var (
	ErrNil           = redis.ErrNil
	Int              = redis.Int
	Int64            = redis.Int64
	Uint64           = redis.Uint64
	Float64          = redis.Float64
	String           = redis.String
	Bytes            = redis.Bytes
	Bool             = redis.Bool
	Values           = redis.Values
	Float64s         = redis.Float64s
	Strings          = redis.Strings
	ByteSlices       = redis.ByteSlices
	Int64s           = redis.Int64s
	Ints             = redis.Ints
	StringMap        = redis.StringMap
	IntMap           = redis.IntMap
	Int64Map         = redis.Int64Map
	Float64Map       = redis.Float64Map
	Positions        = redis.Positions
	Uint64s          = redis.Uint64s
	Uint64Map        = redis.Uint64Map
	SlowLogs         = redis.SlowLogs
	Latencies        = redis.Latencies
	LatencyHistories = redis.LatencyHistories
)

var ErrorLockFailed = errors.New("not lock success")

Functions

func NewInner

func NewInner() (gone.Goner, gone.GonerId)

func NewRedisCache

func NewRedisCache() (gone.Goner, gone.GonerId)

func NewRedisLocker

func NewRedisLocker() (gone.Goner, gone.GonerId)

func NewRedisPool

func NewRedisPool() (gone.Angel, gone.GonerId)

func Priest

func Priest(cemetery gone.Cemetery) error

Types

type Cache

type Cache interface {
	Put(key string, value any, ttl ...time.Duration) error
	Get(key string, value any) error
	Remove(key string) (err error)
	Keys(key string) ([]string, error)
}

type Conn

type Conn = redis.Conn

type Locker

type Locker interface {
	TryLock(key string, ttl time.Duration) (unlock Unlock, err error)
	LockAndDo(key string, fn func(), lockTime, checkPeriod time.Duration) (err error)
}

type Pool

type Pool interface {
	Get() Conn
}

type Unlock

type Unlock func()