redisstore

package

v0.0.0-...-ba1b225 Latest Latest Go to latest Published: Jun 20, 2019 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/theaaf/keyvaluestore

Links

Open Source Insights

Documentation ¶

Index ¶

func ProfileClient(client *redis.Client, profiler Profiler) *redis.Client
type AtomicWriteOperation
type Backend
type BasicProfiler
type BatchOperation
type DeleteResult
- func (r *DeleteResult) Result() (bool, error)
type ErrorResult
- func (r *ErrorResult) Result() error
type GetResult
- func (r *GetResult) Result() (*string, error)
type Profiler
type RedisCmd
type SMembersResult
- func (r *SMembersResult) Result() ([]string, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ProfileClient ¶

func ProfileClient(client *redis.Client, profiler Profiler) *redis.Client

Types ¶

type AtomicWriteOperation ¶

type AtomicWriteOperation struct {
	Client *redis.Client
	// contains filtered or unexported fields
}

func (*AtomicWriteOperation) CAS ¶

func (op *AtomicWriteOperation) CAS(key string, oldValue, newValue string) keyvaluestore.AtomicWriteResult

func (*AtomicWriteOperation) Delete ¶

func (op *AtomicWriteOperation) Delete(key string) keyvaluestore.AtomicWriteResult

func (*AtomicWriteOperation) Exec ¶

func (op *AtomicWriteOperation) Exec() (bool, error)

func (*AtomicWriteOperation) SetNX ¶

func (op *AtomicWriteOperation) SetNX(key string, value interface{}) keyvaluestore.AtomicWriteResult

type Backend ¶

type Backend struct {
	Client *redis.Client
}

func (*Backend) AddInt ¶

func (b *Backend) AddInt(key string, n int64) (int64, error)

func (*Backend) AtomicWrite ¶

func (b *Backend) AtomicWrite() keyvaluestore.AtomicWriteOperation

func (*Backend) Batch ¶

func (b *Backend) Batch() keyvaluestore.BatchOperation

func (*Backend) CAS ¶

func (b *Backend) CAS(key string, transform func(prev *string) (interface{}, error)) (bool, error)

func (*Backend) Delete ¶

func (b *Backend) Delete(key string) (bool, error)

func (*Backend) Get ¶

func (b *Backend) Get(key string) (*string, error)

func (*Backend) SAdd ¶

func (b *Backend) SAdd(key string, member interface{}, members ...interface{}) error

func (*Backend) SMembers ¶

func (b *Backend) SMembers(key string) ([]string, error)

func (*Backend) SRem ¶

func (b *Backend) SRem(key string, member interface{}, members ...interface{}) error

func (*Backend) Set ¶

func (b *Backend) Set(key string, value interface{}) error

func (*Backend) SetNX ¶

func (b *Backend) SetNX(key string, value interface{}) (bool, error)

func (*Backend) SetXX ¶

func (b *Backend) SetXX(key string, value interface{}) (bool, error)

func (*Backend) WithProfiler ¶

func (b *Backend) WithProfiler(profiler interface{}) *Backend

func (*Backend) ZAdd ¶

func (b *Backend) ZAdd(key string, member interface{}, score float64) error

func (*Backend) ZCount ¶

func (b *Backend) ZCount(key string, min, max float64) (int, error)

func (*Backend) ZIncrBy ¶

func (b *Backend) ZIncrBy(key string, member string, n float64) (float64, error)

func (*Backend) ZLexCount ¶

func (b *Backend) ZLexCount(key string, min, max string) (int, error)

func (*Backend) ZRangeByLex ¶

func (b *Backend) ZRangeByLex(key string, min, max string, limit int) ([]string, error)

func (*Backend) ZRangeByScore ¶

func (b *Backend) ZRangeByScore(key string, min, max float64, limit int) ([]string, error)

func (*Backend) ZRangeByScoreWithScores ¶

func (b *Backend) ZRangeByScoreWithScores(key string, min, max float64, limit int) (keyvaluestore.ScoredMembers, error)

func (*Backend) ZRem ¶

func (b *Backend) ZRem(key string, member interface{}) error

func (*Backend) ZRevRangeByLex ¶

func (b *Backend) ZRevRangeByLex(key string, min, max string, limit int) ([]string, error)

func (*Backend) ZRevRangeByScore ¶

func (b *Backend) ZRevRangeByScore(key string, min, max float64, limit int) ([]string, error)

func (*Backend) ZRevRangeByScoreWithScores ¶

func (b *Backend) ZRevRangeByScoreWithScores(key string, min, max float64, limit int) (keyvaluestore.ScoredMembers, error)

func (*Backend) ZScore ¶

func (b *Backend) ZScore(key string, member interface{}) (*float64, error)

type BasicProfiler ¶

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

func (*BasicProfiler) AddRedisCommandProfile ¶

func (p *BasicProfiler) AddRedisCommandProfile(cmd redis.Cmder, duration time.Duration)

func (*BasicProfiler) AddRedisPipelineProfile ¶

func (p *BasicProfiler) AddRedisPipelineProfile(cmds []redis.Cmder, duration time.Duration)

func (*BasicProfiler) RedisCommandCount ¶

func (p *BasicProfiler) RedisCommandCount() int

func (*BasicProfiler) RedisCommandDuration ¶

func (p *BasicProfiler) RedisCommandDuration() time.Duration

func (*BasicProfiler) RedisRoundTripCount ¶

func (p *BasicProfiler) RedisRoundTripCount() int

type BatchOperation ¶

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

func (*BatchOperation) Delete ¶

func (op *BatchOperation) Delete(key string) keyvaluestore.DeleteResult

func (*BatchOperation) Exec ¶

func (op *BatchOperation) Exec() error

func (*BatchOperation) Get ¶

func (op *BatchOperation) Get(key string) keyvaluestore.GetResult

func (*BatchOperation) SAdd ¶

func (op *BatchOperation) SAdd(key string, member interface{}, members ...interface{}) keyvaluestore.ErrorResult

func (*BatchOperation) SMembers ¶

func (op *BatchOperation) SMembers(key string) keyvaluestore.SMembersResult

func (*BatchOperation) SRem ¶

func (op *BatchOperation) SRem(key string, member interface{}, members ...interface{}) keyvaluestore.ErrorResult

func (*BatchOperation) Set ¶

func (op *BatchOperation) Set(key string, value interface{}) keyvaluestore.ErrorResult

func (*BatchOperation) ZAdd ¶

func (op *BatchOperation) ZAdd(key string, member interface{}, score float64) keyvaluestore.ErrorResult

func (*BatchOperation) ZRem ¶

func (op *BatchOperation) ZRem(key string, member interface{}) keyvaluestore.ErrorResult

type DeleteResult ¶

type DeleteResult struct {
	*redis.IntCmd
}

func (*DeleteResult) Result ¶

func (r *DeleteResult) Result() (bool, error)

type ErrorResult ¶

type ErrorResult struct {
	RedisCmd
}

func (*ErrorResult) Result ¶

func (r *ErrorResult) Result() error

type GetResult ¶

type GetResult struct {
	*redis.StringCmd
}

func (*GetResult) Result ¶

func (r *GetResult) Result() (*string, error)

type Profiler ¶

type Profiler interface {
	AddRedisCommandProfile(cmd redis.Cmder, duration time.Duration)
	AddRedisPipelineProfile(cmds []redis.Cmder, duration time.Duration)
}

type RedisCmd ¶

type RedisCmd interface {
	Err() error
}

type SMembersResult ¶

type SMembersResult struct {
	*redis.StringSliceCmd
}

func (*SMembersResult) Result ¶

func (r *SMembersResult) Result() ([]string, error)

Source Files ¶

View all Source files

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