redis

package
v1.4.13 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2021 License: BSD-3-Clause Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DefaultInstanceManager = NewInstanceManager()
View Source 
var RedisNil = fmt.Sprintf("redis: nil")

Functions

This section is empty.

Types

type ApolloConfig 

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

func NewApolloConfiger 

func NewApolloConfiger() *ApolloConfig

func (*ApolloConfig) GetConfig 

func (m *ApolloConfig) GetConfig(ctx context.Context, namespace string) (*Config, error)

func (*ApolloConfig) Init 

func (m *ApolloConfig) Init(ctx context.Context) error

func (*ApolloConfig) ParseKey 

func (m *ApolloConfig) ParseKey(ctx context.Context, key string) (*KeyParts, error)

func (*ApolloConfig) Watch 

func (m *ApolloConfig) Watch(ctx context.Context) <-chan *center.ChangeEvent

type Client 

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

func NewClient 

func NewClient(ctx context.Context, namespace string, wrapper string) (*Client, error)

func NewClientWithOptions added in v1.4.6 

func NewClientWithOptions(ctx context.Context, namespace string, opts ...Option) (*Client, error)

func NewDefaultClient 

func NewDefaultClient(ctx context.Context, namespace, addr, wrapper string, poolSize int, useWrapper bool, timeout time.Duration) (*Client, error)

func (*Client) Append added in v1.4.10 

func (m *Client) Append(ctx context.Context, key, value string) *redis.IntCmd

func (*Client) Close 

func (m *Client) Close(ctx context.Context) error

func (*Client) Decr 

func (m *Client) Decr(ctx context.Context, key string) *redis.IntCmd

func (*Client) DecrBy 

func (m *Client) DecrBy(ctx context.Context, key string, value int64) *redis.IntCmd

func (*Client) Del 

func (m *Client) Del(ctx context.Context, keys ...string) *redis.IntCmd

func (*Client) Eval added in v1.3.35 

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

func (*Client) EvalSha added in v1.3.35 

func (m *Client) EvalSha(ctx context.Context, scriptHash string, keys []string, args ...interface{}) *redis.Cmd

func (*Client) Exists 

func (m *Client) Exists(ctx context.Context, key string) *redis.IntCmd

func (*Client) Expire 

func (m *Client) Expire(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd

func (*Client) Get 

func (m *Client) Get(ctx context.Context, key string) *redis.StringCmd

func (*Client) GetBit 

func (m *Client) GetBit(ctx context.Context, key string, offset int64) *redis.IntCmd

func (*Client) HDel 

func (m *Client) HDel(ctx context.Context, key string, fields ...string) *redis.IntCmd

func (*Client) HExists 

func (m *Client) HExists(ctx context.Context, key string, field string) *redis.BoolCmd

func (*Client) HGet 

func (m *Client) HGet(ctx context.Context, key string, field string) *redis.StringCmd

func (*Client) HGetAll 

func (m *Client) HGetAll(ctx context.Context, key string) *redis.StringStringMapCmd

func (*Client) HIncrBy 

func (m *Client) HIncrBy(ctx context.Context, key string, field string, incr int64) *redis.IntCmd

func (*Client) HIncrByFloat 

func (m *Client) HIncrByFloat(ctx context.Context, key string, field string, incr float64) *redis.FloatCmd

func (*Client) HKeys 

func (m *Client) HKeys(ctx context.Context, key string) *redis.StringSliceCmd

func (*Client) HLen 

func (m *Client) HLen(ctx context.Context, key string) *redis.IntCmd

func (*Client) HMGet 

func (m *Client) HMGet(ctx context.Context, key string, fields ...string) *redis.SliceCmd

func (*Client) HMSet 

func (m *Client) HMSet(ctx context.Context, key string, fields map[string]interface{}) *redis.StatusCmd

func (*Client) HScan added in v1.4.10 

func (m *Client) HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd

func (*Client) HSet 

func (m *Client) HSet(ctx context.Context, key string, field string, value interface{}) *redis.BoolCmd

func (*Client) HSetNX 

func (m *Client) HSetNX(ctx context.Context, key string, field string, val interface{}) *redis.BoolCmd

func (*Client) HVals 

func (m *Client) HVals(ctx context.Context, key string) *redis.StringSliceCmd

func (*Client) Incr 

func (m *Client) Incr(ctx context.Context, key string) *redis.IntCmd

func (*Client) IncrBy 

func (m *Client) IncrBy(ctx context.Context, key string, value int64) *redis.IntCmd

func (*Client) LIndex 

func (m *Client) LIndex(ctx context.Context, key string, index int64) *redis.StringCmd

func (*Client) LInsert 

func (m *Client) LInsert(ctx context.Context, key, op string, pivot, value interface{}) *redis.IntCmd

func (*Client) LLen 

func (m *Client) LLen(ctx context.Context, key string) *redis.IntCmd

func (*Client) LPop 

func (m *Client) LPop(ctx context.Context, key string) *redis.StringCmd

func (*Client) LPush 

func (m *Client) LPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd

func (*Client) LPushX 

func (m *Client) LPushX(ctx context.Context, key string, value interface{}) *redis.IntCmd

func (*Client) LRange 

func (m *Client) LRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd

func (*Client) LRem 

func (m *Client) LRem(ctx context.Context, key string, count int64, value interface{}) *redis.IntCmd

func (*Client) LSet 

func (m *Client) LSet(ctx context.Context, key string, index int64, value interface{}) *redis.StatusCmd

func (*Client) LTrim 

func (m *Client) LTrim(ctx context.Context, key string, start, stop int64) *redis.StatusCmd

func (*Client) MGet 

func (m *Client) MGet(ctx context.Context, keys ...string) *redis.SliceCmd

func (*Client) MSet 

func (m *Client) MSet(ctx context.Context, pairs ...interface{}) *redis.StatusCmd

func (*Client) Pipeline added in v1.4.6 

func (m *Client) Pipeline() *Pipeline

func (*Client) RPop 

func (m *Client) RPop(ctx context.Context, key string) *redis.StringCmd

func (*Client) RPush 

func (m *Client) RPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd

func (*Client) RPushX 

func (m *Client) RPushX(ctx context.Context, key string, value interface{}) *redis.IntCmd

func (*Client) SAdd added in v1.4.7 

func (m *Client) SAdd(ctx context.Context, key string, members ...interface{}) *redis.IntCmd

func (*Client) SCard added in v1.4.7 

func (m *Client) SCard(ctx context.Context, key string) *redis.IntCmd

func (*Client) SIsMember added in v1.4.7 

func (m *Client) SIsMember(ctx context.Context, key string, member interface{}) *redis.BoolCmd

func (*Client) SMembers added in v1.4.10 

func (m *Client) SMembers(ctx context.Context, key string) *redis.StringSliceCmd

func (*Client) SPop added in v1.4.7 

func (m *Client) SPop(ctx context.Context, key string) *redis.StringCmd

func (*Client) SPopN added in v1.4.7 

func (m *Client) SPopN(ctx context.Context, key string, count int64) *redis.StringSliceCmd

func (*Client) SRandMember added in v1.4.11 

func (m *Client) SRandMember(ctx context.Context, key string) *redis.StringCmd

func (*Client) SRandMemberN added in v1.4.11 

func (m *Client) SRandMemberN(ctx context.Context, key string, count int64) *redis.StringSliceCmd

func (*Client) SRem added in v1.4.7 

func (m *Client) SRem(ctx context.Context, key string, members ...interface{}) *redis.IntCmd

func (*Client) SScan added in v1.4.7 

func (m *Client) SScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd

func (*Client) ScriptExists added in v1.3.35 

func (m *Client) ScriptExists(ctx context.Context, scriptHash string) *redis.BoolSliceCmd

func (*Client) ScriptLoad added in v1.3.35 

func (m *Client) ScriptLoad(ctx context.Context, script string) *redis.StringCmd

func (*Client) Set 

func (m *Client) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd

func (*Client) SetBit 

func (m *Client) SetBit(ctx context.Context, key string, offset int64, value int) *redis.IntCmd

func (*Client) SetNX 

func (m *Client) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.BoolCmd

func (*Client) TTL 

func (m *Client) TTL(ctx context.Context, key string) *redis.DurationCmd

func (*Client) ZAdd 

func (m *Client) ZAdd(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

func (*Client) ZAddCh 

func (m *Client) ZAddCh(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

func (*Client) ZAddNX 

func (m *Client) ZAddNX(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

func (*Client) ZAddNXCh 

func (m *Client) ZAddNXCh(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

func (*Client) ZAddXX 

func (m *Client) ZAddXX(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

func (*Client) ZAddXXCh 

func (m *Client) ZAddXXCh(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

func (*Client) ZCard 

func (m *Client) ZCard(ctx context.Context, key string) *redis.IntCmd

func (*Client) ZCount 

func (m *Client) ZCount(ctx context.Context, key, min, max string) *redis.IntCmd

func (*Client) ZIncr 

func (m *Client) ZIncr(ctx context.Context, key string, member redis.Z) *redis.FloatCmd

func (*Client) ZIncrBy 

func (m *Client) ZIncrBy(ctx context.Context, key string, increment float64, member string) *redis.FloatCmd

func (*Client) ZIncrNX 

func (m *Client) ZIncrNX(ctx context.Context, key string, member redis.Z) *redis.FloatCmd

func (*Client) ZIncrXX 

func (m *Client) ZIncrXX(ctx context.Context, key string, member redis.Z) *redis.FloatCmd

func (*Client) ZRange 

func (m *Client) ZRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd

func (*Client) ZRangeByLex 

func (m *Client) ZRangeByLex(ctx context.Context, key string, by redis.ZRangeBy) *redis.StringSliceCmd

func (*Client) ZRangeByScore 

func (m *Client) ZRangeByScore(ctx context.Context, key string, by redis.ZRangeBy) *redis.StringSliceCmd

func (*Client) ZRangeWithScores 

func (m *Client) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *redis.ZSliceCmd

func (*Client) ZRank 

func (m *Client) ZRank(ctx context.Context, key string, member string) *redis.IntCmd

func (*Client) ZRem 

func (m *Client) ZRem(ctx context.Context, key string, members []interface{}) *redis.IntCmd

func (*Client) ZRemRangeByRank added in v1.4.8 

func (m *Client) ZRemRangeByRank(ctx context.Context, key string, start int64, stop int64) *redis.IntCmd

func (*Client) ZRemRangeByScore added in v1.4.8 

func (m *Client) ZRemRangeByScore(ctx context.Context, key, min, max string) *redis.IntCmd

func (*Client) ZRevRange 

func (m *Client) ZRevRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd

func (*Client) ZRevRangeWithScores 

func (m *Client) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *redis.ZSliceCmd

func (*Client) ZRevRank 

func (m *Client) ZRevRank(ctx context.Context, key string, member string) *redis.IntCmd

func (*Client) ZScan added in v1.4.10 

func (m *Client) ZScan(ctx context.Context, key string, cursor uint64, match string, count int64) *redis.ScanCmd

func (*Client) ZScore 

func (m *Client) ZScore(ctx context.Context, key string, member string) *redis.FloatCmd

type Config 

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

type Configer 

type Configer interface {
	Init(ctx context.Context) error
	GetConfig(ctx context.Context, namespace string) (*Config, error)
	ParseKey(ctx context.Context, key string) (*KeyParts, error)
	Watch(ctx context.Context) <-chan *center.ChangeEvent
}
var DefaultConfiger Configer

func NewConfiger 

func NewConfiger(configType constants.ConfigerType) (Configer, error)

func NewEtcdConfiger 

func NewEtcdConfiger() Configer

func NewSimpleConfiger 

func NewSimpleConfiger() Configer

type EtcdConfig 

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

func (*EtcdConfig) GetConfig 

func (m *EtcdConfig) GetConfig(ctx context.Context, namespace string) (*Config, error)

func (*EtcdConfig) Init 

func (m *EtcdConfig) Init(ctx context.Context) error

func (*EtcdConfig) ParseKey 

func (m *EtcdConfig) ParseKey(ctx context.Context, key string) (*KeyParts, error)

func (*EtcdConfig) Watch 

func (m *EtcdConfig) Watch(ctx context.Context) <-chan *center.ChangeEvent

type InstanceConf 

type InstanceConf struct {
	Group     string
	Namespace string
	Wrapper   string
	NoFixKey  bool
}

func (*InstanceConf) String 

func (m *InstanceConf) String() string

type InstanceManager 

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

func NewInstanceManager 

func NewInstanceManager() *InstanceManager

func (*InstanceManager) Close 

func (m *InstanceManager) Close()

func (*InstanceManager) GetInstance 

func (m *InstanceManager) GetInstance(ctx context.Context, conf *InstanceConf) (*Client, error)

func (*InstanceManager) Watch 

func (m *InstanceManager) Watch(ctx context.Context)

type KeyParts 

type KeyParts struct {
	Namespace string
	Group     string
}

type Option added in v1.4.6 

type Option interface {
	// contains filtered or unexported methods
}

func WithNoFixKey added in v1.4.6 

func WithNoFixKey(n bool) Option

func WithUseWrapper added in v1.4.6 

func WithUseWrapper(n bool) Option

func WithWrapper added in v1.4.6 

func WithWrapper(w string) Option

type Pipeline added in v1.4.6 

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

func (*Pipeline) Close added in v1.4.6 

func (m *Pipeline) Close() error

func (*Pipeline) Decr added in v1.4.6 

func (m *Pipeline) Decr(ctx context.Context, key string) *redis.IntCmd

func (*Pipeline) DecrBy added in v1.4.6 

func (m *Pipeline) DecrBy(ctx context.Context, key string, value int64) *redis.IntCmd

func (*Pipeline) Del added in v1.4.6 

func (m *Pipeline) Del(ctx context.Context, keys ...string) *redis.IntCmd

func (*Pipeline) Discard added in v1.4.6 

func (m *Pipeline) Discard(ctx context.Context) error

func (*Pipeline) Exec added in v1.4.6 

func (m *Pipeline) Exec(ctx context.Context) ([]redis.Cmder, error)

func (*Pipeline) Exists added in v1.4.6 

func (m *Pipeline) Exists(ctx context.Context, key string) *redis.IntCmd

func (*Pipeline) Expire added in v1.4.6 

func (m *Pipeline) Expire(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd

func (*Pipeline) Get added in v1.4.6 

func (m *Pipeline) Get(ctx context.Context, key string) *redis.StringCmd

func (*Pipeline) GetBit added in v1.4.6 

func (m *Pipeline) GetBit(ctx context.Context, key string, offset int64) *redis.IntCmd

func (*Pipeline) HDel added in v1.4.6 

func (m *Pipeline) HDel(ctx context.Context, key string, fields ...string) *redis.IntCmd

func (*Pipeline) HExists added in v1.4.6 

func (m *Pipeline) HExists(ctx context.Context, key string, field string) *redis.BoolCmd

func (*Pipeline) HGet added in v1.4.6 

func (m *Pipeline) HGet(ctx context.Context, key string, field string) *redis.StringCmd

func (*Pipeline) HGetAll added in v1.4.6 

func (m *Pipeline) HGetAll(ctx context.Context, key string) *redis.StringStringMapCmd

func (*Pipeline) HIncrBy added in v1.4.6 

func (m *Pipeline) HIncrBy(ctx context.Context, key string, field string, incr int64) *redis.IntCmd

func (*Pipeline) HIncrByFloat added in v1.4.6 

func (m *Pipeline) HIncrByFloat(ctx context.Context, key string, field string, incr float64) *redis.FloatCmd

func (*Pipeline) HKeys added in v1.4.6 

func (m *Pipeline) HKeys(ctx context.Context, key string) *redis.StringSliceCmd

func (*Pipeline) HLen added in v1.4.6 

func (m *Pipeline) HLen(ctx context.Context, key string) *redis.IntCmd

func (*Pipeline) HMGet added in v1.4.6 

func (m *Pipeline) HMGet(ctx context.Context, key string, fields ...string) *redis.SliceCmd

func (*Pipeline) HMSet added in v1.4.6 

func (m *Pipeline) HMSet(ctx context.Context, key string, fields map[string]interface{}) *redis.StatusCmd

func (*Pipeline) HSet added in v1.4.6 

func (m *Pipeline) HSet(ctx context.Context, key string, field string, value interface{}) *redis.BoolCmd

func (*Pipeline) HSetNX added in v1.4.6 

func (m *Pipeline) HSetNX(ctx context.Context, key string, field string, val interface{}) *redis.BoolCmd

func (*Pipeline) HVals added in v1.4.6 

func (m *Pipeline) HVals(ctx context.Context, key string) *redis.StringSliceCmd

func (*Pipeline) Incr added in v1.4.6 

func (m *Pipeline) Incr(ctx context.Context, key string) *redis.IntCmd

func (*Pipeline) IncrBy added in v1.4.6 

func (m *Pipeline) IncrBy(ctx context.Context, key string, value int64) *redis.IntCmd

func (*Pipeline) LIndex added in v1.4.6 

func (m *Pipeline) LIndex(ctx context.Context, key string, index int64) *redis.StringCmd

func (*Pipeline) LInsert added in v1.4.6 

func (m *Pipeline) LInsert(ctx context.Context, key, op string, pivot, value interface{}) *redis.IntCmd

func (*Pipeline) LLen added in v1.4.6 

func (m *Pipeline) LLen(ctx context.Context, key string) *redis.IntCmd

func (*Pipeline) LPop added in v1.4.6 

func (m *Pipeline) LPop(ctx context.Context, key string) *redis.StringCmd

func (*Pipeline) LPush added in v1.4.6 

func (m *Pipeline) LPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd

func (*Pipeline) LPushX added in v1.4.6 

func (m *Pipeline) LPushX(ctx context.Context, key string, value interface{}) *redis.IntCmd

func (*Pipeline) LRange added in v1.4.6 

func (m *Pipeline) LRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd

func (*Pipeline) LRem added in v1.4.6 

func (m *Pipeline) LRem(ctx context.Context, key string, count int64, value interface{}) *redis.IntCmd

func (*Pipeline) LSet added in v1.4.6 

func (m *Pipeline) LSet(ctx context.Context, key string, index int64, value interface{}) *redis.StatusCmd

func (*Pipeline) LTrim added in v1.4.6 

func (m *Pipeline) LTrim(ctx context.Context, key string, start, stop int64) *redis.StatusCmd

func (*Pipeline) MGet added in v1.4.6 

func (m *Pipeline) MGet(ctx context.Context, keys ...string) *redis.SliceCmd

func (*Pipeline) MSet added in v1.4.6 

func (m *Pipeline) MSet(ctx context.Context, pairs ...interface{}) *redis.StatusCmd

func (*Pipeline) RPop added in v1.4.6 

func (m *Pipeline) RPop(ctx context.Context, key string) *redis.StringCmd

func (*Pipeline) RPush added in v1.4.6 

func (m *Pipeline) RPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd

func (*Pipeline) RPushX added in v1.4.6 

func (m *Pipeline) RPushX(ctx context.Context, key string, value interface{}) *redis.IntCmd

func (*Pipeline) Set added in v1.4.6 

func (m *Pipeline) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd

func (*Pipeline) SetBit added in v1.4.6 

func (m *Pipeline) SetBit(ctx context.Context, key string, offset int64, value int) *redis.IntCmd

func (*Pipeline) SetNX added in v1.4.6 

func (m *Pipeline) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.BoolCmd

func (*Pipeline) TTL added in v1.4.6 

func (m *Pipeline) TTL(ctx context.Context, key string) *redis.DurationCmd

func (*Pipeline) ZAdd added in v1.4.6 

func (m *Pipeline) ZAdd(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

func (*Pipeline) ZAddCh added in v1.4.6 

func (m *Pipeline) ZAddCh(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

func (*Pipeline) ZAddNX added in v1.4.6 

func (m *Pipeline) ZAddNX(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

func (*Pipeline) ZAddNXCh added in v1.4.6 

func (m *Pipeline) ZAddNXCh(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

func (*Pipeline) ZAddXX added in v1.4.6 

func (m *Pipeline) ZAddXX(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

func (*Pipeline) ZAddXXCh added in v1.4.6 

func (m *Pipeline) ZAddXXCh(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

func (*Pipeline) ZCard added in v1.4.6 

func (m *Pipeline) ZCard(ctx context.Context, key string) *redis.IntCmd

func (*Pipeline) ZCount added in v1.4.6 

func (m *Pipeline) ZCount(ctx context.Context, key, min, max string) *redis.IntCmd

func (*Pipeline) ZIncr added in v1.4.6 

func (m *Pipeline) ZIncr(ctx context.Context, key string, member redis.Z) *redis.FloatCmd

func (*Pipeline) ZIncrBy added in v1.4.6 

func (m *Pipeline) ZIncrBy(ctx context.Context, key string, increment float64, member string) *redis.FloatCmd

func (*Pipeline) ZIncrNX added in v1.4.6 

func (m *Pipeline) ZIncrNX(ctx context.Context, key string, member redis.Z) *redis.FloatCmd

func (*Pipeline) ZIncrXX added in v1.4.6 

func (m *Pipeline) ZIncrXX(ctx context.Context, key string, member redis.Z) *redis.FloatCmd

func (*Pipeline) ZRange added in v1.4.6 

func (m *Pipeline) ZRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd

func (*Pipeline) ZRangeByLex added in v1.4.6 

func (m *Pipeline) ZRangeByLex(ctx context.Context, key string, by redis.ZRangeBy) *redis.StringSliceCmd

func (*Pipeline) ZRangeByScore added in v1.4.6 

func (m *Pipeline) ZRangeByScore(ctx context.Context, key string, by redis.ZRangeBy) *redis.StringSliceCmd

func (*Pipeline) ZRangeWithScores added in v1.4.6 

func (m *Pipeline) ZRangeWithScores(ctx context.Context, key string, start, stop int64) *redis.ZSliceCmd

func (*Pipeline) ZRank added in v1.4.6 

func (m *Pipeline) ZRank(ctx context.Context, key string, member string) *redis.IntCmd

func (*Pipeline) ZRem added in v1.4.6 

func (m *Pipeline) ZRem(ctx context.Context, key string, members []interface{}) *redis.IntCmd

func (*Pipeline) ZRevRange added in v1.4.6 

func (m *Pipeline) ZRevRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd

func (*Pipeline) ZRevRangeWithScores added in v1.4.6 

func (m *Pipeline) ZRevRangeWithScores(ctx context.Context, key string, start, stop int64) *redis.ZSliceCmd

func (*Pipeline) ZRevRank added in v1.4.6 

func (m *Pipeline) ZRevRank(ctx context.Context, key string, member string) *redis.IntCmd

func (*Pipeline) ZScore added in v1.4.6 

func (m *Pipeline) ZScore(ctx context.Context, key string, member string) *redis.FloatCmd

type SimpleConfig 

type SimpleConfig struct {
}

func (*SimpleConfig) GetConfig 

func (m *SimpleConfig) GetConfig(ctx context.Context, namespace string) (*Config, error)

func (*SimpleConfig) Init 

func (m *SimpleConfig) Init(ctx context.Context) error

func (*SimpleConfig) ParseKey 

func (m *SimpleConfig) ParseKey(ctx context.Context, key string) (*KeyParts, error)

func (*SimpleConfig) Watch 

func (m *SimpleConfig) Watch(ctx context.Context) <-chan *center.ChangeEvent

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.