queryset

package
v0.0.0-...-93f7185 Latest Latest
Warning

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

Go to latest
Published: May 21, 2018 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New(key string, q *query.Query) *querySet

Types

type ListQuerySet

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

func NewList

func NewList(key string, q *query.Query) *ListQuerySet

func (ListQuerySet) Key

func (this ListQuerySet) Key() string

func (ListQuerySet) Protect

func (this ListQuerySet) Protect(expire time.Duration) richTypes.ListQuerySeter

========= 连贯操作接口 ========= 保护数据库

func (ListQuerySet) Querier

func (this ListQuerySet) Querier() richTypes.Querier

func (*ListQuerySet) Rebuilding

func (this *ListQuerySet) Rebuilding() error

func (*ListQuerySet) ScanSlice

func (this *ListQuerySet) ScanSlice(slc interface{}, start, stop int64) error

func (ListQuerySet) SetRebuildFunc

func (this ListQuerySet) SetRebuildFunc(f func(ctx context.Context) ([]interface{}, time.Duration, error)) richTypes.ListQuerySeter

重构List的方法(基于RPush)

func (ListQuerySet) WithContext

func (this ListQuerySet) WithContext(ctx context.Context) richTypes.ListQuerySeter

type StringQuerySet

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

func NewString

func NewString(key string, q *query.Query) *StringQuerySet

func (*StringQuerySet) Del

func (this *StringQuerySet) Del() error

移除当前key

func (*StringQuerySet) Get

func (this *StringQuerySet) Get() (string, error)

func (*StringQuerySet) IncrBy

func (this *StringQuerySet) IncrBy(incr int64) (int64, error)

如果key存在,则给当前key增长指定的值

func (StringQuerySet) Key

func (this StringQuerySet) Key() string

func (StringQuerySet) Protect

func (this StringQuerySet) Protect(expire time.Duration) richTypes.StringQuerySeter

========= 连贯操作接口 ========= 保护数据库

func (StringQuerySet) Querier

func (this StringQuerySet) Querier() richTypes.Querier

func (*StringQuerySet) Rebuilding

func (this *StringQuerySet) Rebuilding() error

func (*StringQuerySet) Scan

func (this *StringQuerySet) Scan(value interface{}) error

func (*StringQuerySet) Set

func (this *StringQuerySet) Set(value interface{}, expire time.Duration) error

========= 写入接口 ========= 写入当前key

func (*StringQuerySet) SetNX

func (this *StringQuerySet) SetNX(value interface{}, expire time.Duration) (bool, error)

尝试写入当前Key,如果key存在则不写入

func (StringQuerySet) SetRebuildFunc

func (this StringQuerySet) SetRebuildFunc(f func(ctx context.Context) (interface{}, time.Duration)) richTypes.StringQuerySeter

重构String的方法

func (StringQuerySet) WithContext

type ZSetQuerySet

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

func NewZSet

func NewZSet(key string, q *query.Query) *ZSetQuerySet

func (*ZSetQuerySet) AddExpire

func (this *ZSetQuerySet) AddExpire(member interface{}, score float64, expire time.Duration) (int64, error)

func (*ZSetQuerySet) Count

func (this *ZSetQuerySet) Count() (int64, error)

func (*ZSetQuerySet) IsMember

func (this *ZSetQuerySet) IsMember(member string) (bool, error)

func (ZSetQuerySet) Key

func (this ZSetQuerySet) Key() string

func (*ZSetQuerySet) Members

func (this *ZSetQuerySet) Members() ([]string, error)

func (ZSetQuerySet) Protect

func (this ZSetQuerySet) Protect(expire time.Duration) richTypes.ZSetQuerySeter

防止频繁重建 expire 保护有效时间

func (ZSetQuerySet) Querier

func (this ZSetQuerySet) Querier() richTypes.Querier

func (*ZSetQuerySet) RangeASC

func (this *ZSetQuerySet) RangeASC(start, stop int64) ([]string, error)

func (*ZSetQuerySet) RangeASCWithScores

func (this *ZSetQuerySet) RangeASCWithScores(start, stop int64) ([]redis.Z, error)

func (*ZSetQuerySet) RangeByScoreASC

func (this *ZSetQuerySet) RangeByScoreASC(min, max string, offset, count int64) ([]string, error)

func (*ZSetQuerySet) RangeByScoreDESC

func (this *ZSetQuerySet) RangeByScoreDESC(min, max string, offset, count int64) ([]string, error)

func (*ZSetQuerySet) RangeDESC

func (this *ZSetQuerySet) RangeDESC(start, stop int64) ([]string, error)

func (*ZSetQuerySet) RangeDESCWithScores

func (this *ZSetQuerySet) RangeDESCWithScores(start, stop int64) ([]redis.Z, error)

func (*ZSetQuerySet) Rebuilding

func (this *ZSetQuerySet) Rebuilding() error

func (*ZSetQuerySet) Rem

func (this *ZSetQuerySet) Rem(member ...interface{}) error

func (*ZSetQuerySet) Score

func (this *ZSetQuerySet) Score(member string) (float64, error)

func (ZSetQuerySet) SetRebuildFunc

func (this ZSetQuerySet) SetRebuildFunc(rebuildFunc func(context.Context) ([]redis.Z, time.Duration)) richTypes.ZSetQuerySeter

func (ZSetQuerySet) WithContext

func (this ZSetQuerySet) WithContext(ctx context.Context) richTypes.ZSetQuerySeter

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL