db

package
v0.0.0-...-cb81ebf Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 25, 2023 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DEFAULT_LOCK_TOKEN = "Matrix"
)

Variables

This section is empty.

Functions

func InitRedis 

func InitRedis()

Types

type ClientType 

type ClientType int32
const (
	T_Client  ClientType = 1
	T_Cluster ClientType = 2
	NilError             = redis.Nil
)

type ClusterOptions 

type ClusterOptions func(*redis.ClusterOptions)

type IRedis 

type IRedis interface {
	Get(ctx context.Context, key string) (string, error)
	Set(ctx context.Context, key, value string, expiration time.Duration) error
	HSet(ctx context.Context, key string, field, value string) error
	HGet(ctx context.Context, key string, field string) (string, error)
	HGetAll(ctx context.Context, key string) (map[string]string, error)
	HRem(ctx context.Context, key string, fields ...string) error
	ZAdd(ctx context.Context, key, value string, score float64) error
	ZRange(ctx context.Context, key string, start, stop int64) ([]string, error)
	ZRem(ctx context.Context, key string, fields ...string) error
	ZRevRange(ctx context.Context, key string, start, stop int64) ([]string, error)
	ZCard(ctx context.Context, key string) (int, error)
	ZIncrBy(ctx context.Context, key string, increment float64, member string) error
	ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) ([]redis.Z, error)
	ZRangeWithScores(ctx context.Context, key string, start, stop int64) ([]redis.Z, error)
	ZCount(ctx context.Context, key string, min, max int64) (int64, error)
	LPush(ctx context.Context, key string, value string) (int64, error)
	LRem(ctx context.Context, key string, count int64, value string) (int64, error)
	LLen(ctx context.Context, key string) (int64, error)
	Del(ctx context.Context, key string) error
	ExpireAt(ctx context.Context, key string, expiration time.Duration) error
	Lock(ctx context.Context, key string, acquireTimeout time.Duration, lockTimeout time.Duration) error
	UnLock(ctx context.Context, key string) error
	IncrBy(ctx context.Context, key string, value int64) (int64, error)
	DecrBy(ctx context.Context, key string, value int64) (int64, error)
	Pipeline() redis.Pipeliner
	Eval(ctx context.Context, script string, keys []string, args ...interface{}) *redis.Cmd
	EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *redis.Cmd
	ScriptExists(ctx context.Context, hashes ...string) *redis.BoolSliceCmd
	ScriptLoad(ctx context.Context, script string) *redis.StringCmd
	NewScript(src string) *redis.Script
}
var (
	RedisGlobal IRedis
)

func NewRedisClient 

func NewRedisClient(addr, userName, userPwd string, clientType ClientType) IRedis

type RedisClient 

type RedisClient struct {
	Client *redis.Client
}

func (*RedisClient) DecrBy 

func (client *RedisClient) DecrBy(ctx context.Context, key string, value int64) (int64, error)

func (*RedisClient) Del 

func (client *RedisClient) Del(ctx context.Context, key string) error

func (*RedisClient) Eval 

func (client *RedisClient) Eval(ctx context.Context, script string, keys []string, args ...interface{}) *redis.Cmd

func (*RedisClient) EvalSha 

func (client *RedisClient) EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *redis.Cmd

func (*RedisClient) ExpireAt 

func (client *RedisClient) ExpireAt(ctx context.Context, key string, expiration time.Duration) error

func (*RedisClient) Get 

func (client *RedisClient) Get(ctx context.Context, key string) (string, error)

func (*RedisClient) HGet 

func (client *RedisClient) HGet(ctx context.Context, key string, field string) (string, error)

func (*RedisClient) HGetAll 

func (client *RedisClient) HGetAll(ctx context.Context, key string) (map[string]string, error)

func (*RedisClient) HRem 

func (client *RedisClient) HRem(ctx context.Context, key string, fields ...string) error

func (*RedisClient) HSet 

func (client *RedisClient) HSet(ctx context.Context, key string, field, value string) error

func (*RedisClient) IncrBy 

func (client *RedisClient) IncrBy(ctx context.Context, key string, value int64) (int64, error)

func (*RedisClient) LLen 

func (client *RedisClient) LLen(ctx context.Context, key string) (int64, error)

func (*RedisClient) LPush 

func (client *RedisClient) LPush(ctx context.Context, key string, value string) (int64, error)

func (*RedisClient) LRem 

func (client *RedisClient) LRem(ctx context.Context, key string, count int64, value string) (int64, error)

func (*RedisClient) Lock 

func (client *RedisClient) Lock(ctx context.Context, key string, acquireTimeout time.Duration, lockTimeout time.Duration) error

func (*RedisClient) NewScript 

func (client *RedisClient) NewScript(src string) *redis.Script

func (*RedisClient) Pipeline 

func (client *RedisClient) Pipeline() redis.Pipeliner

func (*RedisClient) ScriptExists 

func (client *RedisClient) ScriptExists(ctx context.Context, hashes ...string) *redis.BoolSliceCmd

func (*RedisClient) ScriptLoad 

func (client *RedisClient) ScriptLoad(ctx context.Context, script string) *redis.StringCmd

func (*RedisClient) Set 

func (client *RedisClient) Set(ctx context.Context, key, value string, expiration time.Duration) error

func (*RedisClient) UnLock 

func (client *RedisClient) UnLock(ctx context.Context, key string) error

func (*RedisClient) ZAdd 

func (client *RedisClient) ZAdd(ctx context.Context, key, value string, score float64) error

func (*RedisClient) ZCard 

func (client *RedisClient) ZCard(ctx context.Context, key string) (int, error)

func (*RedisClient) ZCount 

func (client *RedisClient) ZCount(ctx context.Context, key string, min, max int64) (int64, error)

func (*RedisClient) ZIncrBy 

func (client *RedisClient) ZIncrBy(ctx context.Context, key string, increment float64, member string) error

func (*RedisClient) ZRange 

func (client *RedisClient) ZRange(ctx context.Context, key string, start, stop int64) ([]string, error)

func (*RedisClient) ZRangeWithScores 

func (client *RedisClient) ZRangeWithScores(ctx context.Context, key string, start, stop int64) ([]redis.Z, error)

func (*RedisClient) ZRem 

func (client *RedisClient) ZRem(ctx context.Context, key string, fields ...string) error

func (*RedisClient) ZRevRange 

func (client *RedisClient) ZRevRange(ctx context.Context, key string, start, stop int64) ([]string, error)

func (*RedisClient) ZRevRangeWithScores 

func (client *RedisClient) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) ([]redis.Z, error)

type RedisCluster 

type RedisCluster struct {
	Client *redis.ClusterClient
	// contains filtered or unexported fields
}

func (*RedisCluster) DecrBy 

func (client *RedisCluster) DecrBy(ctx context.Context, key string, value int64) (int64, error)

func (*RedisCluster) Del 

func (client *RedisCluster) Del(ctx context.Context, key string) error

func (*RedisCluster) Eval 

func (client *RedisCluster) Eval(ctx context.Context, script string, keys []string, args ...interface{}) *redis.Cmd

func (*RedisCluster) EvalSha 

func (client *RedisCluster) EvalSha(ctx context.Context, sha1 string, keys []string, args ...interface{}) *redis.Cmd

func (*RedisCluster) ExpireAt 

func (client *RedisCluster) ExpireAt(ctx context.Context, key string, expiration time.Duration) error

func (*RedisCluster) Get 

func (client *RedisCluster) Get(ctx context.Context, key string) (string, error)

func (*RedisCluster) HGet 

func (client *RedisCluster) HGet(ctx context.Context, key string, field string) (string, error)

func (*RedisCluster) HGetAll 

func (client *RedisCluster) HGetAll(ctx context.Context, key string) (map[string]string, error)

func (*RedisCluster) HRem 

func (client *RedisCluster) HRem(ctx context.Context, key string, fields ...string) error

func (*RedisCluster) HSet 

func (client *RedisCluster) HSet(ctx context.Context, key string, field, value string) error

func (*RedisCluster) IncrBy 

func (client *RedisCluster) IncrBy(ctx context.Context, key string, value int64) (int64, error)

func (*RedisCluster) LLen 

func (client *RedisCluster) LLen(ctx context.Context, key string) (int64, error)

func (*RedisCluster) LPush 

func (client *RedisCluster) LPush(ctx context.Context, key string, value string) (int64, error)

func (*RedisCluster) LRem 

func (client *RedisCluster) LRem(ctx context.Context, key string, count int64, value string) (int64, error)

func (*RedisCluster) Lock 

func (client *RedisCluster) Lock(ctx context.Context, key string, acquireTimeOut, lockTimeOut time.Duration) error

Lock @Description: redis distributed lock @param key mutex name @param ttl set the expiry of a mutex to the given value. @param retryDelay set the amount of time to wait between retries. @param tries set the number of times lock acquire is attempted @return error

func (*RedisCluster) NewScript 

func (client *RedisCluster) NewScript(src string) *redis.Script

func (*RedisCluster) Pipeline 

func (client *RedisCluster) Pipeline() redis.Pipeliner

func (*RedisCluster) ScriptExists 

func (client *RedisCluster) ScriptExists(ctx context.Context, hashes ...string) *redis.BoolSliceCmd

func (*RedisCluster) ScriptLoad 

func (client *RedisCluster) ScriptLoad(ctx context.Context, script string) *redis.StringCmd

func (*RedisCluster) Set 

func (client *RedisCluster) Set(ctx context.Context, key, value string, expiration time.Duration) error

func (*RedisCluster) UnLock 

func (client *RedisCluster) UnLock(ctx context.Context, key string) error

func (*RedisCluster) ZAdd 

func (client *RedisCluster) ZAdd(ctx context.Context, key, value string, score float64) error

func (*RedisCluster) ZCard 

func (client *RedisCluster) ZCard(ctx context.Context, key string) (int, error)

func (*RedisCluster) ZCount 

func (client *RedisCluster) ZCount(ctx context.Context, key string, min, max int64) (int64, error)

func (*RedisCluster) ZIncrBy 

func (client *RedisCluster) ZIncrBy(ctx context.Context, key string, increment float64, member string) error

func (*RedisCluster) ZRange 

func (client *RedisCluster) ZRange(ctx context.Context, key string, start, stop int64) ([]string, error)

func (*RedisCluster) ZRangeWithScores 

func (client *RedisCluster) ZRangeWithScores(ctx context.Context, key string, start, stop int64) ([]redis.Z, error)

func (*RedisCluster) ZRem 

func (client *RedisCluster) ZRem(ctx context.Context, key string, fields ...string) error

func (*RedisCluster) ZRevRange 

func (client *RedisCluster) ZRevRange(ctx context.Context, key string, start, stop int64) ([]string, error)

func (*RedisCluster) ZRevRangeWithScores 

func (client *RedisCluster) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) ([]redis.Z, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.