debouncer

Feb 29, 2024

Changes in this version

+ type GobSerializer struct

+ func NewGobSerializer[V any]() *GobSerializer[V]

+ func (s *GobSerializer[V]) Deserilize(data []byte) (V, error)

+ func (s *GobSerializer[V]) Serialize(value V) ([]byte, error)

+ type JSONSerializer struct

+ func (JSONSerializer[V]) Deserilize(data []byte) (V, error)

+ func (JSONSerializer[V]) Serialize(value V) ([]byte, error)

Aug 7, 2022

Changes in this version

type Local

+ Cache suppressor.Cache

Aug 3, 2022

Changes in this version

type Distributed

+ Serializer Serializer

+ type Serializer interface

+ Deserilize func([]byte) (any, error)

+ Serialize func(any) ([]byte, error)

Jul 21, 2022

Changes in this version

+ type Config struct

+ type Distributed struct

+ Cache adapters.Cache

+ Locker adapters.LockFactory

+ Retry time.Duration

+ TTL time.Duration

+ type Local struct

+ Capacity int

+ Policy cache.EvictionPolicy

+ TTL time.Duration

Oct 19, 2021

Changes in this version

+ type CacheDriver int

+ const Memcached

+ const Redis

+ type Closure func() (interface{}, error)

+ type Debouncer struct

+ func NewDebouncer(impl CacheDriver, dsn string, localCacheTTL, distributedCacheTTL time.Duration) (*Debouncer, error)

+ func (d *Debouncer) Do(key string, duration time.Duration, closure Closure) (interface{}, error)

+ type DistributedGroup struct

+ func (g *DistributedGroup) Do(key string, duration time.Duration, closure Closure) (interface{}, error)