xdb

Documentation

Index

• func BeginTx(rdb *redis.Client, cb func(tx *redis.Tx) error, keys ...string) error
• func Commit(rdb *redis.Client, cb func(pipe redis.Pipeliner) error) error
• func CommitTx(tx *redis.Tx, cb func(pipe redis.Pipeliner) error) error
• func Getter[T any, PT SetGetter[T]](rdb *redis.Client, key string) (*T, bool, error)
• func MysqlOverSsh(dsn string, cli *ssh.Client) string
• func NewRedisOptions(addr, user, pass string, db int) *redis.Options
• func NewRedisOptionsWithUrl(url string) *redis.Options
• func RedisOverSsh(opt *redis.Options, cli *ssh.Client) (*redis.Client, error)
• func Setter[T any](key string, t *T) func(redis.Pipeliner) error
• type SetGetter

Functions

func BeginTx

func BeginTx(rdb *redis.Client, cb func(tx *redis.Tx) error, keys ...string) error

func Commit

func Commit(rdb *redis.Client, cb func(pipe redis.Pipeliner) error) error

func CommitTx

func CommitTx(tx *redis.Tx, cb func(pipe redis.Pipeliner) error) error

func Getter

func Getter[T any, PT SetGetter[T]](rdb *redis.Client, key string) (*T, bool, error)

func MysqlOverSsh

func MysqlOverSsh(dsn string, cli *ssh.Client) string

func NewRedisOptions

func NewRedisOptions(addr, user, pass string, db int) *redis.Options

func NewRedisOptionsWithUrl

func NewRedisOptionsWithUrl(url string) *redis.Options

func RedisOverSsh

func RedisOverSsh(opt *redis.Options, cli *ssh.Client) (*redis.Client, error)

func Setter

func Setter[T any](key string, t *T) func(redis.Pipeliner) error

Types

type SetGetter

type SetGetter[T any] interface {
	Init()
	*T
}