cache

Apr 14, 2021

Changes in this version

type Cache

+ func (c *Cache) ActiveUpdate()

type Option

+ func WithLimiterTimeout(timeout time.Duration) Option

+ func WithLockTimeout(timeout time.Duration) Option

+ func WithQueryAutoUpdateCacheTimeout(timeout time.Duration) Option

type Options

+ QueryAutoUpdateCacheTimeout time.Duration

+ QueryLimiterTimeout time.Duration

+ QueryLockTimeout time.Duration

Mar 27, 2021

Changes in this version

+ var Defaultopt = Options

+ var ErrAutoUpdateAlreadyStarted = errors.New("已经启动了自动更新任务")

+ var ErrAutoUpdateNeedUpdatePeriod = errors.New("自动更新需要设置UpdatePeriod")

+ var ErrLimiterNotAllow = errors.New("限制器不允许执行更新任务")

+ var ErrUpdateFuncAlreadyRegisted = errors.New("缓存函数已经注册")

+ type Cache struct

+ func New(k *clientkey.ClientKey, opts ...Option) *Cache

+ func (c *Cache) AutoUpdate() error

+ func (c *Cache) Get(ctx context.Context, force ForceLevelType) ([]byte, error)

+ func (c *Cache) RegistUpdateFunc(fn Cachefunc) error

+ func (c *Cache) StopAutoUpdate() error

+ func (c *Cache) Update(ctx context.Context, force ForceLevelType) ([]byte, error)

+ type Cachefunc func() ([]byte, error)

+ type EmptyResCacheModeType uint16

+ const EmptyResCacheMode__DELETE

+ const EmptyResCacheMode__IGNORE

+ const EmptyResCacheMode__SAVE

+ type ForceLevelType uint16

+ const ForceLevel__CONSTRAINT

+ const ForceLevel__NOCONSTRAINT

+ const ForceLevel__STRICT

+ type Option interface

+ Apply func(*Options)

+ func WithLimiter(limiter h.CanBeLimiter) Option

+ func WithLock(lock h.Canlock) Option

+ func WithUpdatePeriod(updatePeriod string) Option

+ type Options struct

+ EmptyResCacheMode EmptyResCacheModeType

+ Limiter h.CanBeLimiter

+ Lock h.Canlock

+ UpdatePeriod string