beeorm

Jul 5, 2023

Changes in this version

type Engine

+ DisableReadOnly func(entity Entity) Entity

+ ReadByID func(id uint64, schema TableSchema) (entity Entity)

+ ReadByIDs func(ids []uint64, entities interface{}, references ...string) (found bool)

Feb 10, 2023

Changes in this version

type BackgroundConsumer

+ func (r *BackgroundConsumer) SetBlockTime(ttl time.Duration)

type EventsConsumer

+ SetBlockTime func(ttl time.Duration)

Jan 23, 2023

Changes in this version

type Entity

+ IsToDelete func() bool

type Flusher

+ CancelDelete func(entity ...Entity) Flusher

type ORM

+ func (orm *ORM) IsToDelete() bool

Dec 29, 2022

Changes in this version

+ const BackgroundConsumerGroupName

type BackgroundConsumer

+ func (b *BackgroundConsumer) DisableBlockMode()

+ func (r *BackgroundConsumer) RegisterLazyFlushQueryErrorResolver(resolver LazyFlushQueryErrorResolver)

type EventsConsumer

+ DisableBlockMode func()

+ type LazyFlushQueryErrorResolver func(engine Engine, db *DB, sql string, queryError *mysql.MySQLError) error

Dec 28, 2022

Changes in this version

+ type EntityLog struct

+ Before map[string]interface{}

+ Changes map[string]interface{}

+ Date time.Time

+ EntityID uint64

+ LogID uint64

+ Meta map[string]interface{}

type EventBroker

+ GetStreamGroupStatistics func(stream, group string) *RedisStreamGroupStatistics

+ GetStreamStatistics func(stream string) *RedisStreamStatistics

+ GetStreamsStatistics func(stream ...string) []*RedisStreamStatistics

type Pager

+ func (pager *Pager) String() string

+ type RedisStreamConsumerStatistics struct

+ Name string

+ Pending uint64

+ type RedisStreamGroupStatistics struct

+ Consumers []*RedisStreamConsumerStatistics

+ Group string

+ Lag int64

+ LastDeliveredDuration time.Duration

+ LastDeliveredID string

+ LowerDuration time.Duration

+ LowerID string

+ Pending uint64

+ type RedisStreamStatistics struct

+ Groups []*RedisStreamGroupStatistics

+ Len uint64

+ OldestEventSeconds int

+ RedisPool string

+ Stream string

type TableSchema

+ GetEntityLogs func(engine Engine, entityID uint64, pager *Pager, where *Where) []EntityLog

Dec 23, 2022

Changes in this version

type Where

+ func (where *Where) ShowFakeDeleted() *Where

Dec 7, 2022

Changes in this version

+ func SetUUIDServerID(id uint16)

Nov 14, 2022

Changes in this version

type Entity

+ Clone func() Entity

type ORM

+ func (orm *ORM) Clone() Entity

Nov 9, 2022

Changes in this version

type Registry

+ func (r *Registry) RegisterRedisSentinelWithOptions(namespace string, opts redis.FailoverOptions, db int, sentinels []string, ...)

May 31, 2024

Changes in this version

type RedisSearchQuery

+ func (q *RedisSearchQuery) AppendQueryRawAfterFilters(query string) *RedisSearchQuery

May 27, 2024

Changes in this version

type RedisSearch

+ func (r *RedisSearch) ForceReindexWithoutDrop(index string)

May 19, 2023

Changes in this version

type RedisCache

+ func (r *RedisCache) ZRangeArgs(args redis.ZRangeArgs) []string

+ func (r *RedisCache) ZRangeArgsWithScores(args redis.ZRangeArgs) []redis.Z

Mar 28, 2023

Changes in this version

type RedisCache

+ func (r *RedisCache) ZRemRangeByRank(key string, start, stop int64) int64

Jul 25, 2022

Changes in this version

type TableSchema

+ GetUniqueIndexes func() map[string][]string

Jul 25, 2022

Changes in this version

type Engine

+ func (e *Engine) FlushWithFullCheck(entity ...Entity) error

Jul 4, 2022

Changes in this version

type BackgroundConsumer

+ func (r *BackgroundConsumer) SetLazyFlushWorkers(workers int)

Jun 30, 2022

Changes in this version

type BackgroundConsumer

+ func (r *BackgroundConsumer) GetLazyFlushEventsSample(count int64) []string

Jun 27, 2022

Changes in this version

type Engine

+ func (e *Engine) SetQueryTimeLimit(seconds int)

Apr 19, 2022

Changes in this version

+ const AsyncConsumerGroupName

+ const LazyChannelName

+ const LogChannelName

+ const RedisSearchIndexerChannelName

+ const RedisStreamGarbageCollectorChannelName

Apr 19, 2022

Changes in this version

type Registry

+ func (r *Registry) RegisterRedisSentinelWithCredentials(masterName, namespace, user, password string, db int, sentinels []string, ...)

+ func (r *Registry) RegisterRedisWithCredentials(address, namespace, user, password string, db int, code ...string)

Mar 22, 2022

Changes in this version

+ type LoadFields struct

+ func (lf LoadFields) AddField(field string)

+ func (lf LoadFields) AddFieldWithAlias(field, alias string)

type RedisSearchAggregate

+ func (a *RedisSearchAggregate) Load(fields LoadFields) *RedisSearchAggregate

+ func (a *RedisSearchAggregate) LoadAll() *RedisSearchAggregate

Mar 18, 2022

Changes in this version

type RedisSearch

+ func (r *RedisSearch) SearchCount(index string, query *RedisSearchQuery) uint64

Feb 24, 2022

Changes in this version

type RedisCache

+ func (r *RedisCache) ScriptExists(sha1 string) bool

Feb 17, 2022

Changes in this version

type ValidatedRegistry

+ GetTableSchemaForCachePrefix func(cachePrefix string) TableSchema

Dec 8, 2021

Changes in this version

type Registry

+ func (r *Registry) ForceEntityLogInAllEntities(dbPool string)

Nov 25, 2021

Changes in this version

type Engine

+ func (e *Engine) SearchWithFakeDeleted(where *Where, pager *Pager, entities interface{}, references ...string)

Oct 4, 2021

Changes in this version

type Registry

+ func (r *Registry) SetDefaultCollate(collate string)

Sep 24, 2021

Changes in this version

+ func DisableCacheHashCheck()

Sep 22, 2021

Changes in this version

type RedisPoolConfig

+ GetNamespace func() string

+ HasNamespace func() bool

Sep 13, 2021

Changes in this version

type RedisSearchIndexPusher

+ SetBool func(key string, value bool)

Sep 1, 2021

Changes in this version

type LocalCache

+ func (c *LocalCache) GetObjectsCount() int

Aug 31, 2021

Changes in this version

type RedisCache

+ func (r *RedisCache) IncrWithExpire(key string, expire time.Duration) int64

Aug 31, 2021

Changes in this version

type RedisSearchQuery

+ func (q *RedisSearchQuery) WithFakeDeleteRows() *RedisSearchQuery

Aug 31, 2021

Changes in this version

type RedisSearchQuery

+ func (q *RedisSearchQuery) FilterManyReferenceIn(field string, id ...uint64) *RedisSearchQuery

+ func (q *RedisSearchQuery) FilterManyReferenceNotIn(field string, id ...uint64) *RedisSearchQuery

Aug 30, 2021

Changes in this version

+ 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 Engine

+ func (e *Engine) RedisSearchAggregate(entity Entity, query *RedisSearchAggregate, pager *Pager) (result []map[string]string, totalRows uint64)

type RedisSearch

+ func (r *RedisSearch) Aggregate(index string, query *RedisSearchAggregate, pager *Pager) (result []map[string]string, totalRows uint64)

+ 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) Sort(fields ...RedisSearchAggregateSort) *RedisSearchAggregate

+ type RedisSearchAggregateSort struct

+ Desc bool

+ Field string

type RedisSearchQuery

+ func (q *RedisSearchQuery) Aggregate() *RedisSearchAggregate

Aug 24, 2021

Changes in this version

type RedisSearchQuery

+ func (q *RedisSearchQuery) QueryFieldPrefixMatch(field string, value ...string) *RedisSearchQuery

Aug 17, 2021

Changes in this version

type RedisSearchIndexPusher

+ SetIntNil func(key string)

Aug 11, 2021

Changes in this version

type BackgroundConsumer

+ func (b *BackgroundConsumer) Shutdown(timeout time.Duration)

type EventsConsumer

+ Shutdown func(timeout time.Duration)

type RedisCache

+ func (r *RedisCache) HSetNx(key, field string, value interface{}) bool

type RedisSearchQuery

+ func (q *RedisSearchQuery) FilterStringStartsWith(field string, value ...string) *RedisSearchQuery

Jul 30, 2021

Changes in this version

type Engine

+ func (e *Engine) ReadByte() (byte, error)

Jul 26, 2021

Changes in this version

type Engine

+ func (e *Engine) EnableQueryDebugCustom(mysql, redis, local bool)

type EventsConsumer

+ Claim func(from, to int)

+ ConsumeMany func(nr, count int, handler EventConsumerHandler) bool

Jul 22, 2021

Changes in this version

+ const RedisSearchNullNumber

+ func EscapeRedisSearchString(val string) string

+ 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 (b *BackgroundConsumer) SetErrorHandler(handler ConsumerErrorHandler)

+ func (b *BackgroundConsumer) SetLimit(limit int)

+ func (r *BackgroundConsumer) Digest()

+ type Bind map[string]interface

+ type CachedQuery struct

+ type ConsumerErrorHandler func(err error, event Event)

+ 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) CachedSearchLazy(entities interface{}, indexName string, pager *Pager, arguments ...interface{}) (totalRows int)

+ func (e *Engine) CachedSearchOne(entity Entity, indexName string, arguments ...interface{}) (found bool)

+ func (e *Engine) CachedSearchOneLazy(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) CachedSearchOneWithReferencesLazy(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) CachedSearchWithReferencesLazy(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(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) ForceDelete(entity Entity)

+ func (e *Engine) ForceDeleteMany(entities ...Entity)

+ func (e *Engine) GetAlters() (alters []Alter)

+ func (e *Engine) GetContext() context.Context

+ 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) LoadByIDLazy(id uint64, entity Entity, references ...string) (found bool)

+ func (e *Engine) LoadByIDs(ids []uint64, entities interface{}, references ...string)

+ func (e *Engine) LoadByIDsLazy(ids []uint64, entities interface{}, references ...string)

+ func (e *Engine) LoadLazy(entity Entity, references ...string)

+ 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) RedisSearchCount(entity Entity, query *RedisSearchQuery) (totalRows uint64)

+ func (e *Engine) RedisSearchIds(entity Entity, query *RedisSearchQuery, pager *Pager) (ids []uint64, totalRows uint64)

+ func (e *Engine) RedisSearchLazy(entities interface{}, query *RedisSearchQuery, pager *Pager, ...) (totalRows uint64)

+ func (e *Engine) RedisSearchOne(entity Entity, query *RedisSearchQuery, references ...string) (found bool)

+ func (e *Engine) RedisSearchOneLazy(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) SearchLazy(where *Where, pager *Pager, entities interface{}, references ...string)

+ func (e *Engine) SearchOne(where *Where, entity Entity, references ...string) (found bool)

+ func (e *Engine) SearchOneLazy(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) SearchWithCountLazy(where *Where, pager *Pager, entities interface{}, references ...string) (totalRows int)

+ func (e *Engine) SetLogMetaData(key string, value interface{})

+ type Entity interface

+ Fill func(engine *Engine)

+ GetDirtyBind func(engine *Engine) (bind Bind, has bool)

+ GetFieldLazy func(engine *Engine, field string) interface{}

+ GetID func() uint64

+ IsDirty func(engine *Engine) bool

+ IsLazy 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

+ Consume func(count int, handler EventConsumerHandler)

+ DisableLoop func()

+ SetErrorHandler func(handler ConsumerErrorHandler)

+ SetLimit func(limit int)

+ type ExecResult interface

+ LastInsertId func() uint64

+ RowsAffected func() uint64

+ type Flusher interface

+ Clear func()

+ Delete func(entity ...Entity) Flusher

+ Flush func()

+ FlushInTransaction func()

+ FlushInTransactionWithCheck func() error

+ 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 LocalCache struct

+ func (c *LocalCache) Clear()

+ func (c *LocalCache) Get(key string) (value interface{}, ok bool)

+ func (c *LocalCache) GetPoolConfig() LocalCachePoolConfig

+ func (c *LocalCache) GetSet(key string, ttl time.Duration, provider func() interface{}) interface{}

+ func (c *LocalCache) HMGet(key string, fields ...string) map[string]interface{}

+ func (c *LocalCache) HMSet(key string, fields map[string]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) Fill(engine *Engine)

+ func (orm *ORM) GetDirtyBind(engine *Engine) (bind Bind, has bool)

+ func (orm *ORM) GetFieldLazy(engine *Engine, field string) interface{}

+ func (orm *ORM) GetID() uint64

+ func (orm *ORM) IsDirty(engine *Engine) bool

+ func (orm *ORM) IsLazy() 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{}) interface{}

+ 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) Incr(key string) int64

+ func (r *RedisCache) IncrBy(key string, incr int64) 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) 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) 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) 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(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) ZRangeWithScores(key string, start, stop int64) []redis.Z

+ 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

+ type RedisSearch struct

+ func (r *RedisSearch) ForceReindex(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) 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 RedisSearchIndex struct

+ DefaultLanguage string

+ DefaultScore float64

+ Fields []RedisSearchIndexField

+ Filter string

+ Indexer RedisSearchIndexerFunc

+ LanguageField string

+ MaxTextFields bool

+ Name string

+ NoFields bool

+ NoFreqs bool

+ NoNHL bool

+ NoOffsets bool

+ PayloadField string

+ Prefixes []string

+ RedisPool string

+ ScoreField string

+ SkipInitialScan bool

+ StopWords []string

+ Temporary int

+ 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

+ Filter string

+ KeyType string

+ LanguageField string

+ PayloadField 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()

+ SetFloat func(key string, value float64)

+ SetGeo func(key string, lon float64, lat float64)

+ SetInt func(key string, value int64)

+ 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) AppendQueryRaw(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) 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) 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) WithPayLoads() *RedisSearchQuery

+ func (q *RedisSearchQuery) WithScores() *RedisSearchQuery

+ type RedisSearchResult struct

+ ExplainScore []interface{}

+ Fields []interface{}

+ Key string

+ PayLoad string

+ Score float64

+ func (r *RedisSearchResult) Value(field string) interface{}

+ type Registry struct

+ func NewRegistry() *Registry

+ 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 string, db int, code ...string)

+ func (r *Registry) RegisterRedisSearchIndex(index ...*RedisSearchIndex)

+ func (r *Registry) RegisterRedisSentinel(masterName string, db int, sentinels []string, code ...string)

+ func (r *Registry) RegisterRedisStream(name string, redisPool string, groups []string)

+ func (r *Registry) SetDefaultEncoding(encoding string)

+ func (r *Registry) Validate(ctx context.Context) (ValidatedRegistry, 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

+ 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(ctx context.Context) *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

+ 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