redisstore

Documentation

Index

• func ProfileClient(client *redis.Client, profiler Profiler) *redis.Client
• type AtomicWriteOperation
  • func (op *AtomicWriteOperation) CAS(key string, oldValue, newValue string) keyvaluestore.AtomicWriteResult
  • func (op *AtomicWriteOperation) Delete(key string) keyvaluestore.AtomicWriteResult
  • func (op *AtomicWriteOperation) Exec() (bool, error)
  • func (op *AtomicWriteOperation) SetNX(key string, value interface{}) keyvaluestore.AtomicWriteResult
• type Backend
  • func (b *Backend) AddInt(key string, n int64) (int64, error)
  • func (b *Backend) AtomicWrite() keyvaluestore.AtomicWriteOperation
  • func (b *Backend) Batch() keyvaluestore.BatchOperation
  • func (b *Backend) CAS(key string, transform func(prev *string) (interface{}, error)) (bool, error)
  • func (b *Backend) Delete(key string) (bool, error)
  • func (b *Backend) Get(key string) (*string, error)
  • func (b *Backend) SAdd(key string, member interface{}, members ...interface{}) error
  • func (b *Backend) SMembers(key string) ([]string, error)
  • func (b *Backend) SRem(key string, member interface{}, members ...interface{}) error
  • func (b *Backend) Set(key string, value interface{}) error
  • func (b *Backend) SetNX(key string, value interface{}) (bool, error)
  • func (b *Backend) SetXX(key string, value interface{}) (bool, error)
  • func (b *Backend) WithProfiler(profiler interface{}) *Backend
  • func (b *Backend) ZAdd(key string, member interface{}, score float64) error
  • func (b *Backend) ZCount(key string, min, max float64) (int, error)
  • func (b *Backend) ZIncrBy(key string, member string, n float64) (float64, error)
  • func (b *Backend) ZLexCount(key string, min, max string) (int, error)
  • func (b *Backend) ZRangeByLex(key string, min, max string, limit int) ([]string, error)
  • func (b *Backend) ZRangeByScore(key string, min, max float64, limit int) ([]string, error)
  • func (b *Backend) ZRangeByScoreWithScores(key string, min, max float64, limit int) (keyvaluestore.ScoredMembers, error)
  • func (b *Backend) ZRem(key string, member interface{}) error
  • func (b *Backend) ZRevRangeByLex(key string, min, max string, limit int) ([]string, error)
  • func (b *Backend) ZRevRangeByScore(key string, min, max float64, limit int) ([]string, error)
  • func (b *Backend) ZRevRangeByScoreWithScores(key string, min, max float64, limit int) (keyvaluestore.ScoredMembers, error)
  • func (b *Backend) ZScore(key string, member interface{}) (*float64, error)
• type BasicProfiler
  • func (p *BasicProfiler) AddRedisCommandProfile(cmd redis.Cmder, duration time.Duration)
  • func (p *BasicProfiler) AddRedisPipelineProfile(cmds []redis.Cmder, duration time.Duration)
  • func (p *BasicProfiler) RedisCommandCount() int
  • func (p *BasicProfiler) RedisCommandDuration() time.Duration
  • func (p *BasicProfiler) RedisRoundTripCount() int
• type BatchOperation
  • func (op *BatchOperation) Delete(key string) keyvaluestore.DeleteResult
  • func (op *BatchOperation) Exec() error
  • func (op *BatchOperation) Get(key string) keyvaluestore.GetResult
  • func (op *BatchOperation) SAdd(key string, member interface{}, members ...interface{}) keyvaluestore.ErrorResult
  • func (op *BatchOperation) SMembers(key string) keyvaluestore.SMembersResult
  • func (op *BatchOperation) SRem(key string, member interface{}, members ...interface{}) keyvaluestore.ErrorResult
  • func (op *BatchOperation) Set(key string, value interface{}) keyvaluestore.ErrorResult
  • func (op *BatchOperation) ZAdd(key string, member interface{}, score float64) keyvaluestore.ErrorResult
  • func (op *BatchOperation) ZRem(key string, member interface{}) keyvaluestore.ErrorResult
• 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)

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)