rejonson

Documentation

Index

• func JsonArrAppend(processor RedisProcessor, ctx context.Context, key string, path string, ...) *redis.IntCmd
• func JsonArrIndex(processor RedisProcessor, ctx context.Context, key string, path string, ...) *redis.IntCmd
• func JsonArrInsert(processor RedisProcessor, ctx context.Context, key string, path string, ...) *redis.IntCmd
• func JsonArrLen(processor RedisProcessor, ctx context.Context, key string, path string) *redis.IntCmd
• func JsonArrPop(processor RedisProcessor, ctx context.Context, key string, path string, ...) *redis.StringCmd
• func JsonArrTrim(processor RedisProcessor, ctx context.Context, key string, path string, ...) *redis.IntCmd
• func JsonDel(processor RedisProcessor, ctx context.Context, key string, args ...interface{}) *redis.IntCmd
• func JsonGet(processor RedisProcessor, ctx context.Context, key string, args ...interface{}) *redis.StringCmd
• func JsonMGet(processor RedisProcessor, ctx context.Context, key string, args ...interface{}) *redis.StringSliceCmd
• func JsonNumIncrBy(processor RedisProcessor, ctx context.Context, key string, path string, ...) *redis.StringCmd
• func JsonNumMultBy(processor RedisProcessor, ctx context.Context, key string, path string, ...) *redis.StringCmd
• func JsonObjKeys(processor RedisProcessor, ctx context.Context, key string, path string) *redis.StringSliceCmd
• func JsonObjLen(processor RedisProcessor, ctx context.Context, key string, path string) *redis.IntCmd
• func JsonSet(processor RedisProcessor, ctx context.Context, key string, path string, ...) *redis.StatusCmd
• func JsonStrAppend(processor RedisProcessor, ctx context.Context, key string, path string, ...) *redis.IntCmd
• func JsonStrLen(processor RedisProcessor, ctx context.Context, key string, path string) *redis.IntCmd
• func JsonType(processor RedisProcessor, ctx context.Context, key string, path string) *redis.StringCmd
• type Client
  • func ExtendClient(client *redis.Client) *Client
  • func (processor *Client) JsonArrAppend(ctx context.Context, key string, path string, args ...interface{}) *redis.IntCmd
  • func (processor *Client) JsonArrIndex(ctx context.Context, key string, path string, value interface{}, ...) *redis.IntCmd
  • func (processor *Client) JsonArrInsert(ctx context.Context, key string, path string, index int, values ...interface{}) *redis.IntCmd
  • func (processor *Client) JsonArrLen(ctx context.Context, key string, path string) *redis.IntCmd
  • func (processor *Client) JsonArrPop(ctx context.Context, key string, path string, index int) *redis.StringCmd
  • func (processor *Client) JsonArrTrim(ctx context.Context, key string, path string, start int, stop int) *redis.IntCmd
  • func (processor *Client) JsonDel(ctx context.Context, key string, args ...interface{}) *redis.IntCmd
  • func (processor *Client) JsonGet(ctx context.Context, key string, args ...interface{}) *redis.StringCmd
  • func (processor *Client) JsonMGet(ctx context.Context, key string, args ...interface{}) *redis.StringSliceCmd
  • func (processor *Client) JsonNumIncrBy(ctx context.Context, key string, path string, value int) *redis.StringCmd
  • func (processor *Client) JsonNumMultBy(ctx context.Context, key string, path string, value int) *redis.StringCmd
  • func (processor *Client) JsonObjKeys(ctx context.Context, key string, path string) *redis.StringSliceCmd
  • func (processor *Client) JsonObjLen(ctx context.Context, key string, path string) *redis.IntCmd
  • func (processor *Client) JsonSet(ctx context.Context, key string, path string, json string, args ...interface{}) *redis.StatusCmd
  • func (processor *Client) JsonStrAppend(ctx context.Context, key string, path string, value string) *redis.IntCmd
  • func (processor *Client) JsonStrLen(ctx context.Context, key string, path string) *redis.IntCmd
  • func (processor *Client) JsonType(ctx context.Context, key string, path string) *redis.StringCmd
  • func (cl *Client) Pipeline() *Pipeline
  • func (cl *Client) TXPipeline() *Pipeline
• type Pipeline
  • func ExtendPipeline(pipeline redis.Pipeliner) *Pipeline
  • func (processor *Pipeline) JsonArrAppend(ctx context.Context, key string, path string, args ...interface{}) *redis.IntCmd
  • func (processor *Pipeline) JsonArrIndex(ctx context.Context, key string, path string, value interface{}, ...) *redis.IntCmd
  • func (processor *Pipeline) JsonArrInsert(ctx context.Context, key string, path string, index int, values ...interface{}) *redis.IntCmd
  • func (processor *Pipeline) JsonArrLen(ctx context.Context, key string, path string) *redis.IntCmd
  • func (processor *Pipeline) JsonArrPop(ctx context.Context, key string, path string, index int) *redis.StringCmd
  • func (processor *Pipeline) JsonArrTrim(ctx context.Context, key string, path string, start int, stop int) *redis.IntCmd
  • func (processor *Pipeline) JsonDel(ctx context.Context, key string, args ...interface{}) *redis.IntCmd
  • func (processor *Pipeline) JsonGet(ctx context.Context, key string, args ...interface{}) *redis.StringCmd
  • func (processor *Pipeline) JsonMGet(ctx context.Context, key string, args ...interface{}) *redis.StringSliceCmd
  • func (processor *Pipeline) JsonNumIncrBy(ctx context.Context, key string, path string, value int) *redis.StringCmd
  • func (processor *Pipeline) JsonNumMultBy(ctx context.Context, key string, path string, value int) *redis.StringCmd
  • func (processor *Pipeline) JsonObjKeys(ctx context.Context, key string, path string) *redis.StringSliceCmd
  • func (processor *Pipeline) JsonObjLen(ctx context.Context, key string, path string) *redis.IntCmd
  • func (processor *Pipeline) JsonSet(ctx context.Context, key string, path string, json string, args ...interface{}) *redis.StatusCmd
  • func (processor *Pipeline) JsonStrAppend(ctx context.Context, key string, path string, value string) *redis.IntCmd
  • func (processor *Pipeline) JsonStrLen(ctx context.Context, key string, path string) *redis.IntCmd
  • func (processor *Pipeline) JsonType(ctx context.Context, key string, path string) *redis.StringCmd
  • func (pl *Pipeline) Pipeline() *Pipeline
• type RedisProcessor

Functions

func JsonArrAppend

func JsonArrAppend(processor RedisProcessor, ctx context.Context, key string, path string, args ...interface{}) *redis.IntCmd

---- JsonArrAppend ----

func JsonArrIndex

func JsonArrIndex(processor RedisProcessor, ctx context.Context, key string, path string, value interface{}, startAndStop ...interface{}) *redis.IntCmd

---- JsonArrIndex ----

func JsonArrInsert

func JsonArrInsert(processor RedisProcessor, ctx context.Context, key string, path string, index int, values ...interface{}) *redis.IntCmd

---- JsonArrInsert ----

func JsonArrLen

func JsonArrLen(processor RedisProcessor, ctx context.Context, key string, path string) *redis.IntCmd

---- JsonArrLen ----

func JsonArrPop

func JsonArrPop(processor RedisProcessor, ctx context.Context, key string, path string, index int) *redis.StringCmd

---- JsonArrPop ----

func JsonArrTrim

func JsonArrTrim(processor RedisProcessor, ctx context.Context, key string, path string, start int, stop int) *redis.IntCmd

---- JsonArrTrim ----

func JsonDel

func JsonDel(processor RedisProcessor, ctx context.Context, key string, args ...interface{}) *redis.IntCmd

---- JsonDel ----

func JsonGet

func JsonGet(processor RedisProcessor, ctx context.Context, key string, args ...interface{}) *redis.StringCmd

---- JsonGet ----

func JsonMGet

func JsonMGet(processor RedisProcessor, ctx context.Context, key string, args ...interface{}) *redis.StringSliceCmd

---- JsonMGet ----

func JsonNumIncrBy

func JsonNumIncrBy(processor RedisProcessor, ctx context.Context, key string, path string, value int) *redis.StringCmd

---- JsonNumIncrBy ----

func JsonNumMultBy

func JsonNumMultBy(processor RedisProcessor, ctx context.Context, key string, path string, value int) *redis.StringCmd

---- JsonNumMultBy ----

func JsonObjKeys

func JsonObjKeys(processor RedisProcessor, ctx context.Context, key string, path string) *redis.StringSliceCmd

---- JsonObjKeys ----

func JsonObjLen

func JsonObjLen(processor RedisProcessor, ctx context.Context, key string, path string) *redis.IntCmd

---- JsonObjLen ----

func JsonSet

func JsonSet(processor RedisProcessor, ctx context.Context, key string, path string, json string, args ...interface{}) *redis.StatusCmd

---- JsonSet ----

func JsonStrAppend

func JsonStrAppend(processor RedisProcessor, ctx context.Context, key string, path string, value string) *redis.IntCmd

---- JsonStrAppend ----

func JsonStrLen

func JsonStrLen(processor RedisProcessor, ctx context.Context, key string, path string) *redis.IntCmd

---- JsonStrLen ----

func JsonType

func JsonType(processor RedisProcessor, ctx context.Context, key string, path string) *redis.StringCmd

---- JsonType ----

Types

type Client

type Client struct {
	*redis.Client
}

Client is an extended redis.Client, stores a pointer to the original redis.Client

func ExtendClient

func ExtendClient(client *redis.Client) *Client

func (*Client) JsonArrAppend

func (processor *Client) JsonArrAppend(ctx context.Context, key string, path string, args ...interface{}) *redis.IntCmd

func (*Client) JsonArrIndex

func (processor *Client) JsonArrIndex(ctx context.Context, key string, path string, value interface{}, startAndStop ...interface{}) *redis.IntCmd

func (*Client) JsonArrInsert

func (processor *Client) JsonArrInsert(ctx context.Context, key string, path string, index int, values ...interface{}) *redis.IntCmd

func (*Client) JsonArrLen

func (processor *Client) JsonArrLen(ctx context.Context, key string, path string) *redis.IntCmd

func (*Client) JsonArrPop

func (processor *Client) JsonArrPop(ctx context.Context, key string, path string, index int) *redis.StringCmd

func (*Client) JsonArrTrim

func (processor *Client) JsonArrTrim(ctx context.Context, key string, path string, start int, stop int) *redis.IntCmd

func (*Client) JsonDel

func (processor *Client) JsonDel(ctx context.Context, key string, args ...interface{}) *redis.IntCmd

func (*Client) JsonGet

func (processor *Client) JsonGet(ctx context.Context, key string, args ...interface{}) *redis.StringCmd

func (*Client) JsonMGet

func (processor *Client) JsonMGet(ctx context.Context, key string, args ...interface{}) *redis.StringSliceCmd

func (*Client) JsonNumIncrBy

func (processor *Client) JsonNumIncrBy(ctx context.Context, key string, path string, value int) *redis.StringCmd

func (*Client) JsonNumMultBy

func (processor *Client) JsonNumMultBy(ctx context.Context, key string, path string, value int) *redis.StringCmd

func (*Client) JsonObjKeys

func (processor *Client) JsonObjKeys(ctx context.Context, key string, path string) *redis.StringSliceCmd

func (*Client) JsonObjLen

func (processor *Client) JsonObjLen(ctx context.Context, key string, path string) *redis.IntCmd

func (*Client) JsonSet

func (processor *Client) JsonSet(ctx context.Context, key string, path string, json string, args ...interface{}) *redis.StatusCmd

func (*Client) JsonStrAppend

func (processor *Client) JsonStrAppend(ctx context.Context, key string, path string, value string) *redis.IntCmd

func (*Client) JsonStrLen

func (processor *Client) JsonStrLen(ctx context.Context, key string, path string) *redis.IntCmd

func (*Client) JsonType

func (processor *Client) JsonType(ctx context.Context, key string, path string) *redis.StringCmd

func (*Client) Pipeline

func (cl *Client) Pipeline() *Pipeline

func (*Client) TXPipeline

func (cl *Client) TXPipeline() *Pipeline

type Pipeline

type Pipeline struct {
	redis.Pipeliner
}

Pipeline is an extended redis.Pipeline, stores a pointer to the original redis.Pipeliner

func ExtendPipeline

func ExtendPipeline(pipeline redis.Pipeliner) *Pipeline

func (*Pipeline) JsonArrAppend

func (processor *Pipeline) JsonArrAppend(ctx context.Context, key string, path string, args ...interface{}) *redis.IntCmd

func (*Pipeline) JsonArrIndex

func (processor *Pipeline) JsonArrIndex(ctx context.Context, key string, path string, value interface{}, startAndStop ...interface{}) *redis.IntCmd

func (*Pipeline) JsonArrInsert

func (processor *Pipeline) JsonArrInsert(ctx context.Context, key string, path string, index int, values ...interface{}) *redis.IntCmd

func (*Pipeline) JsonArrLen

func (processor *Pipeline) JsonArrLen(ctx context.Context, key string, path string) *redis.IntCmd

func (*Pipeline) JsonArrPop

func (processor *Pipeline) JsonArrPop(ctx context.Context, key string, path string, index int) *redis.StringCmd

func (*Pipeline) JsonArrTrim

func (processor *Pipeline) JsonArrTrim(ctx context.Context, key string, path string, start int, stop int) *redis.IntCmd

func (*Pipeline) JsonDel

func (processor *Pipeline) JsonDel(ctx context.Context, key string, args ...interface{}) *redis.IntCmd

func (*Pipeline) JsonGet

func (processor *Pipeline) JsonGet(ctx context.Context, key string, args ...interface{}) *redis.StringCmd

func (*Pipeline) JsonMGet

func (processor *Pipeline) JsonMGet(ctx context.Context, key string, args ...interface{}) *redis.StringSliceCmd

func (*Pipeline) JsonNumIncrBy

func (processor *Pipeline) JsonNumIncrBy(ctx context.Context, key string, path string, value int) *redis.StringCmd

func (*Pipeline) JsonNumMultBy

func (processor *Pipeline) JsonNumMultBy(ctx context.Context, key string, path string, value int) *redis.StringCmd

func (*Pipeline) JsonObjKeys

func (processor *Pipeline) JsonObjKeys(ctx context.Context, key string, path string) *redis.StringSliceCmd

func (*Pipeline) JsonObjLen

func (processor *Pipeline) JsonObjLen(ctx context.Context, key string, path string) *redis.IntCmd

func (*Pipeline) JsonSet

func (processor *Pipeline) JsonSet(ctx context.Context, key string, path string, json string, args ...interface{}) *redis.StatusCmd

func (*Pipeline) JsonStrAppend

func (processor *Pipeline) JsonStrAppend(ctx context.Context, key string, path string, value string) *redis.IntCmd

func (*Pipeline) JsonStrLen

func (processor *Pipeline) JsonStrLen(ctx context.Context, key string, path string) *redis.IntCmd

func (*Pipeline) JsonType

func (processor *Pipeline) JsonType(ctx context.Context, key string, path string) *redis.StringCmd

func (*Pipeline) Pipeline

func (pl *Pipeline) Pipeline() *Pipeline

type RedisProcessor

type RedisProcessor interface {
	Process(context.Context, redis.Cmder) error
}

RedisProcessor is redis client or pipeline instance that will process a command