Versions in this module Expand all Collapse all v1 v1.0.0 Feb 26, 2026 Changes in this version + const AsyncConsumerGroupName + const LazyChannelName + const LogChannelName + const RedisSearchIndexerChannelName + const RedisSearchNullNumber + const RedisStreamGarbageCollectorChannelName + func DisableCacheHashCheck() + func EscapeRedisSearchString(val string) string + type AggregateReduce struct + func NewAggregateReduceAvg(property, alias string) AggregateReduce + func NewAggregateReduceCount(alias string) AggregateReduce + func NewAggregateReduceCountDistinct(property, alias string, distinctish bool) AggregateReduce + func NewAggregateReduceFirstValue(property, alias string) AggregateReduce + func NewAggregateReduceFirstValueBy(property, byProperty, alias string, desc bool) AggregateReduce + func NewAggregateReduceMax(property, alias string) AggregateReduce + func NewAggregateReduceMin(property, alias string) AggregateReduce + func NewAggregateReduceQuantile(property, quantile, alias string) AggregateReduce + func NewAggregateReduceRandomSample(property, alias string, size ...int) AggregateReduce + func NewAggregateReduceStdDev(property, alias string) AggregateReduce + func NewAggregateReduceSum(property, alias string) AggregateReduce + func NewAggregateReduceToList(property, alias string) AggregateReduce + type Alter struct + Pool string + SQL string + Safe bool + func (a Alter) Exec() + type BackgroundConsumer struct + func NewBackgroundConsumer(engine *Engine) *BackgroundConsumer + func (b *BackgroundConsumer) DisableLoop() + func (r *BackgroundConsumer) Digest(ctx context.Context) bool + func (r *BackgroundConsumer) GetLazyFlushEventsSample(count int64) []string + func (r *BackgroundConsumer) SetLazyFlushWorkers(workers int) + type Bind map[string]interface + type CachedQuery struct + type DB struct + func (db *DB) Begin() + func (db *DB) Commit() + func (db *DB) Exec(query string, args ...interface{}) ExecResult + func (db *DB) GetPoolConfig() MySQLPoolConfig + func (db *DB) IsInTransaction() bool + func (db *DB) Query(query string, args ...interface{}) (rows Rows, close func()) + func (db *DB) QueryRow(query *Where, toFill ...interface{}) (found bool) + func (db *DB) Rollback() + type DirtyEntityEvent interface + Added func() bool + Deleted func() bool + ID func() uint64 + TableSchema func() TableSchema + Updated func() bool + func EventDirtyEntity(e Event) DirtyEntityEvent + type DuplicatedKeyError struct + Index string + Message string + func (err *DuplicatedKeyError) Error() string + type Engine struct + func (e *Engine) CachedSearch(entities interface{}, indexName string, pager *Pager, arguments ...interface{}) (totalRows int) + func (e *Engine) CachedSearchCount(entity Entity, indexName string, arguments ...interface{}) int + func (e *Engine) CachedSearchIDs(entity Entity, indexName string, pager *Pager, arguments ...interface{}) (totalRows int, ids []uint64) + func (e *Engine) CachedSearchOne(entity Entity, indexName string, arguments ...interface{}) (found bool) + func (e *Engine) CachedSearchOneWithReferences(entity Entity, indexName string, arguments []interface{}, references []string) (found bool) + func (e *Engine) CachedSearchWithReferences(entities interface{}, indexName string, pager *Pager, arguments []interface{}, ...) (totalRows int) + func (e *Engine) ClearCacheByIDs(entity Entity, ids ...uint64) + func (e *Engine) Clone() *Engine + func (e *Engine) Delete(entity Entity) + func (e *Engine) DeleteLazy(entity Entity) + func (e *Engine) DeleteMany(entities ...Entity) + func (e *Engine) EnableQueryDebug() + func (e *Engine) EnableQueryDebugCustom(mysql, redis, local bool) + func (e *Engine) EnableRequestCache() + func (e *Engine) Flush(entity Entity) + func (e *Engine) FlushLazy(entity Entity) + func (e *Engine) FlushLazyMany(entities ...Entity) + func (e *Engine) FlushMany(entities ...Entity) + func (e *Engine) FlushWithCheck(entity ...Entity) error + func (e *Engine) FlushWithFullCheck(entity ...Entity) error + func (e *Engine) ForceDelete(entity Entity) + func (e *Engine) ForceDeleteMany(entities ...Entity) + func (e *Engine) GetAlters() (alters []Alter) + func (e *Engine) GetEventBroker() EventBroker + func (e *Engine) GetLocalCache(code ...string) *LocalCache + func (e *Engine) GetMysql(code ...string) *DB + func (e *Engine) GetRedis(code ...string) *RedisCache + func (e *Engine) GetRedisSearch(code ...string) *RedisSearch + func (e *Engine) GetRedisSearchIndexAlters() (alters []RedisSearchIndexAlter) + func (e *Engine) GetRegistry() ValidatedRegistry + func (e *Engine) Load(entity Entity, references ...string) (found bool) + func (e *Engine) LoadByID(id uint64, entity Entity, references ...string) (found bool) + func (e *Engine) LoadByIDs(ids []uint64, entities interface{}, references ...string) (found bool) + func (e *Engine) MarkDirty(entity Entity, queueCode string, ids ...uint64) + func (e *Engine) NewFlusher() Flusher + func (e *Engine) NewRedisSearchIndexPusher(pool string) RedisSearchIndexPusher + func (e *Engine) RedisSearch(entities interface{}, query *RedisSearchQuery, pager *Pager, ...) (totalRows uint64) + func (e *Engine) RedisSearchAggregate(entity Entity, query *RedisSearchAggregate, pager *Pager) (result []map[string]string, totalRows uint64) + func (e *Engine) RedisSearchCount(entity Entity, query *RedisSearchQuery) (totalRows uint64) + func (e *Engine) RedisSearchIds(entity Entity, query *RedisSearchQuery, pager *Pager) (ids []uint64, totalRows uint64) + func (e *Engine) RedisSearchOne(entity Entity, query *RedisSearchQuery, references ...string) (found bool) + func (e *Engine) RegisterQueryLogger(handler LogHandler, mysql, redis, local bool) + func (e *Engine) Search(where *Where, pager *Pager, entities interface{}, references ...string) + func (e *Engine) SearchIDs(where *Where, pager *Pager, entity Entity) []uint64 + func (e *Engine) SearchIDsWithCount(where *Where, pager *Pager, entity Entity) (results []uint64, totalRows int) + func (e *Engine) SearchOne(where *Where, entity Entity, references ...string) (found bool) + func (e *Engine) SearchWithCount(where *Where, pager *Pager, entities interface{}, references ...string) (totalRows int) + func (e *Engine) SearchWithFakeDeleted(where *Where, pager *Pager, entities interface{}, references ...string) + func (e *Engine) SetLogMetaData(key string, value interface{}) + func (e *Engine) SetQueryTimeLimit(seconds int) + type Entity interface + GetDirtyBind func() (bind Bind, has bool) + GetID func() uint64 + IsDirty func() bool + IsLoaded func() bool + SetEntityLogMeta func(key string, value interface{}) + SetField func(field string, value interface{}) error + SetOnDuplicateKeyUpdate func(bind Bind) + type Enum interface + GetDefault func() string + GetFields func() []string + Has func(value string) bool + Index func(value string) int + type Event interface + Ack func() + ID func() string + Stream func() string + Tag func(key string) (value string) + Unserialize func(val interface{}) + type EventBroker interface + Consumer func(group string) EventsConsumer + NewFlusher func() EventFlusher + Publish func(stream string, body interface{}, meta ...string) (id string) + type EventConsumerHandler func([]Event) + type EventFlusher interface + Flush func() + Publish func(stream string, body interface{}, meta ...string) + type EventsConsumer interface + Claim func(from, to int) + Consume func(ctx context.Context, count int, handler EventConsumerHandler) bool + ConsumeMany func(ctx context.Context, nr, count int, handler EventConsumerHandler) bool + DisableLoop func() + type ExecResult interface + LastInsertId func() uint64 + RowsAffected func() uint64 + type Flusher interface + Clear func() + Delete func(entity ...Entity) Flusher + Flush func() + FlushLazy func() + FlushWithCheck func() error + FlushWithFullCheck func() error + ForceDelete func(entity ...Entity) Flusher + Track func(entity ...Entity) Flusher + type ForeignKeyError struct + Constraint string + Message string + func (err *ForeignKeyError) Error() string + type LoadFields struct + func (lf *LoadFields) AddField(field string) + func (lf *LoadFields) AddFieldWithAlias(field, alias string) + type LocalCache struct + func (c *LocalCache) Clear() + func (c *LocalCache) Get(key string) (value interface{}, ok bool) + func (c *LocalCache) GetObjectsCount() int + func (c *LocalCache) GetPoolConfig() LocalCachePoolConfig + func (c *LocalCache) GetSet(key string, ttl time.Duration, provider func() interface{}) interface{} + func (c *LocalCache) MGet(keys ...string) []interface{} + func (c *LocalCache) MSet(pairs ...interface{}) + func (c *LocalCache) Remove(keys ...string) + func (c *LocalCache) Set(key string, value interface{}) + type LocalCachePoolConfig interface + GetCode func() string + GetLimit func() int + type Lock struct + func (l *Lock) Refresh(ttl time.Duration) bool + func (l *Lock) Release() + func (l *Lock) TTL() time.Duration + type Locker struct + func (l *Locker) Obtain(key string, ttl time.Duration, waitTimeout time.Duration) (lock *Lock, obtained bool) + type LogHandler interface + Handle func(log map[string]interface{}) + type LogQueueValue struct + Before map[string]interface{} + Changes map[string]interface{} + ID uint64 + LogID uint64 + Meta map[string]interface{} + PoolName string + TableName string + Updated time.Time + type MySQLPoolConfig interface + GetCode func() string + GetDataSourceURI func() string + GetDatabase func() string + GetVersion func() int + type ORM struct + func (orm *ORM) GetDirtyBind() (bind Bind, has bool) + func (orm *ORM) GetID() uint64 + func (orm *ORM) IsDirty() bool + func (orm *ORM) IsLoaded() bool + func (orm *ORM) SetEntityLogMeta(key string, value interface{}) + func (orm *ORM) SetField(field string, value interface{}) error + func (orm *ORM) SetOnDuplicateKeyUpdate(bind Bind) + type Pager struct + CurrentPage int + PageSize int + func NewPager(currentPage, pageSize int) *Pager + func (pager *Pager) GetCurrentPage() int + func (pager *Pager) GetPageSize() int + func (pager *Pager) IncrementPage() + type PipeLineBool struct + func (c *PipeLineBool) Result() bool + type PipeLineGet struct + func (c *PipeLineGet) Result() (value string, has bool) + type PipeLineInt struct + func (c *PipeLineInt) Result() int64 + type PipeLineString struct + func (c *PipeLineString) Result() string + type QueryLoggerSource int + type RedisCache struct + func (r *RedisCache) Del(keys ...string) + func (r *RedisCache) Eval(script string, keys []string, args ...interface{}) interface{} + func (r *RedisCache) EvalSha(sha1 string, keys []string, args ...interface{}) (res interface{}, exists bool) + func (r *RedisCache) Exists(keys ...string) int64 + func (r *RedisCache) Expire(key string, expiration time.Duration) bool + func (r *RedisCache) FlushAll() + func (r *RedisCache) FlushDB() + func (r *RedisCache) Get(key string) (value string, has bool) + func (r *RedisCache) GetLocker() *Locker + func (r *RedisCache) GetPoolConfig() RedisPoolConfig + func (r *RedisCache) GetSet(key string, ttlSeconds int, provider func() interface{}) interface{} + func (r *RedisCache) HDel(key string, fields ...string) + func (r *RedisCache) HGet(key, field string) (value string, has bool) + func (r *RedisCache) HGetAll(key string) map[string]string + func (r *RedisCache) HIncrBy(key, field string, incr int64) int64 + func (r *RedisCache) HLen(key string) int64 + func (r *RedisCache) HMGet(key string, fields ...string) map[string]interface{} + func (r *RedisCache) HSet(key string, values ...interface{}) + func (r *RedisCache) HSetNx(key, field string, value interface{}) bool + func (r *RedisCache) Incr(key string) int64 + func (r *RedisCache) IncrBy(key string, incr int64) int64 + func (r *RedisCache) IncrWithExpire(key string, expire time.Duration) int64 + func (r *RedisCache) Info(section ...string) string + func (r *RedisCache) LLen(key string) int64 + func (r *RedisCache) LPush(key string, values ...interface{}) int64 + func (r *RedisCache) LRange(key string, start, stop int64) []string + func (r *RedisCache) LRem(key string, count int64, value interface{}) + func (r *RedisCache) LSet(key string, index int64, value interface{}) + func (r *RedisCache) Ltrim(key string, start, stop int64) + func (r *RedisCache) MGet(keys ...string) []interface{} + func (r *RedisCache) MSet(pairs ...interface{}) + func (r *RedisCache) PipeLine() *RedisPipeLine + func (r *RedisCache) Publish(channel string, message interface{}) int64 + func (r *RedisCache) RPop(key string) (value string, found bool) + func (r *RedisCache) RPush(key string, values ...interface{}) int64 + func (r *RedisCache) RateLimit(key string, period time.Duration, limit int) bool + func (r *RedisCache) SAdd(key string, members ...interface{}) int64 + func (r *RedisCache) SCard(key string) int64 + func (r *RedisCache) SPop(key string) (string, bool) + func (r *RedisCache) SPopN(key string, max int64) []string + func (r *RedisCache) ScriptExists(sha1 string) bool + func (r *RedisCache) ScriptLoad(script string) string + func (r *RedisCache) Set(key string, value interface{}, ttlSeconds int) + func (r *RedisCache) SetNX(key string, value interface{}, ttlSeconds int) bool + func (r *RedisCache) Subscribe(channels ...string) *redis.PubSub + func (r *RedisCache) Type(key string) string + func (r *RedisCache) XAck(stream, group string, ids ...string) int64 + func (r *RedisCache) XClaim(a *redis.XClaimArgs) []redis.XMessage + func (r *RedisCache) XClaimJustID(a *redis.XClaimArgs) []string + func (r *RedisCache) XDel(stream string, ids ...string) int64 + func (r *RedisCache) XGroupCreate(stream, group, start string) (key string, exists bool) + func (r *RedisCache) XGroupCreateMkStream(stream, group, start string) (key string, exists bool) + func (r *RedisCache) XGroupDelConsumer(stream, group, consumer string) int64 + func (r *RedisCache) XGroupDestroy(stream, group string) int64 + func (r *RedisCache) XInfoGroups(stream string) []redis.XInfoGroup + func (r *RedisCache) XInfoStream(stream string) *redis.XInfoStream + func (r *RedisCache) XLen(stream string) int64 + func (r *RedisCache) XPending(stream, group string) *redis.XPending + func (r *RedisCache) XPendingExt(a *redis.XPendingExtArgs) []redis.XPendingExt + func (r *RedisCache) XRange(stream, start, stop string, count int64) []redis.XMessage + func (r *RedisCache) XRead(a *redis.XReadArgs) []redis.XStream + func (r *RedisCache) XReadGroup(ctx context.Context, a *redis.XReadGroupArgs) (streams []redis.XStream) + func (r *RedisCache) XRevRange(stream, start, stop string, count int64) []redis.XMessage + func (r *RedisCache) XTrim(stream string, maxLen int64) (deleted int64) + func (r *RedisCache) ZAdd(key string, members ...*redis.Z) int64 + func (r *RedisCache) ZCard(key string) int64 + func (r *RedisCache) ZCount(key string, min, max string) int64 + func (r *RedisCache) ZRangeArgs(args redis.ZRangeArgs) []string + func (r *RedisCache) ZRangeArgsWithScores(args redis.ZRangeArgs) []redis.Z + func (r *RedisCache) ZRangeWithScores(key string, start, stop int64) []redis.Z + func (r *RedisCache) ZRemRangeByRank(key string, start, stop int64) int64 + func (r *RedisCache) ZRevRange(key string, start, stop int64) []string + func (r *RedisCache) ZRevRangeWithScores(key string, start, stop int64) []redis.Z + func (r *RedisCache) ZScore(key, member string) float64 + type RedisPipeLine struct + func (rp *RedisPipeLine) Del(key ...string) + func (rp *RedisPipeLine) Exec() + func (rp *RedisPipeLine) Expire(key string, expiration time.Duration) *PipeLineBool + func (rp *RedisPipeLine) Get(key string) *PipeLineGet + func (rp *RedisPipeLine) HDel(key string, values ...string) + func (rp *RedisPipeLine) HIncrBy(key, field string, incr int64) *PipeLineInt + func (rp *RedisPipeLine) HSet(key string, values ...interface{}) + func (rp *RedisPipeLine) Set(key string, value interface{}, expiration time.Duration) + func (rp *RedisPipeLine) XAdd(stream string, values []string) *PipeLineString + type RedisPoolConfig interface + GetAddress func() string + GetCode func() string + GetDatabase func() int + GetNamespace func() string + HasNamespace func() bool + type RedisSearch struct + func (r *RedisSearch) Aggregate(index string, query *RedisSearchAggregate, pager *Pager) (result []map[string]string, totalRows uint64) + func (r *RedisSearch) ForceReindex(index string) + func (r *RedisSearch) ForceReindexWithoutDrop(index string) + func (r *RedisSearch) GetPoolConfig() RedisPoolConfig + func (r *RedisSearch) Info(indexName string) *RedisSearchIndexInfo + func (r *RedisSearch) ListIndices() []string + func (r *RedisSearch) Search(index string, query *RedisSearchQuery, pager *Pager) (total uint64, rows []*RedisSearchResult) + func (r *RedisSearch) SearchCount(index string, query *RedisSearchQuery) uint64 + func (r *RedisSearch) SearchKeys(index string, query *RedisSearchQuery, pager *Pager) (total uint64, keys []string) + func (r *RedisSearch) SearchRaw(index string, query *RedisSearchQuery, pager *Pager) (total uint64, rows []interface{}) + type RedisSearchAggregate struct + func (a *RedisSearchAggregate) Apply(expression, alias string) *RedisSearchAggregate + func (a *RedisSearchAggregate) Filter(expression string) *RedisSearchAggregate + func (a *RedisSearchAggregate) GroupByField(field string, reduce ...AggregateReduce) *RedisSearchAggregate + func (a *RedisSearchAggregate) GroupByFields(fields []string, reduce ...AggregateReduce) *RedisSearchAggregate + func (a *RedisSearchAggregate) Load(fields *LoadFields) *RedisSearchAggregate + func (a *RedisSearchAggregate) LoadAll() *RedisSearchAggregate + func (a *RedisSearchAggregate) Sort(fields ...RedisSearchAggregateSort) *RedisSearchAggregate + type RedisSearchAggregateSort struct + Desc bool + Field string + type RedisSearchIndex struct + DefaultLanguage string + DefaultScore float64 + Fields []RedisSearchIndexField + Indexer RedisSearchIndexerFunc + LanguageField string + MaxTextFields bool + Name string + NoFields bool + NoFreqs bool + NoNHL bool + NoOffsets bool + Prefixes []string + RedisPool string + ScoreField string + SkipInitialScan bool + StopWords []string + func NewRedisSearchIndex(name, pool string, prefixes []string) *RedisSearchIndex + func (rs *RedisSearchIndex) AddGeoField(name string, sortable, noindex bool) + func (rs *RedisSearchIndex) AddNumericField(name string, sortable, noindex bool) + func (rs *RedisSearchIndex) AddTagField(name string, sortable, noindex bool, separator string) + func (rs *RedisSearchIndex) AddTextField(name string, weight float64, sortable, noindex, nostem bool) + type RedisSearchIndexAlter struct + Changes []string + Documents uint64 + Execute func() + Name string + Pool string + Query string + type RedisSearchIndexField struct + Name string + NoIndex bool + NoStem bool + Sortable bool + TagSeparator string + Type string + Weight float64 + type RedisSearchIndexInfo struct + BytesPerRecordAvg int + Definition RedisSearchIndexInfoDefinition + DocTableSizeMB float64 + Fields []RedisSearchIndexInfoField + HashIndexingFailures uint64 + Indexing bool + InvertedSzMB float64 + KeyTableSizeMB float64 + MaxDocID uint64 + Name string + NumDocs uint64 + NumRecords uint64 + NumTerms uint64 + OffsetBitsPerRecordAvg float64 + OffsetVectorsSzMB float64 + OffsetsPerTermAvg float64 + Options RedisSearchIndexInfoOptions + PercentIndexed float64 + RecordsPerDocAvg int + SortableValuesSizeMB float64 + StopWords []string + TotalInvertedIndexBlocks float64 + type RedisSearchIndexInfoDefinition struct + DefaultScore float64 + KeyType string + LanguageField string + Prefixes []string + ScoreField string + type RedisSearchIndexInfoField struct + Name string + NoIndex bool + NoStem bool + Sortable bool + TagSeparator string + Type string + Weight float64 + type RedisSearchIndexInfoOptions struct + MaxTextFields bool + NoFields bool + NoFreqs bool + NoOffsets bool + type RedisSearchIndexPusher interface + DeleteDocuments func(key ...string) + Flush func() + NewDocument func(key string) + PushDocument func() + SetBool func(key string, value bool) + SetFloat func(key string, value float64) + SetGeo func(key string, lon float64, lat float64) + SetInt func(key string, value int64) + SetIntNil func(key string) + SetString func(key string, value string) + SetTag func(key string, tag ...string) + SetUint func(key string, value uint64) + type RedisSearchIndexerFunc func(engine *Engine, lastID uint64, pusher RedisSearchIndexPusher) (newID uint64, hasMore bool) + type RedisSearchQuery struct + func NewRedisSearchQuery() *RedisSearchQuery + func (q *RedisSearchQuery) Aggregate() *RedisSearchAggregate + func (q *RedisSearchQuery) AppendQueryRaw(query string) *RedisSearchQuery + func (q *RedisSearchQuery) AppendQueryRawAfterFilters(query string) *RedisSearchQuery + func (q *RedisSearchQuery) ExplainScore() *RedisSearchQuery + func (q *RedisSearchQuery) FilterBool(field string, value bool) *RedisSearchQuery + func (q *RedisSearchQuery) FilterDate(field string, date time.Time) *RedisSearchQuery + func (q *RedisSearchQuery) FilterDateGreater(field string, date time.Time) *RedisSearchQuery + func (q *RedisSearchQuery) FilterDateGreaterEqual(field string, date time.Time) *RedisSearchQuery + func (q *RedisSearchQuery) FilterDateLess(field string, date time.Time) *RedisSearchQuery + func (q *RedisSearchQuery) FilterDateLessEqual(field string, date time.Time) *RedisSearchQuery + func (q *RedisSearchQuery) FilterDateMinMax(field string, min, max time.Time) *RedisSearchQuery + func (q *RedisSearchQuery) FilterDateNull(field string) *RedisSearchQuery + func (q *RedisSearchQuery) FilterDateTime(field string, date time.Time) *RedisSearchQuery + func (q *RedisSearchQuery) FilterDateTimeGreater(field string, date time.Time) *RedisSearchQuery + func (q *RedisSearchQuery) FilterDateTimeGreaterEqual(field string, date time.Time) *RedisSearchQuery + func (q *RedisSearchQuery) FilterDateTimeLess(field string, date time.Time) *RedisSearchQuery + func (q *RedisSearchQuery) FilterDateTimeLessEqual(field string, date time.Time) *RedisSearchQuery + func (q *RedisSearchQuery) FilterDateTimeMinMax(field string, min, max time.Time) *RedisSearchQuery + func (q *RedisSearchQuery) FilterDateTimeNull(field string) *RedisSearchQuery + func (q *RedisSearchQuery) FilterFloat(field string, value ...float64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterFloatGreater(field string, value float64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterFloatGreaterEqual(field string, value float64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterFloatLess(field string, value float64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterFloatLessEqual(field string, value float64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterFloatMinMax(field string, min, max float64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterFloatNull(field string) *RedisSearchQuery + func (q *RedisSearchQuery) FilterGeo(field string, lon, lat, radius float64, unit string) *RedisSearchQuery + func (q *RedisSearchQuery) FilterInt(field string, value ...int64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterIntGreater(field string, value int64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterIntGreaterEqual(field string, value int64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterIntLess(field string, value int64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterIntLessEqual(field string, value int64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterIntMinMax(field string, min, max int64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterIntNull(field string) *RedisSearchQuery + func (q *RedisSearchQuery) FilterManyReferenceIn(field string, id ...uint64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterManyReferenceNotIn(field string, id ...uint64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterNotDate(field string, date time.Time) *RedisSearchQuery + func (q *RedisSearchQuery) FilterNotDateNull(field string) *RedisSearchQuery + func (q *RedisSearchQuery) FilterNotInt(field string, value ...int64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterNotIntNull(field string) *RedisSearchQuery + func (q *RedisSearchQuery) FilterNotString(field string, value ...string) *RedisSearchQuery + func (q *RedisSearchQuery) FilterNotTag(field string, tag ...string) *RedisSearchQuery + func (q *RedisSearchQuery) FilterString(field string, value ...string) *RedisSearchQuery + func (q *RedisSearchQuery) FilterTag(field string, tag ...string) *RedisSearchQuery + func (q *RedisSearchQuery) FilterUint(field string, value ...uint64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterUintGreater(field string, value uint64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterUintGreaterEqual(field string, value uint64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterUintLess(field string, value uint64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterUintLessEqual(field string, value uint64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterUintMinMax(field string, min, max uint64) *RedisSearchQuery + func (q *RedisSearchQuery) FilterUintNull(field string) *RedisSearchQuery + func (q *RedisSearchQuery) Highlight(field ...string) *RedisSearchQuery + func (q *RedisSearchQuery) HighlightTags(openTag, closeTag string) *RedisSearchQuery + func (q *RedisSearchQuery) InFields(field ...string) *RedisSearchQuery + func (q *RedisSearchQuery) InKeys(key ...string) *RedisSearchQuery + func (q *RedisSearchQuery) InOrder() *RedisSearchQuery + func (q *RedisSearchQuery) Lang(lang string) *RedisSearchQuery + func (q *RedisSearchQuery) NoStopWords() *RedisSearchQuery + func (q *RedisSearchQuery) Query(query string) *RedisSearchQuery + func (q *RedisSearchQuery) QueryField(field string, value ...string) *RedisSearchQuery + func (q *RedisSearchQuery) QueryFieldPrefixMatch(field string, value ...string) *RedisSearchQuery + func (q *RedisSearchQuery) QueryRaw(query string) *RedisSearchQuery + func (q *RedisSearchQuery) Return(field ...string) *RedisSearchQuery + func (q *RedisSearchQuery) Slop(slop int) *RedisSearchQuery + func (q *RedisSearchQuery) Sort(field string, desc bool) *RedisSearchQuery + func (q *RedisSearchQuery) Summarize(field ...string) *RedisSearchQuery + func (q *RedisSearchQuery) SummarizeOptions(separator string, frags, len int) *RedisSearchQuery + func (q *RedisSearchQuery) Verbatim() *RedisSearchQuery + func (q *RedisSearchQuery) WithFakeDeleteRows() *RedisSearchQuery + func (q *RedisSearchQuery) WithScores() *RedisSearchQuery + type RedisSearchResult struct + ExplainScore []interface{} + Fields []interface{} + Key string + Score float64 + func (r *RedisSearchResult) Value(field string) interface{} + type Registry struct + func NewRegistry() *Registry + func (r *Registry) ForceEntityLogInAllEntities(dbPool string) + func (r *Registry) InitByYaml(yaml map[string]interface{}) + func (r *Registry) RegisterEntity(entity ...Entity) + func (r *Registry) RegisterEnum(code string, values []string, defaultValue ...string) + func (r *Registry) RegisterEnumStruct(code string, val interface{}, defaultValue ...string) + func (r *Registry) RegisterLocalCache(size int, code ...string) + func (r *Registry) RegisterMySQLPool(dataSourceName string, code ...string) + func (r *Registry) RegisterRedis(address, namespace string, db int, code ...string) + func (r *Registry) RegisterRedisSearchIndex(index ...*RedisSearchIndex) + func (r *Registry) RegisterRedisSentinel(masterName, namespace string, db int, sentinels []string, code ...string) + func (r *Registry) RegisterRedisSentinelWithCredentials(masterName, namespace, user, password string, db int, sentinels []string, ...) + func (r *Registry) RegisterRedisStream(name string, redisPool string, groups []string) + func (r *Registry) RegisterRedisWithCredentials(address, namespace, user, password string, db int, code ...string) + func (r *Registry) SetDefaultCollate(collate string) + func (r *Registry) SetDefaultEncoding(encoding string) + func (r *Registry) Validate() (validated ValidatedRegistry, deferFunc func(), err error) + type Rows interface + Columns func() []string + Next func() bool + Scan func(dest ...interface{}) + type SQLRow interface + Scan func(dest ...interface{}) error + type SQLRows interface + Close func() error + Columns func() ([]string, error) + Err func() error + Next func() bool + Scan func(dest ...interface{}) error + type TableSchema interface + DropTable func(engine *Engine) + GetColumns func() []string + GetLocalCache func(engine *Engine) (cache *LocalCache, has bool) + GetMysql func(engine *Engine) *DB + GetRedisCache func(engine *Engine) (cache *RedisCache, has bool) + GetRedisSearch func(engine *Engine) (search *RedisSearch, has bool) + GetReferences func() []string + GetSchemaChanges func(engine *Engine) (has bool, alters []Alter) + GetTableName func() string + GetType func() reflect.Type + GetUniqueIndexes func() map[string][]string + GetUsage func(registry ValidatedRegistry) map[reflect.Type][]string + NewEntity func() Entity + ReindexRedisSearchIndex func(engine *Engine) + TruncateTable func(engine *Engine) + UpdateSchema func(engine *Engine) + UpdateSchemaAndTruncateTable func(engine *Engine) + type ValidatedRegistry interface + CreateEngine func() *Engine + GetEntities func() map[string]reflect.Type + GetEnum func(code string) Enum + GetLocalCachePools func() map[string]LocalCachePoolConfig + GetMySQLPools func() map[string]MySQLPoolConfig + GetRedisPools func() map[string]RedisPoolConfig + GetRedisSearchIndices func() map[string][]*RedisSearchIndex + GetRedisStreams func() map[string]map[string][]string + GetSourceRegistry func() *Registry + GetTableSchema func(entityName string) TableSchema + GetTableSchemaForCachePrefix func(cachePrefix string) TableSchema + GetTableSchemaForEntity func(entity Entity) TableSchema + type Where struct + func NewWhere(query string, parameters ...interface{}) *Where + func (where *Where) Append(query string, parameters ...interface{}) + func (where *Where) GetParameters() []interface{} + func (where *Where) SetParameter(index int, param interface{}) *Where + func (where *Where) SetParameters(params ...interface{}) *Where + func (where *Where) String() string
Go to main page