cachecalc

Oct 27, 2023

Changes in this version

type CacheEntry

+ CalcDuration time.Duration

type CachedCalcOpts

+ CalcTime time.Duration

type ExternalCache

+ func NewPostgresCache(ctx context.Context, dbUrl string) (ExternalCache, error)

+ Close func() error

+ type PostgresCache struct

+ func (p *PostgresCache) Close() error

+ func (p *PostgresCache) Del(ctx context.Context, key string) error

+ func (p *PostgresCache) Get(ctx context.Context, key string) (value []byte, exists bool, err error)

+ func (p *PostgresCache) Set(ctx context.Context, key string, value []byte, ttl time.Duration) error

+ func (p *PostgresCache) SetNX(ctx context.Context, key string, value []byte, ttl time.Duration) (keyCreated bool, err error)

type RedisExternalCache

+ func (r *RedisExternalCache) Close() error

type SQLiteCache

+ func (c *SQLiteCache) Close() error

Oct 11, 2023

Changes in this version

+ func DeserializeValue(buf []byte, valPtr any) error

Jun 11, 2023

Changes in this version

+ type CacheEntry struct

+ Err error

+ Expire time.Time

+ Refresh time.Time

+ Request time.Time

+ Value []byte

type CachedCalculations

+ func (cc *CachedCalculations) RemoveEntries(filter func(key string, entry *CacheEntry) bool)

Jun 11, 2023

Changes in this version

+ func GetCachedCalcOpt(ctx context.Context, key string, ...) (T, error)

+ func GetCachedCalcOptX(cc *CachedCalculations, ctx context.Context, key string, ...) (result T, err error)

+ type CachedCalcOpts struct

+ MaxTTL time.Duration

+ MinTTL time.Duration

+ type CalculateValueAndOpt func(context.Context) (any, CachedCalcOpts, error)

May 9, 2023

Changes in this version

+ var DefaultCCs = NewCachedCalculations(4, nil)

+ func GetCachedCalc(ctx context.Context, key string, minTTL, maxTTL time.Duration, ...) (result T, err error)

+ func GetCachedCalcX(cc *CachedCalculations, ctx context.Context, key string, ...) (result T, err error)

+ func GetRedis(ctx context.Context) (*redis.Client, error)

+ type CachedCalculation struct

+ Calculate CalculateValue

+ Key string

+ LimitWorker bool

+ MaxTTL time.Duration

+ MinTTL time.Duration

+ type CachedCalculations struct

+ func NewCachedCalculations(maxWorkers int, externalCache ExternalCache) *CachedCalculations

+ func (cc *CachedCalculations) Close()

+ type CalculateValue func(context.Context) (any, error)

+ type ExternalCache interface

+ Del func(ctx context.Context, key string) error

+ Get func(ctx context.Context, key string) (value []byte, exists bool, err error)

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

+ SetNX func(ctx context.Context, key string, value []byte, ttl time.Duration) (keyCreated bool, err error)

+ func NewRedisCache(ctx context.Context) (ExternalCache, error)

+ type RedisExternalCache struct

+ func (r *RedisExternalCache) Del(ctx context.Context, key string) error

+ func (r *RedisExternalCache) Get(ctx context.Context, key string) (value []byte, exists bool, err error)

+ func (r *RedisExternalCache) Set(ctx context.Context, key string, value []byte, ttl time.Duration) error

+ func (r *RedisExternalCache) SetNX(ctx context.Context, key string, value []byte, ttl time.Duration) (bool, error)

+ type SQLiteCache struct

+ func NewSQLiteCache(dbPath string) (*SQLiteCache, error)

+ func (c *SQLiteCache) Del(ctx context.Context, key string) error

+ func (c *SQLiteCache) Get(ctx context.Context, key string) (value []byte, exists bool, err error)

+ func (c *SQLiteCache) Set(ctx context.Context, key string, value []byte, ttl time.Duration) error

+ func (c *SQLiteCache) SetNX(ctx context.Context, key string, value []byte, ttl time.Duration) (keyCreated bool, err error)