cache

Dec 1, 2021

Changes in this version

type HTTP

+ Transport http.RoundTripper

+ func (h HTTP) RoundTrip(r *http.Request) (*http.Response, error)

+ func (h HTTP) RoundTripper(transport http.RoundTripper) http.RoundTripper

Nov 14, 2021

Changes in this version

type Cache

+ Clear func() error

+ Close func() error

+ Del func(keys ...string) error

type Hybrid

+ func (c *Hybrid) Clear() error

+ func (c *Hybrid) Close() error

+ func (c *Hybrid) Del(keys ...string) error

type Memory

+ func (c *Memory) Clear() error

+ func (c *Memory) Close() error

+ func (c *Memory) Del(keys ...string) error

type Redis

+ func (c *Redis) Clear() error

+ func (c *Redis) Close() error

+ func (c *Redis) Del(keys ...string) error

Nov 13, 2021

Changes in this version

+ var ErrNoCache = errors.New("hybridcache: no cache")

+ var ErrNotFound = errors.New("hybridcache: not found")

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

+ func IsDetached(ctx context.Context) bool

+ type Cache interface

+ Fetch func(key string) (value []byte, ttl time.Duration, err error)

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

+ Race func(key string, fn func() ([]byte, error), timeout time.Duration) ([]byte, error)

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

+ type Func struct

+ Cache Cache

+ FreshFor time.Duration

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

+ TTL time.Duration

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

+ WaitFor time.Duration

+ func NewFunc(c Cache, waitFor, freshFor, ttl time.Duration) *Func

+ func (f Func) Do(ctx context.Context, key string, fn func(context.Context) (interface{}, error), ...) (err error)

+ func (f Func) DoBytes(ctx context.Context, key string, fn func(context.Context) ([]byte, error)) (value []byte, err error)

+ type HTTP struct

+ AcceptRequest func(*http.Request) bool

+ AcceptResponse func(*http.Response) bool

+ Cache Cache

+ ErrorHandler func(http.ResponseWriter, *http.Request, error)

+ FreshFor time.Duration

+ RequestKey func(*http.Request) string

+ TTL time.Duration

+ WaitFor time.Duration

+ func NewHTTP(c Cache, waitFor, freshFor, ttl time.Duration) *HTTP

+ func (h HTTP) Handler(next http.Handler) http.Handler

+ type Hybrid struct

+ Downstream Cache

+ Upstream Cache

+ func NewHybrid(upstream, downstream Cache) *Hybrid

+ func (c *Hybrid) Fetch(key string) (value []byte, ttl time.Duration, err error)

+ func (c *Hybrid) Get(key string) (value []byte, err error)

+ func (c *Hybrid) Race(key string, fn func() ([]byte, error), timeout time.Duration) ([]byte, error)

+ func (c *Hybrid) Set(key string, value []byte, ttl time.Duration) error

+ type Memory struct

+ Cache *ristretto.Cache

+ MaxTTL time.Duration

+ func NewMemory(maxItems, maxSize int64, maxTTL time.Duration) *Memory

+ func (c *Memory) Fetch(key string) (value []byte, ttl time.Duration, err error)

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

+ func (c *Memory) Race(key string, fn func() ([]byte, error), _ time.Duration) ([]byte, error)

+ func (c *Memory) Set(key string, value []byte, ttl time.Duration) error

+ type Redis struct

+ DelayFunc func(tries int) time.Duration

+ ErrorMapper func(error) error

+ LockPrefix string

+ Pool *redis.Pool

+ Prefix string

+ SkipLock bool

+ SuppressionTTL time.Duration

+ func NewRedis(pool *redis.Pool) *Redis

+ func (c *Redis) Fetch(key string) (value []byte, ttl time.Duration, err error)

+ func (c *Redis) Get(key string) (res []byte, err error)

+ func (c *Redis) Race(key string, fn func() ([]byte, error), timeout time.Duration) (value []byte, err error)

+ func (c *Redis) Set(key string, value []byte, ttl time.Duration) error