Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

hacache

package

Go to main page

Versions in this module

v2

v2.3.2

Jul 12, 2023

v2.3.1

Dec 17, 2021

v2.3.0

Aug 4, 2021

Changes in this version

+ const GMFnRunConcurrency

+ type GaugeMetricType string

type Stats

+ FnRunConcurrency int32

+ func (s *Stats) ExportGauge() map[GaugeMetricType]int32

+ func (s *Stats) Gauge(m GaugeMetricType, i int32)

v2.2.2

Apr 12, 2021

v2.2.1

Jan 27, 2021

v2.2.0

Jan 13, 2021

Changes in this version

+ type FnResult struct

+ Err error

+ Ignore bool

+ Val interface{}

v2.1.1

Jan 12, 2021

Changes in this version

+ const SkipCache

+ var CurrentStats = new(Stats)

+ var ErrorFnRunLimited = errors.New("ha-cache fn run rate limited")

+ var ErrorInvalidCacheKey = errors.New("invalid cache key")

+ func CacheResult(ctx context.Context) bool

+ func IgnoreFuncResult(ctx context.Context)

+ func WrapCacheContext(ctx context.Context) context.Context

+ type CacheContext struct

+ func (ctx *CacheContext) CacheResult() bool

+ func (ctx *CacheContext) IgnoreResult()

+ type CachedValue struct

+ Bytes []byte

+ CreateTS int64

+ type Encoder interface

+ Decode func(b []byte) (interface{}, error)

+ Encode func(v interface{}) ([]byte, error)

+ NewValue func() interface{}

+ type Event interface

+ type EventCacheExpired struct

+ Args []interface{}

+ type EventCacheInvalid struct

+ Data interface{}

+ Key string

+ type HaCache struct

+ func New(opt *Options) (*HaCache, error)

+ func (hc *HaCache) Do(args ...interface{}) (interface{}, error)

+ func (hc *HaCache) FnRun(background bool, args ...interface{}) (interface{}, error)

+ func (hc *HaCache) GenCacheKey(args ...interface{}) string

+ func (hc *HaCache) Get(key string) (*CachedValue, error)

+ func (hc *HaCache) Set(key string, data interface{}) error

+ func (hc *HaCache) Trigger(event Event)

+ type HaEncoder struct

+ NewValueFn func() interface{}

+ func NewEncoder(n func() interface{}) *HaEncoder

+ func (enc *HaEncoder) Decode(b []byte) (interface{}, error)

+ func (enc *HaEncoder) Encode(v interface{}) ([]byte, error)

+ func (enc *HaEncoder) NewValue() interface{}

+ type MetricType string

+ const MEventChanBlocked

+ const MFnRun

+ const MFnRunErr

+ const MFnRunLimited

+ const MHit

+ const MInvalidReturned

+ const MMiss

+ const MMissExpired

+ const MMissInvalid

+ const MSkip

+ const MWorkerPanic

+ type Options struct

+ Encoder Encoder

+ EventBufferSize int32

+ Expiration time.Duration

+ Fn interface{}

+ FnRunLimit int32

+ GenKeyFn interface{}

+ Logger *zap.Logger

+ MaxAcceptableExpiration time.Duration

+ Storage Storage

+ func (opt *Options) Init()

+ type Stats struct

+ EventChanBlocked int32

+ Exporter *statsd.Client

+ FnRun int32

+ FnRunErr int32

+ FnRunLimited int32

+ Hit int32

+ InvalidReturned int32

+ Miss int32

+ MissExpired int32

+ MissInvalid int32

+ Skip int32

+ WorkerPanic int32

+ func (s *Stats) Export() map[MetricType]int32

+ func (s *Stats) Incr(m MetricType, i int32)

+ func (s *Stats) Run()

+ func (s *Stats) Setup(client *statsd.Client)

+ type Storage interface

+ Get func(key string) ([]byte, error)

+ Set func(key string, value []byte, expiration time.Duration) error

Other modules containing this package

github.com/xiachufang/pkg