internal

Documentation

Index

• Constants
• type Client
• type Config
  • func (config *Config) CreateClient() (client Client, err error)
  • func (config *Config) LoadSSL() (ssl *tls.Config, err error)
• type Database
  • func NewDatabase(log logs.Logger, client Client) *Database
  • func (db *Database) Close()
  • func (db *Database) HandleCommand(ctx context.Context, name string, params []interface{}) (result []byte, err errors.CodeError)

Constants

const (
	HDEL     = "HDEL"
	HEXISTS  = "HEXISTS"
	HGET     = "HGET"
	HGETALL  = "HGETALL"
	HINCERBY = "HINCRBY"
	HKEYS    = "HKEYS"
	HLEN     = "HLEN"
	HMGET    = "HMGET"
	HMSET    = "HMSET"
	HSET     = "HSET"
	HSETNX   = "HSETNX"
	HVALS    = "HVALS"
	HSCAN    = "HSCAN"
)

const (
	KEYS    = "KEYS"
	DEL     = "DEL"
	EXISTS  = "EXISTS"
	EXPIRE  = "EXPIRE"
	PERSIST = "PERSIST"
	SCAN    = "SCAN"
)

const (
	BLPOP      = "BLPOP"
	BRPOP      = "BRPOP"
	BRPOPLPUSH = "BRPOPLPUSH"
	LINDEX     = "LINDEX"
	LINSERT    = "LINSERT"
	LLEN       = "LLEN"
	LPOP       = "LPOP"
	LPUSH      = "LPUSH"
	LPUSHX     = "LPUSHX"
	LRANGE     = "LRANGE"
	LREM       = "LREM"
	LSET       = "LSET"
	LTRIM      = "LTRIM"
	RPOP       = "RPOP"
	RPOPLPUSH  = "RPOPLPUSH"
	RPUSH      = "RPUSH"
	RPUSHX     = "RPUSHX"
)

const (
	SADD        = "SADD"
	SCARD       = "SCARD"
	SDIFF       = "SDIFF"
	SDIFFSTORE  = "SDIFFSTORE"
	SINTER      = "SINTER"
	SINTERSTORE = "SINTERSTORE"
	SISMEMBER   = "SISMEMBER"
	SMEMBERS    = "SMEMBERS"
	SMOVE       = "SMOVE"
	SPOP        = "SPOP"
	SRANDMEMBER = "SRANDMEMBER"
	SREM        = "SREM"
	SUNION      = "SUNION"
	SUNIONSTORE = "SUNIONSTORE"
	SSCAN       = "SSCAN"
)

const (
	ZADD             = "ZADD"
	ZCARD            = "ZCARD"
	ZCOUNT           = "ZCOUNT"
	ZINCRBY          = "ZINCRBY"
	ZINTERSTORE      = "ZINTERSTORE"
	ZLEXCOUNT        = "ZLEXCOUNT"
	ZRANGE           = "ZRANGE"
	ZRANGEBYLEX      = "ZRANGEBYLEX"
	ZRANGEBYSCORE    = "ZRANGEBYSCORE"
	ZRANK            = "ZRANK"
	ZREM             = "ZREM"
	ZREMRANGEBYLEX   = "ZREMRANGEBYLEX"
	ZREMRANGEBYRANK  = "ZREMRANGEBYRANK"
	ZREMRANGEBYSCORE = "ZREMRANGEBYSCORE"
	ZREVRANGE        = "ZREVRANGE"
	ZREVRANGEBYSCORE = "ZREVRANGEBYSCORE"
	ZREVRANK         = "ZREVRANK"
	ZSCORE           = "ZSCORE"
	ZUNIONSTORE      = "ZUNIONSTORE"
	ZSCAN            = "ZSCAN"
)

const (
	SET    = "SET"
	SETNX  = "SETNX"
	GET    = "GET"
	GETSET = "GETSET"
	MGET   = "MGET"
	MSET   = "MSET"
	SETEX  = "SETEX"
	INCR   = "INCR"
	INCRBY = "INCRBY"
	DECR   = "DECR"
	DECRBY = "DECRBY"
	APPEND = "APPEND"
)

const (
	SORT = "SORT"
)

Types

type Client

type Client interface {
	Do(ctx context.Context, args ...interface{}) *rds.Cmd
	Writer() (cmd rds.Cmdable)
	Reader() (cmd rds.Cmdable)
	Close() (err error)
}

type Config

type Config struct {
	MasterSlaverMode   bool     `json:"masterSlaverMode"`
	Network            string   `json:"network"`
	Addr               []string `json:"addr"`
	Username           string   `json:"username"`
	Password           string   `json:"password"`
	DB                 int      `json:"db"`
	PoolSize           int      `json:"poolSize"`
	SSL                bool     `json:"ssl"`
	CaFilePath         string   `json:"caFilePath"`
	CertFilePath       string   `json:"certFilePath"`
	KeyFilePath        string   `json:"keyFilePath"`
	InsecureSkipVerify bool     `json:"insecureSkipVerify"`
}

func (*Config) CreateClient

func (config *Config) CreateClient() (client Client, err error)

func (*Config) LoadSSL

func (config *Config) LoadSSL() (ssl *tls.Config, err error)

type Database

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

func NewDatabase

func NewDatabase(log logs.Logger, client Client) *Database

func (*Database) Close

func (db *Database) Close()

func (*Database) HandleCommand

func (db *Database) HandleCommand(ctx context.Context, name string, params []interface{}) (result []byte, err errors.CodeError)