cache

Documentation

Index

• type Adapter
• type AdapterQueue
• type ConsumerFunc
• type Memory
  • func (m *Memory) Append(name string, message Message) error
  • func (m *Memory) Connect() 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) HashDel(hk, key string) error
  • func (m *Memory) HashGet(hk, key string) (string, error)
  • func (m *Memory) Increase(key string) error
  • func (m *Memory) Register(name string, f ConsumerFunc)
  • func (m *Memory) Run()
  • func (m *Memory) Set(key string, val interface{}, expire int) error
  • func (m *Memory) Shutdown()
• type MemoryMessage
  • func (m *MemoryMessage) GetID() string
  • func (m *MemoryMessage) GetStream() string
  • func (m *MemoryMessage) GetValues() map[string]interface{}
  • func (m *MemoryMessage) SetID(id string)
  • func (m *MemoryMessage) SetStream(stream string)
  • func (m *MemoryMessage) SetValues(values map[string]interface{})
• type Message
• type Redis
  • func (r *Redis) Append(name string, message Message) error
  • func (r *Redis) Connect() 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) HashDel(hk, key string) error
  • func (r *Redis) HashGet(hk, key string) (string, error)
  • func (r *Redis) Increase(key string) error
  • func (r *Redis) Lock(key string, ttl int64, options *redislock.Options) (*redislock.Lock, error)
  • func (r *Redis) Register(name string, f ConsumerFunc)
  • func (r *Redis) Run()
  • func (r *Redis) Set(key string, val interface{}, expire int) error
  • func (r *Redis) Shutdown()
• type RedisMessage
  • func (m *RedisMessage) GetID() string
  • func (m *RedisMessage) GetStream() string
  • func (m *RedisMessage) GetValues() map[string]interface{}
  • func (m *RedisMessage) SetID(id string)
  • func (m *RedisMessage) SetStream(stream string)
  • func (m *RedisMessage) SetValues(values map[string]interface{})

Types

type Adapter

type Adapter interface {
	Connect() error
	Get(key string) (string, error)
	Set(key string, val interface{}, expire int) error
	Del(key string) error
	HashGet(hk, key string) (string, error)
	HashDel(hk, key string) error
	Increase(key string) error
	Decrease(key string) error
	Expire(key string, dur time.Duration) error
	AdapterQueue
}

type AdapterQueue

type AdapterQueue interface {
	Append(name string, message Message) error
	Register(name string, f ConsumerFunc)
	Run()
	Shutdown()
}

type ConsumerFunc

type ConsumerFunc func(Message) error

type Memory

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

func (*Memory) Append

func (m *Memory) Append(name string, message Message) error

func (*Memory) Connect

func (m *Memory) Connect() 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) HashDel

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

func (*Memory) HashGet

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

func (*Memory) Increase

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

func (*Memory) Register

func (m *Memory) Register(name string, f ConsumerFunc)

func (*Memory) Run

func (m *Memory) Run()

func (*Memory) Set

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

func (*Memory) Shutdown

func (m *Memory) Shutdown()

type MemoryMessage

type MemoryMessage struct {
	redisqueue.Message
}

func (*MemoryMessage) GetID

func (m *MemoryMessage) GetID() string

func (*MemoryMessage) GetStream

func (m *MemoryMessage) GetStream() string

func (*MemoryMessage) GetValues

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

func (*MemoryMessage) SetID

func (m *MemoryMessage) SetID(id string)

func (*MemoryMessage) SetStream

func (m *MemoryMessage) SetStream(stream string)

func (*MemoryMessage) SetValues

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

type Message

type Message interface {
	SetID(string)
	SetStream(string)
	SetValues(map[string]interface{})
	GetID() string
	GetStream() string
	GetValues() map[string]interface{}
}

type Redis

type Redis struct {
	ConnectOption   *redis.Options
	ConsumerOptions *redisqueue.ConsumerOptions
	ProducerOptions *redisqueue.ProducerOptions
	// contains filtered or unexported fields
}

Redis cache implement

func (*Redis) Append

func (r *Redis) Append(name string, message Message) error

func (*Redis) Connect

func (r *Redis) Connect() error

Connect Setup

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) 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) Increase

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

Increase

func (*Redis) Lock

func (r *Redis) Lock(key string, ttl int64, options *redislock.Options) (*redislock.Lock, error)

func (*Redis) Register

func (r *Redis) Register(name string, f ConsumerFunc)

func (*Redis) Run

func (r *Redis) Run()

func (*Redis) Set

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

Set value with key and expire time

func (*Redis) Shutdown

func (r *Redis) Shutdown()

type RedisMessage

type RedisMessage struct {
	redisqueue.Message
}

func (*RedisMessage) GetID

func (m *RedisMessage) GetID() string

func (*RedisMessage) GetStream

func (m *RedisMessage) GetStream() string

func (*RedisMessage) GetValues

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

func (*RedisMessage) SetID

func (m *RedisMessage) SetID(id string)

func (*RedisMessage) SetStream

func (m *RedisMessage) SetStream(stream string)

func (*RedisMessage) SetValues

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