core

package
v1.0.1-0...-a84aae9 Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	RedisConfMap map[string]string
)

Functions

func AddRedis 

func AddRedis(key, addr string, options redis.Options)

Add redis instance by options.

func GetClient 

func GetClient(key string) *redis.Client

GetClient returns a redis client. key is redis instance's name.

func GetEnableKafka 

func GetEnableKafka() bool

GetEnableKafka returns the value of enableKafka.

func GetEnableStub 

func GetEnableStub() bool

GetEnableStub returns the value of enableStub.

func GetRedisClient 

func GetRedisClient(server string) *redis.Client

GetRedisClient return redis client specified by redis server host.

func GetRedisConf 

func GetRedisConf() map[string]string

GetRedisConf returns redis server config.

func GetSelectors 

func GetSelectors() map[string]*Selector

GetSelectors returns redis clients map with Weight configuration.

func GetSlowThreshold 

func GetSlowThreshold() time.Duration

GetSlowThreshold returns the value of slowThreshold.

func GetWarnKeySize 

func GetWarnKeySize() int

GetWarnKeySize returns the value of warnKeySize.

func SetInstance 

func SetInstance(server string, client *redis.Client)

SetInstance can set redis client into redisInstances Map.

Types

type PipelineIns 

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

type RedisResult 

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

func (RedisResult) Error 

func (res RedisResult) Error() error

func (RedisResult) ToBool 

func (res RedisResult) ToBool() (back bool, err error)

func (RedisResult) ToBoolSlice 

func (res RedisResult) ToBoolSlice() (back []bool, err error)

func (RedisResult) ToFloat64 

func (res RedisResult) ToFloat64() (back float64, err error)

func (RedisResult) ToInt64 

func (res RedisResult) ToInt64() (back int64, err error)

func (RedisResult) ToSlice 

func (res RedisResult) ToSlice() (back []interface{}, err error)

func (RedisResult) ToString 

func (res RedisResult) ToString() (back string, err error)

func (RedisResult) ToStringIntMap 

func (res RedisResult) ToStringIntMap() (map[string]int64, error)

ToStringIntMap will force the result into map[string]int64 type.

func (RedisResult) ToStringSlice 

func (res RedisResult) ToStringSlice() (back []string, err error)

func (RedisResult) ToStringStringMap 

func (res RedisResult) ToStringStringMap() (map[string]string, error)

ToStringStringMap will force the result into map[string]string type.

func (RedisResult) ToStringStructMap 

func (res RedisResult) ToStringStructMap() (map[string]struct{}, error)

ToStringStructMap will force the result into map[string]struct{} type.

func (RedisResult) ToTime 

func (res RedisResult) ToTime() (back time.Time, err error)

func (RedisResult) ToZSlice 

func (res RedisResult) ToZSlice() ([]redis.Z, error)

ToZSlice will force the result into []redis.Z type.

type Selector 

type Selector struct {
	Servers []*Weighted
}

func (*Selector) Select 

func (s *Selector) Select() string

Select a redis server address according to weight configuration.

type Weighted 

type Weighted struct {
	Server          string
	Weight          int
	CurrentWeight   int
	EffectiveWeight int
}

redis server Weighted struct.

type XesRedis 

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

func (*XesRedis) Decr 

func (this *XesRedis) Decr(keyName string, keyParams []interface{}) (back int64, err error)

func (*XesRedis) DecrBy 

func (this *XesRedis) DecrBy(keyName string, keyParams []interface{}, decrement interface{}) (back int64, err error)

func (*XesRedis) Del 

func (this *XesRedis) Del(keyName string, keyParams []interface{}, otherKeys ...interface{}) (back int64, err error)

NOTE: support multi del Del("key1",nil,"key2",nil,"key3",nil)

func (*XesRedis) Eval 

func (this *XesRedis) Eval(instance string, script string, keys []string, args ...interface{}) (interface{}, error)

exec redis lua

func (*XesRedis) ExecPipeLine 

func (this *XesRedis) ExecPipeLine() (ret []RedisResult, errs []error)

Executing commands in the PipeLine.

func (*XesRedis) Exists 

func (this *XesRedis) Exists(keyName string, keyParams []interface{}) (back bool, err error)

func (*XesRedis) Expire 

func (this *XesRedis) Expire(keyName string, keyParams []interface{}, value interface{}) (back bool, err error)

func (*XesRedis) Get 

func (this *XesRedis) Get(keyName string, keyParams []interface{}) (back string, err error)

func (*XesRedis) GetCtx 

func (this *XesRedis) GetCtx() context.Context

GetCtx returns redis client's ctx.

func (*XesRedis) GetKey 

func (this *XesRedis) GetKey() string

GetKey return redis client's key or keyName.

func (*XesRedis) GetKeyName 

func (this *XesRedis) GetKeyName() string

GetKeyName returns redis client's keyName.

func (*XesRedis) GetKeyParams 

func (this *XesRedis) GetKeyParams() []interface{}

GetKeyParams returns redis client's key params.

func (*XesRedis) GetPipeLiner 

func (this *XesRedis) GetPipeLiner() map[string]*PipelineIns

GetPipeLiner returns redis client's pipeLiners.

func (*XesRedis) GetSet 

func (this *XesRedis) GetSet(keyName string, keyParams []interface{}, value interface{}) (back string, err error)

func (*XesRedis) Go 

func (this *XesRedis) Go() *XesRedis

async switch.

func (*XesRedis) HDel 

func (this *XesRedis) HDel(keyName string, keyParams []interface{}, fields []interface{}) (back string, err error)

func (*XesRedis) HGet 

func (this *XesRedis) HGet(keyName string, keyParams []interface{}, filed interface{}) (back string, err error)

func (*XesRedis) HGetAll 

func (this *XesRedis) HGetAll(keyName string, keyParams []interface{}) (back map[string]string, err error)

func (*XesRedis) HIncrBy 

func (this *XesRedis) HIncrBy(keyName string, keyParams []interface{}, field interface{}, increment interface{}) (back int64, err error)

func (*XesRedis) HLen 

func (this *XesRedis) HLen(keyName string, keyParams []interface{}) (back int64, err error)

func (*XesRedis) HMGet 

func (this *XesRedis) HMGet(keyName string, keyParams []interface{}, fileds []interface{}) (back []string, err error)

func (*XesRedis) HMSet 

func (this *XesRedis) HMSet(keyName string, keyParams []interface{}, value map[string]interface{}) (back string, err error)

func (*XesRedis) HSet 

func (this *XesRedis) HSet(keyName string, keyParams []interface{}, field interface{}, value interface{}) (back string, err error)

func (*XesRedis) HSetNx 

func (this *XesRedis) HSetNx(keyName string, keyParams []interface{}, field interface{}, value interface{}) (back bool, err error)

func (*XesRedis) Hkeys 

func (this *XesRedis) Hkeys(keyName string, keyParams []interface{}) (back []string, err error)

func (*XesRedis) Hvals 

func (this *XesRedis) Hvals(keyName string, keyParams []interface{}) (back []string, err error)

func (*XesRedis) Incr 

func (this *XesRedis) Incr(keyName string, keyParams []interface{}) (back int64, err error)

func (*XesRedis) IncrBy 

func (this *XesRedis) IncrBy(keyName string, keyParams []interface{}, increment interface{}) (back int64, err error)

func (*XesRedis) IncrByFloat 

func (this *XesRedis) IncrByFloat(keyName string, keyParams []interface{}, value interface{}) (back float64, err error)

func (*XesRedis) LLen 

func (this *XesRedis) LLen(keyName string, keyParams []interface{}) (back int64, err error)

func (*XesRedis) LPush 

func (this *XesRedis) LPush(keyName string, keyParams []interface{}, value []interface{}) (back int64, err error)

func (*XesRedis) LRange 

func (this *XesRedis) LRange(keyName string, keyParams []interface{}, start interface{}, end interface{}) (back []string, err error)

func (*XesRedis) LRem 

func (this *XesRedis) LRem(keyName string, keyParams []interface{}, value interface{}, count int) (back int64, err error)

func (*XesRedis) LTrim 

func (this *XesRedis) LTrim(keyName string, keyParams []interface{}, start, stop int) (back int64, err error)

func (*XesRedis) MGet 

func (this *XesRedis) MGet(keyName string, keyParams []interface{}, otherKeys ...interface{}) (back []string, err error)

NOTE: MGet("key1_%v",[]interface{}{100},"key2",nil,"key3",nil)

func (*XesRedis) MSet 

func (this *XesRedis) MSet(keyName string, keyParams []interface{}, value interface{}, otherKeys ...interface{}) (back string, err error)

NOTE: MSet("key1_%v",[]interface{}{100},"value1","key2",nil,"value2","key3",nil,"value3")

func (*XesRedis) OpenPipeLine 

func (this *XesRedis) OpenPipeLine()

Initialize pipeLiners in the redis instance。

func (*XesRedis) Persist 

func (this *XesRedis) Persist(keyName string, keyParams []interface{}) (back int64, err error)

func (*XesRedis) RPop 

func (this *XesRedis) RPop(keyName string, keyParams []interface{}) (back string, err error)

func (*XesRedis) RPush 

func (this *XesRedis) RPush(keyName string, keyParams []interface{}, value []interface{}) (back int64, err error)

func (*XesRedis) SAdd 

func (this *XesRedis) SAdd(keyName string, keyParams []interface{}, members []interface{}) (back int64, err error)

func (*XesRedis) SCard 

func (this *XesRedis) SCard(keyName string, keyParams []interface{}) (back int64, err error)

func (*XesRedis) SDiff 

func (this *XesRedis) SDiff(keyName string, keyParams []interface{}, otherKeys ...interface{}) (back []string, err error)

func (*XesRedis) SMembers 

func (this *XesRedis) SMembers(keyName string, keyParams []interface{}) (back []string, err error)

func (*XesRedis) SRandMember 

func (this *XesRedis) SRandMember(keyName string, keyParams []interface{}, count []interface{}) (back []string, err error)

func (*XesRedis) SRem 

func (this *XesRedis) SRem(keyName string, keyParams []interface{}, member []interface{}) (back int64, err error)

func (*XesRedis) SUnionStore 

func (this *XesRedis) SUnionStore(keyName string, keyParams []interface{}, otherKeys ...interface{}) (back int64, err error)

func (*XesRedis) Set 

func (this *XesRedis) Set(keyName string, keyParams []interface{}, value interface{}, ex int64) (back string, err error)

func (*XesRedis) SetCtx 

func (this *XesRedis) SetCtx(ctx context.Context)

SetCtx will set ctx into redis client.

func (*XesRedis) SetHandler 

func (this *XesRedis) SetHandler(handler redo.XesRedisHandler)

SetPipeLiner will set handler into redis client.

func (*XesRedis) SetInstanceIP 

func (this *XesRedis) SetInstanceIP(ip string)

SetInstanceIP will set redis server host into redis client.

func (*XesRedis) SetNX 

func (this *XesRedis) SetNX(keyName string, keyParams []interface{}, value interface{}, ex int64) (back string, err error)

返回类型不匹配，请使用SetNXBool，已废弃，兼容已上线服务保留

func (*XesRedis) SetNXBool 

func (this *XesRedis) SetNXBool(keyName string, keyParams []interface{}, value interface{}) (back bool, err error)

func (*XesRedis) SetPipeLineFlag 

func (this *XesRedis) SetPipeLineFlag()

SetPipeLineFlag will set goPipeLine flag into redis client.

func (*XesRedis) SetPipeLiner 

func (this *XesRedis) SetPipeLiner(pip map[string]*PipelineIns)

SetPipeLiner will set pipeLiners into redis client.

func (*XesRedis) SisMember 

func (this *XesRedis) SisMember(keyName string, keyParams []interface{}, member []interface{}) (back int64, err error)

func (*XesRedis) String 

func (this *XesRedis) String() (back string)

Format redis execution information.

func (*XesRedis) TTL 

func (this *XesRedis) TTL(keyName string, keyParams []interface{}) (back int64, err error)

func (*XesRedis) ZAdd 

func (this *XesRedis) ZAdd(keyName string, keyParams []interface{}, zParams []interface{}) (back int64, err error)

func (*XesRedis) ZCard 

func (this *XesRedis) ZCard(keyName string, keyParams []interface{}) (back int64, err error)

func (*XesRedis) ZCount 

func (this *XesRedis) ZCount(keyName string, keyParams []interface{}, start interface{}, end interface{}) (back int64, err error)

func (*XesRedis) ZIncrBy 

func (this *XesRedis) ZIncrBy(keyName string, keyParams []interface{}, increment interface{}, member string) (back float64, err error)

func (*XesRedis) ZRange 

func (this *XesRedis) ZRange(keyName string, keyParams []interface{}, start interface{}, end interface{}) (back []string, err error)

func (*XesRedis) ZRangeByScore 

func (this *XesRedis) ZRangeByScore(keyName string, keyParams []interface{}, start interface{}, end interface{}, limits ...interface{}) (back []string, err error)

func (*XesRedis) ZRangeByScoreWithSocres 

func (this *XesRedis) ZRangeByScoreWithSocres(keyName string, keyParams []interface{}, start interface{}, end interface{}, limits ...interface{}) (back []redis.Z, err error)

func (*XesRedis) ZRangeWithScores 

func (this *XesRedis) ZRangeWithScores(keyName string, keyParams []interface{}, start interface{}, end interface{}) (back []redis.Z, err error)

func (*XesRedis) ZRank 

func (this *XesRedis) ZRank(keyName string, keyParams []interface{}, member string) (back int64, err error)

func (*XesRedis) ZRem 

func (this *XesRedis) ZRem(keyName string, keyParams []interface{}, childkeys []interface{}) (int64, error)

func (*XesRedis) ZRemRangeByRank 

func (this *XesRedis) ZRemRangeByRank(keyName string, keyParams []interface{}, start interface{}, end interface{}) (int64, error)

func (*XesRedis) ZRemRangeByScore 

func (this *XesRedis) ZRemRangeByScore(keyName string, keyParams []interface{}, min interface{}, max interface{}) (int64, error)

func (*XesRedis) ZRevRange 

func (this *XesRedis) ZRevRange(keyName string, keyParams []interface{}, start interface{}, end interface{}) (back []string, err error)

func (*XesRedis) ZRevRangeByScore 

func (this *XesRedis) ZRevRangeByScore(keyName string, keyParams []interface{}, start interface{}, end interface{}, limits ...interface{}) (back []string, err error)

func (*XesRedis) ZRevRangeByScoreWithSocres 

func (this *XesRedis) ZRevRangeByScoreWithSocres(keyName string, keyParams []interface{}, start interface{}, end interface{}, limits ...interface{}) (back []redis.Z, err error)

func (*XesRedis) ZRevRangeWithScores 

func (this *XesRedis) ZRevRangeWithScores(keyName string, keyParams []interface{}, start interface{}, end interface{}) (back []redis.Z, err error)

func (*XesRedis) ZRevRank 

func (this *XesRedis) ZRevRank(keyName string, keyParams []interface{}, member string) (back int64, err error)

func (*XesRedis) ZScore 

func (this *XesRedis) ZScore(keyName string, keyParams []interface{}, member string) (back float64, err error)

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.