cache

Jan 21, 2026

Changes in this version

type PageSorter

+ Expr string

Dec 27, 2025

Changes in this version

+ type AggField struct

+ Agg Agg

+ Alias string

+ Field string

type Cache

+ Items func() map[string]T

+ Keys func() ([]string, error)

type GoCache

+ func (g *GoCache[T]) Items() map[string]T

+ func (g *GoCache[T]) Keys() ([]string, error)

type JSONFileCache

+ func (c *JSONFileCache[T]) Items() map[string]T

+ func (c *JSONFileCache[T]) Keys() ([]string, error)

+ type PageGroupItem struct

+ Group map[string]string

+ Value map[string]float64

type Pager

+ GroupByFields func(conditions map[string]any, groupFields []string, aggFields []AggField, ...) ([]*PageGroupItem, error)

type RedisCache

+ func (r *RedisCache[T]) AddDelayed(queue string, value T, score float64) error

+ func (r *RedisCache[T]) Items() map[string]T

+ func (r *RedisCache[T]) Keys() ([]string, error)

+ func (r *RedisCache[T]) LPop(queue string) (value T, err error)

+ func (r *RedisCache[T]) PopDueDelayed(queue string, now float64, limit int) ([]T, error)

type SQLiteCache

+ func (c *SQLiteCache[T]) Items() map[string]T

+ func (c *SQLiteCache[T]) Keys() ([]string, error)

type SQLiteCachePage

+ func (c *SQLiteCachePage[T]) GroupByFields(conditions map[string]any, groupFields []string, aggFields []AggField, ...) ([]*PageGroupItem, error)

Aug 5, 2025

Changes in this version

type RedisCache

+ func (r *RedisCache[T]) BRPopCtx(ctx context.Context, timeout time.Duration, queue string) (value T, err error)

+ func (r *RedisCache[T]) GetCtx() context.Context

type RedisConfig

+ PoolSize int

Jun 25, 2025

Changes in this version

+ type Agg string

+ const AggAvg

+ const AggCount

+ const AggMax

+ const AggMin

+ const AggSum

+ const AggTotal

type Granularity

+ const Granularity10Minutes

+ const Granularity30Minutes

+ const Granularity5Minutes

Jun 3, 2025

Changes in this version

+ type Granularity string

+ const GranularityDay

+ const GranularityHour

+ const GranularityMinute

+ const GranularityMonth

+ const GranularityWeek

+ const GranularityYear

type PageCache

+ func (p *PageCache[T]) JSON() string

+ type PageTimeItem struct

+ At string

+ Value map[string]float64

+ type Pager interface

+ Count func(conditions map[string]any) (int64, error)

+ Delete func(conditions map[string]any) error

+ Find func(page, size int64, conditions map[string]any, sort ...PageSorter) (*PageCache[T], error)

+ Get func(conditions map[string]any) (*T, error)

+ GroupByTime func(conditions map[string]any, from, to time.Time, granularity Granularity, ...) ([]*PageTimeItem, error)

+ Put func(value T) error

+ Update func(conditions map[string]any, value *T) error

+ func NewPager[T any](ctx context.Context, t Type, args ...any) Pager[T]

type SQLiteCachePage

+ func (c *SQLiteCachePage[T]) Delete(conditions map[string]any) error

+ func (c *SQLiteCachePage[T]) GroupByTime(conditions map[string]any, from, to time.Time, granularity Granularity, ...) ([]*PageTimeItem, error)

May 4, 2025

Changes in this version

+ type PageCache struct

+ Items []*T

+ Page int64

+ Size int64

+ Total int64

+ type PageSorter struct

+ Asc bool

+ SortField string

+ func PageSorterAsc(field string) PageSorter

+ func PageSorterDesc(field string) PageSorter

+ type PageStorage interface

+ Count func(conditions map[string]any) (int64, error)

+ Find func(page, size int64, conditions map[string]any, sort ...PageSorter) (*PageCache[T], error)

+ Get func(conditions map[string]any) (*T, error)

+ Put func(value T) error

+ Update func(conditions map[string]any, value *T) error

+ func NewPageStorage[T any](ctx context.Context, t Type, args ...any) PageStorage[T]

+ type SQLiteCache struct

+ func NewSQLiteCache[T any](cacheType string) (*SQLiteCache[T], error)

+ func (c *SQLiteCache[T]) BRPop(timeout time.Duration, key string) (T, error)

+ func (c *SQLiteCache[T]) Del(key string) error

+ func (c *SQLiteCache[T]) Exists(key string) (bool, error)

+ func (c *SQLiteCache[T]) Expire(key string, expiration time.Duration) error

+ func (c *SQLiteCache[T]) Flush() error

+ func (c *SQLiteCache[T]) Get(key string) (T, error)

+ func (c *SQLiteCache[T]) Incr(key string) (int64, error)

+ func (c *SQLiteCache[T]) IsInitialized() bool

+ func (c *SQLiteCache[T]) RPush(key string, value T) error

+ func (c *SQLiteCache[T]) Set(key string, value T, expiration time.Duration) error

+ type SQLiteCachePage struct

+ func NewSQLiteCachePage[T any](name string) (*SQLiteCachePage[T], error)

+ func (c *SQLiteCachePage[T]) Count(conditions map[string]any) (int64, error)

+ func (c *SQLiteCachePage[T]) Find(page, size int64, conditions map[string]any, sorts ...PageSorter) (*PageCache[T], error)

+ func (c *SQLiteCachePage[T]) Get(conditions map[string]any) (*T, error)

+ func (c *SQLiteCachePage[T]) Put(value T) error

+ func (c *SQLiteCachePage[T]) Update(conditions map[string]any, value *T) error

type Type

+ const Sqlite

Apr 24, 2025

Changes in this version

type Cache

+ func New[T any](t Type, args ...any) Cache[T]

+ Flush func() error

type GoCache

+ func (g *GoCache[T]) Flush() error

+ type JSONFileCache struct

+ func NewJSONCache[T any](cacheType string) (*JSONFileCache[T], error)

+ func (c *JSONFileCache[T]) BRPop(timeout time.Duration, key string) (value T, err error)

+ func (c *JSONFileCache[T]) Del(key string) error

+ func (c *JSONFileCache[T]) Exists(key string) (bool, error)

+ func (c *JSONFileCache[T]) Expire(key string, expiration time.Duration) error

+ func (c *JSONFileCache[T]) Flush() error

+ func (c *JSONFileCache[T]) Get(key string) (T, error)

+ func (c *JSONFileCache[T]) Incr(key string) (int64, error)

+ func (c *JSONFileCache[T]) IsInitialized() bool

+ func (c *JSONFileCache[T]) RPush(key string, value T) error

+ func (c *JSONFileCache[T]) Set(key string, value T, expiration time.Duration) error

type RedisCache

+ func (r *RedisCache[T]) Flush() error

+ type Type string

+ const JSON

+ const Memory

+ const Redis

Dec 16, 2024

Changes in this version

+ var ErrCacheMiss = errors.New("cache miss")

+ func RestRedisInstance()

type Cache

+ BRPop func(timeout time.Duration, key string) (value interface{}, err error)

+ Del func(key string) error

+ Exists func(key string) (bool, error)

+ Expire func(key string, expiration time.Duration) error

+ Incr func(key string) (int64, error)

+ IsInitialized func() bool

+ RPush func(key string, value T) error

type GoCache

+ func (g *GoCache[T]) BRPop(_ time.Duration, key string) (value interface{}, err error)

+ func (g *GoCache[T]) Del(key string) error

+ func (g *GoCache[T]) Exists(key string) (bool, error)

+ func (g *GoCache[T]) Expire(key string, expiration time.Duration) error

+ func (g *GoCache[T]) Incr(key string) (int64, error)

+ func (g *GoCache[T]) IsInitialized() bool

+ func (g *GoCache[T]) RPush(key string, value T) error

+ type Queue struct

+ Items []T

type RedisCache

+ func (r *RedisCache) BRPop(timeout time.Duration, key string) (value interface{}, err error)

+ func (r *RedisCache) Del(key string) error

+ func (r *RedisCache) Exists(key string) (bool, error)

+ func (r *RedisCache) Expire(key string, expiration time.Duration) error

+ func (r *RedisCache) Incr(key string) (int64, error)

+ func (r *RedisCache) IsInitialized() bool

+ func (r *RedisCache) RPush(key string, value interface{}) error

Dec 11, 2024

Changes in this version

+ var SimpleTool = func(ctx *gin.Context) *Tool[any]

+ type Cache interface

+ Delete func(key string) error

+ Get func(key string) (T, error)

+ Set func(key string, value T, expiration time.Duration) error

+ type GoCache struct

+ func NewGoCache[T any](defaultExpiration, cleanupInterval time.Duration) *GoCache[T]

+ func (g *GoCache[T]) Delete(key string) error

+ func (g *GoCache[T]) Get(key string) (T, error)

+ func (g *GoCache[T]) Set(key string, value T, expiration time.Duration) error

+ type LoaderFunc func(key string) (T, error)

+ type RedisCache struct

+ Client *redis.Client

+ Ctx context.Context

+ var RedisInstance *RedisCache

+ func GetRedisInstance() *RedisCache

+ func NewRedisCache(cfg RedisConfig) (*RedisCache, error)

+ func (r *RedisCache) Delete(key string) error

+ func (r *RedisCache) Get(key string) (interface{}, error)

+ func (r *RedisCache) Set(key string, value interface{}, expiration time.Duration) error

+ type RedisConfig struct

+ Addr string

+ DB int

+ Password string

+ type Tool struct

+ Ctx *gin.Context

+ func NewCacheTool[T any](ctx *gin.Context, caches []Cache[T], loader LoaderFunc[T]) *Tool[T]

+ func (c *Tool[T]) Delete(key string) error

+ func (c *Tool[T]) Get(key string, expiration time.Duration) (T, error)

+ func (c *Tool[T]) Set(key string, value T, expiration time.Duration) error