Versions in this module Expand all Collapse all v0 v0.1.1 Aug 19, 2026 Changes in this version + type BatchDeleteRequest struct + Filters []interface{} + IDs []interface{} + Soft bool + type BatchIncrementRequest struct + Column string + Filters []interface{} + IDs []interface{} + IsDecr bool + Value interface{} + type BatchUpdateRequest struct + Filters []interface{} + Updates map[string]interface{} + type BatchUpsertRequest struct + BatchSize int + ConflictColumns []string + Data []T + UpdateColumns []string + type CountRequest struct + Filters []filter_translator.FilterParam + type CountResponse struct + Code int + Count int64 + Message string + type DeleteRequest struct + ID interface{} + Soft bool + type HTTPRouterManager struct + func NewHTTPRouterManagerFromModel[T any](model T) *HTTPRouterManager[T] + func NewHTTPRouterManager[T any](svc *serviceManager.ServiceManager[T]) *HTTPRouterManager[T] + type IncrementRequest struct + Column string + ID interface{} + IsDecr bool + Value interface{} + type InvalidateRequest struct + Keys []string + Pattern string + type InvalidateResponse struct + Code int + Count int + Message string + type LookupCountRequest struct + Filters []filter_translator.FilterParam + KeyPattern string + UseCustomFilter bool + type LookupCountResponse struct + Code int + Count int + Message string + type LookupRequest struct + FallbackToDB bool + Filters []filter_translator.FilterParam + KeyPattern string + UseCustomFilter bool + type LookupResponse struct + Code int + Count int + Data map[string]*T + Keys []string + Message string + type LookupRouterGroup struct + RouterGroup *gin.RouterGroup + Service *service.ServiceManager[T] + TranslatorRegistry *filter_translator.RedisTranslatorRegistry + func NewLookupRouterGroup[T any](rg *gin.RouterGroup, service *service.ServiceManager[T]) *LookupRouterGroup[T] + func (lrg *LookupRouterGroup[T]) HandleCount(c *gin.Context) + func (lrg *LookupRouterGroup[T]) HandleGetByKey(c *gin.Context) + func (lrg *LookupRouterGroup[T]) HandleInvalidate(c *gin.Context) + func (lrg *LookupRouterGroup[T]) HandleLookup(c *gin.Context) + func (lrg *LookupRouterGroup[T]) RegisterRoutes(basePath string) + func (lrg *LookupRouterGroup[T]) SetCacheAsideConfig(ttl time.Duration, refreshOnHit bool) *LookupRouterGroup[T] + func (lrg *LookupRouterGroup[T]) SetCustomFilter(filterFunc func(context.Context, *redis.Client, []string) ([]string, error)) *LookupRouterGroup[T] + func (lrg *LookupRouterGroup[T]) SetDefaults(keyPattern string, cacheExpire time.Duration) *LookupRouterGroup[T] + func (lrg *LookupRouterGroup[T]) SetKeyBuilder(builder func(uint) string) *LookupRouterGroup[T] + type PaginatedQueryMethod struct + FilterFunc func(*gorm.DB) *gorm.DB + Name string + Order string + OrderBy string + PageSize int + Service *service.ServiceManager[T] + func (m *PaginatedQueryMethod[T]) Execute(ctx context.Context, page int, filters []filter_translator.GormFilter) (*service.QueryResult[T], error) + type QueryMethodRegistry struct + func NewQueryMethodRegistry[T any]() *QueryMethodRegistry[T] + func (r *QueryMethodRegistry[T]) Get(name string) (*PaginatedQueryMethod[T], bool) + func (r *QueryMethodRegistry[T]) Register(method *PaginatedQueryMethod[T]) + type QueryRequest struct + Filters []filter_translator.FilterParam + Method string + Page int + type QueryResponse struct + Code int + Data []T + Message string + Page int + PageSize int + Total int64 + TotalPages int + type QueryRouterGroup struct + MethodRegistry *QueryMethodRegistry[T] + RouterGroup *gin.RouterGroup + Service *service.ServiceManager[T] + TranslatorRegistry *filter_translator.GormTranslatorRegistry + func NewQueryRouterGroup[T any](rg *gin.RouterGroup, service *service.ServiceManager[T]) *QueryRouterGroup[T] + func (qrg *QueryRouterGroup[T]) HandleCount(c *gin.Context) + func (qrg *QueryRouterGroup[T]) HandleGetByID(c *gin.Context) + func (qrg *QueryRouterGroup[T]) HandleQuery(c *gin.Context) + func (qrg *QueryRouterGroup[T]) RegisterActiveListMethod(pageSize int) + func (qrg *QueryRouterGroup[T]) RegisterCommonMethods(defaultPageSize int) + func (qrg *QueryRouterGroup[T]) RegisterListMethod(pageSize int) + func (qrg *QueryRouterGroup[T]) RegisterMethod(name string, pageSize int, filterFunc func(*gorm.DB) *gorm.DB, orderBy string, ...) + func (qrg *QueryRouterGroup[T]) RegisterRoutes(basePath string) + func (qrg *QueryRouterGroup[T]) RegisterSearchMethod(pageSize int, searchFields []string) + type RefreshCacheRequest struct + Expiration int64 + ID interface{} + Key string + type SetQueryRequest struct + BatchSize int + Data []T + InvalidateCache bool + OnConflictUpdate bool + type SetSingleRequest struct + Data *T + InvalidateCache bool + OnConflictUpdate bool + type UpdateRequest struct + ID interface{} + Updates map[string]interface{} + type UpsertRequest struct + ConflictColumns []string + Data *T + UpdateColumns []string + type WarmupCacheRequest struct + Expiration int64 + KeyTemplate string + Limit int + OrderBy string + type WriteResponse struct + Code int + Message string + RowsAffected int64 + type WriteRouterGroup struct + RouterGroup *gin.RouterGroup + Service *service.ServiceManager[T] + func NewWriteRouterGroup[T any](rg *gin.RouterGroup, service *service.ServiceManager[T]) *WriteRouterGroup[T] + func (wrg *WriteRouterGroup[T]) HandleBatchDelete(c *gin.Context) + func (wrg *WriteRouterGroup[T]) HandleBatchIncrement(c *gin.Context) + func (wrg *WriteRouterGroup[T]) HandleBatchInsert(c *gin.Context) + func (wrg *WriteRouterGroup[T]) HandleBatchUpdate(c *gin.Context) + func (wrg *WriteRouterGroup[T]) HandleBatchUpsert(c *gin.Context) + func (wrg *WriteRouterGroup[T]) HandleDelete(c *gin.Context) + func (wrg *WriteRouterGroup[T]) HandleIncrement(c *gin.Context) + func (wrg *WriteRouterGroup[T]) HandleInsert(c *gin.Context) + func (wrg *WriteRouterGroup[T]) HandleSetQuery(c *gin.Context) + func (wrg *WriteRouterGroup[T]) HandleSetSingle(c *gin.Context) + func (wrg *WriteRouterGroup[T]) HandleUpdate(c *gin.Context) + func (wrg *WriteRouterGroup[T]) HandleUpsert(c *gin.Context) + func (wrg *WriteRouterGroup[T]) RegisterRoutes(basePath string) + type WritedownQueryRequest struct + BatchSize int + Data []T + Expiration int64 + IDs []interface{} + Incremental bool + KeyTemplate string + LoadAll bool + Overwrite bool + UsePipeline bool + type WritedownResponse struct + Code int + Data *T + ItemsWritten int + Message string + type WritedownRouterConfig struct + KeyBuilder cache_key_builder.KeyBuilder[T] + type WritedownRouterGroup struct + KeyBuilder cache_key_builder.KeyBuilder[T] + RouterGroup *gin.RouterGroup + Service *service.ServiceManager[T] + func NewWritedownRouterGroup[T any](rg *gin.RouterGroup, svc *service.ServiceManager[T], ...) *WritedownRouterGroup[T] + func (wdg *WritedownRouterGroup[T]) HandleRefreshCache(c *gin.Context) + func (wdg *WritedownRouterGroup[T]) HandleWarmupCache(c *gin.Context) + func (wdg *WritedownRouterGroup[T]) HandleWritedownQuery(c *gin.Context) + func (wdg *WritedownRouterGroup[T]) HandleWritedownSingle(c *gin.Context) + func (wdg *WritedownRouterGroup[T]) HandleWritedownWithLock(c *gin.Context) + func (wdg *WritedownRouterGroup[T]) HandleWritedownWithVersion(c *gin.Context) + func (wdg *WritedownRouterGroup[T]) RegisterRoutes(basePath string) + func (wdg *WritedownRouterGroup[T]) SetKeyBuilder(builder cache_key_builder.KeyBuilder[T]) + type WritedownSingleRequest struct + Async bool + Data *T + ExpirationSeconds int64 + ID interface{} + Key string + NX bool + Overwrite bool + XX bool + type WritedownWithLockRequest struct + Expiration int64 + ID interface{} + Key string + LockTimeout int64 + type WritedownWithVersionRequest struct + Data *T + Expiration int64 + Key string + Version int64