redisdb

Documentation

Index

• Variables
• func CleanupHook()
• func Delete(key string) error
• func Exists(key string) (bool, error)
• func Get(key string) ([]byte, error)
• func GetKeys(pattern string) ([]string, error)
• func Incr(counterKey string) (int, error)
• func LockRedis(client *redislock.Client, ctx context.Context, lock_key string, lock_time int) (lock *redislock.Lock, err error)
• func NewPool(maxidle int, maxactive int, idletimeout int, server string) *redis.Pool
• func Ping() error
• func RedisClient(maxidle int, maxactive int, server string) (client *redis9.Client, err error)
• func RedisMetric()
• func RedisServerDelete(service string, hostname string) error
• func RedisServerExists(service string, hostname string) (status bool, err error)
• func RedisServiceExists(service string) (status bool, err error)
• func RedisServiceExprieScan(service string, expire int64) (normalHost []string, expireHost []string, alarm bool, err error)
• func RedisServiceScan(service string) (keys []string, err error)
• func RedisServiceWrite(service string, hostname string) (status bool, err error)
• func ReidsServerRead(service string, hostname string) (value []byte, err error)
• func ReleaseLockRedis(lock *redislock.Lock, ctx context.Context)
• func Set(key string, value string) error

Variables

var (
	WRITE       = 0
	READ        = 0
	ErrNil      = errors.New("no matching record found in redis database")
	Ctx         = context.TODO()
	Pool        *redis.Pool
	MaxIdle     int
	MaxActive   int
	IdleTimeOut int
	Server      string
)

Functions

func CleanupHook

func CleanupHook()

func Delete

func Delete(key string) error

func Exists

func Exists(key string) (bool, error)

func Get

func Get(key string) ([]byte, error)

func GetKeys

func GetKeys(pattern string) ([]string, error)

func Incr

func Incr(counterKey string) (int, error)

func LockRedis

func LockRedis(client *redislock.Client, ctx context.Context, lock_key string,
	lock_time int) (lock *redislock.Lock, err error)

func NewPool

func NewPool(maxidle int, maxactive int, idletimeout int, server string) *redis.Pool

func Ping

func Ping() error

func RedisClient

func RedisClient(maxidle int, maxactive int, server string) (client *redis9.Client, err error)

func RedisMetric

func RedisMetric()

func RedisServerDelete

func RedisServerDelete(service string, hostname string) error

func RedisServerExists

func RedisServerExists(service string, hostname string) (status bool, err error)

func RedisServiceExists

func RedisServiceExists(service string) (status bool, err error)

func RedisServiceExprieScan

func RedisServiceExprieScan(service string, expire int64) (normalHost []string, expireHost []string,
	alarm bool, err error)

func RedisServiceScan

func RedisServiceScan(service string) (keys []string, err error)

func RedisServiceWrite

func RedisServiceWrite(service string, hostname string) (status bool, err error)

func ReidsServerRead

func ReidsServerRead(service string, hostname string) (value []byte, err error)

func ReleaseLockRedis

func ReleaseLockRedis(lock *redislock.Lock, ctx context.Context)

func Set

func Set(key string, value string) error