cache

Documentation

Index

• type Memory
  • func NewMemory() *Memory
  • func (m *Memory) BRPop(timeout time.Duration, keys ...string) ([]string, error)
  • func (m *Memory) Decrease(key string) error
  • func (m *Memory) Del(key string) error
  • func (m *Memory) Expire(key string, dur time.Duration) error
  • func (m *Memory) Get(key string) (string, error)
  • func (m *Memory) HExists(hk, key string) (bool, error)
  • func (m *Memory) HIncrBy(key, field string, increment int) (int64, error)
  • func (m *Memory) HashDel(hk, key string) error
  • func (m *Memory) HashGet(hk, key string) (string, error)
  • func (m *Memory) HashGetAll(hk string) (map[string]string, error)
  • func (m *Memory) HashSet(key string, val ...interface{}) error
  • func (m *Memory) Increase(key string) error
  • func (m *Memory) LPush(key string, values ...interface{}) (int64, error)
  • func (r *Memory) LRange(key string, start, stop int64) ([]string, error)
  • func (m *Memory) RPop(key string) (string, error)
  • func (m *Memory) RPush(key string, values ...interface{}) error
  • func (m *Memory) ScanKey(key string) []string
  • func (m *Memory) Set(key string, val interface{}, expire int) error
  • func (*Memory) String() string
• type Message
  • func (m *Message) GetID() string
  • func (m *Message) GetPrefix() (prefix string)
  • func (m *Message) GetStream() string
  • func (m *Message) GetValues() map[string]interface{}
  • func (m *Message) SetID(id string)
  • func (m *Message) SetPrefix(prefix string)
  • func (m *Message) SetStream(stream string)
  • func (m *Message) SetValues(values map[string]interface{})
• type Redis
  • func NewRedis(client *redis.Client, options *redis.Options) (*Redis, error)
  • func (r *Redis) BRPop(timeout time.Duration, keys ...string) ([]string, error)
  • func (r *Redis) Decrease(key string) error
  • func (r *Redis) Del(key string) error
  • func (r *Redis) Expire(key string, dur time.Duration) error
  • func (r *Redis) Get(key string) (string, error)
  • func (r *Redis) GetClient() *redis.Client
  • func (r *Redis) HExists(hk, key string) (bool, error)
  • func (r *Redis) HIncrBy(key, field string, increment int) (int64, error)
  • func (r *Redis) HashDel(hk, key string) error
  • func (r *Redis) HashGet(hk, key string) (string, error)
  • func (r *Redis) HashGetAll(hk string) (map[string]string, error)
  • func (r *Redis) HashSet(key string, val ...interface{}) error
  • func (r *Redis) Increase(key string) error
  • func (r *Redis) LPush(key string, values ...interface{}) (int64, error)
  • func (r *Redis) LRange(key string, start, stop int64) ([]string, error)
  • func (r *Redis) RPop(key string) (string, error)
  • func (r *Redis) RPush(key string, values ...interface{}) error
  • func (r *Redis) ScanKey(key string) []string
  • func (r *Redis) Set(key string, val interface{}, expire int) error
  • func (*Redis) String() string

Types

type Memory

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

func NewMemory

func NewMemory() *Memory

NewMemory memory模式

func (*Memory) BRPop

func (m *Memory) BRPop(timeout time.Duration, keys ...string) ([]string, error)

func (*Memory) Decrease

func (m *Memory) Decrease(key string) error

func (*Memory) Del

func (m *Memory) Del(key string) error

func (*Memory) Expire

func (m *Memory) Expire(key string, dur time.Duration) error

func (*Memory) Get

func (m *Memory) Get(key string) (string, error)

func (*Memory) HExists

func (m *Memory) HExists(hk, key string) (bool, error)

func (*Memory) HIncrBy

func (m *Memory) HIncrBy(key, field string, increment int) (int64, error)

func (*Memory) HashDel

func (m *Memory) HashDel(hk, key string) error

func (*Memory) HashGet

func (m *Memory) HashGet(hk, key string) (string, error)

func (*Memory) HashGetAll

func (m *Memory) HashGetAll(hk string) (map[string]string, error)

func (*Memory) HashSet

func (m *Memory) HashSet(key string, val ...interface{}) error

func (*Memory) Increase

func (m *Memory) Increase(key string) error

func (*Memory) LPush

func (m *Memory) LPush(key string, values ...interface{}) (int64, error)

func (*Memory) LRange

func (r *Memory) LRange(key string, start, stop int64) ([]string, error)

func (*Memory) RPop

func (m *Memory) RPop(key string) (string, error)

func (*Memory) RPush

func (m *Memory) RPush(key string, values ...interface{}) error

func (*Memory) ScanKey

func (m *Memory) ScanKey(key string) []string

func (*Memory) Set

func (m *Memory) Set(key string, val interface{}, expire int) error

func (*Memory) String

func (*Memory) String() string

type Message

type Message struct {
	redisqueue.Message
}

func (*Message) GetID

func (m *Message) GetID() string

func (*Message) GetPrefix

func (m *Message) GetPrefix() (prefix string)

func (*Message) GetStream

func (m *Message) GetStream() string

func (*Message) GetValues

func (m *Message) GetValues() map[string]interface{}

func (*Message) SetID

func (m *Message) SetID(id string)

func (*Message) SetPrefix

func (m *Message) SetPrefix(prefix string)

func (*Message) SetStream

func (m *Message) SetStream(stream string)

func (*Message) SetValues

func (m *Message) SetValues(values map[string]interface{})

type Redis

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

Redis cache implement

func NewRedis

func NewRedis(client *redis.Client, options *redis.Options) (*Redis, error)

NewRedis redis模式

func (*Redis) BRPop

func (r *Redis) BRPop(timeout time.Duration, keys ...string) ([]string, error)

列表尾部读取(阻塞)

func (*Redis) Decrease

func (r *Redis) Decrease(key string) error

func (*Redis) Del

func (r *Redis) Del(key string) error

Del delete key in redis

func (*Redis) Expire

func (r *Redis) Expire(key string, dur time.Duration) error

Set ttl

func (*Redis) Get

func (r *Redis) Get(key string) (string, error)

Get from key

func (*Redis) GetClient

func (r *Redis) GetClient() *redis.Client

GetClient 暴露原生client

func (*Redis) HExists

func (r *Redis) HExists(hk, key string) (bool, error)

HExists hash表中是否存在key

func (*Redis) HIncrBy

func (r *Redis) HIncrBy(key, field string, increment int) (int64, error)

func (*Redis) HashDel

func (r *Redis) HashDel(hk, key string) error

HashDel delete key in specify redis's hashtable

func (*Redis) HashGet

func (r *Redis) HashGet(hk, key string) (string, error)

HashGet from key

func (*Redis) HashGetAll

func (r *Redis) HashGetAll(hk string) (map[string]string, error)

HashGetAll from key

func (*Redis) HashSet

func (r *Redis) HashSet(key string, val ...interface{}) error

func (*Redis) Increase

func (r *Redis) Increase(key string) error

Increase

func (*Redis) LPush

func (r *Redis) LPush(key string, values ...interface{}) (int64, error)

列表头部添加

func (*Redis) LRange

func (r *Redis) LRange(key string, start, stop int64) ([]string, error)

func (*Redis) RPop

func (r *Redis) RPop(key string) (string, error)

列表尾部读取(非阻塞)

func (*Redis) RPush

func (r *Redis) RPush(key string, values ...interface{}) error

列表尾部添加

func (*Redis) ScanKey

func (r *Redis) ScanKey(key string) []string

func (*Redis) Set

func (r *Redis) Set(key string, val interface{}, expire int) error

Set value with key and expire time

func (*Redis) String

func (*Redis) String() string