cache

README

Cache

用于定时或者条件更新数据. 例如: 1.爬虫请求页面时间或者某个值 2.请求某表的内容信息, 减少频繁操作

使用方法

cache := New(func() interface{} {
    resp, _ := gcurl.Execute(`curl "http://httpbin.org/uuid"`)
    return string(resp.Content())
}) // 创建 cache 并添加请求方法. 默认为异步更新. 当到触发条件的时间. 返回值还是上次值. 更新完后再次调用才是最新值. cache.SetBlock 可以用这个函数设置为阻塞. 更新会让更新方法彻底完成后. 返回值.
cache.SetUpdateInterval(time.Millisecond * 50) // 设置更新时间
// cache.Update() 主动更新.  
log.Println(cache.Value()) // { "uuid": "fbbea7fc-3a71-4e65-bc18-6642eddf83a7" }
time.Sleep(time.Millisecond * 50)
log.Println(cache.Value()) // { "uuid": "125c0d4d-e598-4b37-b0da-c928d44b703d" }

Documentation

Overview

Package cache 缓存 异步更新

Index

• type Cache
  • func New(interval time.Duration, u UpdateMehtod) Cache
  • func NewBlockCache(interval time.Duration, u UpdateMehtod) Cache
• type CacheBlock
  • func (cache *CacheBlock) Destroy()
  • func (cache *CacheBlock) GetUpdate() time.Time
  • func (cache *CacheBlock) SetOnUpdateError(errFunc func(err interface{}))
  • func (cache *CacheBlock) SetShare(share interface{})
  • func (cache *CacheBlock) Value() interface{}
• type CacheInterval
  • func (cache *CacheInterval) Destroy()
  • func (cache *CacheInterval) GetUpdate() time.Time
  • func (cache *CacheInterval) SetOnUpdateError(errFunc func(err interface{}))
  • func (cache *CacheInterval) SetShare(share interface{})
  • func (cache *CacheInterval) Value() interface{}
• type UpdateMehtod

Types

type Cache

type Cache interface {
	SetShare(share interface{})
	SetOnUpdateError(func(err interface{}))
	Destroy()
	Value() interface{}
	GetUpdate() time.Time
}

func New

func New(interval time.Duration, u UpdateMehtod) Cache

New 创建一个Cache对象

func NewBlockCache

func NewBlockCache(interval time.Duration, u UpdateMehtod) Cache

NewBlockCache 创建一个Cache对象

type CacheBlock

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

CacheBlock 缓存

func (*CacheBlock) Destroy

func (cache *CacheBlock) Destroy()

Destroy 异步更新必须调用Destroy, 销毁对象

func (*CacheBlock) GetUpdate

func (cache *CacheBlock) GetUpdate() time.Time

Value 获取缓存的值

func (*CacheBlock) SetOnUpdateError

func (cache *CacheBlock) SetOnUpdateError(errFunc func(err interface{}))

SetOnUpdateError 默认false

func (*CacheBlock) SetShare

func (cache *CacheBlock) SetShare(share interface{})

func (*CacheBlock) Value

func (cache *CacheBlock) Value() interface{}

Value 获取缓存的值

type CacheInterval

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

CacheInterval 缓存

func (*CacheInterval) Destroy

func (cache *CacheInterval) Destroy()

Destroy 异步更新必须调用Destroy, 销毁对象

func (*CacheInterval) GetUpdate

func (cache *CacheInterval) GetUpdate() time.Time

Value 获取缓存的值

func (*CacheInterval) SetOnUpdateError

func (cache *CacheInterval) SetOnUpdateError(errFunc func(err interface{}))

SetOnUpdateError 默认false

func (*CacheInterval) SetShare

func (cache *CacheInterval) SetShare(share interface{})

func (*CacheInterval) Value

func (cache *CacheInterval) Value() interface{}

Value 获取缓存的值

type UpdateMehtod

type UpdateMehtod func(share interface{}) interface{}

UpdateMehtod 更新方法