goredis

Aug 4, 2023

Changes in this version

type Scriptor

+ func FastInit(host string, port int, Password string, db int, poolSize int, scriptDB int, ...) (*Scriptor, error)

Jul 25, 2022

Changes in this version

+ var EmptyRedisReplyValue = &RedisReplyValue

+ func GetNullableInt(value *RedisReplyValue) (null.Int, error)

+ func GetNullableString(value *RedisReplyValue) null.String

+ type Option struct

+ DB int

+ Host string

+ Password string

+ PoolSize int

+ Port int

+ ScriptDefinition string

+ func (opt *Option) Create() *redis.Client

+ type RedisArrayReplyReader struct

+ func NewRedisArrayReplyReader(redisReply []interface{}) *RedisArrayReplyReader

+ func (r *RedisArrayReplyReader) ForEach(action func(i int, v *RedisReplyValue) error) error

+ func (r *RedisArrayReplyReader) GetLength() int

+ func (r *RedisArrayReplyReader) HasNext() bool

+ func (r *RedisArrayReplyReader) ReadArray() *RedisArrayReplyReader

+ func (r *RedisArrayReplyReader) ReadFloat64(defaultValue float64) (float64, error)

+ func (r *RedisArrayReplyReader) ReadInt32(defaultValue int32) (int32, error)

+ func (r *RedisArrayReplyReader) ReadInt64(defaultValue int64) (int64, error)

+ func (r *RedisArrayReplyReader) ReadString() string

+ func (r *RedisArrayReplyReader) ReadValue() *RedisReplyValue

+ func (r *RedisArrayReplyReader) SkipValue()

+ type RedisReplyValue struct

+ func NewRedisReplyValue(value interface{}) *RedisReplyValue

+ func (v *RedisReplyValue) AsFloat64(defaultValue float64) (float64, error)

+ func (v *RedisReplyValue) AsInt32(defaultValue int32) (int32, error)

+ func (v *RedisReplyValue) AsInt64(defaultValue int64) (int64, error)

+ func (v *RedisReplyValue) AsString() string

+ func (v *RedisReplyValue) IsNil() bool

+ func (v *RedisReplyValue) ToArrayReplyReader() *RedisArrayReplyReader

+ func (v *RedisReplyValue) Value() interface{}

+ type ScriptDescriptor struct

+ Scripts map[string]string

+ func NewScriptDescriptor(ctx context.Context, client *redis.Client, scripts *map[string]string, ...) (*ScriptDescriptor, error)

+ func (scriptDescriptor *ScriptDescriptor) LoadScripts(ctx context.Context, client *redis.Client, redisScriptDefinition string, ...) error

+ func (scriptDescriptor *ScriptDescriptor) Register(ctx context.Context, client *redis.Client, scripts *map[string]string, ...) error

+ type Scriptor struct

+ CTX context.Context

+ Client *redis.Client

+ func New(client *redis.Client, scriptDB int, redisScriptDefinition string, ...) (*Scriptor, error)

+ func NewDB(opt *Option, scriptDB int, redisScriptDefinition string, ...) (*Scriptor, error)

+ func (s *Scriptor) Exec(script string, keys []string, args ...interface{}) (interface{}, error)

+ func (s *Scriptor) ExecSha(scriptname string, keys []string, args ...interface{}) (interface{}, error)