cache

Documentation

Index

• type Memory
  • func NewMemory() *Memory
  • 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) 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{})

Types

type Memory

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

func NewMemory

func NewMemory() *Memory

NewMemory memory模式

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

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

func (*Memory) String

func (*Memory) String() string

type Message

type Message struct {
	queue.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{})